| /kernel/linux/linux-5.10/net/rds/ |
| H A D | threads.c | 71 struct workqueue_struct *rds_wq; variable
72 EXPORT_SYMBOL_GPL(rds_wq); variable
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()
230 queue_delayed_work(rds_wq, &cp->cp_recv_w, 0); in rds_recv_worker()
234 queue_delayed_work(rds_wq, in rds_recv_worker()
[all...] |
| H A D | tcp_send.c | 203 queue_delayed_work(rds_wq, &cp->cp_send_w, 0); in rds_tcp_write_space()
|
| 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_listen.c | 342 flush_workqueue(rds_wq); in rds_tcp_listen_stop()
|
| H A D | tcp_recv.c | 328 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 | 462 queue_delayed_work(rds_wq, &cp->cp_send_w, 1); in rds_send_xmit()
1389 queue_delayed_work(rds_wq, &cpath->cp_send_w, 1); in rds_sendmsg()
1479 /* schedule the send work on rds_wq */ in rds_send_probe()
1482 queue_delayed_work(rds_wq, &cp->cp_send_w, 1); in rds_send_probe()
|
| H A D | ib_send.c | 301 queue_delayed_work(rds_wq, &conn->c_send_w, 0); in rds_ib_send_cqe_handler()
423 queue_delayed_work(rds_wq, &conn->c_send_w, 0); in rds_ib_send_add_credits()
|
| H A D | connection.c | 890 queue_work(rds_wq, &cp->cp_down_w); in rds_conn_path_drop()
915 queue_delayed_work(rds_wq, &cp->cp_conn_w, 0); in rds_conn_path_connect_if_down()
|
| H A D | tcp.c | 524 queue_work(rds_wq, &rtn->rds_tcp_accept_w); in rds_tcp_accept_work()
|
| H A D | ib_recv.c | 459 queue_delayed_work(rds_wq, &conn->c_recv_w, 1); in rds_ib_recv_refill()
|
| H A D | rds.h | 996 extern struct workqueue_struct *rds_wq;
|
| /kernel/linux/linux-6.6/net/rds/ |
| H A D | threads.c | 71 struct workqueue_struct *rds_wq; variable
72 EXPORT_SYMBOL_GPL(rds_wq); variable
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, in rds_recv_worker()
[all...] |
| 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 | 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_listen.c | 347 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()
1473 /* schedule the send work on rds_wq */ in rds_send_probe()
1476 queue_delayed_work(rds_wq, &cp->cp_send_w, 1); in rds_send_probe()
|
| 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 | connection.c | 890 queue_work(rds_wq, &cp->cp_down_w); in rds_conn_path_drop()
915 queue_delayed_work(rds_wq, &cp->cp_conn_w, 0); in rds_conn_path_connect_if_down()
|
| H A D | tcp.c | 541 queue_work(rds_wq, &rtn->rds_tcp_accept_w); in rds_tcp_accept_work()
|
| H A D | ib_recv.c | 460 queue_delayed_work(rds_wq, &conn->c_recv_w, 1); in rds_ib_recv_refill()
|
| H A D | rds.h | 995 extern struct workqueue_struct *rds_wq;
|