Lines Matching refs:conn
87 rdsv3_connect_complete(struct rdsv3_connection *conn) in rdsv3_connect_complete() argument
89 RDSV3_DPRINTF4("rdsv3_connect_complete", "Enter(conn: %p)", conn); in rdsv3_connect_complete()
91 if (!rdsv3_conn_transition(conn, RDSV3_CONN_CONNECTING, in rdsv3_connect_complete()
98 atomic_get(&conn->c_state)); in rdsv3_connect_complete()
100 conn->c_state = RDSV3_CONN_ERROR; in rdsv3_connect_complete()
101 rdsv3_queue_work(rdsv3_wq, &conn->c_down_w); in rdsv3_connect_complete()
107 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr)); in rdsv3_connect_complete()
109 conn->c_reconnect_jiffies = 0; in rdsv3_connect_complete()
110 conn->c_last_connect_jiffies = ddi_get_lbolt(); in rdsv3_connect_complete()
112 set_bit(0, &conn->c_map_queued); in rdsv3_connect_complete()
113 rdsv3_queue_delayed_work(rdsv3_wq, &conn->c_send_w, 0); in rdsv3_connect_complete()
114 rdsv3_queue_delayed_work(rdsv3_wq, &conn->c_recv_w, 0); in rdsv3_connect_complete()
116 RDSV3_DPRINTF4("rdsv3_connect_complete", "Return(conn: %p)", conn); in rdsv3_connect_complete()
138 rdsv3_queue_reconnect(struct rdsv3_connection *conn) in rdsv3_queue_reconnect() argument
144 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr), in rdsv3_queue_reconnect()
145 conn->c_reconnect_jiffies); in rdsv3_queue_reconnect()
147 set_bit(RDSV3_RECONNECT_PENDING, &conn->c_flags); in rdsv3_queue_reconnect()
148 if (conn->c_reconnect_jiffies == 0) { in rdsv3_queue_reconnect()
149 conn->c_reconnect_jiffies = rdsv3_sysctl_reconnect_min_jiffies; in rdsv3_queue_reconnect()
150 rdsv3_queue_delayed_work(rdsv3_wq, &conn->c_conn_w, 0); in rdsv3_queue_reconnect()
158 rand % conn->c_reconnect_jiffies, conn->c_reconnect_jiffies, in rdsv3_queue_reconnect()
159 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr)); in rdsv3_queue_reconnect()
161 rdsv3_queue_delayed_work(rdsv3_wq, &conn->c_conn_w, in rdsv3_queue_reconnect()
162 rand % conn->c_reconnect_jiffies); in rdsv3_queue_reconnect()
164 conn->c_reconnect_jiffies = min(conn->c_reconnect_jiffies * 2, in rdsv3_queue_reconnect()
171 struct rdsv3_connection *conn = __containerof(work, in rdsv3_connect_worker() local
177 clear_bit(RDSV3_RECONNECT_PENDING, &conn->c_flags); in rdsv3_connect_worker()
178 if (rdsv3_conn_transition(conn, RDSV3_CONN_DOWN, in rdsv3_connect_worker()
180 ret = conn->c_trans->conn_connect(conn); in rdsv3_connect_worker()
184 "ret %d", conn, NIPQUAD(conn->c_laddr), in rdsv3_connect_worker()
185 NIPQUAD(conn->c_faddr), ret); in rdsv3_connect_worker()
189 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr), ret); in rdsv3_connect_worker()
192 if (rdsv3_conn_transition(conn, RDSV3_CONN_CONNECTING, in rdsv3_connect_worker()
194 rdsv3_queue_reconnect(conn); in rdsv3_connect_worker()
197 "RDS: connect failed: %p", conn); in rdsv3_connect_worker()
198 rdsv3_conn_drop(conn); in rdsv3_connect_worker()
209 struct rdsv3_connection *conn = __containerof(work, in rdsv3_send_worker() local
215 if (rdsv3_conn_state(conn) == RDSV3_CONN_UP) { in rdsv3_send_worker()
216 ret = rdsv3_send_xmit(conn); in rdsv3_send_worker()
217 RDSV3_DPRINTF5("rdsv3", "conn %p ret %d", conn, ret); in rdsv3_send_worker()
221 rdsv3_queue_delayed_work(rdsv3_wq, &conn->c_send_w, 0); in rdsv3_send_worker()
225 rdsv3_queue_delayed_work(rdsv3_wq, &conn->c_send_w, 2); in rdsv3_send_worker()
237 struct rdsv3_connection *conn = __containerof(work, in rdsv3_recv_worker() local
243 if (rdsv3_conn_state(conn) == RDSV3_CONN_UP) { in rdsv3_recv_worker()
244 ret = conn->c_trans->recv(conn); in rdsv3_recv_worker()
245 RDSV3_DPRINTF5("rdsv3", "conn %p ret %d", conn, ret); in rdsv3_recv_worker()
249 rdsv3_queue_delayed_work(rdsv3_wq, &conn->c_recv_w, 0); in rdsv3_recv_worker()
253 rdsv3_queue_delayed_work(rdsv3_wq, &conn->c_recv_w, 2); in rdsv3_recv_worker()
265 struct rdsv3_connection *conn = __containerof(work, in rdsv3_shutdown_worker() local
267 rdsv3_conn_shutdown(conn); in rdsv3_shutdown_worker()
275 struct rdsv3_connection *conn = __containerof(work, in rdsv3_reaper_worker() local
278 if (rdsv3_conn_state(conn) != RDSV3_CONN_UP && in rdsv3_reaper_worker()
279 !time_after(conn->c_last_connect_jiffies, in rdsv3_reaper_worker()
281 rdsv3_conn_destroy(conn); in rdsv3_reaper_worker()
283 rdsv3_queue_delayed_work(rdsv3_wq, &conn->c_reap_w, in rdsv3_reaper_worker()