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

Method OnRootNodeCreated

src/tabletnode/tabletnode_zk_adapter.cc:176–190  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

174*/
175
176void TabletNodeZkAdapter::OnRootNodeCreated() {
177 LOG(INFO) << "root node is created";
178 // watch root node
179 int zk_errno = zk::ZE_OK;
180 bool is_exist = false;
181 std::string root_tablet_addr;
182 while (!WatchRootNode(&is_exist, &root_tablet_addr, &zk_errno)) {
183 LOG(ERROR) << "fail to root node : " << zk::ZkErrnoToString(zk_errno);
184 ThisThread::Sleep(FLAGS_tera_zk_retry_period);
185 }
186 LOG(INFO) << "watch root node success";
187 if (!root_tablet_addr.empty()) {
188 tabletnode_impl_->SetRootTabletAddr(root_tablet_addr);
189 }
190}
191
192void TabletNodeZkAdapter::OnRootNodeDeleted() {
193 LOG(INFO) << "root node is deleted";

Callers

nothing calls this directly

Calls 3

ZkErrnoToStringFunction · 0.85
SetRootTabletAddrMethod · 0.80
emptyMethod · 0.45

Tested by

no test coverage detected