Home
last modified time | relevance | path

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

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/
H A Dnstackx_dfile_transfer.c273 dFileTrans->msgReceiver(dFileTrans, msgType, &transMsg); in NotifyTransMsg()
351 dFileTrans->mtu, &dFileTrans->sendBufferLength); in SendFileHeader()
472 dFileTrans->timeout = dFileTrans->config.maxRtt; in WaitForFileHeaderConfirmPrepare()
521 dFileTrans->transId, dFileTrans->lostAckCnt, in SendFileDataOngoing()
575 EncodeFileTransferDoneAckFrame(dFileTrans->sendBuffer, dFileTrans->mtu, dFileTrans->transId, in SendFileTransferDoneAckFrame()
688 dFileTrans->timeout = dFileTrans->config.maxRtt; in ReceiveFileHeaderPrepare()
792 dFileTrans->sendBuffer, dFileTrans->mtu, &dFileTrans->sendBufferLength); in SendFileHeaderConfirm()
871 … dFileTrans->transId, elapseTime, dFileTrans->idleTimeoutCnt, dFileTrans->lastFileDataRecvFileId, in ReceiverIdleTimeout()
992 dFileTrans->timeout = dFileTrans->config.maxRtt; in WaitForFileTransferDoneAckPrepare()
1072 … dFileTrans->transId, GetReceiveStateMessage(dFileTrans->recvState), dFileTrans->errorCode); in SetReceiveState()
[all …]
H A Dnstackx_dfile_retransmission.c24 static void SendBackPressureFrame(DFileTrans *dFileTrans) in SendBackPressureFrame() argument
26 PeerInfo *peerInfo = (PeerInfo *)(dFileTrans->context); in SendBackPressureFrame()
34 if (!CapsRecvFeedback(dFileTrans->session)) { in SendBackPressureFrame()
39 dFileTrans->backPressureBypassCnt++; in SendBackPressureFrame()
56 dFileTrans->fileManager->recvListOverIo = 1; in SendBackPressureFrame()
58 dFileTrans->fileManager->recvListOverIo = 0; in SendBackPressureFrame()
66 if (dFileTrans->fileManager->recvListOverIo == 1) { in SendBackPressureFrame()
69 dFileTrans->fileManager->iowCount); in SendBackPressureFrame()
71 if (dFileTrans->fileManager->recvListOverIo == 1) { in SendBackPressureFrame()
72 ClockGetTime(CLOCK_MONOTONIC, &dFileTrans->ts); in SendBackPressureFrame()
[all …]
H A Dnstackx_dfile_session.c225 if (session == NULL || dFileTrans == NULL || msg == NULL || in UpdateMsgProcessInfo()
231 msg->transferUpdate.transId = dFileTrans->transId; in UpdateMsgProcessInfo()
234 totalBytes = DFileTransGetTotalBytes(dFileTrans); in UpdateMsgProcessInfo()
250 if (dFileTrans->fileList->vtransFlag) { in UpdateMsgProcessInfo()
314 uint8_t flag = dFileTrans->fileList->smallFlag; in CheckTransDone()
321 ListRemoveNode(&dFileTrans->list); in CheckTransDone()
323 DFileTransDestroy(dFileTrans); in CheckTransDone()
339 PeerInfo *peerInfo = dFileTrans->context; in DTransMsgReceiver()
342 UpdateMsgProcessInfo(session, dFileTrans, msgType, msg); in DTransMsgReceiver()
369 ProcessSessionTrans(session, dFileTrans->transId); in DTransMsgReceiver()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/
H A Dnstackx_dfile_transfer.h283 int32_t HandleDFileFrame(DFileTrans *dFileTrans, DFileFrame *dFileFrame);
284 void DFileTransProcess(DFileTrans *dFileTrans);
285 int64_t DFileTransGetTimeout(DFileTrans *dFileTrans);
286 int32_t DFileTransSetMtu(DFileTrans *dFileTrans, uint16_t mtu);
289 void DFileTransDestroy(DFileTrans *dFileTrans);
290 void DFileTransDestroyInner(DFileTrans *dFileTrans);
291 uint64_t DFileTransGetTotalBytes(const DFileTrans *dFileTrans);
293 DFileTrans *dFileTrans);
295 DFileTrans *dFileTrans);
296 int32_t SendFrame(DFileTrans *dFileTrans, uint8_t *frame, size_t frameLength, DFileSendState *nextS…
[all …]
H A Dnstackx_dfile_retransmission.h34 void SendFileDataAck(DFileTrans *dFileTrans, DFileReceiveState *nextState);