+
+ current_block = malloc(sizeof(pa_memblock_queue));
+ memset(current_block, 0, sizeof(pa_memblock_queue));
+
+ current_block->memblock = u->memchunk.memblock;
+ if (u->current == NULL) { u->current = current_block; }
+ if (u->last == NULL) { u->last = current_block; }
+ else {
+ u->last->next = current_block;
+ u->last = current_block;
+ }
+
+ //pa_memblock_unref(u->memchunk.memblock);
+ pa_memchunk_reset(&u->memchunk);
+ if (ate >= u->sink->thread_info.max_request) break;