Home
last modified time | relevance | path

Searched refs:cp_wq (Results 1 – 6 of 6) sorted by relevance

/linux/net/rds/
H A Dconnection.c290 conn->c_path[i].cp_wq = in __rds_conn_create()
293 if (!conn->c_path[i].cp_wq) in __rds_conn_create()
294 conn->c_path[i].cp_wq = rds_wq; in __rds_conn_create()
370 if (free_cp[i].cp_wq != rds_wq) in __rds_conn_create()
371 destroy_workqueue(free_cp[i].cp_wq); in __rds_conn_create()
557 if (cp->cp_wq != rds_wq) { in rds_conn_path_destroy()
558 destroy_workqueue(cp->cp_wq); in rds_conn_path_destroy()
559 cp->cp_wq = NULL; in rds_conn_path_destroy()
1004 queue_work(cp->cp_wq, &cp->cp_down_w); in rds_conn_path_drop()
1029 queue_delayed_work(cp->cp_wq, &cp->cp_conn_w, 0); in rds_conn_path_connect_if_down()
H A Dsend.c548 queue_delayed_work(cp->cp_wq, in rds_send_xmit()
1382 queue_delayed_work(conn->c_path[0].cp_wq, in rds_sendmsg()
1459 queue_delayed_work(cpath->cp_wq, &cpath->cp_send_w, 1); in rds_sendmsg()
1556 queue_delayed_work(cp->cp_wq, &cp->cp_send_w, 1); in rds_send_probe()
H A Dcong.c245 queue_delayed_work(cp->cp_wq, &cp->cp_send_w, 0); in rds_cong_queue_updates()
H A Dtcp_listen.c322 queue_delayed_work(cp->cp_wq, &cp->cp_recv_w, 0); in rds_tcp_accept_one()
H A Drds.h121 struct workqueue_struct *cp_wq; member
H A Dib_recv.c461 queue_delayed_work(conn->c_path->cp_wq, &conn->c_recv_w, 1); in rds_ib_recv_refill()