aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/client_config/connector.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/client_config/connector.h')
-rw-r--r--src/core/client_config/connector.h19
1 files changed, 9 insertions, 10 deletions
diff --git a/src/core/client_config/connector.h b/src/core/client_config/connector.h
index 01aa716412..e9b8be4b53 100644
--- a/src/core/client_config/connector.h
+++ b/src/core/client_config/connector.h
@@ -55,8 +55,6 @@ typedef struct {
gpr_timespec deadline;
/** channel arguments (to be passed to transport) */
const grpc_channel_args *channel_args;
- /** metadata context */
- grpc_mdctx *metadata_context;
} grpc_connect_in_args;
typedef struct {
@@ -69,23 +67,24 @@ typedef struct {
struct grpc_connector_vtable {
void (*ref)(grpc_connector *connector);
- void (*unref)(grpc_connector *connector);
+ void (*unref)(grpc_exec_ctx *exec_ctx, grpc_connector *connector);
/** Implementation of grpc_connector_shutdown */
- void (*shutdown)(grpc_connector *connector);
+ void (*shutdown)(grpc_exec_ctx *exec_ctx, grpc_connector *connector);
/** Implementation of grpc_connector_connect */
- void (*connect)(grpc_connector *connector,
+ void (*connect)(grpc_exec_ctx *exec_ctx, grpc_connector *connector,
const grpc_connect_in_args *in_args,
- grpc_connect_out_args *out_args, grpc_iomgr_closure *notify);
+ grpc_connect_out_args *out_args, grpc_closure *notify);
};
void grpc_connector_ref(grpc_connector *connector);
-void grpc_connector_unref(grpc_connector *connector);
+void grpc_connector_unref(grpc_exec_ctx *exec_ctx, grpc_connector *connector);
/** Connect using the connector: max one outstanding call at a time */
-void grpc_connector_connect(grpc_connector *connector,
+void grpc_connector_connect(grpc_exec_ctx *exec_ctx, grpc_connector *connector,
const grpc_connect_in_args *in_args,
grpc_connect_out_args *out_args,
- grpc_iomgr_closure *notify);
+ grpc_closure *notify);
/** Cancel any pending connection */
-void grpc_connector_shutdown(grpc_connector *connector);
+void grpc_connector_shutdown(grpc_exec_ctx *exec_ctx,
+ grpc_connector *connector);
#endif