aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/end2end/tests/invoke_large_request.c
diff options
context:
space:
mode:
Diffstat (limited to 'test/core/end2end/tests/invoke_large_request.c')
-rw-r--r--test/core/end2end/tests/invoke_large_request.c202
1 files changed, 109 insertions, 93 deletions
diff --git a/test/core/end2end/tests/invoke_large_request.c b/test/core/end2end/tests/invoke_large_request.c
index f79d146da1..da19222c53 100644
--- a/test/core/end2end/tests/invoke_large_request.c
+++ b/test/core/end2end/tests/invoke_large_request.c
@@ -43,78 +43,95 @@
#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 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, n_seconds_time(5), NULL);
- } while (ev.type != GRPC_QUEUE_SHUTDOWN);
+ do
+ {
+ ev = grpc_completion_queue_next (cq, n_seconds_time (5), 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 gpr_slice large_slice(void) {
- gpr_slice slice = gpr_slice_malloc(1000000);
- memset(GPR_SLICE_START_PTR(slice), 'x', GPR_SLICE_LENGTH(slice));
+static gpr_slice
+large_slice (void)
+{
+ gpr_slice slice = gpr_slice_malloc (1000000);
+ memset (GPR_SLICE_START_PTR (slice), 'x', GPR_SLICE_LENGTH (slice));
return slice;
}
-static void test_invoke_large_request(grpc_end2end_test_config config) {
- grpc_end2end_test_fixture f =
- begin_test(config, "test_invoke_large_request", NULL, NULL);
+static void
+test_invoke_large_request (grpc_end2end_test_config config)
+{
+ grpc_end2end_test_fixture f = begin_test (config, "test_invoke_large_request", NULL, NULL);
- gpr_slice request_payload_slice = large_slice();
- gpr_slice response_payload_slice = large_slice();
+ gpr_slice request_payload_slice = large_slice ();
+ gpr_slice response_payload_slice = large_slice ();
grpc_call *c;
grpc_call *s;
- grpc_byte_buffer *request_payload =
- grpc_raw_byte_buffer_create(&request_payload_slice, 1);
- grpc_byte_buffer *response_payload =
- grpc_raw_byte_buffer_create(&response_payload_slice, 1);
- gpr_timespec deadline = n_seconds_time(30);
- cq_verifier *cqv = cq_verifier_create(f.cq);
+ grpc_byte_buffer *request_payload = grpc_raw_byte_buffer_create (&request_payload_slice, 1);
+ grpc_byte_buffer *response_payload = grpc_raw_byte_buffer_create (&response_payload_slice, 1);
+ gpr_timespec deadline = n_seconds_time (30);
+ cq_verifier *cqv = cq_verifier_create (f.cq);
grpc_op ops[6];
grpc_op *op;
grpc_metadata_array initial_metadata_recv;
@@ -129,14 +146,13 @@ static void test_invoke_large_request(grpc_end2end_test_config config) {
size_t details_capacity = 0;
int was_cancelled = 2;
- c = grpc_channel_create_call(f.client, NULL, GRPC_PROPAGATE_DEFAULTS, f.cq,
- "/foo", "foo.test.google.fr", deadline, NULL);
- GPR_ASSERT(c);
+ c = grpc_channel_create_call (f.client, NULL, GRPC_PROPAGATE_DEFAULTS, f.cq, "/foo", "foo.test.google.fr", deadline, NULL);
+ GPR_ASSERT (c);
- grpc_metadata_array_init(&initial_metadata_recv);
- grpc_metadata_array_init(&trailing_metadata_recv);
- grpc_metadata_array_init(&request_metadata_recv);
- grpc_call_details_init(&call_details);
+ grpc_metadata_array_init (&initial_metadata_recv);
+ grpc_metadata_array_init (&trailing_metadata_recv);
+ grpc_metadata_array_init (&request_metadata_recv);
+ grpc_call_details_init (&call_details);
op = ops;
op->op = GRPC_OP_SEND_INITIAL_METADATA;
@@ -171,15 +187,13 @@ static void test_invoke_large_request(grpc_end2end_test_config config) {
op->flags = 0;
op->reserved = NULL;
op++;
- error = grpc_call_start_batch(c, ops, (size_t)(op - ops), tag(1), NULL);
- GPR_ASSERT(GRPC_CALL_OK == error);
+ error = grpc_call_start_batch (c, ops, (size_t) (op - ops), tag (1), NULL);
+ GPR_ASSERT (GRPC_CALL_OK == error);
- error =
- grpc_server_request_call(f.server, &s, &call_details,
- &request_metadata_recv, f.cq, f.cq, tag(101));
- GPR_ASSERT(GRPC_CALL_OK == error);
- cq_expect_completion(cqv, tag(101), 1);
- cq_verify(cqv);
+ error = grpc_server_request_call (f.server, &s, &call_details, &request_metadata_recv, f.cq, f.cq, tag (101));
+ GPR_ASSERT (GRPC_CALL_OK == error);
+ cq_expect_completion (cqv, tag (101), 1);
+ cq_verify (cqv);
op = ops;
op->op = GRPC_OP_SEND_INITIAL_METADATA;
@@ -192,11 +206,11 @@ static void test_invoke_large_request(grpc_end2end_test_config config) {
op->flags = 0;
op->reserved = NULL;
op++;
- error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(102), NULL);
- GPR_ASSERT(GRPC_CALL_OK == error);
+ error = grpc_call_start_batch (s, ops, (size_t) (op - ops), tag (102), NULL);
+ GPR_ASSERT (GRPC_CALL_OK == error);
- cq_expect_completion(cqv, tag(102), 1);
- cq_verify(cqv);
+ cq_expect_completion (cqv, tag (102), 1);
+ cq_verify (cqv);
op = ops;
op->op = GRPC_OP_RECV_CLOSE_ON_SERVER;
@@ -216,41 +230,43 @@ static void test_invoke_large_request(grpc_end2end_test_config config) {
op->flags = 0;
op->reserved = NULL;
op++;
- error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(103), NULL);
- GPR_ASSERT(GRPC_CALL_OK == error);
+ error = grpc_call_start_batch (s, ops, (size_t) (op - ops), tag (103), NULL);
+ GPR_ASSERT (GRPC_CALL_OK == error);
- cq_expect_completion(cqv, tag(103), 1);
- cq_expect_completion(cqv, tag(1), 1);
- cq_verify(cqv);
+ cq_expect_completion (cqv, tag (103), 1);
+ cq_expect_completion (cqv, tag (1), 1);
+ cq_verify (cqv);
- GPR_ASSERT(status == GRPC_STATUS_UNIMPLEMENTED);
- GPR_ASSERT(0 == strcmp(details, "xyz"));
- GPR_ASSERT(0 == strcmp(call_details.method, "/foo"));
- GPR_ASSERT(0 == strcmp(call_details.host, "foo.test.google.fr"));
- GPR_ASSERT(was_cancelled == 1);
+ GPR_ASSERT (status == GRPC_STATUS_UNIMPLEMENTED);
+ GPR_ASSERT (0 == strcmp (details, "xyz"));
+ GPR_ASSERT (0 == strcmp (call_details.method, "/foo"));
+ GPR_ASSERT (0 == strcmp (call_details.host, "foo.test.google.fr"));
+ GPR_ASSERT (was_cancelled == 1);
- gpr_free(details);
- grpc_metadata_array_destroy(&initial_metadata_recv);
- grpc_metadata_array_destroy(&trailing_metadata_recv);
- grpc_metadata_array_destroy(&request_metadata_recv);
- grpc_call_details_destroy(&call_details);
+ gpr_free (details);
+ grpc_metadata_array_destroy (&initial_metadata_recv);
+ grpc_metadata_array_destroy (&trailing_metadata_recv);
+ grpc_metadata_array_destroy (&request_metadata_recv);
+ grpc_call_details_destroy (&call_details);
- grpc_call_destroy(c);
- grpc_call_destroy(s);
+ grpc_call_destroy (c);
+ grpc_call_destroy (s);
- cq_verifier_destroy(cqv);
+ cq_verifier_destroy (cqv);
- grpc_byte_buffer_destroy(request_payload);
- grpc_byte_buffer_destroy(response_payload);
- grpc_byte_buffer_destroy(request_payload_recv);
- grpc_byte_buffer_destroy(response_payload_recv);
- gpr_slice_unref(request_payload_slice);
- gpr_slice_unref(response_payload_slice);
+ grpc_byte_buffer_destroy (request_payload);
+ grpc_byte_buffer_destroy (response_payload);
+ grpc_byte_buffer_destroy (request_payload_recv);
+ grpc_byte_buffer_destroy (response_payload_recv);
+ gpr_slice_unref (request_payload_slice);
+ gpr_slice_unref (response_payload_slice);
- end_test(&f);
- config.tear_down_data(&f);
+ end_test (&f);
+ config.tear_down_data (&f);
}
-void grpc_end2end_tests(grpc_end2end_test_config config) {
- test_invoke_large_request(config);
+void
+grpc_end2end_tests (grpc_end2end_test_config config)
+{
+ test_invoke_large_request (config);
}
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-04 15:41:13 +0000