aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/end2end/tests/cancel_after_accept.c
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-01-16 09:53:39 -0800
committerGravatar Craig Tiller <ctiller@google.com>2015-01-16 09:53:39 -0800
commit7b01878736840395f13244bd68edaf0d88b4c3e4 (patch)
tree62157ae945af04cef92bfd50106552ad8d78a491 /test/core/end2end/tests/cancel_after_accept.c
parent19cdb35a2cb229dbf14f0163f090c11427a8f797 (diff)
Fix returned status
The client should return status deadline exceeded when the deadline is exceeded (not cancelled status)
Diffstat (limited to 'test/core/end2end/tests/cancel_after_accept.c')
-rw-r--r--test/core/end2end/tests/cancel_after_accept.c22
1 files changed, 7 insertions, 15 deletions
diff --git a/test/core/end2end/tests/cancel_after_accept.c b/test/core/end2end/tests/cancel_after_accept.c
index 8568605197..cfbb4796aa 100644
--- a/test/core/end2end/tests/cancel_after_accept.c
+++ b/test/core/end2end/tests/cancel_after_accept.c
@@ -43,14 +43,7 @@
#include <grpc/support/time.h>
#include <grpc/support/useful.h>
#include "test/core/end2end/cq_verifier.h"
-
-/* allow cancellation by either grpc_call_cancel, or by wait_for_deadline (which
- * does nothing) */
-typedef grpc_call_error (*canceller)(grpc_call *call);
-
-static grpc_call_error wait_for_deadline(grpc_call *call) {
- return GRPC_CALL_OK;
-}
+#include "test/core/end2end/tests/cancel_test_helpers.h"
enum { TIMEOUT = 200000 };
@@ -112,7 +105,7 @@ static void end_test(grpc_end2end_test_fixture *f) {
/* Cancel after accept, no payload */
static void test_cancel_after_accept(grpc_end2end_test_config config,
- canceller call_cancel) {
+ cancellation_mode mode) {
grpc_call *c;
grpc_call *s;
grpc_end2end_test_fixture f = begin_test(config, __FUNCTION__, NULL, NULL);
@@ -138,10 +131,10 @@ static void test_cancel_after_accept(grpc_end2end_test_config config,
cq_expect_client_metadata_read(v_client, tag(2), NULL);
cq_verify(v_client);
- GPR_ASSERT(GRPC_CALL_OK == call_cancel(c));
+ GPR_ASSERT(GRPC_CALL_OK == mode.initiate_cancel(c));
- cq_expect_finished_with_status(v_client, tag(3), GRPC_STATUS_CANCELLED, NULL,
- NULL);
+ cq_expect_finished_with_status(v_client, tag(3), mode.expect_status,
+ mode.expect_details, NULL);
cq_verify(v_client);
cq_expect_finished_with_status(v_server, tag(102), GRPC_STATUS_CANCELLED,
@@ -159,9 +152,8 @@ static void test_cancel_after_accept(grpc_end2end_test_config config,
void grpc_end2end_tests(grpc_end2end_test_config config) {
int i;
- canceller cancellers[2] = {grpc_call_cancel, wait_for_deadline};
- for (i = 0; i < GPR_ARRAY_SIZE(cancellers); i++) {
- test_cancel_after_accept(config, cancellers[i]);
+ for (i = 0; i < GPR_ARRAY_SIZE(cancellation_modes); i++) {
+ test_cancel_after_accept(config, cancellation_modes[i]);
}
}