| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_task_context.cpp | 487 …xt::CommErrHandlerFunc(int errCode, ISyncTaskContext *context, int32_t sessionId, bool isDirectEnd) in CommErrHandlerFunc() argument
500 isDirectEnd); in CommErrHandlerFunc()
528 void SyncTaskContext::CommErrHandlerFuncInner(int errCode, uint32_t sessionId, bool isDirectEnd) in CommErrHandlerFuncInner() argument
543 …E("[SyncTaskContext][CommErr] errCode %d, isDirectEnd %d", errCode, static_cast<int>(isDirectEnd)); in CommErrHandlerFuncInner()
544 if (!isDirectEnd) { in CommErrHandlerFuncInner()
|
| H A D | sync_task_context.h | 177 …ErrHandlerFunc(int errCode, ISyncTaskContext *context, int32_t sessionId, bool isDirectEnd = true);
232 void CommErrHandlerFuncInner(int errCode, uint32_t sessionId, bool isDirectEnd = true);
|
| H A D | time_sync.cpp | 505 … CommErrHandler handler = [this](int ret, bool isDirectEnd) { CommErrHandlerFunc(ret, this); }; in TimeSyncDriver() argument
526 … CommErrHandler handler = [this](int ret, bool isDirectEnd) { CommErrHandlerFunc(ret, this); }; in GetTimeOffset() argument
624 …Packet(deviceId_, message, [handler, timeSyncPtr, sessionId, this](int errCode, bool isDirectEnd) { in SendMessageWithSendEnd() argument
635 handler(errCode, isDirectEnd); in SendMessageWithSendEnd()
|
| H A D | remote_executor.cpp | 523 [this, sessionId](int errCode, bool isDirectEnd) { in SendRequestMessage() argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | communicator_type_define.h | 28 using OnSendEnd = std::function<void(int result, bool isDirectEnd)>;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator_aggregator.cpp | 384 void VirtualCommunicatorAggregator::MockDirectEndFlag(bool isDirectEnd) in MockDirectEndFlag() argument
386 isDirectEnd_ = isDirectEnd; in MockDirectEndFlag()
|
| H A D | virtual_communicator_aggregator.h | 98 void MockDirectEndFlag(bool isDirectEnd);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_deep_test.cpp | 994 auto sendResultNotifier = [&sendResult](int result, bool isDirectEnd) { in __anonb9037cf22502() argument
995 sendResult.push_back(std::pair<int, bool>(result, isDirectEnd)); in __anonb9037cf22502()
1039 auto sendResultNotifier = [&sendResult](int result, bool isDirectEnd) { in __anonb9037cf22702() argument
1040 sendResult.push_back(std::pair<int, bool>(result, isDirectEnd)); in __anonb9037cf22702()
|
| H A D | distributeddb_communicator_send_receive_test.cpp | 581 auto sendResultNotifier = [&sendResult](int result, bool isDirectEnd) { in __anon922778e00f02() argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_state_machine.cpp | 481 requestSessionId = context_->GetRequestSessionId()](int ret, bool isDirectEnd) { in DoTimeSync() argument
482 SyncTaskContext::CommErrHandlerFunc(ret, context, requestSessionId, isDirectEnd); in DoTimeSync()
514 requestSessionId = context_->GetRequestSessionId()](int ret, bool isDirectEnd) { in DoAbilitySync() argument
515 SyncTaskContext::CommErrHandlerFunc(ret, context, requestSessionId, isDirectEnd); in DoAbilitySync()
|
| H A D | single_ver_data_sync.cpp | 1066 …Handler handler = [this, context, sessionId = message->GetSessionId()](int ret, bool isDirectEnd) { in SendDataPacket() argument
1067 SyncTaskContext::CommErrHandlerFunc(ret, context, sessionId, isDirectEnd); in SendDataPacket()
1458 …Handler handler = [this, context, sessionId = message->GetSessionId()](int ret, bool isDirectEnd) { in SendReSendPacket() argument
1459 SyncTaskContext::CommErrHandlerFunc(ret, context, sessionId, isDirectEnd); in SendReSendPacket()
1917 …Handler handler = [this, context, sessionId = message->GetSessionId()](int ret, bool isDirectEnd) { in SendControlPacket() argument
1918 SyncTaskContext::CommErrHandlerFunc(ret, context, sessionId, isDirectEnd); in SendControlPacket()
|