diff options
author | 2015-09-22 12:33:20 -0700 | |
---|---|---|
committer | 2015-09-22 12:33:20 -0700 | |
commit | a82950e68318a6aab6fe894fa39f7fa616c4647b (patch) | |
tree | 7d02bd1e9e1cbae1f14ad4ad1e06d3ae81a96dfe /src/core/iomgr/wakeup_fd_pipe.c | |
parent | 8af4c337181322cc4fb396199c90f574cfb4163f (diff) |
clang-format all core files
Diffstat (limited to 'src/core/iomgr/wakeup_fd_pipe.c')
-rw-r--r-- | src/core/iomgr/wakeup_fd_pipe.c | 69 |
1 files changed, 26 insertions, 43 deletions
diff --git a/src/core/iomgr/wakeup_fd_pipe.c b/src/core/iomgr/wakeup_fd_pipe.c index 4c87e3e1d9..80de181d9d 100644 --- a/src/core/iomgr/wakeup_fd_pipe.c +++ b/src/core/iomgr/wakeup_fd_pipe.c @@ -44,71 +44,54 @@ #include "src/core/iomgr/socket_utils_posix.h" #include <grpc/support/log.h> -static void -pipe_init (grpc_wakeup_fd * fd_info) -{ +static void pipe_init(grpc_wakeup_fd* fd_info) { int pipefd[2]; /* TODO(klempner): Make this nonfatal */ - GPR_ASSERT (0 == pipe (pipefd)); - GPR_ASSERT (grpc_set_socket_nonblocking (pipefd[0], 1)); - GPR_ASSERT (grpc_set_socket_nonblocking (pipefd[1], 1)); + GPR_ASSERT(0 == pipe(pipefd)); + GPR_ASSERT(grpc_set_socket_nonblocking(pipefd[0], 1)); + GPR_ASSERT(grpc_set_socket_nonblocking(pipefd[1], 1)); fd_info->read_fd = pipefd[0]; fd_info->write_fd = pipefd[1]; } -static void -pipe_consume (grpc_wakeup_fd * fd_info) -{ +static void pipe_consume(grpc_wakeup_fd* fd_info) { char buf[128]; ssize_t r; - for (;;) - { - r = read (fd_info->read_fd, buf, sizeof (buf)); - if (r > 0) - continue; - if (r == 0) - return; - switch (errno) - { - case EAGAIN: - return; - case EINTR: - continue; - default: - gpr_log (GPR_ERROR, "error reading pipe: %s", strerror (errno)); - return; - } + for (;;) { + r = read(fd_info->read_fd, buf, sizeof(buf)); + if (r > 0) continue; + if (r == 0) return; + switch (errno) { + case EAGAIN: + return; + case EINTR: + continue; + default: + gpr_log(GPR_ERROR, "error reading pipe: %s", strerror(errno)); + return; } + } } -static void -pipe_wakeup (grpc_wakeup_fd * fd_info) -{ +static void pipe_wakeup(grpc_wakeup_fd* fd_info) { char c = 0; - while (write (fd_info->write_fd, &c, 1) != 1 && errno == EINTR) + while (write(fd_info->write_fd, &c, 1) != 1 && errno == EINTR) ; } -static void -pipe_destroy (grpc_wakeup_fd * fd_info) -{ - if (fd_info->read_fd != 0) - close (fd_info->read_fd); - if (fd_info->write_fd != 0) - close (fd_info->write_fd); +static void pipe_destroy(grpc_wakeup_fd* fd_info) { + if (fd_info->read_fd != 0) close(fd_info->read_fd); + if (fd_info->write_fd != 0) close(fd_info->write_fd); } -static int -pipe_check_availability (void) -{ +static int pipe_check_availability(void) { /* Assume that pipes are always available. */ return 1; } const grpc_wakeup_fd_vtable grpc_pipe_wakeup_fd_vtable = { - pipe_init, pipe_consume, pipe_wakeup, pipe_destroy, - pipe_check_availability -}; + pipe_init, pipe_consume, pipe_wakeup, pipe_destroy, + pipe_check_availability}; #endif /* GPR_POSIX_WAKUP_FD */ |