Home
last modified time | relevance | path

Searched refs:sk (Results 1 – 12 of 12) sorted by relevance

/fs/dlm/
Dlowcomms.c409 static void lowcomms_data_ready(struct sock *sk) in lowcomms_data_ready() argument
411 struct connection *con = sock2con(sk); in lowcomms_data_ready()
416 static void lowcomms_write_space(struct sock *sk) in lowcomms_write_space() argument
418 struct connection *con = sock2con(sk); in lowcomms_write_space()
426 con->sock->sk->sk_write_pending--; in lowcomms_write_space()
442 static void lowcomms_state_change(struct sock *sk) in lowcomms_state_change() argument
449 if (sk->sk_shutdown) { in lowcomms_state_change()
450 if (sk->sk_shutdown == RCV_SHUTDOWN) in lowcomms_state_change()
451 lowcomms_data_ready(sk); in lowcomms_state_change()
452 } else if (sk->sk_state == TCP_ESTABLISHED) { in lowcomms_state_change()
[all …]
/fs/ocfs2/cluster/
Dtcp.c141 static void o2net_listen_data_ready(struct sock *sk);
600 static void o2net_data_ready(struct sock *sk) in o2net_data_ready() argument
602 void (*ready)(struct sock *sk); in o2net_data_ready()
605 read_lock_bh(&sk->sk_callback_lock); in o2net_data_ready()
606 sc = sk->sk_user_data; in o2net_data_ready()
613 ready = sk->sk_data_ready; in o2net_data_ready()
615 read_unlock_bh(&sk->sk_callback_lock); in o2net_data_ready()
617 ready(sk); in o2net_data_ready()
621 static void o2net_state_change(struct sock *sk) in o2net_state_change() argument
623 void (*state_change)(struct sock *sk); in o2net_state_change()
[all …]
Dtcp.h72 if (sock->sk->sk_state != TCP_ESTABLISHED && in o2net_link_down()
73 sock->sk->sk_state != TCP_CLOSE_WAIT) in o2net_link_down()
Dtcp_internal.h167 void (*sc_state_change)(struct sock *sk);
168 void (*sc_data_ready)(struct sock *sk);
Dnetdebug.c326 inet = inet_sk(sc->sc_sock->sk); in sc_show_sock_container()
/fs/ncpfs/
Dncp_fs_sb.h113 void (*data_ready)(struct sock* sk);
114 void (*error_report)(struct sock* sk);
115 void (*write_space)(struct sock* sk); /* STREAM mode only */
154 extern void ncp_tcp_data_ready(struct sock* sk);
155 extern void ncp_tcp_write_space(struct sock* sk);
156 extern void ncp_tcp_error_report(struct sock* sk);
Dinode.c314 struct sock* sk = server->ncp_sock->sk; in ncp_stop_tasks() local
316 lock_sock(sk); in ncp_stop_tasks()
317 sk->sk_error_report = server->error_report; in ncp_stop_tasks()
318 sk->sk_data_ready = server->data_ready; in ncp_stop_tasks()
319 sk->sk_write_space = server->write_space; in ncp_stop_tasks()
320 release_sock(sk); in ncp_stop_tasks()
324 if (sk->sk_socket->type == SOCK_STREAM) in ncp_stop_tasks()
636 lock_sock(sock->sk); in ncp_fill_super()
637 server->data_ready = sock->sk->sk_data_ready; in ncp_fill_super()
638 server->write_space = sock->sk->sk_write_space; in ncp_fill_super()
[all …]
Dsock.c93 void ncp_tcp_data_ready(struct sock *sk) in ncp_tcp_data_ready() argument
95 struct ncp_server *server = sk->sk_user_data; in ncp_tcp_data_ready()
97 server->data_ready(sk); in ncp_tcp_data_ready()
101 void ncp_tcp_error_report(struct sock *sk) in ncp_tcp_error_report() argument
103 struct ncp_server *server = sk->sk_user_data; in ncp_tcp_error_report()
105 server->error_report(sk); in ncp_tcp_error_report()
109 void ncp_tcp_write_space(struct sock *sk) in ncp_tcp_write_space() argument
111 struct ncp_server *server = sk->sk_user_data; in ncp_tcp_write_space()
115 server->write_space(sk); in ncp_tcp_write_space()
425 hdrl = sock->sk->sk_family == AF_INET ? 8 : 6; in ncpdgram_rcv_proc()
/fs/btrfs/
Dioctl.c1937 struct btrfs_ioctl_search_key *sk) in key_in_sk() argument
1942 test.objectid = sk->min_objectid; in key_in_sk()
1943 test.type = sk->min_type; in key_in_sk()
1944 test.offset = sk->min_offset; in key_in_sk()
1950 test.objectid = sk->max_objectid; in key_in_sk()
1951 test.type = sk->max_type; in key_in_sk()
1952 test.offset = sk->max_offset; in key_in_sk()
1962 struct btrfs_ioctl_search_key *sk, in copy_to_sk() argument
1983 if (btrfs_header_generation(leaf) > sk->max_transid) { in copy_to_sk()
1994 if (!key_in_sk(key, sk)) in copy_to_sk()
[all …]
/fs/cifs/
Dconnect.c3151 struct sock *sk = sock->sk; in cifs_reclassify_socket4() local
3152 BUG_ON(!sock_allow_reclassification(sk)); in cifs_reclassify_socket4()
3153 sock_lock_init_class_and_name(sk, "slock-AF_INET-CIFS", in cifs_reclassify_socket4()
3160 struct sock *sk = sock->sk; in cifs_reclassify_socket6() local
3161 BUG_ON(!sock_allow_reclassification(sk)); in cifs_reclassify_socket6()
3162 sock_lock_init_class_and_name(sk, "slock-AF_INET6-CIFS", in cifs_reclassify_socket6()
3322 socket->sk->sk_allocation = GFP_NOFS; in generic_ip_connect()
3338 socket->sk->sk_rcvtimeo = 7 * HZ; in generic_ip_connect()
3339 socket->sk->sk_sndtimeo = 5 * HZ; in generic_ip_connect()
3343 if (socket->sk->sk_sndbuf < (200 * 1024)) in generic_ip_connect()
[all …]
/fs/afs/
Drxrpc.c72 socket->sk->sk_allocation = GFP_NOFS; in afs_open_socket()
599 static void afs_wake_up_call_waiter(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_call_waiter() argument
611 static void afs_wake_up_async_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_wake_up_async_call() argument
728 static void afs_rx_new_call(struct sock *sk, struct rxrpc_call *rxcall, in afs_rx_new_call() argument
/fs/
Deventpoll.c436 struct sock *sk; in ep_set_busy_poll_napi_id() local
446 sk = sock->sk; in ep_set_busy_poll_napi_id()
447 if (!sk) in ep_set_busy_poll_napi_id()
450 napi_id = READ_ONCE(sk->sk_napi_id); in ep_set_busy_poll_napi_id()