Home
last modified time | relevance | path

Searched refs:recvLen (Results 1 – 22 of 22) sorted by relevance

/ohos5.0/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 < length) { in SocketRecvForTcp()
443 ret = TcpSocketRecv(session, buffer, length - session->recvLen, srcAddr, addrLen); in SocketRecvForTcp()
453 session->recvLen, payloadLen, frameHeader->type); in SocketRecvForTcp()
457 if ((session->recvLen - length) < payloadLen) { in SocketRecvForTcp()
[all …]
H A Dnstackx_dfile_mp.c59 …ret = DFileSessionHandleReadBuffer(session, session->recvBuffer, (size_t)session->recvLen, &peerAd… in DFileSocketRecvSP()
60 session->recvLen = 0; in DFileSocketRecvSP()
/ohos5.0/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()
/ohos5.0/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 < 0) { in TransTdcRecvData()
653 …ANS_SDK, "client recv data failed, channelId=%{public}d, recvLen=%{public}d.", channelId, recvLen); in TransTdcRecvData()
655 } else if (recvLen == 0) { in TransTdcRecvData()
659 ret = TransClientUpdateTdcDataBufWInfo(channelId, recvBuf, recvLen); in TransTdcRecvData()
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/
H A Dtrans_tcp_direct_message_static_test.cpp402 int32_t recvLen = 10; variable
403 void *tmp = SoftBusCalloc(recvLen);
409 ret = TransTdcUpdateDataBufWInfo(channelId, recvBufNull, recvLen);
412 strcpy_s(recvBuf, recvLen, recvStr.c_str());
413 ret = TransTdcUpdateDataBufWInfo(channelId, recvBuf, recvLen);
758 int32_t recvLen = 10; variable
759 void *tmp = SoftBusCalloc(recvLen);
765 strcpy_s(recvBuf, recvLen, recvStr.c_str());
768 ret = TransTdcUpdateDataBufWInfo(channelId, recvBuf, recvLen);
H A Dtrans_tcp_direct_message_append_test.cpp472 int32_t recvLen = -1; variable
474 EXPECT_CALL(TcpMessageMock, ConnRecvSocketData).WillOnce(Return(recvLen));
494 int32_t recvLen = 0; variable
496 EXPECT_CALL(TcpMessageMock, ConnRecvSocketData).WillOnce(Return(recvLen));
517 int32_t recvLen = 2; variable
519 EXPECT_CALL(TcpMessageMock, ConnRecvSocketData).WillRepeatedly(Return(recvLen));
540 int32_t recvLen = VALIDRECVLEN; variable
542 EXPECT_CALL(TcpMessageMock, ConnRecvSocketData).WillRepeatedly(Return(recvLen));
/ohos5.0/base/startup/init/services/param/linux/
H A Dparam_request.c101 ssize_t recvLen = recv(fd, (char *)buffer, RECV_BUFFER_MAX, 0); in ReadMessage() local
102 if (recvLen <= 0) { in ReadMessage()
117 if ((size_t)recvLen > sizeof(ParamMessage)) { in ReadMessage()
118 PARAM_LOGV("recv message len is %d", recvLen); in ReadMessage()
/ohos5.0/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()
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/
H A Dtrans_tcp_direct_message.c1267 if (recvLen > freeLen) { in TransTdcUpdateDataBufWInfo()
1270 "trans tdc. recvLen=%{public}d, freeLen=%{public}d.", recvLen, freeLen); in TransTdcUpdateDataBufWInfo()
1273 if (memcpy_s(item->w, recvLen, recvBuf, recvLen) != EOK) { in TransTdcUpdateDataBufWInfo()
1278 item->w += recvLen; in TransTdcUpdateDataBufWInfo()
1299 int32_t recvLen = ConnRecvSocketData(fd, buffer, bufferSize - totalRecvLen, 0); in TransRecvTdcSocketData() local
1300 if (recvLen < 0) { in TransRecvTdcSocketData()
1302 "totalRecv=%{public}d", channelId, recvLen, bufferSize, totalRecvLen); in TransRecvTdcSocketData()
1304 } else if (recvLen == 0) { in TransRecvTdcSocketData()
1310 if (TransTdcUpdateDataBufWInfo(channelId, buffer, recvLen) != SOFTBUS_OK) { in TransRecvTdcSocketData()
1314 buffer += recvLen; in TransRecvTdcSocketData()
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/
H A Dtrans_tcp_direct_test.cpp400 int recvLen = MAX_LEN; variable
402 ret = TransClientUpdateTdcDataBufWInfo(channelId, NULL, recvLen);
405 ret = TransClientUpdateTdcDataBufWInfo(channelId, const_cast<char *>(recvBuf), recvLen);
411 ret = TransClientUpdateTdcDataBufWInfo(channelId, const_cast<char *>(recvBuf), recvLen);
417 ret = TransClientUpdateTdcDataBufWInfo(channelId, const_cast<char *>(recvBuf), recvLen);
420 recvLen = strlen(recvBuf);
421 ret = TransClientUpdateTdcDataBufWInfo(channelId, const_cast<char *>(recvBuf), recvLen);
/ohos5.0/foundation/communication/dsoftbus/core/authentication/src/
H A Dauth_tcp_connection.c182 … ssize_t recvLen = ConnRecvSocketData(fd, (char *)&buf[offset], (size_t)(sizeof(buf) - offset), in RecvPacketHead() local
184 if (recvLen < 0) { in RecvPacketHead()
190 offset += (uint32_t)recvLen; in RecvPacketHead()
204 … ssize_t recvLen = ConnRecvSocketData(fd, (char *)(data + offset), (size_t)(len - offset), 0); in RecvPacketData() local
205 if (recvLen < 0) { in RecvPacketData()
210 offset += (uint32_t)recvLen; in RecvPacketData()
/ohos5.0/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()
/ohos5.0/base/security/access_token/services/tokensyncmanager/test/unittest/
H A Dtoken_sync_service_test.cpp618 int recvLen = 0x1000; variable
619 CompressMock(recvJson, recvBuffer, recvLen);
632 SoftBusSocketListener::OnClientBytes(1, recvBuffer, recvLen);
845 int recvLen = 0x1000; variable
846 CompressMock(recvJson, recvBuffer, recvLen);
851 SoftBusSocketListener::OnClientBytes(1, recvBuffer, recvLen);
1358 int recvLen = 0x1000; variable
1368 SoftBusSocketListener::OnServiceBytes(0, nullptr, recvLen);
1371 SoftBusSocketListener::OnClientBytes(0, nullptr, recvLen);
/ohos5.0/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 …LOGE(CONN_COMMON, "receiveData: error occurred! recvLen=%{public}d, len=%{public}d", recvLen, len); in RecvData()
292 recvLen += (uint32_t)n; in RecvData()
/ohos5.0/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 …TSTACK_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 …_LOGE("recv fail, socket:%{public}d, recvLen:%{public}zd, errno:%{public}d", sock, recvLen, errno); in ExitOrAbnormal()
791 auto recvLen = recvfrom(currentFd, buf.get(), bufferSize, 0, addr, &tempAddrLen); in PollRecvData() local
792 if (recvLen <= 0) { in PollRecvData()
793 if (ExitOrAbnormal(currentFd, recvLen, callback) < 0) { in PollRecvData()
799 void *data = malloc(recvLen); in PollRecvData()
804 …if (memcpy_s(data, recvLen, buf.get(), recvLen) != EOK || !callback.OnMessage(data, recvLen, addr)… in PollRecvData()
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()
/ohos5.0/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()
/ohos5.0/base/startup/init/services/param/watcher/proxy/
H A Dwatcher_manager.cpp265 ssize_t recvLen = 0; in RunLoop() local
272 recvLen = recv(fd, buffer.data(), RECV_BUFFER_MAX, 0); in RunLoop()
274 if (recvLen <= 0) { in RunLoop()
283 uint32_t dataLen = static_cast<uint32_t>(recvLen); in RunLoop()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/
H A Dnstackx_dfile_session.h148 uint32_t recvLen; member
/ohos5.0/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()
/ohos5.0/base/startup/appspawn/test/unittest/
H A Dapp_spawn_test_helper.cpp266 int recvLen = recvmsg(socketFd, &msg, flags); in HandleRecvMessage() local
281 return recvLen; in HandleRecvMessage()
/ohos5.0/base/startup/appspawn/standard/
H A Dappspawn_service.c317 int recvLen = recvmsg(socketFd, &msg, flags); in HandleRecvMessage() local
333 return recvLen; in HandleRecvMessage()