Method Init

src/observer/rowlocknode/rowlocknode_impl.cc:23–37

RowlockNodeImpl::~RowlockNodeImpl() {}

bool RowlockNodeImpl::Init() {
  std::string local_addr = tera::utils::GetLocalHostName() + ":" + FLAGS_rowlock_server_port;
  if (FLAGS_tera_coord_type == "zk") {
    zk_adapter_.reset(new RowlockNodeZkAdapter(this, local_addr));
  } else if (FLAGS_tera_coord_type == "ins") {
    zk_adapter_.reset(new InsRowlockNodeZkAdapter(this, local_addr));
  } else {
    zk_adapter_.reset(new FakeRowlockNodeZkAdapter(this, local_addr));
  }

  zk_adapter_->Init();

  LOG(INFO) << "Rowlock node init finish";
  return true;
}

bool RowlockNodeImpl::Exit() { return true; }