Home
last modified time | relevance | path

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

12

/drivers/staging/lustre/include/linux/lnet/
Dapi.h75 int LNetGetId(unsigned int index, lnet_process_id_t *id);
94 lnet_process_id_t match_id_in,
102 lnet_process_id_t match_id_in,
185 lnet_process_id_t target_in,
193 lnet_process_id_t target_in,
Dlnetst.h89 lnet_process_id_t nde_id; /* id of node */
129 lnet_process_id_t rpe_peer; /* peer's id */
290 lnet_process_id_t *lstio_dbg_idsp; /* IN: id of test
320 lnet_process_id_t *lstio_grp_idsp; /* IN: array of nodes */
332 lnet_process_id_t *lstio_grp_idsp; /* IN: nodes */
432 lnet_process_id_t *lstio_sta_idsp; /* IN: pid */
Dtypes.h317 } lnet_process_id_t; typedef
561 lnet_process_id_t target;
563 lnet_process_id_t initiator;
Dlib-lnet.h464 void lnet_prep_send(lnet_msg_t *msg, int type, lnet_process_id_t target,
504 lnet_process_id_t id, __u64 mbits);
506 lnet_process_id_t id, __u64 mbits,
665 int lnet_ping(lnet_process_id_t id, int timeout_ms,
666 lnet_process_id_t *ids, int n_ids);
Dlib-types.h60 lnet_process_id_t msg_target;
132 lnet_process_id_t me_match_id;
425 lnet_process_id_t mi_id;
Dnidstr.h86 char *libcfs_id2str(lnet_process_id_t id);
/drivers/staging/lustre/lnet/selftest/
Dconsole.h54 lnet_process_id_t nd_id; /* id of the node */
179 lstcon_id2hash (lnet_process_id_t id, struct list_head *hash) in lstcon_id2hash()
201 int lstcon_nodes_debug(int timeout, int nnd, lnet_process_id_t *nds_up,
207 int lstcon_nodes_add(char *name, int nnd, lnet_process_id_t *nds_up,
209 int lstcon_nodes_remove(char *name, int nnd, lnet_process_id_t *nds_up,
227 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;
358 lnet_process_id_t dest,
402 lnet_process_id_t tsu_dest; /* id of dest node */
416 sfw_create_rpc(lnet_process_id_t peer, int service,
420 lnet_process_id_t peer, unsigned features,
433 srpc_create_client_rpc(lnet_process_id_t peer, int service,
521 srpc_init_client_rpc (srpc_client_rpc_t *rpc, lnet_process_id_t peer, in srpc_init_client_rpc()
Dconsole.c72 lstcon_node_find(lnet_process_id_t id, lstcon_node_t **ndpp, int create) in lstcon_node_find()
140 lnet_process_id_t id, lstcon_ndlink_t **ndlpp, int create) in lstcon_ndlink_find()
287 lstcon_group_ndlink_find(lstcon_group_t *grp, lnet_process_id_t id, in lstcon_group_ndlink_find()
403 int count, lnet_process_id_t *ids_up, in lstcon_group_nodes_add()
409 lnet_process_id_t id; in lstcon_group_nodes_add()
470 int count, lnet_process_id_t *ids_up, in lstcon_group_nodes_remove()
476 lnet_process_id_t id; in lstcon_group_nodes_remove()
548 lstcon_nodes_add(char *name, int count, lnet_process_id_t *ids_up, in lstcon_nodes_add()
653 lnet_process_id_t *ids_up, struct list_head *result_up) in lstcon_nodes_remove()
1527 lstcon_nodes_stat(int count, lnet_process_id_t *ids_up, in lstcon_nodes_stat()
[all …]
Drpc.c357 int len, int options, lnet_process_id_t peer, in srpc_post_passive_rdma()
397 int options, lnet_process_id_t peer, lnet_nid_t self, in srpc_post_active_rdma()
448 srpc_post_active_rqtbuf(lnet_process_id_t peer, int service, void *buf, in srpc_post_active_rqtbuf()
460 lnet_process_id_t any = {0}; in srpc_post_passive_rqtbuf()
1303 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.c255 lnet_process_id_t dest, srpc_client_rpc_t **rpcpp) in brw_client_prep_rpc()
Dframework.c899 sfw_create_test_rpc(sfw_test_unit_t *tsu, lnet_process_id_t peer, in sfw_create_test_rpc()
1378 sfw_create_rpc(lnet_process_id_t peer, int service, in sfw_create_rpc()
/drivers/staging/lustre/lnet/klnds/socklnd/
Dsocklnd.h399 lnet_process_id_t ksnp_id; /* who's on the other end(s) */
624 int ksocknal_add_peer(lnet_ni_t *ni, lnet_process_id_t id, __u32 ip, int port);
625 ksock_peer_t *ksocknal_find_peer_locked(lnet_ni_t *ni, lnet_process_id_t id);
626 ksock_peer_t *ksocknal_find_peer(lnet_ni_t *ni, lnet_process_id_t id);
636 int ksocknal_close_matching_conns(lnet_process_id_t id, __u32 ipaddr);
641 lnet_process_id_t id);
662 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()
448 ksocknal_add_peer(lnet_ni_t *ni, lnet_process_id_t id, __u32 ipaddr, int port) in ksocknal_add_peer()
565 ksocknal_del_peer(lnet_ni_t *ni, lnet_process_id_t id, __u32 ip) in ksocknal_del_peer()
1013 lnet_process_id_t peerid; in ksocknal_create_conn()
1715 ksocknal_close_matching_conns(lnet_process_id_t id, __u32 ipaddr) in ksocknal_close_matching_conns()
1765 lnet_process_id_t id = {0}; in ksocknal_notify()
1791 lnet_process_id_t id = {.nid = nid, .pid = LUSTRE_SRV_LNET_PID}; in ksocknal_query()
[all …]
Dsocklnd_cb.c830 ksocknal_launch_packet (lnet_ni_t *ni, ksock_tx_t *tx, lnet_process_id_t id) in ksocknal_launch_packet()
925 lnet_process_id_t target = lntmsg->msg_target; in ksocknal_send()
1110 lnet_process_id_t *id; in ksocknal_process_receive()
1686 ksock_hello_msg_t *hello, lnet_process_id_t *peerid, in ksocknal_recv_hello()
1700 lnet_process_id_t recv_id; in ksocknal_recv_hello()
/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()
Dniobuf.c116 lnet_process_id_t peer; in ptlrpc_register_bulk()
682 static lnet_process_id_t match_id = {LNET_NID_ANY, LNET_PID_ANY}; in ptlrpc_register_rqbd()
Devents.c435 lnet_process_id_t *peer, lnet_nid_t *self) in ptlrpc_uuid_to_peer()
/drivers/staging/lustre/lnet/lnet/
Dapi-ni.c1341 lnet_process_id_t id = {0}; in LNetCtl()
1398 (lnet_process_id_t *)data->ioc_pbuf1, in LNetCtl()
1399 data->ioc_plen1/sizeof(lnet_process_id_t)); in LNetCtl()
1408 id = *((lnet_process_id_t *) arg); in LNetCtl()
1457 LNetGetId(unsigned int index, lnet_process_id_t *id) in LNetGetId()
1508 lnet_process_id_t id; in lnet_create_ping_info()
1584 lnet_process_id_t id; in lnet_ping_target_init()
1601 memset(&id, 0, sizeof(lnet_process_id_t)); in lnet_ping_target_init()
1685 lnet_ping(lnet_process_id_t id, int timeout_ms, lnet_process_id_t *ids, int n_ids) in lnet_ping()
1697 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-ptl.c47 lnet_ptl_match_type(unsigned int index, lnet_process_id_t match_id, in lnet_ptl_match_type()
216 lnet_match2mt(struct lnet_portal *ptl, lnet_process_id_t id, __u64 mbits) in lnet_match2mt()
227 lnet_mt_of_attach(unsigned int index, lnet_process_id_t id, in lnet_mt_of_attach()
357 lnet_process_id_t id, __u64 mbits) in lnet_mt_match_head()
Dlib-move.c621 lnet_prep_send(lnet_msg_t *msg, int type, lnet_process_id_t target, in lnet_prep_send()
1499 lnet_process_id_t src = {0}; in lnet_parse_reply()
1563 lnet_process_id_t src = {0}; in lnet_parse_ack()
1653 lnet_process_id_t src = {0}; in lnet_print_hdr()
1654 lnet_process_id_t dst = {0}; in lnet_print_hdr()
1945 lnet_process_id_t id = {0}; in lnet_drop_delayed_msg_list()
1987 lnet_process_id_t id; in lnet_recv_delayed_msg_list()
2059 lnet_process_id_t target, unsigned int portal, in LNetPut()
2155 lnet_process_id_t peer_id = getmsg->msg_target; in lnet_create_reply_msg()
2260 lnet_process_id_t target, unsigned int portal, in LNetGet()
/drivers/staging/lustre/lustre/llite/
Dsuper25.c94 lnet_process_id_t lnet_id; in init_lustre_lite()
/drivers/staging/lustre/lustre/include/
Dlustre_net.h280 lnet_process_id_t c_peer;
1451 lnet_process_id_t rq_peer;
2271 lnet_process_id_t *peer, lnet_nid_t *self);
2285 struct ptlrpc_connection *ptlrpc_connection_get(lnet_process_id_t peer,

12