Searched refs:rds_wq (Results 1 – 12 of 12) sorted by relevance
/linux/net/rds/ |
H A D | threads.c | 71 struct workqueue_struct *rds_wq; variable 72 EXPORT_SYMBOL_GPL(rds_wq); 92 queue_delayed_work(rds_wq, &cp->cp_send_w, 0); in rds_connect_path_complete() 93 queue_delayed_work(rds_wq, &cp->cp_recv_w, 0); in rds_connect_path_complete() 143 queue_delayed_work(rds_wq, &cp->cp_conn_w, 0); in rds_queue_reconnect() 154 queue_delayed_work(rds_wq, &cp->cp_conn_w, in rds_queue_reconnect() 206 queue_delayed_work(rds_wq, &cp->cp_send_w, 0); in rds_send_worker() 210 queue_delayed_work(rds_wq, &cp->cp_send_w, 2); in rds_send_worker() 231 queue_delayed_work(rds_wq, &cp->cp_recv_w, 0); in rds_recv_worker() 235 queue_delayed_work(rds_wq, &cp->cp_recv_w, 2); in rds_recv_worker() [all …]
|
H A D | ib.c | 125 queue_work(rds_wq, &rds_ibdev->free_work); in rds_ib_dev_put() 496 flush_workqueue(rds_wq); in rds_ib_unregister_client()
|
H A D | tcp_send.c | 204 queue_delayed_work(rds_wq, &cp->cp_send_w, 0); in rds_tcp_write_space()
|
H A D | tcp_listen.c | 351 flush_workqueue(rds_wq); in rds_tcp_listen_stop()
|
H A D | tcp_recv.c | 330 queue_delayed_work(rds_wq, &cp->cp_recv_w, 0); in rds_tcp_data_ready()
|
H A D | cong.c | 245 queue_delayed_work(rds_wq, &cp->cp_send_w, 0); in rds_cong_queue_updates()
|
H A D | send.c | 461 queue_delayed_work(rds_wq, &cp->cp_send_w, 1); in rds_send_xmit() 1383 queue_delayed_work(rds_wq, &cpath->cp_send_w, 1); in rds_sendmsg() 1476 queue_delayed_work(rds_wq, &cp->cp_send_w, 1); in rds_send_probe()
|
H A D | connection.c | 888 queue_work(rds_wq, &cp->cp_down_w); in rds_conn_path_drop() 913 queue_delayed_work(rds_wq, &cp->cp_conn_w, 0); in rds_conn_path_connect_if_down()
|
H A D | ib_send.c | 300 queue_delayed_work(rds_wq, &conn->c_send_w, 0); in rds_ib_send_cqe_handler() 422 queue_delayed_work(rds_wq, &conn->c_send_w, 0); in rds_ib_send_add_credits()
|
H A D | tcp.c | 542 queue_work(rds_wq, &rtn->rds_tcp_accept_w); in rds_tcp_accept_work()
|
H A D | rds.h | 995 extern struct workqueue_struct *rds_wq;
|
H A D | ib_recv.c | 460 queue_delayed_work(rds_wq, &conn->c_recv_w, 1); in rds_ib_recv_refill()
|