Lines Matching +full:rpc +full:- +full:if
1 // SPDX-License-Identifier: GPL-2.0-only
16 #if IS_ENABLED(CONFIG_SUNRPC_DEBUG)
33 return xprt->bc_alloc_count < xprt->bc_alloc_max; in xprt_need_to_requeue()
44 dprintk("RPC: free allocations for req= %p\n", req); in xprt_free_allocation()
45 WARN_ON_ONCE(test_bit(RPC_BC_PA_IN_USE, &req->rq_bc_pa_state)); in xprt_free_allocation()
46 xbufp = &req->rq_rcv_buf; in xprt_free_allocation()
47 free_page((unsigned long)xbufp->head[0].iov_base); in xprt_free_allocation()
48 xbufp = &req->rq_snd_buf; in xprt_free_allocation()
49 free_page((unsigned long)xbufp->head[0].iov_base); in xprt_free_allocation()
55 buf->head[0].iov_len = PAGE_SIZE; in xprt_bc_reinit_xdr_buf()
56 buf->tail[0].iov_len = 0; in xprt_bc_reinit_xdr_buf()
57 buf->pages = NULL; in xprt_bc_reinit_xdr_buf()
58 buf->page_len = 0; in xprt_bc_reinit_xdr_buf()
59 buf->flags = 0; in xprt_bc_reinit_xdr_buf()
60 buf->len = 0; in xprt_bc_reinit_xdr_buf()
61 buf->buflen = PAGE_SIZE; in xprt_bc_reinit_xdr_buf()
69 if (page == NULL) in xprt_alloc_xdr_buf()
70 return -ENOMEM; in xprt_alloc_xdr_buf()
80 /* Pre-allocate one backchannel rpc_rqst */ in xprt_alloc_bc_req()
82 if (req == NULL) in xprt_alloc_bc_req()
85 req->rq_xprt = xprt; in xprt_alloc_bc_req()
88 if (xprt_alloc_xdr_buf(&req->rq_rcv_buf, gfp_flags) < 0) { in xprt_alloc_bc_req()
92 req->rq_rcv_buf.len = PAGE_SIZE; in xprt_alloc_bc_req()
95 if (xprt_alloc_xdr_buf(&req->rq_snd_buf, gfp_flags) < 0) { in xprt_alloc_bc_req()
125 if (!xprt->ops->bc_setup) in xprt_setup_backchannel()
127 return xprt->ops->bc_setup(xprt, min_reqs); in xprt_setup_backchannel()
137 dprintk("RPC: setup backchannel transport\n"); in xprt_setup_bc()
139 if (min_reqs > BC_MAX_SLOTS) in xprt_setup_bc()
152 /* Pre-allocate one backchannel rpc_rqst */ in xprt_setup_bc()
154 if (req == NULL) { in xprt_setup_bc()
160 dprintk("RPC: adding req= %p\n", req); in xprt_setup_bc()
161 list_add(&req->rq_bc_pa_list, &tmp_list); in xprt_setup_bc()
167 spin_lock(&xprt->bc_pa_lock); in xprt_setup_bc()
168 list_splice(&tmp_list, &xprt->bc_pa_list); in xprt_setup_bc()
169 xprt->bc_alloc_count += min_reqs; in xprt_setup_bc()
170 xprt->bc_alloc_max += min_reqs; in xprt_setup_bc()
171 atomic_add(min_reqs, &xprt->bc_slot_count); in xprt_setup_bc()
172 spin_unlock(&xprt->bc_pa_lock); in xprt_setup_bc()
174 dprintk("RPC: setup backchannel transport done\n"); in xprt_setup_bc()
185 list_del(&req->rq_bc_pa_list); in xprt_setup_bc()
189 dprintk("RPC: setup backchannel transport failed\n"); in xprt_setup_bc()
190 return -ENOMEM; in xprt_setup_bc()
194 * xprt_destroy_backchannel - Destroys the backchannel preallocated structures.
204 if (xprt->ops->bc_destroy) in xprt_destroy_backchannel()
205 xprt->ops->bc_destroy(xprt, max_reqs); in xprt_destroy_backchannel()
213 dprintk("RPC: destroy backchannel transport\n"); in xprt_destroy_bc()
215 if (max_reqs == 0) in xprt_destroy_bc()
218 spin_lock_bh(&xprt->bc_pa_lock); in xprt_destroy_bc()
219 xprt->bc_alloc_max -= min(max_reqs, xprt->bc_alloc_max); in xprt_destroy_bc()
220 list_for_each_entry_safe(req, tmp, &xprt->bc_pa_list, rq_bc_pa_list) { in xprt_destroy_bc()
221 dprintk("RPC: req=%p\n", req); in xprt_destroy_bc()
222 list_del(&req->rq_bc_pa_list); in xprt_destroy_bc()
224 xprt->bc_alloc_count--; in xprt_destroy_bc()
225 atomic_dec(&xprt->bc_slot_count); in xprt_destroy_bc()
226 if (--max_reqs == 0) in xprt_destroy_bc()
229 spin_unlock_bh(&xprt->bc_pa_lock); in xprt_destroy_bc()
232 dprintk("RPC: backchannel list empty= %s\n", in xprt_destroy_bc()
233 list_empty(&xprt->bc_pa_list) ? "true" : "false"); in xprt_destroy_bc()
241 dprintk("RPC: allocate a backchannel request\n"); in xprt_get_bc_request()
242 if (list_empty(&xprt->bc_pa_list)) { in xprt_get_bc_request()
243 if (!new) in xprt_get_bc_request()
245 if (atomic_read(&xprt->bc_slot_count) >= BC_MAX_SLOTS) in xprt_get_bc_request()
247 list_add_tail(&new->rq_bc_pa_list, &xprt->bc_pa_list); in xprt_get_bc_request()
248 xprt->bc_alloc_count++; in xprt_get_bc_request()
249 atomic_inc(&xprt->bc_slot_count); in xprt_get_bc_request()
251 req = list_first_entry(&xprt->bc_pa_list, struct rpc_rqst, in xprt_get_bc_request()
253 req->rq_reply_bytes_recvd = 0; in xprt_get_bc_request()
254 memcpy(&req->rq_private_buf, &req->rq_rcv_buf, in xprt_get_bc_request()
255 sizeof(req->rq_private_buf)); in xprt_get_bc_request()
256 req->rq_xid = xid; in xprt_get_bc_request()
257 req->rq_connect_cookie = xprt->connect_cookie; in xprt_get_bc_request()
258 dprintk("RPC: backchannel req=%p\n", req); in xprt_get_bc_request()
269 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_request()
271 xprt->ops->bc_free_rqst(req); in xprt_free_bc_request()
276 struct rpc_xprt *xprt = req->rq_xprt; in xprt_free_bc_rqst()
278 dprintk("RPC: free backchannel req=%p\n", req); in xprt_free_bc_rqst()
280 req->rq_connect_cookie = xprt->connect_cookie - 1; in xprt_free_bc_rqst()
282 clear_bit(RPC_BC_PA_IN_USE, &req->rq_bc_pa_state); in xprt_free_bc_rqst()
289 spin_lock_bh(&xprt->bc_pa_lock); in xprt_free_bc_rqst()
290 if (xprt_need_to_requeue(xprt)) { in xprt_free_bc_rqst()
291 xprt_bc_reinit_xdr_buf(&req->rq_snd_buf); in xprt_free_bc_rqst()
292 xprt_bc_reinit_xdr_buf(&req->rq_rcv_buf); in xprt_free_bc_rqst()
293 req->rq_rcv_buf.len = PAGE_SIZE; in xprt_free_bc_rqst()
294 list_add_tail(&req->rq_bc_pa_list, &xprt->bc_pa_list); in xprt_free_bc_rqst()
295 xprt->bc_alloc_count++; in xprt_free_bc_rqst()
296 atomic_inc(&xprt->bc_slot_count); in xprt_free_bc_rqst()
299 spin_unlock_bh(&xprt->bc_pa_lock); in xprt_free_bc_rqst()
300 if (req != NULL) { in xprt_free_bc_rqst()
307 dprintk("RPC: Last session removed req=%p\n", req); in xprt_free_bc_rqst()
322 * Return an available rpc_rqst, otherwise NULL if non are available.
329 spin_lock(&xprt->bc_pa_lock); in xprt_lookup_bc_request()
330 list_for_each_entry(req, &xprt->bc_pa_list, rq_bc_pa_list) { in xprt_lookup_bc_request()
331 if (req->rq_connect_cookie != xprt->connect_cookie) in xprt_lookup_bc_request()
333 if (req->rq_xid == xid) in xprt_lookup_bc_request()
338 spin_unlock(&xprt->bc_pa_lock); in xprt_lookup_bc_request()
339 if (new) { in xprt_lookup_bc_request()
340 if (req != new) in xprt_lookup_bc_request()
343 } else if (req) in xprt_lookup_bc_request()
356 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_bc_request()
357 struct svc_serv *bc_serv = xprt->bc_serv; in xprt_complete_bc_request()
359 spin_lock(&xprt->bc_pa_lock); in xprt_complete_bc_request()
360 list_del(&req->rq_bc_pa_list); in xprt_complete_bc_request()
361 xprt->bc_alloc_count--; in xprt_complete_bc_request()
362 spin_unlock(&xprt->bc_pa_lock); in xprt_complete_bc_request()
364 req->rq_private_buf.len = copied; in xprt_complete_bc_request()
365 set_bit(RPC_BC_PA_IN_USE, &req->rq_bc_pa_state); in xprt_complete_bc_request()
367 dprintk("RPC: add callback request to list\n"); in xprt_complete_bc_request()
369 lwq_enqueue(&req->rq_bc_list, &bc_serv->sv_cb_list); in xprt_complete_bc_request()
370 svc_pool_wake_idle_thread(&bc_serv->sv_pools[0]); in xprt_complete_bc_request()