diff options
| author |  Yihua Zhang <yihuaz@google.com> | 2018-10-02 19:21:32 -0700 |
|---|---|---|
| committer | Yihua Zhang <yihuaz@google.com> | 2018-10-02 19:21:32 -0700 |
| commit | c0fa62f2b6248e450a15b3e1f24e6dd5b6a28e91 (patch) | |
| tree | 474d3358c56e5c83d9677efff611ad6a84732522 /src/core/ext/transport/chttp2/server | |
| parent | 95dc4f1b8dfe30c7b983147690f483e0894687fd (diff) | |
pass a pollset_set to ALTS TSI handshaker
Diffstat (limited to 'src/core/ext/transport/chttp2/server')
| -rw-r--r-- | src/core/ext/transport/chttp2/server/chttp2_server.cc | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/core/ext/transport/chttp2/server/chttp2_server.cc b/src/core/ext/transport/chttp2/server/chttp2_server.cc index 3f8a26ae32..b95baa9191 100644 --- a/src/core/ext/transport/chttp2/server/chttp2_server.cc +++ b/src/core/ext/transport/chttp2/server/chttp2_server.cc @@ -67,6 +67,7 @@ typedef struct { grpc_timer timer; grpc_closure on_timeout; grpc_closure on_receive_settings; + grpc_pollset_set* interested_parties; } server_connection_state; static void server_connection_state_unref( @@ -76,6 +77,9 @@ static void server_connection_state_unref( GRPC_CHTTP2_UNREF_TRANSPORT(connection_state->transport, "receive settings timeout"); } + grpc_pollset_set_del_pollset(connection_state->interested_parties, + connection_state->accepting_pollset); + grpc_pollset_set_destroy(connection_state->interested_parties); gpr_free(connection_state); } } @@ -189,7 +193,11 @@ static void on_accept(void* arg, grpc_endpoint* tcp, connection_state->accepting_pollset = accepting_pollset; connection_state->acceptor = acceptor; connection_state->handshake_mgr = handshake_mgr; + connection_state->interested_parties = grpc_pollset_set_create(); + grpc_pollset_set_add_pollset(connection_state->interested_parties, + connection_state->accepting_pollset); grpc_handshakers_add(HANDSHAKER_SERVER, state->args, + connection_state->interested_parties, connection_state->handshake_mgr); const grpc_arg* timeout_arg = grpc_channel_args_find(state->args, GRPC_ARG_SERVER_HANDSHAKE_TIMEOUT_MS); |