Searched refs:MutationBatcher (Results 1 – 12 of 12) sorted by relevance
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/bigtable/ |
H A D | mutation_batcher.cc | 35 MutationBatcher::Options::Options() in Options() 41 std::pair<future<void>, future<Status>> MutationBatcher::AsyncApply( in AsyncApply() 80 future<void> MutationBatcher::AsyncWaitForNoPendingRequests() { in AsyncWaitForNoPendingRequests() 89 MutationBatcher::PendingSingleRowMutation::PendingSingleRowMutation( in PendingSingleRowMutation() 143 bool MutationBatcher::FlushIfPossible(CompletionQueue cq) { in FlushIfPossible() 165 MutationBatcher* self; in FlushIfPossible() 176 void MutationBatcher::OnBulkApplyDone( in OnBulkApplyDone() 177 CompletionQueue cq, MutationBatcher::Batch batch, in OnBulkApplyDone() 213 std::vector<MutationBatcher::AdmissionPromise> MutationBatcher::TryAdmit( in TryAdmit() 230 void MutationBatcher::Admit(PendingSingleRowMutation mut) { in Admit() [all …]
|
H A D | mutation_batcher_test.cc | 253 std::unique_ptr<MutationBatcher> batcher_; 257 MutationBatcher::Options opt = MutationBatcher::Options() in TEST() 290 batcher_.reset(new MutationBatcher(table_, MutationBatcher::Options() in TEST_F() 339 batcher_.reset(new MutationBatcher( in TEST_P() 340 table_, MutationBatcher::Options() in TEST_P() 408 batcher_.reset(new MutationBatcher( in TEST_F() 423 new MutationBatcher(table_, MutationBatcher::Options().SetMaxSizePerBatch( in TEST_F() 449 new MutationBatcher(table_, MutationBatcher::Options().SetMaxBatches(1))); in TEST_F() 486 batcher_.reset(new MutationBatcher( in TEST_F() 557 batcher_.reset(new MutationBatcher( in TEST_F() [all …]
|
H A D | mutation_batcher.h | 52 class MutationBatcher { 88 explicit MutationBatcher(Table table, Options options = Options()) 96 virtual ~MutationBatcher() = default; 255 void OnBulkApplyDone(CompletionQueue cq, MutationBatcher::Batch batch, 264 std::vector<MutationBatcher::AdmissionPromise> TryAdmit(CompletionQueue& cq);
|
H A D | table.h | 51 class MutationBatcher; variable 828 friend class MutationBatcher; variable
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/bigtable/ |
H A D | mutation_batcher.cc | 35 MutationBatcher::Options::Options() in Options() 41 std::pair<future<void>, future<Status>> MutationBatcher::AsyncApply( in AsyncApply() 80 future<void> MutationBatcher::AsyncWaitForNoPendingRequests() { in AsyncWaitForNoPendingRequests() 89 MutationBatcher::PendingSingleRowMutation::PendingSingleRowMutation( in PendingSingleRowMutation() 143 bool MutationBatcher::FlushIfPossible(CompletionQueue cq) { in FlushIfPossible() 165 MutationBatcher* self; in FlushIfPossible() 176 void MutationBatcher::OnBulkApplyDone( in OnBulkApplyDone() 177 CompletionQueue cq, MutationBatcher::Batch batch, in OnBulkApplyDone() 213 std::vector<MutationBatcher::AdmissionPromise> MutationBatcher::TryAdmit( in TryAdmit() 230 void MutationBatcher::Admit(PendingSingleRowMutation mut) { in Admit() [all …]
|
H A D | mutation_batcher_test.cc | 253 std::unique_ptr<MutationBatcher> batcher_; 257 MutationBatcher::Options opt = MutationBatcher::Options() in TEST() 290 batcher_.reset(new MutationBatcher(table_, MutationBatcher::Options() in TEST_F() 339 batcher_.reset(new MutationBatcher( in TEST_P() 340 table_, MutationBatcher::Options() in TEST_P() 408 batcher_.reset(new MutationBatcher( in TEST_F() 423 new MutationBatcher(table_, MutationBatcher::Options().SetMaxSizePerBatch( in TEST_F() 449 new MutationBatcher(table_, MutationBatcher::Options().SetMaxBatches(1))); in TEST_F() 486 batcher_.reset(new MutationBatcher( in TEST_F() 557 batcher_.reset(new MutationBatcher( in TEST_F() [all …]
|
H A D | mutation_batcher.h | 56 class MutationBatcher { 92 explicit MutationBatcher(Table table, Options options = Options()) 100 virtual ~MutationBatcher() = default; 259 void OnBulkApplyDone(CompletionQueue cq, MutationBatcher::Batch batch, 268 std::vector<MutationBatcher::AdmissionPromise> TryAdmit(CompletionQueue& cq);
|
H A D | table.h | 51 class MutationBatcher; variable 902 friend class MutationBatcher; variable
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/examples/ |
H A D | gcs2cbt.cc | 67 cbt::MutationBatcher batcher(table); in main()
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/examples/ |
H A D | gcs2cbt.cc | 78 cbt::MutationBatcher batcher(table); in main()
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/ |
H A D | CHANGELOG.md | 141 * fix: deadlock in MutationBatcher (#4327) 680 * Fix a race condition in `MutationBatcher`. 750 * Implement a helper class (`MutationBatcher`) to automatically batch and manage
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/ |
H A D | CHANGELOG.md | 373 * fix: deadlock in MutationBatcher (#4327) 912 * Fix a race condition in `MutationBatcher`. 982 * Implement a helper class (`MutationBatcher`) to automatically batch and manage
|