| /foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A D | socket_util.cpp | 27 int sendSize = len; in SocketSendData() local
29 while (sendSize) { in SocketSendData()
30 ssize_t size = send(sockFd, buf, sendSize, 0); in SocketSendData()
34 if (size > sendSize) { in SocketSendData()
38 sendSize -= size; in SocketSendData()
51 int sendSize = len; in SocketSendFd() local
82 sendSize = -1; in SocketSendFd()
91 return sendSize; in SocketSendFd()
|
| /foundation/communication/ipc/ipc/native/test/fuzztest/core/bufferobject_fuzzer/ |
| H A D | bufferobject_fuzzer.cpp | 31 uint32_t sendSize = *(reinterpret_cast<const uint32_t*>(data)); in GetSendBufferAndLockTest() local
32 char *sendBuffer = object.GetSendBufferAndLock(sendSize); in GetSendBufferAndLockTest()
46 uint32_t sendSize = *(reinterpret_cast<const uint32_t*>(data)); in GetReceiveBufferAndLockTest() local
47 char *sendBuffer = object.GetReceiveBufferAndLock(sendSize); in GetReceiveBufferAndLockTest()
176 uint32_t sendSize = *(reinterpret_cast<const uint32_t*>(data)); in GetNeedBufferSizeTest() local
177 uint32_t ret = object.GetNeedBufferSize(sendSize); in GetNeedBufferSizeTest()
226 uint32_t sendSize = *(reinterpret_cast<const uint32_t*>(data)); in UpdateSendBufferTest() local
227 object.UpdateSendBuffer(sendSize); in UpdateSendBufferTest()
|
| /foundation/graphic/graphic_2d/utils/socketpair/export/ |
| H A D | local_socketpair.h | 30 int32_t CreateChannel(size_t sendSize, size_t receiveSize);
51 int32_t SetSockopt(size_t sendSize, size_t receiveSize, int32_t* socketPair, int32_t socketPairSize);
|
| /foundation/graphic/graphic_2d/utils/socketpair/src/ |
| H A D | local_socketpair.cpp | 60 int32_t LocalSocketPair::SetSockopt(size_t sendSize, size_t receiveSize, int32_t* socketPair, int32_t socketPairSize)
in SetSockopt() argument
63 int32_t ret = setsockopt(socketPair[i], SOL_SOCKET, SO_SNDBUF, &sendSize, sizeof(sendSize));
in SetSockopt()
88 int32_t LocalSocketPair::CreateChannel(size_t sendSize, size_t receiveSize)
in CreateChannel() argument
114 int32_t ret = SetSockopt(sendSize, receiveSize, socketPair, SOCKET_PAIR_SIZE);
in CreateChannel()
|
| /foundation/communication/ipc/ipc/native/src/mock/include/ |
| H A D | dbinder_base_invoker_object.h | 302 uint32_t sendSize = transData->sizeOfSelf;
in MoveTransData2Buffer() local
303 char *sendBuffer = sessionBuff->GetSendBufferAndLock(sendSize);
in MoveTransData2Buffer()
310 sessionBuff->UpdateSendBuffer(sendSize);
in MoveTransData2Buffer()
314 sendSize > sessionBuff->GetSendBufferSize() - static_cast<uint32_t>(writeCursor)) {
in MoveTransData2Buffer()
317 sendSize:%{public}u bufferSize:%{public}u",
in MoveTransData2Buffer()
318 writeCursor, readCursor, sendSize, sessionBuff->GetSendBufferSize());
in MoveTransData2Buffer()
321 if (memcpy_s(sendBuffer + writeCursor, sendSize, transData.get(), sendSize)) {
in MoveTransData2Buffer()
323 ZLOGE(LOG_LABEL, "fail to copy from tr to sendBuffer, parcelSize:%{public}u", sendSize);
in MoveTransData2Buffer()
327 writeCursor += static_cast<ssize_t>(sendSize);
in MoveTransData2Buffer()
[all...] |
| H A D | dbinder_base_invoker_process.h | 212 uint32_t sendSize = ((data.GetDataSize() > 0) ? data.GetDataSize() : sizeof(binder_size_t)) +
in ProcessNormalData() local
217 transData.reset(reinterpret_cast<dbinder_transaction_data *>(::operator new(sendSize)));
in ProcessNormalData()
219 ZLOGE(LOG_LABEL, "new buffer failed of length:%{public}u", sendSize);
in ProcessNormalData()
222 ConstructTransData(data, *transData, sendSize, seqNum, cmd, code, flags);
in ProcessNormalData()
|
| /foundation/multimedia/av_codec/test/nativedemo/avdemuxer/server_demo/ |
| H A D | file_server_demo.cpp | 224 int32_t sendSize = std::min(BUFFER_LNE, size); in FileReadFunc() local
225 std::vector<uint8_t> fileBuff(sendSize); in FileReadFunc()
226 ret = read(fileFd, fileBuff.data(), sendSize); in FileReadFunc()
229 ret = send(connFd, fileBuff.data(), std::min(ret, sendSize), MSG_NOSIGNAL); in FileReadFunc()
|
| /foundation/multimedia/av_codec/test/unittest/common/ |
| H A D | http_server_demo.cpp | 234 int32_t sendSize = std::min(BUFFER_LNE, size); in FileReadFunc() local
235 std::vector<uint8_t> fileBuff(sendSize); in FileReadFunc()
236 ret = read(fileFd, fileBuff.data(), sendSize); in FileReadFunc()
239 ret = send(connFd, fileBuff.data(), std::min(ret, sendSize), MSG_NOSIGNAL); in FileReadFunc()
|
| /foundation/CastEngine/castengine_wifi_display/tests/demo/network/ |
| H A D | network_server_demo.cpp | 114 int sendSize = buf->Size(); variable
115 sessionStr->Send(std::move(buf), sendSize); variable
|
| /foundation/communication/netstack/frameworks/cj/http/include/ |
| H A D | ffi_structs.h | 112 uint32_t sendSize; member
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/media_library_helper/src/ |
| H A D | media_file_utils.cpp | 756 off_t sendSize = fileSize - offset; in CopyFile() local
757 if (sendSize > sendSize1G) { in CopyFile()
758 sendSize = sendSize1G; in CopyFile()
760 if (sendfile(wfd, rfd, &offset, sendSize) != sendSize) { in CopyFile()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/dfx/ |
| H A D | dfx_types.h | 155 int sendSize; member
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/ |
| H A D | hiview_adapter.cpp | 310 it->second.val.sendSize += stat.sendSize; in ReportTrafficStatistic()
340 .v = { .i64 = static_cast<int64_t>(kv.second.val.sendSize) }, in InvokeTraffic()
|
| /foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/src/ |
| H A D | local_socket_exec.cpp | 295 size_t sendSize = (sockType == SOCK_STREAM ? leftSize : std::min<size_t>(leftSize, bufferSize)); in PollSendData() local
296 auto sendLen = sendto(sock, curPos, sendSize, 0, addr, addrLen); in PollSendData()
462 uint32_t sendSize = DEFAULT_BUFFER_SIZE; in SetSocketDefaultBufferSize() local
464 sendSize = mgr->extraOptions_.GetSendBufferSize(); in SetSocketDefaultBufferSize()
466 SetSocketBufferSize(sockfd, SO_SNDBUF, sendSize); in SetSocketDefaultBufferSize()
|
| H A D | socket_exec.cpp | 570 size_t sendSize = (sockType == SOCK_STREAM ? leftSize : std::min<size_t>(leftSize, bufferSize)); in PollSendData() local
571 auto sendLen = sendto(sock, curPos, sendSize, 0, addr, addrLen); in PollSendData()
|
| /foundation/communication/netstack/frameworks/js/napi/tls/src/ |
| H A D | tls_socket.cpp | 1247 bool TLSSocket::TLSSocketInternal::PollSend(int sockfd, ssl_st *ssl, const char *pdata, int sendSize) in PollSend() argument
1253 while (sendSize > 0) { in PollSend()
1270 size_t curSendSize = std::min<size_t>(sendSize, bufferSize); in PollSend()
1282 NETSTACK_LOGI("send len is 0, should have sent len is %{public}d", sendSize); in PollSend()
1286 sendSize -= len; in PollSend()
|
| /foundation/communication/netstack/interfaces/innerkits/tls_socket/include/ |
| H A D | tls_socket.h | 563 bool PollSend(int sockfd, ssl_st *ssl, const char *pdata, int sendSize);
|
| /foundation/communication/netstack/frameworks/cj/http/src/ |
| H A D | net_http_client_exec.cpp | 935 CDataSendProgressInfo info = {.sendSize = ulLen.nLen, .totalSize = ulLen.tLen}; in ProgressCallback()
|