Home
last modified time | relevance | path

Searched refs:uvEntry (Results 1 - 2 of 2) sorted by relevance

/foundation/distributeddatamgr/data_share/frameworks/native/provider/src/
H A Ddatashare_uv_queue.cpp62 LOG_ERROR("invalid uvEntry."); in SyncCall()
66 auto *uvEntry = static_cast<UvEntry*>(work->data); in SyncCall() local
68 std::unique_lock<std::mutex> lock(uvEntry->mutex); in SyncCall()
69 uvEntry->count.fetch_add(1); in SyncCall()
77 if (uvEntry->condition.wait_for(lock, std::chrono::seconds(WAIT_TIME), [uvEntry] { return uvEntry->done; })) { in SyncCall()
82 if (!uvEntry->done && uv_cancel((uv_req_t*)work) != napi_ok) { in SyncCall()
/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/common/
H A Duv_queue.cpp81 UvEntry *uvEntry = static_cast<UvEntry *>(work->data); in CallFunction() local
82 delete uvEntry; in CallFunction()
83 uvEntry = nullptr; in CallFunction()

Completed in 1 milliseconds