aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/httpcli/httpcli.c
diff options
context:
space:
mode:
authorGravatar Craig Tiller <craig.tiller@gmail.com>2015-05-11 10:09:09 -0700
committerGravatar Craig Tiller <craig.tiller@gmail.com>2015-05-11 10:09:09 -0700
commitca22c972b058d498568df599fea4a6f80685c85b (patch)
treed4bca3888dcacc0033b2bb623f5a9b75d7f5ef97 /src/core/httpcli/httpcli.c
parent6a29aa051b28fc14c135f36cbe2133086adff67b (diff)
More plumbing work through creds framework
Diffstat (limited to 'src/core/httpcli/httpcli.c')
-rw-r--r--src/core/httpcli/httpcli.c7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/core/httpcli/httpcli.c b/src/core/httpcli/httpcli.c
index fe7ea6a86b..54cc992545 100644
--- a/src/core/httpcli/httpcli.c
+++ b/src/core/httpcli/httpcli.c
@@ -59,6 +59,7 @@ typedef struct {
int use_ssl;
grpc_httpcli_response_cb on_response;
void *user_data;
+ grpc_pollset_set *interested_parties;
} internal_request;
static grpc_httpcli_get_override g_get_override = NULL;
@@ -206,7 +207,7 @@ static void next_address(internal_request *req) {
return;
}
addr = &req->addresses->addrs[req->next_address++];
- grpc_tcp_client_connect(on_connected, req, (struct sockaddr *)&addr->addr,
+ grpc_tcp_client_connect(on_connected, req, req->interested_parties, (struct sockaddr *)&addr->addr,
addr->len, req->deadline);
}
@@ -224,6 +225,7 @@ static void on_resolved(void *arg, grpc_resolved_addresses *addresses) {
void grpc_httpcli_get(const grpc_httpcli_request *request,
gpr_timespec deadline,
+ grpc_pollset_set *interested_parties,
grpc_httpcli_response_cb on_response, void *user_data) {
internal_request *req;
if (g_get_override &&
@@ -238,6 +240,7 @@ void grpc_httpcli_get(const grpc_httpcli_request *request,
req->user_data = user_data;
req->deadline = deadline;
req->use_ssl = request->use_ssl;
+ req->interested_parties = interested_parties;
if (req->use_ssl) {
req->host = gpr_strdup(request->host);
}
@@ -249,6 +252,7 @@ void grpc_httpcli_get(const grpc_httpcli_request *request,
void grpc_httpcli_post(const grpc_httpcli_request *request,
const char *body_bytes, size_t body_size,
gpr_timespec deadline,
+ grpc_pollset_set *interested_parties,
grpc_httpcli_response_cb on_response, void *user_data) {
internal_request *req;
if (g_post_override && g_post_override(request, body_bytes, body_size,
@@ -264,6 +268,7 @@ void grpc_httpcli_post(const grpc_httpcli_request *request,
req->user_data = user_data;
req->deadline = deadline;
req->use_ssl = request->use_ssl;
+ req->interested_parties = interested_parties;
if (req->use_ssl) {
req->host = gpr_strdup(request->host);
}