| /net/caif/ |
| A D | caif_socket.c | 319 !timeo) in caif_stream_data_wait()
324 timeo = schedule_timeout(timeo); in caif_stream_data_wait()
350 long timeo; in caif_stream_recvmsg() local
407 timeo = caif_stream_data_wait(sk, timeo); in caif_stream_recvmsg()
471 if (!timeo) in caif_wait_for_flow_on()
486 timeo = schedule_timeout(timeo); in caif_wait_for_flow_on()
523 long timeo; in caif_seqpkt_sendmsg() local
594 long timeo; in caif_stream_sendmsg() local
604 timeo = caif_wait_for_flow_on(cf_sk, 1, timeo, &err); in caif_stream_sendmsg()
742 long timeo; in caif_connect() local
[all …]
|
| /net/sunrpc/ |
| A D | timer.c | 35 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/bluetooth/ |
| A D | af_bluetooth.c | 404 timeo = schedule_timeout(timeo); in bt_sock_data_wait()
411 return timeo; in bt_sock_data_wait()
420 long timeo; in bt_sock_stream_recvmsg() local
448 if (!timeo) in bt_sock_stream_recvmsg()
451 timeo = bt_sock_data_wait(sk, timeo); in bt_sock_stream_recvmsg()
712 if (!timeo) { in bt_sock_wait_state()
718 err = sock_intr_errno(timeo); in bt_sock_wait_state()
723 timeo = schedule_timeout(timeo); in bt_sock_wait_state()
741 unsigned long timeo; in bt_sock_wait_ready() local
751 if (!timeo) { in bt_sock_wait_ready()
[all …]
|
| A D | l2cap_sock.c | 334 long timeo; in l2cap_sock_accept() local
339 timeo = sock_rcvtimeo(sk, arg->flags & O_NONBLOCK); in l2cap_sock_accept()
341 BT_DBG("sk %p timeo %ld", sk, timeo); in l2cap_sock_accept()
355 if (!timeo) { in l2cap_sock_accept()
361 err = sock_intr_errno(timeo); in l2cap_sock_accept()
367 timeo = wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in l2cap_sock_accept()
1272 int timeo = L2CAP_WAIT_ACK_POLL_PERIOD; in __l2cap_wait_ack() local
1283 if (!timeo) in __l2cap_wait_ack()
1284 timeo = L2CAP_WAIT_ACK_POLL_PERIOD; in __l2cap_wait_ack()
1287 err = sock_intr_errno(timeo); in __l2cap_wait_ack()
[all …]
|
| /net/rxrpc/ |
| A D | sendmsg.c | 75 ret = sock_intr_errno(*timeo); in rxrpc_wait_to_be_connected()
78 *timeo = schedule_timeout(*timeo); in rxrpc_wait_to_be_connected()
109 long *timeo) in rxrpc_wait_for_tx_window_intr() argument
120 return sock_intr_errno(*timeo); in rxrpc_wait_for_tx_window_intr()
123 *timeo = schedule_timeout(*timeo); in rxrpc_wait_for_tx_window_intr()
173 long *timeo) in rxrpc_wait_for_tx_window_nonintr() argument
184 *timeo = schedule_timeout(*timeo); in rxrpc_wait_for_tx_window_nonintr()
194 long *timeo, in rxrpc_wait_for_tx_window() argument
329 long timeo; in rxrpc_send_data() local
342 ret = rxrpc_wait_to_be_connected(call, &timeo); in rxrpc_send_data()
[all …]
|
| A D | recvmsg.c | 374 long timeo; in rxrpc_recvmsg() local
384 timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT); in rxrpc_recvmsg()
400 if (timeo == 0) { in rxrpc_recvmsg()
419 timeo = schedule_timeout(timeo); in rxrpc_recvmsg()
565 ret = sock_intr_errno(timeo); in rxrpc_recvmsg()
|
| /net/ipv4/ |
| A D | udp_bpf.c | 39 long timeo) in udp_msg_wait_data() argument
47 if (!timeo) in udp_msg_wait_data()
54 wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in udp_msg_wait_data()
86 long timeo; in udp_bpf_recvmsg() local
89 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in udp_bpf_recvmsg()
90 data = udp_msg_wait_data(sk, psock, timeo); in udp_bpf_recvmsg()
|
| A D | inet_timewait_sock.c | 95 static void inet_twsk_schedule(struct inet_timewait_sock *tw, int timeo) in inet_twsk_schedule() argument
97 __inet_twsk_schedule(tw, timeo, false); in inet_twsk_schedule()
110 int timeo) in inet_twsk_hashdance_schedule() argument
164 inet_twsk_schedule(tw, timeo); in inet_twsk_hashdance_schedule()
269 void __inet_twsk_schedule(struct inet_timewait_sock *tw, int timeo, bool rearm) in __inet_twsk_schedule() argument
297 bool kill = timeo <= 4*HZ; in __inet_twsk_schedule()
301 BUG_ON(mod_timer(&tw->tw_timer, jiffies + timeo)); in __inet_twsk_schedule()
304 mod_timer_pending(&tw->tw_timer, jiffies + timeo); in __inet_twsk_schedule()
|
| A D | tcp_bpf.c | 181 long timeo) in tcp_msg_wait_data() argument
189 if (!timeo) in tcp_msg_wait_data()
194 ret = sk_wait_event(sk, &timeo, in tcp_msg_wait_data()
282 long timeo; in tcp_bpf_recvmsg_parser() local
302 if (!timeo) { in tcp_bpf_recvmsg_parser()
308 copied = sock_intr_errno(timeo); in tcp_bpf_recvmsg_parser()
312 data = tcp_msg_wait_data(sk, psock, timeo); in tcp_bpf_recvmsg_parser()
358 long timeo; in tcp_bpf_recvmsg() local
362 data = tcp_msg_wait_data(sk, psock, timeo); in tcp_bpf_recvmsg()
500 long timeo; in tcp_bpf_sendmsg() local
[all …]
|
| A D | af_inet.c | 596 static long inet_wait_for_connect(struct sock *sk, long timeo, int writebias) in inet_wait_for_connect() argument
610 timeo = wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in inet_wait_for_connect()
612 if (signal_pending(current) || !timeo) in inet_wait_for_connect()
617 return timeo; in inet_wait_for_connect()
629 long timeo; in __inet_stream_connect() local
694 timeo = sock_sndtimeo(sk, flags & O_NONBLOCK); in __inet_stream_connect()
703 if (!timeo || !inet_wait_for_connect(sk, timeo, writebias)) in __inet_stream_connect()
706 err = sock_intr_errno(timeo); in __inet_stream_connect()
|
| A D | inet_connection_sock.c | 611 static int inet_csk_wait_for_connect(struct sock *sk, long timeo) in inet_csk_wait_for_connect() argument
636 timeo = schedule_timeout(timeo); in inet_csk_wait_for_connect()
645 err = sock_intr_errno(timeo); in inet_csk_wait_for_connect()
649 if (!timeo) in inet_csk_wait_for_connect()
678 long timeo = sock_rcvtimeo(sk, arg->flags & O_NONBLOCK); in inet_csk_accept() local
682 if (!timeo) in inet_csk_accept()
685 error = inet_csk_wait_for_connect(sk, timeo); in inet_csk_accept()
|
| /net/unix/ |
| A D | unix_bpf.c | 17 long timeo) in unix_msg_wait_data() argument
26 if (!timeo) in unix_msg_wait_data()
33 wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in unix_msg_wait_data()
79 long timeo; in unix_bpf_recvmsg() local
82 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in unix_bpf_recvmsg()
83 data = unix_msg_wait_data(sk, psock, timeo); in unix_bpf_recvmsg()
|
| A D | af_unix.c | 1639 timeo = schedule_timeout(timeo); in unix_wait_for_peer()
1642 return timeo; in unix_wait_for_peer()
1655 long timeo; in unix_stream_connect() local
1726 timeo = unix_wait_for_peer(other, timeo); in unix_stream_connect()
2106 long timeo; in unix_dgram_sendmsg() local
2273 timeo = unix_wait_for_peer(other, timeo); in unix_dgram_sendmsg()
2587 long timeo; in __unix_dgram_recvmsg() local
2740 !timeo) in unix_stream_data_wait()
2745 timeo = schedule_timeout(timeo); in unix_stream_data_wait()
2933 long timeo; in unix_stream_read_generic() local
[all …]
|
| /net/strparser/ |
| A D | strparser.c | 57 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/vmw_vsock/ |
| A D | vsock_bpf.c | 37 static bool vsock_msg_wait_data(struct sock *sk, struct sk_psock *psock, long timeo) in vsock_msg_wait_data() argument
46 if (!timeo) in vsock_msg_wait_data()
53 wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in vsock_msg_wait_data()
103 long timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in vsock_bpf_recvmsg() local
105 if (!vsock_msg_wait_data(sk, psock, timeo)) { in vsock_bpf_recvmsg()
|
| /net/smc/ |
| A D | smc_rx.c | 256 int smc_rx_wait(struct smc_sock *smc, long *timeo, size_t peeked, in smc_rx_wait() argument
270 rc = sk_wait_event(sk, timeo, in smc_rx_wait()
357 long timeo; in smc_rx_recvmsg() local
369 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in smc_rx_recvmsg()
403 !timeo || in smc_rx_recvmsg()
421 if (!timeo) in smc_rx_recvmsg()
424 read_done = sock_intr_errno(timeo); in smc_rx_recvmsg()
430 smc_rx_wait(smc, &timeo, peeked_bytes, smc_rx_data_available); in smc_rx_recvmsg()
444 smc_rx_wait(smc, &timeo, peeked_bytes, func); in smc_rx_recvmsg()
|
| A D | smc_tx.c | 82 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/llc/ |
| A D | af_llc.c | 523 if (!timeo || !llc_ui_wait_for_conn(sk, timeo)) in llc_ui_connect()
526 rc = sock_intr_errno(timeo); in llc_ui_connect()
660 if (!timeo) in llc_wait_data()
662 rc = sock_intr_errno(timeo); in llc_wait_data()
666 if (sk_wait_data(sk, &timeo, NULL)) in llc_wait_data()
772 long timeo; in llc_ui_recvmsg() local
779 timeo = sock_rcvtimeo(sk, nonblock); in llc_ui_recvmsg()
801 copied = timeo ? sock_intr_errno(timeo) : -EAGAIN; in llc_ui_recvmsg()
821 !timeo || in llc_ui_recvmsg()
846 if (!timeo) { in llc_ui_recvmsg()
[all …]
|
| /net/rds/ |
| A D | recv.c | 643 long timeo; in rds_recvmsg() local
650 timeo = sock_rcvtimeo(sk, nonblock); in rds_recvmsg()
652 rdsdebug("size %zu flags 0x%x timeo %ld\n", size, msg_flags, timeo); in rds_recvmsg()
679 timeo = wait_event_interruptible_timeout(*sk_sleep(sk), in rds_recvmsg()
682 rds_next_incoming(rs, &inc)), timeo); in rds_recvmsg()
684 timeo); in rds_recvmsg()
685 if (timeo > 0 || timeo == MAX_SCHEDULE_TIMEOUT) in rds_recvmsg()
688 ret = timeo; in rds_recvmsg()
|
| /net/nfc/ |
| A D | llcp_sock.c | 17 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()
454 long timeo; in llcp_sock_accept() local
466 timeo = sock_rcvtimeo(sk, arg->flags & O_NONBLOCK); in llcp_sock_accept()
473 if (!timeo) { in llcp_sock_accept()
479 ret = sock_intr_errno(timeo); in llcp_sock_accept()
484 timeo = schedule_timeout(timeo); in llcp_sock_accept()
|
| /net/iucv/ |
| A D | af_iucv.c | 60 long __timeo = timeo; \
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
819 if (!timeo) { in iucv_sock_accept()
825 timeo = schedule_timeout(timeo); in iucv_sock_accept()
834 err = sock_intr_errno(timeo); in iucv_sock_accept()
910 long timeo; in iucv_sock_sendmsg() local
[all …]
|
| /net/bluetooth/rfcomm/ |
| A D | sock.c | 476 long timeo; in rfcomm_sock_accept() local
486 timeo = sock_rcvtimeo(sk, arg->flags & O_NONBLOCK); in rfcomm_sock_accept()
488 BT_DBG("sk %p timeo %ld", sk, timeo); in rfcomm_sock_accept()
502 if (!timeo) { in rfcomm_sock_accept()
508 err = sock_intr_errno(timeo); in rfcomm_sock_accept()
514 timeo = wait_woken(&wait, TASK_INTERRUPTIBLE, timeo); in rfcomm_sock_accept()
|
| /net/tls/ |
| A D | tls_main.c | 141 int wait_on_pending_writer(struct sock *sk, long *timeo) in wait_on_pending_writer() argument
148 if (!*timeo) { in wait_on_pending_writer()
154 rc = sock_intr_errno(*timeo); in wait_on_pending_writer()
158 ret = sk_wait_event(sk, timeo, in wait_on_pending_writer()
344 struct tls_context *ctx, long timeo) in tls_sk_proto_cleanup() argument
347 !wait_on_pending_writer(sk, &timeo)) in tls_sk_proto_cleanup()
372 long timeo = sock_sndtimeo(sk, 0); in tls_sk_proto_close() local
382 tls_sk_proto_cleanup(sk, ctx, timeo); in tls_sk_proto_close()
|
| /net/phonet/ |
| A D | socket.c | 224 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()
|
| /net/bluetooth/cmtp/ |
| A D | capi.c | 368 unsigned long timeo = CMTP_INTEROP_TIMEOUT; in cmtp_register_appl() local
403 if (!timeo) { in cmtp_register_appl()
421 timeo = schedule_timeout(timeo); in cmtp_register_appl()
|