Home
last modified time | relevance | path

Searched refs:send (Results 1 - 25 of 62) sorted by relevance

123

/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_common.c31 (void)SYS_ARCH_SEM_POST(&pcb->send.sendSem); in FillpFreeItemAndEvent()
76 struct FillpHashLlist *unackList = &pcb->send.unackList; in FillpMoveOneNode()
79 cmpGap = (FILLP_LLONG)pcb->send.retramistRto; in FillpMoveOneNode()
100 pcb->send.inSendBytes -= (FILLP_ULLONG)item->dataLen; in FillpMoveOneNode()
103 FillpDelPktSeqHashItem(item->pktNum, &pcb->send.pktSeqMap); in FillpMoveOneNode()
104 if (SkipListInsert(&pcb->send.unrecvList, (void *)item, &item->skipListNode, FILLP_TRUE) != in FillpMoveOneNode()
112 pcb->send.unrecvRedunListBytes += item->dataLen; in FillpMoveOneNode()
146 unackList = &pcb->send.unackList; in FillpMoveUnackToUnrecvAll()
165 if (pcb->send.unrecvList.nodeNum > 0) { in FillpMoveUnackToUnrecvAll()
173 FILLP_LOGINF("cost between send in LogForMsgRTT()
[all...]
H A Dfillp_flow_control.c126 struct FillpHashLlist *mapList = &pcb->send.pktSeqMap; in FillpAppLimitedStatus()
166 struct FillpFlowControl *flowControl = &pcb->send.flowControl; in FillpCalSendInterval()
202 FILLP_UINT32 unackNum = pcb->send.unackList.count; in FillpFcTailProtected()
204 pcb->send.unrecvList.nodeNum + pcb->send.itemWaitTokenLists.nodeNum + pcb->send.redunList.nodeNum; in FillpFcTailProtected()
207 unsendSize += pcb->send.unSendList.size; in FillpFcTailProtected()
210 deltaUs = pcb->pcbInst->curTime - pcb->send.lastSendTs; in FillpFcTailProtected()
213 tailProtect = &pcb->send.tailProtect; in FillpFcTailProtected()
222 pcb->send in FillpFcTailProtected()
[all...]
H A Dfillp_flow_control_alg0.c32 struct FillpFlowControl *flowControl = &pcb->send.flowControl; in FillpAlg0CalSendInterval()
55 alg->flowControl = &pcb->send.flowControl; in FillpAlg0FlowControlInit()
101 pcb->send.flowControl.fcAlg = alg; in FillpAlg0FcInit()
105 pcb->send.tailProtect.judgeThreshold = FILLP_ONE_FIFTH_OF_RTT; in FillpAlg0FcInit()
106 pcb->send.retramistRto = (FILLP_ULLONG)pcb->rtt; in FillpAlg0FcInit()
107 pcb->send.flowControl.sendRate = FILLP_FC0_DEFAULT_RATE; in FillpAlg0FcInit()
120 struct FillpFlowControlAlg0 *alg = (struct FillpFlowControlAlg0 *)pcb->send.flowControl.fcAlg; in FillpAlg0FcDeinit()
122 if (pcb->send.flowControl.fcAlg == FILLP_NULL_PTR) { in FillpAlg0FcDeinit()
132 pcb->send.flowControl.fcAlg = FILLP_NULL_PTR; in FillpAlg0FcDeinit()
145 struct FillpFlowControlAlg0 *alg = (struct FillpFlowControlAlg0 *)pcb->send in FillpAlg0CalMaxPackRcvInterval()
[all...]
H A Dfillp_input.c201 FILLP_LOGWAR("fillp_sock_id:%d, seqnum received = %u from the peer is not in the send window range = %u", in FillpDataInput()
318 if (FillpNumIsbigger(pktHdr->seqNum, pcb->send.seqNum) || in FillpCheckNackSeq()
319 FillpNumIsbigger(pcb->send.seqNum, (pktHdr->seqNum + pcb->send.pktSendCache))) { in FillpCheckNackSeq()
320 FILLP_LOGDTL("fillp_sock_id:%d Invalid NACK sequence number. seqNum = %u, pcb->send.seqNum = %u", in FillpCheckNackSeq()
321 FILLP_GET_SOCKET(pcb)->index, pktHdr->seqNum, pcb->send.seqNum); in FillpCheckNackSeq()
326 if ((pcb->send.nackPktStartNum == seqPktNum->beginPktNum) && in FillpCheckNackSeq()
327 (pcb->send.nackPktEndNum == seqPktNum->endPktNum)) { in FillpCheckNackSeq()
384 struct FillpSendPcb *sendPcb = &pcb->send; in ProtectLongLoopRun()
404 if (pcb->send in ProtectLongLoopRun()
[all...]
H A Dfillp_output.c33 struct FillpSendPcb *sendPcb = &pcb->send; in FillpMoveRedundantItemToUnrecvList()
43 (void)SYS_ARCH_SEM_POST(&pcb->send.send_sem); in FillpMoveRedundantItemToUnrecvList()
65 item->seqNum = pcb->send.seqNum; in FillpGetSendItem()
75 FILLP_LOGINF("send expand: last seq:%u, cost:%lld, size:%u", item->seqNum, in FillpGetSendItem()
99 FILLP_LOGDBG("Ask more buffer for send success, fillp_sock_id:%d", sock->index); in FillpIsAskMoreBuf()
114 pcb->send.unSendList.size, pcb->send.unackList.count, pcb->send.unrecvList.nodeNum, in FillpDoneSendAllData()
115 pcb->send.redunList.nodeNum, pcb->send in FillpDoneSendAllData()
[all...]
H A Dfillp_timer.c22 #define FILLP_UNLIMIT_SEND_INTERVAL 100 /* try to send every 100us */
182 struct FillpFlowControl *flowControl = &pcb->send.flowControl; in FillpSendTimerCb()
197 if (pcb->send.flowControl.sendInterval < pcb->pcbInst->minSendInterval) { in FillpEnableSendTimer()
198 pcb->pcbInst->minSendInterval = pcb->send.flowControl.sendInterval; in FillpEnableSendTimer()
203 FILLP_LOGDBG("enable, pcb->send.flowControl.sendTime:%lld, interval:%u", pcb->send.flowControl.sendTime, in FillpEnableSendTimer()
205 if (pcb->send.flowControl.sendTime == 0) { in FillpEnableSendTimer()
206 pcb->send.flowControl.remainBytes = 0; in FillpEnableSendTimer()
207 pcb->send.flowControl.sendTime = pcb->pcbInst->curTime; in FillpEnableSendTimer()
210 pcb->send in FillpEnableSendTimer()
[all...]
H A Dfillp_conn.c67 if ((pcb->recv.seqNum == pcb->recv.seqStartNum) && (pcb->send.maxAckNumFromReceiver == in FillpConnReqStateCheck()
68 pcb->send.seqStartNum)) { /* Only if no data received or no data acked */ in FillpConnReqStateCheck()
501 newConn->pcb->fpcb.send.pktSendCache = (FILLP_UINT32)maxSendCache * (FILLP_UINT32)newConn->pcb->fpcb.pktSize; in FillpInitNewPcbByNewConn()
504 ((newConn->pcb->fpcb.send.pktSendCache / newConn->pcb->fpcb.pktSize) != maxSendCache)) { in FillpInitNewPcbByNewConn()
526 newConn->pcb->fpcb.send.pktNum = confirm->cookieContent.localPacketSeqNumber; in FillpInitNewPcbByConfirm()
527 newConn->pcb->fpcb.send.seqNum = confirm->cookieContent.localMessageSeqNumber; in FillpInitNewPcbByConfirm()
530 newConn->pcb->fpcb.send.pktStartNum = confirm->cookieContent.localPacketSeqNumber; in FillpInitNewPcbByConfirm()
531 newConn->pcb->fpcb.send.seqStartNum = confirm->cookieContent.localMessageSeqNumber; in FillpInitNewPcbByConfirm()
532 newConn->pcb->fpcb.send.ackSeqNum = confirm->cookieContent.localMessageSeqNumber; in FillpInitNewPcbByConfirm()
533 newConn->pcb->fpcb.send in FillpInitNewPcbByConfirm()
[all...]
H A Dfillp_pcb.c133 struct FillpSendPcb *pcb = &fpcb->send; in InitSendPcbSimplePar()
176 FILLP_LOGINF("send itemPool Size = %u", fpcb->mpSendSize); in InitSendPcbSimplePar()
182 FILLP_LOGINF("FillP init send PCB cache size:%u", fpcb->mpSendSize); in InitSimplePcbPar()
224 struct FillpSendPcb *pcb = &fpcb->send; in InitItemPool()
255 struct FillpSendPcb *pcb = &fpcb->send; in FillpInitSendpcb()
270 FILLP_LOGINF("send init cache size:%d", initCacheSize); in FillpInitSendpcb()
515 struct FillpFlowControl *flowControl = &fpcb->send.flowControl; in FillpPcbSendFc()
537 HlistAddTail(&fpcb->send.unSendList, &item[i]->unsendNode); in FillpPcbSend()
550 struct FillpSendPcb *pcb = &fpcb->send; in FillpPcbFreeSendItemArray()
600 struct FillpSendPcb *pcb = &fpcb->send; in FillpPcbRemoveSend()
[all...]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dpcb.c65 if (!OS_SOCK_OPS_FUNC_VALID(osSock, send)) { in SpungePcbSend()
72 if (size != (FILLP_INT) osSock->ioSock->ops->send(osSock->ioSock, in SpungePcbSend()
126 FILLP_LOGDTL("gso send %zu", conn->iovCount); in SpungePcbSendmsgInner()
132 * As kernel udp gso suggested, fallback to send. in SpungePcbSendmsgInner()
146 FILLP_LOGERR("fallback to send, ret %d", ret); in SpungePcbSendmsgInner()
162 FILLP_BOOL send = FILLP_FALSE; in SpungePcbSendmsg() local
182 send = FILLP_TRUE; in SpungePcbSendmsg()
189 if ((conn->iovCount < UDP_MAX_SEG) && (fpcb->isLast == FILLP_FALSE) && send == FILLP_FALSE) { in SpungePcbSendmsg()
224 pcb->fpcb.send.pktStartNum = FILLP_CRYPTO_RAND(); in SpungePcbNew()
225 pcb->fpcb.send in SpungePcbNew()
[all...]
H A Dfillp_buf_item.c67 if ((fpcb != FILLP_NULL_PTR) && (fpcb->send.preItem == data)) { in FillpFreeBufItem()
68 fpcb->send.preItem = FILLP_NULL_PTR; in FillpFreeBufItem()
H A Dspunge_core.c89 bytesExpected += pcb->fpcb.send.flowControl.remainBytes; in SpungeCalExpectedBytes()
97 sock->index, pcb->fpcb.send.unrecvList.nodeNum, pcb->fpcb.send.unackList.count); in SpungeCalExpectedBytes()
105 pcb->fpcb.send.flowControl.remainBytes = (bytesExpected - (FILLP_UINT32)sendBytes); in SpungeDoSendUpdate()
107 pcb->fpcb.send.flowControl.remainBytes = 0; in SpungeDoSendUpdate()
124 struct FillpFlowControl *flowControl = &pcb->fpcb.send.flowControl; in SpungeDoSendCycle()
136 /* flow control alg may need to change bytesExpected for the this send cycle a according to current status */ in SpungeDoSendCycle()
141 /* If BytesExpected less than pktSize, no need to send, just store the remainBytes */ in SpungeDoSendCycle()
143 /* Make sure that the send bytes won't more than bytesExpected */ in SpungeDoSendCycle()
149 pcb->fpcb.send in SpungeDoSendCycle()
[all...]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp_pcb.h100 FILLP_LLONG sendTime; /* pre send time */
130 FillpQueue *unsendBox; /* data pkt wait to send APP will fill pkt to it */
172 struct FillpSendPcb send; member
212 then client will send the connect request again with this cookiePreserveTime time */
240 return (pcb->send.unSendList.size + pcb->send.unrecvList.nodeNum + in FillpPcbGetTotalPktCnt()
241 pcb->send.redunList.nodeNum + pcb->send.unackList.count + pcb->send.itemWaitTokenLists.nodeNum); in FillpPcbGetTotalPktCnt()
246 return (pcb->send in FillpPcbGetDirectlySend()
[all...]
H A Dfillp_common.h43 (((seqNum) / FILLP_UNACK_HASH_MOD) & (pcb)->send.unackList.hashModSize)
/foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/
H A Drs_profiler_socket.cpp181 const ssize_t sentBytes = send(client_, bytes, size - sent, 0); in SendWhenReady()
262 fd_set send = GetFdSet(client_); in GetStatus() local
267 if (select(client_ + 1, &receive, &send, nullptr, &timeout) == 0) { in GetStatus()
272 readyToSend = IsFdSet(client_, send); in GetStatus()
/foundation/communication/netmanager_base/interfaces/innerkits/netmanagernative/include/
H A Dnetwork_sharing.h23 int64_t send = 0; member
/foundation/communication/wifi/wifi/test/wifi_standard/wifi_hal/unittest/
H A Dmock_wpa_ctrl.h36 void MockWpaCallback(struct wpa_ctrl *send, const char *message);
H A Dmock_wpa_ctrl.cpp121 void MockWpaCallback(struct wpa_ctrl *send, const char *message) in MockWpaCallback() argument
123 if (send == NULL || message == NULL) { in MockWpaCallback()
126 write(send->s, message, strlen(message)); in MockWpaCallback()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dsockets.h45 FILLP_UINT32 txBurst; /* max pkt number to send each cycle */
58 FILLP_UINT32 sendCache; /* size of send cache */
146 FILLP_INT directlySend; /* directly send packet in the app thread instead of in the main thread */
156 #define SOCK_GET_SENDPKTPOOL(_sock) ((_sock)->netconn->pcb->fpcb.send.itemPool)
157 #define SOCK_GET_SENDBOX(_sock) ((_sock)->netconn->pcb->fpcb.send.unsendBox)
167 #define SOCK_GET_SENDSEM(_sock) ((_sock)->netconn->pcb->fpcb.send.sendSem)
222 /* Get the blocking status of netconn calls (@todo: write/send is missing) */
/foundation/multimedia/av_codec/test/unittest/common/
H A Dhttp_server_demo.cpp176 ret = send(connFd, httpContext.c_str(), httpContext.size(), MSG_NOSIGNAL); in SendRequestSize()
178 std::cout << "send httpContext failed, ret=" << ret << std::endl; in SendRequestSize()
239 ret = send(connFd, fileBuff.data(), std::min(ret, sendSize), MSG_NOSIGNAL); in FileReadFunc()
241 std::cout << "send file buffer failed, ret=" << ret << std::endl; in FileReadFunc()
247 send(connFd, httpContext.c_str(), httpContext.size(), MSG_NOSIGNAL); in FileReadFunc()
250 send(connFd, httpContext.c_str(), httpContext.size(), MSG_NOSIGNAL); in FileReadFunc()
/foundation/communication/bluetooth/frameworks/inner/src/
H A Dbluetooth_socket_outputstream.cpp49 auto ret = send(socketFd_, buf, length, MSG_NOSIGNAL); in Write()
52 HILOGE("socket send time %{public}" PRId64, endTimestamp - beginTimestamp); in Write()
/foundation/distributedhardware/distributed_camera/services/cameraservice/base/include/
H A Ddcamera_frame_info.h26 int64_t send = 0; member
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/feedingsmoother/derived/
H A Ddcamera_time_statistician.cpp28 int64_t trans = frameInfo.timePonit.recv - frameInfo.timePonit.send + frameInfo.offset; in CalProcessTime()
53 int64_t sink = frameInfo.timePonit.send - frameInfo.timePonit.startEncode; in CalWholeProcessTime()
/foundation/multimedia/av_codec/test/nativedemo/avdemuxer/server_demo/
H A Dfile_server_demo.cpp167 ret = send(connFd, httpContext.c_str(), httpContext.size(), MSG_NOSIGNAL); in SendRequestSize()
169 std::cout << "send httpContext failed, ret=" << ret << std::endl; in SendRequestSize()
229 ret = send(connFd, fileBuff.data(), std::min(ret, sendSize), MSG_NOSIGNAL); in FileReadFunc()
230 if (ret <= 0) { // send file buffer failed in FileReadFunc()
236 send(connFd, httpContext.c_str(), httpContext.size(), MSG_NOSIGNAL); in FileReadFunc()
/foundation/communication/netmanager_base/services/netmanagernative/src/manager/
H A Dsharing_manager.cpp405 int64_t send = in GetNetworkSharingTraffic() local
408 traffic.send = send; in GetNetworkSharingTraffic()
409 traffic.all += send; in GetNetworkSharingTraffic()
/foundation/multimodalinput/input/util/socket/src/
H A Duds_client.cpp64 auto count = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()

Completed in 15 milliseconds

123