| /system/bt/btif/src/ |
| D | btif_sock_util.cc | 55 OSI_NO_INTR(ret = send(sock_fd, buf, s, 0)); in sock_send_all()
70 OSI_NO_INTR(ret = recv(sock_fd, buf, r, MSG_WAITALL)); in sock_recv_all()
113 OSI_NO_INTR(ret = sendmsg(sock_fd, &msg, MSG_NOSIGNAL)); in sock_send_fd()
|
| D | btif_sock_thread.cc | 239 OSI_NO_INTR(ret = send(ts[h].cmd_fdw, &cmd, sizeof(cmd), 0)); in btsock_thread_add_fd()
257 OSI_NO_INTR(ret = send(ts[thread_handle].cmd_fdw, &cmd, sizeof(cmd), 0)); in btsock_thread_remove_fd_and_close()
290 OSI_NO_INTR(ret = send(ts[h].cmd_fdw, cmd_send, size_send, 0)); in btsock_thread_post_cmd()
306 OSI_NO_INTR(ret = send(ts[h].cmd_fdw, &cmd, sizeof(cmd), 0)); in btsock_thread_wakeup()
322 OSI_NO_INTR(ret = send(ts[h].cmd_fdw, &cmd, sizeof(cmd), 0)); in btsock_thread_exit()
409 OSI_NO_INTR(ret = recv(fd, &cmd, sizeof(cmd), MSG_WAITALL)); in process_cmd_sock()
503 OSI_NO_INTR(ret = poll(pfds, ts[h].poll_count, -1)); in sock_poll_thread()
|
| D | btif_pan.cc | 412 OSI_NO_INTR(ret = write(tap_fd, packet, len + sizeof(tETH_HDR))); in btpan_tap_send()
672 OSI_NO_INTR(ret = read(fd, btpan_cb.congest_packet, in btu_exec_tap_fd_read()
724 OSI_NO_INTR(ret = poll(&ufd, 1, 0)); in btu_exec_tap_fd_read()
|
| D | btif_sock_l2cap.cc | 812 OSI_NO_INTR(sent = send(sock->our_fd, buf, len, MSG_DONTWAIT)); in flush_incoming_que_on_wr_signal_l()
872 OSI_NO_INTR(count = recv(fd, get_l2cap_sdu_start_ptr(buffer), size, in btsock_l2cap_signaled()
|
| D | btif_sock_rfc.cc | 783 OSI_NO_INTR( in send_data_to_app()
937 OSI_NO_INTR(received = recv(slot->fd, buf, size, 0)); in bta_co_rfc_data_outgoing()
|
| D | btif_rc.cc | 5505 OSI_NO_INTR(nanosleep(&delay, &delay)); in sleep_ms()
|
| /system/bt/hci/src/ |
| D | btsnoop_net.cc | 84 OSI_NO_INTR(ret = send(client_socket_, data, length, 0)); in btsnoop_net_write()
125 OSI_NO_INTR(client_socket = accept(listen_socket_, NULL, NULL)); in listen_fn_()
140 OSI_NO_INTR(send(client_socket_, "btsnoop\0\0\0\0\1\0\0\x3\xea", 16, 0)); in listen_fn_()
|
| D | hci_layer_linux.cc | 315 OSI_NO_INTR(wrote = write(fd, &ev, 6)); in wait_hcidev()
324 OSI_NO_INTR(n = poll(fds, 1, MGMT_EV_POLL_TIMEOUT)); in wait_hcidev()
336 OSI_NO_INTR(n = read(fd, &ev, sizeof(struct mgmt_pkt))); in wait_hcidev()
384 OSI_NO_INTR(len = write(fd, &event, sizeof(event))); in rfkill()
|
| /system/bt/osi/src/ |
| D | socket.cc | 118 OSI_NO_INTR(fd = accept(socket->fd, NULL, NULL)); in socket_accept()
135 OSI_NO_INTR(ret = recv(socket->fd, buf, count, MSG_DONTWAIT)); in socket_read()
145 OSI_NO_INTR(ret = send(socket->fd, buf, count, MSG_DONTWAIT)); in socket_write()
178 OSI_NO_INTR(ret = sendmsg(socket->fd, &msg, MSG_DONTWAIT)); in socket_write_and_transfer_fd()
|
| D | reactor.cc | 246 OSI_NO_INTR(ret = epoll_wait(reactor->epoll_fd, events, MAX_EVENTS, -1)); in run_reactor()
|
| /system/bt/udrv/ulinux/ |
| D | uipc.cc | 148 OSI_NO_INTR(poll_ret = poll(&pfd, 1, 0)); in accept_server_socket()
156 OSI_NO_INTR(fd = accept(sfd, (struct sockaddr*)&remote, &len)); in accept_server_socket()
290 OSI_NO_INTR( in uipc_check_interrupt_locked()
299 OSI_NO_INTR(send(uipc.signal_fds[1], &sig_on, sizeof(sig_on), 0)); in uipc_wakeup_locked()
347 OSI_NO_INTR(ret = poll(&pfd, 1, 1)); in uipc_flush_ch_locked()
603 OSI_NO_INTR(ret = write(uipc.ch[ch_id].fd, p_buf, msglen)); in UIPC_Send()
646 OSI_NO_INTR(poll_ret = poll(&pfd, 1, uipc.ch[ch_id].read_poll_tmo_ms)); in UIPC_Read()
668 OSI_NO_INTR(n = recv(fd, p_buf + n_read, len - n_read, 0)); in UIPC_Read()
|
| /system/bt/osi/include/ |
| D | osi.h | 56 #define OSI_NO_INTR(fn) \ macro
|
| /system/bt/vendor_libs/test_vendor_lib/model/devices/ |
| D | server_port_factory.cc | 40 OSI_NO_INTR(listen_fd_ = socket(AF_INET, SOCK_STREAM, 0)); in SetUp()
81 …OSI_NO_INTR(accept_fd = accept(listen_fd_, reinterpret_cast<sockaddr*>(&test_channel_address), &so… in Accept()
|
| /system/bt/service/ipc/ |
| D | linux_ipc_host.cc | 250 OSI_NO_INTR(size = in OnMessage()
261 OSI_NO_INTR(size = read(pfds_[kFdIpc].fd, &ipc_msg[0], ipc_msg.size())); in OnMessage()
310 OSI_NO_INTR(r = read(pfds_[kFdGatt].fd, id.data(), id.size())); in OnGattWrite()
329 OSI_NO_INTR(r = write(pfds_[kFdIpc].fd, transmit.data(), transmit.size())); in OnGattWrite()
|
| /system/bt/vendor_libs/test_vendor_lib/model/setup/ |
| D | test_channel_transport.cc | 37 OSI_NO_INTR(listen_fd_ = socket(AF_INET, SOCK_STREAM, 0)); in SetUp()
80 OSI_NO_INTR(accept_fd = accept(listen_fd, NULL, NULL)); in Accept()
|
| /system/bt/osi/src/socket_utils/ |
| D | socket_local_client.cc | 124 OSI_NO_INTR(err = connect(fd, (struct sockaddr*)&addr, alen)); in osi_socket_local_client_connect()
|
| /system/bt/btif/co/ |
| D | bta_hh_co.cc | 64 OSI_NO_INTR(ret = write(fd, ev, sizeof(*ev))); in uhid_write()
87 OSI_NO_INTR(ret = read(p_dev->fd, &ev, sizeof(ev))); in uhid_read_event()
256 OSI_NO_INTR(ret = poll(pfds, 1, 50)); in btif_hh_poll_event_thread()
|
| /system/bt/tools/hci/ |
| D | main.c | 187 OSI_NO_INTR(ret = connect(sock, (const struct sockaddr*)&addr, sizeof(addr))); in write_hci_command()
|
| /system/bt/audio_hearing_aid_hw/src/ |
| D | audio_hearing_aid_hw.cc | 296 OSI_NO_INTR(read = recv(fd, p, len, MSG_NOSIGNAL)); in skt_read()
310 OSI_NO_INTR(sent = send(fd, p, len, MSG_NOSIGNAL)); in skt_write()
320 OSI_NO_INTR(sent = send(fd, p, len - count, MSG_NOSIGNAL | MSG_DONTWAIT)); in skt_write()
362 OSI_NO_INTR(ret = recv(common->ctrl_fd, buffer, length, MSG_NOSIGNAL)); in ha_ctrl_receive()
399 OSI_NO_INTR(sent = send(common->ctrl_fd, buffer, remaining, MSG_NOSIGNAL)); in ha_ctrl_send()
446 OSI_NO_INTR(sent = send(common->ctrl_fd, &cmd, 1, MSG_NOSIGNAL)); in ha_command()
|
| /system/bt/audio_a2dp_hw/src/ |
| D | audio_a2dp_hw.cc | 290 OSI_NO_INTR(read = recv(fd, p, len, MSG_NOSIGNAL)); in skt_read()
304 OSI_NO_INTR(sent = send(fd, p, len, MSG_NOSIGNAL)); in skt_write()
314 OSI_NO_INTR(sent = send(fd, p, len - count, MSG_NOSIGNAL | MSG_DONTWAIT)); in skt_write()
356 OSI_NO_INTR(ret = recv(common->ctrl_fd, buffer, length, MSG_NOSIGNAL)); in a2dp_ctrl_receive()
393 OSI_NO_INTR(sent = send(common->ctrl_fd, buffer, remaining, MSG_NOSIGNAL)); in a2dp_ctrl_send()
441 OSI_NO_INTR(sent = send(common->ctrl_fd, &cmd, 1, MSG_NOSIGNAL)); in a2dp_command()
|
| /system/bt/service/ |
| D | gatt_server_old.cc | 284 OSI_NO_INTR(status = write(g_internal->pipefd[kPipeWriteEnd], in RequestWriteCallback()
325 OSI_NO_INTR(status = write(g_internal->pipefd[kPipeWriteEnd], uuid.data(), in RequestExecWriteCallback()
|
| /system/bt/common/ |
| D | metrics.cc | 477 OSI_NO_INTR(ret = write(fd, protoBase64.c_str(), protoBase64.size())); in WriteBase64()
|