diff options
author | 2018-02-27 19:26:09 -0500 | |
---|---|---|
committer | 2018-02-27 19:26:09 -0500 | |
commit | 6cc5a09ffda1cd441b8d5c67b99ac6b7698d5bf6 (patch) | |
tree | 341a544d3716edff2ff3b9ceb7a211774a91a3c7 /src/core/lib/iomgr/udp_server.cc | |
parent | b293e9e8224d1ebe03cc7ef28782c4148542bff0 (diff) |
fix format
Diffstat (limited to 'src/core/lib/iomgr/udp_server.cc')
-rw-r--r-- | src/core/lib/iomgr/udp_server.cc | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/core/lib/iomgr/udp_server.cc b/src/core/lib/iomgr/udp_server.cc index d829c76034..8f9e08557b 100644 --- a/src/core/lib/iomgr/udp_server.cc +++ b/src/core/lib/iomgr/udp_server.cc @@ -123,7 +123,7 @@ class GrpcUdpListener { // connections. grpc_closure orphan_fd_closure_; grpc_closure destroyed_closure_; - // To be scheduled on another thread to actually read/write. + // To be scheduled on another thread to actually read/write. grpc_closure do_read_closure_; grpc_closure do_write_closure_; grpc_closure notify_on_write_closure_; @@ -159,9 +159,7 @@ GrpcUdpListener::GrpcUdpListener(grpc_udp_server* server, int fd, gpr_mu_init(&mutex_); } -GrpcUdpListener::~GrpcUdpListener() { - gpr_mu_destroy(&mutex_); -} +GrpcUdpListener::~GrpcUdpListener() { gpr_mu_destroy(&mutex_); } /* the overall server */ struct grpc_udp_server { @@ -239,7 +237,6 @@ void GrpcUdpListener::shutdown_fd(void* args, grpc_error* error) { gpr_mu_unlock(sp->mutex()); } - static void finish_shutdown(grpc_udp_server* s) { if (s->shutdown_complete != nullptr) { GRPC_CLOSURE_SCHED(s->shutdown_complete, GRPC_ERROR_NONE); @@ -248,7 +245,7 @@ static void finish_shutdown(grpc_udp_server* s) { gpr_mu_destroy(&s->mu); gpr_log(GPR_DEBUG, "Destroy all listeners."); - for(size_t i = 0; i < s->listeners.size(); ++i) { + for (size_t i = 0; i < s->listeners.size(); ++i) { s->listeners[i].OnDestroy(); } @@ -257,7 +254,6 @@ static void finish_shutdown(grpc_udp_server* s) { } grpc_core::Delete(s); - } static void destroyed_port(void* server, grpc_error* error) { @@ -658,7 +654,7 @@ void grpc_udp_server_start(grpc_udp_server* s, grpc_pollset** pollsets, s->pollsets = pollsets; s->user_data = user_data; - for(size_t i = 0; i < s->listeners.size(); ++i) { + for (size_t i = 0; i < s->listeners.size(); ++i) { s->listeners[i].StartListening(pollsets, pollset_count, s->handler_factory); } |