Lines Matching refs:due
94 self.due = set()
115 state.due.remove(token)
116 if (state.client is _CANCELLED or state.statused) and not state.due:
153 state.due.add(token)
274 self._state.due.add(_SEND_INITIAL_METADATA_TOKEN)
321 self._state.due.add(_RECEIVE_MESSAGE_TOKEN)
327 _RECEIVE_MESSAGE_TOKEN not in self._state.due):
366 state.due.add(_RECEIVE_MESSAGE_TOKEN)
452 state.due.add(token)
455 if token not in state.due:
479 state.due.add(_SEND_STATUS_FROM_SERVER_TOKEN)
598 state.due.add(_RECEIVE_CLOSE_ON_SERVER_TOKEN)
666 self.due = set()
688 state.due.add(_REQUEST_CALL_TAG)
693 if not state.rpc_states and not state.due:
712 state.due.remove(_SHUTDOWN_TAG)
717 state.due.remove(_REQUEST_CALL_TAG)
761 state.due.add(_SHUTDOWN_TAG)