/ohos5.0/base/msdp/device_status/frameworks/native/src/ |
H A D | fd_listener.cpp | 40 char szBuf[MAX_PACKET_BUF_SIZE] = { 0 }; in OnReadable() 42 ssize_t size = recv(fd, szBuf, MAX_PACKET_BUF_SIZE, MSG_DONTWAIT | MSG_NOSIGNAL); in OnReadable() 58 if (static_cast<size_t>(size) < MAX_PACKET_BUF_SIZE) { in OnReadable()
|
H A D | client.cpp | 180 if (size == 0 || size > MAX_PACKET_BUF_SIZE) { in OnRecvMsg()
|
/ohos5.0/foundation/multimodalinput/input/frameworks/proxy/module_loader/src/ |
H A D | mmi_fd_listener.cpp | 43 char szBuf[MAX_PACKET_BUF_SIZE] = {}; in OnReadable() 48 while (oneRecvSize < MAX_PACKET_BUF_SIZE) { in OnReadable() 49 ssize_t size = recv(fd, szBuf + oneRecvSize, MAX_PACKET_BUF_SIZE - oneRecvSize, in OnReadable()
|
/ohos5.0/foundation/multimodalinput/input/util/common/include/ |
H A D | config_multimodal.h | 34 #define MAX_PACKET_BUF_SIZE (1024*8) macro 36 #define MAX_STREAM_BUF_SIZE (MAX_PACKET_BUF_SIZE*2)
|
/ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/ |
H A D | stream_session.rs | 26 const MAX_PACKET_BUF_SIZE: usize = 256; const 117 if size == 0 || size > MAX_PACKET_BUF_SIZE { in session_send_msg()
|
H A D | epoll_manager.rs | 22 const MAX_PACKET_BUF_SIZE: usize = 256; const
|
H A D | stream_buffer.rs | 35 pub const MAX_PACKET_BUF_SIZE: usize = 256; const 300 if !(0..=MAX_PACKET_BUF_SIZE).contains(&size) { in read_client_packets()
|
/ohos5.0/base/msdp/device_status/services/native/src/ |
H A D | devicestatus_dumper.cpp | 383 char buf[MAX_PACKET_BUF_SIZE] = { 0 }; in CheckDefineOutput() 384 int32_t ret = snprintf_s(buf, MAX_PACKET_BUF_SIZE, MAX_PACKET_BUF_SIZE - 1, fmt, args...); in CheckDefineOutput()
|
H A D | stream_server.cpp | 218 char szBuf[MAX_PACKET_BUF_SIZE] = { 0 }; in OnEpollRecv() 220 ssize_t size = recv(fd, szBuf, MAX_PACKET_BUF_SIZE, MSG_DONTWAIT | MSG_NOSIGNAL); in OnEpollRecv() 239 if (static_cast<size_t>(size) < MAX_PACKET_BUF_SIZE) { in OnEpollRecv()
|
/ohos5.0/base/sensors/sensor/utils/ipc/include/ |
H A D | proto.h | 29 static constexpr size_t MAX_PACKET_BUF_SIZE = 256; variable
|
/ohos5.0/foundation/multimodalinput/input/service/module_loader/src/ |
H A D | uds_server.cpp | 265 char szBuf[MAX_PACKET_BUF_SIZE] = {}; in OnEpollRecv() 267 auto size = recv(fd, szBuf, MAX_PACKET_BUF_SIZE, MSG_DONTWAIT | MSG_NOSIGNAL); in OnEpollRecv() 286 if (size < MAX_PACKET_BUF_SIZE) { in OnEpollRecv()
|
/ohos5.0/base/msdp/device_status/utils/common/include/ |
H A D | proto.h | 29 inline constexpr size_t MAX_PACKET_BUF_SIZE { MAX_STREAM_BUF_SIZE };
|
/ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/src/ |
H A D | socket_connection.cpp | 59 char buf[MAX_PACKET_BUF_SIZE] {}; in OnReadable()
|
H A D | socket_session.cpp | 62 if ((size == 0) || (size > MAX_PACKET_BUF_SIZE)) { in SendMsg()
|
/ohos5.0/base/msdp/device_status/intention/ipc/socket/src/ |
H A D | socket_connection.cpp | 59 char buf[MAX_PACKET_BUF_SIZE] {}; in OnReadable()
|
H A D | socket_session.cpp | 61 if ((size == 0) || (size > MAX_PACKET_BUF_SIZE)) { in SendMsg()
|
/ohos5.0/base/sensors/sensor/utils/ipc/src/ |
H A D | stream_socket.cpp | 54 if (head->size < 0 || head->size > MAX_PACKET_BUF_SIZE) { in OnReadPackets()
|
H A D | stream_session.cpp | 57 if ((size == 0) || (size > MAX_PACKET_BUF_SIZE)) { in SendMsg()
|
/ohos5.0/foundation/multimodalinput/input/util/socket/src/ |
H A D | uds_client.cpp | 49 if ((size == 0) || (size > MAX_PACKET_BUF_SIZE)) { in SendMsg()
|
H A D | uds_socket.cpp | 103 if (head->size < 0 || head->size > MAX_PACKET_BUF_SIZE) { in OnReadPackets()
|
/ohos5.0/base/msdp/device_status/utils/ipc/src/ |
H A D | stream_client.cpp | 51 if ((size == 0) || (size > MAX_PACKET_BUF_SIZE)) { in SendMsg()
|
H A D | stream_session.cpp | 46 if ((size == 0) || (size > MAX_PACKET_BUF_SIZE)) { in SendMsg()
|
H A D | stream_socket.cpp | 85 …static_cast<int32_t>(head->size) < 0) || (static_cast<size_t>(head->size) > MAX_PACKET_BUF_SIZE)) { in OnReadPackets()
|
/ohos5.0/foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/src/ |
H A D | dsoftbus_adapter_impl.cpp | 198 if (buffer.Size() > MAX_PACKET_BUF_SIZE) { in SendPacket() 240 if (buffer.Size() > MAX_PACKET_BUF_SIZE) { in BroadcastPacket() 542 if ((head->size < 0) || (static_cast<size_t>(head->size) > MAX_PACKET_BUF_SIZE)) { in HandleSessionData()
|
/ohos5.0/base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/ |
H A D | dsoftbus_adapter_impl.cpp | 193 if (buffer.Size() > MAX_PACKET_BUF_SIZE) { in SendPacket() 235 if (buffer.Size() > MAX_PACKET_BUF_SIZE) { in BroadcastPacket() 544 if ((head->size < 0) || (static_cast<size_t>(head->size) > MAX_PACKET_BUF_SIZE)) { in HandleSessionData()
|