Lines Matching refs:buffers
1333 rpcrdma_buffer_get(struct rpcrdma_buffer *buffers) in rpcrdma_buffer_get() argument
1335 struct rpcrdma_ia *ia = rdmab_to_ia(buffers); in rpcrdma_buffer_get()
1340 spin_lock_irqsave(&buffers->rb_lock, flags); in rpcrdma_buffer_get()
1341 if (buffers->rb_send_index == buffers->rb_max_requests) { in rpcrdma_buffer_get()
1342 spin_unlock_irqrestore(&buffers->rb_lock, flags); in rpcrdma_buffer_get()
1347 req = buffers->rb_send_bufs[buffers->rb_send_index]; in rpcrdma_buffer_get()
1348 if (buffers->rb_send_index < buffers->rb_recv_index) { in rpcrdma_buffer_get()
1351 buffers->rb_recv_index - buffers->rb_send_index); in rpcrdma_buffer_get()
1354 req->rl_reply = buffers->rb_recv_bufs[buffers->rb_recv_index]; in rpcrdma_buffer_get()
1355 buffers->rb_recv_bufs[buffers->rb_recv_index++] = NULL; in rpcrdma_buffer_get()
1357 buffers->rb_send_bufs[buffers->rb_send_index++] = NULL; in rpcrdma_buffer_get()
1362 req = rpcrdma_buffer_get_frmrs(req, buffers, &stale); in rpcrdma_buffer_get()
1365 req = rpcrdma_buffer_get_fmrs(req, buffers); in rpcrdma_buffer_get()
1370 spin_unlock_irqrestore(&buffers->rb_lock, flags); in rpcrdma_buffer_get()
1372 rpcrdma_retry_flushed_linv(&stale, buffers); in rpcrdma_buffer_get()
1383 struct rpcrdma_buffer *buffers = req->rl_buffer; in rpcrdma_buffer_put() local
1384 struct rpcrdma_ia *ia = rdmab_to_ia(buffers); in rpcrdma_buffer_put()
1387 spin_lock_irqsave(&buffers->rb_lock, flags); in rpcrdma_buffer_put()
1388 rpcrdma_buffer_put_sendbuf(req, buffers); in rpcrdma_buffer_put()
1392 rpcrdma_buffer_put_mrs(req, buffers); in rpcrdma_buffer_put()
1397 spin_unlock_irqrestore(&buffers->rb_lock, flags); in rpcrdma_buffer_put()
1408 struct rpcrdma_buffer *buffers = req->rl_buffer; in rpcrdma_recv_buffer_get() local
1411 spin_lock_irqsave(&buffers->rb_lock, flags); in rpcrdma_recv_buffer_get()
1412 if (buffers->rb_recv_index < buffers->rb_max_requests) { in rpcrdma_recv_buffer_get()
1413 req->rl_reply = buffers->rb_recv_bufs[buffers->rb_recv_index]; in rpcrdma_recv_buffer_get()
1414 buffers->rb_recv_bufs[buffers->rb_recv_index++] = NULL; in rpcrdma_recv_buffer_get()
1416 spin_unlock_irqrestore(&buffers->rb_lock, flags); in rpcrdma_recv_buffer_get()
1426 struct rpcrdma_buffer *buffers = rep->rr_buffer; in rpcrdma_recv_buffer_put() local
1430 spin_lock_irqsave(&buffers->rb_lock, flags); in rpcrdma_recv_buffer_put()
1431 buffers->rb_recv_bufs[--buffers->rb_recv_index] = rep; in rpcrdma_recv_buffer_put()
1432 spin_unlock_irqrestore(&buffers->rb_lock, flags); in rpcrdma_recv_buffer_put()