Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
Signed-off-by: tabokie <xy.tao@outlook.com>
  • Loading branch information
tabokie committed Dec 29, 2019
1 parent c985bc4 commit 7203694
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 9 deletions.
12 changes: 6 additions & 6 deletions src/blob_gc_job.cc
Original file line number Diff line number Diff line change
Expand Up @@ -271,7 +271,7 @@ Status BlobGCJob::DoRunGC() {
std::unique_ptr<BlobFileHandle> blob_file_handle;
std::unique_ptr<BlobFileBuilder> blob_file_builder;

auto *cfh = blob_gc_->column_family_handle();
auto* cfh = blob_gc_->column_family_handle();

Options options;
options.table_properties_collector_factories.emplace_back(
Expand Down Expand Up @@ -376,13 +376,13 @@ Status BlobGCJob::DoRunGC() {
callback.value = index_entry;
rewrite_batches_.emplace_back(
std::make_pair(WriteBatch(), std::move(callback)));
auto &wb = rewrite_batches_.back().first;
auto& wb = rewrite_batches_.back().first;
s = WriteBatchInternal::PutBlobIndex(&wb, cfh->GetID(), blob_record.key,
index_entry);
} else if (gc_rewrite_mode_ == TitanGcRewriteMode::kMerge) {
new_blob_index.EncodeTo(&index_entry);
rewrite_batches_without_callback_.emplace_back(WriteBatch());
auto &wb = rewrite_batches_without_callback_.back();
auto& wb = rewrite_batches_without_callback_.back();
s = WriteBatchInternal::Merge(&wb, cfh->GetID(), blob_record.key,
index_entry);
} else { // TitanGcRewriteMode::kIngest / TitanGcRewriteMode::kFastIngest
Expand Down Expand Up @@ -601,7 +601,7 @@ Status BlobGCJob::RewriteValidKeyToLSM() {
// @TODO(tabokie): fix statistics here.
switch (gc_rewrite_mode_) {
case TitanGcRewriteMode::kDefault:
for (auto &write_batch : rewrite_batches_) {
for (auto& write_batch : rewrite_batches_) {
if (blob_gc_->GetColumnFamilyData()->IsDropped()) {
s = Status::Aborted("Column family drop");
break;
Expand Down Expand Up @@ -632,7 +632,7 @@ Status BlobGCJob::RewriteValidKeyToLSM() {
}
break;
case TitanGcRewriteMode::kMerge:
for (auto &write_batch : rewrite_batches_without_callback_) {
for (auto& write_batch : rewrite_batches_without_callback_) {
if (blob_gc_->GetColumnFamilyData()->IsDropped()) {
s = Status::Aborted("Column family drop");
break;
Expand Down Expand Up @@ -665,7 +665,7 @@ Status BlobGCJob::RewriteValidKeyToLSM() {
case TitanGcRewriteMode::kIngest:
case TitanGcRewriteMode::kFastIngest:
if (ingestion_file_ready_) {
auto *cfh = blob_gc_->column_family_handle();
auto* cfh = blob_gc_->column_family_handle();
IngestExternalFileOptions ifo;
ifo.skip_memtable_check =
(gc_rewrite_mode_ == TitanGcRewriteMode::kFastIngest);
Expand Down
6 changes: 3 additions & 3 deletions src/blob_gc_job.h
Original file line number Diff line number Diff line change
Expand Up @@ -45,8 +45,8 @@ class BlobGCJob {

BlobGC* blob_gc_;
DB* base_db_;
DBImpl* base_db_impl_;
port::Mutex* mutex_;
DBImpl *base_db_impl_;
port::Mutex *mutex_;
TitanDBOptions db_options_;
const TitanGcRewriteMode gc_rewrite_mode_;
Env *env_;
Expand All @@ -70,7 +70,7 @@ class BlobGCJob {

std::atomic_bool *shuting_down_{nullptr};

TitanStats* stats_;
TitanStats *stats_;

struct {
uint64_t bytes_read = 0;
Expand Down

0 comments on commit 7203694

Please sign in to comment.