Lines Matching defs:qn
1154 static int dlm_match_nodes(struct dlm_ctxt *dlm, struct dlm_query_nodeinfo *qn)
1161 for (j = 0; j < qn->qn_numnodes; ++j)
1162 mlog(0, "Node %3d, %pI4:%u\n", qn->qn_nodes[j].ni_nodenum,
1163 &(qn->qn_nodes[j].ni_ipv4_address),
1164 ntohs(qn->qn_nodes[j].ni_ipv4_port));
1169 for (j = 0; j < qn->qn_numnodes; ++j) {
1170 if (qn->qn_nodes[j].ni_nodenum == i) {
1171 remote = &(qn->qn_nodes[j]);
1192 "local node %d\n", qn->qn_domain,
1196 qn->qn_nodenum, dlm->node_num);
1200 "joining node %d\n", qn->qn_domain,
1203 dlm->node_num, qn->qn_nodenum);
1216 struct dlm_query_nodeinfo *qn = NULL;
1223 qn = kzalloc(sizeof(struct dlm_query_nodeinfo), GFP_KERNEL);
1224 if (!qn) {
1234 qn->qn_nodes[count].ni_nodenum = node->nd_num;
1235 qn->qn_nodes[count].ni_ipv4_port = node->nd_ipv4_port;
1236 qn->qn_nodes[count].ni_ipv4_address = node->nd_ipv4_address;
1243 qn->qn_nodenum = dlm->node_num;
1244 qn->qn_numnodes = count;
1245 qn->qn_namelen = strlen(dlm->name);
1246 memcpy(qn->qn_domain, dlm->name, qn->qn_namelen);
1257 qn, sizeof(struct dlm_query_nodeinfo),
1268 kfree(qn);
1275 struct dlm_query_nodeinfo *qn;
1279 qn = (struct dlm_query_nodeinfo *) msg->buf;
1281 mlog(0, "Node %u queries nodes on domain %s\n", qn->qn_nodenum,
1282 qn->qn_domain);
1285 dlm = __dlm_lookup_domain_full(qn->qn_domain, qn->qn_namelen);
1288 "join domain\n", qn->qn_nodenum, qn->qn_domain);
1294 if (dlm->joining_node != qn->qn_nodenum) {
1296 "joining node is %d\n", qn->qn_nodenum, qn->qn_domain,
1305 "but active dlm protocol is %d.%d\n", qn->qn_nodenum,
1306 qn->qn_domain, dlm->dlm_locking_proto.pv_major,
1311 status = dlm_match_nodes(dlm, qn);