Lines Matching defs:node
220 struct hmdfs_peer *node = NULL;
229 node = connect->node;
235 node->device_id, rd_err);
237 async_work = (struct hmdfs_async_work *)hmdfs_find_msg_head(node,
262 hmdfs_client_resp_statis(node->sbi, F_READPAGE, HMDFS_RESP_DELAY, 0, 0);
603 old_cred = hmdfs_override_creds(tcp->connect->node->sbi->system_cred);
629 hmdfs_node_inc_evt_seq(tcp->connect->node);
631 if (tcp->connect->node->status != NODE_STAT_OFFLINE)
836 connect->node->device_id);
923 struct hmdfs_peer *node = NULL;
979 node = tcp->connect->node;
982 node->owner, node->device_id, fd);
1050 peer = conn->node;
1072 mutex_lock(&conn->node->conn_impl_list_lock);
1073 list_for_each_entry_safe(conn_impl, next, &conn->node->conn_impl_list,
1077 list_move(&conn->list, &conn->node->conn_deleting_list);
1082 mutex_unlock(&conn->node->conn_impl_list_lock);
1096 mutex_unlock(&conn->node->conn_impl_list_lock);
1116 lookup_conn_by_socketfd_unsafe(struct hmdfs_peer *node, struct socket *socket)
1121 list_for_each_entry(tcp_conn, &node->conn_impl_list, list) {
1142 struct connection *alloc_conn_tcp(struct hmdfs_peer *node, int socket_fd,
1155 tcp_conn->node = node;
1175 static struct connection *add_conn_tcp_unsafe(struct hmdfs_peer *node,
1181 conn = lookup_conn_by_socketfd_unsafe(node, socket);
1189 list_add(&conn2add->list, &node->conn_impl_list);
1191 list_add_tail(&conn2add->list, &node->conn_impl_list);
1196 struct connection *hmdfs_get_conn_tcp(struct hmdfs_peer *node, int fd,
1209 mutex_lock(&node->conn_impl_list_lock);
1210 tcp_conn = lookup_conn_by_socketfd_unsafe(node, socket);
1211 mutex_unlock(&node->conn_impl_list_lock);
1219 tcp_conn = alloc_conn_tcp(node, fd, master_key, status, socket);
1226 mutex_lock(&node->conn_impl_list_lock);
1227 on_peer_conn = add_conn_tcp_unsafe(node, socket, tcp_conn);
1228 mutex_unlock(&node->conn_impl_list_lock);