| /drivers/staging/lustre/lustre/mdc/ |
| D | mdc_internal.h | 45 void mdc_pack_body(struct ptlrpc_request *req, const struct lu_fid *fid,
47 int mdc_pack_req(struct ptlrpc_request *req, int version, int opc);
48 void mdc_is_subdir_pack(struct ptlrpc_request *req, const struct lu_fid *pfid,
50 void mdc_swap_layouts_pack(struct ptlrpc_request *req,
52 void mdc_readdir_pack(struct ptlrpc_request *req, __u64 pgoff, __u32 size,
54 void mdc_getattr_pack(struct ptlrpc_request *req, __u64 valid, int flags,
56 void mdc_setattr_pack(struct ptlrpc_request *req, struct md_op_data *op_data,
58 void mdc_create_pack(struct ptlrpc_request *req, struct md_op_data *op_data,
61 void mdc_open_pack(struct ptlrpc_request *req, struct md_op_data *op_data,
64 void mdc_unlink_pack(struct ptlrpc_request *req, struct md_op_data *op_data);
[all …]
|
| D | mdc_request.c | 58 static inline int mdc_queue_wait(struct ptlrpc_request *req) in mdc_queue_wait()
78 struct ptlrpc_request *req; in mdc_getstatus()
124 struct ptlrpc_request *req) in mdc_getattr_common()
166 struct ptlrpc_request **request) in mdc_getattr()
168 struct ptlrpc_request *req; in mdc_getattr()
208 struct ptlrpc_request **request) in mdc_getattr_name()
210 struct ptlrpc_request *req; in mdc_getattr_name()
254 struct ptlrpc_request **request) in mdc_is_subdir()
256 struct ptlrpc_request *req; in mdc_is_subdir()
283 __u32 suppgid, struct ptlrpc_request **request) in mdc_xattr_common()
[all …]
|
| D | mdc_reint.c | 47 static int mdc_reint(struct ptlrpc_request *request, in mdc_reint()
105 struct ptlrpc_request **request, struct md_open_data **mod) in mdc_setattr()
108 struct ptlrpc_request *req; in mdc_setattr()
208 struct ptlrpc_request **request) in mdc_create()
210 struct ptlrpc_request *req; in mdc_create()
304 struct ptlrpc_request **request) in mdc_unlink()
308 struct ptlrpc_request *req = *request; in mdc_unlink()
357 struct ptlrpc_request **request) in mdc_link()
361 struct ptlrpc_request *req; in mdc_link()
402 struct ptlrpc_request **request) in mdc_rename()
[all …]
|
| D | mdc_locks.c | 231 static inline void mdc_clear_replay_flag(struct ptlrpc_request *req, int rc) in mdc_clear_replay_flag()
256 static void mdc_realloc_openmsg(struct ptlrpc_request *req, in mdc_realloc_openmsg()
272 static struct ptlrpc_request *mdc_intent_open_pack(struct obd_export *exp, in mdc_intent_open_pack()
278 struct ptlrpc_request *req; in mdc_intent_open_pack()
356 static struct ptlrpc_request *
361 struct ptlrpc_request *req; in mdc_intent_getxattr_pack()
401 static struct ptlrpc_request *mdc_intent_unlink_pack(struct obd_export *exp, in mdc_intent_unlink_pack()
405 struct ptlrpc_request *req; in mdc_intent_unlink_pack()
439 static struct ptlrpc_request *mdc_intent_getattr_pack(struct obd_export *exp, in mdc_intent_getattr_pack()
443 struct ptlrpc_request *req; in mdc_intent_getattr_pack()
[all …]
|
| D | mdc_lib.c | 54 void mdc_is_subdir_pack(struct ptlrpc_request *req, const struct lu_fid *pfid, in mdc_is_subdir_pack()
69 void mdc_swap_layouts_pack(struct ptlrpc_request *req, in mdc_swap_layouts_pack()
81 void mdc_pack_body(struct ptlrpc_request *req, const struct lu_fid *fid, in mdc_pack_body()
97 void mdc_readdir_pack(struct ptlrpc_request *req, __u64 pgoff, in mdc_readdir_pack()
111 void mdc_create_pack(struct ptlrpc_request *req, struct md_op_data *op_data, in mdc_create_pack()
180 void mdc_open_pack(struct ptlrpc_request *req, struct md_op_data *op_data, in mdc_open_pack()
305 void mdc_setattr_pack(struct ptlrpc_request *req, struct md_op_data *op_data, in mdc_setattr_pack()
342 void mdc_unlink_pack(struct ptlrpc_request *req, struct md_op_data *op_data) in mdc_unlink_pack()
369 void mdc_link_pack(struct ptlrpc_request *req, struct md_op_data *op_data) in mdc_link_pack()
393 void mdc_rename_pack(struct ptlrpc_request *req, struct md_op_data *op_data, in mdc_rename_pack()
[all …]
|
| /drivers/staging/lustre/lustre/include/ |
| D | lustre_sec.h | 50 struct ptlrpc_request;
386 struct ptlrpc_request *req);
399 struct ptlrpc_request *req);
412 struct ptlrpc_request *req);
425 struct ptlrpc_request *req);
448 struct ptlrpc_request *req,
465 struct ptlrpc_request *req,
612 struct ptlrpc_request *req,
623 struct ptlrpc_request *req);
636 struct ptlrpc_request *req,
[all …]
|
| D | lustre_net.h | 484 struct ptlrpc_request *req,
1235 int (*hpreq_lock_match)(struct ptlrpc_request *, struct ldlm_lock *);
1239 int (*hpreq_check)(struct ptlrpc_request *);
1243 void (*hpreq_fini)(struct ptlrpc_request *);
1252 struct ptlrpc_request { struct
1458 void (*rq_replay_cb)(struct ptlrpc_request *); argument
1463 void (*rq_commit_cb)(struct ptlrpc_request *); argument
1519 struct ptlrpc_request *req, int rc) in ptlrpc_req_interpret() argument
1536 static inline bool ptlrpc_nrs_req_can_move(struct ptlrpc_request *req) in ptlrpc_nrs_req_can_move()
1554 static inline int lustre_req_swabbed(struct ptlrpc_request *req, int index) in lustre_req_swabbed()
[all …]
|
| D | obd.h | 600 struct ptlrpc_request *req) in oti_init()
959 int (*mi_cb)(struct ptlrpc_request *req,
1118 struct ptlrpc_request *mod_open_req;
1119 struct ptlrpc_request *mod_close_req;
1132 struct md_open_data *, struct ptlrpc_request **);
1135 __u64, struct ptlrpc_request **);
1141 struct ptlrpc_request **, __u64);
1143 struct ptlrpc_request **);
1145 struct ptlrpc_request **);
1148 struct ptlrpc_request **,
[all …]
|
| D | lustre_dlm.h | 285 struct ptlrpc_request *r,
1069 struct ldlm_lock *ldlm_request_lock(struct ptlrpc_request *req);
1106 struct ptlrpc_request *r, int increase) in ldlm_res_lvbo_update()
1233 int ldlm_cli_enqueue(struct obd_export *exp, struct ptlrpc_request **reqp,
1240 struct ptlrpc_request *req,
1244 struct ptlrpc_request *req,
1248 int ldlm_cli_enqueue_fini(struct obd_export *exp, struct ptlrpc_request *req,
1252 int ldlm_cli_update_pool(struct ptlrpc_request *req);
1271 struct ptlrpc_request *req, ldlm_cancel_flags_t flags);
|
| D | obd_class.h | 1384 struct ptlrpc_request **request) in md_getattr()
1419 struct ptlrpc_request **request) in md_close()
1432 struct ptlrpc_request **request) in md_create()
1461 struct ptlrpc_request **req, in md_enqueue()
1475 struct ptlrpc_request **request) in md_getattr_name()
1488 int lookup_flags, struct ptlrpc_request **reqp, in md_intent_lock()
1503 struct ptlrpc_request **request) in md_link()
1515 int newlen, struct ptlrpc_request **request) in md_rename()
1529 struct ptlrpc_request **request) in md_is_subdir()
1541 struct ptlrpc_request **request, in md_setattr()
[all …]
|
| /drivers/staging/lustre/lustre/ptlrpc/ |
| D | ptlrpc_internal.h | 64 struct ptlrpc_request *ptlrpc_request_cache_alloc(gfp_t flags);
65 void ptlrpc_request_cache_free(struct ptlrpc_request *req);
72 void ptlrpc_request_handle_notconn(struct ptlrpc_request *);
80 int lustre_unpack_req_ptlrpc_body(struct ptlrpc_request *req, int offset);
81 int lustre_unpack_rep_ptlrpc_body(struct ptlrpc_request *req, int offset);
90 void ptlrpc_lprocfs_rpc_sent(struct ptlrpc_request *req, long amount);
91 void ptlrpc_lprocfs_do_request_stat(struct ptlrpc_request *req,
123 struct ptlrpc_request *req, bool hp);
124 void ptlrpc_nrs_req_finalize(struct ptlrpc_request *req);
125 void ptlrpc_nrs_req_stop_nolock(struct ptlrpc_request *req);
[all …]
|
| D | client.c | 50 static int ptlrpc_send_new_req(struct ptlrpc_request *req);
51 static int ptlrpcd_check_work(struct ptlrpc_request *req);
139 struct ptlrpc_bulk_desc *ptlrpc_prep_bulk_imp(struct ptlrpc_request *req, in ptlrpc_prep_bulk_imp()
221 void ptlrpc_at_set_req_timeout(struct ptlrpc_request *req) in ptlrpc_at_set_req_timeout()
262 static void ptlrpc_at_adj_service(struct ptlrpc_request *req, in ptlrpc_at_adj_service()
285 int ptlrpc_at_get_net_latency(struct ptlrpc_request *req) in ptlrpc_at_get_net_latency()
291 static void ptlrpc_at_adj_net_latency(struct ptlrpc_request *req, in ptlrpc_at_adj_net_latency()
331 static int unpack_reply(struct ptlrpc_request *req) in unpack_reply()
355 static int ptlrpc_at_recv_early_reply(struct ptlrpc_request *req) in ptlrpc_at_recv_early_reply()
357 struct ptlrpc_request *early_req; in ptlrpc_at_recv_early_reply()
[all …]
|
| D | sec_null.c | 80 int null_ctx_sign(struct ptlrpc_cli_ctx *ctx, struct ptlrpc_request *req) in null_ctx_sign()
95 int null_ctx_verify(struct ptlrpc_cli_ctx *ctx, struct ptlrpc_request *req) in null_ctx_verify()
157 struct ptlrpc_request *req, in null_alloc_reqbuf()
181 struct ptlrpc_request *req) in null_free_reqbuf()
199 struct ptlrpc_request *req, in null_alloc_repbuf()
217 struct ptlrpc_request *req) in null_free_repbuf()
228 struct ptlrpc_request *req, in null_enlarge_reqbuf()
286 int null_accept(struct ptlrpc_request *req) in null_accept()
308 int null_alloc_rs(struct ptlrpc_request *req, int msgsize) in null_alloc_rs()
350 int null_authorize(struct ptlrpc_request *req) in null_authorize()
|
| D | recover.c | 73 struct ptlrpc_request *req = NULL; in ptlrpc_replay_next()
110 req = list_entry(tmp, struct ptlrpc_request, in ptlrpc_replay_next()
123 struct ptlrpc_request, in ptlrpc_replay_next()
143 req = list_entry(tmp, struct ptlrpc_request, in ptlrpc_replay_next()
181 struct ptlrpc_request *req, *next; in ptlrpc_resend()
216 struct ptlrpc_request *req; in ptlrpc_wake_delayed()
220 req = list_entry(tmp, struct ptlrpc_request, rq_list); in ptlrpc_wake_delayed()
229 void ptlrpc_request_handle_notconn(struct ptlrpc_request *failed_req) in ptlrpc_request_handle_notconn()
|
| D | sec.c | 352 int sptlrpc_req_get_ctx(struct ptlrpc_request *req) in sptlrpc_req_get_ctx()
386 void sptlrpc_req_put_ctx(struct ptlrpc_request *req, int sync) in sptlrpc_req_put_ctx()
405 int sptlrpc_req_ctx_switch(struct ptlrpc_request *req, in sptlrpc_req_ctx_switch()
472 static int sptlrpc_req_replace_dead_ctx(struct ptlrpc_request *req) in sptlrpc_req_replace_dead_ctx()
537 struct ptlrpc_request *req = data; in ctx_refresh_timeout()
558 struct ptlrpc_request *req = data; in ctx_refresh_interrupt()
566 void req_off_ctx_list(struct ptlrpc_request *req, struct ptlrpc_cli_ctx *ctx) in req_off_ctx_list()
588 int sptlrpc_req_refresh_ctx(struct ptlrpc_request *req, long timeout) in sptlrpc_req_refresh_ctx()
756 void sptlrpc_req_set_flavor(struct ptlrpc_request *req, int opcode) in sptlrpc_req_set_flavor()
818 void sptlrpc_request_out_callback(struct ptlrpc_request *req) in sptlrpc_request_out_callback()
[all …]
|
| D | nrs_fifo.c | 173 struct ptlrpc_request *req = container_of(nrq, in nrs_fifo_req_get()
174 struct ptlrpc_request, in nrs_fifo_req_get()
238 struct ptlrpc_request *req = container_of(nrq, struct ptlrpc_request, in nrs_fifo_req_stop()
|
| D | sec_plain.c | 191 int plain_ctx_sign(struct ptlrpc_cli_ctx *ctx, struct ptlrpc_request *req) in plain_ctx_sign()
215 int plain_ctx_verify(struct ptlrpc_cli_ctx *ctx, struct ptlrpc_request *req) in plain_ctx_verify()
289 struct ptlrpc_request *req, in plain_cli_wrap_bulk()
332 struct ptlrpc_request *req, in plain_cli_unwrap_bulk()
539 struct ptlrpc_request *req, in plain_alloc_reqbuf()
584 struct ptlrpc_request *req) in plain_free_reqbuf()
595 struct ptlrpc_request *req, in plain_alloc_repbuf()
626 struct ptlrpc_request *req) in plain_free_repbuf()
635 struct ptlrpc_request *req, in plain_enlarge_reqbuf()
710 int plain_accept(struct ptlrpc_request *req) in plain_accept()
[all …]
|
| D | service.c | 63 static void ptlrpc_server_hpreq_fini(struct ptlrpc_request *req);
64 static void ptlrpc_at_remove_timed(struct ptlrpc_request *req);
693 static void ptlrpc_server_free_request(struct ptlrpc_request *req) in ptlrpc_server_free_request()
716 static void ptlrpc_server_drop_request(struct ptlrpc_request *req) in ptlrpc_server_drop_request()
770 req = list_entry(tmp, struct ptlrpc_request, in ptlrpc_server_drop_request()
785 struct ptlrpc_request, in ptlrpc_server_drop_request()
825 struct ptlrpc_request *req) in ptlrpc_server_finish_request()
838 struct ptlrpc_request *req) in ptlrpc_server_finish_active_request()
859 static int ptlrpc_check_req(struct ptlrpc_request *req) in ptlrpc_check_req()
923 static int ptlrpc_at_add_timed(struct ptlrpc_request *req) in ptlrpc_at_add_timed()
[all …]
|
| D | import.c | 107 struct ptlrpc_request *request,
221 ptlrpc_inflight_deadline(struct ptlrpc_request *req, time64_t now) in ptlrpc_inflight_deadline()
248 struct ptlrpc_request *req; in ptlrpc_inflight_timeout()
253 req = list_entry(tmp, struct ptlrpc_request, rq_list); in ptlrpc_inflight_timeout()
269 struct ptlrpc_request *req; in ptlrpc_invalidate_import()
343 struct ptlrpc_request, in ptlrpc_invalidate_import()
351 struct ptlrpc_request, in ptlrpc_invalidate_import()
589 struct ptlrpc_request *req; in ptlrpc_first_transno()
596 req = list_entry(tmp, struct ptlrpc_request, rq_replay_list); in ptlrpc_first_transno()
607 req = list_entry(tmp, struct ptlrpc_request, rq_replay_list); in ptlrpc_first_transno()
[all …]
|
| D | niobuf.c | 113 static int ptlrpc_register_bulk(struct ptlrpc_request *req) in ptlrpc_register_bulk()
241 int ptlrpc_unregister_bulk(struct ptlrpc_request *req, int async) in ptlrpc_unregister_bulk()
300 static void ptlrpc_at_set_reply(struct ptlrpc_request *req, int flags) in ptlrpc_at_set_reply()
349 int ptlrpc_send_reply(struct ptlrpc_request *req, int flags) in ptlrpc_send_reply()
437 int ptlrpc_reply(struct ptlrpc_request *req) in ptlrpc_reply()
449 int ptlrpc_send_error(struct ptlrpc_request *req, int may_be_difficult) in ptlrpc_send_error()
472 int ptlrpc_error(struct ptlrpc_request *req) in ptlrpc_error()
484 int ptl_send_rpc(struct ptlrpc_request *request, int noreply) in ptl_send_rpc()
|
| D | ptlrpcd.c | 162 void ptlrpcd_wake(struct ptlrpc_request *req) in ptlrpcd_wake()
173 ptlrpcd_select_pc(struct ptlrpc_request *req) in ptlrpcd_select_pc()
205 struct ptlrpc_request *req; in ptlrpcd_steal_rqset()
211 req = list_entry(pos, struct ptlrpc_request, in ptlrpcd_steal_rqset()
229 void ptlrpcd_add_req(struct ptlrpc_request *req) in ptlrpcd_add_req()
280 struct ptlrpc_request *req; in ptlrpcd_check()
326 req = list_entry(pos, struct ptlrpc_request, rq_set_chain); in ptlrpcd_check()
|
| /drivers/staging/lustre/lustre/lmv/ |
| D | lmv_internal.h | 55 int flags, struct ptlrpc_request **reqp,
61 int flags, struct ptlrpc_request **reqp,
67 int flags, struct ptlrpc_request **reqp,
78 static inline struct lmv_stripe_md *lmv_get_mea(struct ptlrpc_request *req) in lmv_get_mea()
|
| D | lmv_intent.c | 57 struct ptlrpc_request **reqp, in lmv_intent_remote()
63 struct ptlrpc_request *req = NULL; in lmv_intent_remote()
161 int flags, struct ptlrpc_request **reqp, in lmv_intent_open()
244 int flags, struct ptlrpc_request **reqp, in lmv_intent_lookup()
294 int flags, struct ptlrpc_request **reqp, in lmv_intent_lock()
|
| /drivers/staging/lustre/lustre/osc/ |
| D | osc_request.c | 106 struct ptlrpc_request *req, void *data, int rc);
201 static inline void osc_pack_req_body(struct ptlrpc_request *req, in osc_pack_req_body()
214 struct ptlrpc_request *req, in osc_getattr_interpret()
244 struct ptlrpc_request *req; in osc_getattr_async()
274 struct ptlrpc_request *req; in osc_getattr()
317 struct ptlrpc_request *req; in osc_setattr()
356 struct ptlrpc_request *req, in osc_setattr_interpret()
382 struct ptlrpc_request *req; in osc_setattr_async_base()
437 struct ptlrpc_request *req; in osc_real_create()
526 struct ptlrpc_request *req; in osc_punch_base()
[all …]
|
| /drivers/staging/lustre/lustre/llite/ |
| D | namei.c | 405 static int ll_lookup_it_finish(struct ptlrpc_request *request, in ll_lookup_it_finish()
487 struct ptlrpc_request *req = NULL; in ll_lookup_it()
652 (struct ptlrpc_request *) in ll_atomic_open()
680 struct ptlrpc_request *request = NULL; in ll_create_node()
744 static void ll_update_times(struct ptlrpc_request *request, in ll_update_times()
766 struct ptlrpc_request *request = NULL; in ll_new_node()
871 int ll_objects_destroy(struct ptlrpc_request *request, struct inode *dir) in ll_objects_destroy()
947 struct ptlrpc_request *request = NULL; in ll_unlink()
997 struct ptlrpc_request *request = NULL; in ll_rmdir()
1047 struct ptlrpc_request *request = NULL; in ll_link()
[all …]
|