Home
last modified time | relevance | path

Searched refs:cpt (Results 1 – 25 of 35) sorted by relevance

12

/drivers/staging/lustre/lnet/libcfs/linux/
Dlinux-cpu.c228 cfs_cpt_weight(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_weight() argument
230 LASSERT(cpt == CFS_CPT_ANY || (cpt >= 0 && cpt < cptab->ctb_nparts)); in cfs_cpt_weight()
232 return cpt == CFS_CPT_ANY ? in cfs_cpt_weight()
234 cpumask_weight(cptab->ctb_parts[cpt].cpt_cpumask); in cfs_cpt_weight()
239 cfs_cpt_online(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_online() argument
241 LASSERT(cpt == CFS_CPT_ANY || (cpt >= 0 && cpt < cptab->ctb_nparts)); in cfs_cpt_online()
243 return cpt == CFS_CPT_ANY ? in cfs_cpt_online()
246 cpumask_any_and(cptab->ctb_parts[cpt].cpt_cpumask, in cfs_cpt_online()
252 cfs_cpt_cpumask(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_cpumask() argument
254 LASSERT(cpt == CFS_CPT_ANY || (cpt >= 0 && cpt < cptab->ctb_nparts)); in cfs_cpt_cpumask()
[all …]
Dlinux-mem.c45 void *libcfs_kvzalloc_cpt(struct cfs_cpt_table *cptab, int cpt, size_t size, in libcfs_kvzalloc_cpt() argument
51 cfs_cpt_spread_node(cptab, cpt)); in libcfs_kvzalloc_cpt()
54 ret = vmalloc_node(size, cfs_cpt_spread_node(cptab, cpt)); in libcfs_kvzalloc_cpt()
/drivers/staging/lustre/include/linux/lnet/
Dlib-lnet.h118 unsigned int cpt = (cookie >> LNET_COOKIE_TYPE_BITS) & LNET_CPT_MASK; in lnet_cpt_of_cookie() local
124 return cpt < LNET_CPT_NUMBER ? cpt : cpt % LNET_CPT_NUMBER; in lnet_cpt_of_cookie()
128 lnet_res_lock(int cpt) in lnet_res_lock() argument
130 cfs_percpt_lock(the_lnet.ln_res_lock, cpt); in lnet_res_lock()
134 lnet_res_unlock(int cpt) in lnet_res_unlock() argument
136 cfs_percpt_unlock(the_lnet.ln_res_lock, cpt); in lnet_res_unlock()
142 int cpt = lnet_cpt_current(); in lnet_res_lock_current() local
144 lnet_res_lock(cpt); in lnet_res_lock_current()
145 return cpt; in lnet_res_lock_current()
149 lnet_net_lock(int cpt) in lnet_net_lock() argument
[all …]
/drivers/staging/lustre/include/linux/libcfs/
Dlibcfs_cpu.h81 cpumask_t *cfs_cpt_cpumask(struct cfs_cpt_table *cptab, int cpt);
99 cfs_cpt_cpumask(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_cpumask() argument
129 int cfs_cpt_weight(struct cfs_cpt_table *cptab, int cpt);
133 int cfs_cpt_online(struct cfs_cpt_table *cptab, int cpt);
137 nodemask_t *cfs_cpt_nodemask(struct cfs_cpt_table *cptab, int cpt);
149 int cfs_cpt_bind(struct cfs_cpt_table *cptab, int cpt);
154 int cfs_cpt_set_cpu(struct cfs_cpt_table *cptab, int cpt, int cpu);
158 void cfs_cpt_unset_cpu(struct cfs_cpt_table *cptab, int cpt, int cpu);
164 int cpt, cpumask_t *mask);
169 int cpt, cpumask_t *mask);
[all …]
Dlibcfs_private.h135 #define LIBCFS_CPT_ALLOC_GFP(ptr, cptab, cpt, size, mask) \ argument
139 kmalloc_node((size), (mask), cfs_cpt_spread_node(cptab, cpt)) :\
140 vmalloc_node(size, cfs_cpt_spread_node(cptab, cpt)); \
145 #define LIBCFS_CPT_ALLOC(ptr, cptab, cpt, size) \ argument
146 LIBCFS_CPT_ALLOC_GFP(ptr, cptab, cpt, size, GFP_NOFS)
Dlibcfs_workitem.h66 int cfs_wi_sched_create(char *name, struct cfs_cpt_table *cptab, int cpt,
Dlibcfs.h121 void *libcfs_kvzalloc_cpt(struct cfs_cpt_table *cptab, int cpt, size_t size,
/drivers/staging/lustre/lnet/libcfs/
Dlibcfs_cpu.c97 cfs_cpt_weight(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_weight() argument
104 cfs_cpt_online(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_online() argument
111 cfs_cpt_nodemask(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_nodemask() argument
118 cfs_cpt_set_cpu(struct cfs_cpt_table *cptab, int cpt, int cpu) in cfs_cpt_set_cpu() argument
125 cfs_cpt_unset_cpu(struct cfs_cpt_table *cptab, int cpt, int cpu) in cfs_cpt_unset_cpu() argument
131 cfs_cpt_set_cpumask(struct cfs_cpt_table *cptab, int cpt, cpumask_t *mask) in cfs_cpt_set_cpumask() argument
138 cfs_cpt_unset_cpumask(struct cfs_cpt_table *cptab, int cpt, cpumask_t *mask) in cfs_cpt_unset_cpumask() argument
144 cfs_cpt_set_node(struct cfs_cpt_table *cptab, int cpt, int node) in cfs_cpt_set_node() argument
151 cfs_cpt_unset_node(struct cfs_cpt_table *cptab, int cpt, int node) in cfs_cpt_unset_node() argument
157 cfs_cpt_set_nodemask(struct cfs_cpt_table *cptab, int cpt, nodemask_t *mask) in cfs_cpt_set_nodemask() argument
[all …]
Dworkitem.c336 int cpt, int nthrs, struct cfs_wi_sched **sched_pp) in cfs_wi_sched_create() argument
343 LASSERT(!cptab || cpt == CFS_CPT_ANY || in cfs_wi_sched_create()
344 (cpt >= 0 && cpt < cfs_cpt_number(cptab))); in cfs_wi_sched_create()
357 sched->ws_cpt = cpt; in cfs_wi_sched_create()
/drivers/staging/lustre/lnet/lnet/
Dlib-msg.c132 lnet_msg_commit(lnet_msg_t *msg, int cpt) in lnet_msg_commit() argument
134 struct lnet_msg_container *container = the_lnet.ln_msg_containers[cpt]; in lnet_msg_commit()
135 lnet_counters_t *counters = the_lnet.ln_counters[cpt]; in lnet_msg_commit()
143 msg->msg_tx_cpt = cpt; in lnet_msg_commit()
151 msg->msg_rx_cpt = cpt; in lnet_msg_commit()
275 lnet_msg_decommit(lnet_msg_t *msg, int cpt, int status) in lnet_msg_decommit() argument
277 int cpt2 = cpt; in lnet_msg_decommit()
283 LASSERT(cpt == msg->msg_tx_cpt); in lnet_msg_decommit()
289 if (cpt != msg->msg_rx_cpt) { in lnet_msg_decommit()
290 lnet_net_unlock(cpt); in lnet_msg_decommit()
[all …]
Dlib-md.c75 int cpt = lnet_cpt_of_cookie(md->md_lh.lh_cookie); in lnet_md_unlink() local
77 LASSERT(*md->md_eq->eq_refs[cpt] > 0); in lnet_md_unlink()
78 (*md->md_eq->eq_refs[cpt])--; in lnet_md_unlink()
168 lnet_md_link(lnet_libmd_t *md, lnet_handle_eq_t eq_handle, int cpt) in lnet_md_link() argument
170 struct lnet_res_container *container = the_lnet.ln_md_containers[cpt]; in lnet_md_link()
194 (*md->md_eq->eq_refs[cpt])++; in lnet_md_link()
277 int cpt; in LNetMDAttach() local
298 cpt = lnet_cpt_of_cookie(meh.cookie); in LNetMDAttach()
300 lnet_res_lock(cpt); in LNetMDAttach()
308 rc = lnet_md_link(md, umd.eq_handle, cpt); in LNetMDAttach()
[all …]
Dlib-move.c601 int cpt = msg->msg_tx_cpt; in lnet_post_send_locked() local
602 struct lnet_tx_queue *tq = ni->ni_tx_queues[cpt]; in lnet_post_send_locked()
612 the_lnet.ln_counters[cpt]->drop_count++; in lnet_post_send_locked()
613 the_lnet.ln_counters[cpt]->drop_length += msg->msg_len; in lnet_post_send_locked()
614 lnet_net_unlock(cpt); in lnet_post_send_locked()
621 lnet_net_lock(cpt); in lnet_post_send_locked()
627 lnet_net_unlock(cpt); in lnet_post_send_locked()
634 lnet_net_lock(cpt); in lnet_post_send_locked()
674 lnet_net_unlock(cpt); in lnet_post_send_locked()
676 lnet_net_lock(cpt); in lnet_post_send_locked()
[all …]
Dlib-me.c152 int cpt; in LNetMEInsert() local
163 cpt = lnet_cpt_of_cookie(current_meh.cookie); in LNetMEInsert()
165 lnet_res_lock(cpt); in LNetMEInsert()
171 lnet_res_unlock(cpt); in LNetMEInsert()
181 lnet_res_unlock(cpt); in LNetMEInsert()
193 lnet_res_lh_initialize(the_lnet.ln_me_containers[cpt], &new_me->me_lh); in LNetMEInsert()
202 lnet_res_unlock(cpt); in LNetMEInsert()
228 int cpt; in LNetMEUnlink() local
232 cpt = lnet_cpt_of_cookie(meh.cookie); in LNetMEUnlink()
233 lnet_res_lock(cpt); in LNetMEUnlink()
[all …]
Dlib-ptl.c84 lnet_ptl_enable_mt(struct lnet_portal *ptl, int cpt) in lnet_ptl_enable_mt() argument
86 struct lnet_match_table *mtable = ptl->ptl_mtables[cpt]; in lnet_ptl_enable_mt()
94 ptl->ptl_mt_maps[ptl->ptl_mt_nmaps] = cpt; in lnet_ptl_enable_mt()
96 LASSERT(ptl->ptl_mt_maps[i] != cpt); in lnet_ptl_enable_mt()
97 if (ptl->ptl_mt_maps[i] < cpt) in lnet_ptl_enable_mt()
102 ptl->ptl_mt_maps[i] = cpt; in lnet_ptl_enable_mt()
109 lnet_ptl_disable_mt(struct lnet_portal *ptl, int cpt) in lnet_ptl_disable_mt() argument
111 struct lnet_match_table *mtable = ptl->ptl_mtables[cpt]; in lnet_ptl_disable_mt()
128 if (ptl->ptl_mt_maps[i] >= cpt) /* overwrite it */ in lnet_ptl_disable_mt()
268 unsigned int cpt; in lnet_mt_of_match() local
[all …]
Drouter.c423 int cpt; in lnet_check_routes() local
427 cpt = lnet_net_lock_current(); in lnet_check_routes()
455 lnet_net_unlock(cpt); in lnet_check_routes()
466 lnet_net_unlock(cpt); in lnet_check_routes()
592 int cpt; in lnet_get_route() local
596 cpt = lnet_net_lock_current(); in lnet_get_route()
612 lnet_net_unlock(cpt); in lnet_get_route()
619 lnet_net_unlock(cpt); in lnet_get_route()
801 int cpt = lnet_net_lock_current(); in lnet_wait_known_routerstate() local
813 lnet_net_unlock(cpt); in lnet_wait_known_routerstate()
[all …]
Dpeer.c259 lnet_nid2peer_locked(lnet_peer_t **lpp, lnet_nid_t nid, int cpt) in lnet_nid2peer_locked() argument
272 cpt2 = cpt != LNET_LOCK_EX ? cpt : lnet_cpt_of_nid_locked(nid); in lnet_nid2peer_locked()
292 lnet_net_unlock(cpt); in lnet_nid2peer_locked()
301 lnet_net_lock(cpt); in lnet_nid2peer_locked()
324 lnet_net_lock(cpt); in lnet_nid2peer_locked()
367 int cpt; in lnet_debug_peer() local
369 cpt = lnet_cpt_of_nid(nid); in lnet_debug_peer()
370 lnet_net_lock(cpt); in lnet_debug_peer()
372 rc = lnet_nid2peer_locked(&lp, nid, cpt); in lnet_debug_peer()
374 lnet_net_unlock(cpt); in lnet_debug_peer()
[all …]
Dnet_fault.c240 int cpt; in lnet_drop_rule_list() local
244 cpt = lnet_net_lock_current(); in lnet_drop_rule_list()
257 lnet_net_unlock(cpt); in lnet_drop_rule_list()
268 int cpt; in lnet_drop_rule_reset() local
270 cpt = lnet_net_lock_current(); in lnet_drop_rule_reset()
288 lnet_net_unlock(cpt); in lnet_drop_rule_reset()
360 int cpt; in lnet_drop_rule_match() local
371 cpt = lnet_net_lock_current(); in lnet_drop_rule_match()
378 lnet_net_unlock(cpt); in lnet_drop_rule_match()
605 int cpt; in delayed_msg_process() local
[all …]
Dapi-ni.c417 lnet_res_container_setup(struct lnet_res_container *rec, int cpt, int type) in lnet_res_container_setup() argument
426 rec->rec_lh_cookie = (cpt << LNET_COOKIE_TYPE_BITS) | type; in lnet_res_container_setup()
429 LIBCFS_CPT_ALLOC(rec->rec_lh_hash, lnet_cpt_table(), cpt, in lnet_res_container_setup()
656 lnet_net2ni_locked(__u32 net, int cpt) in lnet_net2ni_locked() argument
661 LASSERT(cpt != LNET_LOCK_EX); in lnet_net2ni_locked()
667 lnet_ni_addref_locked(ni, cpt); in lnet_net2ni_locked()
734 int cpt; in lnet_cpt_of_nid() local
743 cpt = lnet_net_lock_current(); in lnet_cpt_of_nid()
745 lnet_net_unlock(cpt); in lnet_cpt_of_nid()
755 int cpt; in lnet_islocalnet() local
[all …]
Drouter_proc.c68 #define LNET_PROC_POS_MAKE(cpt, ver, hash, off) \ argument
69 (((((loff_t)(cpt)) & LNET_PROC_CPT_MASK) << LNET_PROC_VPOS_BITS) | \
400 int cpt = LNET_PROC_CPT_GET(*ppos); in proc_lnet_peers() local
413 if (cpt >= LNET_CPT_NUMBER) { in proc_lnet_peers()
441 lnet_net_lock(cpt); in proc_lnet_peers()
442 ptable = the_lnet.ln_peer_tables[cpt]; in proc_lnet_peers()
447 lnet_net_unlock(cpt); in proc_lnet_peers()
521 lnet_net_unlock(cpt); in proc_lnet_peers()
531 lnet_net_unlock(cpt); in proc_lnet_peers()
535 cpt++; in proc_lnet_peers()
[all …]
/drivers/staging/lustre/lustre/ptlrpc/
Dptlrpcd.c170 int cpt; in ptlrpcd_select_pc() local
176 cpt = cfs_cpt_current(cfs_cpt_table, 1); in ptlrpcd_select_pc()
178 idx = cpt; in ptlrpcd_select_pc()
180 idx = ptlrpcds_cpt_idx[cpt]; in ptlrpcd_select_pc()
480 static void ptlrpcd_ctl_init(struct ptlrpcd_ctl *pc, int index, int cpt) in ptlrpcd_ctl_init() argument
483 pc->pc_cpt = cpt; in ptlrpcd_ctl_init()
494 "ptlrpcd_%02d_%02d", cpt, index); in ptlrpcd_ctl_init()
686 int cpt; in ptlrpcd_init() local
731 for (cpt = 0; cpt < ncpts; cpt++) { in ptlrpcd_init()
733 if (cpts[i] == cpt) in ptlrpcd_init()
[all …]
Dlproc_ptlrpc.c785 #define PTLRPC_REQ_CPT2POS(svc, cpt) \ argument
787 (cpt) << (64 - (svc)->srv_cpt_bits))
807 unsigned int cpt; in ptlrpc_lprocfs_svc_req_history_start() local
824 cpt = PTLRPC_REQ_POS2CPT(svc, *pos); in ptlrpc_lprocfs_svc_req_history_start()
827 if (i < cpt) /* skip */ in ptlrpc_lprocfs_svc_req_history_start()
829 if (i > cpt) /* make up the lowest position for this CPT */ in ptlrpc_lprocfs_svc_req_history_start()
Dservice.c452 struct ptlrpc_service_part *svcpt, int cpt) in ptlrpc_service_part_init() argument
459 svcpt->scp_cpt = cpt; in ptlrpc_service_part_init()
494 cfs_cpt_spread_node(svc->srv_cptable, cpt)); in ptlrpc_service_part_init()
503 cfs_cpt_spread_node(svc->srv_cptable, cpt)); in ptlrpc_service_part_init()
553 int cpt; in ptlrpc_register_service() local
637 cpt = CFS_CPT_ANY; in ptlrpc_register_service()
639 cpt = cpts ? cpts[i] : i; in ptlrpc_register_service()
642 cfs_cpt_spread_node(cptable, cpt)); in ptlrpc_register_service()
649 rc = ptlrpc_service_part_init(service, svcpt, cpt); in ptlrpc_register_service()
/drivers/staging/lustre/lnet/klnds/o2iblnd/
Do2iblnd.c320 int cpt = lnet_cpt_of_nid(nid); in kiblnd_create_peer() local
326 LIBCFS_CPT_ALLOC(peer, lnet_cpt_table(), cpt, sizeof(*peer)); in kiblnd_create_peer()
595 static int kiblnd_get_completion_vector(struct kib_conn *conn, int cpt) in kiblnd_get_completion_vector() argument
607 mask = cfs_cpt_cpumask(lnet_cpt_table(), cpt); in kiblnd_get_completion_vector()
643 int cpt; in kiblnd_create_conn() local
652 cpt = lnet_cpt_of_nid(peer->ibp_nid); in kiblnd_create_conn()
653 sched = kiblnd_data.kib_scheds[cpt]; in kiblnd_create_conn()
657 LIBCFS_CPT_ALLOC(init_qp_attr, lnet_cpt_table(), cpt, in kiblnd_create_conn()
665 LIBCFS_CPT_ALLOC(conn, lnet_cpt_table(), cpt, sizeof(*conn)); in kiblnd_create_conn()
688 LIBCFS_CPT_ALLOC(conn->ibc_connvars, lnet_cpt_table(), cpt, in kiblnd_create_conn()
[all …]
/drivers/staging/lustre/lnet/klnds/socklnd/
Dsocklnd.c101 int cpt = lnet_cpt_of_nid(id.nid); in ksocknal_create_peer() local
109 LIBCFS_CPT_ALLOC(peer, lnet_cpt_table(), cpt, sizeof(*peer)); in ksocknal_create_peer()
665 ksocknal_choose_scheduler_locked(unsigned int cpt) in ksocknal_choose_scheduler_locked() argument
667 struct ksock_sched_info *info = ksocknal_data.ksnd_sched_info[cpt]; in ksocknal_choose_scheduler_locked()
1039 int cpt; in ksocknal_create_conn() local
1136 cpt = lnet_cpt_of_nid(peerid.nid); in ksocknal_create_conn()
1286 sched = ksocknal_choose_scheduler_locked(cpt); in ksocknal_create_conn()
1325 conn->ksnc_port, incarnation, cpt, in ksocknal_create_conn()
2786 int cpt = !cpts ? i : cpts[i]; in ksocknal_net_start_threads() local
2788 LASSERT(cpt < cfs_cpt_number(lnet_cpt_table())); in ksocknal_net_start_threads()
[all …]
/drivers/s390/cio/
Ddevice_status.c157 cdev_irb->esw.esw0.erw.cpt = irb->esw.esw0.erw.cpt; in ccw_device_accumulate_esw()

12