Home
last modified time | relevance | path

Searched refs:seqNum (Results 1 - 25 of 94) sorted by relevance

1234

/foundation/communication/dsoftbus/tests/core/transmission/common/trans_pending_pkt_test/
H A Dtrans_pending_pkt_test.cpp93 int32_t seqNum = 1111; in HWTEST_F() local
96 item = CreatePendingItem(channelId, seqNum); in HWTEST_F()
111 int32_t seqNum = 1111; in HWTEST_F() local
114 int32_t ret = ProcPendingPacket(channelId, seqNum, type); in HWTEST_F()
117 ret = ProcPendingPacket(channelId, seqNum, type); in HWTEST_F()
121 ret = ProcPendingPacket(channelId, seqNum, type); in HWTEST_F()
134 int32_t seqNum = 222; in HWTEST_F() local
136 int32_t ret = SetPendingPacket(channelId, seqNum, type); in HWTEST_F()
139 ret = SetPendingPacket(channelId, seqNum, type); in HWTEST_F()
144 ret = SetPendingPacket(channelId, seqNum, typ in HWTEST_F()
179 int32_t seqNum = 0; HWTEST_F() local
222 int32_t seqNum = 0; HWTEST_F() local
244 int32_t seqNum = 0; HWTEST_F() local
[all...]
/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()
130 FILLP_LOGDBG("start sending a new frame, seq: %d", info->seqNum); in FillpFrameTxInitItem()
133 h->curFrame.info.seqNum = (FILLP_UINT32)info->seqNum; in FillpFrameTxInitItem()
143 FILLP_LOGDBG("frame %d end, total size: %u", info->seqNum, in FillpFrameTxInitItem()
[all...]
H A Dfillp_input.c161 if (!FillpNumIsbigger(item->seqNum, pcb->recv.seqNum)) { in FillpProcessItemData()
197 item->seqNum = pktHdr->seqNum; in FillpDataInput()
200 if (FillpNumIsbigger(item->seqNum, (pcb->recv.seqNum + pcb->recv.pktRecvCache + privRecvCacheSize))) { in FillpDataInput()
202 FILLP_GET_SOCKET(pcb)->index, item->seqNum, in FillpDataInput()
203 (pcb->recv.seqNum + pcb->recv.pktRecvCache + privRecvCacheSize)); in FillpDataInput()
240 FILLP_LOGINF("first flag: fillpSockId:%d, seqNum:%u, flag: 0x%4x", in ProcessPcbItem()
241 FILLP_GET_SOCKET(pcb)->index, pktHdr->seqNum, pktHd in ProcessPcbItem()
[all...]
H A Dfillp_common.c38 FILLP_GET_SOCKET(pcb)->index, item->seqNum, item->dataLen); in InsertUnrecvListFail()
85 if (FillpNumIsbigger(item->seqNum, lostSeq) == FILLP_TRUE) { in FillpMoveOneNode()
173 FILLP_LOGINF("cost between send-recv: last seq:%u, cost:%lld, size:%u", item->seqNum, in LogForMsgRTT()
178 static void FillpAckItemWaitTklist(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckItemWaitTklist() argument
183 if (!FillpNumIsbigger(seqNum, pcb->send.ackSeqNum)) { in FillpAckItemWaitTklist()
190 if (FillpNumIsbigger(item->seqNum, seqNum)) { in FillpAckItemWaitTklist()
207 static int FillpAckUnrecvList(struct FillpPcb *pcb, FILLP_UINT32 seqNum) in FillpAckUnrecvList() argument
215 if (!FillpNumIsbigger(seqNum, pcb->send.ackSeqNum)) { in FillpAckUnrecvList()
222 if (FillpNumIsbigger(item->seqNum, seqNu in FillpAckUnrecvList()
242 FillpAckRedunlist(struct FillpPcb *pcb, FILLP_UINT32 seqNum) FillpAckRedunlist() argument
[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()
75 FILLP_LOGINF("send expand: last seq:%u, cost:%lld, size:%u", item->seqNum, in FillpGetSendItem()
110 FILLP_LOGDBG("fillp_sock_id:%d, appLimited triggle, pktNum:%u, seqNum:%u, sc:%u, " in FillpDoneSendAllData()
113 FILLP_GET_SOCKET(pcb)->index, item->pktNum, item->seqNum, ite in FillpDoneSendAllData()
[all...]
H A Dfillp_conn.c50 tmpHead1->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpConnReqInputTrace()
67 if ((pcb->recv.seqNum == pcb->recv.seqStartNum) && (pcb->send.maxAckNumFromReceiver == in FillpConnReqStateCheck()
419 tmpHead->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpConnReqAckTrace()
455 pcb->peerUniqueId = pktHdr->seqNum; in FillpConnReqAckInput()
527 newConn->pcb->fpcb.send.seqNum = confirm->cookieContent.localMessageSeqNumber; in FillpInitNewPcbByConfirm()
537 newConn->pcb->fpcb.recv.seqNum = confirm->cookieContent.remoteMessageSeqNumber; in FillpInitNewPcbByConfirm()
716 tempHdr->seqNum = FILLP_HTONL(pktHdr->seqNum); in FillpConnConfirmTrace()
[all...]
/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);
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/
H A Drs_egl_image_manager.cpp289 RS_OPTIONAL_TRACE_NAME_FMT("MapEglImage seqNum: %d", bufferId); in MapEglImageFromSurfaceBuffer()
317 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()
345 UnMapEglImageFromSurfaceBufferForUniRedraw(int32_t seqNum) UnMapEglImageFromSurfaceBufferForUniRedraw() argument
[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()
H A Drs_egl_image_manager.h80 void UnMapEglImageFromSurfaceBuffer(int32_t seqNum);
81 void UnMapEglImageFromSurfaceBufferForUniRedraw(int32_t seqNum);
/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()
163 static PendingPktInfo *GetPendingPacket(int32_t channelId, int32_t seqNum, int32_t type) in GetPendingPacket() argument
182 if (item->seq == seqNum && item->channelId == channelId) { in GetPendingPacket()
192 void DelPendingPacketbyChannelId(int32_t channelId, int32_t seqNum, int32_t type) in DelPendingPacketbyChannelId() argument
212 if (item->seq == seqNum && item->channelId == channelId) { in DelPendingPacketbyChannelId()
225 int32_t ProcPendingPacket(int32_t channelId, int32_t seqNum, int32_ argument
257 SetPendingPacket(int32_t channelId, int32_t seqNum, int32_t type) SetPendingPacket() argument
[all...]
/foundation/graphic/graphic_2d/frameworks/surfaceimage/src/
H A Dsurface_image.cpp86 void SurfaceImage::UpdateSurfaceInfo(uint32_t seqNum, sptr<SurfaceBuffer> buffer, const sptr<SyncFence> &acquireFence, in UpdateSurfaceInfo() argument
98 currentSurfaceImage_ = seqNum; in UpdateSurfaceInfo()
141 uint32_t seqNum = buffer->GetSeqNum(); in UpdateSurfaceImage() local
142 UpdateSurfaceInfo(seqNum, buffer, acquireFence, timestamp, damage); in UpdateSurfaceImage()
270 void SurfaceImage::CheckImageCacheNeedClean(uint32_t seqNum) in CheckImageCacheNeedClean() argument
274 if (seqNum == it->first) { in CheckImageCacheNeedClean()
304 void SurfaceImage::DestroyEGLImageBySeq(uint32_t seqNum) in DestroyEGLImageBySeq() argument
306 auto iter = imageCacheSeqs_.find(seqNum); in DestroyEGLImageBySeq()
309 imageCacheSeqs_.erase(seqNum); in DestroyEGLImageBySeq()
313 void SurfaceImage::NewBufferDestroyEGLImage(bool isNewBuffer, uint32_t seqNum) in NewBufferDestroyEGLImage() argument
324 uint32_t seqNum = buffer->GetSeqNum(); UpdateEGLImageAndTexture() local
[all...]
/foundation/communication/dsoftbus/tests/adapter/unittest/
H A Ddsoftbus_crypto_test.cpp354 int32_t seqNum = 1; in HWTEST_F() local
356 inLen, (unsigned char*)encryptData, &encryptLen, seqNum); in HWTEST_F()
374 int32_t seqNum = 1; in HWTEST_F() local
376 inLen, (unsigned char*)encryptData, &encryptLen, seqNum); in HWTEST_F()
378 ret = SoftBusEncryptDataWithSeq(&cipherKey, nullptr, inLen, (unsigned char*)encryptData, &encryptLen, seqNum); in HWTEST_F()
396 int32_t seqNum = 1; in HWTEST_F() local
398 inLen, (unsigned char*)encryptData, &encryptLen, seqNum); in HWTEST_F()
416 int32_t seqNum = 1; in HWTEST_F() local
418 inLen, nullptr, &encryptLen, seqNum); in HWTEST_F()
421 inLen, (unsigned char*)encryptData, nullptr, seqNum); in HWTEST_F()
535 int32_t seqNum = 1; HWTEST_F() local
563 int32_t seqNum = 1; HWTEST_F() local
595 int32_t seqNum = 1; HWTEST_F() local
623 int32_t seqNum = 1; HWTEST_F() local
[all...]
/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()
64 return GetCommonInterface()->SoftBusEncryptDataWithSeq(cipherKey, input, inLen, encryptData, encryptLen, seqNum); in SoftBusEncryptDataWithSeq()
68 unsigned char *decryptData, uint32_t *decryptLen, int32_t seqNum) in SoftBusDecryptDataWithSeq()
70 return GetCommonInterface()->SoftBusDecryptDataWithSeq(cipherKey, input, inLen, decryptData, decryptLen, seqNum); in SoftBusDecryptDataWithSeq()
61 SoftBusEncryptDataWithSeq(AesGcmCipherKey *cipherKey, const unsigned char *input, uint32_t inLen, unsigned char *encryptData, uint32_t *encryptLen, int32_t seqNum) SoftBusEncryptDataWithSeq() argument
67 SoftBusDecryptDataWithSeq(AesGcmCipherKey *cipherKey, const unsigned char *input, uint32_t inLen, unsigned char *decryptData, uint32_t *decryptLen, int32_t seqNum) SoftBusDecryptDataWithSeq() argument
/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()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_common.h42 #define FILLP_UNACKLIST_HASHINDEX(seqNum, pcb) \
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
/foundation/graphic/graphic_2d/frameworks/surfaceimage/include/
H A Dsurface_image.h88 void UpdateSurfaceInfo(uint32_t seqNum, sptr<SurfaceBuffer> buffer, const sptr<SyncFence> &acquireFence,
90 void CheckImageCacheNeedClean(uint32_t seqNum);
93 void NewBufferDestroyEGLImage(bool isNewBuffer, uint32_t seqNum);
94 void DestroyEGLImageBySeq(uint32_t seqNum);
/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, detail); in SyncCompleted()
76 ZLOGE("status:%{public}d, sequenceId:%{public}" PRIu64, status, seqNum); in SyncCompleted()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_notifier_proxy.cpp28 int32_t RdbNotifierProxy::OnComplete(uint32_t seqNum, Details &&result) in OnComplete() argument
35 if (!ITypesUtil::Marshal(data, seqNum, result)) { in OnComplete()
43 ZLOGE("seqNum:%{public}u, send request failed", seqNum); in OnComplete()
/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()
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/
H A Dtrans_tcp_direct_test.cpp538 int32_t seqNum = BUF_LEN; in HWTEST_F() local
539 int32_t ret = TransTdcEncryptWithSeq(nullptr, seqNum, in, inLen, out, &outLen); in HWTEST_F()
542 ret = TransTdcEncryptWithSeq(g_sessionkey, seqNum, nullptr, inLen, out, &outLen); in HWTEST_F()
545 ret = TransTdcEncryptWithSeq(g_sessionkey, seqNum, in, inLen, out, &outLen); in HWTEST_F()
560 int32_t seqNum = 1; in HWTEST_F() local
567 ret = ProcPendingPacket(channelId, seqNum, type); in HWTEST_F()
677 int32_t seqNum = 1; in HWTEST_F() local
681 int32_t ret = TransTdcProcessDataByFlag(flag, seqNum, nullptr, plain, plainLen); in HWTEST_F()
863 int32_t seqNum = 1; in HWTEST_F() local
866 ret = TransTdcProcessDataByFlag(FLAG_BYTES, seqNum, channe in HWTEST_F()
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/common/mock/include/
H A Dtrans_common_mock.h40 unsigned char *encryptData, uint32_t *encryptLen, int32_t seqNum) = 0;
44 unsigned char *decryptData, uint32_t *decryptLen, int32_t seqNum) = 0;
/foundation/communication/dsoftbus/adapter/common/include/
H A Dsoftbus_adapter_crypto.h81 unsigned char *encryptData, uint32_t *encryptLen, int32_t seqNum);
87 unsigned char *encryptData, uint32_t *encryptLen, int32_t seqNum);
/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()
37 ZLOGE(LOG_LABEL, "seqNum invalid, listenFd:%{public}d handle:%{public}d", socketId, handle); in WriteTransaction()
41 /* save seqNum for wait thread */ 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()

Completed in 14 milliseconds

1234