Lines Matching refs:qn
1156 static int dlm_match_nodes(struct dlm_ctxt *dlm, struct dlm_query_nodeinfo *qn) in dlm_match_nodes() argument
1163 for (j = 0; j < qn->qn_numnodes; ++j) in dlm_match_nodes()
1164 mlog(0, "Node %3d, %pI4:%u\n", qn->qn_nodes[j].ni_nodenum, in dlm_match_nodes()
1165 &(qn->qn_nodes[j].ni_ipv4_address), in dlm_match_nodes()
1166 ntohs(qn->qn_nodes[j].ni_ipv4_port)); in dlm_match_nodes()
1171 for (j = 0; j < qn->qn_numnodes; ++j) { in dlm_match_nodes()
1172 if (qn->qn_nodes[j].ni_nodenum == i) { in dlm_match_nodes()
1173 remote = &(qn->qn_nodes[j]); in dlm_match_nodes()
1194 "local node %d\n", qn->qn_domain, in dlm_match_nodes()
1198 qn->qn_nodenum, dlm->node_num); in dlm_match_nodes()
1202 "joining node %d\n", qn->qn_domain, in dlm_match_nodes()
1205 dlm->node_num, qn->qn_nodenum); in dlm_match_nodes()
1218 struct dlm_query_nodeinfo *qn = NULL; in dlm_send_nodeinfo() local
1225 qn = kzalloc(sizeof(struct dlm_query_nodeinfo), GFP_KERNEL); in dlm_send_nodeinfo()
1226 if (!qn) { in dlm_send_nodeinfo()
1236 qn->qn_nodes[count].ni_nodenum = node->nd_num; in dlm_send_nodeinfo()
1237 qn->qn_nodes[count].ni_ipv4_port = node->nd_ipv4_port; in dlm_send_nodeinfo()
1238 qn->qn_nodes[count].ni_ipv4_address = node->nd_ipv4_address; in dlm_send_nodeinfo()
1245 qn->qn_nodenum = dlm->node_num; in dlm_send_nodeinfo()
1246 qn->qn_numnodes = count; in dlm_send_nodeinfo()
1247 qn->qn_namelen = strlen(dlm->name); in dlm_send_nodeinfo()
1248 memcpy(qn->qn_domain, dlm->name, qn->qn_namelen); in dlm_send_nodeinfo()
1259 qn, sizeof(struct dlm_query_nodeinfo), in dlm_send_nodeinfo()
1270 kfree(qn); in dlm_send_nodeinfo()
1277 struct dlm_query_nodeinfo *qn; in dlm_query_nodeinfo_handler() local
1281 qn = (struct dlm_query_nodeinfo *) msg->buf; in dlm_query_nodeinfo_handler()
1283 mlog(0, "Node %u queries nodes on domain %s\n", qn->qn_nodenum, in dlm_query_nodeinfo_handler()
1284 qn->qn_domain); in dlm_query_nodeinfo_handler()
1287 dlm = __dlm_lookup_domain_full(qn->qn_domain, qn->qn_namelen); in dlm_query_nodeinfo_handler()
1290 "join domain\n", qn->qn_nodenum, qn->qn_domain); in dlm_query_nodeinfo_handler()
1296 if (dlm->joining_node != qn->qn_nodenum) { in dlm_query_nodeinfo_handler()
1298 "joining node is %d\n", qn->qn_nodenum, qn->qn_domain, in dlm_query_nodeinfo_handler()
1307 "but active dlm protocol is %d.%d\n", qn->qn_nodenum, in dlm_query_nodeinfo_handler()
1308 qn->qn_domain, dlm->dlm_locking_proto.pv_major, in dlm_query_nodeinfo_handler()
1313 status = dlm_match_nodes(dlm, qn); in dlm_query_nodeinfo_handler()