int enqueue (T* buf, UInt32 bufLen_I) {
#if DO_DEBUG
- fprintf (stderr, "enqueue: buf = %X, bufLen = %ld.\n",
- (unsigned int)buf, bufLen_I);
+ fprintf (stderr, "enqueue: buf = %X, bufLen = %ld, #av_wr = %ld, "
+ "#av_rd = %ld.\n", (unsigned int)buf, bufLen_I,
+ d_n_avail_write_I, d_n_avail_read_I);
#endif
if (bufLen_I > d_bufLen_I) {
fprintf (stderr, "cannot add buffer longer (%ld"
d_internal->unlock ();
return (2);
}
+ // set the return value to 1: success; change if needed
+ int retval = 1;
if (bufLen_I > d_n_avail_write_I) {
if (d_doWriteBlock) {
while (bufLen_I > d_n_avail_write_I) {
#if DO_DEBUG
fprintf (stderr, "circular_buffer::enqueue: overflow\n");
#endif
- return (-1);
+ retval = -1;
}
}
UInt32 n_now_I = d_bufLen_I - d_writeNdx_I, n_start_I = 0;
d_n_avail_write_I -= bufLen_I;
d_readBlock->signal ();
d_internal->unlock ();
- return (1);
+ return (retval);
};
/*
* buffer length is larger than the instantiated buffer length
*/
-
int dequeue (T* buf, UInt32* bufLen_I) {
#if DO_DEBUG
- fprintf (stderr, "dequeue: buf = %X, *bufLen = %ld.\n",
- (unsigned int)buf, *bufLen_I);
+ fprintf (stderr, "dequeue: buf = %X, *bufLen = %ld, #av_wr = %ld, "
+ "#av_rd = %ld.\n", (unsigned int)buf, *bufLen_I,
+ d_n_avail_write_I, d_n_avail_read_I);
#endif
if (!bufLen_I)
throw std::runtime_error ("circular_buffer::dequeue(): "