Searched refs:rpc_state (Results 1 – 6 of 6) sorted by relevance
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _channel_rpc.py | 20 def __init__(self, rpc_state): argument
21 self._rpc_state = rpc_state
36 def __init__(self, rpc_state): argument
37 self._rpc_state = rpc_state
54 def __init__(self, rpc_state): argument
55 self._rpc_state = rpc_state
76 def __init__(self, rpc_state): argument
77 self._rpc_state = rpc_state
99 rpc_state = channel_state.take_rpc_state(method_descriptor)
101 rpc_state.take_invocation_metadata_and_request())
[all …]
|
| D | _channel_state.py | 30 rpc_state = _rpc_state.State(invocation_metadata, requests,
33 self._rpc_states[method_full_rpc_name].append(rpc_state)
35 return rpc_state
|
| /external/libevent/ |
| D | evrpc.c | 288 struct evrpc_req_generic *rpc_state = NULL; in evrpc_request_cb() local
295 rpc_state = mm_calloc(1, sizeof(struct evrpc_req_generic)); in evrpc_request_cb()
296 if (rpc_state == NULL) in evrpc_request_cb()
298 rpc_state->rpc = rpc; in evrpc_request_cb()
299 rpc_state->http_req = req; in evrpc_request_cb()
300 rpc_state->rpc_data = NULL; in evrpc_request_cb()
305 evrpc_hook_associate_meta_(&rpc_state->hook_meta, req->evcon); in evrpc_request_cb()
311 rpc_state, req, req->input_buffer); in evrpc_request_cb()
316 evrpc_pause_request(rpc->base, rpc_state, in evrpc_request_cb()
328 evrpc_request_cb_closure(rpc_state, EVRPC_CONTINUE); in evrpc_request_cb()
[all …]
|
| D | evrpc-internal.h | 83 void evrpc_reqstate_free_(struct evrpc_req_generic* rpc_state);
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _server.py | 586 rpc_state = _RPCState()
588 lambda ignored_event: (rpc_state, (),))
589 return rpc_state
721 rpc_state, rpc_future = _handle_call(
724 if rpc_state is not None:
725 state.rpc_states.add(rpc_state)
735 rpc_state, callbacks = event.tag(event)
739 if rpc_state is not None:
741 state.rpc_states.remove(rpc_state)
|
| /external/grpc-grpc/test/core/end2end/ |
| D | bad_server_response_test.cc | 73 struct rpc_state { struct
89 static struct rpc_state state; argument
|