| 44 | RowlockNodeEntry::~RowlockNodeEntry() {} |
| 45 | |
| 46 | bool RowlockNodeEntry::StartServer() { |
| 47 | SetProcessorAffinity(); |
| 48 | IpAddress rowlocknode_addr("0.0.0.0", FLAGS_rowlock_server_port); |
| 49 | LOG(INFO) << "Start RPC server at: " << rowlocknode_addr.ToString(); |
| 50 | rowlocknode_impl_.reset(new RowlockNodeImpl()); |
| 51 | remote_rowlocknode_ = new RemoteRowlockNode(rowlocknode_impl_.get()); |
| 52 | rpc_server_->RegisterService(remote_rowlocknode_); |
| 53 | if (!rpc_server_->Start(rowlocknode_addr.ToString())) { |
| 54 | LOG(ERROR) << "start RPC server error"; |
| 55 | return false; |
| 56 | } |
| 57 | if (!rowlocknode_impl_->Init()) { |
| 58 | LOG(ERROR) << "fail to init rowlocknode_impl"; |
| 59 | return false; |
| 60 | } |
| 61 | LOG(INFO) << "finish starting RPC server"; |
| 62 | |
| 63 | return true; |
| 64 | } |
| 65 | |
| 66 | void RowlockNodeEntry::ShutdownServer() { |
| 67 | LOG(INFO) << "shut down server"; |