Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 31) sorted by relevance

12

/rocksdb-6.9/include/rocksdb/
Dstatus.h109 static Status NotFound(SubCode msg = kNone) { return Status(kNotFound, msg); }
115 return Status(kCorruption, msg);
122 return Status(kNotSupported, msg);
135 static Status IOError(SubCode msg = kNone) { return Status(kIOError, msg); }
148 return Status(kIncomplete, msg);
158 static Status Aborted(SubCode msg = kNone) { return Status(kAborted, msg); }
163 static Status Busy(SubCode msg = kNone) { return Status(kBusy, msg); }
165 return Status(kBusy, msg, msg2);
168 static Status TimedOut(SubCode msg = kNone) { return Status(kTimedOut, msg); }
173 static Status Expired(SubCode msg = kNone) { return Status(kExpired, msg); }
[all …]
Dio_status.h73 return IOStatus(kNotSupported, msg);
78 return IOStatus(kNotFound, msg, msg2);
82 return IOStatus(kNotFound, msg);
89 return IOStatus(kCorruption, msg);
101 return IOStatus(kIOError, msg, msg2);
104 return IOStatus(kIOError, msg);
107 static IOStatus Busy(SubCode msg = kNone) { return IOStatus(kBusy, msg); }
109 return IOStatus(kBusy, msg, msg2);
113 return IOStatus(kTimedOut, msg);
158 const size_t len1 = msg.size(); in IOStatus()
[all …]
/rocksdb-6.9/db/
Dversion_edit.cc442 msg = "db id"; in DecodeFrom()
509 if (!msg) { in DecodeFrom()
520 if (!msg) { in DecodeFrom()
537 if (!msg) { in DecodeFrom()
558 if (!msg) { in DecodeFrom()
581 if (!msg) { in DecodeFrom()
617 if (!msg) { in DecodeFrom()
628 if (!msg) { in DecodeFrom()
641 if (!msg) { in DecodeFrom()
654 if (!msg) { in DecodeFrom()
[all …]
Dversion_edit_handler.cc257 std::string msg("no "); in CheckIterationResult() local
259 msg.append("log_file_number, "); in CheckIterationResult()
262 msg.append("next_file_number, "); in CheckIterationResult()
265 msg.append("last_sequence, "); in CheckIterationResult()
267 msg = msg.substr(0, msg.size() - 2); in CheckIterationResult()
268 msg.append(" entry in MANIFEST"); in CheckIterationResult()
269 *s = Status::Corruption(msg); in CheckIterationResult()
272 std::string msg; in CheckIterationResult() local
274 msg.append(", "); in CheckIterationResult()
275 msg.append(cf.second); in CheckIterationResult()
[all …]
Dlog_test.cc193 void Write(const std::string& msg) { in Write() argument
194 writer_.AddRecord(Slice(msg)); in Write()
266 std::string MatchError(const std::string& msg) const { in MatchError()
267 if (report_.message_.find(msg) == std::string::npos) { in MatchError()
787 void Encode(const std::string& msg) { log_writer_->AddRecord(Slice(msg)); } in Encode() argument
Dtransaction_log_impl.cc199 const char* msg = "Create a new iterator to fetch the new tail."; in NextImpl() local
200 current_status_ = Status::TryAgain(msg); in NextImpl()
Dcorruption_test.cc163 const char* msg = strerror(errno); in CorruptFile() local
164 FAIL() << fname << ": " << msg; in CorruptFile()
Dversion_edit.h434 bool GetLevel(Slice* input, int* level, const char** msg);
/rocksdb-6.9/include/rocksdb/utilities/
Dldb_cmd_execute_result.h24 LDBCommandExecuteResult(State state, std::string& msg) in LDBCommandExecuteResult() argument
25 : state_(state), message_(msg) {} in LDBCommandExecuteResult()
55 static LDBCommandExecuteResult Succeed(std::string msg) { in Succeed() argument
56 return LDBCommandExecuteResult(EXEC_SUCCEED, msg); in Succeed()
59 static LDBCommandExecuteResult Failed(std::string msg) { in Failed() argument
60 return LDBCommandExecuteResult(EXEC_FAILED, msg); in Failed()
Dobject_registry.h56 std::string* msg) const { in NewFactoryObject() argument
57 return factory_(target, guard, msg); in NewFactoryObject()
/rocksdb-6.9/utilities/
Dobject_registry_test.cc39 std::string msg; in TEST_F() local
42 auto res = registry->NewObject<Env>("a://test", &env_guard, &msg); in TEST_F()
48 res = registry->NewObject<Env>("b://test", &env_guard, &msg); in TEST_F()
54 res = registry->NewObject<Env>("c://test", &env_guard, &msg); in TEST_F()
62 std::string msg; in TEST_F() local
78 ObjectRegistry::NewInstance()->NewObject<Env>("test-local", &guard, &msg), in TEST_F()
81 ObjectRegistry::NewInstance()->NewObject("test-global", &guard, &msg), in TEST_F()
83 ASSERT_NE(registry->NewObject<Env>("test-local", &guard, &msg), nullptr); in TEST_F()
84 ASSERT_NE(registry->NewObject<Env>("test-global", &guard, &msg), nullptr); in TEST_F()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DRocksDBException.java21 public RocksDBException(final String msg) { in RocksDBException() argument
22 this(msg, null); in RocksDBException()
25 public RocksDBException(final String msg, final Status status) { in RocksDBException() argument
26 super(msg); in RocksDBException()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc1622 str->append(msg.data(), msg.size()); in AppendWithSpace()
4366 snprintf(msg, sizeof(msg), "(%" PRIu64 " ops)", num_); in DoWrite()
4917 char msg[100]; in ReadToRowCache() local
5000 char msg[100]; in ReadRandomFast() local
5595 snprintf(msg, sizeof(msg), in MixGraph()
6063 snprintf(msg, sizeof(msg), in RandomWithVerify()
6171 snprintf(msg, sizeof(msg), in UpdateRandom()
6224 snprintf(msg, sizeof(msg), in XORUpdateRandom()
6386 snprintf(msg, sizeof(msg), in ReadRandomMergeRandom()
6585 snprintf(msg, sizeof(msg), in RandomTransaction()
[all …]
Ddb_crashtest.py435 msg = ("check_mode={0}, kill option={1}, exitcode={2}\n".format(
437 print(msg)
Dldb_cmd_impl.h255 static void Help(std::string& msg);
285 static void Help(std::string& msg);
/rocksdb-6.9/utilities/transactions/
Dtransaction_util.cc90 char msg[300]; in CheckKey() local
91 snprintf(msg, sizeof(msg), in CheckKey()
101 result = Status::TryAgain(msg); in CheckKey()
Dtransaction_lock_mgr.cc294 char msg[255]; in TryLock() local
295 snprintf(msg, sizeof(msg), "Column family id not found: %" PRIu32, in TryLock()
298 return Status::InvalidArgument(msg); in TryLock()
/rocksdb-6.9/utilities/persistent_cache/
Dpersistent_cache_bench.cc150 std::ostringstream msg; in PrintStats() local
151 msg << "Test stats" << std::endl in PrintStats()
163 fprintf(stderr, "%s\n", msg.str().c_str()); in PrintStats()
314 std::ostringstream msg; in main() local
315 msg << "Config" << std::endl in main()
330 fprintf(stderr, "%s\n", msg.str().c_str()); in main()
/rocksdb-6.9/util/
Dstatus.cc57 Status::Status(Code _code, SubCode _subcode, const Slice& msg, in Status() argument
62 const size_t len1 = msg.size(); in Status()
66 memcpy(result, msg.data(), len1); in Status()
/rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/
Dgtest-all.cc2143 Message msg; in HasOneFailure() local
2414 *msg << '\0'; in StreamWideCharsToMessage()
2817 Message msg; in EqFailure() local
2853 Message msg; in GetBoolAssertionFailureMessage() local
2859 return msg.GetString(); in GetBoolAssertionFailureMessage()
6094 Message msg; in AddTestPartResult() local
6095 msg << message; in AddTestPartResult()
7689 Message msg; in DeathTestThreadWarning() local
7697 msg << " See " in DeathTestThreadWarning()
10623 Message msg; in ParseInt32() local
[all …]
/rocksdb-6.9/buckifier/
Dbuckify_rocksdb.py223 def exit_with_error(msg): argument
224 print(ColorString.error(msg))
/rocksdb-6.9/java/rocksjni/
Dloggerjnicallback.cc134 const std::unique_ptr<char[]> msg = format_str(format, ap); in Logv() local
141 jstring jmsg = env->NewStringUTF(msg.get()); in Logv()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.h197 void VerificationAbort(SharedState* shared, std::string msg, Status s) const;
199 void VerificationAbort(SharedState* shared, std::string msg, int cf,
Ddb_stress_test_base.cc312 void StressTest::VerificationAbort(SharedState* shared, std::string msg, in VerificationAbort() argument
314 fprintf(stderr, "Verification failed: %s. Status is %s\n", msg.c_str(), in VerificationAbort()
319 void StressTest::VerificationAbort(SharedState* shared, std::string msg, int cf, in VerificationAbort() argument
323 key, msg.c_str()); in VerificationAbort()
/rocksdb-6.9/table/
Dmeta_blocks.cc142 std::string msg = in LogPropertiesCollectionError() local
145 ROCKS_LOG_ERROR(info_log, "%s", msg.c_str()); in LogPropertiesCollectionError()

12