@@ -80,14 +80,14 @@ void ServerAsyncImpl::DriveCQ() {
8080}
8181
8282bool ServerAsyncImpl::IncrementRpcPending () {
83- absl::MutexLock lock (& shutdown_lock_);
83+ absl::MutexLock lock (shutdown_lock_);
8484 if (server_shutdown_) return false ;
8585 ++rpcs_pending_;
8686 return true ;
8787}
8888
8989bool ServerAsyncImpl::DecrementRpcPending () {
90- absl::MutexLock lock (& shutdown_lock_);
90+ absl::MutexLock lock (shutdown_lock_);
9191 rpcs_pending_--;
9292 if (rpcs_pending_ == 0 ) {
9393 // If count is zero, then server is shutdown (because new RPCs are requested
@@ -231,7 +231,7 @@ absl::Status ServerAsyncImpl::BuildAndStart(
231231 const std::string& address_uri,
232232 std::shared_ptr<::grpc::ServerCredentials> creds,
233233 int async_pool_size) {
234- absl::MutexLock lock (& shutdown_lock_);
234+ absl::MutexLock lock (shutdown_lock_);
235235 if (server_shutdown_) {
236236 return absl::InternalError (" Cannot initialize in the middle of shutdown" );
237237 }
@@ -280,7 +280,7 @@ void ServerAsyncImpl::Shutdown() {
280280 GOOGLE_LOG (INFO) << " Shutting down ..." ;
281281 ::grpc::Server* server;
282282 {
283- absl::MutexLock lock (& shutdown_lock_);
283+ absl::MutexLock lock (shutdown_lock_);
284284 server_shutdown_ = true ;
285285 // Get the server_ variable that is protected by a lock and capture it
286286 // in a local since we can't hold the lock while performing a Shutdown
0 commit comments