diff options
| author |  Craig Tiller <craig.tiller@gmail.com> | 2015-07-20 14:04:18 -0700 |
|---|---|---|
| committer | Craig Tiller <craig.tiller@gmail.com> | 2015-07-20 14:04:18 -0700 |
| commit | 81bcc4caba6fb137c306b818ca0acfe3692c31ff (patch) | |
| tree | a4347dcf232671ff2a9d9bae401c1118d5cef406 /src/core/iomgr/tcp_client_windows.c | |
| parent | 1b22b9db94784bc589d372e2b30eb939d009c3d9 (diff) | |
Make endpoint peer API work on Windows
Diffstat (limited to 'src/core/iomgr/tcp_client_windows.c')
| -rw-r--r-- | src/core/iomgr/tcp_client_windows.c | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/core/iomgr/tcp_client_windows.c b/src/core/iomgr/tcp_client_windows.c index 16741452b9..32dd1ec11d 100644 --- a/src/core/iomgr/tcp_client_windows.c +++ b/src/core/iomgr/tcp_client_windows.c @@ -58,6 +58,7 @@ typedef struct { grpc_winsocket *socket; gpr_timespec deadline; grpc_alarm alarm; + char *addr_name; int refs; int aborted; } async_connect; @@ -67,6 +68,7 @@ static void async_connect_cleanup(async_connect *ac) { gpr_mu_unlock(&ac->mu); if (done) { gpr_mu_destroy(&ac->mu); + gpr_free(ac->addr_name); gpr_free(ac); } } @@ -107,7 +109,7 @@ static void on_connect(void *acp, int from_iocp) { gpr_log(GPR_ERROR, "on_connect error: %s", utf8_message); gpr_free(utf8_message); } else if (!aborted) { - ep = grpc_tcp_create(ac->socket); + ep = grpc_tcp_create(ac->socket, ac->addr_name); } } else { gpr_log(GPR_ERROR, "on_connect is shutting down"); @@ -213,6 +215,7 @@ void grpc_tcp_client_connect(void (*cb)(void *arg, grpc_endpoint *tcp), ac->socket = socket; gpr_mu_init(&ac->mu); ac->refs = 2; + ac->addr_name = grpc_sockaddr_to_uri(addr); ac->aborted = 0; grpc_alarm_init(&ac->alarm, deadline, on_alarm, ac, |