Lines Matching defs:conn
566 hmdfs_err("TCP conn %d is broken, current sk_state is %d",
573 hmdfs_err("TCP conn %d is broken, current sock state is %d",
584 "TCP conn %d is broken, the strparser has stopped",
1043 static void connection_notify_to_close(struct connection *conn)
1049 tcp = conn->connect_handle;
1050 peer = conn->node;
1059 void hmdfs_reget_connection(struct connection *conn)
1068 if (!conn)
1072 mutex_lock(&conn->node->conn_impl_list_lock);
1073 list_for_each_entry_safe(conn_impl, next, &conn->node->conn_impl_list,
1075 if (conn_impl == conn) {
1077 list_move(&conn->list, &conn->node->conn_deleting_list);
1082 mutex_unlock(&conn->node->conn_impl_list_lock);
1086 tcp = conn->connect_handle;
1096 mutex_unlock(&conn->node->conn_impl_list_lock);
1102 kref_read(&conn->ref_cnt), stop_thread);
1110 connection_notify_to_close(conn);
1112 connection_put(conn);
1135 struct connection *conn =
1138 hmdfs_reget_connection(conn);
1139 connection_put(conn);
1165 hmdfs_err("Failed to alloc tcp_handle for strcut conn");
1179 struct connection *conn;
1181 conn = lookup_conn_by_socketfd_unsafe(node, socket);
1182 if (conn) {
1184 return conn;
1213 hmdfs_info("Got a existing tcp conn: fsocket_fd = %d",
1221 hmdfs_info("Failed to alloc a tcp conn, socket_fd %d", fd);
1231 hmdfs_info("Got a newly allocated tcp conn: socket_fd = %d", fd);
1238 hmdfs_info("Got a existing tcp conn: socket_fd = %d", fd);