diff --git a/frameworks/libs/distributeddb/communicator/src/communicator_aggregator.cpp b/frameworks/libs/distributeddb/communicator/src/communicator_aggregator.cpp index 110680e2f82323966cddbfd7cfbe1fcf6b7f8211..7f249de9ebffc062d5c837acab2858e6062811e8 100644 --- a/frameworks/libs/distributeddb/communicator/src/communicator_aggregator.cpp +++ b/frameworks/libs/distributeddb/communicator/src/communicator_aggregator.cpp @@ -773,9 +773,9 @@ int CommunicatorAggregator::RegCallbackToAdapter() LOGI("[CommAggr] Send able dev=%.3s, softBusErrCode=%d", target.c_str(), softBusErrCode); if (softBusErrCode == E_OK) { (void)IncreaseSendSequenceId(target); + OnSendable(target); } scheduler_.SetSoftBusErrCode(target, softBusErrCode); - OnSendable(target); }, [this]() { RefObject::DecObjRef(this); }); if (errCode != E_OK) {