Home
last modified time | relevance | path

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

12

/drivers/staging/lustre/lustre/libcfs/linux/
Dlinux-cpu.c238 cfs_cpt_weight(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_weight() argument
240 LASSERT(cpt == CFS_CPT_ANY || (cpt >= 0 && cpt < cptab->ctb_nparts)); in cfs_cpt_weight()
242 return cpt == CFS_CPT_ANY ? in cfs_cpt_weight()
244 cpus_weight(*cptab->ctb_parts[cpt].cpt_cpumask); in cfs_cpt_weight()
249 cfs_cpt_online(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_online() argument
251 LASSERT(cpt == CFS_CPT_ANY || (cpt >= 0 && cpt < cptab->ctb_nparts)); in cfs_cpt_online()
253 return cpt == CFS_CPT_ANY ? in cfs_cpt_online()
255 any_online_cpu(*cptab->ctb_parts[cpt].cpt_cpumask) != NR_CPUS; in cfs_cpt_online()
260 cfs_cpt_cpumask(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_cpumask() argument
262 LASSERT(cpt == CFS_CPT_ANY || (cpt >= 0 && cpt < cptab->ctb_nparts)); in cfs_cpt_cpumask()
[all …]
/drivers/staging/lustre/include/linux/libcfs/
Dlibcfs_cpu.h85 cpumask_t *cfs_cpt_cpumask(struct cfs_cpt_table *cptab, int cpt);
103 cfs_cpt_cpumask(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_cpumask() argument
133 int cfs_cpt_weight(struct cfs_cpt_table *cptab, int cpt);
137 int cfs_cpt_online(struct cfs_cpt_table *cptab, int cpt);
141 nodemask_t *cfs_cpt_nodemask(struct cfs_cpt_table *cptab, int cpt);
153 int cfs_cpt_bind(struct cfs_cpt_table *cptab, int cpt);
158 int cfs_cpt_set_cpu(struct cfs_cpt_table *cptab, int cpt, int cpu);
162 void cfs_cpt_unset_cpu(struct cfs_cpt_table *cptab, int cpt, int cpu);
168 int cpt, cpumask_t *mask);
173 int cpt, cpumask_t *mask);
[all …]
Dlibcfs_private.h166 #define LIBCFS_CPT_ALLOC_GFP(ptr, cptab, cpt, size, mask) \ argument
170 kmalloc_node((size), (mask), cfs_cpt_spread_node(cptab, cpt)) :\
171 vmalloc_node(size, cfs_cpt_spread_node(cptab, cpt)); \
176 #define LIBCFS_CPT_ALLOC(ptr, cptab, cpt, size) \ argument
177 LIBCFS_CPT_ALLOC_GFP(ptr, cptab, cpt, size, GFP_NOFS)
Dlibcfs_workitem.h70 int cfs_wi_sched_create(char *name, struct cfs_cpt_table *cptab, int cpt,
/drivers/staging/lustre/include/linux/lnet/
Dlib-lnet.h117 unsigned int cpt = (cookie >> LNET_COOKIE_TYPE_BITS) & LNET_CPT_MASK; in lnet_cpt_of_cookie() local
121 return cpt < LNET_CPT_NUMBER ? cpt : cpt % LNET_CPT_NUMBER; in lnet_cpt_of_cookie()
125 lnet_res_lock(int cpt) in lnet_res_lock() argument
127 cfs_percpt_lock(the_lnet.ln_res_lock, cpt); in lnet_res_lock()
131 lnet_res_unlock(int cpt) in lnet_res_unlock() argument
133 cfs_percpt_unlock(the_lnet.ln_res_lock, cpt); in lnet_res_unlock()
139 int cpt = lnet_cpt_current(); in lnet_res_lock_current() local
141 lnet_res_lock(cpt); in lnet_res_lock_current()
142 return cpt; in lnet_res_lock_current()
146 lnet_net_lock(int cpt) in lnet_net_lock() argument
[all …]
/drivers/staging/lustre/lustre/libcfs/
Dlibcfs_cpu.c101 cfs_cpt_weight(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_weight() argument
108 cfs_cpt_online(struct cfs_cpt_table *cptab, int cpt) in cfs_cpt_online() argument
115 cfs_cpt_set_cpu(struct cfs_cpt_table *cptab, int cpt, int cpu) in cfs_cpt_set_cpu() argument
122 cfs_cpt_unset_cpu(struct cfs_cpt_table *cptab, int cpt, int cpu) in cfs_cpt_unset_cpu() argument
128 cfs_cpt_set_cpumask(struct cfs_cpt_table *cptab, int cpt, cpumask_t *mask) in cfs_cpt_set_cpumask() argument
135 cfs_cpt_unset_cpumask(struct cfs_cpt_table *cptab, int cpt, cpumask_t *mask) in cfs_cpt_unset_cpumask() argument
141 cfs_cpt_set_node(struct cfs_cpt_table *cptab, int cpt, int node) in cfs_cpt_set_node() argument
148 cfs_cpt_unset_node(struct cfs_cpt_table *cptab, int cpt, int node) in cfs_cpt_unset_node() argument
154 cfs_cpt_set_nodemask(struct cfs_cpt_table *cptab, int cpt, nodemask_t *mask) in cfs_cpt_set_nodemask() argument
161 cfs_cpt_unset_nodemask(struct cfs_cpt_table *cptab, int cpt, nodemask_t *mask) in cfs_cpt_unset_nodemask() argument
[all …]
Dlibcfs_mem.c128 int cpt; in cfs_percpt_current() local
131 cpt = cfs_cpt_current(arr->va_cptab, 0); in cfs_percpt_current()
132 if (cpt < 0) in cfs_percpt_current()
135 return arr->va_ptrs[cpt]; in cfs_percpt_current()
Dworkitem.c353 int cpt, int nthrs, struct cfs_wi_sched **sched_pp) in cfs_wi_sched_create() argument
360 LASSERT(cptab == NULL || cpt == CFS_CPT_ANY || in cfs_wi_sched_create()
361 (cpt >= 0 && cpt < cfs_cpt_number(cptab))); in cfs_wi_sched_create()
370 sched->ws_cpt = cpt; in cfs_wi_sched_create()
/drivers/staging/lustre/lnet/lnet/
Dlib-md.c77 int cpt = lnet_cpt_of_cookie(md->md_lh.lh_cookie); in lnet_md_unlink() local
79 LASSERT(*md->md_eq->eq_refs[cpt] > 0); in lnet_md_unlink()
80 (*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()
190 (*md->md_eq->eq_refs[cpt])++; in lnet_md_link()
273 int cpt; in LNetMDAttach() local
292 cpt = lnet_cpt_of_cookie(meh.cookie); in LNetMDAttach()
294 lnet_res_lock(cpt); in LNetMDAttach()
304 rc = lnet_md_link(md, umd.eq_handle, cpt); in LNetMDAttach()
[all …]
Dlib-msg.c137 lnet_msg_commit(lnet_msg_t *msg, int cpt) in lnet_msg_commit() argument
139 struct lnet_msg_container *container = the_lnet.ln_msg_containers[cpt]; in lnet_msg_commit()
140 lnet_counters_t *counters = the_lnet.ln_counters[cpt]; in lnet_msg_commit()
148 msg->msg_tx_cpt = cpt; in lnet_msg_commit()
156 msg->msg_rx_cpt = cpt; in lnet_msg_commit()
274 lnet_msg_decommit(lnet_msg_t *msg, int cpt, int status) in lnet_msg_decommit() argument
276 int cpt2 = cpt; in lnet_msg_decommit()
282 LASSERT(cpt == msg->msg_tx_cpt); in lnet_msg_decommit()
288 if (cpt != msg->msg_rx_cpt) { in lnet_msg_decommit()
289 lnet_net_unlock(cpt); in lnet_msg_decommit()
[all …]
Dlib-move.c792 int cpt = msg->msg_tx_cpt; in lnet_post_send_locked() local
793 struct lnet_tx_queue *tq = ni->ni_tx_queues[cpt]; in lnet_post_send_locked()
803 the_lnet.ln_counters[cpt]->drop_count++; in lnet_post_send_locked()
804 the_lnet.ln_counters[cpt]->drop_length += msg->msg_len; in lnet_post_send_locked()
805 lnet_net_unlock(cpt); in lnet_post_send_locked()
812 lnet_net_lock(cpt); in lnet_post_send_locked()
818 lnet_net_unlock(cpt); in lnet_post_send_locked()
826 lnet_net_lock(cpt); in lnet_post_send_locked()
866 lnet_net_unlock(cpt); in lnet_post_send_locked()
868 lnet_net_lock(cpt); in lnet_post_send_locked()
[all …]
Dlib-me.c157 int cpt; in LNetMEInsert() local
169 cpt = lnet_cpt_of_cookie(current_meh.cookie); in LNetMEInsert()
171 lnet_res_lock(cpt); in LNetMEInsert()
177 lnet_res_unlock(cpt); in LNetMEInsert()
187 lnet_res_unlock(cpt); in LNetMEInsert()
199 lnet_res_lh_initialize(the_lnet.ln_me_containers[cpt], &new_me->me_lh); in LNetMEInsert()
208 lnet_res_unlock(cpt); in LNetMEInsert()
234 int cpt; in LNetMEUnlink() local
239 cpt = lnet_cpt_of_cookie(meh.cookie); in LNetMEUnlink()
240 lnet_res_lock(cpt); in LNetMEUnlink()
[all …]
Dlib-ptl.c89 lnet_ptl_enable_mt(struct lnet_portal *ptl, int cpt) in lnet_ptl_enable_mt() argument
91 struct lnet_match_table *mtable = ptl->ptl_mtables[cpt]; in lnet_ptl_enable_mt()
99 ptl->ptl_mt_maps[ptl->ptl_mt_nmaps] = cpt; in lnet_ptl_enable_mt()
101 LASSERT(ptl->ptl_mt_maps[i] != cpt); in lnet_ptl_enable_mt()
102 if (ptl->ptl_mt_maps[i] < cpt) in lnet_ptl_enable_mt()
107 ptl->ptl_mt_maps[i] = cpt; in lnet_ptl_enable_mt()
114 lnet_ptl_disable_mt(struct lnet_portal *ptl, int cpt) in lnet_ptl_disable_mt() argument
116 struct lnet_match_table *mtable = ptl->ptl_mtables[cpt]; in lnet_ptl_disable_mt()
133 if (ptl->ptl_mt_maps[i] >= cpt) /* overwrite it */ in lnet_ptl_disable_mt()
269 int cpt; in lnet_mt_of_match() local
[all …]
Dpeer.c206 lnet_nid2peer_locked(lnet_peer_t **lpp, lnet_nid_t nid, int cpt) in lnet_nid2peer_locked() argument
219 cpt2 = cpt != LNET_LOCK_EX ? cpt : lnet_cpt_of_nid_locked(nid); in lnet_nid2peer_locked()
239 lnet_net_unlock(cpt); in lnet_nid2peer_locked()
248 lnet_net_lock(cpt); in lnet_nid2peer_locked()
271 lnet_net_lock(cpt); in lnet_nid2peer_locked()
314 int cpt; in lnet_debug_peer() local
316 cpt = lnet_cpt_of_nid(nid); in lnet_debug_peer()
317 lnet_net_lock(cpt); in lnet_debug_peer()
319 rc = lnet_nid2peer_locked(&lp, nid, cpt); in lnet_debug_peer()
321 lnet_net_unlock(cpt); in lnet_debug_peer()
[all …]
Drouter.c425 int cpt; in lnet_check_routes() local
429 cpt = lnet_net_lock_current(); in lnet_check_routes()
458 lnet_net_unlock(cpt); in lnet_check_routes()
470 lnet_net_unlock(cpt); in lnet_check_routes()
563 int cpt; in lnet_get_route() local
567 cpt = lnet_net_lock_current(); in lnet_get_route()
584 lnet_net_unlock(cpt); in lnet_get_route()
591 lnet_net_unlock(cpt); in lnet_get_route()
765 int cpt = lnet_net_lock_current(); in lnet_wait_known_routerstate() local
777 lnet_net_unlock(cpt); in lnet_wait_known_routerstate()
[all …]
Dapi-ni.c494 int cpt, int type, int objnum, int objsz) in lnet_res_container_setup() argument
510 rec->rec_lh_cookie = (cpt << LNET_COOKIE_TYPE_BITS) | type; in lnet_res_container_setup()
513 LIBCFS_CPT_ALLOC(rec->rec_lh_hash, lnet_cpt_table(), cpt, in lnet_res_container_setup()
729 lnet_net2ni_locked(__u32 net, int cpt) in lnet_net2ni_locked() argument
734 LASSERT(cpt != LNET_LOCK_EX); in lnet_net2ni_locked()
740 lnet_ni_addref_locked(ni, cpt); in lnet_net2ni_locked()
807 int cpt; in lnet_cpt_of_nid() local
816 cpt = lnet_net_lock_current(); in lnet_cpt_of_nid()
818 lnet_net_unlock(cpt); in lnet_cpt_of_nid()
828 int cpt; in lnet_islocalnet() local
[all …]
Drouter_proc.c85 #define LNET_PROC_POS_MAKE(cpt, ver, hash, off) \ argument
86 (((((loff_t)(cpt)) & LNET_PROC_CPT_MASK) << LNET_PROC_VPOS_BITS) | \
435 int cpt = LNET_PROC_CPT_GET(*ppos); in proc_lnet_peers() local
448 if (cpt >= LNET_CPT_NUMBER) { in proc_lnet_peers()
476 lnet_net_lock(cpt); in proc_lnet_peers()
477 ptable = the_lnet.ln_peer_tables[cpt]; in proc_lnet_peers()
482 lnet_net_unlock(cpt); in proc_lnet_peers()
554 lnet_net_unlock(cpt); in proc_lnet_peers()
564 lnet_net_unlock(cpt); in proc_lnet_peers()
568 cpt++; in proc_lnet_peers()
[all …]
/drivers/staging/lustre/lustre/include/
Dobd_support.h602 #define __OBD_MALLOC_VERBOSE(ptr, cptab, cpt, size, flags) \ argument
606 kmalloc_node(size, flags, cfs_cpt_spread_node(cptab, cpt)); \
625 #define __OBD_MALLOC_VERBOSE(ptr, cptab, cpt, size, flags) \ argument
630 cfs_cpt_spread_node(cptab, cpt)); \
649 #define OBD_CPT_ALLOC_GFP(ptr, cptab, cpt, size, gfp_mask) \ argument
650 __OBD_MALLOC_VERBOSE(ptr, cptab, cpt, size, gfp_mask)
652 #define OBD_CPT_ALLOC(ptr, cptab, cpt, size) \ argument
653 OBD_CPT_ALLOC_GFP(ptr, cptab, cpt, size, GFP_NOFS)
655 #define OBD_CPT_ALLOC_PTR(ptr, cptab, cpt) \ argument
656 OBD_CPT_ALLOC(ptr, cptab, cpt, sizeof(*(ptr)))
[all …]
/drivers/staging/lustre/lnet/klnds/o2iblnd/
Do2iblnd.c332 int cpt = lnet_cpt_of_nid(nid); in kiblnd_create_peer() local
338 LIBCFS_CPT_ALLOC(peer, lnet_cpt_table(), cpt, sizeof(*peer)); in kiblnd_create_peer()
624 kiblnd_get_completion_vector(kib_conn_t *conn, int cpt) in kiblnd_get_completion_vector() argument
636 mask = cfs_cpt_cpumask(lnet_cpt_table(), cpt); in kiblnd_get_completion_vector()
670 int cpt; in kiblnd_create_conn() local
679 cpt = lnet_cpt_of_nid(peer->ibp_nid); in kiblnd_create_conn()
680 sched = kiblnd_data.kib_scheds[cpt]; in kiblnd_create_conn()
684 LIBCFS_CPT_ALLOC(init_qp_attr, lnet_cpt_table(), cpt, in kiblnd_create_conn()
692 LIBCFS_CPT_ALLOC(conn, lnet_cpt_table(), cpt, sizeof(*conn)); in kiblnd_create_conn()
713 LIBCFS_CPT_ALLOC(conn->ibc_connvars, lnet_cpt_table(), cpt, in kiblnd_create_conn()
[all …]
Do2iblnd.h348 #define KIB_THREAD_ID(cpt, tid) ((cpt) << KIB_THREAD_SHIFT | (tid)) argument
981 int kiblnd_alloc_pages(kib_pages_t **pp, int cpt, int npages);
/drivers/staging/lustre/lustre/ptlrpc/
Dlproc_ptlrpc.c790 #define PTLRPC_REQ_CPT2POS(svc, cpt) \ argument
792 (cpt) << (64 - (svc)->srv_cpt_bits))
812 unsigned int cpt; in ptlrpc_lprocfs_svc_req_history_start() local
829 cpt = PTLRPC_REQ_POS2CPT(svc, *pos); in ptlrpc_lprocfs_svc_req_history_start()
832 if (i < cpt) /* skip */ in ptlrpc_lprocfs_svc_req_history_start()
834 if (i > cpt) /* make up the lowest position for this CPT */ in ptlrpc_lprocfs_svc_req_history_start()
Dservice.c595 struct ptlrpc_service_part *svcpt, int cpt) in ptlrpc_service_part_init() argument
602 svcpt->scp_cpt = cpt; in ptlrpc_service_part_init()
636 svc->srv_cptable, cpt, sizeof(struct list_head) * size); in ptlrpc_service_part_init()
644 svc->srv_cptable, cpt, sizeof(__u32) * size); in ptlrpc_service_part_init()
694 int cpt; in ptlrpc_register_service() local
779 cpt = CFS_CPT_ANY; in ptlrpc_register_service()
781 cpt = cpts != NULL ? cpts[i] : i; in ptlrpc_register_service()
783 OBD_CPT_ALLOC(svcpt, cptable, cpt, sizeof(*svcpt)); in ptlrpc_register_service()
790 rc = ptlrpc_service_part_init(service, svcpt, cpt); in ptlrpc_register_service()
/drivers/staging/lustre/lnet/klnds/socklnd/
Dsocklnd.c662 ksocknal_choose_scheduler_locked(unsigned int cpt) in ksocknal_choose_scheduler_locked() argument
664 struct ksock_sched_info *info = ksocknal_data.ksnd_sched_info[cpt]; in ksocknal_choose_scheduler_locked()
1024 int cpt; in ksocknal_create_conn() local
1118 cpt = lnet_cpt_of_nid(peerid.nid); in ksocknal_create_conn()
1255 sched = ksocknal_choose_scheduler_locked(cpt); in ksocknal_create_conn()
1295 conn->ksnc_port, incarnation, cpt, in ksocknal_create_conn()
2758 int cpt = (cpts == NULL) ? i : cpts[i]; in ksocknal_net_start_threads() local
2760 LASSERT(cpt < cfs_cpt_number(lnet_cpt_table())); in ksocknal_net_start_threads()
2761 info = ksocknal_data.ksnd_sched_info[cpt]; in ksocknal_net_start_threads()
/drivers/staging/lustre/lnet/selftest/
Dselftest.h424 int sfw_alloc_pages(srpc_server_rpc_t *rpc, int cpt, int npages, int len,
436 srpc_bulk_t *srpc_alloc_bulk(int cpt, unsigned bulk_npg, unsigned bulk_len,
/drivers/s390/cio/
Ddevice_status.c156 cdev_irb->esw.esw0.erw.cpt = irb->esw.esw0.erw.cpt; in ccw_device_accumulate_esw()

12