aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/end2end/tests/no_op.c
diff options
context:
space:
mode:
Diffstat (limited to 'test/core/end2end/tests/no_op.c')
-rw-r--r--test/core/end2end/tests/no_op.c102
1 files changed, 38 insertions, 64 deletions
diff --git a/test/core/end2end/tests/no_op.c b/test/core/end2end/tests/no_op.c
index 0f15963a4a..157d0d5349 100644
--- a/test/core/end2end/tests/no_op.c
+++ b/test/core/end2end/tests/no_op.c
@@ -43,90 +43,64 @@
#include <grpc/support/useful.h>
#include "test/core/end2end/cq_verifier.h"
-enum
-{ TIMEOUT = 200000 };
+enum { TIMEOUT = 200000 };
-static void *
-tag (gpr_intptr t)
-{
- return (void *) t;
-}
+static void *tag(gpr_intptr t) { return (void *)t; }
-static grpc_end2end_test_fixture
-begin_test (grpc_end2end_test_config config, const char *test_name, grpc_channel_args * client_args, grpc_channel_args * server_args)
-{
+static grpc_end2end_test_fixture begin_test(grpc_end2end_test_config config,
+ const char *test_name,
+ grpc_channel_args *client_args,
+ grpc_channel_args *server_args) {
grpc_end2end_test_fixture f;
- gpr_log (GPR_INFO, "%s/%s", test_name, config.name);
- f = config.create_fixture (client_args, server_args);
- config.init_client (&f, client_args);
- config.init_server (&f, server_args);
+ gpr_log(GPR_INFO, "%s/%s", test_name, config.name);
+ f = config.create_fixture(client_args, server_args);
+ config.init_client(&f, client_args);
+ config.init_server(&f, server_args);
return f;
}
-static gpr_timespec
-n_seconds_time (int n)
-{
- return GRPC_TIMEOUT_SECONDS_TO_DEADLINE (n);
+static gpr_timespec n_seconds_time(int n) {
+ return GRPC_TIMEOUT_SECONDS_TO_DEADLINE(n);
}
-static gpr_timespec
-five_seconds_time (void)
-{
- return n_seconds_time (5);
-}
+static gpr_timespec five_seconds_time(void) { return n_seconds_time(5); }
-static void
-drain_cq (grpc_completion_queue * cq)
-{
+static void drain_cq(grpc_completion_queue *cq) {
grpc_event ev;
- do
- {
- ev = grpc_completion_queue_next (cq, five_seconds_time (), NULL);
- }
- while (ev.type != GRPC_QUEUE_SHUTDOWN);
+ do {
+ ev = grpc_completion_queue_next(cq, five_seconds_time(), NULL);
+ } while (ev.type != GRPC_QUEUE_SHUTDOWN);
}
-static void
-shutdown_server (grpc_end2end_test_fixture * f)
-{
- if (!f->server)
- return;
- grpc_server_shutdown_and_notify (f->server, f->cq, tag (1000));
- GPR_ASSERT (grpc_completion_queue_pluck (f->cq, tag (1000), GRPC_TIMEOUT_SECONDS_TO_DEADLINE (5), NULL).type == GRPC_OP_COMPLETE);
- grpc_server_destroy (f->server);
+static void shutdown_server(grpc_end2end_test_fixture *f) {
+ if (!f->server) return;
+ grpc_server_shutdown_and_notify(f->server, f->cq, tag(1000));
+ GPR_ASSERT(grpc_completion_queue_pluck(
+ f->cq, tag(1000), GRPC_TIMEOUT_SECONDS_TO_DEADLINE(5), NULL)
+ .type == GRPC_OP_COMPLETE);
+ grpc_server_destroy(f->server);
f->server = NULL;
}
-static void
-shutdown_client (grpc_end2end_test_fixture * f)
-{
- if (!f->client)
- return;
- grpc_channel_destroy (f->client);
+static void shutdown_client(grpc_end2end_test_fixture *f) {
+ if (!f->client) return;
+ grpc_channel_destroy(f->client);
f->client = NULL;
}
-static void
-end_test (grpc_end2end_test_fixture * f)
-{
- shutdown_server (f);
- shutdown_client (f);
+static void end_test(grpc_end2end_test_fixture *f) {
+ shutdown_server(f);
+ shutdown_client(f);
- grpc_completion_queue_shutdown (f->cq);
- drain_cq (f->cq);
- grpc_completion_queue_destroy (f->cq);
+ grpc_completion_queue_shutdown(f->cq);
+ drain_cq(f->cq);
+ grpc_completion_queue_destroy(f->cq);
}
-static void
-test_no_op (grpc_end2end_test_config config)
-{
- grpc_end2end_test_fixture f = begin_test (config, "no-op", NULL, NULL);
- end_test (&f);
- config.tear_down_data (&f);
+static void test_no_op(grpc_end2end_test_config config) {
+ grpc_end2end_test_fixture f = begin_test(config, "no-op", NULL, NULL);
+ end_test(&f);
+ config.tear_down_data(&f);
}
-void
-grpc_end2end_tests (grpc_end2end_test_config config)
-{
- test_no_op (config);
-}
+void grpc_end2end_tests(grpc_end2end_test_config config) { test_no_op(config); }