Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
levy5307 committed Jan 7, 2021
1 parent 87ad3c3 commit 496c527
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion src/server/rocksdb_wrapper.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -185,7 +185,11 @@ int rocksdb_wrapper::ingestion_files(int64_t decree, const std::vector<std::stri
{
rocksdb::IngestExternalFileOptions ifo;
rocksdb::Status s = _db->IngestExternalFile(sst_file_list, ifo);
derror_rocksdb("IngestExternalFile", s.ToString(), "decree = {}", decree);
if (dsn_unlikely(!s.ok())) {
derror_rocksdb("IngestExternalFile", s.ToString(), "decree = {}", decree);
} else {
ddebug_rocksdb("IngestExternalFile", "Ingest files succeed, decree = {}", decree);
}
return s.code();
}

Expand Down

0 comments on commit 496c527

Please sign in to comment.