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