aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/bad_client
diff options
context:
space:
mode:
authorGravatar Yash Tibrewal <yashkt@google.com>2017-11-06 14:39:17 -0800
committerGravatar Yash Tibrewal <yashkt@google.com>2017-11-06 14:43:31 -0800
commit40422d5fa621624868280094efb2f01c2cd1352b (patch)
treecbb2baa955e11c03fa004e9e0f4f3037ba3d6150 /test/core/bad_client
parentaae4ca01a315a69fcf182d09aea1efdfcda13d48 (diff)
parente759d2ad7abdb0702970eeccc5f033ff4b2a4c7f (diff)
Merge master
Diffstat (limited to 'test/core/bad_client')
-rw-r--r--test/core/bad_client/bad_client.cc36
-rw-r--r--test/core/bad_client/bad_client.h10
-rw-r--r--test/core/bad_client/tests/badreq.cc21
-rw-r--r--test/core/bad_client/tests/connection_prefix.cc6
-rw-r--r--test/core/bad_client/tests/head_of_line_blocking.cc20
-rw-r--r--test/core/bad_client/tests/headers.cc141
-rw-r--r--test/core/bad_client/tests/initial_settings_frame.cc9
-rw-r--r--test/core/bad_client/tests/large_metadata.cc36
-rw-r--r--test/core/bad_client/tests/server_registered_method.cc27
-rw-r--r--test/core/bad_client/tests/simple_request.cc22
-rw-r--r--test/core/bad_client/tests/unknown_frame.cc6
-rw-r--r--test/core/bad_client/tests/window_overflow.cc12
12 files changed, 201 insertions, 145 deletions
diff --git a/test/core/bad_client/bad_client.cc b/test/core/bad_client/bad_client.cc
index b7b28a9ac4..b1944425ba 100644
--- a/test/core/bad_client/bad_client.cc
+++ b/test/core/bad_client/bad_client.cc
@@ -36,53 +36,53 @@
#include "src/core/lib/surface/server.h"
typedef struct {
- grpc_server *server;
- grpc_completion_queue *cq;
+ grpc_server* server;
+ grpc_completion_queue* cq;
grpc_bad_client_server_side_validator validator;
- void *registered_method;
+ void* registered_method;
gpr_event done_thd;
gpr_event done_write;
} thd_args;
-static void thd_func(void *arg) {
- thd_args *a = (thd_args *)arg;
+static void thd_func(void* arg) {
+ thd_args* a = (thd_args*)arg;
a->validator(a->server, a->cq, a->registered_method);
- gpr_event_set(&a->done_thd, (void *)1);
+ gpr_event_set(&a->done_thd, (void*)1);
}
-static void done_write(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) {
- thd_args *a = (thd_args *)arg;
- gpr_event_set(&a->done_write, (void *)1);
+static void done_write(grpc_exec_ctx* exec_ctx, void* arg, grpc_error* error) {
+ thd_args* a = (thd_args*)arg;
+ gpr_event_set(&a->done_write, (void*)1);
}
-static void server_setup_transport(void *ts, grpc_transport *transport) {
- thd_args *a = (thd_args *)ts;
+static void server_setup_transport(void* ts, grpc_transport* transport) {
+ thd_args* a = (thd_args*)ts;
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
grpc_server_setup_transport(&exec_ctx, a->server, transport, NULL,
grpc_server_get_channel_args(a->server));
grpc_exec_ctx_finish(&exec_ctx);
}
-static void read_done(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) {
- gpr_event *read_done = (gpr_event *)arg;
- gpr_event_set(read_done, (void *)1);
+static void read_done(grpc_exec_ctx* exec_ctx, void* arg, grpc_error* error) {
+ gpr_event* read_done = (gpr_event*)arg;
+ gpr_event_set(read_done, (void*)1);
}
void grpc_run_bad_client_test(
grpc_bad_client_server_side_validator server_validator,
grpc_bad_client_client_stream_validator client_validator,
- const char *client_payload, size_t client_payload_length, uint32_t flags) {
+ const char* client_payload, size_t client_payload_length, uint32_t flags) {
grpc_endpoint_pair sfd;
thd_args a;
gpr_thd_id id;
- char *hex;
- grpc_transport *transport;
+ char* hex;
+ grpc_transport* transport;
grpc_slice slice =
grpc_slice_from_copied_buffer(client_payload, client_payload_length);
grpc_slice_buffer outgoing;
grpc_closure done_write_closure;
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT;
- grpc_completion_queue *shutdown_cq;
+ grpc_completion_queue* shutdown_cq;
if (client_payload_length < 4 * 1024) {
hex = gpr_dump(client_payload, client_payload_length,
diff --git a/test/core/bad_client/bad_client.h b/test/core/bad_client/bad_client.h
index a5b01f7f2c..d3abfac2aa 100644
--- a/test/core/bad_client/bad_client.h
+++ b/test/core/bad_client/bad_client.h
@@ -28,13 +28,13 @@
#define GRPC_BAD_CLIENT_REGISTERED_METHOD "/registered/bar"
#define GRPC_BAD_CLIENT_REGISTERED_HOST "localhost"
-typedef void (*grpc_bad_client_server_side_validator)(grpc_server *server,
- grpc_completion_queue *cq,
- void *registered_method);
+typedef void (*grpc_bad_client_server_side_validator)(grpc_server* server,
+ grpc_completion_queue* cq,
+ void* registered_method);
// Returns false if we need to read more data.
typedef bool (*grpc_bad_client_client_stream_validator)(
- grpc_slice_buffer *incoming);
+ grpc_slice_buffer* incoming);
#define GRPC_BAD_CLIENT_DISCONNECT 1
#define GRPC_BAD_CLIENT_LARGE_REQUEST 2
@@ -47,7 +47,7 @@ typedef bool (*grpc_bad_client_client_stream_validator)(
void grpc_run_bad_client_test(
grpc_bad_client_server_side_validator server_validator,
grpc_bad_client_client_stream_validator client_validator,
- const char *client_payload, size_t client_payload_length, uint32_t flags);
+ const char* client_payload, size_t client_payload_length, uint32_t flags);
#define GRPC_RUN_BAD_CLIENT_TEST(server_validator, client_validator, payload, \
flags) \
diff --git a/test/core/bad_client/tests/badreq.cc b/test/core/bad_client/tests/badreq.cc
index 7d9a103e43..5273c831e5 100644
--- a/test/core/bad_client/tests/badreq.cc
+++ b/test/core/bad_client/tests/badreq.cc
@@ -27,8 +27,8 @@
"PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n" \
"\x00\x00\x00\x04\x00\x00\x00\x00\x00" /* settings frame */
-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_milliseconds_to_deadline(20), NULL)
@@ -36,12 +36,13 @@ static void verifier(grpc_server *server, grpc_completion_queue *cq,
}
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
grpc_test_init(argc, argv);
/* invalid content type */
GRPC_RUN_BAD_CLIENT_TEST(
- verifier, NULL, PFX_STR
+ verifier, NULL,
+ PFX_STR
"\x00\x00\xc2\x01\x04\x00\x00\x00\x01"
"\x10\x05:path\x08/foo/bar"
"\x10\x07:scheme\x04http"
@@ -56,7 +57,8 @@ int main(int argc, char **argv) {
/* invalid te */
GRPC_RUN_BAD_CLIENT_TEST(
- verifier, NULL, PFX_STR
+ verifier, NULL,
+ PFX_STR
"\x00\x00\xcb\x01\x04\x00\x00\x00\x01"
"\x10\x05:path\x08/foo/bar"
"\x10\x07:scheme\x04http"
@@ -73,7 +75,8 @@ int main(int argc, char **argv) {
/* two path headers */
GRPC_RUN_BAD_CLIENT_TEST(
- verifier, NULL, PFX_STR
+ verifier, NULL,
+ PFX_STR
"\x00\x00\xd9\x01\x04\x00\x00\x00\x01"
"\x10\x05:path\x08/foo/bar"
"\x10\x05:path\x08/foo/bah"
@@ -90,7 +93,8 @@ int main(int argc, char **argv) {
/* bad accept-encoding algorithm */
GRPC_RUN_BAD_CLIENT_TEST(
- verifier, NULL, PFX_STR
+ verifier, NULL,
+ PFX_STR
"\x00\x00\xd2\x01\x04\x00\x00\x00\x01"
"\x10\x05:path\x08/foo/bar"
"\x10\x07:scheme\x04http"
@@ -106,7 +110,8 @@ int main(int argc, char **argv) {
/* bad grpc-encoding algorithm */
GRPC_RUN_BAD_CLIENT_TEST(
- verifier, NULL, PFX_STR
+ verifier, NULL,
+ PFX_STR
"\x00\x00\xf5\x01\x04\x00\x00\x00\x01"
"\x10\x05:path\x08/foo/bar"
"\x10\x07:scheme\x04http"
diff --git a/test/core/bad_client/tests/connection_prefix.cc b/test/core/bad_client/tests/connection_prefix.cc
index 6cc4b72314..a4fd734e04 100644
--- a/test/core/bad_client/tests/connection_prefix.cc
+++ b/test/core/bad_client/tests/connection_prefix.cc
@@ -19,8 +19,8 @@
#include "src/core/lib/surface/server.h"
#include "test/core/bad_client/bad_client.h"
-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_milliseconds_to_deadline(20), NULL)
@@ -28,7 +28,7 @@ static void verifier(grpc_server *server, grpc_completion_queue *cq,
}
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
grpc_test_init(argc, argv);
GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, "X", 0);
diff --git a/test/core/bad_client/tests/head_of_line_blocking.cc b/test/core/bad_client/tests/head_of_line_blocking.cc
index cb89423907..aad335cf5b 100644
--- a/test/core/bad_client/tests/head_of_line_blocking.cc
+++ b/test/core/bad_client/tests/head_of_line_blocking.cc
@@ -65,16 +65,16 @@ static const char prefix[] =
"\x01\x00\x00\x27\x10"
"";
-static void *tag(intptr_t t) { return (void *)t; }
+static void* tag(intptr_t t) { return (void*)t; }
-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) {
grpc_call_error error;
- grpc_call *s;
- cq_verifier *cqv = cq_verifier_create(cq);
+ grpc_call* s;
+ cq_verifier* cqv = cq_verifier_create(cq);
grpc_metadata_array request_metadata_recv;
gpr_timespec deadline;
- grpc_byte_buffer *payload = NULL;
+ grpc_byte_buffer* payload = NULL;
grpc_metadata_array_init(&request_metadata_recv);
@@ -93,20 +93,20 @@ static void verifier(grpc_server *server, grpc_completion_queue *cq,
cq_verifier_destroy(cqv);
}
-char *g_buffer;
+char* g_buffer;
size_t g_cap = 0;
size_t g_count = 0;
-static void addbuf(const void *data, size_t len) {
+static void addbuf(const void* data, size_t len) {
if (g_count + len > g_cap) {
g_cap = GPR_MAX(g_count + len, g_cap * 2);
- g_buffer = static_cast<char *>(gpr_realloc(g_buffer, g_cap));
+ g_buffer = static_cast<char*>(gpr_realloc(g_buffer, g_cap));
}
memcpy(g_buffer + g_count, data, len);
g_count += len;
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
int i;
grpc_test_init(argc, argv);
diff --git a/test/core/bad_client/tests/headers.cc b/test/core/bad_client/tests/headers.cc
index c704dbbcb6..f96c6f0028 100644
--- a/test/core/bad_client/tests/headers.cc
+++ b/test/core/bad_client/tests/headers.cc
@@ -23,8 +23,8 @@
"PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n" \
"\x00\x00\x00\x04\x00\x00\x00\x00\x00"
-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_milliseconds_to_deadline(20), NULL)
@@ -32,7 +32,7 @@ static void verifier(grpc_server *server, grpc_completion_queue *cq,
}
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
grpc_test_init(argc, argv);
/* partial http2 header prefixes */
@@ -66,194 +66,236 @@ int main(int argc, char **argv) {
GRPC_BAD_CLIENT_DISCONNECT);
/* test adding prioritization data */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x01\x01\x24\x00\x00\x00\x01"
"\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x02\x01\x24\x00\x00\x00\x01"
"\x00\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x03\x01\x24\x00\x00\x00\x01"
"\x00\x00\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x04\x01\x24\x00\x00\x00\x01"
"\x00\x00\x00\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x05\x01\x24\x00\x00\x00\x01"
"",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x05\x01\x24\x00\x00\x00\x01"
"\x00",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x05\x01\x24\x00\x00\x00\x01"
"\x00\x00",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x05\x01\x24\x00\x00\x00\x01"
"\x00\x00\x00",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x05\x01\x24\x00\x00\x00\x01"
"\x00\x00\x00\x00",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x05\x01\x24\x00\x00\x00\x01"
"\x00\x00\x00\x00\x00",
GRPC_BAD_CLIENT_DISCONNECT);
/* test looking up an invalid index */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x01\x01\x04\x00\x00\x00\x01"
"\xfe",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x04\x01\x04\x00\x00\x00\x01"
"\x7f\x7f\x01"
"a",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x04\x01\x04\x00\x00\x00\x01"
"\x0f\x7f\x01"
"a",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x04\x01\x04\x00\x00\x00\x01"
"\x1f\x7f\x01"
"a",
0);
/* test nvr, not indexed in static table */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x03\x01\x04\x00\x00\x00\x01"
"\x01\x01"
"a",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x03\x01\x04\x00\x00\x00\x01"
"\x11\x01"
"a",
GRPC_BAD_CLIENT_DISCONNECT);
/* illegal op code */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x01\x01\x04\x00\x00\x00\x01"
"\x80",
0);
/* parse some long indices */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x02\x01\x04\x00\x00\x00\x01"
"\xff\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x03\x01\x04\x00\x00\x00\x01"
"\xff\x80\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x04\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x05\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x06\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80\x80\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x07\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80\x80\x80\x00",
0);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x08\x01\x04\x00\x00\x00\x01"
"\xff",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x08\x01\x04\x00\x00\x00\x01"
"\xff\x80",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x08\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x08\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x08\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80\x80",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x08\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80\x80\x80",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x08\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80\x80\x80\x80",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x08\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80\x80\x80\x80\x00",
0);
/* overflow on byte 4 */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x06\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80\x80\x7f",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x06\x01\x04\x00\x00\x00\x01"
"\xff\xff\xff\xff\xff\x0f",
GRPC_BAD_CLIENT_DISCONNECT);
/* overflow after byte 4 */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x08\x01\x04\x00\x00\x00\x01"
"\xff\x80\x80\x80\x80\x80\x80\x02",
0);
/* end of headers mid-opcode */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x01\x01\x04\x00\x00\x00\x01"
"\x01",
GRPC_BAD_CLIENT_DISCONNECT);
/* dynamic table size update: set to default */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x03\x01\x04\x00\x00\x00\x01"
"\x3f\xe1\x1f",
GRPC_BAD_CLIENT_DISCONNECT);
/* dynamic table size update: set too large */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x03\x01\x04\x00\x00\x00\x01"
"\x3f\xf1\x1f",
0);
/* dynamic table size update: set twice */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x04\x01\x04\x00\x00\x00\x01"
"\x20\x3f\xe1\x1f",
GRPC_BAD_CLIENT_DISCONNECT);
/* dynamic table size update: set thrice */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x03\x01\x04\x00\x00\x00\x01"
"\x20\x20\x20",
0);
/* non-ending header followed by continuation frame */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x00\x01\x00\x00\x00\x00\x01"
"\x00\x00\x00\x09\x04\x00\x00\x00\x01",
GRPC_BAD_CLIENT_DISCONNECT);
/* non-ending header followed by non-continuation frame */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x00\x01\x00\x00\x00\x00\x01"
"\x00\x00\x00\x00\x04\x00\x00\x00\x01",
0);
/* non-ending header followed by a continuation frame for a different stream
*/
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x00\x01\x04\x00\x00\x00\x01"
"\x00\x00\x00\x01\x00\x00\x00\x00\x03"
"\x00\x00\x00\x09\x04\x00\x00\x00\x01",
@@ -262,7 +304,8 @@ int main(int argc, char **argv) {
GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
PFX_STR "\x00\x00\x00\x09\x04\x00\x00\x00\x01", 0);
/* three header frames */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x00\x01\x04\x00\x00\x00\x01"
"\x00\x00\x00\x01\x04\x00\x00\x00\x01"
"\x00\x00\x00\x01\x04\x00\x00\x00\x01",
@@ -274,13 +317,15 @@ int main(int argc, char **argv) {
GRPC_BAD_CLIENT_DISCONNECT);
/* a badly encoded timeout value */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x19\x01\x04\x00\x00\x00\x01"
"\x10\x0cgrpc-timeout\x0a"
"15 seconds",
GRPC_BAD_CLIENT_DISCONNECT);
/* a badly encoded timeout value: twice (catches caching) */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x19\x01\x04\x00\x00\x00\x01"
"\x10\x0cgrpc-timeout\x0a"
"15 seconds"
diff --git a/test/core/bad_client/tests/initial_settings_frame.cc b/test/core/bad_client/tests/initial_settings_frame.cc
index 0696ef9383..dde9d4b5d3 100644
--- a/test/core/bad_client/tests/initial_settings_frame.cc
+++ b/test/core/bad_client/tests/initial_settings_frame.cc
@@ -22,8 +22,8 @@
#define PFX_STR "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n"
#define ONE_SETTING_HDR "\x00\x00\x06\x04\x00\x00\x00\x00\x00"
-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_milliseconds_to_deadline(20), NULL)
@@ -31,7 +31,7 @@ static void verifier(grpc_server *server, grpc_completion_queue *cq,
}
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
grpc_test_init(argc, argv);
/* various partial prefixes */
@@ -92,7 +92,8 @@ int main(int argc, char **argv) {
PFX_STR ONE_SETTING_HDR "\x00\x04\x00\x01\x00\x00",
GRPC_BAD_CLIENT_DISCONNECT);
/* ack with data */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x00\x04\x00\x00\x00\x00\x00"
"\x00\x00\x01\x04\x01\x00\x00\x00\x00",
0);
diff --git a/test/core/bad_client/tests/large_metadata.cc b/test/core/bad_client/tests/large_metadata.cc
index ca3d234be9..df7dd8f4b3 100644
--- a/test/core/bad_client/tests/large_metadata.cc
+++ b/test/core/bad_client/tests/large_metadata.cc
@@ -93,14 +93,14 @@
"\x10\x02te\x08trailers" \
"\x10\x0auser-agent\"bad-client grpc-c/0.12.0.0 (linux)"
-static void *tag(intptr_t t) { return (void *)t; }
+static void* tag(intptr_t t) { return (void*)t; }
-static void server_verifier(grpc_server *server, grpc_completion_queue *cq,
- void *registered_method) {
+static void server_verifier(grpc_server* server, grpc_completion_queue* cq,
+ void* registered_method) {
grpc_call_error error;
- grpc_call *s;
+ grpc_call* s;
grpc_call_details call_details;
- cq_verifier *cqv = cq_verifier_create(cq);
+ cq_verifier* cqv = cq_verifier_create(cq);
grpc_metadata_array request_metadata_recv;
grpc_call_details_init(&call_details);
@@ -121,13 +121,13 @@ static void server_verifier(grpc_server *server, grpc_completion_queue *cq,
cq_verifier_destroy(cqv);
}
-static void server_verifier_sends_too_much_metadata(grpc_server *server,
- grpc_completion_queue *cq,
- void *registered_method) {
+static void server_verifier_sends_too_much_metadata(grpc_server* server,
+ grpc_completion_queue* cq,
+ void* registered_method) {
grpc_call_error error;
- grpc_call *s;
+ grpc_call* s;
grpc_call_details call_details;
- cq_verifier *cqv = cq_verifier_create(cq);
+ cq_verifier* cqv = cq_verifier_create(cq);
grpc_metadata_array request_metadata_recv;
grpc_call_details_init(&call_details);
@@ -167,10 +167,10 @@ static void server_verifier_sends_too_much_metadata(grpc_server *server,
cq_verifier_destroy(cqv);
}
-static bool client_validator(grpc_slice_buffer *incoming) {
+static bool client_validator(grpc_slice_buffer* incoming) {
for (size_t i = 0; i < incoming->count; ++i) {
- const char *s = (const char *)GRPC_SLICE_START_PTR(incoming->slices[i]);
- char *hex = gpr_dump(s, GRPC_SLICE_LENGTH(incoming->slices[i]),
+ const char* s = (const char*)GRPC_SLICE_START_PTR(incoming->slices[i]);
+ char* hex = gpr_dump(s, GRPC_SLICE_LENGTH(incoming->slices[i]),
GPR_DUMP_HEX | GPR_DUMP_ASCII);
gpr_log(GPR_INFO, "RESPONSE SLICE %" PRIdPTR ": %s", i, hex);
gpr_free(hex);
@@ -183,7 +183,7 @@ static bool client_validator(grpc_slice_buffer *incoming) {
GPR_ASSERT(last_frame_buffer.count == 1);
grpc_slice last_frame = last_frame_buffer.slices[0];
- const uint8_t *p = GRPC_SLICE_START_PTR(last_frame);
+ const uint8_t* p = GRPC_SLICE_START_PTR(last_frame);
bool success =
// Length == 4
*p++ != 0 || *p++ != 0 || *p++ != 4 ||
@@ -204,7 +204,7 @@ static bool client_validator(grpc_slice_buffer *incoming) {
return success;
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
int i;
grpc_test_init(argc, argv);
@@ -213,14 +213,14 @@ int main(int argc, char **argv) {
gpr_strvec headers;
gpr_strvec_init(&headers);
for (i = 0; i < NUM_HEADERS; ++i) {
- char *str;
+ char* str;
gpr_asprintf(&str, "%s%02d%s",
PFX_TOO_MUCH_METADATA_FROM_CLIENT_HEADER_START_STR, i,
PFX_TOO_MUCH_METADATA_FROM_CLIENT_HEADER_END_STR);
gpr_strvec_add(&headers, str);
}
size_t headers_len;
- const char *client_headers = gpr_strvec_flatten(&headers, &headers_len);
+ const char* client_headers = gpr_strvec_flatten(&headers, &headers_len);
gpr_strvec_destroy(&headers);
char client_payload[PFX_TOO_MUCH_METADATA_FROM_CLIENT_PAYLOAD_SIZE] =
PFX_TOO_MUCH_METADATA_FROM_CLIENT_PREFIX_STR;
@@ -229,7 +229,7 @@ int main(int argc, char **argv) {
client_headers, headers_len);
GRPC_RUN_BAD_CLIENT_TEST(server_verifier, client_validator, client_payload,
0);
- gpr_free((void *)client_headers);
+ gpr_free((void*)client_headers);
// Test sending more metadata than the client will accept.
GRPC_RUN_BAD_CLIENT_TEST(server_verifier_sends_too_much_metadata,
diff --git a/test/core/bad_client/tests/server_registered_method.cc b/test/core/bad_client/tests/server_registered_method.cc
index f52350302b..b1b11235de 100644
--- a/test/core/bad_client/tests/server_registered_method.cc
+++ b/test/core/bad_client/tests/server_registered_method.cc
@@ -38,16 +38,16 @@
"\x10\x02te\x08trailers" \
"\x10\x0auser-agent\"bad-client grpc-c/0.12.0.0 (linux)"
-static void *tag(intptr_t t) { return (void *)t; }
+static void* tag(intptr_t t) { return (void*)t; }
-static void verifier_succeeds(grpc_server *server, grpc_completion_queue *cq,
- void *registered_method) {
+static void verifier_succeeds(grpc_server* server, grpc_completion_queue* cq,
+ void* registered_method) {
grpc_call_error error;
- grpc_call *s;
- cq_verifier *cqv = cq_verifier_create(cq);
+ grpc_call* s;
+ cq_verifier* cqv = cq_verifier_create(cq);
grpc_metadata_array request_metadata_recv;
gpr_timespec deadline;
- grpc_byte_buffer *payload = NULL;
+ grpc_byte_buffer* payload = NULL;
grpc_metadata_array_init(&request_metadata_recv);
@@ -66,8 +66,8 @@ static void verifier_succeeds(grpc_server *server, grpc_completion_queue *cq,
cq_verifier_destroy(cqv);
}
-static void verifier_fails(grpc_server *server, grpc_completion_queue *cq,
- void *registered_method) {
+static void verifier_fails(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_milliseconds_to_deadline(20), NULL)
@@ -75,7 +75,7 @@ static void verifier_fails(grpc_server *server, grpc_completion_queue *cq,
}
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
grpc_test_init(argc, argv);
/* body generated with
@@ -86,10 +86,12 @@ int main(int argc, char **argv) {
GRPC_RUN_BAD_CLIENT_TEST(verifier_fails, NULL,
PFX_STR "\x00\x00\x01\x00\x00\x00\x00\x00\x01\x00",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier_fails, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier_fails, NULL,
+ PFX_STR
"\x00\x00\x02\x00\x00\x00\x00\x00\x01\x00\x00",
GRPC_BAD_CLIENT_DISCONNECT);
- GRPC_RUN_BAD_CLIENT_TEST(verifier_fails, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier_fails, NULL,
+ PFX_STR
"\x00\x00\x03\x00\x00\x00\x00\x00\x01\x00\x00\x00",
GRPC_BAD_CLIENT_DISCONNECT);
GRPC_RUN_BAD_CLIENT_TEST(
@@ -116,7 +118,8 @@ int main(int argc, char **argv) {
PFX_STR "\x00\x00\x06\x00\x00\x00\x00\x00\x01\x00\x00\x00\x00\x02\x00",
GRPC_BAD_CLIENT_DISCONNECT);
GRPC_RUN_BAD_CLIENT_TEST(
- verifier_succeeds, NULL, PFX_STR
+ verifier_succeeds, NULL,
+ PFX_STR
"\x00\x00\x07\x00\x01\x00\x00\x00\x01\x00\x00\x00\x00\x02\x00\x00",
0);
diff --git a/test/core/bad_client/tests/simple_request.cc b/test/core/bad_client/tests/simple_request.cc
index a516632819..b9cc1e3259 100644
--- a/test/core/bad_client/tests/simple_request.cc
+++ b/test/core/bad_client/tests/simple_request.cc
@@ -83,14 +83,14 @@
"\x10\x0cgrpc-timeout\x02" \
"5S"
-static void *tag(intptr_t t) { return (void *)t; }
+static void* tag(intptr_t t) { return (void*)t; }
-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) {
grpc_call_error error;
- grpc_call *s;
+ grpc_call* s;
grpc_call_details call_details;
- cq_verifier *cqv = cq_verifier_create(cq);
+ cq_verifier* cqv = cq_verifier_create(cq);
grpc_metadata_array request_metadata_recv;
grpc_call_details_init(&call_details);
@@ -111,8 +111,8 @@ static void verifier(grpc_server *server, grpc_completion_queue *cq,
cq_verifier_destroy(cqv);
}
-static void failure_verifier(grpc_server *server, grpc_completion_queue *cq,
- void *registered_method) {
+static void failure_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_milliseconds_to_deadline(20), NULL)
@@ -120,7 +120,7 @@ static void failure_verifier(grpc_server *server, grpc_completion_queue *cq,
}
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
grpc_test_init(argc, argv);
/* basic request: check that things are working */
@@ -129,7 +129,8 @@ int main(int argc, char **argv) {
GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR_UNUSUAL2, 0);
/* push an illegal data frame */
- GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(verifier, NULL,
+ PFX_STR
"\x00\x00\x05\x00\x00\x00\x00\x00\x01"
"\x34\x00\x00\x00\x00",
0);
@@ -144,7 +145,8 @@ int main(int argc, char **argv) {
GRPC_RUN_BAD_CLIENT_TEST(failure_verifier, NULL,
PFX_STR "\x00\x00\x00\x08\x10\x00\x00\x00\x01", 0);
/* push a window update with bad data */
- GRPC_RUN_BAD_CLIENT_TEST(failure_verifier, NULL, PFX_STR
+ GRPC_RUN_BAD_CLIENT_TEST(failure_verifier, NULL,
+ PFX_STR
"\x00\x00\x04\x08\x00\x00\x00\x00\x01"
"\xff\xff\xff\xff",
0);
diff --git a/test/core/bad_client/tests/unknown_frame.cc b/test/core/bad_client/tests/unknown_frame.cc
index 448803d12b..b8367a2b65 100644
--- a/test/core/bad_client/tests/unknown_frame.cc
+++ b/test/core/bad_client/tests/unknown_frame.cc
@@ -23,8 +23,8 @@
"PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n" \
"\x00\x00\x00\x04\x00\x00\x00\x00\x00"
-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_milliseconds_to_deadline(20), NULL)
@@ -32,7 +32,7 @@ static void verifier(grpc_server *server, grpc_completion_queue *cq,
}
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
grpc_test_init(argc, argv);
/* test adding prioritization data */
diff --git a/test/core/bad_client/tests/window_overflow.cc b/test/core/bad_client/tests/window_overflow.cc
index 40552e5345..cb4b790de2 100644
--- a/test/core/bad_client/tests/window_overflow.cc
+++ b/test/core/bad_client/tests/window_overflow.cc
@@ -42,8 +42,8 @@
"\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_milliseconds_to_deadline(20), NULL)
@@ -51,20 +51,20 @@ static void verifier(grpc_server *server, grpc_completion_queue *cq,
}
}
-char *g_buffer;
+char* g_buffer;
size_t g_cap = 0;
size_t g_count = 0;
-static void addbuf(const void *data, size_t len) {
+static void addbuf(const void* data, size_t len) {
if (g_count + len > g_cap) {
g_cap = GPR_MAX(g_count + len, g_cap * 2);
- g_buffer = static_cast<char *>(gpr_realloc(g_buffer, g_cap));
+ g_buffer = static_cast<char*>(gpr_realloc(g_buffer, g_cap));
}
memcpy(g_buffer + g_count, data, len);
g_count += len;
}
-int main(int argc, char **argv) {
+int main(int argc, char** argv) {
int i, j;
#define MAX_FRAME_SIZE 16384
#define MESSAGES_PER_FRAME (MAX_FRAME_SIZE / 5)