Home
last modified time | relevance | path

Searched refs:timeo (Results 1 – 25 of 52) sorted by relevance

123

/net/caif/
Dcaif_socket.c309 static long caif_stream_data_wait(struct sock *sk, long timeo) in caif_stream_data_wait() argument
323 !timeo) in caif_stream_data_wait()
328 timeo = schedule_timeout(timeo); in caif_stream_data_wait()
339 return timeo; in caif_stream_data_wait()
354 long timeo; in caif_stream_recvmsg() local
370 timeo = sock_rcvtimeo(sk, flags&MSG_DONTWAIT); in caif_stream_recvmsg()
406 if (!timeo) in caif_stream_recvmsg()
411 timeo = caif_stream_data_wait(sk, timeo); in caif_stream_recvmsg()
414 err = sock_intr_errno(timeo); in caif_stream_recvmsg()
465 int wait_writeable, long timeo, int *err) in caif_wait_for_flow_on() argument
[all …]
/net/bluetooth/
Daf_bluetooth.c308 static long bt_sock_data_wait(struct sock *sk, long timeo) in bt_sock_data_wait() argument
322 if (signal_pending(current) || !timeo) in bt_sock_data_wait()
327 timeo = schedule_timeout(timeo); in bt_sock_data_wait()
334 return timeo; in bt_sock_data_wait()
343 long timeo; in bt_sock_stream_recvmsg() local
353 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in bt_sock_stream_recvmsg()
371 if (!timeo) in bt_sock_stream_recvmsg()
374 timeo = bt_sock_data_wait(sk, timeo); in bt_sock_stream_recvmsg()
377 err = sock_intr_errno(timeo); in bt_sock_stream_recvmsg()
540 int bt_sock_wait_state(struct sock *sk, int state, unsigned long timeo) in bt_sock_wait_state() argument
[all …]
Dl2cap_sock.c351 long timeo; in l2cap_sock_accept() local
356 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in l2cap_sock_accept()
358 BT_DBG("sk %p timeo %ld", sk, timeo); in l2cap_sock_accept()
372 if (!timeo) { in l2cap_sock_accept()
378 err = sock_intr_errno(timeo); in l2cap_sock_accept()
384 timeo = wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in l2cap_sock_accept()
1264 int timeo = L2CAP_WAIT_ACK_POLL_PERIOD; in __l2cap_wait_ack() local
1275 if (!timeo) in __l2cap_wait_ack()
1276 timeo = L2CAP_WAIT_ACK_POLL_PERIOD; in __l2cap_wait_ack()
1279 err = sock_intr_errno(timeo); in __l2cap_wait_ack()
[all …]
/net/sunrpc/
Dtimer.c35 void rpc_init_rtt(struct rpc_rtt *rt, unsigned long timeo) in rpc_init_rtt() argument
40 rt->timeo = timeo; in rpc_init_rtt()
42 if (timeo > RPC_RTO_INIT) in rpc_init_rtt()
43 init = (timeo - RPC_RTO_INIT) << 3; in rpc_init_rtt()
115 return rt->timeo; in rpc_calc_rto()
/net/ipv4/
Dudp_bpf.c40 long timeo) in udp_msg_wait_data() argument
48 if (!timeo) in udp_msg_wait_data()
55 wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in udp_msg_wait_data()
87 long timeo; in udp_bpf_recvmsg() local
90 timeo = sock_rcvtimeo(sk, nonblock); in udp_bpf_recvmsg()
91 data = udp_msg_wait_data(sk, psock, timeo); in udp_bpf_recvmsg()
Dtcp_bpf.c157 long timeo) in tcp_msg_wait_data() argument
165 if (!timeo) in tcp_msg_wait_data()
170 ret = sk_wait_event(sk, &timeo, in tcp_msg_wait_data()
202 long timeo; in tcp_bpf_recvmsg_parser() local
221 timeo = sock_rcvtimeo(sk, nonblock); in tcp_bpf_recvmsg_parser()
222 if (!timeo) { in tcp_bpf_recvmsg_parser()
228 copied = sock_intr_errno(timeo); in tcp_bpf_recvmsg_parser()
232 data = tcp_msg_wait_data(sk, psock, timeo); in tcp_bpf_recvmsg_parser()
267 long timeo; in tcp_bpf_recvmsg() local
270 timeo = sock_rcvtimeo(sk, nonblock); in tcp_bpf_recvmsg()
[all …]
Dinet_timewait_sock.c220 void __inet_twsk_schedule(struct inet_timewait_sock *tw, int timeo, bool rearm) in __inet_twsk_schedule() argument
247 tw->tw_kill = timeo <= 4*HZ; in __inet_twsk_schedule()
249 BUG_ON(mod_timer(&tw->tw_timer, jiffies + timeo)); in __inet_twsk_schedule()
252 mod_timer_pending(&tw->tw_timer, jiffies + timeo); in __inet_twsk_schedule()
Dinet_connection_sock.c427 static int inet_csk_wait_for_connect(struct sock *sk, long timeo) in inet_csk_wait_for_connect() argument
452 timeo = schedule_timeout(timeo); in inet_csk_wait_for_connect()
461 err = sock_intr_errno(timeo); in inet_csk_wait_for_connect()
465 if (!timeo) in inet_csk_wait_for_connect()
494 long timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in inet_csk_accept() local
498 if (!timeo) in inet_csk_accept()
501 error = inet_csk_wait_for_connect(sk, timeo); in inet_csk_accept()
878 unsigned long timeo; in reqsk_timer_handler() local
882 timeo = min(TCP_TIMEOUT_INIT << req->num_timeout, TCP_RTO_MAX); in reqsk_timer_handler()
883 mod_timer(&req->rsk_timer, jiffies + timeo); in reqsk_timer_handler()
Dtcp_minisocks.c253 void tcp_time_wait(struct sock *sk, int state, int timeo) in tcp_time_wait() argument
314 if (timeo < rto) in tcp_time_wait()
315 timeo = rto; in tcp_time_wait()
318 timeo = TCP_TIMEWAIT_LEN; in tcp_time_wait()
325 inet_twsk_schedule(tw, timeo); in tcp_time_wait()
/net/unix/
Dunix_bpf.c16 long timeo) in unix_msg_wait_data() argument
25 if (!timeo) in unix_msg_wait_data()
32 wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in unix_msg_wait_data()
76 long timeo; in unix_bpf_recvmsg() local
79 timeo = sock_rcvtimeo(sk, nonblock); in unix_bpf_recvmsg()
80 data = unix_msg_wait_data(sk, psock, timeo); in unix_bpf_recvmsg()
Daf_unix.c1297 static long unix_wait_for_peer(struct sock *other, long timeo) in unix_wait_for_peer() argument
1313 timeo = schedule_timeout(timeo); in unix_wait_for_peer()
1316 return timeo; in unix_wait_for_peer()
1332 long timeo; in unix_stream_connect() local
1343 timeo = sock_sndtimeo(sk, flags & O_NONBLOCK); in unix_stream_connect()
1389 if (!timeo) in unix_stream_connect()
1392 timeo = unix_wait_for_peer(other, timeo); in unix_stream_connect()
1394 err = sock_intr_errno(timeo); in unix_stream_connect()
1766 long timeo; in unix_dgram_sendmsg() local
1827 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in unix_dgram_sendmsg()
[all …]
/net/smc/
Dsmc_rx.c192 int smc_rx_wait(struct smc_sock *smc, long *timeo, in smc_rx_wait() argument
206 rc = sk_wait_event(sk, timeo, in smc_rx_wait()
293 long timeo; in smc_rx_recvmsg() local
305 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in smc_rx_recvmsg()
339 !timeo || in smc_rx_recvmsg()
357 if (!timeo) in smc_rx_recvmsg()
360 read_done = sock_intr_errno(timeo); in smc_rx_recvmsg()
366 smc_rx_wait(smc, &timeo, smc_rx_data_available); in smc_rx_recvmsg()
380 smc_rx_wait(smc, &timeo, func); in smc_rx_recvmsg()
Dsmc_tx.c82 long timeo; in smc_tx_wait() local
86 timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in smc_tx_wait()
101 if (!timeo) { in smc_tx_wait()
108 rc = sock_intr_errno(timeo); in smc_tx_wait()
115 sk_wait_event(sk, &timeo, in smc_tx_wait()
/net/rxrpc/
Dsendmsg.c40 long *timeo) in rxrpc_wait_for_tx_window_intr() argument
51 return sock_intr_errno(*timeo); in rxrpc_wait_for_tx_window_intr()
54 *timeo = schedule_timeout(*timeo); in rxrpc_wait_for_tx_window_intr()
105 long *timeo) in rxrpc_wait_for_tx_window_nonintr() argument
116 *timeo = schedule_timeout(*timeo); in rxrpc_wait_for_tx_window_nonintr()
126 long *timeo, in rxrpc_wait_for_tx_window() argument
142 ret = rxrpc_wait_for_tx_window_intr(rx, call, timeo); in rxrpc_wait_for_tx_window()
147 ret = rxrpc_wait_for_tx_window_nonintr(rx, call, timeo); in rxrpc_wait_for_tx_window()
297 long timeo; in rxrpc_send_data() local
301 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in rxrpc_send_data()
[all …]
Drecvmsg.c493 long timeo; in rxrpc_recvmsg() local
503 timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT); in rxrpc_recvmsg()
518 if (timeo == 0) { in rxrpc_recvmsg()
537 timeo = schedule_timeout(timeo); in rxrpc_recvmsg()
658 ret = sock_intr_errno(timeo); in rxrpc_recvmsg()
/net/strparser/
Dstrparser.c57 static void strp_start_timer(struct strparser *strp, long timeo) in strp_start_timer() argument
59 if (timeo && timeo != LONG_MAX) in strp_start_timer()
60 mod_delayed_work(strp_wq, &strp->msg_timer_work, timeo); in strp_start_timer()
91 size_t max_msg_size, long timeo) in __strp_recv() argument
219 strp_start_timer(strp, timeo); in __strp_recv()
269 strp_start_timer(strp, timeo); in __strp_recv()
319 size_t max_msg_size, long timeo) in strp_process() argument
326 max_msg_size, timeo); in strp_process()
/net/dccp/
Dminisocks.c31 void dccp_time_wait(struct sock *sk, int state, int timeo) in dccp_time_wait() argument
49 if (timeo < rto) in dccp_time_wait()
50 timeo = rto; in dccp_time_wait()
53 timeo = DCCP_TIMEWAIT_LEN; in dccp_time_wait()
60 inet_twsk_schedule(tw, timeo); in dccp_time_wait()
Dproto.c751 long timeo; in dccp_sendmsg() local
760 timeo = sock_sndtimeo(sk, noblock); in dccp_sendmsg()
768 if ((rc = sk_stream_wait_connect(sk, &timeo)) != 0) in dccp_sendmsg()
825 long timeo; in dccp_recvmsg() local
834 timeo = sock_rcvtimeo(sk, nonblock); in dccp_recvmsg()
892 if (!timeo) { in dccp_recvmsg()
898 len = sock_intr_errno(timeo); in dccp_recvmsg()
902 sk_wait_data(sk, &timeo, NULL); in dccp_recvmsg()
/net/llc/
Daf_llc.c519 const long timeo = sock_sndtimeo(sk, flags & O_NONBLOCK); in llc_ui_connect() local
521 if (!timeo || !llc_ui_wait_for_conn(sk, timeo)) in llc_ui_connect()
524 rc = sock_intr_errno(timeo); in llc_ui_connect()
643 static int llc_wait_data(struct sock *sk, long timeo) in llc_wait_data() argument
658 if (!timeo) in llc_wait_data()
660 rc = sock_intr_errno(timeo); in llc_wait_data()
664 if (sk_wait_data(sk, &timeo, NULL)) in llc_wait_data()
771 long timeo; in llc_ui_recvmsg() local
778 timeo = sock_rcvtimeo(sk, nonblock); in llc_ui_recvmsg()
800 copied = timeo ? sock_intr_errno(timeo) : -EAGAIN; in llc_ui_recvmsg()
[all …]
/net/rds/
Drecv.c638 long timeo; in rds_recvmsg() local
645 timeo = sock_rcvtimeo(sk, nonblock); in rds_recvmsg()
647 rdsdebug("size %zu flags 0x%x timeo %ld\n", size, msg_flags, timeo); in rds_recvmsg()
674 timeo = wait_event_interruptible_timeout(*sk_sleep(sk), in rds_recvmsg()
677 rds_next_incoming(rs, &inc)), timeo); in rds_recvmsg()
679 timeo); in rds_recvmsg()
680 if (timeo > 0 || timeo == MAX_SCHEDULE_TIMEOUT) in rds_recvmsg()
683 ret = timeo; in rds_recvmsg()
/net/nfc/
Dllcp_sock.c17 static int sock_wait_state(struct sock *sk, int state, unsigned long timeo) in sock_wait_state() argument
28 if (!timeo) { in sock_wait_state()
34 err = sock_intr_errno(timeo); in sock_wait_state()
39 timeo = schedule_timeout(timeo); in sock_wait_state()
449 long timeo; in llcp_sock_accept() local
461 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in llcp_sock_accept()
468 if (!timeo) { in llcp_sock_accept()
474 ret = sock_intr_errno(timeo); in llcp_sock_accept()
479 timeo = schedule_timeout(timeo); in llcp_sock_accept()
/net/tls/
Dtls_main.c78 int wait_on_pending_writer(struct sock *sk, long *timeo) in wait_on_pending_writer() argument
85 if (!*timeo) { in wait_on_pending_writer()
91 rc = sock_intr_errno(*timeo); in wait_on_pending_writer()
95 if (sk_wait_event(sk, timeo, in wait_on_pending_writer()
274 struct tls_context *ctx, long timeo) in tls_sk_proto_cleanup() argument
277 !wait_on_pending_writer(sk, &timeo)) in tls_sk_proto_cleanup()
304 long timeo = sock_sndtimeo(sk, 0); in tls_sk_proto_close() local
314 tls_sk_proto_cleanup(sk, ctx, timeo); in tls_sk_proto_close()
/net/iucv/
Daf_iucv.c55 #define __iucv_sock_wait(sk, condition, timeo, ret) \ argument
58 long __timeo = timeo; \
80 #define iucv_sock_wait(sk, condition, timeo) \ argument
84 __iucv_sock_wait(sk, condition, timeo, __ret); \
382 unsigned long timeo; in iucv_sock_close() local
406 timeo = sk->sk_lingertime; in iucv_sock_close()
408 timeo = IUCV_DISCONN_TIMEOUT; in iucv_sock_close()
411 timeo); in iucv_sock_close()
803 long timeo; in iucv_sock_accept() local
813 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in iucv_sock_accept()
[all …]
/net/bluetooth/rfcomm/
Dsock.c483 long timeo; in rfcomm_sock_accept() local
493 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in rfcomm_sock_accept()
495 BT_DBG("sk %p timeo %ld", sk, timeo); in rfcomm_sock_accept()
509 if (!timeo) { in rfcomm_sock_accept()
515 err = sock_intr_errno(timeo); in rfcomm_sock_accept()
521 timeo = wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in rfcomm_sock_accept()
/net/phonet/
Dsocket.c224 long timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in pn_socket_connect() local
265 if (!timeo) { in pn_socket_connect()
270 err = sock_intr_errno(timeo); in pn_socket_connect()
277 timeo = schedule_timeout(timeo); in pn_socket_connect()

123