Lines Matching refs:node
134 u32 msgkey, struct task_struct *task, u8 node) in o2net_init_nst() argument
140 nst->st_node = node; in o2net_init_nst()
411 static struct o2net_sock_container *sc_alloc(struct o2nm_node *node) in sc_alloc() argument
423 o2nm_node_get(node); in sc_alloc()
424 sc->sc_node = node; in sc_alloc()
427 status = o2nm_depend_item(&node->nd_item); in sc_alloc()
430 o2nm_node_put(node); in sc_alloc()
1002 int node, ret; in o2net_fill_node_map() local
1005 for (node = 0; node < O2NM_MAX_NODES; ++node) { in o2net_fill_node_map()
1006 if (!o2net_tx_can_proceed(o2net_nn_from_num(node), &sc, &ret)) in o2net_fill_node_map()
1009 set_bit(node, map); in o2net_fill_node_map()
1553 struct o2nm_node *node = NULL, *mynode = NULL; in o2net_start_connect() local
1570 node = o2nm_get_node_by_num(o2net_num_from_nn(nn)); in o2net_start_connect()
1571 if (node == NULL) in o2net_start_connect()
1596 sc = sc_alloc(node); in o2net_start_connect()
1636 remoteaddr.sin_addr.s_addr = node->nd_ipv4_address; in o2net_start_connect()
1637 remoteaddr.sin_port = node->nd_ipv4_port; in o2net_start_connect()
1656 if (node) in o2net_start_connect()
1657 o2nm_node_put(node); in o2net_start_connect()
1694 void o2net_disconnect_node(struct o2nm_node *node) in o2net_disconnect_node() argument
1696 struct o2net_node *nn = o2net_nn_from_num(node->nd_num); in o2net_disconnect_node()
1712 static void o2net_hb_node_down_cb(struct o2nm_node *node, int node_num, in o2net_hb_node_down_cb() argument
1717 if (!node) in o2net_hb_node_down_cb()
1721 o2net_disconnect_node(node); in o2net_hb_node_down_cb()
1726 static void o2net_hb_node_up_cb(struct o2nm_node *node, int node_num, in o2net_hb_node_up_cb() argument
1733 BUG_ON(!node); in o2net_hb_node_up_cb()
1784 struct o2nm_node *node = NULL; in o2net_accept_one() local
1822 node = o2nm_get_node_by_ip(sin.sin_addr.s_addr); in o2net_accept_one()
1823 if (node == NULL) { in o2net_accept_one()
1831 if (o2nm_this_node() >= node->nd_num) { in o2net_accept_one()
1840 node->nd_name, in o2net_accept_one()
1841 node->nd_num, &sin.sin_addr.s_addr, in o2net_accept_one()
1849 if (!o2hb_check_node_heartbeating_from_callback(node->nd_num)) { in o2net_accept_one()
1852 node->nd_name, &sin.sin_addr.s_addr, in o2net_accept_one()
1858 nn = o2net_nn_from_num(node->nd_num); in o2net_accept_one()
1869 node->nd_name, &sin.sin_addr.s_addr, in o2net_accept_one()
1874 sc = sc_alloc(node); in o2net_accept_one()
1897 if (node) in o2net_accept_one()
1898 o2nm_node_put(node); in o2net_accept_one()
2032 int o2net_start_listening(struct o2nm_node *node) in o2net_start_listening() argument
2046 ret = o2net_open_listening_sock(node->nd_ipv4_address, in o2net_start_listening()
2047 node->nd_ipv4_port); in o2net_start_listening()
2052 o2quo_conn_up(node->nd_num); in o2net_start_listening()
2059 void o2net_stop_listening(struct o2nm_node *node) in o2net_stop_listening() argument
2074 struct o2nm_node *node = o2nm_get_node_by_num(i); in o2net_stop_listening() local
2075 if (node) { in o2net_stop_listening()
2076 o2net_disconnect_node(node); in o2net_stop_listening()
2077 o2nm_node_put(node); in o2net_stop_listening()
2089 o2quo_conn_err(node->nd_num); in o2net_stop_listening()