greg/stasis-aries-wal
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

printf -> DEBUG for ringbuffer

Browse source
This commit is contained in:
Sears Russell 2011-11-06 15:49:33 +00:00
parent 4b300dda7a
commit 20d2196040
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/stasis/util/ringbuffer.c
View file

@ -157,7 +157,7 @@ lsn_t stasis_ringbuffer_consume_bytes(stasis_ringbuffer_t * ring, lsn_t* sz, lsn
*sz = (ring->flush > ring->rf) ? RING_NEXT : orig_sz; *sz = (ring->flush > ring->rf) ? RING_NEXT : orig_sz;
if(ring->shutdown) { if(ring->shutdown) {
if(ring->rt == ring->wf) { if(ring->rt == ring->wf) {
fprintf(stderr, "Shutting down, and there are no more bytes. Signaling shutdown thread.\n"); DEBUG(stderr, "Shutting down, and there are no more bytes. Signaling shutdown thread.\n");
pthread_cond_signal(&ring->read_done); pthread_cond_signal(&ring->read_done);
pthread_mutex_unlock(&ring->mut); pthread_mutex_unlock(&ring->mut);
return RING_CLOSED; return RING_CLOSED;