Searched refs:buf_arr_ (Results 1 – 2 of 2) sorted by relevance
384 buf_arr_[i].buffer_ = reinterpret_cast<void *>(start + i * kAsyncBufferSize); in Init()386 buf_arr_[0].bytes_avail_ = kAsyncBufferSize; in Init()387 buf_arr_[0].num_ele_ = 0; in Init()410 AsyncWriter *asyncWriter = &buf_arr_[cur_]; in AsyncWrite()415 asyncWriter = &buf_arr_[cur_]; in AsyncWrite()427 auto *asyncWriter = &buf_arr_[cur_]; in SyncFlush()439 if (buf_arr_[i].rq) { in SyncFlush()440 Status rc = buf_arr_[i].rq->Wait(); in SyncFlush()442 buf_arr_[i].rq.reset(); in SyncFlush()448 asyncWriter = &buf_arr_[cur_]; in SyncFlush()[all …]
353 AsyncWriter buf_arr_[kNumAsyncBuffer]; variable