/foundation/communication/ipc/ipc/native/src/core/include/ |
H A D | buffer_object.h | 50 ssize_t GetReceiveBufferWriteCursor() const; 51 void SetReceiveBufferWriteCursor(ssize_t newWriteCursor); 52 ssize_t GetReceiveBufferReadCursor() const; 53 void SetReceiveBufferReadCursor(ssize_t newReadCursor); 54 ssize_t GetSendBufferWriteCursor() const; 55 void SetSendBufferWriteCursor(ssize_t newWriteCursor); 56 ssize_t GetSendBufferReadCursor() const; 57 void SetSendBufferReadCursor(ssize_t newReadCursor); 65 ssize_t recvBufferCursorW_ = 0; 66 ssize_t recvBufferCursorR [all...] |
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/ |
H A D | stream_packetizer.h | 36 ssize_t CalculateHeaderSize() const; 37 ssize_t CalculateExtSize(ssize_t extSize) const; 40 ssize_t GetPacketLen() const in GetPacketLen() 45 ssize_t GetHeaderLen() const in GetHeaderLen() 51 ssize_t hdrSize_ = 0; 52 ssize_t dataSize_ = 0; 53 ssize_t extSize_ = 0;
|
H A D | stream_common_data.h | 38 int InitStreamData(std::unique_ptr<char[]> inputBuf, ssize_t bufSize, std::unique_ptr<char[]> inputExt, 39 ssize_t extSize); 56 ssize_t GetBufferLen() const override 66 ssize_t GetExtBufferLen() const override 88 ssize_t streamLen_ = 0; 94 ssize_t extBufLen_ = 0;
|
H A D | raw_stream_data.h | 35 int InitStreamData(std::unique_ptr<char[]> buffer, ssize_t bufLen, std::unique_ptr<char[]> extBuffer, 36 ssize_t extLen); 39 ssize_t GetBufferLen() const override; 58 ssize_t GetExtBufferLen() const override 79 ssize_t streamLen_ = 0;
|
H A D | vtp_stream_socket.h | 77 ssize_t GetEncryptOverhead() const; 79 ssize_t Encrypt(const void *in, ssize_t inLen, void *out, ssize_t outLen) const; 81 ssize_t Decrypt(const void *in, ssize_t inLen, void *out, ssize_t outLen) const; 107 bool EncryptStreamPacket(std::unique_ptr<IStream> stream, std::unique_ptr<char[]> &data, ssize_t &len);
|
H A D | raw_stream_data.cpp | 35 std::unique_ptr<IStream> IStream::MakeRawStream(const char *buf, ssize_t bufLen, const StreamFrameInfo &info, int scene) in MakeRawStream() 75 int RawStreamData::InitStreamData(std::unique_ptr<char[]> buffer, ssize_t bufLen, in InitStreamData() 76 std::unique_ptr<char[]> extBuffer, ssize_t extLen) in InitStreamData() 90 ssize_t RawStreamData::GetBufferLen() const in GetBufferLen()
|
H A D | stream_packet_header.h | 82 TwoLevelsTlv(std::unique_ptr<char[]> extBuf, ssize_t extSize) in TwoLevelsTlv() 101 int Packetize(char *start, ssize_t size, ssize_t offset) in Packetize() 150 extLen_ = static_cast<ssize_t>(tl.length); in Depacketize() 162 ssize_t GetExtLen() const in GetExtLen() 224 ssize_t extLen_ = 0; 273 void Packetize(char *pos, ssize_t size, ssize_t offset) const in Packetize()
|
H A D | stream_packetizer.cpp | 24 ssize_t StreamPacketizer::CalculateHeaderSize() const in CalculateHeaderSize() 31 ssize_t StreamPacketizer::CalculateExtSize(ssize_t extSize) const in CalculateExtSize()
|
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/accessor/include/ |
H A D | file_metadata_stream.h | 51 virtual ssize_t FWrite(const void *src, size_t size, ssize_t nmemb, FILE *file); 61 virtual ssize_t FRead(void *destv, size_t size, ssize_t nmemb, FILE *file); 94 * depends on the type of ssize_t. If ssize_t is 32-bit, the maximum size 95 * is 2GB. If ssize_t is 64-bit, the maximum size is 8ZB. 99 virtual ssize_t Write(byte *data, ssize_t size) override; 108 virtual ssize_t Rea [all...] |
H A D | buffer_metadata_stream.h | 78 virtual ssize_t Write(uint8_t *data, ssize_t size) override; 86 virtual ssize_t Read(uint8_t *buf, ssize_t size) override; 173 virtual ssize_t GetSize() override; 219 long CalculateNewCapacity(long currentOffset, ssize_t size);
|
H A D | metadata_stream.h | 114 virtual ssize_t Write(byte *data, ssize_t size) = 0; 122 virtual ssize_t Read(byte *buf, ssize_t size) = 0; 174 virtual ssize_t GetSize() = 0;
|
/foundation/communication/ipc/ipc/native/test/fuzztest/core/bufferobject_fuzzer/ |
H A D | bufferobject_fuzzer.cpp | 80 ssize_t ret = object.GetReceiveBufferWriteCursor(); in GetReceiveBufferWriteCursorTest() 89 if (data == nullptr || size < sizeof(ssize_t)) { in SetReceiveBufferWriteCursorTest() 92 ssize_t cursor = *(reinterpret_cast<const ssize_t*>(data)); in SetReceiveBufferWriteCursorTest() 104 ssize_t ret = object.GetReceiveBufferReadCursor(); in GetReceiveBufferReadCursorTest() 113 if (data == nullptr || size < sizeof(ssize_t)) { in SetReceiveBufferReadCursorTest() 117 ssize_t cursor = *(reinterpret_cast<const ssize_t*>(data)); in SetReceiveBufferReadCursorTest() 128 ssize_t ret = object.GetSendBufferWriteCursor(); in GetSendBufferWriteCursorTest() 137 if (data == nullptr || size < sizeof(ssize_t)) { in SetSendBufferWriteCursorTest() [all...] |
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/accessor/src/ |
H A D | file_metadata_stream.cpp | 38 ssize_t FileWrapper::FWrite(const void *src, size_t size, ssize_t nmemb, FILE *file) in FWrite() 43 ssize_t FileWrapper::FRead(void *destv, size_t size, ssize_t nmemb, FILE *file) in FRead() 86 void HandleFileError(const std::string &operation, const std::string &filePath, int fileDescriptor, ssize_t result, in HandleFileError() 87 ssize_t expectedSize) in HandleFileError() 103 ssize_t FileMetadataStream::Write(byte *data, ssize_t size) in Write() 110 ssize_t result = fileWrapper_->FWrite(data, 1, size, fp_); in Write() 119 ssize_t FileMetadataStrea [all...] |
H A D | buffer_metadata_stream.cpp | 67 ssize_t BufferMetadataStream::Write(uint8_t *data, ssize_t size) in Write() 137 ssize_t BufferMetadataStream::Read(uint8_t *buf, ssize_t size) in Read() 249 if (src.GetSize() > static_cast<ssize_t>(capacity_)) { in CopyFrom() 264 ssize_t estimatedSize = ((src.GetSize() + METADATA_STREAM_PAGE_SIZE - 1) / METADATA_STREAM_PAGE_SIZE) * in CopyFrom() 287 ssize_t buffer_size = std::min((ssize_t)METADATA_STREAM_PAGE_SIZE, src.GetSize()); in ReadAndWriteData() 297 ssize_t bytesRead = src.Read(tempBuffer, buffer_size); in ReadAndWriteData() 322 ssize_t BufferMetadataStrea [all...] |
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/adaptor/include/ |
H A D | stream_adaptor.h | 43 static ssize_t Encrypt(const void *in, ssize_t inLen, void *out, ssize_t outLen, 45 static ssize_t Decrypt(const void *in, ssize_t inLen, void *out, ssize_t outLen, 47 static ssize_t GetEncryptOverhead();
|
/foundation/communication/ipc/ipc/native/src/core/source/ |
H A D | buffer_object.cpp | 176 ssize_t BufferObject::GetReceiveBufferWriteCursor() const in GetReceiveBufferWriteCursor() 181 void BufferObject::SetReceiveBufferWriteCursor(ssize_t newWriteCursor) in SetReceiveBufferWriteCursor() 186 ssize_t BufferObject::GetReceiveBufferReadCursor() const in GetReceiveBufferReadCursor() 191 void BufferObject::SetReceiveBufferReadCursor(ssize_t newReadCursor) in SetReceiveBufferReadCursor() 196 ssize_t BufferObject::GetSendBufferWriteCursor() const in GetSendBufferWriteCursor() 201 void BufferObject::SetSendBufferWriteCursor(ssize_t newWriteCursor) in SetSendBufferWriteCursor() 206 ssize_t BufferObject::GetSendBufferReadCursor() const in GetSendBufferReadCursor() 211 void BufferObject::SetSendBufferReadCursor(ssize_t newReadCursor) in SetSendBufferReadCursor()
|
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/include/ |
H A D | i_stream.h | 29 ssize_t bufLen = 0; 31 ssize_t extLen = 0; 54 static std::unique_ptr<IStream> MakeRawStream(const char *buf, ssize_t bufLen, const StreamFrameInfo &info, 61 virtual ssize_t GetBufferLen() const = 0; 63 virtual ssize_t GetExtBufferLen() const = 0;
|
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/adaptor/src/ |
H A D | stream_adaptor.cpp | 37 ssize_t StreamAdaptor::GetEncryptOverhead() in GetEncryptOverhead() 116 ssize_t StreamAdaptor::Encrypt(const void *in, ssize_t inLen, void *out, ssize_t outLen, in Encrypt() 143 ssize_t StreamAdaptor::Decrypt(const void *in, ssize_t inLen, void *out, ssize_t outLen, in Decrypt()
|
/foundation/communication/dhcp/test/unittest/services/dhcp_server/unittest/ |
H A D | system_func_mock.h | 34 MOCK_METHOD3(write, ssize_t(int fd, const void *buf, size_t count)); 35 MOCK_METHOD3(read, ssize_t(int fd, void *buf, size_t count)); 43 MOCK_METHOD6(sendto, ssize_t(int __fd, const void *__buf, size_t __n, int __flags, struct sockaddr *__addr, 45 MOCK_METHOD6(recvfrom, ssize_t(int __fd, void *__buf, size_t __n, int __flags, struct sockaddr *__addr,
|
/foundation/multimodalinput/input/frameworks/proxy/module_loader/src/ |
H A D | mmi_fd_listener.cpp | 44 ssize_t recvSize = 0; in OnReadable() 47 ssize_t oneRecvSize = 0; in OnReadable() 49 ssize_t size = recv(fd, szBuf + oneRecvSize, MAX_PACKET_BUF_SIZE - oneRecvSize, in OnReadable()
|
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/benchmarks/ |
H A D | file_utils.cpp | 77 ssize_t nwrite = write(fd, reinterpret_cast<uint8_t *>(data), size); in WriteToFile() 90 ssize_t remaining = static_cast<ssize_t>(str.size()); in WriteStringToFile() 92 ssize_t n = write(fd, p, remaining); in WriteStringToFile()
|
/foundation/communication/dhcp/test/unittest/services/dhcp_client/ |
H A D | mock_system_func.cpp | 66 ssize_t __real_write(int fd, const void *buf, size_t count); 67 ssize_t __wrap_write(int fd, const void *buf, size_t count) in __wrap_write() 76 ssize_t __real_read(int fd, void *buf, size_t count); 77 ssize_t __wrap_read(int fd, void *buf, size_t count) in __wrap_read() 166 ssize_t __real_sendto(int fd, const void *buf, size_t count, int flags, const struct sockaddr *addr, socklen_t len); 167 ssize_t __wrap_sendto(int fd, const void *buf, size_t count, int flags, const struct sockaddr *addr, socklen_t len) in __wrap_sendto()
|
/foundation/communication/netmanager_ext/services/mdnsmanager/include/ |
H A D | mdns_socket_listener.h | 49 ssize_t MulticastAll(const MDnsPayload &payload); 52 ssize_t Multicast(int sock, const MDnsPayload &); 53 ssize_t Unicast(int sock, sockaddr *saddr, const MDnsPayload &);
|
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
H A D | sqlite_global_config.h | 32 static constexpr ssize_t DB_WAL_SIZE_LIMIT_MIN = 20 * 1024 * 1024; /* default wal file maximum size : 20M */
33 static constexpr ssize_t DB_WAL_WARNING_SIZE = 256 * 1024 * 1024; /* default wal file maximum size : 256M */
34 static constexpr ssize_t DB_WAL_SIZE_LIMIT_MAX = 512 * 1024 * 1024; /* default wal file maximum size : 512M */
|
/foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
H A D | socket_util.cpp | 30 ssize_t size = send(sockFd, buf, sendSize, 0); in SocketSendData() 76 ssize_t size = sendmsg(sockFd, &msghdr, 0); in SocketSendFd() 78 ssize_t size = sendmsg(sockFd, &msghdr, MSG_NOSIGNAL); in SocketSendFd()
|