Lines Matching refs:sock

104 	struct socket *sock;	/* NULL if not connected */  member
427 static void lowcomms_data_ready(struct sock *sk) in lowcomms_data_ready()
434 static void lowcomms_write_space(struct sock *sk) in lowcomms_write_space()
441 clear_bit(SOCK_NOSPACE, &con->sock->flags); in lowcomms_write_space()
444 con->sock->sk->sk_write_pending--; in lowcomms_write_space()
445 clear_bit(SOCK_ASYNC_NOSPACE, &con->sock->flags); in lowcomms_write_space()
460 static void lowcomms_state_change(struct sock *sk) in lowcomms_state_change()
485 static void add_sock(struct socket *sock, struct connection *con) in add_sock() argument
487 con->sock = sock; in add_sock()
490 con->sock->sk->sk_data_ready = lowcomms_data_ready; in add_sock()
491 con->sock->sk->sk_write_space = lowcomms_write_space; in add_sock()
492 con->sock->sk->sk_state_change = lowcomms_state_change; in add_sock()
493 con->sock->sk->sk_user_data = con; in add_sock()
494 con->sock->sk->sk_allocation = GFP_NOFS; in add_sock()
521 if (con->sock) { in close_connection()
522 sock_release(con->sock); in close_connection()
523 con->sock = NULL; in close_connection()
568 ret = kernel_sendmsg(con->sock, &outmessage, NULL, 0, 0); in sctp_send_shutdown()
690 ret = kernel_getsockopt(con->sock, in process_sctp_notification()
722 lock_sock(con->sock->sk); in process_sctp_notification()
723 ret = sctp_do_peeloff(con->sock->sk, in process_sctp_notification()
725 &new_con->sock); in process_sctp_notification()
726 release_sock(con->sock->sk); in process_sctp_notification()
734 add_sock(new_con->sock, new_con); in process_sctp_notification()
738 ret = kernel_setsockopt(new_con->sock, SOL_SOCKET, SO_LINGER, in process_sctp_notification()
800 if (con->sock == NULL) { in receive_from_sock()
842 r = ret = kernel_recvmsg(con->sock, &msg, iov, nvec, len, in receive_from_sock()
932 if (con->sock == NULL) in tcp_accept_from_sock()
935 newsock->type = con->sock->type; in tcp_accept_from_sock()
936 newsock->ops = con->sock->ops; in tcp_accept_from_sock()
938 result = con->sock->ops->accept(con->sock, newsock, O_NONBLOCK); in tcp_accept_from_sock()
975 if (newcon->sock) { in tcp_accept_from_sock()
993 if (!othercon->sock) { in tcp_accept_from_sock()
995 othercon->sock = newsock; in tcp_accept_from_sock()
1134 ret = kernel_sendmsg(base_con->sock, &outmessage, iov, 1, len); in sctp_init_assoc()
1158 struct socket *sock = NULL; in tcp_connect_to_sock() local
1172 if (con->sock) in tcp_connect_to_sock()
1177 IPPROTO_TCP, &sock); in tcp_connect_to_sock()
1188 sock->sk->sk_user_data = con; in tcp_connect_to_sock()
1191 add_sock(sock, con); in tcp_connect_to_sock()
1197 result = sock->ops->bind(sock, (struct sockaddr *) &src_addr, in tcp_connect_to_sock()
1209 kernel_setsockopt(sock, SOL_TCP, TCP_NODELAY, (char *)&one, in tcp_connect_to_sock()
1212 result = sock->ops->connect(sock, (struct sockaddr *)&saddr, addr_len, in tcp_connect_to_sock()
1220 if (con->sock) { in tcp_connect_to_sock()
1221 sock_release(con->sock); in tcp_connect_to_sock()
1222 con->sock = NULL; in tcp_connect_to_sock()
1223 } else if (sock) { in tcp_connect_to_sock()
1224 sock_release(sock); in tcp_connect_to_sock()
1250 struct socket *sock = NULL; in tcp_create_listen_sock() local
1262 IPPROTO_TCP, &sock); in tcp_create_listen_sock()
1269 kernel_setsockopt(sock, SOL_TCP, TCP_NODELAY, (char *)&one, in tcp_create_listen_sock()
1272 result = kernel_setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, in tcp_create_listen_sock()
1283 result = sock->ops->bind(sock, (struct sockaddr *) saddr, addr_len); in tcp_create_listen_sock()
1286 sock_release(sock); in tcp_create_listen_sock()
1287 sock = NULL; in tcp_create_listen_sock()
1288 con->sock = NULL; in tcp_create_listen_sock()
1291 result = kernel_setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, in tcp_create_listen_sock()
1297 result = sock->ops->listen(sock, 5); in tcp_create_listen_sock()
1300 sock_release(sock); in tcp_create_listen_sock()
1301 sock = NULL; in tcp_create_listen_sock()
1306 return sock; in tcp_create_listen_sock()
1337 result = kernel_bind(sctp_con->sock, in add_sctp_bind_addr()
1341 result = kernel_setsockopt(sctp_con->sock, SOL_SCTP, in add_sctp_bind_addr()
1355 struct socket *sock = NULL; in sctp_listen_for_all() local
1369 IPPROTO_SCTP, &sock); in sctp_listen_for_all()
1383 result = kernel_setsockopt(sock, SOL_SOCKET, SO_RCVBUFFORCE, in sctp_listen_for_all()
1388 result = kernel_setsockopt(sock, SOL_SCTP, SCTP_EVENTS, in sctp_listen_for_all()
1396 result = kernel_setsockopt(sock, SOL_SCTP, SCTP_NODELAY, (char *)&one, in sctp_listen_for_all()
1402 sock->sk->sk_user_data = con; in sctp_listen_for_all()
1403 con->sock = sock; in sctp_listen_for_all()
1404 con->sock->sk->sk_data_ready = lowcomms_data_ready; in sctp_listen_for_all()
1419 result = sock->ops->listen(sock, 5); in sctp_listen_for_all()
1428 sock_release(sock); in sctp_listen_for_all()
1429 con->sock = NULL; in sctp_listen_for_all()
1436 struct socket *sock = NULL; in tcp_listen_for_all() local
1452 sock = tcp_create_listen_sock(con, dlm_local_addr[0]); in tcp_listen_for_all()
1453 if (sock) { in tcp_listen_for_all()
1454 add_sock(sock, con); in tcp_listen_for_all()
1564 if (con->sock == NULL) in send_to_sock()
1581 ret = kernel_sendpage(con->sock, e->page, offset, len, in send_to_sock()
1585 test_bit(SOCK_ASYNC_NOSPACE, &con->sock->flags) && in send_to_sock()
1590 set_bit(SOCK_NOSPACE, &con->sock->flags); in send_to_sock()
1591 con->sock->sk->sk_write_pending++; in send_to_sock()
1732 if (con->sock && con->sock->sk) in stop_conn()
1733 con->sock->sk->sk_user_data = NULL; in stop_conn()