Searched refs:rq_bulk (Results 1 – 9 of 9) sorted by relevance
| /drivers/staging/lustre/lustre/ptlrpc/ |
| D | niobuf.c | 115 struct ptlrpc_bulk_desc *desc = req->rq_bulk; in ptlrpc_register_bulk()
243 struct ptlrpc_bulk_desc *desc = req->rq_bulk; in ptlrpc_unregister_bulk()
538 if (request->rq_bulk != NULL) { in ptl_send_rpc()
|
| D | client.c | 159 req->rq_bulk = desc; in ptlrpc_prep_bulk_imp()
1225 if (!req->rq_bulk) { in after_reply()
1661 if (req->rq_bulk) { in ptlrpc_check_set()
1753 if (req->rq_bulk == NULL || req->rq_status < 0) { in ptlrpc_check_set()
1765 if (req->rq_bulk->bd_failure) { in ptlrpc_check_set()
2249 if (request->rq_bulk != NULL) in __ptlrpc_free_req()
2250 ptlrpc_free_bulk_pin(request->rq_bulk); in __ptlrpc_free_req()
2522 if (req->rq_bulk) { in ptlrpc_resend_req()
|
| D | sec.c | 902 if (req->rq_bulk) { in sptlrpc_cli_wrap_request()
903 rc = sptlrpc_cli_wrap_bulk(req, req->rq_bulk); in sptlrpc_cli_wrap_request()
|
| /drivers/staging/lustre/lustre/osc/ |
| D | osc_request.c | 1125 if (req->rq_bulk->bd_nob_transferred != requested_nob) { in check_write_rcs()
1127 req->rq_bulk->bd_nob_transferred, requested_nob); in check_write_rcs()
1505 LASSERT(req->rq_bulk->bd_nob == aa->aa_requested_nob); in osc_brw_fini_request()
1507 if (sptlrpc_cli_unwrap_bulk_write(req, req->rq_bulk)) in osc_brw_fini_request()
1526 rc = sptlrpc_cli_unwrap_bulk_read(req, req->rq_bulk, rc); in osc_brw_fini_request()
1538 if (rc != req->rq_bulk->bd_nob_transferred) { in osc_brw_fini_request()
1540 rc, req->rq_bulk->bd_nob_transferred); in osc_brw_fini_request()
1560 if (peer->nid != req->rq_bulk->bd_sender) { in osc_brw_fini_request()
1562 router = libcfs_nid2str(req->rq_bulk->bd_sender); in osc_brw_fini_request()
1793 req->rq_bulk->bd_nob_transferred); in brw_interpret()
[all …]
|
| /drivers/staging/lustre/lustre/mdc/ |
| D | mdc_request.c | 1025 rc = sptlrpc_cli_unwrap_bulk_read(req, req->rq_bulk, in mdc_readpage()
1026 req->rq_bulk->bd_nob_transferred); in mdc_readpage()
1032 if (req->rq_bulk->bd_nob_transferred & ~LU_PAGE_MASK) { in mdc_readpage()
1034 req->rq_bulk->bd_nob_transferred, in mdc_readpage()
|
| /drivers/staging/lustre/lustre/include/ |
| D | lustre_net.h | 1468 struct ptlrpc_bulk_desc *rq_bulk; member
2307 desc = req->rq_bulk; in ptlrpc_client_bulk_active()
|
| /drivers/staging/lustre/lustre/lmv/ |
| D | lmv_obd.c | 2165 ncfspgs = ((*request)->rq_bulk->bd_nob_transferred + PAGE_CACHE_SIZE - 1) in lmv_readpage()
2167 nlupgs = (*request)->rq_bulk->bd_nob_transferred >> LU_PAGE_SHIFT; in lmv_readpage()
2168 LASSERT(!((*request)->rq_bulk->bd_nob_transferred & ~LU_PAGE_MASK)); in lmv_readpage()
|
| /drivers/staging/lustre/lustre/mgc/ |
| D | mgc_request.c | 1383 ealen = sptlrpc_cli_unwrap_bulk_read(req, req->rq_bulk, 0); in mgc_process_recover_log()
|
| /drivers/staging/lustre/lustre/llite/ |
| D | dir.c | 197 nrdpgs = (request->rq_bulk->bd_nob_transferred+PAGE_CACHE_SIZE-1) in ll_dir_filler()
|