Merge master after no Extern C changes

pull/13058/head
Yash Tibrewal 7 years ago
commit 36522e9f80
  1. 1
      .gitignore
  2. 3
      BUILD
  3. 4
      include/grpc++/impl/codegen/core_codegen_interface.h
  4. 1
      setup.py
  5. 8
      src/core/ext/filters/client_channel/client_channel.h
  6. 8
      src/core/ext/filters/client_channel/client_channel_factory.h
  7. 4
      src/core/ext/filters/client_channel/client_channel_plugin.cc
  8. 8
      src/core/ext/filters/client_channel/connector.h
  9. 8
      src/core/ext/filters/client_channel/http_connect_handshaker.h
  10. 8
      src/core/ext/filters/client_channel/http_proxy.h
  11. 8
      src/core/ext/filters/client_channel/lb_policy.h
  12. 8
      src/core/ext/filters/client_channel/lb_policy/grpclb/client_load_reporting_filter.h
  13. 4
      src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb.cc
  14. 8
      src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb.h
  15. 8
      src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb_channel.h
  16. 8
      src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb_client_stats.h
  17. 8
      src/core/ext/filters/client_channel/lb_policy/grpclb/load_balancer_api.h
  18. 4
      src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc
  19. 4
      src/core/ext/filters/client_channel/lb_policy/round_robin/round_robin.cc
  20. 8
      src/core/ext/filters/client_channel/lb_policy/subchannel_list.h
  21. 8
      src/core/ext/filters/client_channel/lb_policy_factory.h
  22. 8
      src/core/ext/filters/client_channel/lb_policy_registry.h
  23. 8
      src/core/ext/filters/client_channel/parse_address.h
  24. 8
      src/core/ext/filters/client_channel/proxy_mapper.h
  25. 8
      src/core/ext/filters/client_channel/proxy_mapper_registry.h
  26. 8
      src/core/ext/filters/client_channel/resolver.h
  27. 8
      src/core/ext/filters/client_channel/resolver/dns/c_ares/dns_resolver_ares.cc
  28. 8
      src/core/ext/filters/client_channel/resolver/dns/c_ares/grpc_ares_ev_driver.h
  29. 8
      src/core/ext/filters/client_channel/resolver/dns/c_ares/grpc_ares_wrapper.h
  30. 4
      src/core/ext/filters/client_channel/resolver/dns/native/dns_resolver.cc
  31. 4
      src/core/ext/filters/client_channel/resolver/fake/fake_resolver.cc
  32. 8
      src/core/ext/filters/client_channel/resolver/fake/fake_resolver.h
  33. 4
      src/core/ext/filters/client_channel/resolver/sockaddr/sockaddr_resolver.cc
  34. 8
      src/core/ext/filters/client_channel/resolver_factory.h
  35. 8
      src/core/ext/filters/client_channel/resolver_registry.h
  36. 8
      src/core/ext/filters/client_channel/retry_throttle.h
  37. 8
      src/core/ext/filters/client_channel/subchannel.h
  38. 8
      src/core/ext/filters/client_channel/subchannel_index.h
  39. 8
      src/core/ext/filters/client_channel/uri_parser.h
  40. 4
      src/core/ext/filters/deadline/deadline_filter.cc
  41. 8
      src/core/ext/filters/deadline/deadline_filter.h
  42. 8
      src/core/ext/filters/http/client/http_client_filter.h
  43. 4
      src/core/ext/filters/http/http_filters_plugin.cc
  44. 8
      src/core/ext/filters/http/message_compress/message_compress_filter.h
  45. 8
      src/core/ext/filters/http/server/http_server_filter.h
  46. 8
      src/core/ext/filters/load_reporting/server_load_reporting_filter.h
  47. 4
      src/core/ext/filters/load_reporting/server_load_reporting_plugin.cc
  48. 8
      src/core/ext/filters/load_reporting/server_load_reporting_plugin.h
  49. 4
      src/core/ext/filters/max_age/max_age_filter.cc
  50. 8
      src/core/ext/filters/max_age/max_age_filter.h
  51. 4
      src/core/ext/filters/message_size/message_size_filter.cc
  52. 8
      src/core/ext/filters/message_size/message_size_filter.h
  53. 4
      src/core/ext/filters/workarounds/workaround_cronet_compression_filter.cc
  54. 8
      src/core/ext/filters/workarounds/workaround_cronet_compression_filter.h
  55. 8
      src/core/ext/filters/workarounds/workaround_utils.h
  56. 8
      src/core/ext/transport/chttp2/alpn/alpn.h
  57. 8
      src/core/ext/transport/chttp2/client/chttp2_connector.h
  58. 8
      src/core/ext/transport/chttp2/server/chttp2_server.h
  59. 8
      src/core/ext/transport/chttp2/transport/bin_decoder.h
  60. 8
      src/core/ext/transport/chttp2/transport/bin_encoder.h
  61. 4
      src/core/ext/transport/chttp2/transport/chttp2_plugin.cc
  62. 8
      src/core/ext/transport/chttp2/transport/chttp2_transport.h
  63. 8
      src/core/ext/transport/chttp2/transport/frame.h
  64. 8
      src/core/ext/transport/chttp2/transport/frame_data.h
  65. 8
      src/core/ext/transport/chttp2/transport/frame_goaway.h
  66. 8
      src/core/ext/transport/chttp2/transport/frame_ping.h
  67. 8
      src/core/ext/transport/chttp2/transport/frame_rst_stream.h
  68. 8
      src/core/ext/transport/chttp2/transport/frame_settings.h
  69. 8
      src/core/ext/transport/chttp2/transport/frame_window_update.h
  70. 8
      src/core/ext/transport/chttp2/transport/hpack_encoder.h
  71. 8
      src/core/ext/transport/chttp2/transport/hpack_parser.h
  72. 8
      src/core/ext/transport/chttp2/transport/hpack_table.h
  73. 7
      src/core/ext/transport/chttp2/transport/http2_settings.h
  74. 8
      src/core/ext/transport/chttp2/transport/huffsyms.h
  75. 8
      src/core/ext/transport/chttp2/transport/incoming_metadata.h
  76. 8
      src/core/ext/transport/chttp2/transport/internal.h
  77. 8
      src/core/ext/transport/chttp2/transport/stream_map.h
  78. 8
      src/core/ext/transport/chttp2/transport/varint.h
  79. 8
      src/core/ext/transport/cronet/transport/cronet_transport.h
  80. 6
      src/core/ext/transport/inproc/inproc_plugin.cc
  81. 8
      src/core/ext/transport/inproc/inproc_transport.h
  82. 8
      src/core/lib/backoff/backoff.h
  83. 8
      src/core/lib/channel/channel_args.h
  84. 8
      src/core/lib/channel/channel_stack.h
  85. 8
      src/core/lib/channel/channel_stack_builder.h
  86. 8
      src/core/lib/channel/connected_channel.h
  87. 8
      src/core/lib/channel/handshaker.h
  88. 8
      src/core/lib/channel/handshaker_factory.h
  89. 8
      src/core/lib/channel/handshaker_registry.h
  90. 8
      src/core/lib/compression/algorithm_metadata.h
  91. 8
      src/core/lib/compression/message_compress.h
  92. 2
      src/core/lib/compression/stream_compression.cc
  93. 8
      src/core/lib/compression/stream_compression.h
  94. 8
      src/core/lib/compression/stream_compression_gzip.h
  95. 8
      src/core/lib/compression/stream_compression_identity.h
  96. 8
      src/core/lib/debug/stats.h
  97. 8
      src/core/lib/debug/stats_data.h
  98. 12
      src/core/lib/debug/trace.h
  99. 8
      src/core/lib/http/format_request.h
  100. 8
      src/core/lib/http/httpcli.h
  101. Some files were not shown because too many files have changed in this diff Show More

1
.gitignore vendored

@ -56,6 +56,7 @@ Gemfile.lock
# Temporary test reports
report.xml
*/sponge_log.xml
latency_trace.txt
latency_trace.*.txt

@ -79,10 +79,11 @@ GRPC_PUBLIC_HDRS = [
"include/grpc/byte_buffer.h",
"include/grpc/byte_buffer_reader.h",
"include/grpc/compression.h",
"include/grpc/load_reporting.h",
"include/grpc/fork.h",
"include/grpc/grpc.h",
"include/grpc/grpc_posix.h",
"include/grpc/grpc_security_constants.h",
"include/grpc/load_reporting.h",
"include/grpc/slice.h",
"include/grpc/slice_buffer.h",
"include/grpc/status.h",

@ -25,10 +25,6 @@
#include <grpc/impl/codegen/grpc_types.h>
#include <grpc/impl/codegen/sync.h>
extern "C" {
struct grpc_byte_buffer;
}
namespace grpc {
/// Interface between the codegen library and the minimal subset of core

@ -181,6 +181,7 @@ if "linux" in sys.platform or "darwin" in sys.platform:
pymodinit_type = 'PyObject*' if PY3 else 'void'
pymodinit = '__attribute__((visibility ("default"))) {}'.format(pymodinit_type)
DEFINE_MACROS += (('PyMODINIT_FUNC', pymodinit),)
DEFINE_MACROS += (('GRPC_POSIX_FORK_ALLOW_PTHREAD_ATFORK', 1),)
# By default, Python3 distutils enforces compatibility of
# c plugins (.so files) with the OSX version Python3 was built with.

@ -28,10 +28,6 @@ extern grpc_core::TraceFlag grpc_client_channel_trace;
// Channel arg key for server URI string.
#define GRPC_ARG_SERVER_URI "grpc.server_uri"
#ifdef __cplusplus
extern "C" {
#endif
/* A client channel is a channel that begins disconnected, and can connect
to some endpoint on demand. If that endpoint disconnects, it will be
connected to again later.
@ -56,8 +52,4 @@ void grpc_client_channel_watch_connectivity_state(
grpc_subchannel_call* grpc_client_channel_get_subchannel_call(
grpc_call_element* elem);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_CLIENT_CHANNEL_H */

@ -27,10 +27,6 @@
// Channel arg key for client channel factory.
#define GRPC_ARG_CLIENT_CHANNEL_FACTORY "grpc.client_channel_factory"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_client_channel_factory grpc_client_channel_factory;
typedef struct grpc_client_channel_factory_vtable
grpc_client_channel_factory_vtable;
@ -73,8 +69,4 @@ grpc_channel* grpc_client_channel_factory_create_channel(
grpc_arg grpc_client_channel_factory_create_channel_arg(
grpc_client_channel_factory* factory);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_CLIENT_CHANNEL_FACTORY_H */

@ -62,7 +62,7 @@ static bool set_default_host_if_unset(grpc_channel_stack_builder* builder,
return true;
}
extern "C" void grpc_client_channel_init(void) {
void grpc_client_channel_init(void) {
grpc_lb_policy_registry_init();
grpc_resolver_registry_init();
grpc_retry_throttle_map_init();
@ -77,7 +77,7 @@ extern "C" void grpc_client_channel_init(void) {
grpc_http_connect_register_handshaker_factory();
}
extern "C" void grpc_client_channel_shutdown(void) {
void grpc_client_channel_shutdown(void) {
grpc_subchannel_index_shutdown();
grpc_channel_init_shutdown();
grpc_proxy_mapper_registry_shutdown();

@ -23,10 +23,6 @@
#include "src/core/lib/iomgr/resolve_address.h"
#include "src/core/lib/transport/transport.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_connector grpc_connector;
typedef struct grpc_connector_vtable grpc_connector_vtable;
@ -72,8 +68,4 @@ void grpc_connector_connect(grpc_connector* connector,
/** Cancel any pending connection */
void grpc_connector_shutdown(grpc_connector* connector, grpc_error* why);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_CONNECTOR_H */

@ -28,15 +28,7 @@
/// seperated by colons.
#define GRPC_ARG_HTTP_CONNECT_HEADERS "grpc.http_connect_headers"
#ifdef __cplusplus
extern "C" {
#endif
/// Registers handshaker factory.
void grpc_http_connect_register_handshaker_factory();
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_HTTP_CONNECT_HANDSHAKER_H */

@ -19,14 +19,6 @@
#ifndef GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_HTTP_PROXY_H
#define GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_HTTP_PROXY_H
#ifdef __cplusplus
extern "C" {
#endif
void grpc_register_http_proxy_mapper();
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_HTTP_PROXY_H */

@ -23,10 +23,6 @@
#include "src/core/lib/iomgr/polling_entity.h"
#include "src/core/lib/transport/connectivity_state.h"
#ifdef __cplusplus
extern "C" {
#endif
/** A load balancing policy: specified by a vtable and a struct (which
is expected to be extended to contain some parameters) */
typedef struct grpc_lb_policy grpc_lb_policy;
@ -197,8 +193,4 @@ grpc_connectivity_state grpc_lb_policy_check_connectivity_locked(
void grpc_lb_policy_update_locked(grpc_lb_policy* policy,
const grpc_lb_policy_args* lb_policy_args);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_H */

@ -21,15 +21,7 @@
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
extern const grpc_channel_filter grpc_client_load_reporting_filter;
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_GRPCLB_CLIENT_LOAD_REPORTING_FILTER_H \
*/

@ -1958,7 +1958,7 @@ static bool maybe_add_client_load_reporting_filter(
return true;
}
extern "C" void grpc_lb_policy_grpclb_init() {
void grpc_lb_policy_grpclb_init() {
grpc_register_lb_policy(grpc_glb_lb_factory_create());
grpc_channel_init_register_stage(GRPC_CLIENT_SUBCHANNEL,
GRPC_CHANNEL_INIT_BUILTIN_PRIORITY,
@ -1966,4 +1966,4 @@ extern "C" void grpc_lb_policy_grpclb_init() {
(void*)&grpc_client_load_reporting_filter);
}
extern "C" void grpc_lb_policy_grpclb_shutdown() {}
void grpc_lb_policy_grpclb_shutdown() {}

@ -21,17 +21,9 @@
#include "src/core/ext/filters/client_channel/lb_policy_factory.h"
#ifdef __cplusplus
extern "C" {
#endif
/** Returns a load balancing factory for the glb policy, which tries to connect
* to a load balancing server to decide the next successfully connected
* subchannel to pick. */
grpc_lb_policy_factory* grpc_glb_lb_factory_create();
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_GRPCLB_GRPCLB_H */

@ -23,10 +23,6 @@
#include "src/core/ext/filters/client_channel/resolver/fake/fake_resolver.h"
#include "src/core/lib/slice/slice_hash_table.h"
#ifdef __cplusplus
extern "C" {
#endif
/** Create the channel used for communicating with an LB service.
* Note that an LB *service* may be comprised of several LB *servers*.
*
@ -44,9 +40,5 @@ grpc_channel_args* grpc_lb_policy_grpclb_build_lb_channel_args(
grpc_fake_resolver_response_generator* response_generator,
const grpc_channel_args* args);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_GRPCLB_GRPCLB_CHANNEL_H \
*/

@ -23,10 +23,6 @@
#include <grpc/impl/codegen/grpc_types.h>
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_grpclb_client_stats grpc_grpclb_client_stats;
typedef struct {
@ -65,9 +61,5 @@ void grpc_grpclb_client_stats_get_locked(
void grpc_grpclb_dropped_call_counts_destroy(
grpc_grpclb_dropped_call_counts* drop_entries);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_GRPCLB_GRPCLB_CLIENT_STATS_H \
*/

@ -25,10 +25,6 @@
#include "src/core/ext/filters/client_channel/lb_policy/grpclb/proto/grpc/lb/v1/load_balancer.pb.h"
#include "src/core/ext/filters/client_channel/lb_policy_factory.h"
#ifdef __cplusplus
extern "C" {
#endif
#define GRPC_GRPCLB_SERVICE_NAME_MAX_LENGTH 128
typedef grpc_lb_v1_Server_ip_address_t grpc_grpclb_ip_address;
@ -87,9 +83,5 @@ grpc_millis grpc_grpclb_duration_to_millis(grpc_grpclb_duration* duration_pb);
void grpc_grpclb_initial_response_destroy(
grpc_grpclb_initial_response* response);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_GRPCLB_LOAD_BALANCER_API_H \
*/

@ -578,8 +578,8 @@ static grpc_lb_policy_factory* pick_first_lb_factory_create() {
/* Plugin registration */
extern "C" void grpc_lb_policy_pick_first_init() {
void grpc_lb_policy_pick_first_init() {
grpc_register_lb_policy(pick_first_lb_factory_create());
}
extern "C" void grpc_lb_policy_pick_first_shutdown() {}
void grpc_lb_policy_pick_first_shutdown() {}

@ -675,8 +675,8 @@ static grpc_lb_policy_factory* round_robin_lb_factory_create() {
/* Plugin registration */
extern "C" void grpc_lb_policy_round_robin_init() {
void grpc_lb_policy_round_robin_init() {
grpc_register_lb_policy(round_robin_lb_factory_create());
}
extern "C" void grpc_lb_policy_round_robin_shutdown() {}
void grpc_lb_policy_round_robin_shutdown() {}

@ -36,10 +36,6 @@
// round_robin that could be refactored and moved here. In a future PR,
// need to clean this up.
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_lb_subchannel_list grpc_lb_subchannel_list;
typedef struct {
@ -142,8 +138,4 @@ void grpc_lb_subchannel_list_unref_for_connectivity_watch(
void grpc_lb_subchannel_list_shutdown_and_unref(
grpc_lb_subchannel_list* subchannel_list, const char* reason);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_SUBCHANNEL_LIST_H */

@ -29,10 +29,6 @@
// Channel arg key for grpc_lb_addresses.
#define GRPC_ARG_LB_ADDRESSES "grpc.lb_addresses"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_lb_policy_factory grpc_lb_policy_factory;
typedef struct grpc_lb_policy_factory_vtable grpc_lb_policy_factory_vtable;
@ -131,8 +127,4 @@ void grpc_lb_policy_factory_unref(grpc_lb_policy_factory* factory);
grpc_lb_policy* grpc_lb_policy_factory_create_lb_policy(
grpc_lb_policy_factory* factory, grpc_lb_policy_args* args);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_FACTORY_H */

@ -22,10 +22,6 @@
#include "src/core/ext/filters/client_channel/lb_policy_factory.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
/** Initialize the registry and set \a default_factory as the factory to be
* returned when no name is provided in a lookup */
void grpc_lb_policy_registry_init(void);
@ -41,8 +37,4 @@ void grpc_register_lb_policy(grpc_lb_policy_factory* factory);
grpc_lb_policy* grpc_lb_policy_create(const char* name,
grpc_lb_policy_args* args);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_REGISTRY_H */

@ -24,10 +24,6 @@
#include "src/core/ext/filters/client_channel/uri_parser.h"
#include "src/core/lib/iomgr/resolve_address.h"
#ifdef __cplusplus
extern "C" {
#endif
/** Populate \a resolved_addr from \a uri, whose path is expected to contain a
* unix socket path. Returns true upon success. */
bool grpc_parse_unix(const grpc_uri* uri, grpc_resolved_address* resolved_addr);
@ -49,8 +45,4 @@ bool grpc_parse_ipv4_hostport(const char* hostport, grpc_resolved_address* addr,
bool grpc_parse_ipv6_hostport(const char* hostport, grpc_resolved_address* addr,
bool log_errors);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_PARSE_ADDRESS_H */

@ -25,10 +25,6 @@
#include "src/core/lib/iomgr/resolve_address.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_proxy_mapper grpc_proxy_mapper;
typedef struct {
@ -73,8 +69,4 @@ bool grpc_proxy_mapper_map_address(grpc_proxy_mapper* mapper,
void grpc_proxy_mapper_destroy(grpc_proxy_mapper* mapper);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_PROXY_MAPPER_H */

@ -21,10 +21,6 @@
#include "src/core/ext/filters/client_channel/proxy_mapper.h"
#ifdef __cplusplus
extern "C" {
#endif
void grpc_proxy_mapper_registry_init();
void grpc_proxy_mapper_registry_shutdown();
@ -43,8 +39,4 @@ bool grpc_proxy_mappers_map_address(const grpc_resolved_address* address,
grpc_resolved_address** new_address,
grpc_channel_args** new_args);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_PROXY_MAPPER_REGISTRY_H */

@ -22,10 +22,6 @@
#include "src/core/ext/filters/client_channel/subchannel.h"
#include "src/core/lib/iomgr/iomgr.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_resolver grpc_resolver;
typedef struct grpc_resolver_vtable grpc_resolver_vtable;
@ -86,8 +82,4 @@ void grpc_resolver_next_locked(grpc_resolver* resolver,
grpc_channel_args** result,
grpc_closure* on_complete);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_RESOLVER_H */

@ -411,7 +411,7 @@ static grpc_resolver_factory* dns_ares_resolver_factory_create() {
return &dns_resolver_factory;
}
extern "C" void grpc_resolver_dns_ares_init(void) {
void grpc_resolver_dns_ares_init(void) {
char* resolver = gpr_getenv("GRPC_DNS_RESOLVER");
/* TODO(zyc): Turn on c-ares based resolver by default after the address
sorter and the CNAME support are added. */
@ -427,7 +427,7 @@ extern "C" void grpc_resolver_dns_ares_init(void) {
gpr_free(resolver);
}
extern "C" void grpc_resolver_dns_ares_shutdown(void) {
void grpc_resolver_dns_ares_shutdown(void) {
char* resolver = gpr_getenv("GRPC_DNS_RESOLVER");
if (resolver != nullptr && gpr_stricmp(resolver, "ares") == 0) {
grpc_ares_cleanup();
@ -437,8 +437,8 @@ extern "C" void grpc_resolver_dns_ares_shutdown(void) {
#else /* GRPC_ARES == 1 && !defined(GRPC_UV) */
extern "C" void grpc_resolver_dns_ares_init(void) {}
void grpc_resolver_dns_ares_init(void) {}
extern "C" void grpc_resolver_dns_ares_shutdown(void) {}
void grpc_resolver_dns_ares_shutdown(void) {}
#endif /* GRPC_ARES == 1 && !defined(GRPC_UV) */

@ -23,10 +23,6 @@
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/pollset_set.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_ares_ev_driver grpc_ares_ev_driver;
/* Start \a ev_driver. It will keep working until all IO on its ares_channel is
@ -52,9 +48,5 @@ void grpc_ares_ev_driver_destroy(grpc_ares_ev_driver* ev_driver);
/* Shutdown all the grpc_fds used by \a ev_driver */
void grpc_ares_ev_driver_shutdown(grpc_ares_ev_driver* ev_driver);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_RESOLVER_DNS_C_ARES_GRPC_ARES_EV_DRIVER_H \
*/

@ -25,10 +25,6 @@
#include "src/core/lib/iomgr/polling_entity.h"
#include "src/core/lib/iomgr/resolve_address.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_ares_request grpc_ares_request;
/* Asynchronously resolve \a name. Use \a default_port if a port isn't
@ -67,9 +63,5 @@ grpc_error* grpc_ares_init(void);
it has been called the same number of times as grpc_ares_init(). */
void grpc_ares_cleanup(void);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_RESOLVER_DNS_C_ARES_GRPC_ARES_WRAPPER_H \
*/

@ -281,7 +281,7 @@ static grpc_resolver_factory* dns_resolver_factory_create() {
return &dns_resolver_factory;
}
extern "C" void grpc_resolver_dns_native_init(void) {
void grpc_resolver_dns_native_init(void) {
char* resolver = gpr_getenv("GRPC_DNS_RESOLVER");
if (resolver != nullptr && gpr_stricmp(resolver, "native") == 0) {
gpr_log(GPR_DEBUG, "Using native dns resolver");
@ -299,4 +299,4 @@ extern "C" void grpc_resolver_dns_native_init(void) {
gpr_free(resolver);
}
extern "C" void grpc_resolver_dns_native_shutdown(void) {}
void grpc_resolver_dns_native_shutdown(void) {}

@ -250,8 +250,8 @@ static const grpc_resolver_factory_vtable fake_resolver_factory_vtable = {
static grpc_resolver_factory fake_resolver_factory = {
&fake_resolver_factory_vtable};
extern "C" void grpc_resolver_fake_init(void) {
void grpc_resolver_fake_init(void) {
grpc_register_resolver_type(&fake_resolver_factory);
}
extern "C" void grpc_resolver_fake_shutdown(void) {}
void grpc_resolver_fake_shutdown(void) {}

@ -21,10 +21,6 @@
#include "src/core/ext/filters/client_channel/uri_parser.h"
#include "src/core/lib/channel/channel_args.h"
#ifdef __cplusplus
extern "C" {
#endif
#define GRPC_ARG_FAKE_RESOLVER_RESPONSE_GENERATOR \
"grpc.fake_resolver.response_generator"
@ -60,9 +56,5 @@ grpc_fake_resolver_response_generator_ref(
void grpc_fake_resolver_response_generator_unref(
grpc_fake_resolver_response_generator* generator);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_RESOLVER_FAKE_FAKE_RESOLVER_H \
*/

@ -202,7 +202,7 @@ DECL_FACTORY(unix);
DECL_FACTORY(ipv4);
DECL_FACTORY(ipv6);
extern "C" void grpc_resolver_sockaddr_init(void) {
void grpc_resolver_sockaddr_init(void) {
grpc_register_resolver_type(&ipv4_resolver_factory);
grpc_register_resolver_type(&ipv6_resolver_factory);
#ifdef GRPC_HAVE_UNIX_SOCKET
@ -210,4 +210,4 @@ extern "C" void grpc_resolver_sockaddr_init(void) {
#endif
}
extern "C" void grpc_resolver_sockaddr_shutdown(void) {}
void grpc_resolver_sockaddr_shutdown(void) {}

@ -24,10 +24,6 @@
#include "src/core/ext/filters/client_channel/uri_parser.h"
#include "src/core/lib/iomgr/pollset_set.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_resolver_factory grpc_resolver_factory;
typedef struct grpc_resolver_factory_vtable grpc_resolver_factory_vtable;
@ -69,8 +65,4 @@ grpc_resolver* grpc_resolver_factory_create_resolver(
char* grpc_resolver_factory_get_default_authority(
grpc_resolver_factory* factory, grpc_uri* uri);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_RESOLVER_FACTORY_H */

@ -22,10 +22,6 @@
#include "src/core/ext/filters/client_channel/resolver_factory.h"
#include "src/core/lib/iomgr/pollset_set.h"
#ifdef __cplusplus
extern "C" {
#endif
void grpc_resolver_registry_init();
void grpc_resolver_registry_shutdown(void);
@ -69,8 +65,4 @@ char* grpc_get_default_authority(const char* target);
default prefix if needed. */
char* grpc_resolver_factory_add_default_prefix_if_needed(const char* target);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_RESOLVER_REGISTRY_H */

@ -21,10 +21,6 @@
#include <stdbool.h>
#ifdef __cplusplus
extern "C" {
#endif
/// Tracks retry throttling data for an individual server name.
typedef struct grpc_server_retry_throttle_data grpc_server_retry_throttle_data;
@ -51,8 +47,4 @@ void grpc_retry_throttle_map_shutdown();
grpc_server_retry_throttle_data* grpc_retry_throttle_map_get_data_for_server(
const char* server_name, int max_milli_tokens, int milli_token_ratio);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_RETRY_THROTTLE_H */

@ -26,10 +26,6 @@
#include "src/core/lib/transport/connectivity_state.h"
#include "src/core/lib/transport/metadata.h"
#ifdef __cplusplus
extern "C" {
#endif
// Channel arg containing a grpc_resolved_address to connect to.
#define GRPC_ARG_SUBCHANNEL_ADDRESS "grpc.subchannel_address"
@ -179,8 +175,4 @@ const char* grpc_get_subchannel_address_uri_arg(const grpc_channel_args* args);
/// Caller is responsible for freeing the string.
grpc_arg grpc_create_subchannel_address_arg(const grpc_resolved_address* addr);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_SUBCHANNEL_H */

@ -21,10 +21,6 @@
#include "src/core/ext/filters/client_channel/subchannel.h"
#ifdef __cplusplus
extern "C" {
#endif
/** \file Provides an index of active subchannels so that they can be
shared amongst channels */
@ -78,8 +74,4 @@ void grpc_subchannel_index_unref(void);
* force_creation set. */
void grpc_subchannel_index_test_only_set_force_creation(bool force_creation);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_SUBCHANNEL_INDEX_H */

@ -22,10 +22,6 @@
#include <stddef.h>
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct {
char* scheme;
char* authority;
@ -50,8 +46,4 @@ const char* grpc_uri_get_query_arg(const grpc_uri* uri, const char* key);
/** destroy a uri */
void grpc_uri_destroy(grpc_uri* uri);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_URI_PARSER_H */

@ -364,7 +364,7 @@ static bool maybe_add_deadline_filter(grpc_channel_stack_builder* builder,
: true;
}
extern "C" void grpc_deadline_filter_init(void) {
void grpc_deadline_filter_init(void) {
grpc_channel_init_register_stage(
GRPC_CLIENT_DIRECT_CHANNEL, GRPC_CHANNEL_INIT_BUILTIN_PRIORITY,
maybe_add_deadline_filter, (void*)&grpc_client_deadline_filter);
@ -373,4 +373,4 @@ extern "C" void grpc_deadline_filter_init(void) {
maybe_add_deadline_filter, (void*)&grpc_server_deadline_filter);
}
extern "C" void grpc_deadline_filter_shutdown(void) {}
void grpc_deadline_filter_shutdown(void) {}

@ -20,10 +20,6 @@
#include "src/core/lib/channel/channel_stack.h"
#include "src/core/lib/iomgr/timer.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef enum grpc_deadline_timer_state {
GRPC_DEADLINE_STATE_INITIAL,
GRPC_DEADLINE_STATE_PENDING,
@ -92,8 +88,4 @@ bool grpc_deadline_checking_enabled(const grpc_channel_args* args);
extern const grpc_channel_filter grpc_client_deadline_filter;
extern const grpc_channel_filter grpc_server_deadline_filter;
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_DEADLINE_DEADLINE_FILTER_H */

@ -20,18 +20,10 @@
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
/* Processes metadata on the client side for HTTP2 transports */
extern const grpc_channel_filter grpc_http_client_filter;
/* Channel arg to determine maximum size of payload eligable for GET request */
#define GRPC_ARG_MAX_PAYLOAD_SIZE_FOR_GET "grpc.max_payload_size_for_get"
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_HTTP_CLIENT_HTTP_CLIENT_FILTER_H */

@ -62,7 +62,7 @@ static bool maybe_add_required_filter(grpc_channel_stack_builder* builder,
: true;
}
extern "C" void grpc_http_filters_init(void) {
void grpc_http_filters_init(void) {
grpc_channel_init_register_stage(GRPC_CLIENT_SUBCHANNEL,
GRPC_CHANNEL_INIT_BUILTIN_PRIORITY,
maybe_add_optional_filter, &compress_filter);
@ -83,4 +83,4 @@ extern "C" void grpc_http_filters_init(void) {
maybe_add_required_filter, (void*)&grpc_http_server_filter);
}
extern "C" void grpc_http_filters_shutdown(void) {}
void grpc_http_filters_shutdown(void) {}

@ -23,10 +23,6 @@
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
/** Compression filter for outgoing data.
*
* See <grpc/compression.h> for the available compression settings.
@ -51,9 +47,5 @@ extern "C" {
extern const grpc_channel_filter grpc_message_compress_filter;
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_HTTP_MESSAGE_COMPRESS_MESSAGE_COMPRESS_FILTER_H \
*/

@ -21,15 +21,7 @@
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
/* Processes metadata on the client side for HTTP2 transports */
extern const grpc_channel_filter grpc_http_server_filter;
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_HTTP_SERVER_HTTP_SERVER_FILTER_H */

@ -22,15 +22,7 @@
#include "src/core/ext/filters/load_reporting/server_load_reporting_plugin.h"
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
extern const grpc_channel_filter grpc_server_load_reporting_filter;
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_LOAD_REPORTING_SERVER_LOAD_REPORTING_FILTER_H \
*/

@ -61,10 +61,10 @@ grpc_arg grpc_load_reporting_enable_arg() {
/* Plugin registration */
extern "C" void grpc_server_load_reporting_plugin_init(void) {
void grpc_server_load_reporting_plugin_init(void) {
grpc_channel_init_register_stage(GRPC_SERVER_CHANNEL, INT_MAX,
maybe_add_server_load_reporting_filter,
(void*)&grpc_server_load_reporting_filter);
}
extern "C" void grpc_server_load_reporting_plugin_shutdown() {}
void grpc_server_load_reporting_plugin_shutdown() {}

@ -23,10 +23,6 @@
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
/** Identifiers for the invocation point of the users LR callback */
typedef enum grpc_load_reporting_source {
GRPC_LR_POINT_UNKNOWN = 0,
@ -59,9 +55,5 @@ typedef struct grpc_load_reporting_call_data {
/** Return a \a grpc_arg enabling load reporting */
grpc_arg grpc_load_reporting_enable_arg();
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_LOAD_REPORTING_SERVER_LOAD_REPORTING_PLUGIN_H \
*/

@ -389,10 +389,10 @@ static bool maybe_add_max_age_filter(grpc_channel_stack_builder* builder,
}
}
extern "C" void grpc_max_age_filter_init(void) {
void grpc_max_age_filter_init(void) {
grpc_channel_init_register_stage(GRPC_SERVER_CHANNEL,
GRPC_CHANNEL_INIT_BUILTIN_PRIORITY,
maybe_add_max_age_filter, nullptr);
}
extern "C" void grpc_max_age_filter_shutdown(void) {}
void grpc_max_age_filter_shutdown(void) {}

@ -19,14 +19,6 @@
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
extern const grpc_channel_filter grpc_max_age_filter;
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_MAX_AGE_MAX_AGE_FILTER_H */

@ -302,7 +302,7 @@ static bool maybe_add_message_size_filter(grpc_channel_stack_builder* builder,
}
}
extern "C" void grpc_message_size_filter_init(void) {
void grpc_message_size_filter_init(void) {
grpc_channel_init_register_stage(GRPC_CLIENT_SUBCHANNEL,
GRPC_CHANNEL_INIT_BUILTIN_PRIORITY,
maybe_add_message_size_filter, nullptr);
@ -314,4 +314,4 @@ extern "C" void grpc_message_size_filter_init(void) {
maybe_add_message_size_filter, nullptr);
}
extern "C" void grpc_message_size_filter_shutdown(void) {}
void grpc_message_size_filter_shutdown(void) {}

@ -19,14 +19,6 @@
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
extern const grpc_channel_filter grpc_message_size_filter;
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_MESSAGE_SIZE_MESSAGE_SIZE_FILTER_H */

@ -191,7 +191,7 @@ static bool register_workaround_cronet_compression(
builder, &grpc_workaround_cronet_compression_filter, nullptr, nullptr);
}
extern "C" void grpc_workaround_cronet_compression_filter_init(void) {
void grpc_workaround_cronet_compression_filter_init(void) {
grpc_channel_init_register_stage(
GRPC_SERVER_CHANNEL, GRPC_WORKAROUND_PRIORITY_HIGH,
register_workaround_cronet_compression, nullptr);
@ -199,4 +199,4 @@ extern "C" void grpc_workaround_cronet_compression_filter_init(void) {
parse_user_agent);
}
extern "C" void grpc_workaround_cronet_compression_filter_shutdown(void) {}
void grpc_workaround_cronet_compression_filter_shutdown(void) {}

@ -19,15 +19,7 @@
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
extern const grpc_channel_filter grpc_workaround_cronet_compression_filter;
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_WORKAROUNDS_WORKAROUND_CRONET_COMPRESSION_FILTER_H \
*/

@ -24,10 +24,6 @@
#define GRPC_WORKAROUND_PRIORITY_HIGH 10001
#define GRPC_WORKAROUND_PROIRITY_LOW 9999
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_workaround_user_agent_md {
bool workaround_active[GRPC_MAX_WORKAROUND_ID];
} grpc_workaround_user_agent_md;
@ -38,8 +34,4 @@ typedef bool (*user_agent_parser)(grpc_mdelem);
void grpc_register_workaround(uint32_t id, user_agent_parser parser);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_FILTERS_WORKAROUNDS_WORKAROUND_UTILS_H */

@ -21,10 +21,6 @@
#include <string.h>
#ifdef __cplusplus
extern "C" {
#endif
/* Retuns 1 if the version is supported, 0 otherwise. */
int grpc_chttp2_is_alpn_version_supported(const char* version, size_t size);
@ -35,8 +31,4 @@ size_t grpc_chttp2_num_alpn_versions(void);
* grpc_chttp2_num_alpn_versions()) */
const char* grpc_chttp2_get_alpn_version_index(size_t i);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_ALPN_ALPN_H */

@ -19,16 +19,8 @@
#ifndef GRPC_CORE_EXT_TRANSPORT_CHTTP2_CLIENT_CHTTP2_CONNECTOR_H
#define GRPC_CORE_EXT_TRANSPORT_CHTTP2_CLIENT_CHTTP2_CONNECTOR_H
#ifdef __cplusplus
extern "C" {
#endif
#include "src/core/ext/filters/client_channel/connector.h"
grpc_connector* grpc_chttp2_connector_create();
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_CLIENT_CHTTP2_CONNECTOR_H */

@ -23,17 +23,9 @@
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
/// Adds a port to \a server. Sets \a port_num to the port number.
/// Takes ownership of \a args.
grpc_error* grpc_chttp2_server_add_port(grpc_server* server, const char* addr,
grpc_channel_args* args, int* port_num);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_SERVER_CHTTP2_SERVER_H */

@ -22,10 +22,6 @@
#include <grpc/slice.h>
#include <stdbool.h>
#ifdef __cplusplus
extern "C" {
#endif
struct grpc_base64_decode_context {
/* input/output: */
uint8_t* input_cur;
@ -52,8 +48,4 @@ grpc_slice grpc_chttp2_base64_decode(grpc_slice input);
grpc_slice grpc_chttp2_base64_decode_with_length(grpc_slice input,
size_t output_length);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_BIN_DECODER_H */

@ -21,10 +21,6 @@
#include <grpc/slice.h>
#ifdef __cplusplus
extern "C" {
#endif
/* base64 encode a slice. Returns a new slice, does not take ownership of the
input */
grpc_slice grpc_chttp2_base64_encode(grpc_slice input);
@ -40,8 +36,4 @@ grpc_slice grpc_chttp2_huffman_compress(grpc_slice input);
return y; */
grpc_slice grpc_chttp2_base64_encode_and_huffman_compress(grpc_slice input);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_BIN_ENCODER_H */

@ -20,6 +20,6 @@
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/transport/metadata.h"
extern "C" void grpc_chttp2_plugin_init(void) {}
void grpc_chttp2_plugin_init(void) {}
extern "C" void grpc_chttp2_plugin_shutdown(void) {}
void grpc_chttp2_plugin_shutdown(void) {}

@ -27,10 +27,6 @@ extern grpc_core::TraceFlag grpc_http_trace;
extern grpc_core::TraceFlag grpc_trace_http2_stream_state;
extern grpc_core::DebugOnlyTraceFlag grpc_trace_chttp2_refcount;
#ifdef __cplusplus
extern "C" {
#endif
grpc_transport* grpc_create_chttp2_transport(
const grpc_channel_args* channel_args, grpc_endpoint* ep, int is_client);
@ -39,8 +35,4 @@ grpc_transport* grpc_create_chttp2_transport(
void grpc_chttp2_transport_start_reading(grpc_transport* transport,
grpc_slice_buffer* read_buffer);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_CHTTP2_TRANSPORT_H */

@ -24,10 +24,6 @@
#include "src/core/lib/iomgr/error.h"
#ifdef __cplusplus
extern "C" {
#endif
/* defined in internal.h */
typedef struct grpc_chttp2_stream grpc_chttp2_stream;
typedef struct grpc_chttp2_transport grpc_chttp2_transport;
@ -47,8 +43,4 @@ typedef struct grpc_chttp2_transport grpc_chttp2_transport;
#define GRPC_CHTTP2_DATA_FLAG_PADDED 8
#define GRPC_CHTTP2_FLAG_HAS_PRIORITY 0x20
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_FRAME_H */

@ -28,10 +28,6 @@
#include "src/core/lib/transport/byte_stream.h"
#include "src/core/lib/transport/transport.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef enum {
GRPC_CHTTP2_DATA_FH_0,
GRPC_CHTTP2_DATA_FH_1,
@ -83,8 +79,4 @@ grpc_error* grpc_deframe_unprocessed_incoming_frames(
grpc_slice_buffer* slices, grpc_slice* slice_out,
grpc_byte_stream** stream_out);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_FRAME_DATA_H */

@ -25,10 +25,6 @@
#include "src/core/ext/transport/chttp2/transport/frame.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef enum {
GRPC_CHTTP2_GOAWAY_LSI0,
GRPC_CHTTP2_GOAWAY_LSI1,
@ -63,8 +59,4 @@ void grpc_chttp2_goaway_append(uint32_t last_stream_id, uint32_t error_code,
grpc_slice debug_data,
grpc_slice_buffer* slice_buffer);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_FRAME_GOAWAY_H */

@ -23,10 +23,6 @@
#include "src/core/ext/transport/chttp2/transport/frame.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct {
uint8_t byte;
uint8_t is_ack;
@ -45,8 +41,4 @@ grpc_error* grpc_chttp2_ping_parser_parse(void* parser,
/* Test-only function for disabling ping ack */
void grpc_set_disable_ping_ack(bool disable_ping_ack);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_FRAME_PING_H */

@ -24,10 +24,6 @@
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/transport/transport.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct {
uint8_t byte;
uint8_t reason_bytes[4];
@ -43,8 +39,4 @@ grpc_error* grpc_chttp2_rst_stream_parser_parse(void* parser,
grpc_chttp2_stream* s,
grpc_slice slice, int is_last);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_FRAME_RST_STREAM_H */

@ -25,10 +25,6 @@
#include "src/core/ext/transport/chttp2/transport/http2_settings.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef enum {
GRPC_CHTTP2_SPS_ID0,
GRPC_CHTTP2_SPS_ID1,
@ -61,8 +57,4 @@ grpc_error* grpc_chttp2_settings_parser_parse(void* parser,
grpc_chttp2_stream* s,
grpc_slice slice, int is_last);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_FRAME_SETTINGS_H */

@ -24,10 +24,6 @@
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/transport/transport.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct {
uint8_t byte;
uint8_t is_connection_update;
@ -45,8 +41,4 @@ grpc_error* grpc_chttp2_window_update_parser_parse(void* parser,
grpc_slice slice,
int is_last);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_FRAME_WINDOW_UPDATE_H */

@ -36,10 +36,6 @@
extern grpc_core::TraceFlag grpc_http_trace;
#ifdef __cplusplus
extern "C" {
#endif
typedef struct {
uint32_t filter_elems_sum;
uint32_t max_table_size;
@ -95,8 +91,4 @@ void grpc_chttp2_encode_header(grpc_chttp2_hpack_compressor* c,
const grpc_encode_header_options* options,
grpc_slice_buffer* outbuf);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HPACK_ENCODER_H */

@ -27,10 +27,6 @@
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/transport/metadata.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_chttp2_hpack_parser grpc_chttp2_hpack_parser;
typedef grpc_error* (*grpc_chttp2_hpack_parser_state)(
@ -110,8 +106,4 @@ grpc_error* grpc_chttp2_header_parser_parse(void* hpack_parser,
grpc_chttp2_stream* s,
grpc_slice slice, int is_last);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HPACK_PARSER_H */

@ -24,10 +24,6 @@
#include "src/core/lib/iomgr/error.h"
#include "src/core/lib/transport/metadata.h"
#ifdef __cplusplus
extern "C" {
#endif
/* HPACK header table */
/* last index in the static table */
@ -95,8 +91,4 @@ typedef struct {
grpc_chttp2_hptbl_find_result grpc_chttp2_hptbl_find(
const grpc_chttp2_hptbl* tbl, grpc_mdelem md);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HPACK_TABLE_H */

@ -36,9 +36,6 @@ typedef enum {
#define GRPC_CHTTP2_NUM_SETTINGS 7
#ifdef __cplusplus
extern "C" {
#endif
extern const uint16_t grpc_setting_id_to_wire_id[];
bool grpc_wire_id_to_setting_id(uint32_t wire_id, grpc_chttp2_setting_id* out);
@ -60,8 +57,4 @@ typedef struct {
extern const grpc_chttp2_setting_parameters
grpc_chttp2_settings_parameters[GRPC_CHTTP2_NUM_SETTINGS];
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HTTP2_SETTINGS_H */

@ -19,10 +19,6 @@
#ifndef GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HUFFSYMS_H
#define GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HUFFSYMS_H
#ifdef __cplusplus
extern "C" {
#endif
/* HPACK static huffman table */
#define GRPC_CHTTP2_NUM_HUFFSYMS 257
@ -34,8 +30,4 @@ typedef struct {
extern const grpc_chttp2_huffsym grpc_chttp2_huffsyms[GRPC_CHTTP2_NUM_HUFFSYMS];
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HUFFSYMS_H */

@ -21,10 +21,6 @@
#include "src/core/lib/transport/transport.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct {
gpr_arena* arena;
grpc_metadata_batch batch;
@ -48,8 +44,4 @@ grpc_error* grpc_chttp2_incoming_metadata_buffer_replace_or_add(
void grpc_chttp2_incoming_metadata_buffer_set_deadline(
grpc_chttp2_incoming_metadata_buffer* buffer, grpc_millis deadline);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_INCOMING_METADATA_H */

@ -42,10 +42,6 @@
#include "src/core/lib/transport/connectivity_state.h"
#include "src/core/lib/transport/transport_impl.h"
#ifdef __cplusplus
extern "C" {
#endif
/* streams are kept in various linked lists depending on what things need to
happen to them... this enum labels each list */
typedef enum {
@ -756,8 +752,4 @@ void grpc_chttp2_fail_pending_writes(grpc_chttp2_transport* t,
void grpc_chttp2_config_default_keepalive_args(grpc_channel_args* args,
bool is_client);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_INTERNAL_H */

@ -23,10 +23,6 @@
#include <stddef.h>
#ifdef __cplusplus
extern "C" {
#endif
/* Data structure to map a uint32_t to a data object (represented by a void*)
Represented as a sorted array of keys, and a corresponding array of values.
@ -69,8 +65,4 @@ void grpc_chttp2_stream_map_for_each(grpc_chttp2_stream_map* map,
void* value),
void* user_data);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_STREAM_MAP_H */

@ -21,10 +21,6 @@
#include <grpc/support/port_platform.h>
#ifdef __cplusplus
extern "C" {
#endif
/* Helpers for hpack varint encoding */
/* length of a value that needs varint tail encoding (it's bigger than can be
@ -61,8 +57,4 @@ void grpc_chttp2_hpack_write_varint_tail(uint32_t tail_value, uint8_t* target,
} \
} while (0)
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_VARINT_H */

@ -21,16 +21,8 @@
#include "src/core/lib/transport/transport.h"
#ifdef __cplusplus
extern "C" {
#endif
grpc_transport* grpc_create_cronet_transport(void* engine, const char* target,
const grpc_channel_args* args,
void* reserved);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_CRONET_TRANSPORT_CRONET_TRANSPORT_H */

@ -21,8 +21,6 @@
grpc_core::TraceFlag grpc_inproc_trace(false, "inproc");
extern "C" void grpc_inproc_plugin_init(void) { grpc_inproc_transport_init(); }
void grpc_inproc_plugin_init(void) { grpc_inproc_transport_init(); }
extern "C" void grpc_inproc_plugin_shutdown(void) {
grpc_inproc_transport_shutdown();
}
void grpc_inproc_plugin_shutdown(void) { grpc_inproc_transport_shutdown(); }

@ -21,10 +21,6 @@
#include "src/core/lib/transport/transport_impl.h"
#ifdef __cplusplus
extern "C" {
#endif
grpc_channel* grpc_inproc_channel_create(grpc_server* server,
grpc_channel_args* args,
void* reserved);
@ -34,8 +30,4 @@ extern grpc_core::TraceFlag grpc_inproc_trace;
void grpc_inproc_transport_init(void);
void grpc_inproc_transport_shutdown(void);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_EXT_TRANSPORT_INPROC_INPROC_TRANSPORT_H */

@ -21,10 +21,6 @@
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct {
/// const: how long to wait after the first failure before retrying
grpc_millis initial_backoff;
@ -74,8 +70,4 @@ grpc_backoff_result grpc_backoff_step(grpc_backoff* backoff);
/// grpc_backoff_begin.
void grpc_backoff_reset(grpc_backoff* backoff);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_BACKOFF_BACKOFF_H */

@ -23,10 +23,6 @@
#include <grpc/grpc.h>
#include "src/core/lib/iomgr/socket_mutator.h"
#ifdef __cplusplus
extern "C" {
#endif
// Channel args are intentionally immutable, to avoid the need for locking.
/** Copy the arguments in \a src into a new instance */
@ -152,8 +148,4 @@ grpc_arg grpc_channel_arg_integer_create(char* name, int value);
grpc_arg grpc_channel_arg_pointer_create(char* name, void* value,
const grpc_arg_pointer_vtable* vtable);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_CHANNEL_CHANNEL_ARGS_H */

@ -45,10 +45,6 @@
#include "src/core/lib/support/arena.h"
#include "src/core/lib/transport/transport.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_channel_element grpc_channel_element;
typedef struct grpc_call_element grpc_call_element;
@ -279,8 +275,4 @@ extern grpc_core::TraceFlag grpc_trace_channel;
#define GRPC_CALL_LOG_OP(sev, elem, op) \
if (grpc_trace_channel.enabled()) grpc_call_log_op(sev, elem, op)
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_CHANNEL_CHANNEL_STACK_H */

@ -24,10 +24,6 @@
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/channel/channel_stack.h"
#ifdef __cplusplus
extern "C" {
#endif
/// grpc_channel_stack_builder offers a programmatic interface to selected
/// and order channel filters
typedef struct grpc_channel_stack_builder grpc_channel_stack_builder;
@ -159,8 +155,4 @@ void grpc_channel_stack_builder_destroy(grpc_channel_stack_builder* builder);
extern grpc_core::TraceFlag grpc_trace_channel_stack_builder;
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_CHANNEL_CHANNEL_STACK_BUILDER_H */

@ -21,10 +21,6 @@
#include "src/core/lib/channel/channel_stack_builder.h"
#ifdef __cplusplus
extern "C" {
#endif
extern const grpc_channel_filter grpc_connected_filter;
bool grpc_add_connected_filter(grpc_channel_stack_builder* builder,
@ -33,8 +29,4 @@ bool grpc_add_connected_filter(grpc_channel_stack_builder* builder,
/* Debug helper to dig the transport stream out of a call element */
grpc_stream* grpc_connected_channel_get_stream(grpc_call_element* elem);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_CHANNEL_CONNECTED_CHANNEL_H */

@ -26,10 +26,6 @@
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/tcp_server.h"
#ifdef __cplusplus
extern "C" {
#endif
/// Handshakers are used to perform initial handshakes on a connection
/// before the client sends the initial request. Some examples of what
/// a handshaker can be used for includes support for HTTP CONNECT on
@ -164,8 +160,4 @@ void grpc_handshake_manager_pending_list_remove(grpc_handshake_manager** head,
void grpc_handshake_manager_pending_list_shutdown_all(
grpc_handshake_manager* head, grpc_error* why);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_CHANNEL_HANDSHAKER_H */

@ -24,10 +24,6 @@
#include "src/core/lib/channel/handshaker.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
// A handshaker factory is used to create handshakers.
typedef struct grpc_handshaker_factory grpc_handshaker_factory;
@ -50,8 +46,4 @@ void grpc_handshaker_factory_add_handshakers(
void grpc_handshaker_factory_destroy(
grpc_handshaker_factory* handshaker_factory);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_CHANNEL_HANDSHAKER_FACTORY_H */

@ -24,10 +24,6 @@
#include "src/core/lib/channel/handshaker_factory.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef enum {
HANDSHAKER_CLIENT = 0,
HANDSHAKER_SERVER,
@ -48,8 +44,4 @@ void grpc_handshakers_add(grpc_handshaker_type handshaker_type,
const grpc_channel_args* args,
grpc_handshake_manager* handshake_mgr);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_CHANNEL_HANDSHAKER_REGISTRY_H */

@ -22,10 +22,6 @@
#include <grpc/compression.h>
#include "src/core/lib/transport/metadata.h"
#ifdef __cplusplus
extern "C" {
#endif
/** Return compression algorithm based metadata value */
grpc_slice grpc_compression_algorithm_slice(
grpc_compression_algorithm algorithm);
@ -53,8 +49,4 @@ grpc_compression_algorithm grpc_compression_algorithm_from_slice(
grpc_stream_compression_algorithm grpc_stream_compression_algorithm_from_slice(
grpc_slice str);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_COMPRESSION_ALGORITHM_METADATA_H */

@ -22,10 +22,6 @@
#include <grpc/compression.h>
#include <grpc/slice_buffer.h>
#ifdef __cplusplus
extern "C" {
#endif
/* compress 'input' to 'output' using 'algorithm'.
On success, appends compressed slices to output and returns 1.
On failure, appends uncompressed slices to output and returns 0. */
@ -38,8 +34,4 @@ int grpc_msg_compress(grpc_compression_algorithm algorithm,
int grpc_msg_decompress(grpc_compression_algorithm algorithm,
grpc_slice_buffer* input, grpc_slice_buffer* output);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_COMPRESSION_MESSAGE_COMPRESS_H */

@ -21,7 +21,7 @@
#include "src/core/lib/compression/stream_compression.h"
#include "src/core/lib/compression/stream_compression_gzip.h"
extern "C" const grpc_stream_compression_vtable
extern const grpc_stream_compression_vtable
grpc_stream_compression_identity_vtable;
bool grpc_stream_compress(grpc_stream_compression_context* ctx,

@ -26,10 +26,6 @@
#include "src/core/lib/transport/static_metadata.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_stream_compression_vtable grpc_stream_compression_vtable;
/* Stream compression/decompression context */
@ -115,8 +111,4 @@ void grpc_stream_compression_context_destroy(
int grpc_stream_compression_method_parse(
grpc_slice value, bool is_compress, grpc_stream_compression_method* method);
#ifdef __cplusplus
}
#endif
#endif

@ -21,14 +21,6 @@
#include "src/core/lib/compression/stream_compression.h"
#ifdef __cplusplus
extern "C" {
#endif
extern const grpc_stream_compression_vtable grpc_stream_compression_gzip_vtable;
#ifdef __cplusplus
}
#endif
#endif

@ -21,15 +21,7 @@
#include "src/core/lib/compression/stream_compression.h"
#ifdef __cplusplus
extern "C" {
#endif
extern const grpc_stream_compression_vtable
grpc_stream_compression_identity_vtable;
#ifdef __cplusplus
}
#endif
#endif

@ -23,10 +23,6 @@
#include "src/core/lib/debug/stats_data.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct grpc_stats_data {
gpr_atm counters[GRPC_STATS_COUNTER_COUNT];
gpr_atm histograms[GRPC_STATS_HISTOGRAM_BUCKETS];
@ -60,8 +56,4 @@ double grpc_stats_histo_percentile(const grpc_stats_data* data,
size_t grpc_stats_histo_count(const grpc_stats_data* data,
grpc_stats_histograms histogram);
#ifdef __cplusplus
}
#endif
#endif

@ -24,10 +24,6 @@
#include <inttypes.h>
#include "src/core/lib/iomgr/exec_ctx.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef enum {
GRPC_STATS_COUNTER_CLIENT_CALLS_CREATED,
GRPC_STATS_COUNTER_SERVER_CALLS_CREATED,
@ -434,8 +430,4 @@ extern const int grpc_stats_histo_start[13];
extern const int* const grpc_stats_histo_bucket_boundaries[13];
extern void (*const grpc_stats_inc_histogram[13])(int x);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_DEBUG_STATS_DATA_H */

@ -23,25 +23,15 @@
#include <grpc/support/port_platform.h>
#include <stdbool.h>
#ifdef __cplusplus
extern "C" {
#endif
void grpc_tracer_init(const char* env_var_name);
void grpc_tracer_shutdown(void);
#ifdef __cplusplus
}
#endif
#if defined(__has_feature)
#if __has_feature(thread_sanitizer)
#define GRPC_THREADSAFE_TRACER
#endif
#endif
#ifdef __cplusplus
namespace grpc_core {
class TraceFlag;
@ -110,6 +100,4 @@ class DebugOnlyTraceFlag {
} // namespace grpc_core
#endif // __cplusplus
#endif /* GRPC_CORE_LIB_DEBUG_TRACE_H */

@ -22,10 +22,6 @@
#include <grpc/slice.h>
#include "src/core/lib/http/httpcli.h"
#ifdef __cplusplus
extern "C" {
#endif
grpc_slice grpc_httpcli_format_get_request(const grpc_httpcli_request* request);
grpc_slice grpc_httpcli_format_post_request(const grpc_httpcli_request* request,
const char* body_bytes,
@ -33,8 +29,4 @@ grpc_slice grpc_httpcli_format_post_request(const grpc_httpcli_request* request,
grpc_slice grpc_httpcli_format_connect_request(
const grpc_httpcli_request* request);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_HTTP_FORMAT_REQUEST_H */

@ -32,10 +32,6 @@
/* User agent this library reports */
#define GRPC_HTTPCLI_USER_AGENT "grpc-httpcli/0.0"
#ifdef __cplusplus
extern "C" {
#endif
/* Tracks in-progress http requests
TODO(ctiller): allow caching and capturing multiple requests for the
same content and combining them */
@ -126,8 +122,4 @@ typedef int (*grpc_httpcli_post_override)(const grpc_httpcli_request* request,
void grpc_httpcli_set_override(grpc_httpcli_get_override get,
grpc_httpcli_post_override post);
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_HTTP_HTTPCLI_H */

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

Loading…
Cancel
Save