Searched refs:asyncWriter (Results 1 – 1 of 1) sorted by relevance
410 AsyncWriter *asyncWriter = &buf_arr_[cur_]; in AsyncWrite() local411 if (asyncWriter->bytes_avail_ < sz) { in AsyncWrite()415 asyncWriter = &buf_arr_[cur_]; in AsyncWrite()417 RETURN_IF_NOT_OK(asyncWriter->Write(sz, v)); in AsyncWrite()427 auto *asyncWriter = &buf_arr_[cur_]; in SyncFlush() local428 if (asyncWriter->num_ele_) { in SyncFlush()429 asyncWriter->rq.reset( in SyncFlush()430 … new BatchCacheRowsRequest(cc_, offset_addr_ + cur_ * kAsyncBufferSize, asyncWriter->num_ele_)); in SyncFlush()431 flush_rc_ = cc_->PushRequest(asyncWriter->rq); in SyncFlush()448 asyncWriter = &buf_arr_[cur_]; in SyncFlush()[all …]