Searched defs:isDirectEnd (Results 1 – 8 of 8) sorted by relevance
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| D | time_sync.cpp | 505 … 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()
|
| D | sync_task_context.cpp | 487 …xt::CommErrHandlerFunc(int errCode, ISyncTaskContext *context, int32_t sessionId, bool isDirectEnd) in CommErrHandlerFunc()
531 void SyncTaskContext::CommErrHandlerFuncInner(int errCode, uint32_t sessionId, bool isDirectEnd) in CommErrHandlerFuncInner()
|
| D | remote_executor.cpp | 523 [this, sessionId](int errCode, bool isDirectEnd) { in SendRequestMessage()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| D | distributeddb_communicator_deep_test.cpp | 994 auto sendResultNotifier = [&sendResult](int result, bool isDirectEnd) { in __anon8874f9bc2502()
1039 auto sendResultNotifier = [&sendResult](int result, bool isDirectEnd) { in __anon8874f9bc2702()
|
| D | distributeddb_communicator_send_receive_test.cpp | 581 auto sendResultNotifier = [&sendResult](int result, bool isDirectEnd) { in __anon73861faa0f02()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| D | single_ver_sync_state_machine.cpp | 481 requestSessionId = context_->GetRequestSessionId()](int ret, bool isDirectEnd) { in DoTimeSync()
514 requestSessionId = context_->GetRequestSessionId()](int ret, bool isDirectEnd) { in DoAbilitySync()
|
| D | single_ver_data_sync.cpp | 1069 …Handler handler = [this, context, sessionId = message->GetSessionId()](int ret, bool isDirectEnd) { in SendDataPacket()
1469 …Handler handler = [this, context, sessionId = message->GetSessionId()](int ret, bool isDirectEnd) { in SendReSendPacket()
1939 …Handler handler = [this, context, sessionId = message->GetSessionId()](int ret, bool isDirectEnd) { in SendControlPacket()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| D | virtual_communicator_aggregator.cpp | 384 void VirtualCommunicatorAggregator::MockDirectEndFlag(bool isDirectEnd) in MockDirectEndFlag()
|