Searched refs:current_write (Results 1 – 3 of 3) sorted by relevance
49 struct list_item *current_read, *current_write; member155 bq->current_write = NULL; in fix_current_write()159 if (PA_UNLIKELY(!bq->current_write)) in fix_current_write()160 bq->current_write = bq->blocks_tail; in fix_current_write()163 …while (PA_UNLIKELY(bq->current_write->index + (int64_t) bq->current_write->chunk.length <= bq->wri… in fix_current_write()165 if (bq->current_write->next) in fix_current_write()166 bq->current_write = bq->current_write->next; in fix_current_write()171 …while (PA_LIKELY(bq->current_write != NULL) && PA_UNLIKELY(bq->current_write->index > bq->write_in… in fix_current_write()172 bq->current_write = bq->current_write->prev; in fix_current_write()199 if (bq->current_write == q) in drop_block()[all …]
5572 char* current_write = write_start; in WriteUtf8Impl() local5585 write_capacity - static_cast<int>(current_write - write_start); in WriteUtf8Impl()5599 memcpy(current_write, read_start + read_index, copy_length); in WriteUtf8Impl()5600 current_write += copy_length; in WriteUtf8Impl()5604 current_write += unibrow::Utf8::EncodeOneByte( in WriteUtf8Impl()5605 current_write, static_cast<uint8_t>(read_start[read_index])); in WriteUtf8Impl()5607 (current_write - write_start) <= write_capacity); in WriteUtf8Impl()5613 current_write += unibrow::Utf8::Encode(current_write, character, in WriteUtf8Impl()5617 (current_write - write_start) <= write_capacity); in WriteUtf8Impl()5625 write_capacity - static_cast<int>(current_write - write_start); in WriteUtf8Impl()[all …]
372 BaseObjectPtr<AsyncWrap> current_write = std::move(current_write_); in InvokeQueued() local374 WriteWrap* w = WriteWrap::FromObject(current_write); in InvokeQueued()