|
|
@ -145,6 +145,8 @@ static void cleanup_test() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_non_null_reserved_on_start_batch() { |
|
|
|
static void test_non_null_reserved_on_start_batch() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_non_null_reserved_on_start_batch"); |
|
|
|
|
|
|
|
|
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
|
GPR_ASSERT(GRPC_CALL_ERROR == |
|
|
|
GPR_ASSERT(GRPC_CALL_ERROR == |
|
|
|
grpc_call_start_batch(g_state.call, NULL, 0, NULL, tag(1))); |
|
|
|
grpc_call_start_batch(g_state.call, NULL, 0, NULL, tag(1))); |
|
|
@ -152,6 +154,8 @@ static void test_non_null_reserved_on_start_batch() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_non_null_reserved_on_op() { |
|
|
|
static void test_non_null_reserved_on_op() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_non_null_reserved_on_op"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
|
|
|
|
|
|
|
|
@ -168,6 +172,8 @@ static void test_non_null_reserved_on_op() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_send_initial_metadata_more_than_once() { |
|
|
|
static void test_send_initial_metadata_more_than_once() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_send_initial_metadata_more_than_once"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
|
|
|
|
|
|
|
|
@ -196,6 +202,8 @@ static void test_send_initial_metadata_more_than_once() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_too_many_metadata() { |
|
|
|
static void test_too_many_metadata() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_too_many_metadata"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
|
|
|
|
|
|
|
|
@ -212,6 +220,8 @@ static void test_too_many_metadata() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_send_null_message() { |
|
|
|
static void test_send_null_message() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_send_null_message"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
|
|
|
|
|
|
|
|
@ -233,6 +243,8 @@ static void test_send_null_message() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_send_messages_at_the_same_time() { |
|
|
|
static void test_send_messages_at_the_same_time() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_send_messages_at_the_same_time"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
gpr_slice request_payload_slice = gpr_slice_from_copied_string("hello world"); |
|
|
|
gpr_slice request_payload_slice = gpr_slice_from_copied_string("hello world"); |
|
|
|
grpc_byte_buffer *request_payload = |
|
|
|
grpc_byte_buffer *request_payload = |
|
|
@ -262,6 +274,8 @@ static void test_send_messages_at_the_same_time() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_send_server_status_from_client() { |
|
|
|
static void test_send_server_status_from_client() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_send_server_status_from_client"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
|
|
|
|
|
|
|
|
@ -280,6 +294,8 @@ static void test_send_server_status_from_client() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_receive_initial_metadata_twice_at_client() { |
|
|
|
static void test_receive_initial_metadata_twice_at_client() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_receive_initial_metadata_twice_at_client"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
|
op = g_state.ops; |
|
|
|
op = g_state.ops; |
|
|
@ -306,6 +322,8 @@ static void test_receive_initial_metadata_twice_at_client() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_receive_message_with_invalid_flags() { |
|
|
|
static void test_receive_message_with_invalid_flags() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_receive_message_with_invalid_flags"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
grpc_byte_buffer *payload = NULL; |
|
|
|
grpc_byte_buffer *payload = NULL; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
@ -322,6 +340,8 @@ static void test_receive_message_with_invalid_flags() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_receive_two_messages_at_the_same_time() { |
|
|
|
static void test_receive_two_messages_at_the_same_time() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_receive_two_messages_at_the_same_time"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
grpc_byte_buffer *payload = NULL; |
|
|
|
grpc_byte_buffer *payload = NULL; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
@ -343,6 +363,8 @@ static void test_receive_two_messages_at_the_same_time() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_recv_close_on_server_from_client() { |
|
|
|
static void test_recv_close_on_server_from_client() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_recv_close_on_server_from_client"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
|
|
|
|
|
|
|
|
@ -359,6 +381,8 @@ static void test_recv_close_on_server_from_client() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_recv_status_on_client_twice() { |
|
|
|
static void test_recv_status_on_client_twice() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_recv_status_on_client_twice"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(1); |
|
|
|
prepare_test(1); |
|
|
|
|
|
|
|
|
|
|
@ -395,6 +419,8 @@ static void test_recv_status_on_client_twice() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_send_close_from_client_on_server() { |
|
|
|
static void test_send_close_from_client_on_server() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_send_close_from_client_on_server"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(0); |
|
|
|
prepare_test(0); |
|
|
|
|
|
|
|
|
|
|
@ -410,6 +436,8 @@ static void test_send_close_from_client_on_server() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_recv_status_on_client_from_server() { |
|
|
|
static void test_recv_status_on_client_from_server() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_recv_status_on_client_from_server"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(0); |
|
|
|
prepare_test(0); |
|
|
|
|
|
|
|
|
|
|
@ -431,6 +459,8 @@ static void test_recv_status_on_client_from_server() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_send_status_from_server_with_invalid_flags() { |
|
|
|
static void test_send_status_from_server_with_invalid_flags() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_send_status_from_server_with_invalid_flags"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(0); |
|
|
|
prepare_test(0); |
|
|
|
|
|
|
|
|
|
|
@ -449,6 +479,8 @@ static void test_send_status_from_server_with_invalid_flags() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_too_many_trailing_metadata() { |
|
|
|
static void test_too_many_trailing_metadata() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_too_many_trailing_metadata"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(0); |
|
|
|
prepare_test(0); |
|
|
|
|
|
|
|
|
|
|
@ -468,6 +500,8 @@ static void test_too_many_trailing_metadata() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_send_server_status_twice() { |
|
|
|
static void test_send_server_status_twice() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_send_server_status_twice"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(0); |
|
|
|
prepare_test(0); |
|
|
|
|
|
|
|
|
|
|
@ -493,6 +527,8 @@ static void test_send_server_status_twice() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_recv_close_on_server_with_invalid_flags() { |
|
|
|
static void test_recv_close_on_server_with_invalid_flags() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_recv_close_on_server_with_invalid_flags"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(0); |
|
|
|
prepare_test(0); |
|
|
|
|
|
|
|
|
|
|
@ -509,6 +545,8 @@ static void test_recv_close_on_server_with_invalid_flags() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
static void test_recv_close_on_server_twice() { |
|
|
|
static void test_recv_close_on_server_twice() { |
|
|
|
|
|
|
|
gpr_log(GPR_INFO, "test_recv_close_on_server_twice"); |
|
|
|
|
|
|
|
|
|
|
|
grpc_op *op; |
|
|
|
grpc_op *op; |
|
|
|
prepare_test(0); |
|
|
|
prepare_test(0); |
|
|
|
|
|
|
|
|
|
|
|