Lines Matching refs:node
493 unsigned int node; in dlm_begin_exit_domain_handler() local
499 node = exit_msg->node_idx; in dlm_begin_exit_domain_handler()
500 mlog(0, "%s: Node %u sent a begin exit domain message\n", dlm->name, node); in dlm_begin_exit_domain_handler()
503 set_bit(node, dlm->exit_domain_map); in dlm_begin_exit_domain_handler()
536 int node = -1, num = 0; in __dlm_print_nodes() local
541 while ((node = find_next_bit(dlm->domain_map, O2NM_MAX_NODES, in __dlm_print_nodes()
542 node + 1)) < O2NM_MAX_NODES) { in __dlm_print_nodes()
543 printk("%d ", node); in __dlm_print_nodes()
553 unsigned int node; in dlm_exit_domain_handler() local
561 node = exit_msg->node_idx; in dlm_exit_domain_handler()
564 clear_bit(node, dlm->domain_map); in dlm_exit_domain_handler()
565 clear_bit(node, dlm->exit_domain_map); in dlm_exit_domain_handler()
566 printk(KERN_NOTICE "o2dlm: Node %u leaves domain %s ", node, dlm->name); in dlm_exit_domain_handler()
570 dlm_hb_event_notify_attached(dlm, node, 0); in dlm_exit_domain_handler()
580 unsigned int node) in dlm_send_one_domain_exit() argument
586 msg_type, node); in dlm_send_one_domain_exit()
592 sizeof(leave_msg), node, NULL); in dlm_send_one_domain_exit()
595 "to node %u on domain %s\n", status, msg_type, node, in dlm_send_one_domain_exit()
603 int node = -1; in dlm_begin_exit_domain() local
617 node = find_next_bit(dlm->domain_map, O2NM_MAX_NODES, node + 1); in dlm_begin_exit_domain()
618 if (node >= O2NM_MAX_NODES) in dlm_begin_exit_domain()
620 if (node == dlm->node_num) in dlm_begin_exit_domain()
624 dlm_send_one_domain_exit(dlm, DLM_BEGIN_EXIT_DOMAIN_MSG, node); in dlm_begin_exit_domain()
632 int node, clear_node, status; in dlm_leave_domain() local
642 while ((node = find_next_bit(dlm->domain_map, O2NM_MAX_NODES, in dlm_leave_domain()
655 node); in dlm_leave_domain()
660 "to node %d\n", status, node); in dlm_leave_domain()
673 clear_bit(node, dlm->domain_map); in dlm_leave_domain()
745 static int dlm_query_join_proto_check(char *proto_type, int node, in dlm_query_join_proto_check() argument
756 node, proto_type, in dlm_query_join_proto_check()
766 node, proto_type, in dlm_query_join_proto_check()
1236 struct o2nm_node *node; in dlm_send_nodeinfo() local
1250 node = o2nm_get_node_by_num(i); in dlm_send_nodeinfo()
1251 if (!node) in dlm_send_nodeinfo()
1253 qn->qn_nodes[count].ni_nodenum = node->nd_num; in dlm_send_nodeinfo()
1254 qn->qn_nodes[count].ni_ipv4_port = node->nd_ipv4_port; in dlm_send_nodeinfo()
1255 qn->qn_nodes[count].ni_ipv4_address = node->nd_ipv4_address; in dlm_send_nodeinfo()
1256 mlog(0, "Node %3d, %pI4:%u\n", node->nd_num, in dlm_send_nodeinfo()
1257 &(node->nd_ipv4_address), ntohs(node->nd_ipv4_port)); in dlm_send_nodeinfo()
1259 o2nm_node_put(node); in dlm_send_nodeinfo()
1370 unsigned int node) in dlm_send_one_join_cancel() argument
1381 &cancel_msg, sizeof(cancel_msg), node, in dlm_send_one_join_cancel()
1386 node); in dlm_send_one_join_cancel()
1400 int node; in dlm_send_join_cancels() local
1411 node = -1; in dlm_send_join_cancels()
1412 while ((node = find_next_bit(node_map, O2NM_MAX_NODES, in dlm_send_join_cancels()
1413 node + 1)) < O2NM_MAX_NODES) { in dlm_send_join_cancels()
1414 if (node == dlm->node_num) in dlm_send_join_cancels()
1417 tmpstat = dlm_send_one_join_cancel(dlm, node); in dlm_send_join_cancels()
1420 "node %d\n", tmpstat, node); in dlm_send_join_cancels()
1432 int node, in dlm_request_join() argument
1440 mlog(0, "querying node %d\n", node); in dlm_request_join()
1453 sizeof(join_msg), node, &join_resp); in dlm_request_join()
1457 node); in dlm_request_join()
1485 node); in dlm_request_join()
1495 node, in dlm_request_join()
1504 packet.code, node); in dlm_request_join()
1511 mlog(0, "status %d, node %d response is %d\n", status, node, in dlm_request_join()
1519 unsigned int node) in dlm_send_one_join_assert() argument
1525 mlog(0, "Sending join assert to node %u\n", node); in dlm_send_one_join_assert()
1533 &assert_msg, sizeof(assert_msg), node, in dlm_send_one_join_assert()
1538 node); in dlm_send_one_join_assert()
1548 int status, node, live; in dlm_send_join_asserts() local
1551 node = -1; in dlm_send_join_asserts()
1552 while ((node = find_next_bit(node_map, O2NM_MAX_NODES, in dlm_send_join_asserts()
1553 node + 1)) < O2NM_MAX_NODES) { in dlm_send_join_asserts()
1554 if (node == dlm->node_num) in dlm_send_join_asserts()
1561 status = dlm_send_one_join_assert(dlm, node); in dlm_send_join_asserts()
1564 live = test_bit(node, dlm->live_nodes_map); in dlm_send_join_asserts()
1569 "join on node %d\n", status, node); in dlm_send_join_asserts()
1610 int status = 0, tmpstat, node; in dlm_try_to_join_domain() local
1635 node = -1; in dlm_try_to_join_domain()
1636 while ((node = find_next_bit(ctxt->live_map, O2NM_MAX_NODES, in dlm_try_to_join_domain()
1637 node + 1)) < O2NM_MAX_NODES) { in dlm_try_to_join_domain()
1638 if (node == dlm->node_num) in dlm_try_to_join_domain()
1641 status = dlm_request_join(dlm, node, &response); in dlm_try_to_join_domain()
1650 set_bit(node, ctxt->yes_resp_map); in dlm_try_to_join_domain()