| /drivers/staging/lustre/lustre/ptlrpc/ |
| D | service.c | 62 static int ptlrpc_server_post_idle_rqbds(struct ptlrpc_service_part *svcpt);
72 ptlrpc_alloc_rqbd(struct ptlrpc_service_part *svcpt) in ptlrpc_alloc_rqbd() argument
74 struct ptlrpc_service *svc = svcpt->scp_service; in ptlrpc_alloc_rqbd()
79 svcpt->scp_cpt)); in ptlrpc_alloc_rqbd()
83 rqbd->rqbd_svcpt = svcpt; in ptlrpc_alloc_rqbd()
89 svcpt->scp_cpt, in ptlrpc_alloc_rqbd()
97 spin_lock(&svcpt->scp_lock); in ptlrpc_alloc_rqbd()
98 list_add(&rqbd->rqbd_list, &svcpt->scp_rqbd_idle); in ptlrpc_alloc_rqbd()
99 svcpt->scp_nrqbds_total++; in ptlrpc_alloc_rqbd()
100 spin_unlock(&svcpt->scp_lock); in ptlrpc_alloc_rqbd()
[all …]
|
| D | nrs.c | 736 struct ptlrpc_service_part *svcpt = nrs->nrs_svcpt; in nrs_policy_register() local
739 LASSERT(svcpt != NULL); in nrs_policy_register()
748 cfs_cpt_spread_node(svcpt->scp_service->srv_cptable, in nrs_policy_register()
749 svcpt->scp_cpt)); in nrs_policy_register()
773 svcpt->scp_service->srv_name); in nrs_policy_register()
873 struct ptlrpc_service_part *svcpt = nrs->nrs_svcpt; in nrs_register_policies_locked() local
874 struct ptlrpc_service *svc = svcpt->scp_service; in nrs_register_policies_locked()
884 desc->pd_name, svcpt->scp_cpt, in nrs_register_policies_locked()
911 struct ptlrpc_service_part *svcpt) in nrs_svcpt_setup_locked0() argument
917 if (nrs == &svcpt->scp_nrs_reg) in nrs_svcpt_setup_locked0()
[all …]
|
| D | events.c | 239 #define REQS_CPT_BITS(svcpt) ((svcpt)->scp_service->srv_cpt_bits) argument
243 #define REQS_SEQ_SHIFT(svcpt) REQS_CPT_BITS(svcpt) argument
245 static void ptlrpc_req_add_history(struct ptlrpc_service_part *svcpt, in ptlrpc_req_add_history() argument
257 (svcpt->scp_cpt < 0 ? 0 : svcpt->scp_cpt); in ptlrpc_req_add_history()
259 if (new_seq > svcpt->scp_hist_seq) { in ptlrpc_req_add_history()
262 svcpt->scp_hist_seq = new_seq; in ptlrpc_req_add_history()
264 LASSERT(REQS_SEQ_SHIFT(svcpt) < REQS_USEC_SHIFT); in ptlrpc_req_add_history()
270 svcpt->scp_hist_seq += (1U << REQS_SEQ_SHIFT(svcpt)); in ptlrpc_req_add_history()
271 new_seq = svcpt->scp_hist_seq; in ptlrpc_req_add_history()
276 list_add_tail(&req->rq_history_list, &svcpt->scp_hist_reqs); in ptlrpc_req_add_history()
[all …]
|
| D | ptlrpc_internal.h | 55 int ptlrpc_start_thread(struct ptlrpc_service_part *svcpt, int wait);
122 void ptlrpc_nrs_req_initialize(struct ptlrpc_service_part *svcpt,
126 void ptlrpc_nrs_req_add(struct ptlrpc_service_part *svcpt,
130 ptlrpc_nrs_req_get_nolock0(struct ptlrpc_service_part *svcpt, bool hp,
134 ptlrpc_nrs_req_get_nolock(struct ptlrpc_service_part *svcpt, bool hp, in ptlrpc_nrs_req_get_nolock() argument
137 return ptlrpc_nrs_req_get_nolock0(svcpt, hp, false, force); in ptlrpc_nrs_req_get_nolock()
140 bool ptlrpc_nrs_req_pending_nolock(struct ptlrpc_service_part *svcpt, bool hp);
149 static inline bool nrs_svcpt_has_hp(const struct ptlrpc_service_part *svcpt) in nrs_svcpt_has_hp() argument
151 return svcpt->scp_nrs_hp != NULL; in nrs_svcpt_has_hp()
164 struct ptlrpc_nrs *nrs_svcpt2nrs(struct ptlrpc_service_part *svcpt, bool hp) in nrs_svcpt2nrs() argument
[all …]
|
| D | lproc_ptlrpc.c | 263 struct ptlrpc_service_part *svcpt; in ptlrpc_lprocfs_req_history_len_seq_show() local
267 ptlrpc_service_for_each_part(svcpt, i, svc) in ptlrpc_lprocfs_req_history_len_seq_show()
268 total += svcpt->scp_hist_nrqbds; in ptlrpc_lprocfs_req_history_len_seq_show()
280 struct ptlrpc_service_part *svcpt; in ptlrpc_lprocfs_req_history_max_seq_show() local
284 ptlrpc_service_for_each_part(svcpt, i, svc) in ptlrpc_lprocfs_req_history_max_seq_show()
372 struct ptlrpc_service_part *svcpt; in threads_started_show() local
376 ptlrpc_service_for_each_part(svcpt, i, svc) in threads_started_show()
377 total += svcpt->scp_nthrs_running; in threads_started_show()
482 struct ptlrpc_service_part *svcpt; in ptlrpc_lprocfs_nrs_seq_show() local
517 ptlrpc_service_for_each_part(svcpt, i, svc) { in ptlrpc_lprocfs_nrs_seq_show()
[all …]
|
| D | pack_generic.c | 257 lustre_get_emerg_rs(struct ptlrpc_service_part *svcpt) in lustre_get_emerg_rs() argument
261 spin_lock(&svcpt->scp_rep_lock); in lustre_get_emerg_rs()
264 while (list_empty(&svcpt->scp_rep_idle)) { in lustre_get_emerg_rs()
268 spin_unlock(&svcpt->scp_rep_lock); in lustre_get_emerg_rs()
272 rc = l_wait_event(svcpt->scp_rep_waitq, in lustre_get_emerg_rs()
273 !list_empty(&svcpt->scp_rep_idle), &lwi); in lustre_get_emerg_rs()
276 spin_lock(&svcpt->scp_rep_lock); in lustre_get_emerg_rs()
279 rs = list_entry(svcpt->scp_rep_idle.next, in lustre_get_emerg_rs()
283 spin_unlock(&svcpt->scp_rep_lock); in lustre_get_emerg_rs()
285 memset(rs, 0, svcpt->scp_service->srv_max_reply_size); in lustre_get_emerg_rs()
[all …]
|
| D | niobuf.c | 302 struct ptlrpc_service_part *svcpt = req->rq_rqbd->rqbd_svcpt; in ptlrpc_at_set_reply() local
303 struct ptlrpc_service *svc = svcpt->scp_service; in ptlrpc_at_set_reply()
315 int oldse = at_measured(&svcpt->scp_at_estimate, service_time); in ptlrpc_at_set_reply()
321 at_get(&svcpt->scp_at_estimate)); in ptlrpc_at_set_reply()
333 at_get(&svcpt->scp_at_estimate)); in ptlrpc_at_set_reply()
|
| D | sec.c | 1984 struct ptlrpc_service_part *svcpt = req->rq_rqbd->rqbd_svcpt; in sptlrpc_svc_alloc_rs() local
1986 if (svcpt->scp_service->srv_max_reply_size < in sptlrpc_svc_alloc_rs()
1991 svcpt->scp_service->srv_max_reply_size); in sptlrpc_svc_alloc_rs()
1996 rs = lustre_get_emerg_rs(svcpt); in sptlrpc_svc_alloc_rs()
|
| /drivers/staging/lustre/lustre/ldlm/ |
| D | ldlm_lib.c | 677 struct ptlrpc_service_part *svcpt; in target_send_reply() local
685 svcpt = req->rq_rqbd->rqbd_svcpt; in target_send_reply()
696 LASSERT(rs->rs_svcpt == svcpt); in target_send_reply()
733 spin_lock(&svcpt->scp_rep_lock); in target_send_reply()
735 atomic_inc(&svcpt->scp_nreps_difficult); in target_send_reply()
755 list_add(&rs->rs_list, &svcpt->scp_rep_active); in target_send_reply()
759 spin_unlock(&svcpt->scp_rep_lock); in target_send_reply()
|
| /drivers/staging/lustre/lustre/include/ |
| D | lustre_net.h | 2799 ptlrpc_server_get_timeout(struct ptlrpc_service_part *svcpt) in ptlrpc_server_get_timeout() argument
2801 int at = AT_OFF ? 0 : at_get(&svcpt->scp_at_estimate); in ptlrpc_server_get_timeout()
2803 return svcpt->scp_service->srv_watchdog_factor * in ptlrpc_server_get_timeout()
|