Fix includes

pull/5964/head
Craig Tiller 9 years ago
parent 8a9fd52b71
commit 9533d042d4
  1. 2
      src/core/lib/census/context.c
  2. 4
      src/core/lib/census/grpc_context.c
  3. 10
      src/core/lib/census/grpc_filter.c
  4. 2
      src/core/lib/census/grpc_filter.h
  5. 8
      src/core/lib/census/grpc_plugin.c
  6. 2
      src/core/lib/census/mlog.c
  7. 4
      src/core/lib/channel/channel_args.c
  8. 2
      src/core/lib/channel/channel_stack.c
  9. 4
      src/core/lib/channel/channel_stack.h
  10. 2
      src/core/lib/channel/channel_stack_builder.c
  11. 4
      src/core/lib/channel/channel_stack_builder.h
  12. 18
      src/core/lib/channel/client_channel.c
  13. 4
      src/core/lib/channel/client_channel.h
  14. 14
      src/core/lib/channel/compress_filter.c
  15. 2
      src/core/lib/channel/compress_filter.h
  16. 8
      src/core/lib/channel/connected_channel.c
  17. 2
      src/core/lib/channel/connected_channel.h
  18. 8
      src/core/lib/channel/http_client_filter.c
  19. 2
      src/core/lib/channel/http_client_filter.h
  20. 6
      src/core/lib/channel/http_server_filter.c
  21. 2
      src/core/lib/channel/http_server_filter.h
  22. 4
      src/core/lib/channel/subchannel_call_holder.c
  23. 2
      src/core/lib/channel/subchannel_call_holder.h
  24. 2
      src/core/lib/client_config/client_config.c
  25. 2
      src/core/lib/client_config/client_config.h
  26. 2
      src/core/lib/client_config/connector.c
  27. 6
      src/core/lib/client_config/connector.h
  28. 2
      src/core/lib/client_config/default_initial_connect_string.c
  29. 2
      src/core/lib/client_config/initial_connect_string.c
  30. 2
      src/core/lib/client_config/initial_connect_string.h
  31. 2
      src/core/lib/client_config/lb_policies/load_balancer_api.c
  32. 4
      src/core/lib/client_config/lb_policies/load_balancer_api.h
  33. 6
      src/core/lib/client_config/lb_policies/pick_first.c
  34. 2
      src/core/lib/client_config/lb_policies/pick_first.h
  35. 4
      src/core/lib/client_config/lb_policies/round_robin.c
  36. 4
      src/core/lib/client_config/lb_policies/round_robin.h
  37. 2
      src/core/lib/client_config/lb_policy.c
  38. 4
      src/core/lib/client_config/lb_policy.h
  39. 2
      src/core/lib/client_config/lb_policy_factory.c
  40. 4
      src/core/lib/client_config/lb_policy_factory.h
  41. 2
      src/core/lib/client_config/lb_policy_registry.c
  42. 2
      src/core/lib/client_config/lb_policy_registry.h
  43. 2
      src/core/lib/client_config/resolver.c
  44. 6
      src/core/lib/client_config/resolver.h
  45. 2
      src/core/lib/client_config/resolver_factory.c
  46. 6
      src/core/lib/client_config/resolver_factory.h
  47. 2
      src/core/lib/client_config/resolver_registry.c
  48. 2
      src/core/lib/client_config/resolver_registry.h
  49. 12
      src/core/lib/client_config/resolvers/dns_resolver.c
  50. 2
      src/core/lib/client_config/resolvers/dns_resolver.h
  51. 10
      src/core/lib/client_config/resolvers/sockaddr_resolver.c
  52. 2
      src/core/lib/client_config/resolvers/sockaddr_resolver.h
  53. 14
      src/core/lib/client_config/resolvers/zookeeper_resolver.c
  54. 2
      src/core/lib/client_config/resolvers/zookeeper_resolver.h
  55. 24
      src/core/lib/client_config/subchannel.c
  56. 6
      src/core/lib/client_config/subchannel.h
  57. 2
      src/core/lib/client_config/subchannel_factory.c
  58. 4
      src/core/lib/client_config/subchannel_factory.h
  59. 4
      src/core/lib/client_config/subchannel_index.c
  60. 4
      src/core/lib/client_config/subchannel_index.h
  61. 2
      src/core/lib/client_config/uri_parser.c
  62. 2
      src/core/lib/compression/algorithm_metadata.h
  63. 6
      src/core/lib/compression/compression_algorithm.c
  64. 2
      src/core/lib/compression/message_compress.c
  65. 4
      src/core/lib/debug/trace.c
  66. 4
      src/core/lib/http/format_request.c
  67. 2
      src/core/lib/http/format_request.h
  68. 18
      src/core/lib/http/httpcli.c
  69. 8
      src/core/lib/http/httpcli.h
  70. 8
      src/core/lib/http/httpcli_security_connector.c
  71. 2
      src/core/lib/http/parser.c
  72. 2
      src/core/lib/iomgr/closure.c
  73. 2
      src/core/lib/iomgr/endpoint.c
  74. 4
      src/core/lib/iomgr/endpoint.h
  75. 2
      src/core/lib/iomgr/endpoint_pair.h
  76. 10
      src/core/lib/iomgr/endpoint_pair_posix.c
  77. 8
      src/core/lib/iomgr/endpoint_pair_windows.c
  78. 4
      src/core/lib/iomgr/exec_ctx.c
  79. 2
      src/core/lib/iomgr/exec_ctx.h
  80. 4
      src/core/lib/iomgr/executor.c
  81. 2
      src/core/lib/iomgr/executor.h
  82. 4
      src/core/lib/iomgr/fd_posix.c
  83. 4
      src/core/lib/iomgr/fd_posix.h
  84. 8
      src/core/lib/iomgr/iocp_windows.c
  85. 2
      src/core/lib/iomgr/iocp_windows.h
  86. 12
      src/core/lib/iomgr/iomgr.c
  87. 2
      src/core/lib/iomgr/iomgr_internal.h
  88. 8
      src/core/lib/iomgr/iomgr_posix.c
  89. 2
      src/core/lib/iomgr/iomgr_posix.h
  90. 8
      src/core/lib/iomgr/iomgr_windows.c
  91. 2
      src/core/lib/iomgr/pollset.h
  92. 8
      src/core/lib/iomgr/pollset_multipoller_with_epoll.c
  93. 10
      src/core/lib/iomgr/pollset_multipoller_with_poll_posix.c
  94. 12
      src/core/lib/iomgr/pollset_posix.c
  95. 8
      src/core/lib/iomgr/pollset_posix.h
  96. 2
      src/core/lib/iomgr/pollset_set.h
  97. 4
      src/core/lib/iomgr/pollset_set_posix.c
  98. 4
      src/core/lib/iomgr/pollset_set_posix.h
  99. 2
      src/core/lib/iomgr/pollset_set_windows.c
  100. 2
      src/core/lib/iomgr/pollset_set_windows.h
  101. Some files were not shown because too many files have changed in this diff Show More

@ -38,7 +38,7 @@
#include <grpc/support/useful.h>
#include <stdbool.h>
#include <string.h>
#include "src/core/support/string.h"
#include "src/core/lib/support/string.h"
// Functions in this file support the public context API, including
// encoding/decoding as part of context propagation across RPC's. The overall

@ -33,8 +33,8 @@
#include <grpc/census.h>
#include <grpc/grpc.h>
#include "src/core/surface/api_trace.h"
#include "src/core/surface/call.h"
#include "src/core/lib/surface/api_trace.h"
#include "src/core/lib/surface/call.h"
void grpc_census_call_set_context(grpc_call *call, census_context *context) {
GRPC_API_TRACE("grpc_census_call_set_context(call=%p, census_context=%p)", 2,

@ -31,7 +31,7 @@
*
*/
#include "src/core/census/grpc_filter.h"
#include "src/core/lib/census/grpc_filter.h"
#include <stdio.h>
#include <string.h>
@ -42,10 +42,10 @@
#include <grpc/support/slice.h>
#include <grpc/support/time.h>
#include "src/core/channel/channel_stack.h"
#include "src/core/statistics/census_interface.h"
#include "src/core/statistics/census_rpc_stats.h"
#include "src/core/transport/static_metadata.h"
#include "src/core/lib/channel/channel_stack.h"
#include "src/core/lib/statistics/census_interface.h"
#include "src/core/lib/statistics/census_rpc_stats.h"
#include "src/core/lib/transport/static_metadata.h"
typedef struct call_data {
census_op_id op_id;

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CENSUS_GRPC_FILTER_H
#define GRPC_CORE_LIB_CENSUS_GRPC_FILTER_H
#include "src/core/channel/channel_stack.h"
#include "src/core/lib/channel/channel_stack.h"
/* Census filters: provides tracing and stats collection functionalities. It
needs to reside right below the surface filter in the channel stack. */

@ -31,15 +31,15 @@
*
*/
#include "src/core/census/grpc_plugin.h"
#include "src/core/lib/census/grpc_plugin.h"
#include <limits.h>
#include <grpc/census.h>
#include "src/core/census/grpc_filter.h"
#include "src/core/channel/channel_stack_builder.h"
#include "src/core/surface/channel_init.h"
#include "src/core/lib/census/grpc_filter.h"
#include "src/core/lib/channel/channel_stack_builder.h"
#include "src/core/lib/surface/channel_init.h"
static bool maybe_add_census_filter(grpc_channel_stack_builder *builder,
void *arg_must_be_null) {

@ -88,7 +88,7 @@
// include the name of the structure, which will be passed as the first
// argument. E.g. cl_block_initialize() will initialize a cl_block.
#include "src/core/census/mlog.h"
#include "src/core/lib/census/mlog.h"
#include <grpc/support/alloc.h>
#include <grpc/support/atm.h>
#include <grpc/support/cpu.h>

@ -31,9 +31,9 @@
*
*/
#include "src/core/channel/channel_args.h"
#include "src/core/lib/channel/channel_args.h"
#include <grpc/grpc.h>
#include "src/core/support/string.h"
#include "src/core/lib/support/string.h"
#include <grpc/census.h>
#include <grpc/support/alloc.h>

@ -31,7 +31,7 @@
*
*/
#include "src/core/channel/channel_stack.h"
#include "src/core/lib/channel/channel_stack.h"
#include <grpc/support/log.h>
#include <stdlib.h>

@ -45,8 +45,8 @@
#include <grpc/grpc.h>
#include <grpc/support/log.h>
#include "src/core/debug/trace.h"
#include "src/core/transport/transport.h"
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/transport/transport.h"
typedef struct grpc_channel_element grpc_channel_element;
typedef struct grpc_call_element grpc_call_element;

@ -31,7 +31,7 @@
*
*/
#include "src/core/channel/channel_stack_builder.h"
#include "src/core/lib/channel/channel_stack_builder.h"
#include <string.h>

@ -36,8 +36,8 @@
#include <stdbool.h>
#include "src/core/channel/channel_args.h"
#include "src/core/channel/channel_stack.h"
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/channel/channel_stack.h"
/// grpc_channel_stack_builder offers a programmatic interface to selected
/// and order channel filters

@ -31,7 +31,7 @@
*
*/
#include "src/core/channel/client_channel.h"
#include "src/core/lib/channel/client_channel.h"
#include <stdio.h>
#include <string.h>
@ -41,14 +41,14 @@
#include <grpc/support/sync.h>
#include <grpc/support/useful.h>
#include "src/core/channel/channel_args.h"
#include "src/core/channel/connected_channel.h"
#include "src/core/channel/subchannel_call_holder.h"
#include "src/core/iomgr/iomgr.h"
#include "src/core/profiling/timers.h"
#include "src/core/support/string.h"
#include "src/core/surface/channel.h"
#include "src/core/transport/connectivity_state.h"
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/channel/connected_channel.h"
#include "src/core/lib/channel/subchannel_call_holder.h"
#include "src/core/lib/iomgr/iomgr.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/support/string.h"
#include "src/core/lib/surface/channel.h"
#include "src/core/lib/transport/connectivity_state.h"
/* Client channel implementation */

@ -34,8 +34,8 @@
#ifndef GRPC_CORE_LIB_CHANNEL_CLIENT_CHANNEL_H
#define GRPC_CORE_LIB_CHANNEL_CLIENT_CHANNEL_H
#include "src/core/channel/channel_stack.h"
#include "src/core/client_config/resolver.h"
#include "src/core/lib/channel/channel_stack.h"
#include "src/core/lib/client_config/resolver.h"
/* A client channel is a channel that begins disconnected, and can connect
to some endpoint on demand. If that endpoint disconnects, it will be

@ -39,13 +39,13 @@
#include <grpc/support/log.h>
#include <grpc/support/slice_buffer.h>
#include "src/core/channel/channel_args.h"
#include "src/core/channel/compress_filter.h"
#include "src/core/compression/algorithm_metadata.h"
#include "src/core/compression/message_compress.h"
#include "src/core/profiling/timers.h"
#include "src/core/support/string.h"
#include "src/core/transport/static_metadata.h"
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/channel/compress_filter.h"
#include "src/core/lib/compression/algorithm_metadata.h"
#include "src/core/lib/compression/message_compress.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/support/string.h"
#include "src/core/lib/transport/static_metadata.h"
typedef struct call_data {
gpr_slice_buffer slices; /**< Buffers up input slices to be compressed */

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CHANNEL_COMPRESS_FILTER_H
#define GRPC_CORE_LIB_CHANNEL_COMPRESS_FILTER_H
#include "src/core/channel/channel_stack.h"
#include "src/core/lib/channel/channel_stack.h"
#define GRPC_COMPRESS_REQUEST_ALGORITHM_KEY "grpc-internal-encoding-request"

@ -31,7 +31,7 @@
*
*/
#include "src/core/channel/connected_channel.h"
#include "src/core/lib/channel/connected_channel.h"
#include <stdarg.h>
#include <stdio.h>
@ -41,9 +41,9 @@
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/slice_buffer.h>
#include "src/core/profiling/timers.h"
#include "src/core/support/string.h"
#include "src/core/transport/transport.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/support/string.h"
#include "src/core/lib/transport/transport.h"
#define MAX_BUFFER_LENGTH 8192

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CHANNEL_CONNECTED_CHANNEL_H
#define GRPC_CORE_LIB_CHANNEL_CONNECTED_CHANNEL_H
#include "src/core/channel/channel_stack_builder.h"
#include "src/core/lib/channel/channel_stack_builder.h"
bool grpc_add_connected_filter(grpc_channel_stack_builder *builder,
void *arg_must_be_null);

@ -30,14 +30,14 @@
*
*/
#include "src/core/channel/http_client_filter.h"
#include "src/core/lib/channel/http_client_filter.h"
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/string_util.h>
#include <string.h>
#include "src/core/profiling/timers.h"
#include "src/core/support/string.h"
#include "src/core/transport/static_metadata.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/support/string.h"
#include "src/core/lib/transport/static_metadata.h"
typedef struct call_data {
grpc_linked_mdelem method;

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CHANNEL_HTTP_CLIENT_FILTER_H
#define GRPC_CORE_LIB_CHANNEL_HTTP_CLIENT_FILTER_H
#include "src/core/channel/channel_stack.h"
#include "src/core/lib/channel/channel_stack.h"
/* Processes metadata on the client side for HTTP2 transports */
extern const grpc_channel_filter grpc_http_client_filter;

@ -31,13 +31,13 @@
*
*/
#include "src/core/channel/http_server_filter.h"
#include "src/core/lib/channel/http_server_filter.h"
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <string.h>
#include "src/core/profiling/timers.h"
#include "src/core/transport/static_metadata.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/transport/static_metadata.h"
typedef struct call_data {
uint8_t seen_path;

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CHANNEL_HTTP_SERVER_FILTER_H
#define GRPC_CORE_LIB_CHANNEL_HTTP_SERVER_FILTER_H
#include "src/core/channel/channel_stack.h"
#include "src/core/lib/channel/channel_stack.h"
/* Processes metadata on the client side for HTTP2 transports */
extern const grpc_channel_filter grpc_http_server_filter;

@ -31,11 +31,11 @@
*
*/
#include "src/core/channel/subchannel_call_holder.h"
#include "src/core/lib/channel/subchannel_call_holder.h"
#include <grpc/support/alloc.h>
#include "src/core/profiling/timers.h"
#include "src/core/lib/profiling/timers.h"
#define GET_CALL(holder) \
((grpc_subchannel_call *)(gpr_atm_acq_load(&(holder)->subchannel_call)))

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CHANNEL_SUBCHANNEL_CALL_HOLDER_H
#define GRPC_CORE_LIB_CHANNEL_SUBCHANNEL_CALL_HOLDER_H
#include "src/core/client_config/subchannel.h"
#include "src/core/lib/client_config/subchannel.h"
/** Pick a subchannel for grpc_subchannel_call_holder;
Return 1 if subchannel is available immediately (in which case on_ready

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/client_config.h"
#include "src/core/lib/client_config/client_config.h"
#include <string.h>

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_CLIENT_CONFIG_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_CLIENT_CONFIG_H
#include "src/core/client_config/lb_policy.h"
#include "src/core/lib/client_config/lb_policy.h"
/** Total configuration for a client. Provided, and updated, by
grpc_resolver */

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/connector.h"
#include "src/core/lib/client_config/connector.h"
grpc_connector* grpc_connector_ref(grpc_connector* connector) {
connector->vtable->ref(connector);

@ -34,9 +34,9 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_CONNECTOR_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_CONNECTOR_H
#include "src/core/channel/channel_stack.h"
#include "src/core/iomgr/sockaddr.h"
#include "src/core/transport/transport.h"
#include "src/core/lib/channel/channel_stack.h"
#include "src/core/lib/iomgr/sockaddr.h"
#include "src/core/lib/transport/transport.h"
typedef struct grpc_connector grpc_connector;
typedef struct grpc_connector_vtable grpc_connector_vtable;

@ -32,7 +32,7 @@
*/
#include <grpc/support/slice.h>
#include "src/core/iomgr/sockaddr.h"
#include "src/core/lib/iomgr/sockaddr.h"
void grpc_set_default_initial_connect_string(struct sockaddr **addr,
size_t *addr_len,

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/initial_connect_string.h"
#include "src/core/lib/client_config/initial_connect_string.h"
#include <stddef.h>

@ -35,7 +35,7 @@
#define GRPC_CORE_LIB_CLIENT_CONFIG_INITIAL_CONNECT_STRING_H
#include <grpc/support/slice.h>
#include "src/core/iomgr/sockaddr.h"
#include "src/core/lib/iomgr/sockaddr.h"
typedef void (*grpc_set_initial_connect_string_func)(struct sockaddr **addr,
size_t *addr_len,

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/lb_policies/load_balancer_api.h"
#include "src/core/lib/client_config/lb_policies/load_balancer_api.h"
#include "third_party/nanopb/pb_decode.h"
#include "third_party/nanopb/pb_encode.h"

@ -36,8 +36,8 @@
#include <grpc/support/slice_buffer.h>
#include "src/core/client_config/lb_policy_factory.h"
#include "src/core/proto/grpc/lb/v0/load_balancer.pb.h"
#include "src/core/lib/client_config/lb_policy_factory.h"
#include "src/core/lib/proto/grpc/lb/v0/load_balancer.pb.h"
#ifdef __cplusplus
extern "C" {

@ -31,13 +31,13 @@
*
*/
#include "src/core/client_config/lb_policies/pick_first.h"
#include "src/core/client_config/lb_policy_factory.h"
#include "src/core/lib/client_config/lb_policies/pick_first.h"
#include "src/core/lib/client_config/lb_policy_factory.h"
#include <string.h>
#include <grpc/support/alloc.h>
#include "src/core/transport/connectivity_state.h"
#include "src/core/lib/transport/connectivity_state.h"
typedef struct pending_pick {
struct pending_pick *next;

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICIES_PICK_FIRST_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICIES_PICK_FIRST_H
#include "src/core/client_config/lb_policy_factory.h"
#include "src/core/lib/client_config/lb_policy_factory.h"
/** Returns a load balancing factory for the pick first policy, which picks up
* the first subchannel from \a subchannels to succesfully connect */

@ -31,12 +31,12 @@
*
*/
#include "src/core/client_config/lb_policies/round_robin.h"
#include "src/core/lib/client_config/lb_policies/round_robin.h"
#include <string.h>
#include <grpc/support/alloc.h>
#include "src/core/transport/connectivity_state.h"
#include "src/core/lib/transport/connectivity_state.h"
typedef struct round_robin_lb_policy round_robin_lb_policy;

@ -34,11 +34,11 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICIES_ROUND_ROBIN_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICIES_ROUND_ROBIN_H
#include "src/core/client_config/lb_policy.h"
#include "src/core/lib/client_config/lb_policy.h"
extern int grpc_lb_round_robin_trace;
#include "src/core/client_config/lb_policy_factory.h"
#include "src/core/lib/client_config/lb_policy_factory.h"
/** Returns a load balancing factory for the round robin policy */
grpc_lb_policy_factory *grpc_round_robin_lb_factory_create();

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/lb_policy.h"
#include "src/core/lib/client_config/lb_policy.h"
#define WEAK_REF_BITS 16

@ -34,8 +34,8 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICY_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICY_H
#include "src/core/client_config/subchannel.h"
#include "src/core/transport/connectivity_state.h"
#include "src/core/lib/client_config/subchannel.h"
#include "src/core/lib/transport/connectivity_state.h"
/** A load balancing policy: specified by a vtable and a struct (which
is expected to be extended to contain some parameters) */

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/lb_policy_factory.h"
#include "src/core/lib/client_config/lb_policy_factory.h"
void grpc_lb_policy_factory_ref(grpc_lb_policy_factory* factory) {
factory->vtable->ref(factory);

@ -34,8 +34,8 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICY_FACTORY_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICY_FACTORY_H
#include "src/core/client_config/lb_policy.h"
#include "src/core/client_config/subchannel.h"
#include "src/core/lib/client_config/lb_policy.h"
#include "src/core/lib/client_config/subchannel.h"
typedef struct grpc_lb_policy_factory grpc_lb_policy_factory;
typedef struct grpc_lb_policy_factory_vtable grpc_lb_policy_factory_vtable;

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/lb_policy_registry.h"
#include "src/core/lib/client_config/lb_policy_registry.h"
#include <string.h>

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICY_REGISTRY_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_LB_POLICY_REGISTRY_H
#include "src/core/client_config/lb_policy_factory.h"
#include "src/core/lib/client_config/lb_policy_factory.h"
/** Initialize the registry and set \a default_factory as the factory to be
* returned when no name is provided in a lookup */

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/resolver.h"
#include "src/core/lib/client_config/resolver.h"
void grpc_resolver_init(grpc_resolver *resolver,
const grpc_resolver_vtable *vtable) {

@ -34,9 +34,9 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVER_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVER_H
#include "src/core/client_config/client_config.h"
#include "src/core/client_config/subchannel.h"
#include "src/core/iomgr/iomgr.h"
#include "src/core/lib/client_config/client_config.h"
#include "src/core/lib/client_config/subchannel.h"
#include "src/core/lib/iomgr/iomgr.h"
typedef struct grpc_resolver grpc_resolver;
typedef struct grpc_resolver_vtable grpc_resolver_vtable;

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/resolver_factory.h"
#include "src/core/lib/client_config/resolver_factory.h"
void grpc_resolver_factory_ref(grpc_resolver_factory* factory) {
factory->vtable->ref(factory);

@ -34,9 +34,9 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVER_FACTORY_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVER_FACTORY_H
#include "src/core/client_config/resolver.h"
#include "src/core/client_config/subchannel_factory.h"
#include "src/core/client_config/uri_parser.h"
#include "src/core/lib/client_config/resolver.h"
#include "src/core/lib/client_config/subchannel_factory.h"
#include "src/core/lib/client_config/uri_parser.h"
typedef struct grpc_resolver_factory grpc_resolver_factory;
typedef struct grpc_resolver_factory_vtable grpc_resolver_factory_vtable;

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/resolver_registry.h"
#include "src/core/lib/client_config/resolver_registry.h"
#include <string.h>

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVER_REGISTRY_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVER_REGISTRY_H
#include "src/core/client_config/resolver_factory.h"
#include "src/core/lib/client_config/resolver_factory.h"
void grpc_resolver_registry_init(const char *default_prefix);
void grpc_resolver_registry_shutdown(void);

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/resolvers/dns_resolver.h"
#include "src/core/lib/client_config/resolvers/dns_resolver.h"
#include <string.h>
@ -39,11 +39,11 @@
#include <grpc/support/host_port.h>
#include <grpc/support/string_util.h>
#include "src/core/client_config/lb_policy_registry.h"
#include "src/core/iomgr/resolve_address.h"
#include "src/core/iomgr/timer.h"
#include "src/core/support/backoff.h"
#include "src/core/support/string.h"
#include "src/core/lib/client_config/lb_policy_registry.h"
#include "src/core/lib/iomgr/resolve_address.h"
#include "src/core/lib/iomgr/timer.h"
#include "src/core/lib/support/backoff.h"
#include "src/core/lib/support/string.h"
#define BACKOFF_MULTIPLIER 1.6
#define BACKOFF_JITTER 0.2

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVERS_DNS_RESOLVER_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVERS_DNS_RESOLVER_H
#include "src/core/client_config/resolver_factory.h"
#include "src/core/lib/client_config/resolver_factory.h"
/** Create a dns resolver factory */
grpc_resolver_factory *grpc_dns_resolver_factory_create(void);

@ -33,7 +33,7 @@
#include <grpc/support/port_platform.h>
#include "src/core/client_config/resolvers/sockaddr_resolver.h"
#include "src/core/lib/client_config/resolvers/sockaddr_resolver.h"
#include <stdio.h>
#include <string.h>
@ -42,10 +42,10 @@
#include <grpc/support/host_port.h>
#include <grpc/support/string_util.h>
#include "src/core/client_config/lb_policy_registry.h"
#include "src/core/iomgr/resolve_address.h"
#include "src/core/iomgr/unix_sockets_posix.h"
#include "src/core/support/string.h"
#include "src/core/lib/client_config/lb_policy_registry.h"
#include "src/core/lib/iomgr/resolve_address.h"
#include "src/core/lib/iomgr/unix_sockets_posix.h"
#include "src/core/lib/support/string.h"
typedef struct {
/** base class: must be first */

@ -36,7 +36,7 @@
#include <grpc/support/port_platform.h>
#include "src/core/client_config/resolver_factory.h"
#include "src/core/lib/client_config/resolver_factory.h"
grpc_resolver_factory *grpc_ipv4_resolver_factory_create(void);

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/resolvers/zookeeper_resolver.h"
#include "src/core/lib/client_config/resolvers/zookeeper_resolver.h"
#include <string.h>
@ -41,12 +41,12 @@
#include <grpc/grpc_zookeeper.h>
#include <zookeeper/zookeeper.h>
#include "src/core/client_config/lb_policy_registry.h"
#include "src/core/client_config/resolver_registry.h"
#include "src/core/iomgr/resolve_address.h"
#include "src/core/json/json.h"
#include "src/core/support/string.h"
#include "src/core/surface/api_trace.h"
#include "src/core/lib/client_config/lb_policy_registry.h"
#include "src/core/lib/client_config/resolver_registry.h"
#include "src/core/lib/iomgr/resolve_address.h"
#include "src/core/lib/json/json.h"
#include "src/core/lib/support/string.h"
#include "src/core/lib/surface/api_trace.h"
/** Zookeeper session expiration time in milliseconds */
#define GRPC_ZOOKEEPER_SESSION_TIMEOUT 15000

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVERS_ZOOKEEPER_RESOLVER_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_RESOLVERS_ZOOKEEPER_RESOLVER_H
#include "src/core/client_config/resolver_factory.h"
#include "src/core/lib/client_config/resolver_factory.h"
/** Create a zookeeper resolver factory */
grpc_resolver_factory *grpc_zookeeper_resolver_factory_create(void);

@ -31,24 +31,24 @@
*
*/
#include "src/core/client_config/subchannel.h"
#include "src/core/lib/client_config/subchannel.h"
#include <string.h>
#include <grpc/support/alloc.h>
#include <grpc/support/avl.h>
#include "src/core/channel/channel_args.h"
#include "src/core/channel/client_channel.h"
#include "src/core/channel/connected_channel.h"
#include "src/core/client_config/initial_connect_string.h"
#include "src/core/client_config/subchannel_index.h"
#include "src/core/iomgr/timer.h"
#include "src/core/profiling/timers.h"
#include "src/core/support/backoff.h"
#include "src/core/surface/channel.h"
#include "src/core/surface/channel_init.h"
#include "src/core/transport/connectivity_state.h"
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/channel/client_channel.h"
#include "src/core/lib/channel/connected_channel.h"
#include "src/core/lib/client_config/initial_connect_string.h"
#include "src/core/lib/client_config/subchannel_index.h"
#include "src/core/lib/iomgr/timer.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/support/backoff.h"
#include "src/core/lib/surface/channel.h"
#include "src/core/lib/surface/channel_init.h"
#include "src/core/lib/transport/connectivity_state.h"
#define INTERNAL_REF_BITS 16
#define STRONG_REF_MASK (~(gpr_atm)((1 << INTERNAL_REF_BITS) - 1))

@ -34,9 +34,9 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_SUBCHANNEL_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_SUBCHANNEL_H
#include "src/core/channel/channel_stack.h"
#include "src/core/client_config/connector.h"
#include "src/core/transport/connectivity_state.h"
#include "src/core/lib/channel/channel_stack.h"
#include "src/core/lib/client_config/connector.h"
#include "src/core/lib/transport/connectivity_state.h"
/** A (sub-)channel that knows how to connect to exactly one target
address. Provides a target for load balancing. */

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/subchannel_factory.h"
#include "src/core/lib/client_config/subchannel_factory.h"
void grpc_subchannel_factory_ref(grpc_subchannel_factory* factory) {
factory->vtable->ref(factory);

@ -34,8 +34,8 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_SUBCHANNEL_FACTORY_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_SUBCHANNEL_FACTORY_H
#include "src/core/channel/channel_stack.h"
#include "src/core/client_config/subchannel.h"
#include "src/core/lib/channel/channel_stack.h"
#include "src/core/lib/client_config/subchannel.h"
typedef struct grpc_subchannel_factory grpc_subchannel_factory;
typedef struct grpc_subchannel_factory_vtable grpc_subchannel_factory_vtable;

@ -31,7 +31,7 @@
//
//
#include "src/core/client_config/subchannel_index.h"
#include "src/core/lib/client_config/subchannel_index.h"
#include <stdbool.h>
#include <string.h>
@ -40,7 +40,7 @@
#include <grpc/support/avl.h>
#include <grpc/support/tls.h>
#include "src/core/channel/channel_args.h"
#include "src/core/lib/channel/channel_args.h"
// a map of subchannel_key --> subchannel, used for detecting connections
// to the same destination in order to share them

@ -34,8 +34,8 @@
#ifndef GRPC_CORE_LIB_CLIENT_CONFIG_SUBCHANNEL_INDEX_H
#define GRPC_CORE_LIB_CLIENT_CONFIG_SUBCHANNEL_INDEX_H
#include "src/core/client_config/connector.h"
#include "src/core/client_config/subchannel.h"
#include "src/core/lib/client_config/connector.h"
#include "src/core/lib/client_config/subchannel.h"
/** \file Provides an index of active subchannels so that they can be
shared amongst channels */

@ -31,7 +31,7 @@
*
*/
#include "src/core/client_config/uri_parser.h"
#include "src/core/lib/client_config/uri_parser.h"
#include <string.h>

@ -35,7 +35,7 @@
#define GRPC_CORE_LIB_COMPRESSION_ALGORITHM_METADATA_H
#include <grpc/compression.h>
#include "src/core/transport/metadata.h"
#include "src/core/lib/transport/metadata.h"
/** Return compression algorithm based metadata value */
grpc_mdstr *grpc_compression_algorithm_mdstr(

@ -37,9 +37,9 @@
#include <grpc/compression.h>
#include <grpc/support/useful.h>
#include "src/core/compression/algorithm_metadata.h"
#include "src/core/surface/api_trace.h"
#include "src/core/transport/static_metadata.h"
#include "src/core/lib/compression/algorithm_metadata.h"
#include "src/core/lib/surface/api_trace.h"
#include "src/core/lib/transport/static_metadata.h"
int grpc_compression_algorithm_parse(const char *name, size_t name_length,
grpc_compression_algorithm *algorithm) {

@ -31,7 +31,7 @@
*
*/
#include "src/core/compression/message_compress.h"
#include "src/core/lib/compression/message_compress.h"
#include <string.h>

@ -31,14 +31,14 @@
*
*/
#include "src/core/debug/trace.h"
#include "src/core/lib/debug/trace.h"
#include <string.h>
#include <grpc/grpc.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include "src/core/support/env.h"
#include "src/core/lib/support/env.h"
typedef struct tracer {
const char *name;

@ -31,7 +31,7 @@
*
*/
#include "src/core/http/format_request.h"
#include "src/core/lib/http/format_request.h"
#include <stdarg.h>
#include <stdio.h>
@ -41,7 +41,7 @@
#include <grpc/support/slice.h>
#include <grpc/support/string_util.h>
#include <grpc/support/useful.h>
#include "src/core/support/string.h"
#include "src/core/lib/support/string.h"
static void fill_common_header(const grpc_httpcli_request *request,
gpr_strvec *buf) {

@ -35,7 +35,7 @@
#define GRPC_CORE_LIB_HTTP_FORMAT_REQUEST_H
#include <grpc/support/slice.h>
#include "src/core/http/httpcli.h"
#include "src/core/lib/http/httpcli.h"
gpr_slice grpc_httpcli_format_get_request(const grpc_httpcli_request *request);
gpr_slice grpc_httpcli_format_post_request(const grpc_httpcli_request *request,

@ -31,8 +31,8 @@
*
*/
#include "src/core/http/httpcli.h"
#include "src/core/iomgr/sockaddr.h"
#include "src/core/lib/http/httpcli.h"
#include "src/core/lib/iomgr/sockaddr.h"
#include <string.h>
@ -40,13 +40,13 @@
#include <grpc/support/log.h>
#include <grpc/support/string_util.h>
#include "src/core/http/format_request.h"
#include "src/core/http/parser.h"
#include "src/core/iomgr/endpoint.h"
#include "src/core/iomgr/iomgr_internal.h"
#include "src/core/iomgr/resolve_address.h"
#include "src/core/iomgr/tcp_client.h"
#include "src/core/support/string.h"
#include "src/core/lib/http/format_request.h"
#include "src/core/lib/http/parser.h"
#include "src/core/lib/iomgr/endpoint.h"
#include "src/core/lib/iomgr/iomgr_internal.h"
#include "src/core/lib/iomgr/resolve_address.h"
#include "src/core/lib/iomgr/tcp_client.h"
#include "src/core/lib/support/string.h"
typedef struct {
gpr_slice request_text;

@ -38,10 +38,10 @@
#include <grpc/support/time.h>
#include "src/core/http/parser.h"
#include "src/core/iomgr/endpoint.h"
#include "src/core/iomgr/iomgr_internal.h"
#include "src/core/iomgr/pollset_set.h"
#include "src/core/lib/http/parser.h"
#include "src/core/lib/iomgr/endpoint.h"
#include "src/core/lib/iomgr/iomgr_internal.h"
#include "src/core/lib/iomgr/pollset_set.h"
/* User agent this library reports */
#define GRPC_HTTPCLI_USER_AGENT "grpc-httpcli/0.0"

@ -31,16 +31,16 @@
*
*/
#include "src/core/http/httpcli.h"
#include "src/core/lib/http/httpcli.h"
#include <string.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/string_util.h>
#include "src/core/security/handshake.h"
#include "src/core/support/string.h"
#include "src/core/tsi/ssl_transport_security.h"
#include "src/core/lib/security/handshake.h"
#include "src/core/lib/support/string.h"
#include "src/core/lib/tsi/ssl_transport_security.h"
typedef struct {
grpc_channel_security_connector base;

@ -31,7 +31,7 @@
*
*/
#include "src/core/http/parser.h"
#include "src/core/lib/http/parser.h"
#include <string.h>

@ -31,7 +31,7 @@
*
*/
#include "src/core/iomgr/closure.h"
#include "src/core/lib/iomgr/closure.h"
#include <grpc/support/alloc.h>

@ -31,7 +31,7 @@
*
*/
#include "src/core/iomgr/endpoint.h"
#include "src/core/lib/iomgr/endpoint.h"
void grpc_endpoint_read(grpc_exec_ctx* exec_ctx, grpc_endpoint* ep,
gpr_slice_buffer* slices, grpc_closure* cb) {

@ -37,8 +37,8 @@
#include <grpc/support/slice.h>
#include <grpc/support/slice_buffer.h>
#include <grpc/support/time.h>
#include "src/core/iomgr/pollset.h"
#include "src/core/iomgr/pollset_set.h"
#include "src/core/lib/iomgr/pollset.h"
#include "src/core/lib/iomgr/pollset_set.h"
/* An endpoint caps a streaming channel between two communicating processes.
Examples may be: a tcp socket, <stdin+stdout>, or some shared memory. */

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_IOMGR_ENDPOINT_PAIR_H
#define GRPC_CORE_LIB_IOMGR_ENDPOINT_PAIR_H
#include "src/core/iomgr/endpoint.h"
#include "src/core/lib/iomgr/endpoint.h"
typedef struct {
grpc_endpoint *client;

@ -35,9 +35,9 @@
#ifdef GPR_POSIX_SOCKET
#include "src/core/iomgr/endpoint_pair.h"
#include "src/core/iomgr/socket_utils_posix.h"
#include "src/core/iomgr/unix_sockets_posix.h"
#include "src/core/lib/iomgr/endpoint_pair.h"
#include "src/core/lib/iomgr/socket_utils_posix.h"
#include "src/core/lib/iomgr/unix_sockets_posix.h"
#include <errno.h>
#include <fcntl.h>
@ -48,8 +48,8 @@
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/string_util.h>
#include "src/core/iomgr/tcp_posix.h"
#include "src/core/support/string.h"
#include "src/core/lib/iomgr/tcp_posix.h"
#include "src/core/lib/support/string.h"
static void create_sockets(int sv[2]) {
int flags;

@ -34,16 +34,16 @@
#include <grpc/support/port_platform.h>
#ifdef GPR_WINSOCK_SOCKET
#include "src/core/iomgr/endpoint_pair.h"
#include "src/core/iomgr/sockaddr_utils.h"
#include "src/core/lib/iomgr/endpoint_pair.h"
#include "src/core/lib/iomgr/sockaddr_utils.h"
#include <errno.h>
#include <fcntl.h>
#include <string.h>
#include <grpc/support/log.h>
#include "src/core/iomgr/socket_windows.h"
#include "src/core/iomgr/tcp_windows.h"
#include "src/core/lib/iomgr/socket_windows.h"
#include "src/core/lib/iomgr/tcp_windows.h"
static void create_sockets(SOCKET sv[2]) {
SOCKET svr_sock = INVALID_SOCKET;

@ -31,13 +31,13 @@
*
*/
#include "src/core/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include <grpc/support/log.h>
#include <grpc/support/sync.h>
#include <grpc/support/thd.h>
#include "src/core/profiling/timers.h"
#include "src/core/lib/profiling/timers.h"
#ifndef GRPC_EXECUTION_CONTEXT_SANITIZER
bool grpc_exec_ctx_flush(grpc_exec_ctx *exec_ctx) {

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_IOMGR_EXEC_CTX_H
#define GRPC_CORE_LIB_IOMGR_EXEC_CTX_H
#include "src/core/iomgr/closure.h"
#include "src/core/lib/iomgr/closure.h"
/* #define GRPC_EXECUTION_CONTEXT_SANITIZER 1 */

@ -31,7 +31,7 @@
*
*/
#include "src/core/iomgr/executor.h"
#include "src/core/lib/iomgr/executor.h"
#include <string.h>
@ -39,7 +39,7 @@
#include <grpc/support/log.h>
#include <grpc/support/sync.h>
#include <grpc/support/thd.h>
#include "src/core/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/exec_ctx.h"
typedef struct grpc_executor_data {
int busy; /**< is the thread currently running? */

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_IOMGR_EXECUTOR_H
#define GRPC_CORE_LIB_IOMGR_EXECUTOR_H
#include "src/core/iomgr/closure.h"
#include "src/core/lib/iomgr/closure.h"
/** Initialize the global executor.
*

@ -35,7 +35,7 @@
#ifdef GPR_POSIX_SOCKET
#include "src/core/iomgr/fd_posix.h"
#include "src/core/lib/iomgr/fd_posix.h"
#include <assert.h>
#include <sys/socket.h>
@ -46,7 +46,7 @@
#include <grpc/support/string_util.h>
#include <grpc/support/useful.h>
#include "src/core/iomgr/pollset_posix.h"
#include "src/core/lib/iomgr/pollset_posix.h"
#define CLOSURE_NOT_READY ((grpc_closure *)0)
#define CLOSURE_READY ((grpc_closure *)1)

@ -37,8 +37,8 @@
#include <grpc/support/atm.h>
#include <grpc/support/sync.h>
#include <grpc/support/time.h>
#include "src/core/iomgr/iomgr_internal.h"
#include "src/core/iomgr/pollset.h"
#include "src/core/lib/iomgr/iomgr_internal.h"
#include "src/core/lib/iomgr/pollset.h"
typedef struct grpc_fd grpc_fd;

@ -42,10 +42,10 @@
#include <grpc/support/log_win32.h>
#include <grpc/support/thd.h>
#include "src/core/iomgr/iocp_windows.h"
#include "src/core/iomgr/iomgr_internal.h"
#include "src/core/iomgr/socket_windows.h"
#include "src/core/iomgr/timer.h"
#include "src/core/lib/iomgr/iocp_windows.h"
#include "src/core/lib/iomgr/iomgr_internal.h"
#include "src/core/lib/iomgr/socket_windows.h"
#include "src/core/lib/iomgr/timer.h"
static ULONG g_iocp_kick_token;
static OVERLAPPED g_iocp_custom_overlap;

@ -36,7 +36,7 @@
#include <grpc/support/sync.h>
#include "src/core/iomgr/socket_windows.h"
#include "src/core/lib/iomgr/socket_windows.h"
typedef enum {
GRPC_IOCP_WORK_WORK,

@ -31,7 +31,7 @@
*
*/
#include "src/core/iomgr/iomgr.h"
#include "src/core/lib/iomgr/iomgr.h"
#include <stdlib.h>
#include <string.h>
@ -43,11 +43,11 @@
#include <grpc/support/thd.h>
#include <grpc/support/useful.h>
#include "src/core/iomgr/exec_ctx.h"
#include "src/core/iomgr/iomgr_internal.h"
#include "src/core/iomgr/timer.h"
#include "src/core/support/env.h"
#include "src/core/support/string.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/iomgr_internal.h"
#include "src/core/lib/iomgr/timer.h"
#include "src/core/lib/support/env.h"
#include "src/core/lib/support/string.h"
static gpr_mu g_mu;
static gpr_cv g_rcv;

@ -37,7 +37,7 @@
#include <stdbool.h>
#include <grpc/support/sync.h>
#include "src/core/iomgr/iomgr.h"
#include "src/core/lib/iomgr/iomgr.h"
typedef struct grpc_iomgr_object {
char *name;

@ -35,10 +35,10 @@
#ifdef GPR_POSIX_SOCKET
#include "src/core/debug/trace.h"
#include "src/core/iomgr/fd_posix.h"
#include "src/core/iomgr/iomgr_posix.h"
#include "src/core/iomgr/tcp_posix.h"
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/iomgr/fd_posix.h"
#include "src/core/lib/iomgr/iomgr_posix.h"
#include "src/core/lib/iomgr/tcp_posix.h"
void grpc_iomgr_platform_init(void) {
grpc_fd_global_init();

@ -34,6 +34,6 @@
#ifndef GRPC_CORE_LIB_IOMGR_IOMGR_POSIX_H
#define GRPC_CORE_LIB_IOMGR_IOMGR_POSIX_H
#include "src/core/iomgr/iomgr_internal.h"
#include "src/core/lib/iomgr/iomgr_internal.h"
#endif /* GRPC_CORE_LIB_IOMGR_IOMGR_POSIX_H */

@ -35,13 +35,13 @@
#ifdef GPR_WINSOCK_SOCKET
#include "src/core/iomgr/sockaddr_win32.h"
#include "src/core/lib/iomgr/sockaddr_win32.h"
#include <grpc/support/log.h>
#include "src/core/iomgr/iocp_windows.h"
#include "src/core/iomgr/iomgr.h"
#include "src/core/iomgr/socket_windows.h"
#include "src/core/lib/iomgr/iocp_windows.h"
#include "src/core/lib/iomgr/iomgr.h"
#include "src/core/lib/iomgr/socket_windows.h"
/* Windows' io manager is going to be fully designed using IO completion
ports. All of what we're doing here is basically make sure that

@ -38,7 +38,7 @@
#include <grpc/support/sync.h>
#include <grpc/support/time.h>
#include "src/core/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#define GRPC_POLLSET_KICK_BROADCAST ((grpc_pollset_worker *)1)

@ -44,10 +44,10 @@
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/useful.h>
#include "src/core/iomgr/fd_posix.h"
#include "src/core/iomgr/pollset_posix.h"
#include "src/core/profiling/timers.h"
#include "src/core/support/block_annotate.h"
#include "src/core/lib/iomgr/fd_posix.h"
#include "src/core/lib/iomgr/pollset_posix.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/support/block_annotate.h"
struct epoll_fd_list {
int *epoll_fds;

@ -35,7 +35,7 @@
#ifdef GPR_POSIX_SOCKET
#include "src/core/iomgr/pollset_posix.h"
#include "src/core/lib/iomgr/pollset_posix.h"
#include <errno.h>
#include <poll.h>
@ -46,10 +46,10 @@
#include <grpc/support/log.h>
#include <grpc/support/useful.h>
#include "src/core/iomgr/fd_posix.h"
#include "src/core/iomgr/iomgr_internal.h"
#include "src/core/iomgr/pollset_posix.h"
#include "src/core/support/block_annotate.h"
#include "src/core/lib/iomgr/fd_posix.h"
#include "src/core/lib/iomgr/iomgr_internal.h"
#include "src/core/lib/iomgr/pollset_posix.h"
#include "src/core/lib/support/block_annotate.h"
typedef struct {
/* all polled fds */

@ -35,7 +35,7 @@
#ifdef GPR_POSIX_SOCKET
#include "src/core/iomgr/pollset_posix.h"
#include "src/core/lib/iomgr/pollset_posix.h"
#include <errno.h>
#include <stdlib.h>
@ -47,11 +47,11 @@
#include <grpc/support/thd.h>
#include <grpc/support/tls.h>
#include <grpc/support/useful.h>
#include "src/core/iomgr/fd_posix.h"
#include "src/core/iomgr/iomgr_internal.h"
#include "src/core/iomgr/socket_utils_posix.h"
#include "src/core/profiling/timers.h"
#include "src/core/support/block_annotate.h"
#include "src/core/lib/iomgr/fd_posix.h"
#include "src/core/lib/iomgr/iomgr_internal.h"
#include "src/core/lib/iomgr/socket_utils_posix.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/support/block_annotate.h"
GPR_TLS_DECL(g_current_thread_poller);
GPR_TLS_DECL(g_current_thread_worker);

@ -38,10 +38,10 @@
#include <grpc/support/sync.h>
#include "src/core/iomgr/exec_ctx.h"
#include "src/core/iomgr/iomgr.h"
#include "src/core/iomgr/pollset.h"
#include "src/core/iomgr/wakeup_fd_posix.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/iomgr.h"
#include "src/core/lib/iomgr/pollset.h"
#include "src/core/lib/iomgr/wakeup_fd_posix.h"
typedef struct grpc_pollset_vtable grpc_pollset_vtable;

@ -34,7 +34,7 @@
#ifndef GRPC_CORE_LIB_IOMGR_POLLSET_SET_H
#define GRPC_CORE_LIB_IOMGR_POLLSET_SET_H
#include "src/core/iomgr/pollset.h"
#include "src/core/lib/iomgr/pollset.h"
/* A grpc_pollset_set is a set of pollsets that are interested in an
action. Adding a pollset to a pollset_set automatically adds any

@ -41,8 +41,8 @@
#include <grpc/support/alloc.h>
#include <grpc/support/useful.h>
#include "src/core/iomgr/pollset_posix.h"
#include "src/core/iomgr/pollset_set_posix.h"
#include "src/core/lib/iomgr/pollset_posix.h"
#include "src/core/lib/iomgr/pollset_set_posix.h"
struct grpc_pollset_set {
gpr_mu mu;

@ -34,8 +34,8 @@
#ifndef GRPC_CORE_LIB_IOMGR_POLLSET_SET_POSIX_H
#define GRPC_CORE_LIB_IOMGR_POLLSET_SET_POSIX_H
#include "src/core/iomgr/fd_posix.h"
#include "src/core/iomgr/pollset_set.h"
#include "src/core/lib/iomgr/fd_posix.h"
#include "src/core/lib/iomgr/pollset_set.h"
void grpc_pollset_set_add_fd(grpc_exec_ctx *exec_ctx,
grpc_pollset_set *pollset_set, grpc_fd *fd);

@ -35,7 +35,7 @@
#ifdef GPR_WINSOCK_SOCKET
#include "src/core/iomgr/pollset_set_windows.h"
#include "src/core/lib/iomgr/pollset_set_windows.h"
grpc_pollset_set* grpc_pollset_set_create(pollset_set) { return NULL; }

@ -34,6 +34,6 @@
#ifndef GRPC_CORE_LIB_IOMGR_POLLSET_SET_WINDOWS_H
#define GRPC_CORE_LIB_IOMGR_POLLSET_SET_WINDOWS_H
#include "src/core/iomgr/pollset_set.h"
#include "src/core/lib/iomgr/pollset_set.h"
#endif /* GRPC_CORE_LIB_IOMGR_POLLSET_SET_WINDOWS_H */

Some files were not shown because too many files have changed in this diff Show More

Loading…
Cancel
Save