| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/ |
| D | task.cc | 57 rc_ = vg->GetIntrpService()->Register(ss.str(), this); in operator ()()
58 if (rc_.IsOk()) { in operator ()()
60 rc_ = fnc_obj_(); in operator ()()
63 if (rc_.IsError() && rc_ != StatusCode::kMDInterrupted) { in operator ()()
64 if (rc_.StatusCode() == StatusCode::kMDNetWorkError) { in operator ()()
65 MS_LOG(WARNING) << rc_; in operator ()()
67 …OR) << "Task: " << my_name_ << " - thread(" << ss.str() << ") is terminated with err msg: " << rc_; in operator ()()
72 rc_ = Status(StatusCode::kMDOutOfMemory, __LINE__, __FILE__, e.what()); in operator ()()
73 MS_LOG(ERROR) << rc_; in operator ()()
76 rc_ = Status(StatusCode::kMDUnexpectedError, __LINE__, __FILE__, e.what()); in operator ()()
[all …]
|
| D | task_manager.cc | 213 if (rc.IsError() && master->rc_.IsOk()) { in InterruptMaster()
214 master->rc_ = rc; in InterruptMaster()
217 … MS_LOG(ERROR) << "Task is terminated with err msg(more detail in info level log):" << master->rc_; in InterruptMaster()
228 master->rc_ = Status::OK(); in GetMasterThreadRc()
297 if (rc_.IsError()) { in CreateAsyncTask()
298 return pMytask->IsMasterThread() ? rc_ : Status(StatusCode::kMDInterrupted); in CreateAsyncTask()
|
| D | task.h | 119 Status rc_; variable
|
| D | README.md | 20 Status rc_;
49 rc_ = fnc_obj_();
51 rc_ = Status(StatusCode::kOutOfMemory, __LINE__, __FILE__, e.what());
53 rc_ = Status(StatusCode::kUnexpectedError, __LINE__, __FILE__, e.what());
101 …ber for unlimited number of retrieval. As we shall see later, the value of rc_ will be propagated …
175 A TaskGroup does not save records for all the Task::rc_ for all the threads in this group. Only the…
223 …rc_ by calling TaskManager::InterruptMaster(rc). However, because there can be many TaskGroups run…
225 …form is the *preferred* method. For the second form, TaskManager::master_::rc_ will be reset to OK…
|
| D | task_manager.h | 157 Status rc_;
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_server.cc | 812 cache_req->rc_ = FastCacheRow(&rq, &reply); in ProcessRowRequest()
814 cache_req->rc_ = CacheRow(&rq, &reply); in ProcessRowRequest()
820 cache_req->rc_ = InternalCacheRow(&rq, &reply); in ProcessRowRequest()
824 cache_req->rc_ = BatchCacheRows(&rq); in ProcessRowRequest()
828 cache_req->rc_ = BatchFetchRows(&rq, &reply); in ProcessRowRequest()
833 cache_req->rc_ = InternalFetchRow(&rq); in ProcessRowRequest()
839 cache_req->rc_ = Status(StatusCode::kMDUnexpectedError, __LINE__, __FILE__, errMsg); in ProcessRowRequest()
849 cache_req->rc_ = DestroySession(&rq); in ProcessSessionRequest()
853 cache_req->rc_ = GenerateClientSessionID(GenerateSessionID(), &reply); in ProcessSessionRequest()
857 cache_req->rc_ = ListSessions(&reply); in ProcessSessionRequest()
[all …]
|
| D | cache_grpc_client.cc | 102 ccReqTag->rpc_->Finish(&ccReqTag->base_rq_->reply_, &ccReqTag->rc_, ccReqTag); in HandleRequest()
117 auto &rc = rq->rc_; in WorkerEntry()
119 auto error_code = rq->rc_.error_code(); in WorkerEntry()
125 err_msg = rq->rc_.error_message() + ". GRPC Code " + std::to_string(error_code); in WorkerEntry()
|
| D | cache_grpc_server.h | 60 Status rc_;
|
| D | cache_grpc_client.h | 50 grpc::Status rc_; variable
|
| /third_party/ejdb/src/examples/ |
| D | example1.c | 4 #define CHECK(rc_) \ argument
5 if (rc_) { \
6 iwlog_ecode_error3(rc_); \
|
| /third_party/ejdb/src/ |
| D | ejdb2_internal.h | 77 #define API_UNLOCK(db_, rci_, rc_) \ argument
79 if (rci_) IWRC(iwrc_set_errno(IW_ERROR_THREADING_ERRNO, rci_), rc_)
81 #define API_COLL_UNLOCK(jbc_, rci_, rc_) \ argument
84 if (rci_) IWRC(iwrc_set_errno(IW_ERROR_THREADING_ERRNO, rci_), rc_); \
85 API_UNLOCK((jbc_)->db, rci_, rc_); \
|
| /third_party/iowow/src/kv/ |
| D | iwkv_internal.h | 348 #define API_UNLOCK(iwkv_, rci_, rc_) \ argument
350 if (rci_) IWRC(iwrc_set_errno(IW_ERROR_THREADING_ERRNO, rci_), rc_)
384 #define API_DB_UNLOCK(db_, rci_, rc_) \ argument
387 if (rci_) IWRC(iwrc_set_errno(IW_ERROR_THREADING_ERRNO, rci_), rc_); \
388 API_UNLOCK((db_)->iwkv, rci_, rc_); \
|
| D | iwkv.c | 23 #define IWKV_IS_INTERNAL_RC(rc_) ((rc_) > _IWKV_ERROR_END && (rc_) < _IWKV_RC_END) argument
|
| /third_party/ejdb/ |
| D | CAPI.md | 14 #define CHECK(rc_) \
15 if (rc_) { \
16 iwlog_ecode_error3(rc_); \
|
| D | README.md | 1234 #define CHECK(rc_) \
1235 if (rc_) { \
1236 iwlog_ecode_error3(rc_); \
|
| /third_party/boost/boost/spirit/home/x3/support/ |
| D | no_case.hpp | 54 int32_t operator()(Char lc_, Char const rc_) const in operator ()()
58 auto rc = char_type(rc_); in operator ()()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/api/ |
| D | execute.cc | 221 Status rc_ = t->Compute(de_tensor_row, &de_output_row); in operator ()() local
222 if (rc_.IsError()) { in operator ()()
223 MS_LOG(ERROR) << rc_; in operator ()()
224 return rc_; in operator ()()
|
| /third_party/ejdb/src/jbr/ |
| D | jbr.c | 54 #define JBR_RC_REPORT(code_, r_, rc_) \ argument
56 if ((code_) >= 500) iwlog_ecode_error3(rc_); \
57 const char *strerr = iwlog_ecode_explained(rc_); \
|
| /third_party/ejdb/src/bindings/ejdb2_dart/lib/ |
| D | ejdb2_dart.c | 126 #define EJPORT_RC(co_, rc_) \ argument
127 if (rc_) { \
129 (co_)->value.as_int64 = (rc_); \
|
| /third_party/mesa3d/src/amd/compiler/ |
| D | aco_register_allocation.cpp | 54 assignment(PhysReg reg_, RegClass rc_) : reg(reg_), rc(rc_), assigned(-1) {} in assignment()
199 DefInfo(ra_ctx& ctx, aco_ptr<Instruction>& instr, RegClass rc_, int operand) : rc(rc_) in DefInfo()
1360 IDAndRegClass(unsigned id_, RegClass rc_) : id(id_), rc(rc_) {} in IDAndRegClass()
|
| D | aco_ir.h | 338 constexpr RegClass(RC rc_) : rc(rc_) {} in RegClass()
|
| /third_party/ejdb/src/jql/inc/ |
| D | jqpx.c | 10 #define JQRC(yy_, rc_) do { \ argument
11 iwrc __rc = (rc_); \
|
| /third_party/python/Modules/ |
| D | socketmodule.c | 471 #define _BT_RC_MEMB(sa, memb) ((sa)->rc_##memb)
|