Home
last modified time | relevance | path

Searched refs:CacheServiceState (Results 1 – 6 of 6) sorted by relevance

/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_service.cc32 st_(generate_id ? CacheServiceState::kBuildPhase : CacheServiceState::kNone) {} in CacheService()
73 if (HasBuildPhase() && st_ != CacheServiceState::kBuildPhase) { in CacheRow()
79 if (st_ == CacheServiceState::kNoLocking) { in CacheRow()
131 st_ = CacheServiceState::kNoSpace; in CacheRow()
133 st_ = CacheServiceState::kOutOfMemory; in CacheRow()
147 if (HasBuildPhase() && st_ != CacheServiceState::kBuildPhase) { in FastCacheRow()
153 if (st_ == CacheServiceState::kNoLocking) { in FastCacheRow()
185 st_ = CacheServiceState::kNoSpace; in FastCacheRow()
187 st_ = CacheServiceState::kOutOfMemory; in FastCacheRow()
238 if (HasBuildPhase() && st_ != CacheServiceState::kFetchPhase) { in PreBatchFetch()
[all …]
Dcache_service.h84 using state_type = std::underlying_type<CacheServiceState>::type;
95 CacheServiceState GetState() const { return st_.load(); } in GetState()
136 std::atomic<CacheServiceState> st_;
Dcache_common.h62 enum class CacheServiceState : int8_t { enum
Dcache_client.cc179 auto cache_state = static_cast<CacheServiceState>(out); in CreateCache()
180 if (cache_state == CacheServiceState::kFetchPhase || in CreateCache()
181 (cache_state == CacheServiceState::kBuildPhase && cookie_.empty())) { in CreateCache()
Dcache_server.cc360 if (state != CacheServiceState::kFetchPhase) { in FastCacheRow()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/
Dcache_op.cc127 auto state = static_cast<CacheServiceState>(out); in WaitForCachingAllRows()
129 case CacheServiceState::kBuildPhase: in WaitForCachingAllRows()
134 case CacheServiceState::kFetchPhase: in WaitForCachingAllRows()
137 case CacheServiceState::kOutOfMemory: in WaitForCachingAllRows()
139 case CacheServiceState::kNoSpace: in WaitForCachingAllRows()
141 case CacheServiceState::kNone: in WaitForCachingAllRows()
142 case CacheServiceState::kError: in WaitForCachingAllRows()