Lines Matching defs:socket
42 static int recvmsg_nofs(struct socket *sock, struct msghdr *msg,
56 static int sendmsg_nofs(struct socket *sock, struct msghdr *msg,
70 static int tcp_set_recvtimeo(struct socket *sock, int timeout)
95 static int tcp_read_head_from_socket(struct socket *sock, void *buf,
123 static int tcp_read_buffer_from_socket(struct socket *sock, void *buf,
165 static int hmdfs_drop_readpage_buffer(struct socket *sock,
189 static int hmdfs_get_readpage_buffer(struct socket *sock,
659 hmdfs_err("encrypt tcp socket = NULL");
713 hmdfs_err("tcp socket = NULL");
903 hmdfs_err("invalid socket protocol");
920 uint8_t *master_key, struct socket *socket)
928 tcp->sock = socket;
941 hmdfs_info("socket fd %d, state %d, refcount %ld protocol %d", fd,
942 socket->state, file_count(socket->file),
943 socket->sk->sk_protocol);
953 err = tcp_set_recvtimeo(socket, TCP_RECV_TIMEOUT);
1008 int socket_fd, uint8_t *master_key, struct socket *socket)
1023 ret = tcp_update_socket(tcp, socket_fd, master_key, socket);
1052 // libdistbus/src/TcpSession.cpp will close the socket
1116 lookup_conn_by_socketfd_unsafe(struct hmdfs_peer *node, struct socket *socket)
1124 if (tcp->sock == socket) {
1143 uint8_t *master_key, uint8_t status, struct socket *socket)
1162 (void *)tcp_alloc_handle(tcp_conn, socket_fd, master_key, socket);
1176 struct socket *socket,
1181 conn = lookup_conn_by_socketfd_unsafe(node, socket);
1183 hmdfs_info("socket already in list");
1187 /* Prefer to use socket opened by local device */
1201 struct socket *socket = NULL;
1204 socket = sockfd_lookup(fd, &err);
1205 if (!socket) {
1206 hmdfs_err("lookup socket fail, socket_fd %d, err %d", fd, err);
1210 tcp_conn = lookup_conn_by_socketfd_unsafe(node, socket);
1215 sockfd_put(socket);
1219 tcp_conn = alloc_conn_tcp(node, fd, master_key, status, socket);
1222 sockfd_put(socket);
1227 on_peer_conn = add_conn_tcp_unsafe(node, socket, tcp_conn);