MCPcopy Create free account
hub / github.com/baidu/tera / OnMetaChange

Method OnMetaChange

src/tabletnode/tabletnode_zk_adapter.cc:392–405  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

390}
391
392void InsTabletNodeZkAdapter::OnMetaChange(std::string meta_addr, bool deleted) {
393 (void)meta_addr;
394 (void)deleted;
395 std::string cur_meta;
396 std::string root_path = FLAGS_tera_ins_root_path;
397 std::string meta_table = root_path + kRootTabletNodePath;
398 galaxy::ins::sdk::SDKError err;
399 GetRootTableAddr(&cur_meta);
400 CHECK(ins_sdk_->Watch(meta_table, &InsOnMetaChange, this, &err)) << "watch meta table fail";
401 if (!cur_meta.empty()) {
402 MutexLock locker(&mutex_);
403 tabletnode_impl_->SetRootTabletAddr(cur_meta);
404 }
405}
406
407void InsTabletNodeZkAdapter::OnKickMarkCreated() {
408 LOG(ERROR) << "I am kicked by master";

Callers 1

InsOnMetaChangeFunction · 0.80

Calls 2

SetRootTabletAddrMethod · 0.80
emptyMethod · 0.45

Tested by

no test coverage detected