aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/lib/iomgr/udp_server.cc
diff options
context:
space:
mode:
authorGravatar Dan Zhang <danzh@google.com>2018-02-27 19:26:09 -0500
committerGravatar Dan Zhang <danzh@google.com>2018-02-27 19:26:09 -0500
commit6cc5a09ffda1cd441b8d5c67b99ac6b7698d5bf6 (patch)
tree341a544d3716edff2ff3b9ceb7a211774a91a3c7 /src/core/lib/iomgr/udp_server.cc
parentb293e9e8224d1ebe03cc7ef28782c4148542bff0 (diff)
fix format
Diffstat (limited to 'src/core/lib/iomgr/udp_server.cc')
-rw-r--r--src/core/lib/iomgr/udp_server.cc12
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);
}