|
|
@ -257,11 +257,11 @@ class _Kernel(object): |
|
|
|
termination = None |
|
|
|
termination = None |
|
|
|
else: |
|
|
|
else: |
|
|
|
termination = links.Ticket.Termination.COMPLETION |
|
|
|
termination = links.Ticket.Termination.COMPLETION |
|
|
|
ticket = links.Ticket( |
|
|
|
early_read_ticket = links.Ticket( |
|
|
|
call, rpc_state.sequence_number, None, None, None, None, None, |
|
|
|
call, rpc_state.sequence_number, None, None, None, None, None, |
|
|
|
None, payload, None, None, None, termination) |
|
|
|
None, payload, None, None, None, termination) |
|
|
|
rpc_state.sequence_number += 1 |
|
|
|
rpc_state.sequence_number += 1 |
|
|
|
self._relay.add_value(ticket) |
|
|
|
self._relay.add_value(early_read_ticket) |
|
|
|
|
|
|
|
|
|
|
|
if ticket.payload is not None: |
|
|
|
if ticket.payload is not None: |
|
|
|
call.write(rpc_state.response_serializer(ticket.payload), call) |
|
|
|
call.write(rpc_state.response_serializer(ticket.payload), call) |
|
|
|