Home
last modified time | relevance | path

Searched refs:taskToSend (Results 1 – 1 of 1) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dcommunicator_aggregator.cpp944 SendTask taskToSend; in SendOnceData() local
946 int errCode = scheduler_.ScheduleOutSendTask(taskToSend, totalLength); in SendOnceData()
952 uint32_t mtu = adapterHandle_->GetMtuSize(taskToSend.dstTarget); in SendOnceData()
953 errCode = ProtocolProto::SplitFrameIntoPacketsIfNeed(taskToSend.buffer, mtu, piecePackets); in SendOnceData()
956 TaskFinalizer(taskToSend, errCode); in SendOnceData()
963 …std::pair<const uint8_t *, uint32_t> tmpEntry = taskToSend.buffer->GetReadOnlyBytesForEntireBuffer… in SendOnceData()
965 entry.first = tmpEntry.first - taskToSend.buffer->GetExtendHeadLength(); in SendOnceData()
966 entry.second.first = taskToSend.buffer->GetExtendHeadLength(); in SendOnceData()
977 SendPacketsAndDisposeTask(taskToSend, mtu, eachPacket, totalLength); in SendOnceData()