diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-02-24 15:30:51 -0800 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2017-02-24 15:30:51 -0800 |
| commit | 3d72d71c7cfc9a04cf84911c8e03d22a80176d9d (patch) | |
| tree | d6c1ccc219d8d93b0de2f9de06445e83069ddc1f /src/core/lib/iomgr/tcp_client_uv.c | |
| parent | b82b3d0e528cf46d6583c3e4ba1313a943951ffb (diff) | |
| parent | e1bc938b440f39cafafd327ecff034fa3dda7b1d (diff) | |
Merge github.com:grpc/grpc into zalloc
Diffstat (limited to 'src/core/lib/iomgr/tcp_client_uv.c')
| -rw-r--r-- | src/core/lib/iomgr/tcp_client_uv.c | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/src/core/lib/iomgr/tcp_client_uv.c b/src/core/lib/iomgr/tcp_client_uv.c index 9bd10a1d26..ae66577caf 100644 --- a/src/core/lib/iomgr/tcp_client_uv.c +++ b/src/core/lib/iomgr/tcp_client_uv.c @@ -46,6 +46,8 @@ #include "src/core/lib/iomgr/tcp_uv.h" #include "src/core/lib/iomgr/timer.h" +extern int grpc_tcp_trace; + typedef struct grpc_uv_tcp_connect { uv_connect_t connect_req; grpc_timer alarm; @@ -70,6 +72,12 @@ static void uv_tc_on_alarm(grpc_exec_ctx *exec_ctx, void *acp, grpc_error *error) { int done; grpc_uv_tcp_connect *connect = acp; + if (grpc_tcp_trace) { + const char *str = grpc_error_string(error); + gpr_log(GPR_DEBUG, "CLIENT_CONNECT: %s: on_alarm: error=%s", + connect->addr_name, str); + grpc_error_free_string(str); + } if (error == GRPC_ERROR_NONE) { /* error == NONE implies that the timer ran out, and wasn't cancelled. If it was cancelled, then the handler that cancelled it also should close @@ -144,6 +152,12 @@ static void tcp_client_connect_impl(grpc_exec_ctx *exec_ctx, connect->resource_quota = resource_quota; uv_tcp_init(uv_default_loop(), connect->tcp_handle); connect->connect_req.data = connect; + + if (grpc_tcp_trace) { + gpr_log(GPR_DEBUG, "CLIENT_CONNECT: %s: asynchronously connecting", + connect->addr_name); + } + // TODO(murgatroid99): figure out what the return value here means uv_tcp_connect(&connect->connect_req, connect->tcp_handle, (const struct sockaddr *)resolved_addr->addr, |