Searched refs:BaseRequest (Results 1 – 11 of 11) sorted by relevance
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_request.h | 64 class BaseRequest {
104 explicit BaseRequest(RequestType type) : type_(type) { in BaseRequest() function
109 virtual ~BaseRequest() = default;
119 friend std::ostream &operator<<(std::ostream &out, const BaseRequest &rq) {
170 class FreeSharedBlockRequest : public BaseRequest {
174 : BaseRequest(RequestType::kFreeSharedBlock) { in FreeSharedBlockRequest()
183 class CacheRowRequest : public BaseRequest {
230 class BatchFetchRequest : public BaseRequest {
244 class CreateCacheRequest : public BaseRequest {
269 class GetCacheMissKeysRequest : public BaseRequest {
[all …]
|
| D | cache_grpc_server.cc | 107 if (rq->type_ == BaseRequest::RequestType::kStopService) { in HandleRequest()
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 ()()
174 BaseRequest::Print(out); in Print()
|
| D | cache_grpc_server.h | 37 class CacheServerRequest : public BaseRequest {
44 …: BaseRequest::BaseRequest(BaseRequest::RequestType::kRequestUnknown), st_(STATE::CREATE), respond… in CacheServerRequest()
|
| D | cache_server.cc | 371 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 …]
|
| D | cache_grpc_client.h | 41 explicit CacheClientRequestTag(std::shared_ptr<BaseRequest> rq, int64_t seqNo) in CacheClientRequestTag()
49 std::shared_ptr<BaseRequest> base_rq_;
73 Status HandleRequest(std::shared_ptr<BaseRequest> rq);
|
| D | cache_request.cc | 30 Status BaseRequest::Wait() { in Wait()
130 : BaseRequest(RequestType::kCacheRow), in CacheRowRequest()
141 …: BaseRequest(RequestType::kBatchFetchRows), support_local_bypass_(cc->local_bypass_), row_id_(row… in BatchFetchRequest()
210 : BaseRequest(RequestType::kCreateCache), cache_mem_sz_(cache_mem_sz), flag_(flag), cc_(cc) { in CreateCacheRequest()
349 : BaseRequest(RequestType::kBatchCacheRows) { in BatchCacheRowsRequest()
|
| D | cache_grpc_client.cc | 82 Status CacheClientGreeter::HandleRequest(std::shared_ptr<BaseRequest> rq) { in HandleRequest()
|
| D | cache_client.h | 219 Status PushRequest(std::shared_ptr<BaseRequest> rq) const;
|
| D | cache_client.cc | 285 Status CacheClient::PushRequest(std::shared_ptr<BaseRequest> rq) const { return comm_->HandleReques… in PushRequest()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/stub/ |
| D | cache_grpc_client.h | 36 …Status HandleRequest(std::shared_ptr<BaseRequest> rq) { RETURN_STATUS_UNEXPECTED("Not supported");… in HandleRequest()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | client_callback.h | 1194 template <class Request, class Response, class BaseRequest = Request,
1208 static_cast<const BaseRequest*>(request), in Create()
|