| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator_aggregator.cpp | 169 const Message *inMsg, const OnSendEnd &onEnd) in DispatchMessage() argument
180 return CallSendEnd(-E_PERIPHERAL_INTERFACE_FAIL, onEnd); in DispatchMessage()
185 DispatchMessageInner(srcTarget, dstTarget, inMsg, onEnd); in DispatchMessage()
189 const Message *inMsg, const OnSendEnd &onEnd) in DispatchMessageInner() argument
200 return CallSendEnd(-E_PERIPHERAL_INTERFACE_FAIL, onEnd); in DispatchMessageInner()
222 CallSendEnd(E_OK, onEnd); in DispatchMessageInner()
227 CallSendEnd(-E_NOT_FOUND, onEnd); in DispatchMessageInner()
256 void VirtualCommunicatorAggregator::CallSendEnd(int errCode, const OnSendEnd &onEnd) in CallSendEnd() argument
261 if (onEnd) { in CallSendEnd()
262 (void)RuntimeContext::GetInstance()->ScheduleTask([errCode, onEnd, this]() { in CallSendEnd()
[all …]
|
| H A D | virtual_communicator_aggregator.h | 55 const OnSendEnd &onEnd);
104 void CallSendEnd(int errCode, const OnSendEnd &onEnd);
107 const OnSendEnd &onEnd);
|
| H A D | virtual_communicator.cpp | 54 const OnSendEnd &onEnd) in SendMessage() argument
72 communicatorAggregator_->DispatchMessage(deviceId_, dstTarget, inMsg, onEnd); in SendMessage()
80 communicatorAggregator_->DispatchMessage(deviceId_, dstTarget, message, onEnd); in SendMessage()
|
| H A D | virtual_time_sync_communicator.h | 62 const OnSendEnd &onEnd) override;
|
| H A D | virtual_time_sync_communicator.cpp | 92 const SendConfig &config, const OnSendEnd &onEnd) in SendMessage() argument
|
| H A D | virtual_communicator.h | 60 const OnSendEnd &onEnd) override;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | communicator_proxy.cpp | 204 const OnSendEnd &onEnd) in SendMessage() argument
216 int errCode = targetCommunicator->SendMessage(dstTarget, inMsg, config, onEnd); in SendMessage()
222 return mainComm_->SendMessage(dstTarget, inMsg, config, onEnd); in SendMessage()
|
| H A D | communicator_proxy.h | 47 const OnSendEnd &onEnd) override;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_aggregator.cpp | 279 void DoOnSendEndByTaskIfNeed(const OnSendEnd &onEnd, int result) in DoOnSendEndByTaskIfNeed() argument
281 if (onEnd) { // LCOV_EXCL_BR_LINE in DoOnSendEndByTaskIfNeed()
282 TaskAction onSendEndTask = [onEnd, result]() { in DoOnSendEndByTaskIfNeed()
284 onEnd(result, true); in DoOnSendEndByTaskIfNeed()
296 FrameType inType, const TaskConfig &inConfig, const OnSendEnd &onEnd) in ScheduleSendTask() argument
305 DoOnSendEndByTaskIfNeed(onEnd, -E_PERIPHERAL_INTERFACE_FAIL); in ScheduleSendTask()
324 SendTask task{inBuff, dstTarget, onEnd, info.frameId, true}; in ScheduleSendTask()
453 if (inTask.onEnd) { in TaskFinalizer()
455 inTask.onEnd(result, true); in TaskFinalizer()
|
| H A D | send_task_scheduler.cpp | 307 if (sendTask.onEnd) { in InvalidSendTask()
309 sendTask.onEnd(softBusErrCodeMap_[target], false); in InvalidSendTask()
310 sendTask.onEnd = nullptr; in InvalidSendTask()
|
| H A D | communicator.cpp | 104 const OnSendEnd &onEnd) in SendMessage() argument
134 …ggrHandle_->ScheduleSendTask(dstTarget, buffer, FrameType::APPLICATION_MESSAGE, taskConfig, onEnd); in SendMessage()
|
| H A D | communicator.h | 56 const OnSendEnd &onEnd) override;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | icommunicator.h | 84 …const OnSendEnd &onEnd) = 0; // HW Code Regulation do not allow to use default parameters on virtu…
|
| H A D | send_task_scheduler.h | 39 OnSendEnd onEnd; member
|
| H A D | communicator_aggregator.h | 88 const TaskConfig &inConfig, const OnSendEnd &onEnd = nullptr);
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/interfaces/native/node/ |
| H A D | node_scroll_modifier.cpp | 927 auto onEnd = reinterpret_cast<std::function<void()>*>(callback); in SetScrollOnScrollEnd() local
928 ScrollModelNG::SetOnScrollStop(frameNode, std::move(*onEnd)); in SetScrollOnScrollEnd()
946 auto onEnd = reinterpret_cast<std::function<void()>*>(callback); in SetScrollOnScrollStop() local
947 ScrollModelNG::SetOnScrollStop(frameNode, std::move(*onEnd)); in SetScrollOnScrollStop()
|