Renamed GPR_ constants to GRPC_ in iomgr/port.h

pull/7665/head
murgatroid99 9 years ago
parent 5407089b37
commit 623dd4f556
  1. 8
      include/grpc/impl/codegen/port_platform.h
  2. 4
      src/core/ext/client_config/parse_address.c
  3. 2
      src/core/ext/client_config/parse_address.h
  4. 6
      src/core/ext/resolver/sockaddr/sockaddr_resolver.c
  5. 2
      src/core/lib/iomgr/endpoint_pair_posix.c
  6. 2
      src/core/lib/iomgr/endpoint_pair_windows.c
  7. 12
      src/core/lib/iomgr/ev_epoll_linux.c
  8. 4
      src/core/lib/iomgr/ev_epoll_linux.h
  9. 14
      src/core/lib/iomgr/ev_poll_and_epoll_posix.c
  10. 2
      src/core/lib/iomgr/ev_poll_posix.c
  11. 4
      src/core/lib/iomgr/ev_posix.c
  12. 4
      src/core/lib/iomgr/iocp_windows.c
  13. 2
      src/core/lib/iomgr/iomgr_posix.c
  14. 2
      src/core/lib/iomgr/iomgr_windows.c
  15. 4
      src/core/lib/iomgr/pollset_set_windows.c
  16. 4
      src/core/lib/iomgr/pollset_windows.c
  17. 124
      src/core/lib/iomgr/port.h
  18. 2
      src/core/lib/iomgr/resolve_address_posix.c
  19. 2
      src/core/lib/iomgr/resolve_address_windows.c
  20. 2
      src/core/lib/iomgr/sockaddr.h
  21. 2
      src/core/lib/iomgr/socket_utils.h
  22. 8
      src/core/lib/iomgr/socket_utils_common_posix.c
  23. 2
      src/core/lib/iomgr/socket_utils_linux.c
  24. 4
      src/core/lib/iomgr/socket_utils_posix.c
  25. 4
      src/core/lib/iomgr/socket_utils_windows.c
  26. 4
      src/core/lib/iomgr/socket_windows.c
  27. 2
      src/core/lib/iomgr/tcp_client_posix.c
  28. 4
      src/core/lib/iomgr/tcp_client_windows.c
  29. 8
      src/core/lib/iomgr/tcp_posix.c
  30. 2
      src/core/lib/iomgr/tcp_server_posix.c
  31. 4
      src/core/lib/iomgr/tcp_server_windows.c
  32. 4
      src/core/lib/iomgr/tcp_windows.c
  33. 2
      src/core/lib/iomgr/udp_server.c
  34. 2
      src/core/lib/iomgr/unix_sockets_posix.c
  35. 2
      src/core/lib/iomgr/unix_sockets_posix_noop.c
  36. 4
      src/core/lib/iomgr/wakeup_fd_eventfd.c
  37. 4
      src/core/lib/iomgr/wakeup_fd_nospecial.c
  38. 2
      src/core/lib/iomgr/wakeup_fd_pipe.c
  39. 4
      src/core/lib/iomgr/wakeup_fd_posix.c
  40. 2
      src/core/lib/iomgr/workqueue.h
  41. 4
      src/core/lib/iomgr/workqueue_posix.c
  42. 2
      test/core/end2end/fixtures/h2_full+trace.c
  43. 2
      test/core/end2end/fixtures/h2_sockpair+trace.c
  44. 6
      test/core/iomgr/ev_epoll_linux_test.c
  45. 4
      test/core/util/port_posix.c
  46. 4
      test/core/util/port_windows.c
  47. 4
      test/cpp/end2end/async_end2end_test.cc

@ -178,8 +178,8 @@
#define GPR_LINUX_LOG
#define GPR_SUPPORT_CHANNELS_FROM_FD 1
#define GPR_LINUX_ENV 1
#ifndef GPR_LINUX_EVENTFD
#define GPR_POSIX_NO_SPECIAL_WAKEUP_FD 1
#ifndef GRPC_LINUX_EVENTFD
#define GRPC_POSIX_NO_SPECIAL_WAKEUP_FD 1
#endif
#define GPR_POSIX_FILE 1
#define GPR_POSIX_TMPFILE 1
@ -348,10 +348,6 @@ typedef unsigned __int64 uint64_t;
#error Must define exactly one of GPR_CPU_LINUX, GPR_CPU_POSIX, GPR_WINDOWS, GPR_CPU_IPHONE, GPR_CPU_CUSTOM
#endif
#if defined(GPR_POSIX_MULTIPOLL_WITH_POLL) && !defined(GPR_POSIX_SOCKET)
#error Must define GPR_POSIX_SOCKET to use GPR_POSIX_MULTIPOLL_WITH_POLL
#endif
#if defined(GPR_MSVC_TLS) + defined(GPR_GCC_TLS) + defined(GPR_PTHREAD_TLS) + \
defined(GPR_CUSTOM_TLS) != \
1

@ -35,7 +35,7 @@
#include <stdio.h>
#include <string.h>
#ifdef GPR_HAVE_UNIX_SOCKET
#ifdef GRPC_HAVE_UNIX_SOCKET
#include <sys/un.h>
#endif
@ -44,7 +44,7 @@
#include <grpc/support/log.h>
#include <grpc/support/string_util.h>
#ifdef GPR_HAVE_UNIX_SOCKET
#ifdef GRPC_HAVE_UNIX_SOCKET
int parse_unix(grpc_uri *uri, struct sockaddr_storage *addr, size_t *len) {
struct sockaddr_un *un = (struct sockaddr_un *)addr;

@ -39,7 +39,7 @@
#include "src/core/ext/client_config/uri_parser.h"
#include "src/core/lib/iomgr/sockaddr.h"
#ifdef GPR_HAVE_UNIX_SOCKET
#ifdef GRPC_HAVE_UNIX_SOCKET
/** Populate \a addr and \a len from \a uri, whose path is expected to contain a
* unix socket path. Returns true upon success. */
int parse_unix(grpc_uri *uri, struct sockaddr_storage *addr, size_t *len);

@ -163,7 +163,7 @@ static char *ipv6_get_default_authority(grpc_resolver_factory *factory,
return ip_get_default_authority(uri);
}
#ifdef GPR_HAVE_UNIX_SOCKET
#ifdef GRPC_HAVE_UNIX_SOCKET
char *unix_get_default_authority(grpc_resolver_factory *factory,
grpc_uri *uri) {
return gpr_strdup("localhost");
@ -271,7 +271,7 @@ static void sockaddr_factory_unref(grpc_resolver_factory *factory) {}
static grpc_resolver_factory name##_resolver_factory = { \
&name##_factory_vtable}
#ifdef GPR_HAVE_UNIX_SOCKET
#ifdef GRPC_HAVE_UNIX_SOCKET
DECL_FACTORY(unix);
#endif
DECL_FACTORY(ipv4);
@ -280,7 +280,7 @@ DECL_FACTORY(ipv6);
void grpc_resolver_sockaddr_init(void) {
grpc_register_resolver_type(&ipv4_resolver_factory);
grpc_register_resolver_type(&ipv6_resolver_factory);
#ifdef GPR_HAVE_UNIX_SOCKET
#ifdef GRPC_HAVE_UNIX_SOCKET
grpc_register_resolver_type(&unix_resolver_factory);
#endif
}

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/endpoint_pair.h"
#include "src/core/lib/iomgr/socket_utils_posix.h"

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include "src/core/lib/iomgr/endpoint_pair.h"
#include "src/core/lib/iomgr/sockaddr_utils.h"

@ -35,7 +35,7 @@
#include "src/core/lib/iomgr/port.h"
/* This polling engine is only relevant on linux kernels supporting epoll() */
#ifdef GPR_LINUX_EPOLL
#ifdef GRPC_LINUX_EPOLL
#include "src/core/lib/iomgr/ev_epoll_linux.h"
@ -1905,13 +1905,13 @@ const grpc_event_engine_vtable *grpc_init_epoll_linux(void) {
return &vtable;
}
#else /* defined(GPR_LINUX_EPOLL) */
#if defined(GPR_POSIX_SOCKET)
#else /* defined(GRPC_LINUX_EPOLL) */
#if defined(GRPC_POSIX_SOCKET)
#include "src/core/lib/iomgr/ev_posix.h"
/* If GPR_LINUX_EPOLL is not defined, it means epoll is not available. Return
/* If GRPC_LINUX_EPOLL is not defined, it means epoll is not available. Return
* NULL */
const grpc_event_engine_vtable *grpc_init_epoll_linux(void) { return NULL; }
#endif /* defined(GPR_POSIX_SOCKET) */
#endif /* defined(GRPC_POSIX_SOCKET) */
void grpc_use_signal(int signum) {}
#endif /* !defined(GPR_LINUX_EPOLL) */
#endif /* !defined(GRPC_LINUX_EPOLL) */

@ -39,10 +39,10 @@
const grpc_event_engine_vtable *grpc_init_epoll_linux(void);
#ifdef GPR_LINUX_EPOLL
#ifdef GRPC_LINUX_EPOLL
void *grpc_fd_get_polling_island(grpc_fd *fd);
void *grpc_pollset_get_polling_island(grpc_pollset *ps);
bool grpc_are_polling_islands_equal(void *p, void *q);
#endif /* defined(GPR_LINUX_EPOLL) */
#endif /* defined(GRPC_LINUX_EPOLL) */
#endif /* GRPC_CORE_LIB_IOMGR_EV_EPOLL_LINUX_H */

@ -44,7 +44,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/ev_poll_and_epoll_posix.h"
@ -1338,7 +1338,7 @@ static void become_basic_pollset(grpc_pollset *pollset, grpc_fd *fd_or_null) {
* pollset_multipoller_with_poll_posix.c
*/
#ifndef GPR_LINUX_MULTIPOLL_WITH_EPOLL
#ifndef GRPC_LINUX_MULTIPOLL_WITH_EPOLL
typedef struct {
/* all polled fds */
@ -1520,13 +1520,13 @@ static void poll_become_multipoller(grpc_exec_ctx *exec_ctx,
}
}
#endif /* !GPR_LINUX_MULTIPOLL_WITH_EPOLL */
#endif /* !GRPC_LINUX_MULTIPOLL_WITH_EPOLL */
/*******************************************************************************
* pollset_multipoller_with_epoll_posix.c
*/
#ifdef GPR_LINUX_MULTIPOLL_WITH_EPOLL
#ifdef GRPC_LINUX_MULTIPOLL_WITH_EPOLL
#include <errno.h>
#include <poll.h>
@ -1839,11 +1839,11 @@ static void epoll_become_multipoller(grpc_exec_ctx *exec_ctx,
}
}
#else /* GPR_LINUX_MULTIPOLL_WITH_EPOLL */
#else /* GRPC_LINUX_MULTIPOLL_WITH_EPOLL */
static void remove_fd_from_all_epoll_sets(int fd) {}
#endif /* GPR_LINUX_MULTIPOLL_WITH_EPOLL */
#endif /* GRPC_LINUX_MULTIPOLL_WITH_EPOLL */
/*******************************************************************************
* pollset_set_posix.c
@ -2033,7 +2033,7 @@ static const grpc_event_engine_vtable vtable = {
};
const grpc_event_engine_vtable *grpc_init_poll_and_epoll_posix(void) {
#ifdef GPR_LINUX_MULTIPOLL_WITH_EPOLL
#ifdef GRPC_LINUX_MULTIPOLL_WITH_EPOLL
platform_become_multipoller = epoll_become_multipoller;
#else
platform_become_multipoller = poll_become_multipoller;

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/ev_poll_posix.h"

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/ev_posix.h"
@ -258,4 +258,4 @@ void grpc_pollset_set_del_fd(grpc_exec_ctx *exec_ctx,
grpc_error *grpc_kick_poller(void) { return g_event_engine->kick_poller(); }
#endif // GPR_POSIX_SOCKET
#endif // GRPC_POSIX_SOCKET

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include <winsock2.h>
@ -166,4 +166,4 @@ void grpc_iocp_add_socket(grpc_winsocket *socket) {
GPR_ASSERT(ret == g_iocp);
}
#endif /* GPR_WINSOCK_SOCKET */
#endif /* GRPC_WINSOCK_SOCKET */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/iomgr/ev_posix.h"

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include "src/core/lib/iomgr/sockaddr_windows.h"

@ -34,7 +34,7 @@
#include "src/core/lib/iomgr/port.h"
#include <stdint.h>
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include "src/core/lib/iomgr/pollset_set_windows.h"
@ -60,4 +60,4 @@ void grpc_pollset_set_del_pollset_set(grpc_exec_ctx* exec_ctx,
grpc_pollset_set* bag,
grpc_pollset_set* item) {}
#endif /* GPR_WINSOCK_SOCKET */
#endif /* GRPC_WINSOCK_SOCKET */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include <grpc/support/log.h>
#include <grpc/support/thd.h>
@ -241,4 +241,4 @@ grpc_error *grpc_pollset_kick(grpc_pollset *p,
void grpc_kick_poller(void) { grpc_iocp_kick(); }
#endif /* GPR_WINSOCK_SOCKET */
#endif /* GRPC_WINSOCK_SOCKET */

@ -37,88 +37,86 @@
#define GRPC_CORE_LIB_IOMGR_PORT_H
#if defined(GPR_WINDOWS)
#define GPR_WINSOCK_SOCKET 1
#define GPR_WINDOWS_SOCKETUTILS 1
/* #undef GPR_POSIX_SOCKET */
/* #undef GPR_POSIX_WAKEUP_FD */
#define GRPC_WINSOCK_SOCKET 1
#define GRPC_WINDOWS_SOCKETUTILS 1
#elif defined(GPR_MANYLINUX1)
#define GPR_HAVE_IPV6_RECVPKTINFO 1
#define GPR_HAVE_IP_PKTINFO 1
#define GPR_HAVE_MSG_NOSIGNAL 1
#define GPR_HAVE_UNIX_SOCKET 1
#define GPR_POSIX_NO_SPECIAL_WAKEUP_FD 1
#define GPR_POSIX_SOCKET 1
#define GPR_POSIX_SOCKETADDR 1
#define GPR_POSIX_SOCKETUTILS 1
#define GPR_POSIX_WAKEUP_FD 1
#define GRPC_HAVE_IPV6_RECVPKTINFO 1
#define GRPC_HAVE_IP_PKTINFO 1
#define GRPC_HAVE_MSG_NOSIGNAL 1
#define GRPC_HAVE_UNIX_SOCKET 1
#define GRPC_POSIX_NO_SPECIAL_WAKEUP_FD 1
#define GRPC_POSIX_SOCKET 1
#define GRPC_POSIX_SOCKETADDR 1
#define GRPC_POSIX_SOCKETUTILS 1
#define GRPC_POSIX_WAKEUP_FD 1
#elif defined(GPR_ANDROID)
#define GPR_HAVE_IPV6_RECVPKTINFO 1
#define GPR_HAVE_IP_PKTINFO 1
#define GPR_HAVE_MSG_NOSIGNAL 1
#define GPR_HAVE_UNIX_SOCKET 1
#define GPR_LINUX_EVENTFD 1
#define GPR_POSIX_SOCKET 1
#define GPR_POSIX_SOCKETADDR 1
#define GPR_POSIX_SOCKETUTILS 1
#define GPR_POSIX_WAKEUP_FD 1
#define GRPC_HAVE_IPV6_RECVPKTINFO 1
#define GRPC_HAVE_IP_PKTINFO 1
#define GRPC_HAVE_MSG_NOSIGNAL 1
#define GRPC_HAVE_UNIX_SOCKET 1
#define GRPC_LINUX_EVENTFD 1
#define GRPC_POSIX_SOCKET 1
#define GRPC_POSIX_SOCKETADDR 1
#define GRPC_POSIX_SOCKETUTILS 1
#define GRPC_POSIX_WAKEUP_FD 1
#elif defined(GPR_LINUX)
#define GPR_HAVE_IPV6_RECVPKTINFO 1
#define GPR_HAVE_IP_PKTINFO 1
#define GPR_HAVE_MSG_NOSIGNAL 1
#define GPR_HAVE_UNIX_SOCKET 1
#define GPR_LINUX_MULTIPOLL_WITH_EPOLL 1
#define GPR_POSIX_SOCKET 1
#define GPR_POSIX_SOCKETADDR 1
#define GPR_POSIX_WAKEUP_FD 1
#define GRPC_HAVE_IPV6_RECVPKTINFO 1
#define GRPC_HAVE_IP_PKTINFO 1
#define GRPC_HAVE_MSG_NOSIGNAL 1
#define GRPC_HAVE_UNIX_SOCKET 1
#define GRPC_LINUX_MULTIPOLL_WITH_EPOLL 1
#define GRPC_POSIX_SOCKET 1
#define GRPC_POSIX_SOCKETADDR 1
#define GRPC_POSIX_WAKEUP_FD 1
#ifdef __GLIBC_PREREQ
#if __GLIBC_PREREQ(2, 9)
#define GPR_LINUX_EPOLL 1
#define GPR_LINUX_EVENTFD 1
#define GRPC_LINUX_EPOLL 1
#define GRPC_LINUX_EVENTFD 1
#endif
#if __GLIBC_PREREQ(2, 10)
#define GPR_LINUX_SOCKETUTILS 1
#define GRPC_LINUX_SOCKETUTILS 1
#endif
#endif
#ifndef GPR_LINUX_EVENTFD
#define GPR_POSIX_NO_SPECIAL_WAKEUP_FD 1
#ifndef GRPC_LINUX_EVENTFD
#define GRPC_POSIX_NO_SPECIAL_WAKEUP_FD 1
#endif
#ifndef GPR_LINUX_SOCKETUTILS
#define GPR_POSIX_SOCKETUTILS
#ifndef GRPC_LINUX_SOCKETUTILS
#define GRPC_POSIX_SOCKETUTILS
#endif
#elif defined(GPR_APPLE)
#define GPR_HAVE_IP_PKTINFO 1
#define GPR_HAVE_SO_NOSIGPIPE 1
#define GPR_HAVE_UNIX_SOCKET 1
#define GPR_MSG_IOVLEN_TYPE int
#define GPR_POSIX_NO_SPECIAL_WAKEUP_FD 1
#define GPR_POSIX_SOCKET 1
#define GPR_POSIX_SOCKETADDR 1
#define GPR_POSIX_SOCKETUTILS 1
#define GPR_POSIX_WAKEUP_FD 1
#define GRPC_HAVE_IP_PKTINFO 1
#define GRPC_HAVE_SO_NOSIGPIPE 1
#define GRPC_HAVE_UNIX_SOCKET 1
#define GRPC_MSG_IOVLEN_TYPE int
#define GRPC_POSIX_NO_SPECIAL_WAKEUP_FD 1
#define GRPC_POSIX_SOCKET 1
#define GRPC_POSIX_SOCKETADDR 1
#define GRPC_POSIX_SOCKETUTILS 1
#define GRPC_POSIX_WAKEUP_FD 1
#elif defined(GPR_FREEBSD)
#define GPR_HAVE_IPV6_RECVPKTINFO 1
#define GPR_HAVE_IP_PKTINFO 1
#define GPR_HAVE_SO_NOSIGPIPE 1
#define GPR_HAVE_UNIX_SOCKET 1
#define GPR_POSIX_NO_SPECIAL_WAKEUP_FD 1
#define GPR_POSIX_SOCKET 1
#define GPR_POSIX_SOCKETADDR 1
#define GPR_POSIX_SOCKETUTILS 1
#define GPR_POSIX_WAKEUP_FD 1
#define GRPC_HAVE_IPV6_RECVPKTINFO 1
#define GRPC_HAVE_IP_PKTINFO 1
#define GRPC_HAVE_SO_NOSIGPIPE 1
#define GRPC_HAVE_UNIX_SOCKET 1
#define GRPC_POSIX_NO_SPECIAL_WAKEUP_FD 1
#define GRPC_POSIX_SOCKET 1
#define GRPC_POSIX_SOCKETADDR 1
#define GRPC_POSIX_SOCKETUTILS 1
#define GRPC_POSIX_WAKEUP_FD 1
#elif defined(GPR_NACL)
#define GPR_POSIX_NO_SPECIAL_WAKEUP_FD 1
#define GPR_POSIX_SOCKET 1
#define GPR_POSIX_SOCKETADDR 1
#define GPR_POSIX_SOCKETUTILS 1
#define GPR_POSIX_WAKEUP_FD 1
#define GRPC_POSIX_NO_SPECIAL_WAKEUP_FD 1
#define GRPC_POSIX_SOCKET 1
#define GRPC_POSIX_SOCKETADDR 1
#define GRPC_POSIX_SOCKETUTILS 1
#define GRPC_POSIX_WAKEUP_FD 1
#elif !defined(GPR_NO_AUTODETECT_PLATFORM)
#error "Platform not recognized"
#endif
#if defined(GPR_POSIX_SOCKET) + defined(GPR_WINSOCK_SOCKET) + \
defined(GPR_CUSTOM_SOCKET) != \
#if defined(GRPC_POSIX_SOCKET) + defined(GRPC_WINSOCK_SOCKET) + \
defined(GRPC_CUSTOM_SOCKET) != \
1
#error Must define exactly one of GPR_POSIX_SOCKET, GPR_WINSOCK_SOCKET, GPR_CUSTOM_SOCKET
#error Must define exactly one of GRPC_POSIX_SOCKET, GRPC_WINSOCK_SOCKET, GPR_CUSTOM_SOCKET
#endif
#endif /* GRPC_CORE_LIB_IOMGR_PORT_H */

@ -32,7 +32,7 @@
*/
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/resolve_address.h"
#include "src/core/lib/iomgr/sockaddr.h"

@ -32,7 +32,7 @@
*/
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include "src/core/lib/iomgr/resolve_address.h"
#include "src/core/lib/iomgr/sockaddr.h"

@ -40,7 +40,7 @@
#include "src/core/lib/iomgr/sockaddr_windows.h"
#endif
#ifdef GPR_POSIX_SOCKETADDR
#ifdef GRPC_POSIX_SOCKETADDR
#include "src/core/lib/iomgr/sockaddr_posix.h"
#endif

@ -36,7 +36,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include "sockaddr_windows.h"
#else
#include "sockaddr_posix.h"

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/socket_utils.h"
#include "src/core/lib/iomgr/socket_utils_posix.h"
@ -79,7 +79,7 @@ grpc_error *grpc_set_socket_nonblocking(int fd, int non_blocking) {
}
grpc_error *grpc_set_socket_no_sigpipe_if_possible(int fd) {
#ifdef GPR_HAVE_SO_NOSIGPIPE
#ifdef GRPC_HAVE_SO_NOSIGPIPE
int val = 1;
int newval;
socklen_t intlen = sizeof(newval);
@ -97,7 +97,7 @@ grpc_error *grpc_set_socket_no_sigpipe_if_possible(int fd) {
}
grpc_error *grpc_set_socket_ip_pktinfo_if_possible(int fd) {
#ifdef GPR_HAVE_IP_PKTINFO
#ifdef GRPC_HAVE_IP_PKTINFO
int get_local_ip = 1;
if (0 != setsockopt(fd, IPPROTO_IP, IP_PKTINFO, &get_local_ip,
sizeof(get_local_ip))) {
@ -108,7 +108,7 @@ grpc_error *grpc_set_socket_ip_pktinfo_if_possible(int fd) {
}
grpc_error *grpc_set_socket_ipv6_recvpktinfo_if_possible(int fd) {
#ifdef GPR_HAVE_IPV6_RECVPKTINFO
#ifdef GRPC_HAVE_IPV6_RECVPKTINFO
int get_local_ip = 1;
if (0 != setsockopt(fd, IPPROTO_IPV6, IPV6_RECVPKTINFO, &get_local_ip,
sizeof(get_local_ip))) {

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_LINUX_SOCKETUTILS
#ifdef GRPC_LINUX_SOCKETUTILS
#include "src/core/lib/iomgr/socket_utils_posix.h"

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKETUTILS
#ifdef GRPC_POSIX_SOCKETUTILS
#include "src/core/lib/iomgr/socket_utils_posix.h"
@ -67,4 +67,4 @@ close_and_error:
return -1;
}
#endif /* GPR_POSIX_SOCKETUTILS */
#endif /* GRPC_POSIX_SOCKETUTILS */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINDOWS_SOCKETUTILS
#ifdef GRPC_WINDOWS_SOCKETUTILS
#include "src/core/lib/iomgr/socket_utils.h"
@ -45,4 +45,4 @@ const char *grpc_inet_ntop(int af, const void *src,
return InetNtop(af, src, dst, (size_t)size);
}
#endif /* GPR_WINDOWS_SOCKETUTILS */
#endif /* GRPC_WINDOWS_SOCKETUTILS */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include <winsock2.h>
@ -156,4 +156,4 @@ void grpc_socket_become_ready(grpc_exec_ctx *exec_ctx, grpc_winsocket *socket,
if (should_destroy) destroy(socket);
}
#endif /* GPR_WINSOCK_SOCKET */
#endif /* GRPC_WINSOCK_SOCKET */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/tcp_client.h"

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include "src/core/lib/iomgr/sockaddr_windows.h"
@ -228,4 +228,4 @@ failure:
grpc_exec_ctx_sched(exec_ctx, on_done, final_error, NULL);
}
#endif /* GPR_WINSOCK_SOCKET */
#endif /* GRPC_WINSOCK_SOCKET */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/network_status_tracker.h"
#include "src/core/lib/iomgr/tcp_posix.h"
@ -58,14 +58,14 @@
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/support/string.h"
#ifdef GPR_HAVE_MSG_NOSIGNAL
#ifdef GRPC_HAVE_MSG_NOSIGNAL
#define SENDMSG_FLAGS MSG_NOSIGNAL
#else
#define SENDMSG_FLAGS 0
#endif
#ifdef GPR_MSG_IOVLEN_TYPE
typedef GPR_MSG_IOVLEN_TYPE msg_iovlen_type;
#ifdef GRPC_MSG_IOVLEN_TYPE
typedef GRPC_MSG_IOVLEN_TYPE msg_iovlen_type;
#else
typedef size_t msg_iovlen_type;
#endif

@ -38,7 +38,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/tcp_server.h"

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include <io.h>
@ -543,4 +543,4 @@ void grpc_tcp_server_start(grpc_exec_ctx *exec_ctx, grpc_tcp_server *s,
void grpc_tcp_server_shutdown_listeners(grpc_exec_ctx *exec_ctx,
grpc_tcp_server *s) {}
#endif /* GPR_WINSOCK_SOCKET */
#endif /* GRPC_WINSOCK_SOCKET */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_WINSOCK_SOCKET
#ifdef GRPC_WINSOCK_SOCKET
#include <limits.h>
@ -416,4 +416,4 @@ grpc_endpoint *grpc_tcp_create(grpc_winsocket *socket, char *peer_string) {
return &tcp->base;
}
#endif /* GPR_WINSOCK_SOCKET */
#endif /* GRPC_WINSOCK_SOCKET */

@ -39,7 +39,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GRPC_NEED_UDP
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/udp_server.h"

@ -32,7 +32,7 @@
*/
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_HAVE_UNIX_SOCKET
#ifdef GRPC_HAVE_UNIX_SOCKET
#include <string.h>
#include <sys/stat.h>

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/unix_sockets_posix.h"
#ifndef GPR_HAVE_UNIX_SOCKET
#ifndef GRPC_HAVE_UNIX_SOCKET
#include <grpc/support/log.h>

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_LINUX_EVENTFD
#ifdef GRPC_LINUX_EVENTFD
#include <errno.h>
#include <sys/eventfd.h>
@ -94,4 +94,4 @@ const grpc_wakeup_fd_vtable grpc_specialized_wakeup_fd_vtable = {
eventfd_create, eventfd_consume, eventfd_wakeup, eventfd_destroy,
eventfd_check_availability};
#endif /* GPR_LINUX_EVENTFD */
#endif /* GRPC_LINUX_EVENTFD */

@ -38,7 +38,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_NO_SPECIAL_WAKEUP_FD
#ifdef GRPC_POSIX_NO_SPECIAL_WAKEUP_FD
#include <stddef.h>
#include "src/core/lib/iomgr/wakeup_fd_posix.h"
@ -48,4 +48,4 @@ static int check_availability_invalid(void) { return 0; }
const grpc_wakeup_fd_vtable grpc_specialized_wakeup_fd_vtable = {
NULL, NULL, NULL, NULL, check_availability_invalid};
#endif /* GPR_POSIX_NO_SPECIAL_WAKEUP_FD */
#endif /* GRPC_POSIX_NO_SPECIAL_WAKEUP_FD */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_WAKEUP_FD
#ifdef GRPC_POSIX_WAKEUP_FD
#include "src/core/lib/iomgr/wakeup_fd_posix.h"

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_WAKEUP_FD
#ifdef GRPC_POSIX_WAKEUP_FD
#include <stddef.h>
#include "src/core/lib/iomgr/wakeup_fd_pipe.h"
@ -69,4 +69,4 @@ void grpc_wakeup_fd_destroy(grpc_wakeup_fd *fd_info) {
wakeup_fd_vtable->destroy(fd_info);
}
#endif /* GPR_POSIX_WAKEUP_FD */
#endif /* GRPC_POSIX_WAKEUP_FD */

@ -41,7 +41,7 @@
#include "src/core/lib/iomgr/pollset_set.h"
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/workqueue_posix.h"
#endif

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/workqueue.h"
@ -148,4 +148,4 @@ void grpc_workqueue_enqueue(grpc_exec_ctx *exec_ctx, grpc_workqueue *workqueue,
gpr_mu_unlock(&workqueue->mu);
}
#endif /* GPR_POSIX_SOCKET */
#endif /* GRPC_POSIX_SOCKET */

@ -110,7 +110,7 @@ int main(int argc, char **argv) {
code paths in trace.c to be taken */
gpr_setenv("GRPC_TRACE", "doesnt-exist,http,all");
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
g_fixture_slowdown_factor = isatty(STDOUT_FILENO) ? 10.0 : 1.0;
#else
g_fixture_slowdown_factor = 10.0;

@ -147,7 +147,7 @@ int main(int argc, char **argv) {
/* force tracing on, with a value to force many
code paths in trace.c to be taken */
gpr_setenv("GRPC_TRACE", "doesnt-exist,http,all");
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
g_fixture_slowdown_factor = isatty(STDOUT_FILENO) ? 10.0 : 1.0;
#else
g_fixture_slowdown_factor = 10.0;

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
/* This test only relevant on linux systems where epoll() is available */
#ifdef GPR_LINUX_EPOLL
#ifdef GRPC_LINUX_EPOLL
#include "src/core/lib/iomgr/ev_epoll_linux.h"
#include "src/core/lib/iomgr/ev_posix.h"
@ -239,6 +239,6 @@ int main(int argc, char **argv) {
grpc_iomgr_shutdown();
return 0;
}
#else /* defined(GPR_LINUX_EPOLL) */
#else /* defined(GRPC_LINUX_EPOLL) */
int main(int argc, char **argv) { return 0; }
#endif /* !defined(GPR_LINUX_EPOLL) */
#endif /* !defined(GRPC_LINUX_EPOLL) */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#include "test/core/util/test_config.h"
#if defined(GPR_POSIX_SOCKET) && defined(GRPC_TEST_PICK_PORT)
#if defined(GRPC_POSIX_SOCKET) && defined(GRPC_TEST_PICK_PORT)
#include "test/core/util/port.h"
@ -237,4 +237,4 @@ int grpc_pick_unused_port_or_die(void) {
void grpc_recycle_unused_port(int port) { GPR_ASSERT(free_chosen_port(port)); }
#endif /* GPR_POSIX_SOCKET && GRPC_TEST_PICK_PORT */
#endif /* GRPC_POSIX_SOCKET && GRPC_TEST_PICK_PORT */

@ -33,7 +33,7 @@
#include "src/core/lib/iomgr/port.h"
#include "test/core/util/test_config.h"
#if defined(GPR_WINSOCK_SOCKET) && defined(GRPC_TEST_PICK_PORT)
#if defined(GRPC_WINSOCK_SOCKET) && defined(GRPC_TEST_PICK_PORT)
#include "test/core/util/port.h"
@ -242,4 +242,4 @@ int grpc_pick_unused_port_or_die(void) {
void grpc_recycle_unused_port(int port) { GPR_ASSERT(free_chosen_port(port)); }
#endif /* GPR_WINSOCK_SOCKET && GRPC_TEST_PICK_PORT */
#endif /* GRPC_WINSOCK_SOCKET && GRPC_TEST_PICK_PORT */

@ -55,7 +55,7 @@
#include "test/cpp/util/string_ref_helper.h"
#include "test/cpp/util/test_credentials_provider.h"
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
#include "src/core/lib/iomgr/ev_posix.h"
#endif
@ -74,7 +74,7 @@ namespace {
void* tag(int i) { return (void*)(intptr_t)i; }
int detag(void* p) { return static_cast<int>(reinterpret_cast<intptr_t>(p)); }
#ifdef GPR_POSIX_SOCKET
#ifdef GRPC_POSIX_SOCKET
static int maybe_assert_non_blocking_poll(struct pollfd* pfds, nfds_t nfds,
int timeout) {
if (gpr_tls_get(&g_is_async_end2end_test)) {

Loading…
Cancel
Save