aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/python/grpcio_test/grpc_test/framework/interfaces/links/test_cases.py
diff options
context:
space:
mode:
authorGravatar Nathaniel Manista <nathaniel@google.com>2015-08-13 10:10:18 -0700
committerGravatar Nathaniel Manista <nathaniel@google.com>2015-08-13 17:22:21 +0000
commit515b0a93526a3955f5f76ce6013394f87a6c904c (patch)
tree4d9d856e9a93c291cdce5c85c1e6ece2ad6b4768 /src/python/grpcio_test/grpc_test/framework/interfaces/links/test_cases.py
parenta39d739c35e43fa8db3bbc0e6d30bf75a704fa6e (diff)
Service-side read without allowance
This compensates for the abstraction mismatch described in issue 2916.
Diffstat (limited to 'src/python/grpcio_test/grpc_test/framework/interfaces/links/test_cases.py')
-rw-r--r--src/python/grpcio_test/grpc_test/framework/interfaces/links/test_cases.py9
1 files changed, 1 insertions, 8 deletions
diff --git a/src/python/grpcio_test/grpc_test/framework/interfaces/links/test_cases.py b/src/python/grpcio_test/grpc_test/framework/interfaces/links/test_cases.py
index 26ca035c44..1e575d1a9e 100644
--- a/src/python/grpcio_test/grpc_test/framework/interfaces/links/test_cases.py
+++ b/src/python/grpcio_test/grpc_test/framework/interfaces/links/test_cases.py
@@ -303,16 +303,9 @@ class TransmissionTest(object):
invocation_message, links.Ticket.Termination.COMPLETION)
self._invocation_link.accept_ticket(original_invocation_ticket)
- # TODO(nathaniel): This shouldn't be necessary. Detecting the end of the
- # invocation-side ticket sequence shouldn't require granting allowance for
- # another payload.
self._service_mate.block_until_tickets_satisfy(
at_least_n_payloads_received_predicate(1))
service_operation_id = self._service_mate.tickets()[0].operation_id
- self._service_link.accept_ticket(
- links.Ticket(
- service_operation_id, 0, None, None, links.Ticket.Subscription.FULL,
- None, 1, None, None, None, None, None, None))
self._service_mate.block_until_tickets_satisfy(terminated)
self._assert_is_valid_invocation_sequence(
@@ -321,7 +314,7 @@ class TransmissionTest(object):
invocation_terminal_metadata, links.Ticket.Termination.COMPLETION)
original_service_ticket = links.Ticket(
- service_operation_id, 1, None, None, links.Ticket.Subscription.FULL,
+ service_operation_id, 0, None, None, links.Ticket.Subscription.FULL,
timeout, 0, service_initial_metadata, service_payload,
service_terminal_metadata, service_code, service_message,
links.Ticket.Termination.COMPLETION)