Home
last modified time | relevance | path

Searched defs:RequestType (Results 1 – 17 of 17) sorted by relevance

/third_party/grpc/test/cpp/qps/
Dserver_async.cc54 std::function<void(ServiceType*, ServerContextType*, RequestType*, in AsyncQpsServerTest() argument
59 ServerAsyncReaderWriter<ResponseType, RequestType>*, in AsyncQpsServerTest() argument
252 std::function<void(ServerContextType*, RequestType*, in ServerRpcContextUnaryImpl() argument
256 std::function<grpc::Status(RequestType*, ResponseType*)> invoke_method) in ServerRpcContextUnaryImpl()
310 grpc::ServerAsyncReaderWriter<ResponseType, RequestType>*, void*)> in ServerRpcContextStreamingImpl() argument
312 std::function<grpc::Status(RequestType*, ResponseType*)> invoke_method) in ServerRpcContextStreamingImpl()
388 grpc::ServerAsyncReader<ResponseType, RequestType>*, in ServerRpcContextStreamingFromClientImpl() argument
391 std::function<grpc::Status(RequestType*, ResponseType*)> invoke_method) in ServerRpcContextStreamingFromClientImpl()
456 std::function<void(ServerContextType*, RequestType*, in ServerRpcContextStreamingFromServerImpl() argument
459 std::function<grpc::Status(RequestType*, ResponseType*)> invoke_method) in ServerRpcContextStreamingFromServerImpl()
Dclient_async.cc67 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextUnaryImpl()
338 ClientRpcContextStreamingPingPongImpl( in ClientRpcContextStreamingPingPongImpl()
657 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextStreamingFromServerImpl()
Dclient.h57 ClientRequestCreator(RequestType* /*req*/, const PayloadConfig&) { in ClientRequestCreator() argument
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/
D_interceptor.py100 self, continuation: Callable[[ClientCallDetails, RequestType], argument
103 request: RequestType) -> Union[UnaryUnaryCall, ResponseType]:
133 self, continuation: Callable[[ClientCallDetails, RequestType], argument
135 client_call_details: ClientCallDetails, request: RequestType
171 continuation: Callable[[ClientCallDetails, RequestType], argument
212 continuation: Callable[[ClientCallDetails, RequestType], argument
496 async def write(self, request: RequestType) -> None:
559 request: RequestType, timeout: Optional[float],
579 wait_for_ready: Optional[bool], request: RequestType,
588 request: RequestType) -> _base_call.UnaryUnaryCall:
[all …]
D_typing.py22 RequestType = TypeVar('RequestType') variable
D_base_call.py180 async def write(self, request: RequestType) -> None:
231 async def write(self, request: RequestType) -> None:
D_call.py416 async def _write(self, request: RequestType) -> None:
449 async def write(self, request: RequestType) -> None:
476 def __init__(self, request: RequestType, deadline: Optional[float],
525 def __init__(self, request: RequestType, deadline: Optional[float],
/third_party/grpc/src/python/grpcio/grpc/aio/
D_interceptor.py100 self, continuation: Callable[[ClientCallDetails, RequestType], argument
103 request: RequestType) -> Union[UnaryUnaryCall, ResponseType]:
133 self, continuation: Callable[[ClientCallDetails, RequestType], argument
135 client_call_details: ClientCallDetails, request: RequestType
171 continuation: Callable[[ClientCallDetails, RequestType], argument
212 continuation: Callable[[ClientCallDetails, RequestType], argument
495 async def write(self, request: RequestType) -> None:
558 request: RequestType, timeout: Optional[float],
579 wait_for_ready: Optional[bool], request: RequestType,
587 request: RequestType) -> _base_call.UnaryUnaryCall:
[all …]
D_typing.py22 RequestType = TypeVar('RequestType') variable
D_base_call.py180 async def write(self, request: RequestType) -> None:
231 async def write(self, request: RequestType) -> None:
D_call.py415 async def _write(self, request: RequestType) -> None:
448 async def write(self, request: RequestType) -> None:
475 def __init__(self, request: RequestType, deadline: Optional[float],
524 def __init__(self, request: RequestType, deadline: Optional[float],
/third_party/grpc/include/grpcpp/impl/codegen/
Dmethod_handler.h102 const RequestType*, ResponseType*)> in RpcMethodHandler()
145 ServerReader<RequestType>*, ResponseType*)> in ClientStreamingHandler()
193 const RequestType*, ServerWriter<ResponseType>*)> in ServerStreamingHandler()
333 ServerUnaryStreamer<RequestType, ResponseType>*)> in StreamedUnaryHandler()
348 ServerSplitStreamer<RequestType, ResponseType>*)> in SplitServerStreamingHandler()
Dserver_callback_handlers.h35 const RequestType*, ResponseType*)> in CallbackUnaryHandler()
40 ::grpc::experimental::MessageAllocator<RequestType, ResponseType>* in SetMessageAllocator()
184 ::grpc::experimental::MessageHolder<RequestType, ResponseType>* in ServerCallbackUnaryImpl()
678 std::function<ServerBidiReactor<RequestType, ResponseType>*( in CallbackBidiHandler()
818 void SetupReactor(ServerBidiReactor<RequestType, ResponseType>* reactor) { in SetupReactor()
/third_party/grpc/src/python/grpcio/grpc/
D_simple_stubs.py27 RequestType = TypeVar('RequestType') variable
170 request: RequestType,
251 request: RequestType,
331 request_iterator: Iterator[RequestType],
411 request_iterator: Iterator[RequestType],
/third_party/grpc/include/grpcpp/generic/
Dgeneric_stub.h111 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall()
148 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall()
188 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCallInternal()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_request.h67 enum class RequestType : int16_t { enum
/third_party/libusb/libusb/os/
Dwindows_winusb.h480 UCHAR RequestType; member