|
|
|
@ -208,6 +208,11 @@ void AsyncGRPCServer::WaitClientGet(int count) {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
bool AsyncGRPCServer::WaitServerReady() {
|
|
|
|
|
std::unique_lock<std::mutex> lock(this->mutex_ready_);
|
|
|
|
|
condition_ready_.wait(lock, [&] { return this->ready_ == 1; });
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void AsyncGRPCServer::RunSyncUpdate() {
|
|
|
|
|
::grpc::ServerBuilder builder;
|
|
|
|
|
builder.AddListeningPort(address_, ::grpc::InsecureServerCredentials(),
|
|
|
|
|