Plaster
New
List
Login
text
apl
aspx
asterisk
brainfuck
c
c++hdr
c++src
cassandra
ceylon
clojure
clojurescript
cmake
cobol
coffeescript
common-lisp
crystal
csharp
css
cypher-query
cython
d
dart
diff
django
dockerfile
dylan
ebnf
ecl
ecmascript
edn
eiffel
ejs
elm
erb
erlang
ez80
factor
fcl
feature
forth
fortran
fragment
gfm
go
gql
groovy
gss
haml
handlebars-template
haskell
haxe
hive
html
http
httpd-php
httpd-php-open
hxml
ini
java
javascript
json
jsp
jsx
julia
kotlin
latex
less
literate-haskell
lua
mariadb
markdown
mbox
mirc
mscgen
msgenny
mssql
mumps
mysql
n-triples
nesc
nginx-conf
nsis
objectivec
octave
oz
pascal
perl
pgp
pgp-keys
pgp-signature
pgsql
php
pig
plsql
properties
protobuf
puppet
python
q
rpm-changes
rpm-spec
rsrc
ruby
rustsrc
sas
sass
scala
scheme
scss
sieve
slim
smarty
solr
soy
sparql-query
spreadsheet
sql
squirrel
stex
styl
swift
systemverilog
tcl
textile
tiddlywiki
tiki
tlv
tornado
ttcn-asn
ttcn-cfg
turtle
twig
typescript
typescript-jsx
vb
vbscript
velocity
verilog
vertex
vhdl
vue
webidl
xml
xml-dtd
xquery
xu
yaml
z80
default
Visibility:
public
unlisted
private
static inline int bip_request_read(uint32_t *off, uint32_t *size, struct bip *buffer){ printf("size=%u, read=%u, write=%u, reserved=%u\n",buffer->size, buffer->read , buffer->write, buffer->reserved); fflush(stdout); read_buffer_state(read, write, full_r2, buffer); printf("full_r2=%u\n",full_r2); fflush(stdout); if(full_r2){ uint32_t available = buffer->size - read; if(0 < available){ *size = MIN(*size, available); *off = read; }else if(0 < write){ // We are at the end and need to wrap now. //retry: printf("entering cas loop\n"); fflush(stdout); while(!atomic_cas(buffer->write, write_, write)){ printf("before atomic_read\n"); fflush(stdout); write_ = atomic_read(buffer->write); printf("after atomic_read\n"); fflush(stdout); write = write_ & 0x7FFFFFFF; // goto retry; } printf("out of cas loop\n"); fflush(stdout); // write = ( buffer->write & 0x7FFFFFFF); *size = MIN(*size, write); *off = 0; printf("before atomic_write\n"); fflush(stdout); atomic_write(buffer->read, 0); printf("after atomic_write\n"); fflush(stdout); //buffer->read=0; }else{ // Write has not done anything yet, no space! *size = 0; *off = 0; // fflush(stdout); printf("return 0, branch 1\n"); fflush(stdout); return 0; } }else if(read < write){ *size = MIN(*size, write-read); *off = read; }else{ *size = 0; *off = 0; //fflush(stdout); printf("return 0, branch 2\n"); fflush(stdout); return 0; } // fflush(stdout); printf("return 1\n"); fflush(stdout); return 1; }