Lines Matching refs:o2net_wq
108 static struct workqueue_struct *o2net_wq; variable
463 if (!queue_work(o2net_wq, work)) in o2net_sc_queue_work()
471 if (!queue_delayed_work(o2net_wq, work, delay)) in o2net_sc_queue_delayed_work()
526 queue_delayed_work(o2net_wq, &nn->nn_still_up, in o2net_set_nn_state()
550 if (!valid && o2net_wq) { in o2net_set_nn_state()
560 queue_delayed_work(o2net_wq, &nn->nn_connect_work, delay); in o2net_set_nn_state()
572 queue_delayed_work(o2net_wq, &nn->nn_connect_expired, delay); in o2net_set_nn_state()
1030 if (o2net_wq == NULL) { in o2net_send_message_vec()
1509 queue_delayed_work(o2net_wq, &nn->nn_still_up, in o2net_idle_timer()
1702 if (o2net_wq) { in o2net_disconnect_node()
1706 flush_workqueue(o2net_wq); in o2net_disconnect_node()
1959 queue_work(o2net_wq, &o2net_listen_work); in o2net_listen_data_ready()
2029 BUG_ON(o2net_wq != NULL); in o2net_start_listening()
2033 o2net_wq = alloc_ordered_workqueue("o2net", WQ_MEM_RECLAIM); in o2net_start_listening()
2034 if (o2net_wq == NULL) { in o2net_start_listening()
2042 destroy_workqueue(o2net_wq); in o2net_start_listening()
2043 o2net_wq = NULL; in o2net_start_listening()
2057 BUG_ON(o2net_wq == NULL); in o2net_stop_listening()
2076 destroy_workqueue(o2net_wq); in o2net_stop_listening()
2077 o2net_wq = NULL; in o2net_stop_listening()