Home
last modified time | relevance | path

Searched defs:isDirectEnd (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dtime_sync.cpp505 … CommErrHandler handler = [this](int ret, bool isDirectEnd) { CommErrHandlerFunc(ret, this); }; in TimeSyncDriver()
526 … CommErrHandler handler = [this](int ret, bool isDirectEnd) { CommErrHandlerFunc(ret, this); }; in GetTimeOffset()
624 …Packet(deviceId_, message, [handler, timeSyncPtr, sessionId, this](int errCode, bool isDirectEnd) { in SendMessageWithSendEnd()
H A Dsync_task_context.cpp487 …xt::CommErrHandlerFunc(int errCode, ISyncTaskContext *context, int32_t sessionId, bool isDirectEnd) in CommErrHandlerFunc()
528 void SyncTaskContext::CommErrHandlerFuncInner(int errCode, uint32_t sessionId, bool isDirectEnd) in CommErrHandlerFuncInner()
H A Dremote_executor.cpp523 [this, sessionId](int errCode, bool isDirectEnd) { in SendRequestMessage()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_deep_test.cpp994 auto sendResultNotifier = [&sendResult](int result, bool isDirectEnd) { in __anonb9037cf22502()
1039 auto sendResultNotifier = [&sendResult](int result, bool isDirectEnd) { in __anonb9037cf22702()
H A Ddistributeddb_communicator_send_receive_test.cpp581 auto sendResultNotifier = [&sendResult](int result, bool isDirectEnd) { in __anon922778e00f02()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.cpp481 requestSessionId = context_->GetRequestSessionId()](int ret, bool isDirectEnd) { in DoTimeSync()
514 requestSessionId = context_->GetRequestSessionId()](int ret, bool isDirectEnd) { in DoAbilitySync()
H A Dsingle_ver_data_sync.cpp1066 …Handler handler = [this, context, sessionId = message->GetSessionId()](int ret, bool isDirectEnd) { in SendDataPacket()
1458 …Handler handler = [this, context, sessionId = message->GetSessionId()](int ret, bool isDirectEnd) { in SendReSendPacket()
1917 …Handler handler = [this, context, sessionId = message->GetSessionId()](int ret, bool isDirectEnd) { in SendControlPacket()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator_aggregator.cpp384 void VirtualCommunicatorAggregator::MockDirectEndFlag(bool isDirectEnd) in MockDirectEndFlag()