| 478 | } |
| 479 | |
| 480 | void CheckBuffer() { |
| 481 | size_t curr_buffer_offset = buffer_cur_ * val_len_; |
| 482 | if (curr_buffer_offset + val_len_ > BUFFER_SIZE) { |
| 483 | WriteFile(current_version_, curr_buffer_offset); |
| 484 | if (emb_files_[current_version_]->Count() >= max_app_count_) { |
| 485 | ++current_version_; |
| 486 | current_offset_ = 0; |
| 487 | CreateFile(current_version_); |
| 488 | } |
| 489 | TF_CHECK_OK(UpdateFlushStatus()); |
| 490 | buffer_cur_ = 0; |
| 491 | } |
| 492 | } |
| 493 | |
| 494 | void CheckBufferAsync() { |
| 495 | size_t curr_buffer_offset = buffer_cur_ * val_len_; |