| /drivers/staging/lustre/lnet/klnds/o2iblnd/ |
| D | o2iblnd_modparams.c | 163 int kiblnd_msg_queue_size(int version, lnet_ni_t *ni) in kiblnd_msg_queue_size() argument
167 else if (ni) in kiblnd_msg_queue_size()
168 return ni->ni_peertxcredits; in kiblnd_msg_queue_size()
173 int kiblnd_tunables_setup(struct lnet_ni *ni) in kiblnd_tunables_setup() argument
181 if (!ni->ni_lnd_tunables) { in kiblnd_tunables_setup()
182 LIBCFS_ALLOC(ni->ni_lnd_tunables, in kiblnd_tunables_setup()
183 sizeof(*ni->ni_lnd_tunables)); in kiblnd_tunables_setup()
184 if (!ni->ni_lnd_tunables) in kiblnd_tunables_setup()
187 memcpy(&ni->ni_lnd_tunables->lt_tun_u.lt_o2ib, in kiblnd_tunables_setup()
190 tunables = &ni->ni_lnd_tunables->lt_tun_u.lt_o2ib; in kiblnd_tunables_setup()
[all …]
|
| D | o2iblnd_cb.c | 43 static void kiblnd_init_tx_msg(lnet_ni_t *ni, struct kib_tx *tx,
50 static void kiblnd_unmap_tx(lnet_ni_t *ni, struct kib_tx *tx);
54 kiblnd_tx_done(lnet_ni_t *ni, struct kib_tx *tx) in kiblnd_tx_done() argument
57 struct kib_net *net = ni->ni_data; in kiblnd_tx_done()
68 kiblnd_unmap_tx(ni, tx); in kiblnd_tx_done()
76 LASSERT(ni == tx->tx_conn->ibc_peer->ibp_ni); in kiblnd_tx_done()
92 lnet_finalize(ni, lntmsg[i], rc); in kiblnd_tx_done()
97 kiblnd_txlist_done(lnet_ni_t *ni, struct list_head *txlist, int status) in kiblnd_txlist_done() argument
108 kiblnd_tx_done(ni, tx); in kiblnd_txlist_done()
113 kiblnd_get_idle_tx(lnet_ni_t *ni, lnet_nid_t target) in kiblnd_get_idle_tx() argument
[all …]
|
| D | o2iblnd.h | 602 int kiblnd_msg_queue_size(int version, struct lnet_ni *ni);
606 kiblnd_cfg_rdma_frags(struct lnet_ni *ni) in kiblnd_cfg_rdma_frags() argument
611 tunables = &ni->ni_lnd_tunables->lt_tun_u.lt_o2ib; in kiblnd_cfg_rdma_frags()
617 kiblnd_rdma_frags(int version, struct lnet_ni *ni) in kiblnd_rdma_frags() argument
621 kiblnd_cfg_rdma_frags(ni); in kiblnd_rdma_frags()
625 kiblnd_concurrent_sends(int version, struct lnet_ni *ni) in kiblnd_concurrent_sends() argument
630 tunables = &ni->ni_lnd_tunables->lt_tun_u.lt_o2ib; in kiblnd_concurrent_sends()
767 lnet_ni_t *ni = conn->ibc_peer->ibp_ni; in kiblnd_need_noop() local
770 tunables = &ni->ni_lnd_tunables->lt_tun_u.lt_o2ib; in kiblnd_need_noop()
981 struct ib_mr *kiblnd_find_rd_dma_mr(struct lnet_ni *ni, struct kib_rdma_desc *rd,
[all …]
|
| D | o2iblnd.c | 177 void kiblnd_pack_msg(lnet_ni_t *ni, struct kib_msg *msg, int version, in kiblnd_pack_msg() argument
180 struct kib_net *net = ni->ni_data; in kiblnd_pack_msg()
192 msg->ibm_srcnid = ni->ni_nid; in kiblnd_pack_msg()
316 int kiblnd_create_peer(lnet_ni_t *ni, struct kib_peer **peerp, lnet_nid_t nid) in kiblnd_create_peer() argument
319 struct kib_net *net = ni->ni_data; in kiblnd_create_peer()
332 peer->ibp_ni = ni; in kiblnd_create_peer()
337 peer->ibp_queue_depth = ni->ni_peertxcredits; in kiblnd_create_peer()
415 static int kiblnd_get_peer_info(lnet_ni_t *ni, int index, in kiblnd_get_peer_info() argument
430 if (peer->ibp_ni != ni) in kiblnd_get_peer_info()
471 static int kiblnd_del_peer(lnet_ni_t *ni, lnet_nid_t nid) in kiblnd_del_peer() argument
[all …]
|
| /drivers/staging/dgnc/ |
| D | dgnc_mgmt.c | 165 struct ni_info ni; in dgnc_mgmt_ioctl() local
170 if (copy_from_user(&ni, uarg, sizeof(ni))) in dgnc_mgmt_ioctl()
173 board = ni.board; in dgnc_mgmt_ioctl()
174 channel = ni.channel; in dgnc_mgmt_ioctl()
189 memset(&ni, 0, sizeof(ni)); in dgnc_mgmt_ioctl()
190 ni.board = board; in dgnc_mgmt_ioctl()
191 ni.channel = channel; in dgnc_mgmt_ioctl()
198 ni.mstat |= TIOCM_DTR; in dgnc_mgmt_ioctl()
199 ni.dtr = TIOCM_DTR; in dgnc_mgmt_ioctl()
202 ni.mstat |= TIOCM_RTS; in dgnc_mgmt_ioctl()
[all …]
|
| /drivers/staging/lustre/lnet/lnet/ |
| D | api-ni.c | 659 lnet_ni_t *ni; in lnet_net2ni_locked() local
664 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_net2ni_locked()
666 if (LNET_NIDNET(ni->ni_nid) == net) { in lnet_net2ni_locked()
667 lnet_ni_addref_locked(ni, cpt); in lnet_net2ni_locked()
668 return ni; in lnet_net2ni_locked()
678 lnet_ni_t *ni; in lnet_net2ni() local
681 ni = lnet_net2ni_locked(net, 0); in lnet_net2ni()
684 return ni; in lnet_net2ni()
710 struct lnet_ni *ni; in lnet_cpt_of_nid_locked() local
718 list_for_each_entry(ni, &the_lnet.ln_nis_cpt, ni_cptlist) { in lnet_cpt_of_nid_locked()
[all …]
|
| D | config.c | 82 lnet_ni_t *ni; in lnet_net_unique() local
85 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_net_unique()
87 if (LNET_NIDNET(ni->ni_nid) == net) in lnet_net_unique()
95 lnet_ni_free(struct lnet_ni *ni) in lnet_ni_free() argument
99 if (ni->ni_refs) in lnet_ni_free()
100 cfs_percpt_free(ni->ni_refs); in lnet_ni_free()
102 if (ni->ni_tx_queues) in lnet_ni_free()
103 cfs_percpt_free(ni->ni_tx_queues); in lnet_ni_free()
105 if (ni->ni_cpts) in lnet_ni_free()
106 cfs_expr_list_values_free(ni->ni_cpts, ni->ni_ncpts); in lnet_ni_free()
[all …]
|
| D | lo.c | 35 lolnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in lolnd_send() argument
40 return lnet_parse(ni, &lntmsg->msg_hdr, ni->ni_nid, lntmsg, 0); in lolnd_send()
44 lolnd_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg, in lolnd_recv() argument
63 lnet_finalize(ni, lntmsg, 0); in lolnd_recv()
66 lnet_finalize(ni, sendmsg, 0); in lolnd_recv()
73 lolnd_shutdown(lnet_ni_t *ni) in lolnd_shutdown() argument
82 lolnd_startup(lnet_ni_t *ni) in lolnd_startup() argument
84 LASSERT(ni->ni_lnd == &the_lolnd); in lolnd_startup()
|
| D | lib-move.c | 366 lnet_ni_recv(lnet_ni_t *ni, void *private, lnet_msg_t *msg, int delayed, in lnet_ni_recv() argument
405 rc = ni->ni_lnd->lnd_recv(ni, private, msg, delayed, &to, rlen); in lnet_ni_recv()
407 lnet_finalize(ni, msg, rc); in lnet_ni_recv()
451 lnet_ni_send(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_send() argument
457 LASSERT(LNET_NETTYP(LNET_NIDNET(ni->ni_nid)) == LOLND || in lnet_ni_send()
460 rc = ni->ni_lnd->lnd_send(ni, priv, msg); in lnet_ni_send()
462 lnet_finalize(ni, msg, rc); in lnet_ni_send()
466 lnet_ni_eager_recv(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_eager_recv() argument
473 LASSERT(ni->ni_lnd->lnd_eager_recv); in lnet_ni_eager_recv()
476 rc = ni->ni_lnd->lnd_eager_recv(ni, msg->msg_private, msg, in lnet_ni_eager_recv()
[all …]
|
| D | router.c | 56 lnet_peer_buffer_credits(lnet_ni_t *ni) in lnet_peer_buffer_credits() argument
59 if (ni->ni_peerrtrcredits > 0) in lnet_peer_buffer_credits()
60 return ni->ni_peerrtrcredits; in lnet_peer_buffer_credits()
68 return ni->ni_peertxcredits; in lnet_peer_buffer_credits()
131 lnet_ni_notify_locked(lnet_ni_t *ni, lnet_peer_t *lp) in lnet_ni_notify_locked() argument
141 if (lp->lp_notifying || !ni) in lnet_ni_notify_locked()
153 if (notifylnd && ni->ni_lnd->lnd_notify) { in lnet_ni_notify_locked()
160 ni->ni_lnd->lnd_notify(ni, lp->lp_nid, alive); in lnet_ni_notify_locked()
244 lnet_ni_t *ni; in lnet_shuffle_seed() local
257 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_shuffle_seed()
[all …]
|
| D | acceptor.c | 214 lnet_ni_t *ni; in lnet_accept() local
298 ni = lnet_net2ni(LNET_NIDNET(cr.acr_nid)); in lnet_accept()
299 if (!ni || /* no matching net */ in lnet_accept()
300 ni->ni_nid != cr.acr_nid) { /* right NET, wrong NID! */ in lnet_accept()
301 if (ni) in lnet_accept()
302 lnet_ni_decref(ni); in lnet_accept()
308 if (!ni->ni_lnd->lnd_accept) { in lnet_accept()
310 lnet_ni_decref(ni); in lnet_accept()
319 rc = ni->ni_lnd->lnd_accept(ni, sock); in lnet_accept()
321 lnet_ni_decref(ni); in lnet_accept()
|
| D | router_proc.c | 655 lnet_ni_t *ni = NULL; in proc_lnet_nis() local
666 ni = a_ni; in proc_lnet_nis()
674 if (ni) { in proc_lnet_nis()
683 last_alive = now - ni->ni_last_alive; in proc_lnet_nis()
686 if (ni->ni_lnd->lnd_type == LOLND) in proc_lnet_nis()
689 lnet_ni_lock(ni); in proc_lnet_nis()
690 LASSERT(ni->ni_status); in proc_lnet_nis()
691 stat = (ni->ni_status->ns_status == in proc_lnet_nis()
693 lnet_ni_unlock(ni); in proc_lnet_nis()
699 cfs_percpt_for_each(tq, i, ni->ni_tx_queues) { in proc_lnet_nis()
[all …]
|
| D | peer.c | 104 lnet_peer_table_cleanup_locked(lnet_ni_t *ni, struct lnet_peer_table *ptable) in lnet_peer_table_cleanup_locked() argument
113 if (ni && ni != lp->lp_ni) in lnet_peer_table_cleanup_locked()
144 lnet_peer_table_del_rtrs_locked(lnet_ni_t *ni, struct lnet_peer_table *ptable, in lnet_peer_table_del_rtrs_locked() argument
155 if (ni != lp->lp_ni) in lnet_peer_table_del_rtrs_locked()
171 lnet_peer_tables_cleanup(lnet_ni_t *ni) in lnet_peer_tables_cleanup() argument
181 LASSERT(the_lnet.ln_shutdown || ni); in lnet_peer_tables_cleanup()
188 lnet_peer_table_del_rtrs_locked(ni, ptable, i); in lnet_peer_tables_cleanup()
198 lnet_peer_table_cleanup_locked(ni, ptable); in lnet_peer_tables_cleanup()
|
| D | net_fault.c | 604 struct lnet_ni *ni; in delayed_msg_process() local
611 ni = msg->msg_rxpeer->lp_ni; in delayed_msg_process()
619 rc = lnet_parse_local(ni, msg); in delayed_msg_process()
625 rc = lnet_parse_forward_locked(ni, msg); in delayed_msg_process()
630 lnet_ni_recv(ni, msg->msg_private, msg, 0, in delayed_msg_process()
639 lnet_drop_message(ni, cpt, msg->msg_private, msg->msg_len); in delayed_msg_process()
640 lnet_finalize(ni, msg, rc); in delayed_msg_process()
|
| D | Makefile | 3 lnet-y := api-ni.o config.o nidstrings.o net_fault.o \
|
| D | lib-ptl.c | 922 lnet_clear_lazy_portal(struct lnet_ni *ni, int portal, char *reason) in lnet_clear_lazy_portal() argument
941 if (ni) { in lnet_clear_lazy_portal()
947 if (msg->msg_rxpeer->lp_ni == ni) in lnet_clear_lazy_portal()
|
| /drivers/staging/lustre/include/linux/lnet/ |
| D | lib-lnet.h | 176 #define lnet_ni_lock(ni) spin_lock(&(ni)->ni_lock) argument
177 #define lnet_ni_unlock(ni) spin_unlock(&(ni)->ni_lock) argument
391 lnet_ni_addref_locked(lnet_ni_t *ni, int cpt) in lnet_ni_addref_locked() argument
394 LASSERT(*ni->ni_refs[cpt] >= 0); in lnet_ni_addref_locked()
396 (*ni->ni_refs[cpt])++; in lnet_ni_addref_locked()
400 lnet_ni_addref(lnet_ni_t *ni) in lnet_ni_addref() argument
403 lnet_ni_addref_locked(ni, 0); in lnet_ni_addref()
408 lnet_ni_decref_locked(lnet_ni_t *ni, int cpt) in lnet_ni_decref_locked() argument
411 LASSERT(*ni->ni_refs[cpt] > 0); in lnet_ni_decref_locked()
413 (*ni->ni_refs[cpt])--; in lnet_ni_decref_locked()
[all …]
|
| D | lib-types.h | 190 int (*lnd_startup)(struct lnet_ni *ni);
191 void (*lnd_shutdown)(struct lnet_ni *ni);
192 int (*lnd_ctl)(struct lnet_ni *ni, unsigned int cmd, void *arg);
213 int (*lnd_send)(struct lnet_ni *ni, void *private, lnet_msg_t *msg);
222 int (*lnd_recv)(struct lnet_ni *ni, void *private, lnet_msg_t *msg,
233 int (*lnd_eager_recv)(struct lnet_ni *ni, void *private,
237 void (*lnd_notify)(struct lnet_ni *ni, lnet_nid_t peer, int alive);
240 void (*lnd_query)(struct lnet_ni *ni, lnet_nid_t peer,
244 int (*lnd_accept)(struct lnet_ni *ni, struct socket *sock);
|
| /drivers/staging/lustre/lnet/klnds/socklnd/ |
| D | socklnd.c | 46 ksocknal_ip2iface(lnet_ni_t *ni, __u32 ip) in ksocknal_ip2iface() argument
48 struct ksock_net *net = ni->ni_data; in ksocknal_ip2iface()
99 ksocknal_create_peer(struct ksock_peer **peerp, lnet_ni_t *ni, lnet_process_id_t id) in ksocknal_create_peer() argument
102 struct ksock_net *net = ni->ni_data; in ksocknal_create_peer()
113 peer->ksnp_ni = ni; in ksocknal_create_peer()
175 ksocknal_find_peer_locked(lnet_ni_t *ni, lnet_process_id_t id) in ksocknal_find_peer_locked() argument
186 if (peer->ksnp_ni != ni) in ksocknal_find_peer_locked()
202 ksocknal_find_peer(lnet_ni_t *ni, lnet_process_id_t id) in ksocknal_find_peer() argument
207 peer = ksocknal_find_peer_locked(ni, id); in ksocknal_find_peer()
248 ksocknal_get_peer_info(lnet_ni_t *ni, int index, in ksocknal_get_peer_info() argument
[all …]
|
| D | socklnd.h | 568 void ksocknal_tx_done(lnet_ni_t *ni, struct ksock_tx *tx);
612 int ksocknal_startup(lnet_ni_t *ni);
613 void ksocknal_shutdown(lnet_ni_t *ni);
614 int ksocknal_ctl(lnet_ni_t *ni, unsigned int cmd, void *arg);
615 int ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
616 int ksocknal_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg,
618 int ksocknal_accept(lnet_ni_t *ni, struct socket *sock);
620 int ksocknal_add_peer(lnet_ni_t *ni, lnet_process_id_t id, __u32 ip, int port);
621 struct ksock_peer *ksocknal_find_peer_locked(lnet_ni_t *ni, lnet_process_id_t id);
622 struct ksock_peer *ksocknal_find_peer(lnet_ni_t *ni, lnet_process_id_t id);
[all …]
|
| D | socklnd_cb.c | 394 ksocknal_tx_done(lnet_ni_t *ni, struct ksock_tx *tx) in ksocknal_tx_done() argument
399 LASSERT(ni || tx->tx_conn); in ksocknal_tx_done()
404 if (!ni && tx->tx_conn) in ksocknal_tx_done()
405 ni = tx->tx_conn->ksnc_peer->ksnp_ni; in ksocknal_tx_done()
409 lnet_finalize(ni, lnetmsg, rc); in ksocknal_tx_done()
413 ksocknal_txlist_done(lnet_ni_t *ni, struct list_head *txlist, int error) in ksocknal_txlist_done() argument
433 ksocknal_tx_done(ni, tx); in ksocknal_txlist_done()
842 ksocknal_launch_packet(lnet_ni_t *ni, struct ksock_tx *tx, lnet_process_id_t id) in ksocknal_launch_packet() argument
856 peer = ksocknal_find_peer_locked(ni, id); in ksocknal_launch_packet()
878 peer = ksocknal_find_peer_locked(ni, id); in ksocknal_launch_packet()
[all …]
|
| /drivers/md/ |
| D | dm-stats.c | 212 size_t ni; in dm_stats_cleanup() local
219 for (ni = 0; ni < s->n_entries; ni++) { in dm_stats_cleanup()
220 shared = &s->stat_shared[ni]; in dm_stats_cleanup()
224 (unsigned long)ni, in dm_stats_cleanup()
249 size_t ni; in dm_stats_create() local
316 for (ni = 0; ni < n_entries; ni++) { in dm_stats_create()
317 atomic_set(&s->stat_shared[ni].in_flight[READ], 0); in dm_stats_create()
318 atomic_set(&s->stat_shared[ni].in_flight[WRITE], 0); in dm_stats_create()
328 for (ni = 0; ni < n_entries; ni++) { in dm_stats_create()
329 s->stat_shared[ni].tmp.histogram = hi; in dm_stats_create()
[all …]
|
| /drivers/staging/octeon/ |
| D | ethernet.c | 659 struct device_node *ni, *np; in cvm_oct_node_for_port() local
661 ni = cvm_oct_of_get_child(pip, interface); in cvm_oct_node_for_port()
662 if (!ni) in cvm_oct_node_for_port()
665 np = cvm_oct_of_get_child(ni, port); in cvm_oct_node_for_port()
666 of_node_put(ni); in cvm_oct_node_for_port()
|
| /drivers/infiniband/hw/hfi1/ |
| D | mad.c | 332 struct opa_node_info *ni; in __subn_get_opa_nodeinfo() local
336 ni = (struct opa_node_info *)data; in __subn_get_opa_nodeinfo()
344 ni->port_guid = cpu_to_be64(dd->pport[pidx].guid); in __subn_get_opa_nodeinfo()
345 ni->base_version = OPA_MGMT_BASE_VERSION; in __subn_get_opa_nodeinfo()
346 ni->class_version = OPA_SMI_CLASS_VERSION; in __subn_get_opa_nodeinfo()
347 ni->node_type = 1; /* channel adapter */ in __subn_get_opa_nodeinfo()
348 ni->num_ports = ibdev->phys_port_cnt; in __subn_get_opa_nodeinfo()
350 ni->system_image_guid = ib_hfi1_sys_image_guid; in __subn_get_opa_nodeinfo()
352 ni->node_guid = cpu_to_be64(dd->pport->guid); in __subn_get_opa_nodeinfo()
353 ni->partition_cap = cpu_to_be16(hfi1_get_npkeys(dd)); in __subn_get_opa_nodeinfo()
[all …]
|
| /drivers/media/pci/ngene/ |
| D | ngene-core.c | 1465 struct ngene_info *ni = dev->card_info; in init_channel() local
1466 int io = ni->io_type[nr]; in init_channel()
1475 if (ni->demod_attach[nr]) { in init_channel()
1476 ret = ni->demod_attach[nr](chan); in init_channel()
1480 if (chan->fe && ni->tuner_attach[nr]) { in init_channel()
1481 ret = ni->tuner_attach[nr](chan); in init_channel()
|