Home
last modified time | relevance | path

Searched refs:RequestType (Results 1 – 25 of 34) sorted by relevance

12

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_request.h67 enum class RequestType : int16_t { enum
104 explicit BaseRequest(RequestType type) : type_(type) { in BaseRequest()
137 return type_ == RequestType::kBatchCacheRows || type_ == RequestType::kBatchFetchRows || in IsRowRequest()
138 type_ == RequestType::kInternalCacheRow || type_ == RequestType::kInternalFetchRow || in IsRowRequest()
139 type_ == RequestType::kCacheRow; in IsRowRequest()
145 return type_ == RequestType::kCreateCache || type_ == RequestType::kDestroyCache || in IsAdminRequest()
146 type_ == RequestType::kGetStat || type_ == RequestType::kGetCacheState || in IsAdminRequest()
147 type_ == RequestType::kAllocateSharedBlock || type_ == RequestType::kFreeSharedBlock || in IsAdminRequest()
148 type_ == RequestType::kCacheSchema || type_ == RequestType::kFetchSchema || in IsAdminRequest()
149 type_ == RequestType::kBuildPhaseDone || type_ == RequestType::kToggleWriteMode || in IsAdminRequest()
[all …]
Dcache_grpc_server.cc107 if (rq->type_ == BaseRequest::RequestType::kStopService) { in HandleRequest()
146 type_ = static_cast<RequestType>(rq_.type()); in operator ()()
152 …if (type_ == BaseRequest::RequestType::kBatchFetchRows || type_ == BaseRequest::RequestType::kBatc… in operator ()()
153 …type_ == BaseRequest::RequestType::kStopService || type_ == BaseRequest::RequestType::kAllocateSha… in operator ()()
154 type_ == BaseRequest::RequestType::kFreeSharedBlock) { in operator ()()
Dcache_server.cc371 if (static_cast<BaseRequest::RequestType>(rq->type()) == BaseRequest::RequestType::kCacheRow) { in FastCacheRow()
459 cache_rq->type_ = BaseRequest::RequestType::kInternalFetchRow; in BatchFetch()
783 cache_rq->type_ = BaseRequest::RequestType::kInternalCacheRow; in BatchCacheRows()
809 case BaseRequest::RequestType::kCacheRow: { in ProcessRowRequest()
818 case BaseRequest::RequestType::kInternalCacheRow: { in ProcessRowRequest()
823 case BaseRequest::RequestType::kBatchCacheRows: { in ProcessRowRequest()
827 case BaseRequest::RequestType::kBatchFetchRows: { in ProcessRowRequest()
831 case BaseRequest::RequestType::kInternalFetchRow: { in ProcessRowRequest()
848 case BaseRequest::RequestType::kDropSession: { in ProcessSessionRequest()
852 case BaseRequest::RequestType::kGenerateSessionId: { in ProcessSessionRequest()
[all …]
/third_party/grpc/include/grpcpp/impl/codegen/
Dmethod_handler.h79 template <class RequestType>
81 ::grpc::Status* status, RequestType* request) { in UnaryDeserializeHelper()
84 *status = ::grpc::SerializationTraits<RequestType>::Deserialize( in UnaryDeserializeHelper()
85 &buf, static_cast<RequestType*>(request)); in UnaryDeserializeHelper()
90 request->~RequestType(); in UnaryDeserializeHelper()
95 template <class ServiceType, class RequestType, class ResponseType,
96 class BaseRequestType = RequestType,
102 const RequestType*, ResponseType*)> in RpcMethodHandler() argument
114 static_cast<RequestType*>(param.request), &rsp); in RunHandler()
116 static_cast<RequestType*>(param.request)->~RequestType(); in RunHandler()
[all …]
Dserver_callback_handlers.h30 template <class RequestType, class ResponseType>
35 const RequestType*, ResponseType*)> in CallbackUnaryHandler() argument
40 ::grpc::experimental::MessageAllocator<RequestType, ResponseType>* in SetMessageAllocator() argument
49 ::grpc::experimental::MessageHolder<RequestType, ResponseType>*>( in RunHandler()
84 RequestType* request = nullptr; in Deserialize()
85 ::grpc::experimental::MessageHolder<RequestType, ResponseType>* in Deserialize()
92 call, sizeof(DefaultMessageHolder<RequestType, ResponseType>))) in Deserialize()
93 DefaultMessageHolder<RequestType, ResponseType>(); in Deserialize()
98 ::grpc::SerializationTraits<RequestType>::Deserialize(&buf, request); in Deserialize()
110 const RequestType*, ResponseType*)>
[all …]
Dbyte_buffer.h39 template <class RequestType, class ResponseType>
41 template <class RequestType, class ResponseType>
43 template <class RequestType>
45 RequestType*);
46 template <class ServiceType, class RequestType, class ResponseType>
166 template <class RequestType>
168 ::grpc::Status*, RequestType*);
169 template <class ServiceType, class RequestType, class ResponseType>
171 template <class RequestType, class ResponseType>
173 template <class RequestType, class ResponseType>
Dserver_context_impl.h69 template <class ServiceType, class RequestType, class ResponseType>
71 template <class RequestType, class ResponseType>
73 template <class RequestType, class ResponseType>
75 template <class RequestType, class ResponseType>
77 template <class RequestType, class ResponseType>
79 template <class ServiceType, class RequestType, class ResponseType>
81 template <class ServiceType, class RequestType, class ResponseType>
87 template <class ServiceType, class RequestType, class ResponseType>
356 template <class ServiceType, class RequestType, class ResponseType>
358 template <class ServiceType, class RequestType, class ResponseType>
[all …]
Dserver_context.h67 template <class ServiceType, class RequestType, class ResponseType>
69 template <class RequestType, class ResponseType>
71 template <class RequestType, class ResponseType>
73 template <class RequestType, class ResponseType>
75 template <class RequestType, class ResponseType>
77 template <class ServiceType, class RequestType, class ResponseType>
82 template <class ServiceType, class RequestType, class ResponseType,
89 template <class ServiceType, class RequestType, class ResponseType>
374 template <class ServiceType, class RequestType, class ResponseType,
377 template <class ServiceType, class RequestType, class ResponseType>
[all …]
Dcompletion_queue_impl.h66 template <class ServiceType, class RequestType, class ResponseType>
68 template <class ServiceType, class RequestType, class ResponseType>
70 template <class ServiceType, class RequestType, class ResponseType>
275 template <class ServiceType, class RequestType, class ResponseType>
277 template <class ServiceType, class RequestType, class ResponseType>
279 template <class ServiceType, class RequestType, class ResponseType>
Dsync_stream_impl.h618 template <class ServiceType, class RequestType, class ResponseType>
693 template <class ServiceType, class RequestType, class ResponseType>
822 template <class RequestType, class ResponseType>
824 : public ServerReaderWriterInterface<ResponseType, RequestType> {
847 bool Read(RequestType* request) override { in Read()
873 internal::ServerReaderWriterBody<ResponseType, RequestType> body_;
878 ServerUnaryStreamer<RequestType, ResponseType>, true>;
889 template <class RequestType, class ResponseType>
891 : public ServerReaderWriterInterface<ResponseType, RequestType> {
914 bool Read(RequestType* request) override { in Read()
[all …]
Dsync_stream.h617 template <class ServiceType, class RequestType, class ResponseType>
692 template <class ServiceType, class RequestType, class ResponseType>
819 template <class RequestType, class ResponseType>
821 : public ServerReaderWriterInterface<ResponseType, RequestType> {
844 bool Read(RequestType* request) override { in Read()
870 internal::ServerReaderWriterBody<ResponseType, RequestType> body_;
875 ServerUnaryStreamer<RequestType, ResponseType>, true>;
885 template <class RequestType, class ResponseType>
887 : public ServerReaderWriterInterface<ResponseType, RequestType> {
910 bool Read(RequestType* request) override { in Read()
[all …]
Dcompletion_queue.h67 template <class ServiceType, class RequestType, class ResponseType,
70 template <class ServiceType, class RequestType, class ResponseType>
72 template <class ServiceType, class RequestType, class ResponseType>
278 template <class ServiceType, class RequestType, class ResponseType>
280 template <class ServiceType, class RequestType, class ResponseType>
/third_party/grpc/include/grpcpp/generic/
Dgeneric_stub.h43 template <class RequestType, class ResponseType>
53 std::unique_ptr<ClientAsyncReaderWriter<RequestType, ResponseType>>
65 const RequestType& request, ::grpc::CompletionQueue* cq) { in PrepareUnaryCall()
80 std::unique_ptr<ClientAsyncReaderWriter<RequestType, ResponseType>> Call( in Call()
90 const RequestType* request, ResponseType* response, in UnaryCall()
101 const RequestType* request, ResponseType* response, in PrepareUnaryCall()
111 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
126 const RequestType* request, ResponseType* response, in UnaryCall()
137 const RequestType* request, ResponseType* response, in PrepareUnaryCall()
148 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() argument
[all …]
/third_party/grpc/test/cpp/qps/
Dserver_async.cc47 template <class RequestType, class ResponseType, class ServiceType,
54 std::function<void(ServiceType*, ServerContextType*, RequestType*, in AsyncQpsServerTest() argument
59 ServerAsyncReaderWriter<ResponseType, RequestType>*, in AsyncQpsServerTest() argument
63 ServerAsyncReader<ResponseType, RequestType>*, in AsyncQpsServerTest()
66 std::function<void(ServiceType*, ServerContextType*, RequestType*, in AsyncQpsServerTest()
71 ServerAsyncReaderWriter<ResponseType, RequestType>*, in AsyncQpsServerTest()
74 std::function<grpc::Status(const PayloadConfig&, RequestType*, in AsyncQpsServerTest()
252 std::function<void(ServerContextType*, RequestType*, in ServerRpcContextUnaryImpl() argument
256 std::function<grpc::Status(RequestType*, ResponseType*)> invoke_method) in ServerRpcContextUnaryImpl() argument
269 req_ = RequestType(); in Reset()
[all …]
Dclient_async.cc63 template <class RequestType, class ResponseType>
67 BenchmarkService::Stub* stub, const RequestType& req, in ClientRpcContextUnaryImpl() argument
71 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&, in ClientRpcContextUnaryImpl()
123 const RequestType& req_;
130 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&,
149 template <class StubType, class RequestType>
150 class AsyncClient : public ClientImpl<StubType, RequestType> {
157 using ClientImpl<StubType, RequestType>::cores_;
158 using ClientImpl<StubType, RequestType>::channels_;
159 using ClientImpl<StubType, RequestType>::request_;
[all …]
Dclient.h54 template <class RequestType>
57 ClientRequestCreator(RequestType* /*req*/, const PayloadConfig&) { in ClientRequestCreator() argument
423 template <class StubType, class RequestType>
438 ClientRequestCreator<RequestType> create_req(&request_, in ClientImpl()
442 const RequestType* request() { return &request_; } in request()
501 RequestType request_;
/third_party/grpc/src/python/grpcio/grpc/aio/
D_base_call.py26 from ._typing import (DoneCallbackType, EOFType, RequestType, ResponseType)
134 class UnaryUnaryCall(Generic[RequestType, ResponseType],
148 class UnaryStreamCall(Generic[RequestType, ResponseType],
175 class StreamUnaryCall(Generic[RequestType, ResponseType],
180 async def write(self, request: RequestType) -> None: argument
204 class StreamStreamCall(Generic[RequestType, ResponseType],
231 async def write(self, request: RequestType) -> None: argument
D_interceptor.py29 from ._typing import (RequestType, SerializingFunction, DeserializingFunction,
100 self, continuation: Callable[[ClientCallDetails, RequestType], argument
103 request: RequestType) -> Union[UnaryUnaryCall, ResponseType]: argument
133 self, continuation: Callable[[ClientCallDetails, RequestType], argument
135 client_call_details: ClientCallDetails, request: RequestType argument
171 continuation: Callable[[ClientCallDetails, RequestType], argument
212 continuation: Callable[[ClientCallDetails, RequestType], argument
465 _write_to_iterator_async_gen: Optional[AsyncIterable[RequestType]]
495 async def write(self, request: RequestType) -> None: argument
558 request: RequestType, timeout: Optional[float], argument
[all …]
D_base_server.py21 from ._typing import RequestType, ResponseType
134 class ServicerContext(Generic[RequestType, ResponseType], abc.ABC):
138 async def read(self) -> RequestType:
D_call.py30 RequestIterableType, RequestType, ResponseType,
415 async def _write(self, request: RequestType) -> None: argument
448 async def write(self, request: RequestType) -> None: argument
471 _request: RequestType
475 def __init__(self, request: RequestType, deadline: Optional[float], argument
520 _request: RequestType
524 def __init__(self, request: RequestType, deadline: Optional[float], argument
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/
D_base_call.py26 from ._typing import (DoneCallbackType, EOFType, RequestType, ResponseType)
134 class UnaryUnaryCall(Generic[RequestType, ResponseType],
148 class UnaryStreamCall(Generic[RequestType, ResponseType],
175 class StreamUnaryCall(Generic[RequestType, ResponseType],
180 async def write(self, request: RequestType) -> None: argument
204 class StreamStreamCall(Generic[RequestType, ResponseType],
231 async def write(self, request: RequestType) -> None: argument
D_interceptor.py29 from ._typing import (RequestType, SerializingFunction, DeserializingFunction,
100 self, continuation: Callable[[ClientCallDetails, RequestType], argument
103 request: RequestType) -> Union[UnaryUnaryCall, ResponseType]: argument
133 self, continuation: Callable[[ClientCallDetails, RequestType], argument
135 client_call_details: ClientCallDetails, request: RequestType argument
171 continuation: Callable[[ClientCallDetails, RequestType], argument
212 continuation: Callable[[ClientCallDetails, RequestType], argument
466 _write_to_iterator_async_gen: Optional[AsyncIterable[RequestType]]
496 async def write(self, request: RequestType) -> None: argument
559 request: RequestType, timeout: Optional[float], argument
[all …]
D_base_server.py21 from ._typing import RequestType, ResponseType
134 class ServicerContext(Generic[RequestType, ResponseType], abc.ABC):
138 async def read(self) -> RequestType:
D_call.py30 RequestIterableType, RequestType, ResponseType,
416 async def _write(self, request: RequestType) -> None: argument
449 async def write(self, request: RequestType) -> None: argument
472 _request: RequestType
476 def __init__(self, request: RequestType, deadline: Optional[float], argument
521 _request: RequestType
525 def __init__(self, request: RequestType, deadline: Optional[float], argument
/third_party/grpc/src/python/grpcio/grpc/
D_simple_stubs.py27 RequestType = TypeVar('RequestType') variable
170 request: RequestType, argument
251 request: RequestType, argument
331 request_iterator: Iterator[RequestType], argument
411 request_iterator: Iterator[RequestType], argument

12