aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/iomgr/wakeup_fd_pipe.c
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-09-22 12:33:20 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-09-22 12:33:20 -0700
commita82950e68318a6aab6fe894fa39f7fa616c4647b (patch)
tree7d02bd1e9e1cbae1f14ad4ad1e06d3ae81a96dfe /src/core/iomgr/wakeup_fd_pipe.c
parent8af4c337181322cc4fb396199c90f574cfb4163f (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.c69
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 */