Home
last modified time | relevance | path

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

12

/net/caif/
Dcaif_socket.c316 static long caif_stream_data_wait(struct sock *sk, long timeo) in caif_stream_data_wait() argument
330 !timeo) in caif_stream_data_wait()
335 timeo = schedule_timeout(timeo); in caif_stream_data_wait()
346 return timeo; in caif_stream_data_wait()
362 long timeo; in caif_stream_recvmsg() local
380 timeo = sock_rcvtimeo(sk, flags&MSG_DONTWAIT); in caif_stream_recvmsg()
416 if (!timeo) in caif_stream_recvmsg()
421 timeo = caif_stream_data_wait(sk, timeo); in caif_stream_recvmsg()
424 err = sock_intr_errno(timeo); in caif_stream_recvmsg()
475 int wait_writeable, long timeo, int *err) in caif_wait_for_flow_on() argument
[all …]
/net/sunrpc/
Dtimer.c34 void rpc_init_rtt(struct rpc_rtt *rt, unsigned long timeo) in rpc_init_rtt() argument
39 rt->timeo = timeo; in rpc_init_rtt()
41 if (timeo > RPC_RTO_INIT) in rpc_init_rtt()
42 init = (timeo - RPC_RTO_INIT) << 3; in rpc_init_rtt()
114 return rt->timeo; in rpc_calc_rto()
/net/bluetooth/
Daf_bluetooth.c284 static long bt_sock_data_wait(struct sock *sk, long timeo) in bt_sock_data_wait() argument
298 if (signal_pending(current) || !timeo) in bt_sock_data_wait()
303 timeo = schedule_timeout(timeo); in bt_sock_data_wait()
310 return timeo; in bt_sock_data_wait()
319 long timeo; in bt_sock_stream_recvmsg() local
331 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in bt_sock_stream_recvmsg()
349 if (!timeo) in bt_sock_stream_recvmsg()
352 timeo = bt_sock_data_wait(sk, timeo); in bt_sock_stream_recvmsg()
355 err = sock_intr_errno(timeo); in bt_sock_stream_recvmsg()
527 int bt_sock_wait_state(struct sock *sk, int state, unsigned long timeo) in bt_sock_wait_state() argument
[all …]
Dsco.c575 long timeo; in sco_sock_accept() local
580 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in sco_sock_accept()
582 BT_DBG("sk %p timeo %ld", sk, timeo); in sco_sock_accept()
598 if (!timeo) { in sco_sock_accept()
604 err = sock_intr_errno(timeo); in sco_sock_accept()
609 timeo = schedule_timeout(timeo); in sco_sock_accept()
Dl2cap_sock.c201 long timeo; in l2cap_sock_accept() local
206 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in l2cap_sock_accept()
208 BT_DBG("sk %p timeo %ld", sk, timeo); in l2cap_sock_accept()
224 if (!timeo) { in l2cap_sock_accept()
230 err = sock_intr_errno(timeo); in l2cap_sock_accept()
235 timeo = schedule_timeout(timeo); in l2cap_sock_accept()
/net/decnet/
Daf_decnet.c819 static int dn_confirm_accept(struct sock *sk, long *timeo, gfp_t allocation) in dn_confirm_accept() argument
836 *timeo = schedule_timeout(*timeo); in dn_confirm_accept()
844 err = sock_intr_errno(*timeo); in dn_confirm_accept()
848 if (!*timeo) in dn_confirm_accept()
861 static int dn_wait_run(struct sock *sk, long *timeo) in dn_wait_run() argument
870 if (!*timeo) in dn_wait_run()
877 *timeo = schedule_timeout(*timeo); in dn_wait_run()
885 err = sock_intr_errno(*timeo); in dn_wait_run()
889 if (!*timeo) in dn_wait_run()
903 static int __dn_connect(struct sock *sk, struct sockaddr_dn *addr, int addrlen, long *timeo, int fl… in __dn_connect() argument
[all …]
/net/rds/
Drecv.c403 long timeo; in rds_recvmsg() local
409 timeo = sock_rcvtimeo(sk, nonblock); in rds_recvmsg()
411 rdsdebug("size %zu flags 0x%x timeo %ld\n", size, msg_flags, timeo); in rds_recvmsg()
436 timeo = wait_event_interruptible_timeout(*sk_sleep(sk), in rds_recvmsg()
439 rds_next_incoming(rs, &inc)), timeo); in rds_recvmsg()
441 timeo); in rds_recvmsg()
442 if (timeo > 0 || timeo == MAX_SCHEDULE_TIMEOUT) in rds_recvmsg()
445 ret = timeo; in rds_recvmsg()
Dsend.c933 long timeo = sock_sndtimeo(sk, nonblock); in rds_sendmsg() local
1045 timeo = wait_event_interruptible_timeout(*sk_sleep(sk), in rds_sendmsg()
1050 timeo); in rds_sendmsg()
1051 rdsdebug("sendmsg woke queued %d timeo %ld\n", queued, timeo); in rds_sendmsg()
1052 if (timeo > 0 || timeo == MAX_SCHEDULE_TIMEOUT) in rds_sendmsg()
1055 ret = timeo; in rds_sendmsg()
/net/dccp/
Dminisocks.c46 void dccp_time_wait(struct sock *sk, int state, int timeo) in dccp_time_wait() argument
72 if (timeo < rto) in dccp_time_wait()
73 timeo = rto; in dccp_time_wait()
77 timeo = DCCP_TIMEWAIT_LEN; in dccp_time_wait()
79 inet_twsk_schedule(tw, &dccp_death_row, timeo, in dccp_time_wait()
Dproto.c753 long timeo; in dccp_sendmsg() local
765 timeo = sock_sndtimeo(sk, noblock); in dccp_sendmsg()
773 if ((rc = sk_stream_wait_connect(sk, &timeo)) != 0) in dccp_sendmsg()
814 long timeo; in dccp_recvmsg() local
823 timeo = sock_rcvtimeo(sk, nonblock); in dccp_recvmsg()
881 if (!timeo) { in dccp_recvmsg()
887 len = sock_intr_errno(timeo); in dccp_recvmsg()
891 sk_wait_data(sk, &timeo); in dccp_recvmsg()
/net/llc/
Daf_llc.c473 const long timeo = sock_sndtimeo(sk, flags & O_NONBLOCK); in llc_ui_connect() local
475 if (!timeo || !llc_ui_wait_for_conn(sk, timeo)) in llc_ui_connect()
478 rc = sock_intr_errno(timeo); in llc_ui_connect()
595 static int llc_wait_data(struct sock *sk, long timeo) in llc_wait_data() argument
610 if (!timeo) in llc_wait_data()
612 rc = sock_intr_errno(timeo); in llc_wait_data()
616 if (sk_wait_data(sk, &timeo)) in llc_wait_data()
721 long timeo; in llc_ui_recvmsg() local
730 timeo = sock_rcvtimeo(sk, nonblock); in llc_ui_recvmsg()
752 copied = timeo ? sock_intr_errno(timeo) : -EAGAIN; in llc_ui_recvmsg()
[all …]
/net/unix/
Daf_unix.c1149 static long unix_wait_for_peer(struct sock *other, long timeo) in unix_wait_for_peer() argument
1164 timeo = schedule_timeout(timeo); in unix_wait_for_peer()
1167 return timeo; in unix_wait_for_peer()
1183 long timeo; in unix_stream_connect() local
1194 timeo = sock_sndtimeo(sk, flags & O_NONBLOCK); in unix_stream_connect()
1237 if (!timeo) in unix_stream_connect()
1240 timeo = unix_wait_for_peer(other, timeo); in unix_stream_connect()
1242 err = sock_intr_errno(timeo); in unix_stream_connect()
1556 long timeo; in unix_dgram_sendmsg() local
1617 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in unix_dgram_sendmsg()
[all …]
/net/rxrpc/
Dar-recvmsg.c53 long timeo; in rxrpc_recvmsg() local
66 timeo = sock_rcvtimeo(&rx->sk, flags & MSG_DONTWAIT); in rxrpc_recvmsg()
90 (msg->msg_flags & MSG_PEEK || timeo == 0)) in rxrpc_recvmsg()
104 timeo = schedule_timeout(timeo); in rxrpc_recvmsg()
358 ret = sock_intr_errno(timeo); in rxrpc_recvmsg()
Dar-output.c401 long *timeo) in rxrpc_wait_for_tx_window() argument
408 *timeo); in rxrpc_wait_for_tx_window()
419 ret = sock_intr_errno(*timeo); in rxrpc_wait_for_tx_window()
424 *timeo = schedule_timeout(*timeo); in rxrpc_wait_for_tx_window()
533 long timeo; in rxrpc_send_data() local
539 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in rxrpc_send_data()
577 &timeo); in rxrpc_send_data()
/net/nfc/
Dllcp_sock.c30 static int sock_wait_state(struct sock *sk, int state, unsigned long timeo) in sock_wait_state() argument
41 if (!timeo) { in sock_wait_state()
47 err = sock_intr_errno(timeo); in sock_wait_state()
52 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/ipv4/
Dinet_connection_sock.c257 static int inet_csk_wait_for_connect(struct sock *sk, long timeo) in inet_csk_wait_for_connect() argument
282 timeo = schedule_timeout(timeo); in inet_csk_wait_for_connect()
290 err = sock_intr_errno(timeo); in inet_csk_wait_for_connect()
294 if (!timeo) in inet_csk_wait_for_connect()
323 long timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in inet_csk_accept() local
327 if (!timeo) in inet_csk_accept()
330 error = inet_csk_wait_for_connect(sk, timeo); in inet_csk_accept()
637 unsigned long timeo; in inet_csk_reqsk_queue_prune() local
641 timeo = min(timeout << req->num_timeout, in inet_csk_reqsk_queue_prune()
643 req->expires = now + timeo; in inet_csk_reqsk_queue_prune()
Dinet_timewait_sock.c342 const int timeo, const int timewait_len) in inet_twsk_schedule() argument
371 slot = (timeo + (1 << INET_TWDR_RECYCLE_TICK) - 1) >> INET_TWDR_RECYCLE_TICK; in inet_twsk_schedule()
383 if (timeo >= timewait_len) { in inet_twsk_schedule()
386 slot = DIV_ROUND_UP(timeo, twdr->period); in inet_twsk_schedule()
390 tw->tw_ttd = jiffies + timeo; in inet_twsk_schedule()
Dtcp.c684 long timeo; in tcp_splice_read() local
699 timeo = sock_rcvtimeo(sk, sock->file->f_flags & O_NONBLOCK); in tcp_splice_read()
724 if (!timeo) { in tcp_splice_read()
734 sk_wait_data(sk, &timeo); in tcp_splice_read()
736 ret = sock_intr_errno(timeo); in tcp_splice_read()
744 if (!timeo) in tcp_splice_read()
844 long timeo = sock_sndtimeo(sk, flags & MSG_DONTWAIT); in do_tcp_sendpages() local
852 if ((err = sk_stream_wait_connect(sk, &timeo)) != 0) in do_tcp_sendpages()
936 if ((err = sk_stream_wait_memory(sk, &timeo)) != 0) in do_tcp_sendpages()
1035 long timeo; in tcp_sendmsg() local
[all …]
Dtcp_minisocks.c266 void tcp_time_wait(struct sock *sk, int state, int timeo) in tcp_time_wait() argument
330 if (timeo < rto) in tcp_time_wait()
331 timeo = rto; in tcp_time_wait()
338 timeo = TCP_TIMEWAIT_LEN; in tcp_time_wait()
341 inet_twsk_schedule(tw, &tcp_death_row, timeo, in tcp_time_wait()
Daf_inet.c589 static long inet_wait_for_connect(struct sock *sk, long timeo, int writebias) in inet_wait_for_connect() argument
603 timeo = schedule_timeout(timeo); in inet_wait_for_connect()
605 if (signal_pending(current) || !timeo) in inet_wait_for_connect()
611 return timeo; in inet_wait_for_connect()
623 long timeo; in __inet_stream_connect() local
664 timeo = sock_sndtimeo(sk, flags & O_NONBLOCK); in __inet_stream_connect()
672 if (!timeo || !inet_wait_for_connect(sk, timeo, writebias)) in __inet_stream_connect()
675 err = sock_intr_errno(timeo); in __inet_stream_connect()
/net/iucv/
Daf_iucv.c52 #define __iucv_sock_wait(sk, condition, timeo, ret) \ argument
55 long __timeo = timeo; \
77 #define iucv_sock_wait(sk, condition, timeo) \ argument
81 __iucv_sock_wait(sk, condition, timeo, __ret); \
476 unsigned long timeo; in iucv_sock_close() local
498 timeo = sk->sk_lingertime; in iucv_sock_close()
500 timeo = IUCV_DISCONN_TIMEOUT; in iucv_sock_close()
503 timeo); in iucv_sock_close()
925 long timeo; in iucv_sock_accept() local
935 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in iucv_sock_accept()
[all …]
/net/bluetooth/rfcomm/
Dsock.c469 long timeo; in rfcomm_sock_accept() local
479 timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in rfcomm_sock_accept()
481 BT_DBG("sk %p timeo %ld", sk, timeo); in rfcomm_sock_accept()
497 if (!timeo) { in rfcomm_sock_accept()
503 err = sock_intr_errno(timeo); in rfcomm_sock_accept()
508 timeo = schedule_timeout(timeo); in rfcomm_sock_accept()
/net/core/
Ddatagram.c166 long timeo; in __skb_recv_datagram() local
175 timeo = sock_rcvtimeo(sk, flags & MSG_DONTWAIT); in __skb_recv_datagram()
212 if (!timeo) in __skb_recv_datagram()
215 } while (!wait_for_more_packets(sk, err, &timeo, last)); in __skb_recv_datagram()
/net/bluetooth/cmtp/
Dcapi.c398 unsigned long timeo = CMTP_INTEROP_TIMEOUT; in cmtp_register_appl() local
433 if (!timeo) { in cmtp_register_appl()
451 timeo = schedule_timeout(timeo); in cmtp_register_appl()
/net/phonet/
Dsocket.c233 long timeo = sock_rcvtimeo(sk, flags & O_NONBLOCK); in pn_socket_connect() local
274 if (!timeo) { in pn_socket_connect()
279 err = sock_intr_errno(timeo); in pn_socket_connect()
286 timeo = schedule_timeout(timeo); in pn_socket_connect()

12