diff options
| author |  David Garcia Quintas <dgq@google.com> | 2016-05-03 18:28:09 -0700 |
|---|---|---|
| committer | David Garcia Quintas <dgq@google.com> | 2016-05-03 18:28:09 -0700 |
| commit | f72eb97b3640cb3f99336b34b707c853c6db6ac0 (patch) | |
| tree | 90faf5420288fae668259328ae57da14dc0cb64e /src/core/lib/channel/connected_channel.c | |
| parent | 12e111c6929a689f37fd18deebe5ca64a088094f (diff) | |
Introduced grpc_pops (pollset or pollset_set)
Diffstat (limited to 'src/core/lib/channel/connected_channel.c')
| -rw-r--r-- | src/core/lib/channel/connected_channel.c | 19 |
1 files changed, 5 insertions, 14 deletions
diff --git a/src/core/lib/channel/connected_channel.c b/src/core/lib/channel/connected_channel.c index 405f0a2ecd..314ff6e5ce 100644 --- a/src/core/lib/channel/connected_channel.c +++ b/src/core/lib/channel/connected_channel.c @@ -93,22 +93,13 @@ static void init_call_elem(grpc_exec_ctx *exec_ctx, grpc_call_element *elem, GPR_ASSERT(r == 0); } -static void set_pollset_or_pollset_set( - grpc_exec_ctx *exec_ctx, grpc_call_element *elem, grpc_pollset *pollset, - grpc_pollset_set *pollset_set_alternative) { - GPR_ASSERT((pollset == NULL) + (pollset_set_alternative == NULL) == 1); - GPR_ASSERT(pollset != NULL || pollset_set_alternative != NULL); - +static void set_pollset_or_pollset_set(grpc_exec_ctx *exec_ctx, + grpc_call_element *elem, + grpc_pops *pops) { call_data *calld = elem->call_data; channel_data *chand = elem->channel_data; - if (pollset != NULL) { - grpc_transport_set_pollset(exec_ctx, chand->transport, - TRANSPORT_STREAM_FROM_CALL_DATA(calld), pollset); - } else if (pollset_set_alternative != NULL) { - grpc_transport_set_pollset_set(exec_ctx, chand->transport, - TRANSPORT_STREAM_FROM_CALL_DATA(calld), - pollset_set_alternative); - } + grpc_transport_set_pops(exec_ctx, chand->transport, + TRANSPORT_STREAM_FROM_CALL_DATA(calld), pops); } /* Destructor for call_data */ |