Searched refs:MAX_PACKET_BUF_SIZE (Results 1 - 20 of 20) sorted by relevance
| /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()
|
| /base/sensors/sensor/utils/ipc/include/ |
| H A D | proto.h | 29 static constexpr size_t MAX_PACKET_BUF_SIZE = 256; member
|
| /base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/ |
| H A D | stream_session.rs | 26 const MAX_PACKET_BUF_SIZE: usize = 256; consts
117 if size == 0 || size > MAX_PACKET_BUF_SIZE { in session_send_msg()
118 error!(LOG_LABEL, "size is either equal to 0 or greater than MAX_PACKET_BUF_SIZE, size: {}", size); in session_send_msg()
|
| H A D | epoll_manager.rs | 22 const MAX_PACKET_BUF_SIZE: usize = 256; consts
|
| H A D | stream_buffer.rs | 35 pub const MAX_PACKET_BUF_SIZE: usize = 256; consts
302 if !(0..=MAX_PACKET_BUF_SIZE).contains(&size) { in read_client_packets()
|
| /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 };
|
| /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()
|
| /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()
|
| H A D | socket_session_manager.cpp | 178 char buf[MAX_PACKET_BUF_SIZE] {};
in OnEpollIn()
|
| /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 if ((static_cast<int32_t>(head->size) < 0) || (static_cast<size_t>(head->size) > MAX_PACKET_BUF_SIZE)) {
in OnReadPackets()
|
| /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()
|
| /base/msdp/device_status/intention/services/intention_service/src/ |
| H A D | intention_dumper.cpp | 176 char buf[MAX_PACKET_BUF_SIZE] {}; in CheckDefineOutput()
|
| /base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/ |
| H A D | dsoftbus_adapter_impl.cpp | 204 if (buffer.Size() > MAX_PACKET_BUF_SIZE) { in SendPacket()
246 if (buffer.Size() > MAX_PACKET_BUF_SIZE) { in BroadcastPacket()
556 if ((head->size < 0) || (static_cast<size_t>(head->size) > MAX_PACKET_BUF_SIZE)) { in HandleSessionData()
|
| /base/sensors/sensor/frameworks/native/src/ |
| H A D | sensor_service_client.cpp | 475 if (size == 0 || size > MAX_PACKET_BUF_SIZE) { in ReceiveMessage()
|
Completed in 9 milliseconds