Sha256: 0cf00cf3e41031674e1db4acfa7918ca291d1477966e66efa55256e65784968a
Contents?: true
Size: 1.63 KB
Versions: 5
Compression:
Stored size: 1.63 KB
Contents
/* * * Copyright 2015 gRPC authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * */ #include <grpc/support/port_platform.h> #include "src/core/lib/iomgr/port.h" #ifdef GRPC_POSIX_SOCKETUTILS #include "src/core/lib/iomgr/socket_utils_posix.h" #include <fcntl.h> #include <sys/socket.h> #include <unistd.h> #include <grpc/support/log.h> #include "src/core/lib/iomgr/sockaddr.h" int grpc_accept4(int sockfd, grpc_resolved_address* resolved_addr, int nonblock, int cloexec) { int fd, flags; GPR_ASSERT(sizeof(socklen_t) <= sizeof(size_t)); fd = accept(sockfd, (grpc_sockaddr*)resolved_addr->addr, (socklen_t*)&resolved_addr->len); if (fd >= 0) { if (nonblock) { flags = fcntl(fd, F_GETFL, 0); if (flags < 0) goto close_and_error; if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) != 0) goto close_and_error; } if (cloexec) { flags = fcntl(fd, F_GETFD, 0); if (flags < 0) goto close_and_error; if (fcntl(fd, F_SETFD, flags | FD_CLOEXEC) != 0) goto close_and_error; } } return fd; close_and_error: close(fd); return -1; } #endif /* GRPC_POSIX_SOCKETUTILS */
Version data entries
5 entries across 5 versions & 3 rubygems