Lines Matching refs:nn
283 static u8 o2net_num_from_nn(struct o2net_node *nn) in o2net_num_from_nn() argument
285 BUG_ON(nn == NULL); in o2net_num_from_nn()
286 return nn - o2net_nodes; in o2net_num_from_nn()
291 static int o2net_prep_nsw(struct o2net_node *nn, struct o2net_status_wait *nsw) in o2net_prep_nsw() argument
295 spin_lock(&nn->nn_lock); in o2net_prep_nsw()
296 ret = idr_alloc(&nn->nn_status_idr, nsw, 0, 0, GFP_ATOMIC); in o2net_prep_nsw()
299 list_add_tail(&nsw->ns_node_item, &nn->nn_status_list); in o2net_prep_nsw()
301 spin_unlock(&nn->nn_lock); in o2net_prep_nsw()
311 static void o2net_complete_nsw_locked(struct o2net_node *nn, in o2net_complete_nsw_locked() argument
316 assert_spin_locked(&nn->nn_lock); in o2net_complete_nsw_locked()
322 idr_remove(&nn->nn_status_idr, nsw->ns_id); in o2net_complete_nsw_locked()
327 static void o2net_complete_nsw(struct o2net_node *nn, in o2net_complete_nsw() argument
332 spin_lock(&nn->nn_lock); in o2net_complete_nsw()
337 nsw = idr_find(&nn->nn_status_idr, id); in o2net_complete_nsw()
342 o2net_complete_nsw_locked(nn, nsw, sys_status, status); in o2net_complete_nsw()
345 spin_unlock(&nn->nn_lock); in o2net_complete_nsw()
349 static void o2net_complete_nodes_nsw(struct o2net_node *nn) in o2net_complete_nodes_nsw() argument
354 assert_spin_locked(&nn->nn_lock); in o2net_complete_nodes_nsw()
356 list_for_each_entry_safe(nsw, tmp, &nn->nn_status_list, ns_node_item) { in o2net_complete_nodes_nsw()
357 o2net_complete_nsw_locked(nn, nsw, O2NET_ERR_DIED, 0); in o2net_complete_nodes_nsw()
362 o2net_num_from_nn(nn)); in o2net_complete_nodes_nsw()
365 static int o2net_nsw_completed(struct o2net_node *nn, in o2net_nsw_completed() argument
369 spin_lock(&nn->nn_lock); in o2net_nsw_completed()
371 spin_unlock(&nn->nn_lock); in o2net_nsw_completed()
487 static void o2net_set_nn_state(struct o2net_node *nn, in o2net_set_nn_state() argument
491 int was_valid = nn->nn_sc_valid; in o2net_set_nn_state()
492 int was_err = nn->nn_persistent_error; in o2net_set_nn_state()
493 struct o2net_sock_container *old_sc = nn->nn_sc; in o2net_set_nn_state()
495 assert_spin_locked(&nn->nn_lock); in o2net_set_nn_state()
504 BUG_ON(sc && nn->nn_sc && nn->nn_sc != sc); in o2net_set_nn_state()
512 o2net_num_from_nn(nn), nn->nn_sc, sc, nn->nn_sc_valid, valid, in o2net_set_nn_state()
513 nn->nn_persistent_error, err); in o2net_set_nn_state()
515 nn->nn_sc = sc; in o2net_set_nn_state()
516 nn->nn_sc_valid = valid ? 1 : 0; in o2net_set_nn_state()
517 nn->nn_persistent_error = err; in o2net_set_nn_state()
520 if (nn->nn_persistent_error || nn->nn_sc_valid) in o2net_set_nn_state()
521 wake_up(&nn->nn_sc_wq); in o2net_set_nn_state()
523 if (was_valid && !was_err && nn->nn_persistent_error) { in o2net_set_nn_state()
524 o2quo_conn_err(o2net_num_from_nn(nn)); in o2net_set_nn_state()
525 queue_delayed_work(o2net_wq, &nn->nn_still_up, in o2net_set_nn_state()
533 o2net_complete_nodes_nsw(nn); in o2net_set_nn_state()
537 o2quo_conn_up(o2net_num_from_nn(nn)); in o2net_set_nn_state()
538 cancel_delayed_work(&nn->nn_connect_expired); in o2net_set_nn_state()
553 delay = (nn->nn_last_connect_attempt + in o2net_set_nn_state()
559 queue_delayed_work(o2net_wq, &nn->nn_connect_work, delay); in o2net_set_nn_state()
571 queue_delayed_work(o2net_wq, &nn->nn_connect_expired, delay); in o2net_set_nn_state()
696 static void o2net_ensure_shutdown(struct o2net_node *nn, in o2net_ensure_shutdown() argument
700 spin_lock(&nn->nn_lock); in o2net_ensure_shutdown()
701 if (nn->nn_sc == sc) in o2net_ensure_shutdown()
702 o2net_set_nn_state(nn, NULL, 0, err); in o2net_ensure_shutdown()
703 spin_unlock(&nn->nn_lock); in o2net_ensure_shutdown()
719 struct o2net_node *nn = o2net_nn_from_num(sc->sc_node->nd_num); in o2net_shutdown_sc() local
735 o2net_ensure_shutdown(nn, sc, 0); in o2net_shutdown_sc()
935 struct o2net_node *nn = o2net_nn_from_num(sc->sc_node->nd_num); in o2net_sendpage() local
959 o2net_ensure_shutdown(nn, sc, 0); in o2net_sendpage()
975 static int o2net_tx_can_proceed(struct o2net_node *nn, in o2net_tx_can_proceed() argument
981 spin_lock(&nn->nn_lock); in o2net_tx_can_proceed()
982 if (nn->nn_persistent_error) { in o2net_tx_can_proceed()
985 *error = nn->nn_persistent_error; in o2net_tx_can_proceed()
986 } else if (nn->nn_sc_valid) { in o2net_tx_can_proceed()
987 kref_get(&nn->nn_sc->sc_kref); in o2net_tx_can_proceed()
990 *sc_ret = nn->nn_sc; in o2net_tx_can_proceed()
993 spin_unlock(&nn->nn_lock); in o2net_tx_can_proceed()
1024 struct o2net_node *nn = o2net_nn_from_num(target_node); in o2net_send_message_vec() local
1060 wait_event(nn->nn_sc_wq, o2net_tx_can_proceed(nn, &sc, &ret)); in o2net_send_message_vec()
1087 ret = o2net_prep_nsw(nn, &nsw); in o2net_send_message_vec()
1110 wait_event(nsw.ns_wq, o2net_nsw_completed(nn, &nsw)); in o2net_send_message_vec()
1129 o2net_complete_nsw(nn, &nsw, 0, 0, 0); in o2net_send_message_vec()
1173 struct o2net_node *nn = o2net_nn_from_num(sc->sc_node->nd_num); in o2net_process_message() local
1186 o2net_complete_nsw(nn, NULL, in o2net_process_message()
1260 struct o2net_node *nn = o2net_nn_from_num(sc->sc_node->nd_num); in o2net_check_handshake() local
1270 o2net_ensure_shutdown(nn, sc, -ENOTCONN); in o2net_check_handshake()
1286 o2net_ensure_shutdown(nn, sc, -ENOTCONN); in o2net_check_handshake()
1297 o2net_ensure_shutdown(nn, sc, -ENOTCONN); in o2net_check_handshake()
1308 o2net_ensure_shutdown(nn, sc, -ENOTCONN); in o2net_check_handshake()
1314 spin_lock(&nn->nn_lock); in o2net_check_handshake()
1317 if (nn->nn_sc == sc) { in o2net_check_handshake()
1319 atomic_set(&nn->nn_timeout, 0); in o2net_check_handshake()
1320 o2net_set_nn_state(nn, sc, 1, 0); in o2net_check_handshake()
1322 spin_unlock(&nn->nn_lock); in o2net_check_handshake()
1436 struct o2net_node *nn = o2net_nn_from_num(sc->sc_node->nd_num); in o2net_rx_until_empty() local
1439 o2net_ensure_shutdown(nn, sc, 0); in o2net_rx_until_empty()
1492 struct o2net_node *nn = o2net_nn_from_num(sc->sc_node->nd_num); in o2net_idle_timer() local
1508 atomic_set(&nn->nn_timeout, 1); in o2net_idle_timer()
1509 o2quo_conn_err(o2net_num_from_nn(nn)); in o2net_idle_timer()
1510 queue_delayed_work(o2net_wq, &nn->nn_still_up, in o2net_idle_timer()
1529 struct o2net_node *nn = o2net_nn_from_num(sc->sc_node->nd_num); in o2net_sc_postpone_idle() local
1532 if (atomic_read(&nn->nn_timeout)) { in o2net_sc_postpone_idle()
1533 o2quo_conn_up(o2net_num_from_nn(nn)); in o2net_sc_postpone_idle()
1534 cancel_delayed_work(&nn->nn_still_up); in o2net_sc_postpone_idle()
1535 atomic_set(&nn->nn_timeout, 0); in o2net_sc_postpone_idle()
1550 struct o2net_node *nn = in o2net_start_connect() local
1566 if (o2nm_this_node() <= o2net_num_from_nn(nn)) in o2net_start_connect()
1570 node = o2nm_get_node_by_num(o2net_num_from_nn(nn)); in o2net_start_connect()
1578 spin_lock(&nn->nn_lock); in o2net_start_connect()
1586 timeout = atomic_read(&nn->nn_timeout); in o2net_start_connect()
1587 stop = (nn->nn_sc || in o2net_start_connect()
1588 (nn->nn_persistent_error && in o2net_start_connect()
1589 (nn->nn_persistent_error != -ENOTCONN || timeout == 0))); in o2net_start_connect()
1590 spin_unlock(&nn->nn_lock); in o2net_start_connect()
1594 nn->nn_last_connect_attempt = jiffies; in o2net_start_connect()
1630 spin_lock(&nn->nn_lock); in o2net_start_connect()
1632 o2net_set_nn_state(nn, sc, 0, 0); in o2net_start_connect()
1633 spin_unlock(&nn->nn_lock); in o2net_start_connect()
1652 o2net_ensure_shutdown(nn, sc, 0); in o2net_start_connect()
1667 struct o2net_node *nn = in o2net_connect_expired() local
1670 spin_lock(&nn->nn_lock); in o2net_connect_expired()
1671 if (!nn->nn_sc_valid) { in o2net_connect_expired()
1675 o2net_num_from_nn(nn), in o2net_connect_expired()
1679 o2net_set_nn_state(nn, NULL, 0, 0); in o2net_connect_expired()
1681 spin_unlock(&nn->nn_lock); in o2net_connect_expired()
1686 struct o2net_node *nn = in o2net_still_up() local
1689 o2quo_hb_still_up(o2net_num_from_nn(nn)); in o2net_still_up()
1696 struct o2net_node *nn = o2net_nn_from_num(node->nd_num); in o2net_disconnect_node() local
1699 spin_lock(&nn->nn_lock); in o2net_disconnect_node()
1700 atomic_set(&nn->nn_timeout, 0); in o2net_disconnect_node()
1701 o2net_set_nn_state(nn, NULL, 0, -ENOTCONN); in o2net_disconnect_node()
1702 spin_unlock(&nn->nn_lock); in o2net_disconnect_node()
1705 cancel_delayed_work(&nn->nn_connect_expired); in o2net_disconnect_node()
1706 cancel_delayed_work(&nn->nn_connect_work); in o2net_disconnect_node()
1707 cancel_delayed_work(&nn->nn_still_up); in o2net_disconnect_node()
1729 struct o2net_node *nn = o2net_nn_from_num(node_num); in o2net_hb_node_up_cb() local
1736 nn->nn_last_connect_attempt = jiffies - in o2net_hb_node_up_cb()
1744 spin_lock(&nn->nn_lock); in o2net_hb_node_up_cb()
1745 atomic_set(&nn->nn_timeout, 0); in o2net_hb_node_up_cb()
1746 if (nn->nn_persistent_error) in o2net_hb_node_up_cb()
1747 o2net_set_nn_state(nn, NULL, 0, 0); in o2net_hb_node_up_cb()
1748 spin_unlock(&nn->nn_lock); in o2net_hb_node_up_cb()
1787 struct o2net_node *nn; in o2net_accept_one() local
1855 nn = o2net_nn_from_num(node->nd_num); in o2net_accept_one()
1857 spin_lock(&nn->nn_lock); in o2net_accept_one()
1858 if (nn->nn_sc) in o2net_accept_one()
1862 spin_unlock(&nn->nn_lock); in o2net_accept_one()
1880 spin_lock(&nn->nn_lock); in o2net_accept_one()
1881 atomic_set(&nn->nn_timeout, 0); in o2net_accept_one()
1882 o2net_set_nn_state(nn, sc, 0, 0); in o2net_accept_one()
1883 spin_unlock(&nn->nn_lock); in o2net_accept_one()
2118 struct o2net_node *nn = o2net_nn_from_num(i); in o2net_init() local
2120 atomic_set(&nn->nn_timeout, 0); in o2net_init()
2121 spin_lock_init(&nn->nn_lock); in o2net_init()
2122 INIT_DELAYED_WORK(&nn->nn_connect_work, o2net_start_connect); in o2net_init()
2123 INIT_DELAYED_WORK(&nn->nn_connect_expired, in o2net_init()
2125 INIT_DELAYED_WORK(&nn->nn_still_up, o2net_still_up); in o2net_init()
2127 nn->nn_persistent_error = -ENOTCONN; in o2net_init()
2128 init_waitqueue_head(&nn->nn_sc_wq); in o2net_init()
2129 idr_init(&nn->nn_status_idr); in o2net_init()
2130 INIT_LIST_HEAD(&nn->nn_status_list); in o2net_init()