#include "test_util/sync_point_impl.h"
-int rocksdb_kill_odds = 0;
std::vector<std::string> rocksdb_kill_exclude_prefixes;
#ifndef NDEBUG
SyncPoint::SyncPoint() : impl_(new Data) {}
-SyncPoint:: ~SyncPoint() {
- delete impl_;
-}
+SyncPoint::~SyncPoint() { delete impl_; }
void SyncPoint::LoadDependency(const std::vector<SyncPointPair>& dependencies) {
impl_->LoadDependency(dependencies);
}
void SyncPoint::LoadDependencyAndMarkers(
- const std::vector<SyncPointPair>& dependencies,
- const std::vector<SyncPointPair>& markers) {
+ const std::vector<SyncPointPair>& dependencies,
+ const std::vector<SyncPointPair>& markers) {
impl_->LoadDependencyAndMarkers(dependencies, markers);
}
void SyncPoint::SetCallBack(const std::string& point,
- const std::function<void(void*)>& callback) {
+ const std::function<void(void*)>& callback) {
impl_->SetCallBack(point, callback);
}
impl_->ClearCallBack(point);
}
-void SyncPoint::ClearAllCallBacks() {
- impl_->ClearAllCallBacks();
-}
+void SyncPoint::ClearAllCallBacks() { impl_->ClearAllCallBacks(); }
-void SyncPoint::EnableProcessing() {
- impl_->EnableProcessing();
-}
+void SyncPoint::EnableProcessing() { impl_->EnableProcessing(); }
-void SyncPoint::DisableProcessing() {
- impl_->DisableProcessing();
-}
+void SyncPoint::DisableProcessing() { impl_->DisableProcessing(); }
-void SyncPoint::ClearTrace() {
- impl_->ClearTrace();
-}
+void SyncPoint::ClearTrace() { impl_->ClearTrace(); }
-void SyncPoint::Process(const std::string& point, void* cb_arg) {
+void SyncPoint::Process(const Slice& point, void* cb_arg) {
impl_->Process(point, cb_arg);
}