From 75c9d2f5291f998c9263aebb26f8d87667290a4f Mon Sep 17 00:00:00 2001 From: murgatroid99 Date: Tue, 3 Feb 2015 18:16:23 -0800 Subject: [PATCH 1/2] Added cancel_after_first_response interop test --- src/php/tests/interop/interop_client.php | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) diff --git a/src/php/tests/interop/interop_client.php b/src/php/tests/interop/interop_client.php index d1f994a84b6..afae738c7e0 100755 --- a/src/php/tests/interop/interop_client.php +++ b/src/php/tests/interop/interop_client.php @@ -149,6 +149,25 @@ function pingPong($stub) { 'Call did not complete successfully'); } +function cancelAfterFirstResponse($stub) { + $call = $stub->StreamingInputCall(); + $request = new grpc\testing\StreamingOutputCallRequest(); + $request->setResponseType(grpc\testing\PayloadType::COMPRESSABLE); + $response_parameters = new grpc\testing\ResponseParameters(); + $response_parameters->setSize(31415); + $request->addResponseParameters($response_parameters); + $payload = new grpc\testing\Payload(); + $payload->setBody(str_repeat("\0", 27182)); + $request->setPayload($payload); + + $call->write($request); + $response = $call->read(); + + $call->cancel(); + hardAssert($call->getStatus()->code === Grpc\STATUS_CANCELLED, + 'Call status was not CANCELLED'); +} + $args = getopt('', array('server_host:', 'server_port:', 'test_case:')); if (!array_key_exists('server_host', $args) || !array_key_exists('server_port', $args) || @@ -187,4 +206,6 @@ switch($args['test_case']) { case 'ping_pong': pingPong($stub); break; + case 'cancel_after_first_response': + cancelAfterFirstResponse($stub); } \ No newline at end of file From 554fe351d30f59aee8c9c15338a5545f15375dd2 Mon Sep 17 00:00:00 2001 From: murgatroid99 Date: Tue, 3 Feb 2015 18:18:28 -0800 Subject: [PATCH 2/2] Fixed error in new test --- src/php/tests/interop/interop_client.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/php/tests/interop/interop_client.php b/src/php/tests/interop/interop_client.php index afae738c7e0..5266e9a9fac 100755 --- a/src/php/tests/interop/interop_client.php +++ b/src/php/tests/interop/interop_client.php @@ -150,7 +150,7 @@ function pingPong($stub) { } function cancelAfterFirstResponse($stub) { - $call = $stub->StreamingInputCall(); + $call = $stub->FullDuplexCall(); $request = new grpc\testing\StreamingOutputCallRequest(); $request->setResponseType(grpc\testing\PayloadType::COMPRESSABLE); $response_parameters = new grpc\testing\ResponseParameters();