| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/include/ |
| H A D | socket_app.h | 89 #ifndef MSG_DONTWAIT
90 #define MSG_DONTWAIT 0x40 macro
|
| /ohos5.0/foundation/graphic/graphic_2d/utils/socketpair/src/ |
| H A D | local_socketpair.cpp | 141 ssize_t length = TEMP_FAILURE_RETRY(send(sendFd_, vaddr, size, MSG_DONTWAIT | MSG_NOSIGNAL)); in SendData()
166 length = recv(receiveFd_, vaddr, size, MSG_DONTWAIT); in ReceiveData()
|
| /ohos5.0/base/sensors/medical_sensor/utils/src/ |
| H A D | medical_basic_data_channel.cpp | 149 length = send(sendFd_, vaddr, size, MSG_DONTWAIT | MSG_NOSIGNAL); in SendData()
166 length = recv(receiveFd_, vaddr, size, MSG_DONTWAIT); in ReceiveData()
|
| /ohos5.0/base/sensors/sensor/utils/common/src/ |
| H A D | sensor_basic_data_channel.cpp | 161 ssize_t length = send(sendFd_, &sensorData[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendData()
197 length = recv(receiveFd_, vaddr, size, MSG_DONTWAIT | MSG_NOSIGNAL); in ReceiveData()
|
| /ohos5.0/base/msdp/device_status/frameworks/native/src/ |
| H A D | fd_listener.cpp | 42 ssize_t size = recv(fd, szBuf, MAX_PACKET_BUF_SIZE, MSG_DONTWAIT | MSG_NOSIGNAL); in OnReadable()
|
| /ohos5.0/base/sensors/sensor/frameworks/native/src/ |
| H A D | fd_listener.cpp | 46 ssize_t size = recv(fd, szBuf, MAX_DATA_BUF_SIZE, MSG_DONTWAIT | MSG_NOSIGNAL); in OnReadable()
|
| /ohos5.0/foundation/multimodalinput/input/frameworks/proxy/module_loader/src/ |
| H A D | mmi_fd_listener.cpp | 50 MSG_DONTWAIT | MSG_NOSIGNAL); in OnReadable()
|
| /ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/src/ |
| H A D | socket_connection.cpp | 63 numRead = ::recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in OnReadable()
|
| H A D | socket_session.cpp | 79 ssize_t count = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
|
| /ohos5.0/base/msdp/device_status/intention/ipc/socket/src/ |
| H A D | socket_connection.cpp | 63 numRead = ::recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in OnReadable()
|
| H A D | socket_session.cpp | 78 ssize_t count = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
|
| /ohos5.0/foundation/multimodalinput/input/util/socket/src/ |
| H A D | uds_client.cpp | 64 auto count = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
|
| H A D | uds_session.cpp | 73 auto count = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
|
| /ohos5.0/base/msdp/device_status/utils/ipc/src/ |
| H A D | stream_client.cpp | 66 ssize_t number = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
|
| H A D | stream_session.cpp | 61 ssize_t count = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
|
| /ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/ |
| H A D | stream_session.rs | 134 libc::MSG_DONTWAIT | libc::MSG_NOSIGNAL) in session_send_msg()
|
| /ohos5.0/base/startup/init/interfaces/innerkits/fd_holder/ |
| H A D | fd_holder_internal.c | 135 flags |= MSG_DONTWAIT; in ReceiveFds()
|
| /ohos5.0/base/sensors/sensor/utils/ipc/src/ |
| H A D | stream_session.cpp | 70 auto count = send(fd_, &buf[idx], remSize, MSG_DONTWAIT | MSG_NOSIGNAL); in SendMsg()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/ |
| H A D | socket_app.c | 320 if (SOCK_IS_NONBLOCKING(sock) || ((FILLP_UINT32)flags & MSG_DONTWAIT)) { in SockSendReqFpcbItemWithSem()
365 if ((SOCK_IS_NONBLOCKING(sock) || ((FILLP_UINT)flags & MSG_DONTWAIT))) { in SockSendReqFpcbItemWithoutSem()
591 if (SOCK_IS_NONBLOCKING(sock) || ((FILLP_UINT)flags & MSG_DONTWAIT)) { in SockRecvReqFpcbItemWithSem()
629 if ((SOCK_IS_NONBLOCKING(sock) || ((FILLP_UINT32)flags & MSG_DONTWAIT))) { in SockRecvReqFpcbItemWithoutSem()
691 flags = (FILLP_INT)((FILLP_UINT)flags | MSG_DONTWAIT); in SockRecvmsgDataFromBufCache()
|
| /ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/ |
| H A D | netlink_socket_diag.cpp | 121 ssize_t bytesread = recv(fd, &ack, sizeof(ack), MSG_DONTWAIT | MSG_PEEK); in GetErrorFromKernel()
|
| /ohos5.0/base/msdp/device_status/services/native/src/ |
| H A D | stream_server.cpp | 220 ssize_t size = recv(fd, szBuf, MAX_PACKET_BUF_SIZE, MSG_DONTWAIT | MSG_NOSIGNAL); in OnEpollRecv()
|
| /ohos5.0/foundation/multimodalinput/input/service/module_loader/src/ |
| H A D | uds_server.cpp | 267 auto size = recv(fd, szBuf, MAX_PACKET_BUF_SIZE, MSG_DONTWAIT | MSG_NOSIGNAL); in OnEpollRecv()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A D | socket.cpp | 946 auto sendRet = send(fd, buf, len, MSG_DONTWAIT); in SendDataToApp()
|
| /ohos5.0/foundation/communication/dhcp/services/dhcp_client/src/ |
| H A D | dhcp_client_state_machine.cpp | 1994 if (send(m_sigSockFds[1], &signum, sizeof(signum), MSG_DONTWAIT) < 0) { in SendStopSignal()
|