Home
last modified time | relevance | path

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

/fs/ocfs2/cluster/
Dtcp.c139 static void o2net_listen_data_ready(struct sock *sk, int bytes);
541 static void o2net_data_ready(struct sock *sk, int bytes) in o2net_data_ready() argument
543 void (*ready)(struct sock *sk, int bytes); in o2net_data_ready()
545 read_lock(&sk->sk_callback_lock); in o2net_data_ready()
546 if (sk->sk_user_data) { in o2net_data_ready()
547 struct o2net_sock_container *sc = sk->sk_user_data; in o2net_data_ready()
553 ready = sk->sk_data_ready; in o2net_data_ready()
555 read_unlock(&sk->sk_callback_lock); in o2net_data_ready()
557 ready(sk, bytes); in o2net_data_ready()
561 static void o2net_state_change(struct sock *sk) in o2net_state_change() argument
[all …]
Dtcp.h71 if (sock->sk->sk_state != TCP_ESTABLISHED && in o2net_link_down()
72 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, int bytes);
Dnetdebug.c295 inet = inet_sk(sc->sc_sock->sk); in sc_seq_show()
/fs/smbfs/
Dsock.c52 return socket->sk->sk_user_data; in server_from_socket()
59 smb_data_ready(struct sock *sk, int len) in smb_data_ready() argument
61 struct smb_sb_info *server = server_from_socket(sk->sk_socket); in smb_data_ready()
64 data_ready(sk, len); in smb_data_ready()
65 VERBOSE("(%p, %d)\n", sk, len); in smb_data_ready()
101 sock->sk->sk_data_ready = server->data_ready; in smb_close_socket()
210 if (sock->sk->sk_state != TCP_ESTABLISHED) in smb_receive_header()
276 if (sock->sk->sk_state != TCP_ESTABLISHED) in smb_receive_drop()
322 if (sock->sk->sk_state != TCP_ESTABLISHED) in smb_receive()
370 if (sock->sk->sk_state != TCP_ESTABLISHED) in smb_send_request()
Dproto.h49 extern void smb_data_ready(struct sock *sk, int len);
Dproc.c852 struct sock *sk; in smb_newconn() local
900 sk = SOCKET_I(filp->f_path.dentry->d_inode)->sk; in smb_newconn()
901 sk->sk_user_data = server; in smb_newconn()
904 server->data_ready = xchg(&sk->sk_data_ready, smb_data_ready); in smb_newconn()
/fs/dlm/
Dlowcomms.c261 static void lowcomms_data_ready(struct sock *sk, int count_unused) in lowcomms_data_ready() argument
263 struct connection *con = sock2con(sk); in lowcomms_data_ready()
268 static void lowcomms_write_space(struct sock *sk) in lowcomms_write_space() argument
270 struct connection *con = sock2con(sk); in lowcomms_write_space()
282 static void lowcomms_state_change(struct sock *sk) in lowcomms_state_change() argument
284 if (sk->sk_state == TCP_ESTABLISHED) in lowcomms_state_change()
285 lowcomms_write_space(sk); in lowcomms_state_change()
294 con->sock->sk->sk_data_ready = lowcomms_data_ready; in add_sock()
295 con->sock->sk->sk_write_space = lowcomms_write_space; in add_sock()
296 con->sock->sk->sk_state_change = lowcomms_state_change; in add_sock()
[all …]
/fs/ncpfs/
Dinode.c301 struct sock* sk = server->ncp_sock->sk; in ncp_stop_tasks() local
303 sk->sk_error_report = server->error_report; in ncp_stop_tasks()
304 sk->sk_data_ready = server->data_ready; in ncp_stop_tasks()
305 sk->sk_write_space = server->write_space; in ncp_stop_tasks()
597 server->data_ready = sock->sk->sk_data_ready; in ncp_fill_super()
598 server->write_space = sock->sk->sk_write_space; in ncp_fill_super()
599 server->error_report = sock->sk->sk_error_report; in ncp_fill_super()
600 sock->sk->sk_user_data = server; in ncp_fill_super()
617 sock->sk->sk_data_ready = ncp_tcp_data_ready; in ncp_fill_super()
618 sock->sk->sk_error_report = ncp_tcp_error_report; in ncp_fill_super()
[all …]
Dsock.c98 void ncp_tcp_data_ready(struct sock *sk, int len) in ncp_tcp_data_ready() argument
100 struct ncp_server *server = sk->sk_user_data; in ncp_tcp_data_ready()
102 server->data_ready(sk, len); in ncp_tcp_data_ready()
106 void ncp_tcp_error_report(struct sock *sk) in ncp_tcp_error_report() argument
108 struct ncp_server *server = sk->sk_user_data; in ncp_tcp_error_report()
110 server->error_report(sk); in ncp_tcp_error_report()
114 void ncp_tcp_write_space(struct sock *sk) in ncp_tcp_write_space() argument
116 struct ncp_server *server = sk->sk_user_data; in ncp_tcp_write_space()
120 server->write_space(sk); in ncp_tcp_write_space()
448 hdrl = sock->sk->sk_family == AF_INET ? 8 : 6; in ncpdgram_rcv_proc()
/fs/cifs/
Dconnect.c1689 struct sock *sk = sock->sk; in cifs_reclassify_socket4() local
1690 BUG_ON(sock_owned_by_user(sk)); in cifs_reclassify_socket4()
1691 sock_lock_init_class_and_name(sk, "slock-AF_INET-CIFS", in cifs_reclassify_socket4()
1698 struct sock *sk = sock->sk; in cifs_reclassify_socket6() local
1699 BUG_ON(sock_owned_by_user(sk)); in cifs_reclassify_socket6()
1700 sock_lock_init_class_and_name(sk, "slock-AF_INET6-CIFS", in cifs_reclassify_socket6()
1749 socket->sk->sk_allocation = GFP_NOFS; in ipv4_connect()
1804 socket->sk->sk_rcvtimeo = 7 * HZ; in ipv4_connect()
1805 socket->sk->sk_sndtimeo = 5 * HZ; in ipv4_connect()
1809 if (socket->sk->sk_sndbuf < (200 * 1024)) in ipv4_connect()
[all …]
/fs/afs/
Drxrpc.c87 socket->sk->sk_allocation = GFP_NOFS; in afs_open_socket()
395 static void afs_rx_interceptor(struct sock *sk, unsigned long user_call_ID, in afs_rx_interceptor() argument
405 ASSERTCMP(sk, ==, afs_socket->sk); in afs_rx_interceptor()
/fs/
Dcompat_ioctl.c616 if (mysock && mysock->sk && mysock->sk->sk_family == AF_INET6) { /* ipv6 */ in routing_ioctl()