| /foundation/CastEngine/castengine_cast_plus_stream/src/stream/src/local/src/ |
| H A D | cast_local_file_channel_server.cpp | 263 int CastLocalFileChannelServer::ReadFileData(const struct LocalFileInfo &data, int64_t start, int64_t sendLen, in ReadFileData() argument
274 readLen = ReadFileDataByFd(fd, start, sendLen, ptr); in ReadFileData()
293 int sendLen = static_cast<int>(std::max(static_cast<int64_t>(0), newEnd - start)); in ResponseFileDataRequest() local
299 rsp.append(std::to_string(sendLen) + "\r\n"); in ResponseFileDataRequest()
306 std::unique_ptr<uint8_t[]> buffer = std::make_unique<uint8_t[]>(sendLen + offset); in ResponseFileDataRequest()
308 CLOGE("malloc buffer[%{public}d] fail", sendLen); in ResponseFileDataRequest()
312 if (memcpy_s(buffer.get(), sendLen + offset, rsp.data(), rsp.size()) != EOK) { in ResponseFileDataRequest()
319 int readLen = ReadFileData(data, start, sendLen, ptr); in ResponseFileDataRequest()
322 SendData(buffer.get(), sendLen + offset); in ResponseFileDataRequest()
323 CLOGD("send out start:%{public}" PRId64 " len:%{public}d", start, sendLen); in ResponseFileDataRequest()
367 ReadFileDataByFd(int fd, int64_t start, int sendLen, uint8_t *buffer) ReadFileDataByFd() argument
[all...] |
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/stream/src/local/src/ |
| H A D | cast_local_file_channel_server.cpp | 256 int CastLocalFileChannelServer::ReadFileData(const struct LocalFileInfo &data, int64_t start, int64_t sendLen, in ReadFileData() argument
267 readLen = ReadFileDataByFd(fd, start, sendLen, ptr); in ReadFileData()
286 int sendLen = static_cast<int>(std::max(static_cast<int64_t>(0), newEnd - start)); in ResponseFileDataRequest() local
292 rsp.append(std::to_string(sendLen) + "\r\n"); in ResponseFileDataRequest()
299 std::unique_ptr<uint8_t[]> buffer = std::make_unique<uint8_t[]>(sendLen + offset); in ResponseFileDataRequest()
301 CLOGE("malloc buffer[%{public}d] fail", sendLen); in ResponseFileDataRequest()
305 if (memcpy_s(buffer.get(), sendLen + offset, rsp.data(), rsp.size()) != EOK) { in ResponseFileDataRequest()
312 int readLen = ReadFileData(data, start, sendLen, ptr); in ResponseFileDataRequest()
315 SendData(buffer.get(), sendLen + offset); in ResponseFileDataRequest()
316 CLOGD("send out start:%{public}" PRId64 " len:%{public}d", start, sendLen); in ResponseFileDataRequest()
356 ReadFileDataByFd(int fd, int64_t start, int sendLen, uint8_t *buffer) ReadFileDataByFd() argument
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
| H A D | nstackx_dfile_send.c | 90 ret = SocketSend(socket, (uint8_t *)block->fileDataFrame + block->sendLen, len - block->sendLen); in TcpSendFileDataFrame()
91 if (ret > 0 && ret == (int32_t)(len - block->sendLen)) { in TcpSendFileDataFrame()
92 block->sendLen = 0; in TcpSendFileDataFrame()
101 block->sendLen = block->sendLen + (uint32_t)ret; in TcpSendFileDataFrame()
325 ret = SocketSend(socket, queueNode->frame + queueNode->sendLen, queueNode->length - queueNode->sendLen); in SendControlFrame()
326 if (ret > 0 && ret == (int32_t)(queueNode->length - queueNode->sendLen)) { in SendControlFrame()
327 queueNode->sendLen in SendControlFrame()
[all...] |
| H A D | nstackx_file_manager_client.c | 466 blockFrame->sendLen = 0; in PushFileBlockFrame()
|
| H A D | nstackx_dfile_session.c | 75 queueNode->sendLen = 0; in CreateQueueNode()
|
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/stream/src/local/include/ |
| H A D | cast_local_file_channel_server.h | 70 int ReadFileData(const struct LocalFileInfo &data, int64_t start, int64_t sendLen, uint8_t *ptr);
77 int ReadFileDataByFd(int fd, int64_t start, int sendLen, uint8_t *buffer);
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/stream/src/local/include/ |
| H A D | cast_local_file_channel_server.h | 70 int ReadFileData(const struct LocalFileInfo &data, int64_t start, int64_t sendLen, uint8_t *ptr);
77 int ReadFileDataByFd(int fd, int64_t start, int sendLen, uint8_t *buffer);
|
| /foundation/communication/dhcp/services/dhcp_client/src/ |
| H A D | dhcp_socket.cpp | 212 int sendLen = sizeof(udpPackets) - sizeof(udpPackets.data.options) + optionLen; in SendToDhcpPacket() local
229 udpPackets.ip.tot_len = htons(sendLen); in SendToDhcpPacket()
233 ssize_t nBytes = sendto(nFd, &udpPackets, sendLen, 0, (struct sockaddr *)&rawAddr, sizeof(rawAddr)); in SendToDhcpPacket()
235 DHCP_LOGE("SendToDhcpPacket optionLen:%{public}d sendLen:%{public}d, " in SendToDhcpPacket()
237 optionLen, sendLen, dhcpPackLen, nFd, errno); in SendToDhcpPacket()
239 DHCP_LOGI("SendToDhcpPacket optionLen:%{public}d sendLen:%{public}d, " in SendToDhcpPacket()
241 optionLen, sendLen, dhcpPackLen, nFd, destIndex, static_cast<int>(nBytes)); in SendToDhcpPacket()
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/include/ |
| H A D | socket_app.h | 104 #define SOCK_SENDMSG_DATA_MOD_LEN(iovIter, iovRemainLen, itemIter, itemRemainLen, sendLen, dataLen, cpylen) \
110 (sendLen) += (FILLP_INT)(cpylen); \
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/ |
| H A D | socket_app.c | 409 FILLP_LLONG appSendTime, FILLP_INT sendLen, FILLP_INT bufLen) in SockSendMsgSetItem()
422 if (sendLen == 0) { in SockSendMsgSetItem()
462 FILLP_INT sendLen = 0; in SockSendmsgDataToBufCache() local
477 while (sendLen != bufLen) { in SockSendmsgDataToBufCache()
490 SockSendMsgSetItem(item, sock, appSendTime, sendLen, bufLen); in SockSendmsgDataToBufCache()
506 SOCK_SENDMSG_DATA_MOD_LEN(iovIter, iovRemainLen, itemIter, itemRemainLen, sendLen, item->dataLen, copyLen); in SockSendmsgDataToBufCache()
513 return sendLen; in SockSendmsgDataToBufCache()
518 FILLP_INT sendLen; in SockSendmsg() local
521 sendLen = SocketMsgGetLen(msg); in SockSendmsg()
522 if (sendLen < in SockSendmsg()
408 SockSendMsgSetItem(struct FillpPcbItem *item, FILLP_CONST struct FtSocket *sock, FILLP_LLONG appSendTime, FILLP_INT sendLen, FILLP_INT bufLen) SockSendMsgSetItem() argument
[all...] |
| /foundation/communication/netmanager_ext/services/mdnsmanager/src/ |
| H A D | mdns_socket_listener.cpp | 517 ssize_t sendLen = Multicast(socks_[i], payload); in MulticastAll() local
518 if (sendLen == -1) { in MulticastAll()
519 return sendLen; in MulticastAll()
521 total += sendLen; in MulticastAll()
|
| /foundation/communication/netmanager_ext/services/networksharemanager/src/ |
| H A D | router_advertisement_daemon.cpp | 207 socklen_t sendLen = sizeof(solicitation); in RunRecvRsThread() local
213 recvfrom(socket_, solicitation, IPV6_MIN_MTU, 0, reinterpret_cast<sockaddr *>(&solicitor), &sendLen); in RunRecvRsThread()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/ |
| H A D | nstackx_dfile_session.h | 41 uint32_t sendLen; member
|
| H A D | nstackx_file_manager.h | 143 uint32_t sendLen; member
|
| /foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/src/ |
| H A D | local_socket_exec.cpp | 296 auto sendLen = sendto(sock, curPos, sendSize, 0, addr, addrLen); in PollSendData() local
297 if (sendLen < 0) { in PollSendData()
304 if (sendLen == 0) { in PollSendData()
307 curPos += sendLen; in PollSendData()
308 leftSize -= sendLen; in PollSendData()
|
| H A D | socket_exec.cpp | 571 auto sendLen = sendto(sock, curPos, sendSize, 0, addr, addrLen); in PollSendData() local
572 NETSTACK_LOGD("socketFD: %{public}d, send len: %{public}zu", sock, sendLen); in PollSendData()
573 if (sendLen < 0) { in PollSendData()
580 if (sendLen == 0) { in PollSendData()
583 curPos += sendLen; in PollSendData()
584 leftSize -= sendLen; in PollSendData()
|
| /foundation/communication/dsoftbus/core/connection/ble/src/ |
| H A D | softbus_conn_ble_trans.c | 279 uint32_t sendLen = waitSendLen <= maxPayload ? waitSendLen : maxPayload; in ConnGattTransSend() local
280 uint32_t amount = (uint32_t)g_flowController->apply(g_flowController, (int32_t)sendLen); in ConnGattTransSend()
|
| /foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/heartbeat/src/ |
| H A D | lnn_heartbeat_strategy.c | 311 uint32_t *delayTime, uint32_t sendLen) in SendEachOnce()
317 *delayTime += sendLen; in SendEachOnce()
310 SendEachOnce(LnnHeartbeatFsm *hbFsm, LnnProcessSendOnceMsgPara *msgPara, LnnHeartbeatSendEndData *endData, uint32_t *delayTime, uint32_t sendLen) SendEachOnce() argument
|