|
|
@ -41,9 +41,10 @@ |
|
|
|
#include <string.h> |
|
|
|
#include <string.h> |
|
|
|
#include <unistd.h> |
|
|
|
#include <unistd.h> |
|
|
|
|
|
|
|
|
|
|
|
#include "src/core/iomgr/socket_utils_posix.h" |
|
|
|
|
|
|
|
#include <grpc/support/log.h> |
|
|
|
#include <grpc/support/log.h> |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#include "src/core/iomgr/socket_utils_posix.h" |
|
|
|
|
|
|
|
|
|
|
|
static void pipe_init(grpc_wakeup_fd* fd_info) { |
|
|
|
static void pipe_init(grpc_wakeup_fd* fd_info) { |
|
|
|
int pipefd[2]; |
|
|
|
int pipefd[2]; |
|
|
|
/* TODO(klempner): Make this nonfatal */ |
|
|
|
/* TODO(klempner): Make this nonfatal */ |
|
|
@ -52,7 +53,6 @@ static void pipe_init(grpc_wakeup_fd* fd_info) { |
|
|
|
gpr_log(GPR_ERROR, "pipe creation failed (%d): %s", errno, strerror(errno)); |
|
|
|
gpr_log(GPR_ERROR, "pipe creation failed (%d): %s", errno, strerror(errno)); |
|
|
|
abort(); |
|
|
|
abort(); |
|
|
|
} |
|
|
|
} |
|
|
|
GPR_ASSERT(0 == pipe(pipefd)); |
|
|
|
|
|
|
|
GPR_ASSERT(grpc_set_socket_nonblocking(pipefd[0], 1)); |
|
|
|
GPR_ASSERT(grpc_set_socket_nonblocking(pipefd[0], 1)); |
|
|
|
GPR_ASSERT(grpc_set_socket_nonblocking(pipefd[1], 1)); |
|
|
|
GPR_ASSERT(grpc_set_socket_nonblocking(pipefd[1], 1)); |
|
|
|
fd_info->read_fd = pipefd[0]; |
|
|
|
fd_info->read_fd = pipefd[0]; |
|
|
|