diff options
Diffstat (limited to 'btif/src/btif_hl.c')
| -rw-r--r-- | btif/src/btif_hl.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/btif/src/btif_hl.c b/btif/src/btif_hl.c index d9e0d1f46..cbce15f7b 100644 --- a/btif/src/btif_hl.c +++ b/btif/src/btif_hl.c @@ -4795,8 +4795,8 @@ void btif_hl_select_monitor_callback(fd_set *p_cur_set ,fd_set *p_org_set) { } p_dcb->p_tx_pkt = btif_hl_get_buf (p_dcb->mtu); if (p_dcb) { - int r = (int)recv(p_scb->socket_id[1], p_dcb->p_tx_pkt, - p_dcb->mtu, MSG_DONTWAIT); + int r = (int)TEMP_FAILURE_RETRY(recv(p_scb->socket_id[1], p_dcb->p_tx_pkt, + p_dcb->mtu, MSG_DONTWAIT)); if (r > 0) { BTIF_TRACE_DEBUG("btif_hl_select_monitor_callback send data r =%d", r); p_dcb->tx_size = r; @@ -4852,7 +4852,7 @@ static inline int btif_hl_select_wakeup_init(fd_set* set){ static inline int btif_hl_select_wakeup(void){ char sig_on = btif_hl_signal_select_wakeup; BTIF_TRACE_DEBUG("btif_hl_select_wakeup"); - return send(signal_fds[1], &sig_on, sizeof(sig_on), 0); + return TEMP_FAILURE_RETRY(send(signal_fds[1], &sig_on, sizeof(sig_on), 0)); } /******************************************************************************* @@ -4867,7 +4867,7 @@ static inline int btif_hl_select_wakeup(void){ static inline int btif_hl_select_close_connected(void){ char sig_on = btif_hl_signal_select_close_connected; BTIF_TRACE_DEBUG("btif_hl_select_close_connected"); - return send(signal_fds[1], &sig_on, sizeof(sig_on), 0); + return TEMP_FAILURE_RETRY(send(signal_fds[1], &sig_on, sizeof(sig_on), 0)); } /******************************************************************************* @@ -4884,7 +4884,7 @@ static inline int btif_hl_close_select_thread(void) int result = 0; char sig_on = btif_hl_signal_select_exit; BTIF_TRACE_DEBUG("btif_hl_signal_select_exit"); - result = send(signal_fds[1], &sig_on, sizeof(sig_on), 0); + result = TEMP_FAILURE_RETRY(send(signal_fds[1], &sig_on, sizeof(sig_on), 0)); if (btif_is_enabled()) { /* Wait for the select_thread_id to exit if BT is still enabled @@ -4911,7 +4911,7 @@ static inline int btif_hl_select_wake_reset(void){ char sig_recv = 0; BTIF_TRACE_DEBUG("btif_hl_select_wake_reset"); - recv(signal_fds[0], &sig_recv, sizeof(sig_recv), MSG_WAITALL); + TEMP_FAILURE_RETRY(recv(signal_fds[0], &sig_recv, sizeof(sig_recv), MSG_WAITALL)); return(int)sig_recv; } /******************************************************************************* @@ -4972,7 +4972,7 @@ static void *btif_hl_select_thread(void *arg){ BTIF_TRACE_DEBUG("set curr_set = org_set "); curr_set = org_set; max_curr_s = max_org_s; - int ret = select((max_curr_s + 1), &curr_set, NULL, NULL, NULL); + int ret = TEMP_FAILURE_RETRY(select((max_curr_s + 1), &curr_set, NULL, NULL, NULL)); BTIF_TRACE_DEBUG("select unblocked ret=%d", ret); if (ret == -1) { |