diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-07-05 15:10:12 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2017-07-05 15:10:12 -0700 |
| commit | 7fd8f67b2d0eb3d8eeb9ad2752e4b4b1c767b683 (patch) | |
| tree | a9b7eb4610587325881a43fac89e72e766d2f732 | |
| parent | c7c0b55297e4f79479dffb18e34c8a13bade1e26 (diff) | |
clang-format
| -rw-r--r-- | src/core/lib/iomgr/ev_epollex_linux.c | 28 |
1 files changed, 19 insertions, 9 deletions
diff --git a/src/core/lib/iomgr/ev_epollex_linux.c b/src/core/lib/iomgr/ev_epollex_linux.c index 255e365108..5690431759 100644 --- a/src/core/lib/iomgr/ev_epollex_linux.c +++ b/src/core/lib/iomgr/ev_epollex_linux.c @@ -105,19 +105,27 @@ typedef struct pollable { static const char *polling_obj_type_string(polling_obj_type t) { switch (t) { - case PO_POLLING_GROUP: return "polling_group"; - case PO_POLLSET_SET: return "pollset_set"; - case PO_POLLSET: return "pollset"; - case PO_FD: return "fd"; - case PO_EMPTY_POLLABLE: return "empty_pollable"; - case PO_COUNT: return "<invalid:count>"; + case PO_POLLING_GROUP: + return "polling_group"; + case PO_POLLSET_SET: + return "pollset_set"; + case PO_POLLSET: + return "pollset"; + case PO_FD: + return "fd"; + case PO_EMPTY_POLLABLE: + return "empty_pollable"; + case PO_COUNT: + return "<invalid:count>"; } return "<invalid>"; } static char *pollable_desc(pollable *p) { char *out; - gpr_asprintf(&out, "type=%s group=%p epfd=%d wakeup=%d", polling_obj_type_string(p->po.type), p->po.group, p->epfd, p->wakeup.read_fd); + gpr_asprintf(&out, "type=%s group=%p epfd=%d wakeup=%d", + polling_obj_type_string(p->po.type), p->po.group, p->epfd, + p->wakeup.read_fd); return out; } @@ -557,13 +565,15 @@ static void do_kick_all(grpc_exec_ctx *exec_ctx, void *arg, } if (worker->initialized_cv && worker != pollset->root_worker) { if (GRPC_TRACER_ON(grpc_polling_trace)) { - gpr_log(GPR_DEBUG, "PS:%p kickall_via_cv %p (pollable %p vs %p)", pollset, worker, &pollset->pollable, worker->pollable); + gpr_log(GPR_DEBUG, "PS:%p kickall_via_cv %p (pollable %p vs %p)", + pollset, worker, &pollset->pollable, worker->pollable); } worker->kicked = true; gpr_cv_signal(&worker->cv); } else { if (GRPC_TRACER_ON(grpc_polling_trace)) { - gpr_log(GPR_DEBUG, "PS:%p kickall_via_wakeup %p (pollable %p vs %p)", pollset, worker, &pollset->pollable, worker->pollable); + gpr_log(GPR_DEBUG, "PS:%p kickall_via_wakeup %p (pollable %p vs %p)", + pollset, worker, &pollset->pollable, worker->pollable); } append_error(&error, grpc_wakeup_fd_wakeup(&worker->pollable->wakeup), "pollset_shutdown"); |