Home
last modified time | relevance | path

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 Dmutation_batcher.cc35 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 Dmutation_batcher_test.cc253 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 Dmutation_batcher.h52 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 Dtable.h51 class MutationBatcher; variable
828 friend class MutationBatcher; variable
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/bigtable/
H A Dmutation_batcher.cc35 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 Dmutation_batcher_test.cc253 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 Dmutation_batcher.h56 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 Dtable.h51 class MutationBatcher; variable
902 friend class MutationBatcher; variable
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/examples/
H A Dgcs2cbt.cc67 cbt::MutationBatcher batcher(table); in main()
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/examples/
H A Dgcs2cbt.cc78 cbt::MutationBatcher batcher(table); in main()
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/
H A DCHANGELOG.md141 * 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 DCHANGELOG.md373 * fix: deadlock in MutationBatcher (#4327)
912 * Fix a race condition in `MutationBatcher`.
982 * Implement a helper class (`MutationBatcher`) to automatically batch and manage