Searched refs:st_ (Results 1 – 11 of 11) sorted by relevance
32 st_(generate_id ? CacheServiceState::kBuildPhase : CacheServiceState::kNone) {} in CacheService()73 if (HasBuildPhase() && st_ != CacheServiceState::kBuildPhase) { in CacheRow()77 std::to_string(static_cast<int>(st_.load()))); 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()151 std::to_string(static_cast<int>(st_.load()))); in FastCacheRow()153 if (st_ == CacheServiceState::kNoLocking) { in FastCacheRow()185 st_ = CacheServiceState::kNoSpace; in FastCacheRow()[all …]
103 if (rq->st_ == CacheServerRequest::STATE::PROCESS) { in HandleRequest()105 } else if (rq->st_ == CacheServerRequest::STATE::FINISH) { in HandleRequest()129 if (st_ == STATE::CREATE) { in operator ()()130 st_ = STATE::PROCESS; in operator ()()132 } else if (st_ == STATE::PROCESS) { in operator ()()161 } else if (st_ == STATE::FINISH) { in operator ()()
44 …: BaseRequest::BaseRequest(BaseRequest::RequestType::kRequestUnknown), st_(STATE::CREATE), respond… in CacheServerRequest()61 STATE st_; variable
95 CacheServiceState GetState() const { return st_.load(); } in GetState()136 std::atomic<CacheServiceState> st_; variable
460 cache_rq->st_ = CacheServerRequest::STATE::PROCESS; in BatchFetch()784 cache_rq->st_ = CacheServerRequest::STATE::PROCESS; in BatchCacheRows()957 cache_req->st_ = CacheServerRequest::STATE::FINISH; in ProcessRequest()
28 IntrpResource() : st_(State::kRunning) {} in IntrpResource()32 virtual void Interrupt() { st_ = State::kInterrupted; } in Interrupt()34 virtual void ResetIntrpState() { st_ = State::kRunning; } in ResetIntrpState()36 State CurState() const { return st_; } in CurState()48 std::atomic<State> st_;
49 TensorRowCacheRequest() : st_(State::kEmpty) {} in TensorRowCacheRequest()52 State GetState() const { return st_; } in GetState()53 void SetState(State newState) { st_ = newState; } in SetState()67 std::atomic<State> st_;
256 if (st_.compare_exchange_strong(expected, State::kDirty)) { in AsyncSendCacheRequest()269 st_ = State::kClean; in AsyncSendCacheRequest()274 st_ = State::kEmpty; in AsyncSendCacheRequest()283 if (st_.compare_exchange_strong(expected, State::kClean)) { in CheckCacheResult()
48 st_ = st; in single_stream_rendezvous()56 st_ = st; in notify()66 return std::make_tuple( st_, status_); in wait()72 cudaStream_t st_{}; member in boost::fibers::cuda::detail::single_stream_rendezvous
48 st_ = st; in single_stream_rendezvous()56 st_ = st; in notify()66 return std::make_tuple( st_, status_); in wait()72 hipStream_t st_{}; member in boost::fibers::cuda::detail::single_stream_rendezvous
19465 - In test_os, st_?time is now truncated before comparing it with ST_?TIME.