para_list_add(&br->node, &btrn->input_queue);
return;
}
- PARA_DEBUG_LOG("increasing wrap buffer, sz1: %zu, sz2: %zu\n", sz1, sz2);
/*
* We already have a wrap buffer, but it is too small. It might be
* partially used.
if (wbr->wrap_count == sz1 && wbr->btrb->size >= sz1 + sz2) /* nothing we can do about it */
return;
sz = sz1 + sz2 - wbr->btrb->size; /* amount of new data */
+ PARA_DEBUG_LOG("increasing wrap buffer %zu -> %zu\n", wbr->btrb->size,
+ wbr->btrb->size + sz);
wbr->btrb->size += sz;
wbr->btrb->buf = para_realloc(wbr->btrb->buf, wbr->btrb->size);
/* copy the new data to the end of the reallocated buffer */
if (i == 2)
break;
}
+ assert(i == 2);
/* make a new btrb that combines the two buffers and a br to it. */
sz = szs[0] + szs[1];
buf = para_malloc(sz);