Lines Matching refs:node
490 unsigned int node; in dlm_begin_exit_domain_handler() local
496 node = exit_msg->node_idx; in dlm_begin_exit_domain_handler()
497 mlog(0, "%s: Node %u sent a begin exit domain message\n", dlm->name, node); in dlm_begin_exit_domain_handler()
500 set_bit(node, dlm->exit_domain_map); in dlm_begin_exit_domain_handler()
533 int node = -1, num = 0; in __dlm_print_nodes() local
538 while ((node = find_next_bit(dlm->domain_map, O2NM_MAX_NODES, in __dlm_print_nodes()
539 node + 1)) < O2NM_MAX_NODES) { in __dlm_print_nodes()
540 printk("%d ", node); in __dlm_print_nodes()
550 unsigned int node; in dlm_exit_domain_handler() local
558 node = exit_msg->node_idx; in dlm_exit_domain_handler()
561 clear_bit(node, dlm->domain_map); in dlm_exit_domain_handler()
562 clear_bit(node, dlm->exit_domain_map); in dlm_exit_domain_handler()
563 printk(KERN_NOTICE "o2dlm: Node %u leaves domain %s ", node, dlm->name); in dlm_exit_domain_handler()
567 dlm_hb_event_notify_attached(dlm, node, 0); in dlm_exit_domain_handler()
577 unsigned int node) in dlm_send_one_domain_exit() argument
583 msg_type, node); in dlm_send_one_domain_exit()
589 sizeof(leave_msg), node, NULL); in dlm_send_one_domain_exit()
592 "to node %u on domain %s\n", status, msg_type, node, in dlm_send_one_domain_exit()
600 int node = -1; in dlm_begin_exit_domain() local
614 node = find_next_bit(dlm->domain_map, O2NM_MAX_NODES, node + 1); in dlm_begin_exit_domain()
615 if (node >= O2NM_MAX_NODES) in dlm_begin_exit_domain()
617 if (node == dlm->node_num) in dlm_begin_exit_domain()
621 dlm_send_one_domain_exit(dlm, DLM_BEGIN_EXIT_DOMAIN_MSG, node); in dlm_begin_exit_domain()
629 int node, clear_node, status; in dlm_leave_domain() local
639 while ((node = find_next_bit(dlm->domain_map, O2NM_MAX_NODES, in dlm_leave_domain()
652 node); in dlm_leave_domain()
657 "to node %d\n", status, node); in dlm_leave_domain()
670 clear_bit(node, dlm->domain_map); in dlm_leave_domain()
728 static int dlm_query_join_proto_check(char *proto_type, int node, in dlm_query_join_proto_check() argument
739 node, proto_type, in dlm_query_join_proto_check()
749 node, proto_type, in dlm_query_join_proto_check()
1219 struct o2nm_node *node; in dlm_send_nodeinfo() local
1233 node = o2nm_get_node_by_num(i); in dlm_send_nodeinfo()
1234 if (!node) 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()
1239 mlog(0, "Node %3d, %pI4:%u\n", node->nd_num, in dlm_send_nodeinfo()
1240 &(node->nd_ipv4_address), ntohs(node->nd_ipv4_port)); in dlm_send_nodeinfo()
1242 o2nm_node_put(node); in dlm_send_nodeinfo()
1353 unsigned int node) in dlm_send_one_join_cancel() argument
1364 &cancel_msg, sizeof(cancel_msg), node, in dlm_send_one_join_cancel()
1369 node); in dlm_send_one_join_cancel()
1383 int node; in dlm_send_join_cancels() local
1394 node = -1; in dlm_send_join_cancels()
1395 while ((node = find_next_bit(node_map, O2NM_MAX_NODES, in dlm_send_join_cancels()
1396 node + 1)) < O2NM_MAX_NODES) { in dlm_send_join_cancels()
1397 if (node == dlm->node_num) in dlm_send_join_cancels()
1400 tmpstat = dlm_send_one_join_cancel(dlm, node); in dlm_send_join_cancels()
1403 "node %d\n", tmpstat, node); in dlm_send_join_cancels()
1415 int node, in dlm_request_join() argument
1423 mlog(0, "querying node %d\n", node); in dlm_request_join()
1436 sizeof(join_msg), node, &join_resp); in dlm_request_join()
1440 node); in dlm_request_join()
1468 node); in dlm_request_join()
1478 node, in dlm_request_join()
1487 packet.code, node); in dlm_request_join()
1494 mlog(0, "status %d, node %d response is %d\n", status, node, in dlm_request_join()
1502 unsigned int node) in dlm_send_one_join_assert() argument
1508 mlog(0, "Sending join assert to node %u\n", node); in dlm_send_one_join_assert()
1516 &assert_msg, sizeof(assert_msg), node, in dlm_send_one_join_assert()
1521 node); in dlm_send_one_join_assert()
1531 int status, node, live; in dlm_send_join_asserts() local
1534 node = -1; in dlm_send_join_asserts()
1535 while ((node = find_next_bit(node_map, O2NM_MAX_NODES, in dlm_send_join_asserts()
1536 node + 1)) < O2NM_MAX_NODES) { in dlm_send_join_asserts()
1537 if (node == dlm->node_num) in dlm_send_join_asserts()
1544 status = dlm_send_one_join_assert(dlm, node); in dlm_send_join_asserts()
1547 live = test_bit(node, dlm->live_nodes_map); in dlm_send_join_asserts()
1552 "join on node %d\n", status, node); in dlm_send_join_asserts()
1593 int status = 0, tmpstat, node; in dlm_try_to_join_domain() local
1618 node = -1; in dlm_try_to_join_domain()
1619 while ((node = find_next_bit(ctxt->live_map, O2NM_MAX_NODES, in dlm_try_to_join_domain()
1620 node + 1)) < O2NM_MAX_NODES) { in dlm_try_to_join_domain()
1621 if (node == dlm->node_num) in dlm_try_to_join_domain()
1624 status = dlm_request_join(dlm, node, &response); in dlm_try_to_join_domain()
1633 set_bit(node, ctxt->yes_resp_map); in dlm_try_to_join_domain()