Home
last modified time | relevance | path

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

12

/drivers/staging/lustre/include/linux/lnet/
Dapi.h81 int LNetGetId(unsigned int index, lnet_process_id_t *id);
100 lnet_process_id_t match_id_in,
108 lnet_process_id_t match_id_in,
191 lnet_process_id_t target_in,
199 lnet_process_id_t target_in,
212 int LNetSetAsync(lnet_process_id_t id, int nasync);
Dlnetst.h94 lnet_process_id_t nde_id; /* id of node */
130 lnet_process_id_t rpe_peer; /* peer's id */
282 lnet_process_id_t *lstio_dbg_idsp; /* IN: id of test nodes */
309 lnet_process_id_t *lstio_grp_idsp; /* IN: array of nodes */
320 lnet_process_id_t *lstio_grp_idsp; /* IN: nodes */
409 lnet_process_id_t *lstio_sta_idsp; /* IN: pid */
Dtypes.h136 } lnet_process_id_t; typedef
391 lnet_process_id_t target;
393 lnet_process_id_t initiator;
Dlib-lnet.h674 void lnet_prep_send(lnet_msg_t *msg, int type, lnet_process_id_t target,
714 lnet_process_id_t id, __u64 mbits);
716 lnet_process_id_t id, __u64 mbits,
858 int lnet_ping(lnet_process_id_t id, int timeout_ms,
859 lnet_process_id_t *ids, int n_ids);
Dlib-types.h178 lnet_process_id_t msg_target;
249 lnet_process_id_t me_match_id;
569 lnet_process_id_t mi_id;
/drivers/staging/lustre/lnet/selftest/
Dconsole.h55 lnet_process_id_t nd_id; /* id of the node */
178 lstcon_id2hash (lnet_process_id_t id, struct list_head *hash) in lstcon_id2hash()
197 extern int lstcon_nodes_debug(int timeout, int nnd, lnet_process_id_t *nds_up,
203 extern int lstcon_nodes_add(char *name, int nnd, lnet_process_id_t *nds_up,
205 extern int lstcon_nodes_remove(char *name, int nnd, lnet_process_id_t *nds_up,
225 extern int lstcon_nodes_stat(int count, lnet_process_id_t *ids_up,
Dselftest.h171 lnet_process_id_t buf_peer;
192 lnet_process_id_t srpc_peer;
212 lnet_process_id_t crpc_dest;
356 lnet_process_id_t dest,
398 lnet_process_id_t tsu_dest; /* id of dest node */
412 sfw_create_rpc(lnet_process_id_t peer, int service,
416 lnet_process_id_t peer, unsigned features,
429 srpc_create_client_rpc(lnet_process_id_t peer, int service,
518 srpc_init_client_rpc (srpc_client_rpc_t *rpc, lnet_process_id_t peer, in srpc_init_client_rpc()
Dconsole.c73 lstcon_node_find(lnet_process_id_t id, lstcon_node_t **ndpp, int create) in lstcon_node_find()
141 lnet_process_id_t id, lstcon_ndlink_t **ndlpp, int create) in lstcon_ndlink_find()
288 lstcon_group_ndlink_find(lstcon_group_t *grp, lnet_process_id_t id, in lstcon_group_ndlink_find()
404 int count, lnet_process_id_t *ids_up, in lstcon_group_nodes_add()
410 lnet_process_id_t id; in lstcon_group_nodes_add()
471 int count, lnet_process_id_t *ids_up, in lstcon_group_nodes_remove()
477 lnet_process_id_t id; in lstcon_group_nodes_remove()
549 lstcon_nodes_add(char *name, int count, lnet_process_id_t *ids_up, in lstcon_nodes_add()
654 lnet_process_id_t *ids_up, struct list_head *result_up) in lstcon_nodes_remove()
1529 lstcon_nodes_stat(int count, lnet_process_id_t *ids_up, in lstcon_nodes_stat()
[all …]
Drpc.c356 int len, int options, lnet_process_id_t peer, in srpc_post_passive_rdma()
396 int options, lnet_process_id_t peer, lnet_nid_t self, in srpc_post_active_rdma()
447 srpc_post_active_rqtbuf(lnet_process_id_t peer, int service, void *buf, in srpc_post_active_rqtbuf()
459 lnet_process_id_t any = {0}; in srpc_post_passive_rqtbuf()
1297 srpc_create_client_rpc (lnet_process_id_t peer, int service, in srpc_create_client_rpc()
Dping_test.c90 lnet_process_id_t dest, srpc_client_rpc_t **rpc) in ping_client_prep_rpc()
Dbrw_test.c256 lnet_process_id_t dest, srpc_client_rpc_t **rpcpp) in brw_client_prep_rpc()
/drivers/staging/lustre/lustre/ptlrpc/
Dconnection.c48 ptlrpc_connection_get(lnet_process_id_t peer, lnet_nid_t self, in ptlrpc_connection_get()
166 return cfs_hash_djb2_hash(key, sizeof(lnet_process_id_t), mask); in conn_hashfn()
173 const lnet_process_id_t *conn_key; in conn_keycmp()
176 conn_key = (lnet_process_id_t *)key; in conn_keycmp()
Dniobuf.c117 lnet_process_id_t peer; in ptlrpc_register_bulk()
686 static lnet_process_id_t match_id = {LNET_NID_ANY, LNET_PID_ANY}; in ptlrpc_register_rqbd()
Devents.c437 lnet_process_id_t *peer, lnet_nid_t *self) in ptlrpc_uuid_to_peer()
/drivers/staging/lustre/lnet/klnds/socklnd/
Dsocklnd.h335 lnet_process_id_t ksnp_id; /* who's on the other end(s) */
524 extern int ksocknal_add_peer(lnet_ni_t *ni, lnet_process_id_t id, __u32 ip, int port);
525 extern ksock_peer_t *ksocknal_find_peer_locked (lnet_ni_t *ni, lnet_process_id_t id);
526 extern ksock_peer_t *ksocknal_find_peer (lnet_ni_t *ni, lnet_process_id_t id);
536 extern int ksocknal_close_matching_conns (lnet_process_id_t id, __u32 ipaddr);
541 lnet_process_id_t id);
563 ksock_hello_msg_t *hello, lnet_process_id_t *id,
Dsocklnd.c103 ksocknal_create_peer (ksock_peer_t **peerp, lnet_ni_t *ni, lnet_process_id_t id) in ksocknal_create_peer()
176 ksocknal_find_peer_locked (lnet_ni_t *ni, lnet_process_id_t id) in ksocknal_find_peer_locked()
204 ksocknal_find_peer (lnet_ni_t *ni, lnet_process_id_t id) in ksocknal_find_peer()
249 lnet_process_id_t *id, __u32 *myip, __u32 *peer_ip, in ksocknal_get_peer_info()
449 ksocknal_add_peer (lnet_ni_t *ni, lnet_process_id_t id, __u32 ipaddr, int port) in ksocknal_add_peer()
566 ksocknal_del_peer (lnet_ni_t *ni, lnet_process_id_t id, __u32 ip) in ksocknal_del_peer()
1015 lnet_process_id_t peerid; in ksocknal_create_conn()
1723 ksocknal_close_matching_conns (lnet_process_id_t id, __u32 ipaddr) in ksocknal_close_matching_conns()
1773 lnet_process_id_t id = {0}; in ksocknal_notify()
1799 lnet_process_id_t id = {.nid = nid, .pid = LUSTRE_SRV_LNET_PID}; in ksocknal_query()
[all …]
Dsocklnd_cb.c836 ksocknal_launch_packet (lnet_ni_t *ni, ksock_tx_t *tx, lnet_process_id_t id) in ksocknal_launch_packet()
931 lnet_process_id_t target = lntmsg->msg_target; in ksocknal_send()
1116 lnet_process_id_t *id; in ksocknal_process_receive()
1693 ksock_hello_msg_t *hello, lnet_process_id_t *peerid, in ksocknal_recv_hello()
1707 lnet_process_id_t recv_id; in ksocknal_recv_hello()
/drivers/staging/lustre/lnet/lnet/
Dapi-ni.c1419 lnet_process_id_t id = {0}; in LNetCtl()
1476 (lnet_process_id_t *)data->ioc_pbuf1, in LNetCtl()
1477 data->ioc_plen1/sizeof(lnet_process_id_t)); in LNetCtl()
1486 id = *((lnet_process_id_t *) arg); in LNetCtl()
1535 LNetGetId(unsigned int index, lnet_process_id_t *id) in LNetGetId()
1586 lnet_process_id_t id; in lnet_create_ping_info()
1663 lnet_process_id_t id; in lnet_ping_target_init()
1680 memset(&id, 0, sizeof(lnet_process_id_t)); in lnet_ping_target_init()
1764 lnet_ping(lnet_process_id_t id, int timeout_ms, lnet_process_id_t *ids, int n_ids) in lnet_ping()
1776 lnet_process_id_t tmpid; in lnet_ping()
Dlib-me.c77 lnet_process_id_t match_id, in LNetMEAttach()
149 lnet_process_id_t match_id, in LNetMEInsert()
Dlib-move.c622 lnet_prep_send(lnet_msg_t *msg, int type, lnet_process_id_t target, in lnet_prep_send()
1506 lnet_process_id_t src = {0}; in lnet_parse_reply()
1570 lnet_process_id_t src = {0}; in lnet_parse_ack()
1660 lnet_process_id_t src = {0}; in lnet_print_hdr()
1661 lnet_process_id_t dst = {0}; in lnet_print_hdr()
1948 lnet_process_id_t id = {0}; in lnet_drop_delayed_msg_list()
1990 lnet_process_id_t id; in lnet_recv_delayed_msg_list()
2063 lnet_process_id_t target, unsigned int portal, in LNetPut()
2159 lnet_process_id_t peer_id = getmsg->msg_target; in lnet_create_reply_msg()
2264 lnet_process_id_t target, unsigned int portal, in LNetGet()
[all …]
Dlib-ptl.c47 lnet_ptl_match_type(unsigned int index, lnet_process_id_t match_id, in lnet_ptl_match_type()
217 lnet_match2mt(struct lnet_portal *ptl, lnet_process_id_t id, __u64 mbits) in lnet_match2mt()
228 lnet_mt_of_attach(unsigned int index, lnet_process_id_t id, in lnet_mt_of_attach()
358 lnet_process_id_t id, __u64 mbits) in lnet_mt_match_head()
/drivers/staging/lustre/lustre/llite/
Dsuper25.c109 lnet_process_id_t lnet_id; in init_lustre_lite()
/drivers/staging/lustre/lustre/include/
Dlustre_net.h281 lnet_process_id_t c_peer;
1457 lnet_process_id_t rq_peer;
2277 lnet_process_id_t *peer, lnet_nid_t *self);
2291 struct ptlrpc_connection *ptlrpc_connection_get(lnet_process_id_t peer,
/drivers/staging/lustre/include/linux/libcfs/
Dlibcfs_private.h423 char *libcfs_id2str(lnet_process_id_t id);
/drivers/staging/lustre/lustre/obdclass/
Dobd_mount.c234 lnet_process_id_t id; in lustre_start_mgc()
344 lnet_process_id_t id; in lustre_start_mgc()

12