Home
last modified time | relevance | path

Searched refs:recvLen (Results 1 - 19 of 19) sorted by relevance

/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/
H A Dnstackx_dfile_send.c407 int recvLen = 0; in TcpSocketRecv() local
415 while (recvLen < (int32_t)length) { in TcpSocketRecv()
416 ret = SocketRecv(socket, buffer + session->recvLen, length - (size_t)recvLen, srcAddr, addrLen); in TcpSocketRecv()
428 recvLen = recvLen + ret; in TcpSocketRecv()
429 session->recvLen = session->recvLen + (uint32_t)ret; in TcpSocketRecv()
432 return recvLen; in TcpSocketRecv()
442 if (session->recvLen < lengt in SocketRecvForTcp()
[all...]
H A Dnstackx_dfile_mp.c59 ret = DFileSessionHandleReadBuffer(session, session->recvBuffer, (size_t)session->recvLen, &peerAddr, 0); in DFileSocketRecvSP()
60 session->recvLen = 0; in DFileSocketRecvSP()
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/tcp/
H A Dtcp_socket.cpp150 size_t recvLen = 0; in Recv() local
151 while (recvLen < length) { in Recv()
155 len = ::recv(fd, buff + recvLen, length - recvLen, SOCKET_FLAG); in Recv()
167 recvLen += static_cast<size_t>(len); in Recv()
170 CLOGD("Socket recv DONE!, size:%zu", recvLen); in Recv()
171 return recvLen; in Recv()
/foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/tcp/
H A Dtcp_socket.cpp150 size_t recvLen = 0; in Recv() local
151 while (recvLen < length) { in Recv()
155 len = ::recv(fd, buff + recvLen, length - recvLen, SOCKET_FLAG); in Recv()
167 recvLen += static_cast<size_t>(len); in Recv()
170 CLOGD("Socket recv DONE!, size:%zu", recvLen); in Recv()
171 return recvLen; in Recv()
/foundation/communication/dsoftbus/components/nstackx/nstackx_congestion/platform/unix/qdisc/
H A Dnstackx_nlmsg.c136 int32_t recvLen; in RecvNetlinkResponse() local
142 recvLen = (int32_t)recvmsg(nlSockFd, &msg, 0); in RecvNetlinkResponse()
143 if (recvLen <= 0) { in RecvNetlinkResponse()
144 LOGE(TAG, "2 recvlen %d netlink receive error %s (%d)", recvLen, strerror(errno), errno); in RecvNetlinkResponse()
148 ret = ParseNetlinkMsg(buf, recvLen, nlcb); in RecvNetlinkResponse()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/tcp_direct/src/
H A Dclient_trans_tcp_direct_message.c586 static int32_t TransClientUpdateTdcDataBufWInfo(int32_t channelId, char *recvBuf, int32_t recvLen) in TransClientUpdateTdcDataBufWInfo() argument
608 if (recvLen > freeLen) { in TransClientUpdateTdcDataBufWInfo()
611 "client tdc recvLen override freeLen. recvLen=%{public}d, freeLen=%{public}d", recvLen, freeLen); in TransClientUpdateTdcDataBufWInfo()
614 if (memcpy_s(item->w, recvLen, recvBuf, recvLen) != EOK) { in TransClientUpdateTdcDataBufWInfo()
619 item->w += recvLen; in TransClientUpdateTdcDataBufWInfo()
650 int32_t recvLen = ConnRecvSocketData(fd, recvBuf, len, 0); in TransTdcRecvData() local
651 if (recvLen < in TransTdcRecvData()
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/
H A Dtrans_tcp_direct_message_static_test.cpp403 int32_t recvLen = 10; in HWTEST_F() local
404 void *tmp = SoftBusCalloc(recvLen); in HWTEST_F()
410 ret = TransTdcUpdateDataBufWInfo(channelId, recvBufNull, recvLen); in HWTEST_F()
413 strcpy_s(recvBuf, recvLen, recvStr.c_str()); in HWTEST_F()
414 ret = TransTdcUpdateDataBufWInfo(channelId, recvBuf, recvLen); in HWTEST_F()
749 int32_t recvLen = 10; in HWTEST_F() local
750 void *tmp = SoftBusCalloc(recvLen); in HWTEST_F()
756 strcpy_s(recvBuf, recvLen, recvStr.c_str()); in HWTEST_F()
759 ret = TransTdcUpdateDataBufWInfo(channelId, recvBuf, recvLen); in HWTEST_F()
H A Dtrans_tcp_direct_message_append_test.cpp472 int32_t recvLen = -1; in HWTEST_F() local
474 EXPECT_CALL(TcpMessageMock, ConnRecvSocketData).WillOnce(Return(recvLen)); in HWTEST_F()
494 int32_t recvLen = 0; in HWTEST_F() local
496 EXPECT_CALL(TcpMessageMock, ConnRecvSocketData).WillOnce(Return(recvLen)); in HWTEST_F()
517 int32_t recvLen = 2; in HWTEST_F() local
519 EXPECT_CALL(TcpMessageMock, ConnRecvSocketData).WillRepeatedly(Return(recvLen)); in HWTEST_F()
540 int32_t recvLen = VALIDRECVLEN; in HWTEST_F() local
542 EXPECT_CALL(TcpMessageMock, ConnRecvSocketData).WillRepeatedly(Return(recvLen)); in HWTEST_F()
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/
H A Dtrans_tcp_direct_test.cpp400 int32_t recvLen = MAX_LEN; in HWTEST_F() local
402 ret = TransClientUpdateTdcDataBufWInfo(channelId, NULL, recvLen); in HWTEST_F()
405 ret = TransClientUpdateTdcDataBufWInfo(channelId, const_cast<char *>(recvBuf), recvLen); in HWTEST_F()
411 ret = TransClientUpdateTdcDataBufWInfo(channelId, const_cast<char *>(recvBuf), recvLen); in HWTEST_F()
417 ret = TransClientUpdateTdcDataBufWInfo(channelId, const_cast<char *>(recvBuf), recvLen); in HWTEST_F()
420 recvLen = strlen(recvBuf); in HWTEST_F()
421 ret = TransClientUpdateTdcDataBufWInfo(channelId, const_cast<char *>(recvBuf), recvLen); in HWTEST_F()
/foundation/communication/dsoftbus/core/connection/br/src/
H A Dsoftbus_conn_br_trans.c99 int32_t recvLen = g_sppDriver->Read( in ConnBrTransReadOneFrame() local
101 if (recvLen == BR_READ_SOCKET_CLOSED) { in ConnBrTransReadOneFrame()
113 if (recvLen < 0) { in ConnBrTransReadOneFrame()
116 connectionId, socketHandle, recvLen); in ConnBrTransReadOneFrame()
125 buffer->length += (uint32_t)recvLen; in ConnBrTransReadOneFrame()
/foundation/communication/netmanager_ext/services/mdnsmanager/src/
H A Dmdns_socket_listener.cpp435 ssize_t recvLen = recvmsg(sock, &msg, 0); in ReceiveInSock() local
436 if (recvLen <= 0) { in ReceiveInSock()
437 NETMGR_EXT_LOG_E("mdns_log recvmsg return: [%{public}zd], errno:[%{public}d]", recvLen, errno); in ReceiveInSock()
455 if (ifName == iface_[sock] && recvLen > 0 && recv_) { in ReceiveInSock()
456 payload.resize(static_cast<size_t>(recvLen)); in ReceiveInSock()
/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/
H A Dtrans_tcp_direct_message.c1244 static int32_t TransTdcUpdateDataBufWInfo(int32_t channelId, char *recvBuf, int32_t recvLen) in TransTdcUpdateDataBufWInfo() argument
1265 if (recvLen > freeLen) { in TransTdcUpdateDataBufWInfo()
1268 "trans tdc. recvLen=%{public}d, freeLen=%{public}d.", recvLen, freeLen); in TransTdcUpdateDataBufWInfo()
1271 if (memcpy_s(item->w, recvLen, recvBuf, recvLen) != EOK) { in TransTdcUpdateDataBufWInfo()
1276 item->w += recvLen; in TransTdcUpdateDataBufWInfo()
1297 int32_t recvLen = ConnRecvSocketData(fd, buffer, bufferSize - totalRecvLen, 0); in TransRecvTdcSocketData() local
1298 if (recvLen < 0) { in TransRecvTdcSocketData()
1300 "totalRecv=%{public}d", channelId, recvLen, bufferSiz in TransRecvTdcSocketData()
[all...]
/foundation/communication/dsoftbus/core/connection/tcp/src/
H A Dsoftbus_tcp_connect_manager.c272 uint32_t recvLen = 0; in RecvData() local
286 while (recvLen < len) { in RecvData()
287 ssize_t n = ConnRecvSocketData(fd, data + headSize + recvLen, len - recvLen, g_tcpTimeOut); in RecvData()
289 CONN_LOGE(CONN_COMMON, "receiveData: error occurred! recvLen=%{public}d, len=%{public}d", recvLen, len); in RecvData()
292 recvLen += (uint32_t)n; in RecvData()
/foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/src/
H A Dsocket_exec.cpp699 static int ExitOrAbnormal(int sock, ssize_t recvLen, const MessageCallback &callback) in ExitOrAbnormal() argument
705 NETSTACK_LOGI("not tcpsocket, continue loop, recvLen: %{public}zd, err: %{public}d", recvLen, errno); in ExitOrAbnormal()
708 if (errno == 0 && recvLen == 0) { in ExitOrAbnormal()
709 NETSTACK_LOGI("closed by peer, socket:%{public}d, recvLen:%{public}zd", sock, recvLen); in ExitOrAbnormal()
714 NETSTACK_LOGE("recv fail, socket:%{public}d, recvLen:%{public}zd, errno:%{public}d", sock, recvLen, errno); in ExitOrAbnormal()
795 auto recvLen = recvfrom(currentFd, buf.get(), bufferSize, 0, addr, &tempAddrLen); in PollRecvData() local
796 if (recvLen < in PollRecvData()
[all...]
H A Dlocal_socket_exec.cpp736 auto recvLen = recv(sock, buf.get(), bufferSize, 0); in PollRecvData() local
737 if (recvLen < 0) { in PollRecvData()
746 } else if (recvLen == 0) { in PollRecvData()
750 void *data = malloc(recvLen); in PollRecvData()
755 if (memcpy_s(data, recvLen, buf.get(), recvLen) != EOK || !callback.OnMessage(data, recvLen)) { in PollRecvData()
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/
H A Dnstackx_dfile_session.h148 uint32_t recvLen; member
/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dsocket_app.c730 FILLP_INT recvLen; in SockRecvmsg() local
734 recvLen = SocketMsgGetLen(msg); in SockRecvmsg()
735 if (recvLen <= 0) { in SockRecvmsg()
763 recvLen = SockRecvmsgDataFromBufCache(sock, msg, flags, recvLen); in SockRecvmsg()
765 if (recvLen > 0) { in SockRecvmsg()
767 return recvLen; in SockRecvmsg()
/foundation/communication/dsoftbus/core/authentication/src/
H A Dauth_tcp_connection.c201 ssize_t recvLen = ConnRecvSocketData(fd, (char *)(data + offset), (size_t)(len - offset), 0); in RecvPacketData() local
202 if (recvLen < 0) { in RecvPacketData()
207 offset += (uint32_t)recvLen; in RecvPacketData()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/
H A Dvtp_stream_socket.cpp1181 int32_t recvLen = 0; in RecvStream() local
1182 while (recvLen < dataLength) { in RecvStream()
1188 ret = FtRecv(streamFd_, (buffer.get() + recvLen), dataLength - recvLen, 0); in RecvStream()
1197 recvLen += ret; in RecvStream()

Completed in 29 milliseconds