Lines Matching defs:sock
46 #include <net/sock.h>
69 struct socket *sock; /* NULL if not connected */
120 void (*sk_error_report)(struct sock *);
121 void (*sk_data_ready)(struct sock *);
122 void (*sk_state_change)(struct sock *);
123 void (*sk_write_space)(struct sock *);
402 static void lowcomms_data_ready(struct sock *sk)
413 static void lowcomms_write_space(struct sock *sk)
422 clear_bit(SOCK_NOSPACE, &con->sock->flags);
425 con->sock->sk->sk_write_pending--;
426 clear_bit(SOCKWQ_ASYNC_NOSPACE, &con->sock->flags);
442 static void lowcomms_state_change(struct sock *sk)
471 static void lowcomms_error_report(struct sock *sk)
474 void (*orig_report)(struct sock *) = NULL;
518 static void save_listen_callbacks(struct socket *sock)
520 struct sock *sk = sock->sk;
528 static void restore_callbacks(struct socket *sock)
530 struct sock *sk = sock->sk;
542 static void add_sock(struct socket *sock, struct connection *con)
544 struct sock *sk = sock->sk;
547 con->sock = sock;
594 if (con->sock) {
595 restore_callbacks(con->sock);
596 sock_release(con->sock);
597 con->sock = NULL;
618 if (!con->sock) {
624 ret = kernel_sock_shutdown(con->sock, SHUT_WR);
685 if (con->sock == NULL) {
711 ret = kernel_recvmsg(con->sock, &msg, &iov, 1, iov.iov_len,
783 if (!con->sock) {
788 result = kernel_accept(con->sock, &newsock, O_NONBLOCK);
828 if (newcon->sock) {
860 /* close other sock con if we have something new */
940 result = kernel_bind(con->sock, addr, addr_len);
942 result = sock_bind_add(con->sock->sk, addr, addr_len);
963 struct socket *sock;
967 log_print("attempt to connect sock 0 foiled");
979 if (con->sock) {
993 SOCK_STREAM, IPPROTO_SCTP, &sock);
997 sock_set_mark(sock->sk, mark);
1001 add_sock(sock, con);
1012 sctp_sock_set_nodelay(sock->sk);
1015 * Make sock->ops->connect() function return in specified time,
1019 sock_set_sndtimeo(sock->sk, 5);
1020 result = sock->ops->connect(sock, (struct sockaddr *)&daddr, addr_len,
1022 sock_set_sndtimeo(sock->sk, 0);
1030 con->sock = NULL;
1031 sock_release(sock);
1060 struct socket *sock = NULL;
1065 log_print("attempt to connect sock 0 foiled");
1076 if (con->sock)
1081 SOCK_STREAM, IPPROTO_TCP, &sock);
1085 sock_set_mark(sock->sk, mark);
1097 add_sock(sock, con);
1103 result = sock->ops->bind(sock, (struct sockaddr *) &src_addr,
1115 tcp_sock_set_nodelay(sock->sk);
1117 result = sock->ops->connect(sock, (struct sockaddr *)&saddr, addr_len,
1125 if (con->sock) {
1126 sock_release(con->sock);
1127 con->sock = NULL;
1128 } else if (sock) {
1129 sock_release(sock);
1155 struct socket *sock = NULL;
1166 SOCK_STREAM, IPPROTO_TCP, &sock);
1172 sock_set_mark(sock->sk, dlm_config.ci_mark);
1175 tcp_sock_set_nodelay(sock->sk);
1177 sock_set_reuseaddr(sock->sk);
1179 write_lock_bh(&sock->sk->sk_callback_lock);
1180 sock->sk->sk_user_data = con;
1181 save_listen_callbacks(sock);
1184 write_unlock_bh(&sock->sk->sk_callback_lock);
1188 result = sock->ops->bind(sock, (struct sockaddr *) saddr, addr_len);
1191 sock_release(sock);
1192 sock = NULL;
1193 con->sock = NULL;
1196 sock_set_keepalive(sock->sk);
1198 result = sock->ops->listen(sock, 5);
1201 sock_release(sock);
1202 sock = NULL;
1207 return sock;
1239 struct socket *sock = NULL;
1249 SOCK_STREAM, IPPROTO_SCTP, &sock);
1255 sock_set_rcvbuf(sock->sk, NEEDED_RMEM);
1256 sock_set_mark(sock->sk, dlm_config.ci_mark);
1257 sctp_sock_set_nodelay(sock->sk);
1259 write_lock_bh(&sock->sk->sk_callback_lock);
1261 sock->sk->sk_user_data = con;
1262 save_listen_callbacks(sock);
1263 con->sock = sock;
1264 con->sock->sk->sk_data_ready = lowcomms_data_ready;
1268 write_unlock_bh(&sock->sk->sk_callback_lock);
1274 result = sock->ops->listen(sock, 5);
1283 sock_release(sock);
1284 con->sock = NULL;
1291 struct socket *sock = NULL;
1307 sock = tcp_create_listen_sock(con, dlm_local_addr[0]);
1308 if (sock) {
1309 add_sock(sock, con);
1417 if (con->sock == NULL)
1434 ret = kernel_sendpage(con->sock, e->page, offset, len,
1438 test_bit(SOCKWQ_ASYNC_NOSPACE, &con->sock->flags) &&
1443 set_bit(SOCK_NOSPACE, &con->sock->flags);
1444 con->sock->sk->sk_write_pending++;
1538 if (con->sock == NULL) /* not mutex protected so check it inside too */
1578 if (con->sock && con->sock->sk) {
1579 write_lock_bh(&con->sock->sk->sk_callback_lock);
1580 con->sock->sk->sk_user_data = NULL;
1581 write_unlock_bh(&con->sock->sk->sk_callback_lock);