aboutsummaryrefslogtreecommitdiffhomepage
path: root/test
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-12-16 19:42:09 -0800
committerGravatar Craig Tiller <ctiller@google.com>2015-12-16 19:42:09 -0800
commita3f298ff67e8ee3ada117de136ea2469a146dc5e (patch)
tree89a2a09193d37eb327dbf9bcd13d2bf87419f2f5 /test
parent8a09593639e797e609d7044e8230c2c2a73fcdcc (diff)
clang-format
Diffstat (limited to 'test')
-rw-r--r--test/core/bad_client/tests/window_overflow.c28
-rw-r--r--test/core/bad_ssl/bad_ssl_test.c2
-rw-r--r--test/core/bad_ssl/server.c7
-rw-r--r--test/core/client_config/lb_policies_test.c21
4 files changed, 26 insertions, 32 deletions
diff --git a/test/core/bad_client/tests/window_overflow.c b/test/core/bad_client/tests/window_overflow.c
index 37a3228285..1c898f352d 100644
--- a/test/core/bad_client/tests/window_overflow.c
+++ b/test/core/bad_client/tests/window_overflow.c
@@ -52,11 +52,13 @@
"\x10\x0c" \
"content-type\x10" \
"application/grpc" \
- "\x10\x14grpc-accept-encoding\x15""deflate,identity,gzip" \
+ "\x10\x14grpc-accept-encoding\x15" \
+ "deflate,identity,gzip" \
"\x10\x02te\x08trailers" \
"\x10\x0auser-agent\"bad-client grpc-c/0.12.0.0 (linux)"
-static void verifier(grpc_server *server, grpc_completion_queue *cq, void *registered_method) {
+static void verifier(grpc_server *server, grpc_completion_queue *cq,
+ void *registered_method) {
while (grpc_server_has_open_connections(server)) {
GPR_ASSERT(grpc_completion_queue_next(cq,
GRPC_TIMEOUT_MILLIS_TO_DEADLINE(20),
@@ -80,28 +82,20 @@ static void addbuf(const void *data, size_t len) {
int main(int argc, char **argv) {
int i, j;
#define MAX_FRAME_SIZE 16384
-#define MESSAGES_PER_FRAME (MAX_FRAME_SIZE/5)
-#define FRAME_SIZE (MESSAGES_PER_FRAME*5)
-#define SEND_SIZE (100*1024)
+#define MESSAGES_PER_FRAME (MAX_FRAME_SIZE / 5)
+#define FRAME_SIZE (MESSAGES_PER_FRAME * 5)
+#define SEND_SIZE (100 * 1024)
#define NUM_FRAMES (SEND_SIZE / FRAME_SIZE + 1)
grpc_test_init(argc, argv);
addbuf(PFX_STR, sizeof(PFX_STR) - 1);
for (i = 0; i < NUM_FRAMES; i++) {
- gpr_uint8 hdr[9] = {
- (gpr_uint8)(FRAME_SIZE >> 16),
- (gpr_uint8)(FRAME_SIZE >> 8),
- (gpr_uint8)FRAME_SIZE,
- 0,
- 0,
- 0,
- 0,
- 0,
- 1
- };
+ gpr_uint8 hdr[9] = {(gpr_uint8)(FRAME_SIZE >> 16),
+ (gpr_uint8)(FRAME_SIZE >> 8), (gpr_uint8)FRAME_SIZE, 0,
+ 0, 0, 0, 0, 1};
addbuf(hdr, sizeof(hdr));
for (j = 0; j < MESSAGES_PER_FRAME; j++) {
- gpr_uint8 message[5] = {0,0,0,0,0};
+ gpr_uint8 message[5] = {0, 0, 0, 0, 0};
addbuf(message, sizeof(message));
}
}
diff --git a/test/core/bad_ssl/bad_ssl_test.c b/test/core/bad_ssl/bad_ssl_test.c
index 54ac6d0e1c..08ab482c58 100644
--- a/test/core/bad_ssl/bad_ssl_test.c
+++ b/test/core/bad_ssl/bad_ssl_test.c
@@ -163,7 +163,7 @@ int main(int argc, char **argv) {
grpc_shutdown();
}
gpr_free(args[2]);
-
+
gpr_subprocess_interrupt(svr);
status = gpr_subprocess_join(svr);
gpr_subprocess_destroy(svr);
diff --git a/test/core/bad_ssl/server.c b/test/core/bad_ssl/server.c
index 2ed94de099..6113d364c9 100644
--- a/test/core/bad_ssl/server.c
+++ b/test/core/bad_ssl/server.c
@@ -74,9 +74,8 @@ void bad_ssl_run(grpc_server *server) {
grpc_server_register_completion_queue(server, cq, NULL);
grpc_server_start(server);
- error =
- grpc_server_request_call(server, &s, &call_details,
- &request_metadata_recv, cq, cq, (void*)1);
+ error = grpc_server_request_call(server, &s, &call_details,
+ &request_metadata_recv, cq, cq, (void *)1);
GPR_ASSERT(GRPC_CALL_OK == error);
signal(SIGINT, sigint_handler);
@@ -96,7 +95,7 @@ void bad_ssl_run(grpc_server *server) {
NULL);
switch (ev.type) {
case GRPC_OP_COMPLETE:
- GPR_ASSERT(ev.tag == (void*)1);
+ GPR_ASSERT(ev.tag == (void *)1);
GPR_ASSERT(ev.success == 0);
break;
case GRPC_QUEUE_SHUTDOWN:
diff --git a/test/core/client_config/lb_policies_test.c b/test/core/client_config/lb_policies_test.c
index c088fe2c09..5f6166cbb5 100644
--- a/test/core/client_config/lb_policies_test.c
+++ b/test/core/client_config/lb_policies_test.c
@@ -137,9 +137,8 @@ static void kill_server(const servers_fixture *f, size_t i) {
gpr_log(GPR_INFO, "KILLING SERVER %d", i);
GPR_ASSERT(f->servers[i] != NULL);
grpc_server_shutdown_and_notify(f->servers[i], f->cq, tag(10000));
- GPR_ASSERT(
- grpc_completion_queue_pluck(f->cq, tag(10000), n_millis_time(5000), NULL)
- .type == GRPC_OP_COMPLETE);
+ GPR_ASSERT(grpc_completion_queue_pluck(f->cq, tag(10000), n_millis_time(5000),
+ NULL).type == GRPC_OP_COMPLETE);
grpc_server_destroy(f->servers[i]);
f->servers[i] = NULL;
}
@@ -205,8 +204,8 @@ static void teardown_servers(servers_fixture *f) {
if (f->servers[i] == NULL) continue;
grpc_server_shutdown_and_notify(f->servers[i], f->cq, tag(10000));
GPR_ASSERT(grpc_completion_queue_pluck(f->cq, tag(10000),
- n_millis_time(5000), NULL)
- .type == GRPC_OP_COMPLETE);
+ n_millis_time(5000),
+ NULL).type == GRPC_OP_COMPLETE);
grpc_server_destroy(f->servers[i]);
}
grpc_completion_queue_shutdown(f->cq);
@@ -304,8 +303,8 @@ static int *perform_request(servers_fixture *f, grpc_channel *client,
s_idx = -1;
while ((ev = grpc_completion_queue_next(
- f->cq, GRPC_TIMEOUT_SECONDS_TO_DEADLINE(1), NULL))
- .type != GRPC_QUEUE_TIMEOUT) {
+ f->cq, GRPC_TIMEOUT_SECONDS_TO_DEADLINE(1), NULL)).type !=
+ GRPC_QUEUE_TIMEOUT) {
GPR_ASSERT(ev.type == GRPC_OP_COMPLETE);
read_tag = ((int)(gpr_intptr)ev.tag);
gpr_log(GPR_DEBUG, "EVENT: success:%d, type:%d, tag:%d iter:%d",
@@ -377,8 +376,9 @@ static int *perform_request(servers_fixture *f, grpc_channel *client,
}
}
- GPR_ASSERT(grpc_completion_queue_next(
- f->cq, GRPC_TIMEOUT_MILLIS_TO_DEADLINE(200), NULL).type == GRPC_QUEUE_TIMEOUT);
+ GPR_ASSERT(grpc_completion_queue_next(f->cq,
+ GRPC_TIMEOUT_MILLIS_TO_DEADLINE(200),
+ NULL).type == GRPC_QUEUE_TIMEOUT);
grpc_metadata_array_destroy(&rdata->initial_metadata_recv);
grpc_metadata_array_destroy(&rdata->trailing_metadata_recv);
@@ -800,7 +800,8 @@ static void verify_rebirth_round_robin(const servers_fixture *f,
const size_t expected_seq_length = f->num_servers;
int *seen_elements;
- dump_array("actual_connection_sequence", actual_connection_sequence, num_iters);
+ dump_array("actual_connection_sequence", actual_connection_sequence,
+ num_iters);
/* verify conn. seq. expectation */
/* get the first unique run of length "num_servers". */