Home
last modified time | relevance | path

Searched refs:server_connection_id_ (Results 1 – 3 of 3) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_client.cc61 server_connection_id_(0), in CacheClient()
81 auto rq = std::make_shared<ConnectResetRequest>(server_connection_id_, client_id_); in ~CacheClient()
100 … << "\n Server cache id: " << server_connection_id_ << "\n Cache mem size: " << GetCacheMemSz() in Print()
137 …auto mfree_req = std::make_shared<FreeSharedBlockRequest>(server_connection_id_, client_id_, mem_a… in GetRows()
170 if (server_connection_id_) { in CreateCache()
228 auto rq = std::make_shared<DestroyCacheRequest>(server_connection_id_); in DestroyCache()
238 …CHECK_FAIL_RETURN_UNEXPECTED(server_connection_id_ != 0, "GetStat called but the cache is not in u… in GetStat()
240 auto rq = std::make_shared<GetStatRequest>(server_connection_id_); in GetStat()
250 …CHECK_FAIL_RETURN_UNEXPECTED(server_connection_id_ != 0, "GetState called but the cache is not in … in GetState()
251 auto rq = std::make_shared<GetCacheStateRequest>(server_connection_id_); in GetState()
[all …]
Dcache_request.cc135 rq_.set_connection_id(cc->server_connection_id_); in CacheRowRequest()
142 rq_.set_connection_id(cc->server_connection_id_); in BatchFetchRequest()
233 cc_->server_connection_id_ = p->connection_id(); in PostReply()
350 rq_.set_connection_id(cc->server_connection_id_); in BatchCacheRowsRequest()
Dcache_client.h280 connection_id_type server_connection_id_; variable