diff options
author | 2018-06-11 15:19:06 -0700 | |
---|---|---|
committer | 2018-06-13 15:01:05 -0700 | |
commit | 1198d8dfc625ce123c591d8f5079e75f23f772e5 (patch) | |
tree | 5237875767d8ee43a69b85a183619b5f77514d13 /src/core/lib/iomgr/tcp_client_posix.cc | |
parent | f82e28fb6f6d94f37bc646c1899f2e412e4b949e (diff) |
Reviewer feedback
Diffstat (limited to 'src/core/lib/iomgr/tcp_client_posix.cc')
-rw-r--r-- | src/core/lib/iomgr/tcp_client_posix.cc | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/src/core/lib/iomgr/tcp_client_posix.cc b/src/core/lib/iomgr/tcp_client_posix.cc index 7c4a437dbf..30015fc203 100644 --- a/src/core/lib/iomgr/tcp_client_posix.cc +++ b/src/core/lib/iomgr/tcp_client_posix.cc @@ -66,6 +66,7 @@ typedef struct { static grpc_error* prepare_socket(const grpc_resolved_address* addr, int fd, const grpc_channel_args* channel_args) { grpc_error* err = GRPC_ERROR_NONE; + grpc_socket_mutator* mutator = nullptr; GPR_ASSERT(fd >= 0); @@ -79,15 +80,11 @@ static grpc_error* prepare_socket(const grpc_resolved_address* addr, int fd, } err = grpc_set_socket_no_sigpipe_if_possible(fd); if (err != GRPC_ERROR_NONE) goto error; - if (channel_args) { - const grpc_arg* arg = - grpc_channel_args_find(channel_args, GRPC_ARG_SOCKET_MUTATOR); - grpc_socket_mutator* mutator = - grpc_channel_arg_get_pointer<grpc_socket_mutator>(arg); - if (mutator) { - err = grpc_set_socket_with_mutator(fd, mutator); - if (err != GRPC_ERROR_NONE) goto error; - } + mutator = grpc_channel_args_get_pointer<grpc_socket_mutator>( + channel_args, GRPC_ARG_SOCKET_MUTATOR); + if (mutator != nullptr) { + err = grpc_set_socket_with_mutator(fd, mutator); + if (err != GRPC_ERROR_NONE) goto error; } goto done; |