| /linux-4.1.27/drivers/staging/lustre/lustre/ptlrpc/ |
| D | service.c | 63 static int ptlrpc_server_post_idle_rqbds(struct ptlrpc_service_part *svcpt);
73 ptlrpc_alloc_rqbd(struct ptlrpc_service_part *svcpt) in ptlrpc_alloc_rqbd() argument
75 struct ptlrpc_service *svc = svcpt->scp_service; in ptlrpc_alloc_rqbd()
78 OBD_CPT_ALLOC_PTR(rqbd, svc->srv_cptable, svcpt->scp_cpt); in ptlrpc_alloc_rqbd()
82 rqbd->rqbd_svcpt = svcpt; in ptlrpc_alloc_rqbd()
88 svcpt->scp_cpt, svc->srv_buf_size); in ptlrpc_alloc_rqbd()
94 spin_lock(&svcpt->scp_lock); in ptlrpc_alloc_rqbd()
95 list_add(&rqbd->rqbd_list, &svcpt->scp_rqbd_idle); in ptlrpc_alloc_rqbd()
96 svcpt->scp_nrqbds_total++; in ptlrpc_alloc_rqbd()
97 spin_unlock(&svcpt->scp_lock); in ptlrpc_alloc_rqbd()
[all …]
|
| D | ptlrpc_internal.h | 51 int ptlrpc_start_thread(struct ptlrpc_service_part *svcpt, int wait);
119 void ptlrpc_nrs_req_initialize(struct ptlrpc_service_part *svcpt,
123 void ptlrpc_nrs_req_add(struct ptlrpc_service_part *svcpt,
127 ptlrpc_nrs_req_get_nolock0(struct ptlrpc_service_part *svcpt, bool hp,
131 ptlrpc_nrs_req_get_nolock(struct ptlrpc_service_part *svcpt, bool hp, in ptlrpc_nrs_req_get_nolock() argument
134 return ptlrpc_nrs_req_get_nolock0(svcpt, hp, false, force); in ptlrpc_nrs_req_get_nolock()
138 ptlrpc_nrs_req_peek_nolock(struct ptlrpc_service_part *svcpt, bool hp) in ptlrpc_nrs_req_peek_nolock() argument
140 return ptlrpc_nrs_req_get_nolock0(svcpt, hp, true, false); in ptlrpc_nrs_req_peek_nolock()
144 bool ptlrpc_nrs_req_pending_nolock(struct ptlrpc_service_part *svcpt, bool hp);
153 static inline bool nrs_svcpt_has_hp(const struct ptlrpc_service_part *svcpt) in nrs_svcpt_has_hp() argument
[all …]
|
| D | nrs.c | 738 struct ptlrpc_service_part *svcpt = nrs->nrs_svcpt; in nrs_policy_register() local
741 LASSERT(svcpt != NULL); in nrs_policy_register()
749 OBD_CPT_ALLOC_GFP(policy, svcpt->scp_service->srv_cptable, in nrs_policy_register()
750 svcpt->scp_cpt, sizeof(*policy), GFP_NOFS); in nrs_policy_register()
774 svcpt->scp_service->srv_name); in nrs_policy_register()
874 struct ptlrpc_service_part *svcpt = nrs->nrs_svcpt; in nrs_register_policies_locked() local
875 struct ptlrpc_service *svc = svcpt->scp_service; in nrs_register_policies_locked()
885 desc->pd_name, svcpt->scp_cpt, in nrs_register_policies_locked()
912 struct ptlrpc_service_part *svcpt) in nrs_svcpt_setup_locked0() argument
918 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 | 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()
279 struct ptlrpc_service_part *svcpt; in ptlrpc_lprocfs_req_history_max_seq_show() local
283 ptlrpc_service_for_each_part(svcpt, i, svc) in ptlrpc_lprocfs_req_history_max_seq_show()
369 struct ptlrpc_service_part *svcpt; in ptlrpc_lprocfs_threads_started_seq_show() local
373 ptlrpc_service_for_each_part(svcpt, i, svc) in ptlrpc_lprocfs_threads_started_seq_show()
374 total += svcpt->scp_nthrs_running; in ptlrpc_lprocfs_threads_started_seq_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 | 274 lustre_get_emerg_rs(struct ptlrpc_service_part *svcpt) in lustre_get_emerg_rs() argument
278 spin_lock(&svcpt->scp_rep_lock); in lustre_get_emerg_rs()
281 while (list_empty(&svcpt->scp_rep_idle)) { in lustre_get_emerg_rs()
285 spin_unlock(&svcpt->scp_rep_lock); in lustre_get_emerg_rs()
289 rc = l_wait_event(svcpt->scp_rep_waitq, in lustre_get_emerg_rs()
290 !list_empty(&svcpt->scp_rep_idle), &lwi); in lustre_get_emerg_rs()
293 spin_lock(&svcpt->scp_rep_lock); in lustre_get_emerg_rs()
296 rs = list_entry(svcpt->scp_rep_idle.next, in lustre_get_emerg_rs()
300 spin_unlock(&svcpt->scp_rep_lock); in lustre_get_emerg_rs()
302 memset(rs, 0, svcpt->scp_service->srv_max_reply_size); in lustre_get_emerg_rs()
[all …]
|
| D | niobuf.c | 304 struct ptlrpc_service_part *svcpt = req->rq_rqbd->rqbd_svcpt; in ptlrpc_at_set_reply() local
305 struct ptlrpc_service *svc = svcpt->scp_service; in ptlrpc_at_set_reply()
317 int oldse = at_measured(&svcpt->scp_at_estimate, service_time); in ptlrpc_at_set_reply()
323 at_get(&svcpt->scp_at_estimate)); in ptlrpc_at_set_reply()
336 at_get(&svcpt->scp_at_estimate)); in ptlrpc_at_set_reply()
|
| D | sec.c | 2092 struct ptlrpc_service_part *svcpt = req->rq_rqbd->rqbd_svcpt; in sptlrpc_svc_alloc_rs() local
2093 if (svcpt->scp_service->srv_max_reply_size < in sptlrpc_svc_alloc_rs()
2098 svcpt->scp_service->srv_max_reply_size); in sptlrpc_svc_alloc_rs()
2103 rs = lustre_get_emerg_rs(svcpt); in sptlrpc_svc_alloc_rs()
|
| /linux-4.1.27/drivers/staging/lustre/lustre/ldlm/ |
| D | ldlm_lib.c | 680 struct ptlrpc_service_part *svcpt; in target_send_reply() local
688 svcpt = req->rq_rqbd->rqbd_svcpt; in target_send_reply()
699 LASSERT(rs->rs_svcpt == svcpt); in target_send_reply()
736 spin_lock(&svcpt->scp_rep_lock); in target_send_reply()
738 atomic_inc(&svcpt->scp_nreps_difficult); in target_send_reply()
758 list_add(&rs->rs_list, &svcpt->scp_rep_active); in target_send_reply()
762 spin_unlock(&svcpt->scp_rep_lock); in target_send_reply()
|
| /linux-4.1.27/drivers/staging/lustre/lustre/include/ |
| D | lustre_net.h | 2840 ptlrpc_server_get_timeout(struct ptlrpc_service_part *svcpt) in ptlrpc_server_get_timeout() argument
2842 int at = AT_OFF ? 0 : at_get(&svcpt->scp_at_estimate); in ptlrpc_server_get_timeout()
2844 return svcpt->scp_service->srv_watchdog_factor * in ptlrpc_server_get_timeout()
|