Home
last modified time | relevance | path

Searched refs:seqNum (Results 1 – 25 of 125) sorted by relevance

12345

/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/common/trans_pending_pkt_test/
H A Dtrans_pending_pkt_test.cpp93 int32_t seqNum = 1111; variable
96 item = CreatePendingItem(channelId, seqNum);
111 int32_t seqNum = 1111; variable
117 ret = ProcPendingPacket(channelId, seqNum, type);
121 ret = ProcPendingPacket(channelId, seqNum, type);
134 int32_t seqNum = 222; variable
139 ret = SetPendingPacket(channelId, seqNum, type);
144 ret = SetPendingPacket(channelId, seqNum, type);
179 int32_t seqNum = 0; variable
222 int32_t seqNum = 0; variable
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_frame.c35 FILLP_LOGDBG("item refcnt: %d, seq: %d", refCnt, frameItem->info.seqNum); in FillpFrameItemHold()
42 FILLP_LOGDBG("free frame item of seq: %d", frameItem->info.seqNum); in FillpFrameItemPut()
55 FILLP_LOGERR("alloc frame item failed, seq: %d", frame->seqNum); in FillpFrameItemAlloc()
60 FILLP_LOGDBG("alloc frame item succeeded, seq: %d", frame->seqNum); in FillpFrameItemAlloc()
129 … if (h->curFrame.info.size == 0 || (FILLP_UINT32)info->seqNum != h->curFrame.info.seqNum) { in FillpFrameTxInitItem()
133 h->curFrame.info.seqNum = (FILLP_UINT32)info->seqNum; in FillpFrameTxInitItem()
177 frameOpt->seqNum = FILLP_HTONS((FILLP_UINT16)info->seqNum); in FillpFrameBuildOption()
206 info.seqNum = FILLP_NTOHS(frameOpt->seqNum); in FillpFrameParseOption()
238 frame->info.seqNum = (FILLP_UINT32)item->frame->info.seqNum; in FillpFrameRxNewFrag()
257 frame->curFrag.seqNum = (FILLP_UINT32)item->frame->info.subSeqNum; in FillpFrameRxNewFrag()
[all …]
H A Dfillp_common.c190 if (FillpNumIsbigger(item->seqNum, seqNum)) { in FillpAckItemWaitTklist()
222 if (FillpNumIsbigger(item->seqNum, seqNum)) { in FillpAckUnrecvList()
254 if (FillpNumIsbigger(item->seqNum, seqNum)) { in FillpAckRedunlist()
410 pcb->recv.seqNum = item->seqNum; in FillpUploadRecvBox()
497 pktHead->seqNum = FILLP_HTONL(pcb->recv.seqNum); in FillpSendNack()
608 pcb->recv.seqNum != (item->seqNum - item->dataLen)) { in FillBiggerItem()
647 if (!FillpNumIsbigger(item->seqNum, pcb->recv.seqNum)) { in FillpDataToStack()
663 if (!FillpNumIsbigger(item->seqNum, pcb->recv.seqNum)) { in FillpDataToStack()
675 pcb->recv.seqNum, item->seqNum); in FillpDataToStack()
771 pktHead->seqNum = pcb->recv.seqNum; in FillpBuildAndSendPack()
[all …]
H A Dfillp_input.c161 if (!FillpNumIsbigger(item->seqNum, pcb->recv.seqNum)) { in FillpProcessItemData()
197 item->seqNum = pktHdr->seqNum; in FillpDataInput()
287 FillpNumIsbigger(pktHdr->seqNum, pcb->recv.seqNum)) { in FillpHdlDataInput()
292 FILLP_GET_SOCKET(pcb)->index, pktHdr->seqNum, item->seqNum); in FillpHdlDataInput()
318 if (FillpNumIsbigger(pktHdr->seqNum, pcb->send.seqNum) || in FillpCheckNackSeq()
319 FillpNumIsbigger(pcb->send.seqNum, (pktHdr->seqNum + pcb->send.pktSendCache))) { in FillpCheckNackSeq()
321 FILLP_GET_SOCKET(pcb)->index, pktHdr->seqNum, pcb->send.seqNum); in FillpCheckNackSeq()
344 tmpHead->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpNackInputTrace()
531 tmpHead->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpPackInputSendMsgTrace()
894 tmpHead.seqNum = head->seqNum; in FillpDoInput()
[all …]
H A Dfillp_output.c38 FILLP_GET_SOCKET(pcb)->index, item->seqNum, item->dataLen); in FillpMoveRedundantItemToUnrecvList()
64 sendPcb->seqNum = sendPcb->seqNum + (FILLP_UINT32)item->dataLen; in FillpGetSendItem()
65 item->seqNum = pcb->send.seqNum; in FillpGetSendItem()
72 item->seqNum, (item->seqNum + item->appSendSize - item->dataLen), in FillpGetSendItem()
266 pktHdr->seqNum = FILLP_HTONL(item->seqNum); in FillpBuildDataPkt()
304 if (posItem->seqNum == item->seqNum) { in FillpAddtoListBySeqNum()
306 } else if (FillpNumIsbigger(posItem->seqNum, item->seqNum)) { in FillpAddtoListBySeqNum()
328 FILLP_UINT32 unackIndex = FILLP_UNACKLIST_HASHINDEX(item->seqNum, pcb); in FillpAddToUnackList()
448 pack.lostSeq = pcb->recv.seqNum; in FillpSendAdhocpackToDetectRtt()
501 pack->lostSeq = (item->seqNum - item->dataLen); in FillpSendPack()
[all …]
H A Dfillp_conn.c50 tmpHead1->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpConnReqInputTrace()
419 tmpHead->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpConnReqAckTrace()
455 pcb->peerUniqueId = pktHdr->seqNum; in FillpConnReqAckInput()
716 tempHdr->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpConnConfirmTrace()
827 …ock->index, SYS_ARCH_GET_CUR_TIME_LONGLONG(), pcb->send.seqNum, pcb->send.pktNum, pcb->recv.seqNum, in FillpHandleConnConfirmAckInput()
1016 tmpHeader->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpConnConfirmAckTrace()
1031 pcb->peerUniqueId = tmpHeader->seqNum; in FillpSaveConfirmActToPcb()
1034 pcb->recv.seqNum = tmpHeader->seqNum; in FillpSaveConfirmActToPcb()
1167 tmpHead->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpFinInputTrace()
1370 pktHdr->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpSendConnReqBuild()
[all …]
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/
H A Drs_egl_image_manager.cpp317 void RSEglImageManager::UnMapEglImageFromSurfaceBuffer(int32_t seqNum) in UnMapEglImageFromSurfaceBuffer() argument
322 if (imageCacheSeqs_.count(seqNum) == 0) { in UnMapEglImageFromSurfaceBuffer()
325 if (imageCacheSeqs_[seqNum]) { in UnMapEglImageFromSurfaceBuffer()
326 threadIndex = imageCacheSeqs_[seqNum]->GetThreadIndex(); in UnMapEglImageFromSurfaceBuffer()
329 auto func = [this, seqNum]() { in UnMapEglImageFromSurfaceBuffer()
333 if (imageCacheSeqs_.count(seqNum) == 0) { in UnMapEglImageFromSurfaceBuffer()
336 imageCacheSeq = std::move(imageCacheSeqs_[seqNum]); in UnMapEglImageFromSurfaceBuffer()
339 RS_OPTIONAL_TRACE_NAME_FMT("UnmapEglImage seqNum: %d", seqNum); in UnMapEglImageFromSurfaceBuffer()
347 RSHardwareThread::Instance().PostTask([this, seqNum]() { in UnMapEglImageFromSurfaceBufferForUniRedraw()
349 if (imageCacheSeqs_.count(seqNum) == 0) { in UnMapEglImageFromSurfaceBufferForUniRedraw()
[all …]
H A Drs_vk_image_manager.cpp135 void RSVkImageManager::UnMapVkImageFromSurfaceBuffer(int32_t seqNum) in UnMapVkImageFromSurfaceBuffer() argument
140 if (imageCacheSeqs_.count(seqNum) == 0) { in UnMapVkImageFromSurfaceBuffer()
143 threadIndex = imageCacheSeqs_[seqNum]->GetThreadIndex(); in UnMapVkImageFromSurfaceBuffer()
145 auto func = [this, seqNum, threadIndex]() { in UnMapVkImageFromSurfaceBuffer()
148 if (imageCacheSeqs_.count(seqNum) == 0) { in UnMapVkImageFromSurfaceBuffer()
151 (void)imageCacheSeqs_.erase(seqNum); in UnMapVkImageFromSurfaceBuffer()
/ohos5.0/foundation/graphic/graphic_2d/frameworks/surfaceimage/src/
H A Dsurface_image.cpp99 currentSurfaceImage_ = seqNum; in UpdateSurfaceInfo()
142 uint32_t seqNum = buffer->GetSeqNum(); in UpdateSurfaceImage() local
275 if (seqNum == it->first) { in CheckImageCacheNeedClean()
307 auto iter = imageCacheSeqs_.find(seqNum); in DestroyEGLImageBySeq()
311 imageCacheSeqs_.erase(seqNum); in DestroyEGLImageBySeq()
317 DestroyEGLImageBySeq(seqNum); in NewBufferDestroyEGLImage()
325 uint32_t seqNum = buffer->GetSeqNum(); in UpdateEGLImageAndTexture() local
333 imageCacheSeqs_[seqNum].eglImage_ = eglImage; in UpdateEGLImageAndTexture()
336 auto &image = imageCacheSeqs_[seqNum]; in UpdateEGLImageAndTexture()
340 NewBufferDestroyEGLImage(isNewBuffer, seqNum); in UpdateEGLImageAndTexture()
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/adapter/unittest/
H A Ddsoftbus_crypto_test.cpp354 int32_t seqNum = 1; variable
374 int32_t seqNum = 1; variable
396 int32_t seqNum = 1; variable
416 int32_t seqNum = 1; variable
418 inLen, nullptr, &encryptLen, seqNum);
421 inLen, (unsigned char*)encryptData, nullptr, seqNum);
535 int32_t seqNum = 1; variable
563 int32_t seqNum = 1; variable
595 int32_t seqNum = 1; variable
623 int32_t seqNum = 1; variable
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/transmission/common/src/
H A Dtrans_pending_pkt.c91 static PendingPktInfo *CreatePendingItem(int32_t channelId, int32_t seqNum) in CreatePendingItem() argument
101 item->seq = seqNum; in CreatePendingItem()
131 int32_t AddPendingPacket(int32_t channelId, int32_t seqNum, int32_t type) in AddPendingPacket() argument
144 if (item->seq == seqNum && item->channelId == channelId) { in AddPendingPacket()
151 item = CreatePendingItem(channelId, seqNum); in AddPendingPacket()
182 if (item->seq == seqNum && item->channelId == channelId) { in GetPendingPacket()
212 if (item->seq == seqNum && item->channelId == channelId) { in DelPendingPacketbyChannelId()
225 int32_t ProcPendingPacket(int32_t channelId, int32_t seqNum, int32_t type) in ProcPendingPacket() argument
237 PendingPktInfo *item = GetPendingPacket(channelId, seqNum, type); in ProcPendingPacket()
257 int32_t SetPendingPacket(int32_t channelId, int32_t seqNum, int32_t type) in SetPendingPacket() argument
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/transmission/common/include/
H A Dtrans_pending_pkt.h39 int32_t ProcPendingPacket(int32_t channelId, int32_t seqNum, int32_t type);
40 int32_t SetPendingPacket(int32_t channelId, int32_t seqNum, int32_t type);
42 int32_t AddPendingPacket(int32_t channelId, int32_t seqNum, int32_t type);
43 void DelPendingPacketbyChannelId(int32_t channelId, int32_t seqNum, int32_t type);
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_notifier_stub.cpp65 uint32_t seqNum = 0; in OnCompleteInner() local
67 if (!ITypesUtil::Unmarshal(data, seqNum, result)) { in OnCompleteInner()
71 return OnComplete(seqNum, std::move(result)); in OnCompleteInner()
74 int32_t RdbNotifierStub::OnComplete(uint32_t seqNum, Details &&result) in OnComplete() argument
77 completeNotifier_(seqNum, std::move(result)); in OnComplete()
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/common/mock/src/
H A Dtrans_common_mock.cpp62 unsigned char *encryptData, uint32_t *encryptLen, int32_t seqNum) in SoftBusEncryptDataWithSeq() argument
64 …onInterface()->SoftBusEncryptDataWithSeq(cipherKey, input, inLen, encryptData, encryptLen, seqNum); in SoftBusEncryptDataWithSeq()
68 unsigned char *decryptData, uint32_t *decryptLen, int32_t seqNum) in SoftBusDecryptDataWithSeq() argument
70 …onInterface()->SoftBusDecryptDataWithSeq(cipherKey, input, inLen, decryptData, decryptLen, seqNum); in SoftBusDecryptDataWithSeq()
/ohos5.0/base/security/access_token/services/privacymanager/src/seccomp/
H A Dprivacy_sec_comp_enhance_agent.cpp131 enhance.seqNum = enhanceData.seqNum; in RegisterSecCompEnhance()
141 int32_t PrivacySecCompEnhanceAgent::UpdateSecCompEnhance(int32_t pid, uint32_t seqNum) in UpdateSecCompEnhance() argument
147 iter->seqNum = seqNum; in UpdateSecCompEnhance()
/ohos5.0/foundation/graphic/graphic_2d/frameworks/surfaceimage/include/
H A Dsurface_image.h88 …void UpdateSurfaceInfo(uint32_t seqNum, sptr<SurfaceBuffer> buffer, const sptr<SyncFence> &acquire…
90 void CheckImageCacheNeedClean(uint32_t seqNum);
93 void NewBufferDestroyEGLImage(bool isNewBuffer, uint32_t seqNum);
94 void DestroyEGLImageBySeq(uint32_t seqNum);
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_common.h42 #define FILLP_UNACKLIST_HASHINDEX(seqNum, pcb) \ argument
43 (((seqNum) / FILLP_UNACK_HASH_MOD) & (pcb)->send.unackList.hashModSize)
51 IGNORE_OVERFLOW void FillpAckSendPcb(struct FillpPcb *pcb, FILLP_INT seqNum);
H A Dfillp_frame.h32 FILLP_UINT16 seqNum; member
44 FILLP_UINT32 seqNum; /* fragment sequence number of the frame */ member
48 FILLP_UINT32 seqNum; member
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_notifier_proxy.cpp70 void KVDBNotifierProxy::SyncCompleted(uint64_t seqNum, ProgressDetail &&detail) in SyncCompleted() argument
74 …IPC_SEND(static_cast<uint32_t>(KVDBNotifierCode::TRANS_CLOUD_SYNC_COMPLETED), reply, seqNum, detai… in SyncCompleted()
76 ZLOGE("status:%{public}d, sequenceId:%{public}" PRIu64, status, seqNum); in SyncCompleted()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_notifier_proxy.cpp31 int32_t RdbNotifierProxy::OnComplete(uint32_t seqNum, Details &&result) in OnComplete() argument
38 if (!ITypesUtil::Marshal(data, seqNum, result)) { in OnComplete()
46 ZLOGE("seqNum:%{public}u, send request failed", seqNum); in OnComplete()
/ohos5.0/foundation/communication/ipc/ipc/native/src/mock/include/
H A Ddbinder_base_invoker_interface.h35 uint64_t seqNum = GetUniqueSeqNumber(cmd); in WriteTransaction() local
36 if (seqNum == 0) { in WriteTransaction()
42 seqNumber = seqNum; in WriteTransaction()
44 if (ProcessRawData(sessionObject, data, seqNum) != true) { in WriteTransaction()
50 ProcessNormalData(sessionObject, data, handle, socketId, seqNum, cmd, code, flags, status); in WriteTransaction()
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/
H A Dtrans_tcp_direct_test.cpp538 int32_t seqNum = BUF_LEN; variable
539 int32_t ret = TransTdcEncryptWithSeq(nullptr, seqNum, in, inLen, out, &outLen);
542 ret = TransTdcEncryptWithSeq(g_sessionkey, seqNum, nullptr, inLen, out, &outLen);
545 ret = TransTdcEncryptWithSeq(g_sessionkey, seqNum, in, inLen, out, &outLen);
560 int32_t seqNum = 1; variable
567 ret = ProcPendingPacket(channelId, seqNum, type);
677 int32_t seqNum = 1; variable
681 int32_t ret = TransTdcProcessDataByFlag(flag, seqNum, nullptr, plain, plainLen);
863 int32_t seqNum = 1; variable
866 ret = TransTdcProcessDataByFlag(FLAG_BYTES, seqNum, channel, plain, (uint32_t)strlen(plain));
[all …]
/ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/
H A Dstream_packet_header.h63 uint16_t seqNum; member
267 commonHeader_.seqNum = streamFrameInfo->seqNum; in StreamPacketHeader()
291 common |= commonHeader_.seqNum << WORD_SIZE; in Packetize()
303 commonHeader_.seqNum = seq >> WORD_SIZE; in Depacketize()
357 return commonHeader_.seqNum; in GetSeqNum()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/
H A Ddsched_softbus_session.cpp187 ret = memcpy_s(&headerPara.seqNum, sizeof(headerPara.seqNum), ptr, len); in ReadTlvToHeader()
232 nowSeq_ = headerPara.seqNum; in AssembleFrag()
281 if (nowSeq_ != headerPara.seqNum) { in CheckUnPackBuffer()
283 … "%{public}s.", nowSeq_, headerPara.seqNum, sessionId_, GetAnonymStr(peerDeviceId_).c_str()); in CheckUnPackBuffer()
442 TlvItem seqNum = { TLV_TYPE_SEQ_NUM, sizeof(uint32_t), headPara.seqNum }; in MakeFragDataHeader() local
443 WriteTlvToBuffer(seqNum, &header[i], capacity); in MakeFragDataHeader()
/ohos5.0/foundation/distributedhardware/distributed_camera/services/channel/src/
H A Ddcamera_softbus_session.cpp196 nowSeq_ = headerPara.seqNum; in AssembleFrag()
245 if (nowSeq_ != headerPara.seqNum) { in CheckUnPackBuffer()
247 "%{public}s peerSess: %{public}s", nowSeq_, headerPara.seqNum, mySessionName_.c_str(), in CheckUnPackBuffer()
291 headerPara.seqNum = U32Get(ptrPacket + BINARY_HEADER_SEQNUM_OFFSET); in GetFragDataLen()
407 header[i++] = (headPara.seqNum & UINT32_SHIFT_MASK_24) >> DCAMERA_SHIFT_24; in MakeFragDataHeader()
408 header[i++] = (headPara.seqNum & UINT32_SHIFT_MASK_16) >> DCAMERA_SHIFT_16; in MakeFragDataHeader()
409 header[i++] = (headPara.seqNum & UINT32_SHIFT_MASK_8) >> DCAMERA_SHIFT_8; in MakeFragDataHeader()
410 header[i++] = (headPara.seqNum & UINT32_SHIFT_MASK_0); in MakeFragDataHeader()

12345