diff options
| author |  Hongwei Wang <hongweiw@google.com> | 2015-07-31 15:12:51 -0700 |
|---|---|---|
| committer | Hongwei Wang <hongweiw@google.com> | 2015-07-31 15:12:51 -0700 |
| commit | 8e04d4107ef07c5914b84f14d4f1b0771090c1b0 (patch) | |
| tree | 14206b326e720799472ff662ff03142da09f4866 /src/core/surface | |
| parent | 62b9080a1d1a7b0b7d463d7528b9150fc49d2c62 (diff) | |
Add zookeeper end-to-end test
Diffstat (limited to 'src/core/surface')
| -rw-r--r-- | src/core/surface/channel.c | 3 | ||||
| -rw-r--r-- | src/core/surface/init.c | 16 |
2 files changed, 10 insertions, 9 deletions
diff --git a/src/core/surface/channel.c b/src/core/surface/channel.c index 583d350128..f13f102e14 100644 --- a/src/core/surface/channel.c +++ b/src/core/surface/channel.c @@ -104,7 +104,8 @@ grpc_channel *grpc_channel_create_from_filters( channel->grpc_status_string = grpc_mdstr_from_string(mdctx, "grpc-status", 0); channel->grpc_compression_algorithm_string = grpc_mdstr_from_string(mdctx, "grpc-encoding", 0); - channel->grpc_message_string = grpc_mdstr_from_string(mdctx, "grpc-message", 0); + channel->grpc_message_string = + grpc_mdstr_from_string(mdctx, "grpc-message", 0); for (i = 0; i < NUM_CACHED_STATUS_ELEMS; i++) { char buf[GPR_LTOA_MIN_BUFSIZE]; gpr_ltoa(i, buf); diff --git a/src/core/surface/init.c b/src/core/surface/init.c index 7dedba1e10..cbb94a82b5 100644 --- a/src/core/surface/init.c +++ b/src/core/surface/init.c @@ -64,13 +64,13 @@ static void do_basic_init(void) { typedef struct grpc_plugin { void (*init)(); void (*deinit)(); - struct grpc_plugin* next; + struct grpc_plugin *next; } grpc_plugin; -static grpc_plugin* g_plugins_head = NULL; +static grpc_plugin *g_plugins_head = NULL; -static grpc_plugin* new_plugin(void (*init)(void), void (*deinit)(void)) { - grpc_plugin* plugin = gpr_malloc(sizeof(*plugin)); +static grpc_plugin *new_plugin(void (*init)(void), void (*deinit)(void)) { + grpc_plugin *plugin = gpr_malloc(sizeof(*plugin)); memset(plugin, 0, sizeof(*plugin)); plugin->init = init; plugin->deinit = deinit; @@ -79,13 +79,13 @@ static grpc_plugin* new_plugin(void (*init)(void), void (*deinit)(void)) { } void grpc_register_plugin(void (*init)(void), void (*deinit)(void)) { - grpc_plugin* old_head = g_plugins_head; + grpc_plugin *old_head = g_plugins_head; g_plugins_head = new_plugin(init, deinit); g_plugins_head->next = old_head; } void grpc_init(void) { - grpc_plugin* plugin; + grpc_plugin *plugin; gpr_once_init(&g_basic_init, do_basic_init); gpr_mu_lock(&g_init_mu); @@ -121,8 +121,8 @@ void grpc_init(void) { } void grpc_shutdown(void) { - grpc_plugin* plugin; - grpc_plugin* next; + grpc_plugin *plugin; + grpc_plugin *next; gpr_mu_lock(&g_init_mu); if (--g_initializations == 0) { |