| /drivers/staging/lustre/lustre/ptlrpc/ |
| D | import.c | 59 static void __import_set_state(struct obd_import *imp, in __import_set_state() argument
69 imp->imp_replay_state = LUSTRE_IMP_REPLAY_LOCKS; in __import_set_state()
72 imp->imp_replay_state = LUSTRE_IMP_REPLAY; in __import_set_state()
75 imp->imp_state = state; in __import_set_state()
76 imp->imp_state_hist[imp->imp_state_hist_idx].ish_state = state; in __import_set_state()
77 imp->imp_state_hist[imp->imp_state_hist_idx].ish_time = in __import_set_state()
79 imp->imp_state_hist_idx = (imp->imp_state_hist_idx + 1) % in __import_set_state()
84 #define IMPORT_SET_STATE_NOLOCK(imp, state) \ argument
86 if (imp->imp_state != LUSTRE_IMP_CLOSED) { \
88 imp, obd2cli_tgt(imp->imp_obd), \
[all …]
|
| D | recover.c | 55 void ptlrpc_initiate_recovery(struct obd_import *imp) in ptlrpc_initiate_recovery() argument
57 CDEBUG(D_HA, "%s: starting recovery\n", obd2cli_tgt(imp->imp_obd)); in ptlrpc_initiate_recovery()
58 ptlrpc_connect_import(imp); in ptlrpc_initiate_recovery()
65 int ptlrpc_replay_next(struct obd_import *imp, int *inflight) in ptlrpc_replay_next() argument
77 spin_lock(&imp->imp_lock); in ptlrpc_replay_next()
78 imp->imp_last_transno_checked = 0; in ptlrpc_replay_next()
79 ptlrpc_free_committed(imp); in ptlrpc_replay_next()
80 last_transno = imp->imp_last_replay_transno; in ptlrpc_replay_next()
81 spin_unlock(&imp->imp_lock); in ptlrpc_replay_next()
84 imp, obd2cli_tgt(imp->imp_obd), in ptlrpc_replay_next()
[all …]
|
| D | pinger.c | 48 ptlrpc_prep_ping(struct obd_import *imp) in ptlrpc_prep_ping() argument
52 req = ptlrpc_request_alloc_pack(imp, &RQF_OBD_PING, in ptlrpc_prep_ping()
81 static int ptlrpc_ping(struct obd_import *imp) in ptlrpc_ping() argument
85 req = ptlrpc_prep_ping(imp); in ptlrpc_ping()
88 imp->imp_obd->obd_uuid.uuid, in ptlrpc_ping()
89 obd2cli_tgt(imp->imp_obd)); in ptlrpc_ping()
94 imp->imp_obd->obd_uuid.uuid, obd2cli_tgt(imp->imp_obd)); in ptlrpc_ping()
100 static void ptlrpc_update_next_ping(struct obd_import *imp, int soon) in ptlrpc_update_next_ping() argument
104 if (imp->imp_state == LUSTRE_IMP_DISCON) { in ptlrpc_update_next_ping()
107 at_get(&imp->imp_at.iat_net_latency)); in ptlrpc_update_next_ping()
[all …]
|
| D | client.c | 139 struct obd_import *imp = req->rq_import; in ptlrpc_prep_bulk_imp() local
148 desc->bd_import = class_import_get(imp); in ptlrpc_prep_bulk_imp()
597 struct obd_import *imp; in ptlrpc_request_bufs_pack() local
602 imp = request->rq_import; in ptlrpc_request_bufs_pack()
614 rc = lustre_pack_request(request, imp->imp_msg_magic, count, in ptlrpc_request_bufs_pack()
635 request->rq_request_portal = imp->imp_client->cli_request_portal; in ptlrpc_request_bufs_pack()
636 request->rq_reply_portal = imp->imp_client->cli_reply_portal; in ptlrpc_request_bufs_pack()
680 class_import_put(imp); in ptlrpc_request_bufs_pack()
728 struct ptlrpc_request *__ptlrpc_request_alloc(struct obd_import *imp, in __ptlrpc_request_alloc() argument
741 LASSERTF((unsigned long)imp > 0x1000, "%p", imp); in __ptlrpc_request_alloc()
[all …]
|
| D | llog_client.c | 48 #define LLOG_CLIENT_ENTRY(ctxt, imp) do { \ argument
51 imp = class_import_get(ctxt->loc_imp); \
57 imp = NULL; \
64 #define LLOG_CLIENT_EXIT(ctxt, imp) do { \ argument
66 if (ctxt->loc_imp != imp) \
68 ctxt->loc_imp, imp); \
69 class_import_put(imp); \
80 struct obd_import *imp; in llog_client_open() local
86 LLOG_CLIENT_ENTRY(ctxt, imp); in llog_client_open()
92 req = ptlrpc_request_alloc(imp, &RQF_LLOG_ORIGIN_HANDLE_CREATE); in llog_client_open()
[all …]
|
| D | sec.c | 295 static int import_sec_check_expire(struct obd_import *imp) in import_sec_check_expire() argument
299 spin_lock(&imp->imp_lock); in import_sec_check_expire()
300 if (imp->imp_sec_expire && in import_sec_check_expire()
301 imp->imp_sec_expire < ktime_get_real_seconds()) { in import_sec_check_expire()
303 imp->imp_sec_expire = 0; in import_sec_check_expire()
305 spin_unlock(&imp->imp_lock); in import_sec_check_expire()
311 return sptlrpc_import_sec_adapt(imp, NULL, NULL); in import_sec_check_expire()
327 static int import_sec_validate_get(struct obd_import *imp, in import_sec_validate_get() argument
332 if (unlikely(imp->imp_sec_expire)) { in import_sec_validate_get()
333 rc = import_sec_check_expire(imp); in import_sec_validate_get()
[all …]
|
| D | ptlrpc_internal.h | 77 int ptlrpc_import_in_recovery(struct obd_import *imp);
78 int ptlrpc_set_import_discon(struct obd_import *imp, __u32 conn_cnt);
79 int ptlrpc_replay_next(struct obd_import *imp, int *inflight);
80 void ptlrpc_initiate_recovery(struct obd_import *imp);
240 void ptlrpc_pinger_sending_on_import(struct obd_import *imp);
241 void ptlrpc_pinger_commit_expected(struct obd_import *imp);
|
| D | niobuf.c | 489 struct obd_import *imp = request->rq_import; in ptl_send_rpc() local
490 struct obd_device *obd = imp->imp_obd; in ptl_send_rpc()
503 (imp->imp_state == LUSTRE_IMP_FULL))); in ptl_send_rpc()
516 connection = imp->imp_connection; in ptl_send_rpc()
519 &imp->imp_remote_handle); in ptl_send_rpc()
521 lustre_msg_set_conn_cnt(request->rq_reqmsg, imp->imp_conn_cnt); in ptl_send_rpc()
522 lustre_msghdr_set_flags(request->rq_reqmsg, imp->imp_msghdr_flags); in ptl_send_rpc()
528 LASSERT(AT_OFF || imp->imp_state != LUSTRE_IMP_FULL || in ptl_send_rpc()
529 (imp->imp_msghdr_flags & MSGHDR_AT_SUPPORT) || in ptl_send_rpc()
530 !(imp->imp_connect_data.ocd_connect_flags & in ptl_send_rpc()
[all …]
|
| D | lproc_ptlrpc.c | 1219 struct obd_import *imp = obd->u.cli.cl_import; in lprocfs_wr_import() local
1259 } else if (inst != imp->imp_connect_data.ocd_instance) { in lprocfs_wr_import()
1261 imp->imp_obd->obd_name, in lprocfs_wr_import()
1262 imp->imp_connect_data.ocd_instance, inst); in lprocfs_wr_import()
1266 imp->imp_obd->obd_name, inst); in lprocfs_wr_import()
1271 ptlrpc_recover_import(imp, uuid, 1); in lprocfs_wr_import()
1282 struct obd_import *imp = obd->u.cli.cl_import; in lprocfs_rd_pinger_recov() local
1289 seq_printf(m, "%d\n", !imp->imp_no_pinger_recover); in lprocfs_rd_pinger_recov()
1301 struct obd_import *imp = cli->cl_import; in lprocfs_wr_pinger_recov() local
1315 spin_lock(&imp->imp_lock); in lprocfs_wr_pinger_recov()
[all …]
|
| D | sec_config.c | 810 struct obd_import *imp; in sptlrpc_conf_client_adapt() local
819 imp = obd->u.cli.cl_import; in sptlrpc_conf_client_adapt()
820 if (imp) { in sptlrpc_conf_client_adapt()
821 spin_lock(&imp->imp_lock); in sptlrpc_conf_client_adapt()
822 if (imp->imp_sec) in sptlrpc_conf_client_adapt()
823 imp->imp_sec_expire = ktime_get_real_seconds() + in sptlrpc_conf_client_adapt()
825 spin_unlock(&imp->imp_lock); in sptlrpc_conf_client_adapt()
|
| /drivers/staging/lustre/lustre/ldlm/ |
| D | ldlm_lib.c | 53 static int import_set_conn(struct obd_import *imp, struct obd_uuid *uuid, in import_set_conn() argument
79 spin_lock(&imp->imp_lock); in import_set_conn()
80 list_for_each_entry(item, &imp->imp_conn_list, oic_item) { in import_set_conn()
85 &imp->imp_conn_list); in import_set_conn()
89 imp, imp->imp_obd->obd_name, uuid->uuid, in import_set_conn()
91 spin_unlock(&imp->imp_lock); in import_set_conn()
102 list_add(&imp_conn->oic_item, &imp->imp_conn_list); in import_set_conn()
105 &imp->imp_conn_list); in import_set_conn()
107 imp, imp->imp_obd->obd_name, uuid->uuid, in import_set_conn()
110 spin_unlock(&imp->imp_lock); in import_set_conn()
[all …]
|
| D | ldlm_request.c | 90 struct obd_import *imp; in ldlm_expired_completion_wait() local
116 imp = obd->u.cli.cl_import; in ldlm_expired_completion_wait()
117 ptlrpc_fail_import(imp, lwd->lwd_conn_cnt); in ldlm_expired_completion_wait()
121 obd2cli_tgt(obd), imp->imp_connection->c_remote_uuid.uuid); in ldlm_expired_completion_wait()
228 struct obd_import *imp = NULL; in ldlm_completion_ast() local
251 imp = obd->u.cli.cl_import; in ldlm_completion_ast()
267 if (imp) { in ldlm_completion_ast()
268 spin_lock(&imp->imp_lock); in ldlm_completion_ast()
269 lwd.lwd_conn_cnt = imp->imp_conn_cnt; in ldlm_completion_ast()
270 spin_unlock(&imp->imp_lock); in ldlm_completion_ast()
[all …]
|
| D | ldlm_flock.c | 452 struct obd_import *imp = NULL; in ldlm_flock_completion_ast() local
488 imp = obd->u.cli.cl_import; in ldlm_flock_completion_ast()
490 if (imp) { in ldlm_flock_completion_ast()
491 spin_lock(&imp->imp_lock); in ldlm_flock_completion_ast()
492 fwd.fwd_generation = imp->imp_generation; in ldlm_flock_completion_ast()
493 spin_unlock(&imp->imp_lock); in ldlm_flock_completion_ast()
|
| /drivers/staging/lustre/lustre/include/ |
| D | lustre_ha.h | 46 int ptlrpc_replay(struct obd_import *imp);
47 int ptlrpc_resend(struct obd_import *imp);
48 void ptlrpc_free_committed(struct obd_import *imp);
49 void ptlrpc_wake_delayed(struct obd_import *imp);
50 int ptlrpc_recover_import(struct obd_import *imp, char *new_uuid, int async);
51 int ptlrpc_set_import_active(struct obd_import *imp, int active);
52 void ptlrpc_activate_import(struct obd_import *imp);
53 void ptlrpc_deactivate_import(struct obd_import *imp);
54 void ptlrpc_invalidate_import(struct obd_import *imp);
55 void ptlrpc_fail_import(struct obd_import *imp, __u32 conn_cnt);
|
| D | lustre_export.h | 194 static inline int imp_connect_lru_resize(struct obd_import *imp) in imp_connect_lru_resize() argument
198 ocd = &imp->imp_connect_data; in imp_connect_lru_resize()
215 static inline bool imp_connect_lvb_type(struct obd_import *imp) in imp_connect_lvb_type() argument
219 ocd = &imp->imp_connect_data; in imp_connect_lvb_type()
234 static inline bool imp_connect_disp_stripe(struct obd_import *imp) in imp_connect_disp_stripe() argument
238 ocd = &imp->imp_connect_data; in imp_connect_disp_stripe()
|
| D | lustre_sec.h | 507 struct ptlrpc_sec *(*create_sec)(struct obd_import *imp,
580 int (*install_rctx)(struct obd_import *imp, struct ptlrpc_sec *sec,
722 int (*install_rctx)(struct obd_import *imp, struct ptlrpc_svc_ctx *ctx);
985 int sptlrpc_import_sec_adapt(struct obd_import *imp,
988 struct ptlrpc_sec *sptlrpc_import_sec_ref(struct obd_import *imp);
989 void sptlrpc_import_sec_put(struct obd_import *imp);
991 int sptlrpc_import_check_ctx(struct obd_import *imp);
992 void sptlrpc_import_flush_root_ctx(struct obd_import *imp);
993 void sptlrpc_import_flush_my_ctx(struct obd_import *imp);
994 void sptlrpc_import_flush_all_ctx(struct obd_import *imp);
|
| D | lustre_net.h | 2430 void ptlrpc_abort_inflight(struct obd_import *imp);
2450 struct ptlrpc_request *ptlrpc_request_alloc(struct obd_import *imp,
2452 struct ptlrpc_request *ptlrpc_request_alloc_pool(struct obd_import *imp,
2497 struct obd_import *imp);
2503 void *ptlrpcd_alloc_work(struct obd_import *imp,
2597 int ptlrpc_connect_import(struct obd_import *imp);
2598 int ptlrpc_init_import(struct obd_import *imp);
2599 int ptlrpc_disconnect_import(struct obd_import *imp, int noclose);
2600 int ptlrpc_import_recovery_state_machine(struct obd_import *imp);
2603 int ptlrpc_reconnect_import(struct obd_import *imp);
[all …]
|
| /drivers/staging/lustre/lustre/obdclass/ |
| D | genops.c | 55 static void obd_zombie_import_add(struct obd_import *imp);
818 static void class_import_destroy(struct obd_import *imp) in class_import_destroy() argument
820 CDEBUG(D_IOCTL, "destroying import %p for %s\n", imp, in class_import_destroy()
821 imp->imp_obd->obd_name); in class_import_destroy()
823 LASSERT_ATOMIC_ZERO(&imp->imp_refcount); in class_import_destroy()
825 ptlrpc_put_connection_superhack(imp->imp_connection); in class_import_destroy()
827 while (!list_empty(&imp->imp_conn_list)) { in class_import_destroy()
830 imp_conn = list_entry(imp->imp_conn_list.next, in class_import_destroy()
837 LASSERT(!imp->imp_sec); in class_import_destroy()
838 class_decref(imp->imp_obd, "import", imp); in class_import_destroy()
[all …]
|
| D | lprocfs_status.c | 542 struct obd_import *imp; in lprocfs_rd_server_uuid() local
551 imp = obd->u.cli.cl_import; in lprocfs_rd_server_uuid()
552 imp_state_name = ptlrpc_import_state_name(imp->imp_state); in lprocfs_rd_server_uuid()
555 imp->imp_deactive ? "\tDEACTIVATED" : ""); in lprocfs_rd_server_uuid()
630 if (imp->imp_##flag) \
633 static int obd_import_flags2str(struct obd_import *imp, struct seq_file *m) in obd_import_flags2str() argument
637 if (imp->imp_obd->obd_no_recov) { in obd_import_flags2str()
676 struct obd_import *imp; in lprocfs_rd_import() local
689 imp = obd->u.cli.cl_import; in lprocfs_rd_import()
690 ocd = &imp->imp_connect_data; in lprocfs_rd_import()
[all …]
|
| /drivers/s390/cio/ |
| D | cio_debug.h | 11 #define CIO_TRACE_EVENT(imp, txt) do { \ argument
12 debug_text_event(cio_debug_trace_id, imp, txt); \
15 #define CIO_MSG_EVENT(imp, args...) do { \ argument
16 debug_sprintf_event(cio_debug_msg_id, imp , ##args); \
19 #define CIO_CRW_EVENT(imp, args...) do { \ argument
20 debug_sprintf_event(cio_debug_crw_id, imp , ##args); \
|
| /drivers/staging/lustre/lustre/lov/ |
| D | lov_ea.c | 155 struct obd_import *imp = tgt->ltd_obd->u.cli.cl_import; in lov_tgt_maxbytes() local
157 if (!imp || !tgt->ltd_active) { in lov_tgt_maxbytes()
162 spin_lock(&imp->imp_lock); in lov_tgt_maxbytes()
163 if (imp->imp_state == LUSTRE_IMP_FULL && in lov_tgt_maxbytes()
164 (imp->imp_connect_data.ocd_connect_flags & OBD_CONNECT_MAXBYTES) && in lov_tgt_maxbytes()
165 imp->imp_connect_data.ocd_maxbytes > 0) { in lov_tgt_maxbytes()
166 if (*stripe_maxbytes > imp->imp_connect_data.ocd_maxbytes) in lov_tgt_maxbytes()
167 *stripe_maxbytes = imp->imp_connect_data.ocd_maxbytes; in lov_tgt_maxbytes()
171 spin_unlock(&imp->imp_lock); in lov_tgt_maxbytes()
|
| /drivers/staging/lustre/lustre/mdc/ |
| D | mdc_request.c | 617 struct obd_import *imp = open_req->rq_import; in mdc_set_open_replay_data() local
630 if (och && imp->imp_replayable) { in mdc_set_open_replay_data()
1468 struct obd_import *imp = NULL; in mdc_statfs() local
1477 imp = class_import_get(obd->u.cli.cl_import); in mdc_statfs()
1479 if (!imp) in mdc_statfs()
1482 req = ptlrpc_request_alloc_pack(imp, &RQF_MDS_STATFS, in mdc_statfs()
1500 if (imp->imp_connect_error) in mdc_statfs()
1501 rc = imp->imp_connect_error; in mdc_statfs()
1515 class_import_put(imp); in mdc_statfs()
1572 struct obd_import *imp = class_exp2cliimp(exp); in mdc_ioc_hsm_progress() local
[all …]
|
| /drivers/staging/lustre/lustre/mgc/ |
| D | mgc_request.c | 450 struct obd_import *imp; in lprocfs_mgc_rd_ir_state() local
459 imp = obd->u.cli.cl_import; in lprocfs_mgc_rd_ir_state()
460 ocd = &imp->imp_connect_data; in lprocfs_mgc_rd_ir_state()
991 struct obd_import *imp = class_exp2cliimp(exp); in mgc_set_info_async() local
998 imp->imp_obd->obd_name, value, in mgc_set_info_async()
999 imp->imp_deactive, imp->imp_invalid, in mgc_set_info_async()
1000 imp->imp_replayable, imp->imp_obd->obd_replayable, in mgc_set_info_async()
1001 ptlrpc_import_state_name(imp->imp_state)); in mgc_set_info_async()
1003 if ((imp->imp_state != LUSTRE_IMP_FULL && in mgc_set_info_async()
1004 imp->imp_state != LUSTRE_IMP_NEW) || value > 1) in mgc_set_info_async()
[all …]
|
| /drivers/staging/lustre/lustre/fld/ |
| D | fld_request.c | 345 struct obd_import *imp; in fld_client_rpc() local
349 imp = class_exp2cliimp(exp); in fld_client_rpc()
352 req = ptlrpc_request_alloc_pack(imp, &RQF_FLD_QUERY, in fld_client_rpc()
364 if (imp->imp_connect_flags_orig & OBD_CONNECT_MDS_MDS) in fld_client_rpc()
368 req = ptlrpc_request_alloc_pack(imp, &RQF_FLD_READ, in fld_client_rpc()
|
| /drivers/s390/block/ |
| D | scm_blk.h | 106 #define SCM_LOG(imp, txt) do { \ argument
107 debug_text_event(scm_debug, imp, txt); \
|