Lines Matching refs:qn
1172 static int dlm_match_nodes(struct dlm_ctxt *dlm, struct dlm_query_nodeinfo *qn) in dlm_match_nodes() argument
1179 for (j = 0; j < qn->qn_numnodes; ++j) in dlm_match_nodes()
1180 mlog(0, "Node %3d, %pI4:%u\n", qn->qn_nodes[j].ni_nodenum, in dlm_match_nodes()
1181 &(qn->qn_nodes[j].ni_ipv4_address), in dlm_match_nodes()
1182 ntohs(qn->qn_nodes[j].ni_ipv4_port)); in dlm_match_nodes()
1187 for (j = 0; j < qn->qn_numnodes; ++j) { in dlm_match_nodes()
1188 if (qn->qn_nodes[j].ni_nodenum == i) { in dlm_match_nodes()
1189 remote = &(qn->qn_nodes[j]); in dlm_match_nodes()
1210 "local node %d\n", qn->qn_domain, in dlm_match_nodes()
1214 qn->qn_nodenum, dlm->node_num); in dlm_match_nodes()
1218 "joining node %d\n", qn->qn_domain, in dlm_match_nodes()
1221 dlm->node_num, qn->qn_nodenum); in dlm_match_nodes()
1234 struct dlm_query_nodeinfo *qn = NULL; in dlm_send_nodeinfo() local
1241 qn = kzalloc(sizeof(struct dlm_query_nodeinfo), GFP_KERNEL); in dlm_send_nodeinfo()
1242 if (!qn) { in dlm_send_nodeinfo()
1252 qn->qn_nodes[count].ni_nodenum = node->nd_num; in dlm_send_nodeinfo()
1253 qn->qn_nodes[count].ni_ipv4_port = node->nd_ipv4_port; in dlm_send_nodeinfo()
1254 qn->qn_nodes[count].ni_ipv4_address = node->nd_ipv4_address; in dlm_send_nodeinfo()
1261 qn->qn_nodenum = dlm->node_num; in dlm_send_nodeinfo()
1262 qn->qn_numnodes = count; in dlm_send_nodeinfo()
1263 qn->qn_namelen = strlen(dlm->name); in dlm_send_nodeinfo()
1264 memcpy(qn->qn_domain, dlm->name, qn->qn_namelen); in dlm_send_nodeinfo()
1275 qn, sizeof(struct dlm_query_nodeinfo), in dlm_send_nodeinfo()
1286 kfree(qn); in dlm_send_nodeinfo()
1293 struct dlm_query_nodeinfo *qn; in dlm_query_nodeinfo_handler() local
1297 qn = (struct dlm_query_nodeinfo *) msg->buf; in dlm_query_nodeinfo_handler()
1299 mlog(0, "Node %u queries nodes on domain %s\n", qn->qn_nodenum, in dlm_query_nodeinfo_handler()
1300 qn->qn_domain); in dlm_query_nodeinfo_handler()
1303 dlm = __dlm_lookup_domain_full(qn->qn_domain, qn->qn_namelen); in dlm_query_nodeinfo_handler()
1306 "join domain\n", qn->qn_nodenum, qn->qn_domain); in dlm_query_nodeinfo_handler()
1312 if (dlm->joining_node != qn->qn_nodenum) { in dlm_query_nodeinfo_handler()
1314 "joining node is %d\n", qn->qn_nodenum, qn->qn_domain, in dlm_query_nodeinfo_handler()
1323 "but active dlm protocol is %d.%d\n", qn->qn_nodenum, in dlm_query_nodeinfo_handler()
1324 qn->qn_domain, dlm->dlm_locking_proto.pv_major, in dlm_query_nodeinfo_handler()
1329 status = dlm_match_nodes(dlm, qn); in dlm_query_nodeinfo_handler()