diff options
author | 2014-12-15 14:52:08 -0800 | |
---|---|---|
committer | 2014-12-15 15:39:03 -0800 | |
commit | c6d61c4dd6deb80477cb5977b79b00614b20b409 (patch) | |
tree | 649e913ff67706ee2c41a7cb3102c135424b8f35 /test/core/end2end/fixtures/chttp2_simple_ssl_fullstack.c | |
parent | 608254011d441b1e234fc5d6aa528cedccaddda3 (diff) |
GOAWAY & Reconnection support.
Clients stay connected to a server after it shutdowns until all active calls
have completed, and then they drop.
After a GOAWAY or a disconnect, clients will attempt to re-resolve and
reconnect to the server.
Change on 2014/12/15 by ctiller <ctiller@google.com>
-------------
Created by MOE: http://code.google.com/p/moe-java
MOE_MIGRATED_REVID=82178515
Diffstat (limited to 'test/core/end2end/fixtures/chttp2_simple_ssl_fullstack.c')
-rw-r--r-- | test/core/end2end/fixtures/chttp2_simple_ssl_fullstack.c | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/test/core/end2end/fixtures/chttp2_simple_ssl_fullstack.c b/test/core/end2end/fixtures/chttp2_simple_ssl_fullstack.c index 7b0adb2e8c..047cb801c7 100644 --- a/test/core/end2end/fixtures/chttp2_simple_ssl_fullstack.c +++ b/test/core/end2end/fixtures/chttp2_simple_ssl_fullstack.c @@ -56,6 +56,7 @@ static grpc_end2end_test_fixture chttp2_create_fixture_secure_fullstack( int port = grpc_pick_unused_port_or_die(); fullstack_secure_fixture_data *ffd = gpr_malloc(sizeof(fullstack_secure_fixture_data)); + memset(&f, 0, sizeof(f)); gpr_join_host_port(&ffd->localaddr, "localhost", port); @@ -79,10 +80,13 @@ static void chttp2_init_server_secure_fullstack( grpc_end2end_test_fixture *f, grpc_channel_args *server_args, grpc_server_credentials *server_creds) { fullstack_secure_fixture_data *ffd = f->fixture_data; + if (f->server) { + grpc_server_destroy(f->server); + } f->server = grpc_secure_server_create(server_creds, f->server_cq, server_args); grpc_server_credentials_release(server_creds); - grpc_server_add_secure_http2_port(f->server, ffd->localaddr); + GPR_ASSERT(grpc_server_add_secure_http2_port(f->server, ffd->localaddr)); grpc_server_start(f->server); } |