Lines Matching refs:socket
29 * the socket's tx buffers via a usual blocking sendmsg. They'll block waiting
30 * for a failed socket to timeout. TX callers can also pass in a poniter to an
34 * Handlers for unsolicited messages are registered. Each socket has a page
36 * Handlers are called from only one thread with a reference to this per-socket
43 * Our sock_container holds the state we associate with a socket. It's current
45 * is safe to tear down the socket. The socket is only finally torn down from
47 * as you hold a ref on the container you can trust that the socket is valid
48 * for use with kernel socket APIs.
116 static struct socket *o2net_listen_sock = NULL;
119 * listen work is only queued by the listening socket callbacks on the
537 /* accepted sockets inherit the old listen socket data ready */
591 * This work queue function performs the blocking parts of socket shutdown. A
792 static int o2net_recv_tcp_msg(struct socket *sock, void *data, size_t len)
814 static int o2net_send_tcp_msg(struct socket *sock, struct kvec *vec,
1022 static int o2net_send_status_magic(struct socket *sock, struct o2net_msg *hdr,
1207 * handlers as each full message is read off the socket. it returns -error,
1319 static int o2net_set_nodelay(struct socket *sock)
1386 /* socket shutdown does a del_timer_sync against this as it tears down.
1445 struct socket *sock = NULL;
1484 mlog(0, "can't create socket: %d\n", ret);
1659 static int o2net_accept_one(struct socket *sock)
1663 struct socket *new_sock = NULL;
1770 struct socket *sock = o2net_listen_sock;
1786 /* ->sk_data_ready is also called for a newly established child socket
1789 * socket */
1802 struct socket *sock = NULL;
1812 mlog(ML_ERROR, "unable to create socket, ret=%d\n", ret);
1829 mlog(ML_ERROR, "unable to bind socket at %u.%u.%u.%u:%u, "
1851 * socket. node manager handles all the serialization to only call this
1885 struct socket *sock = o2net_listen_sock;
1891 /* stop the listening socket from generating work */