| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/efa/src/rxr/ |
| H A D | rxr_pkt_type_req.c | 97 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_req_hdr()
320 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_eager_msgrtm()
328 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_eager_tagrtm()
372 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_long_rtm()
385 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_long_msgrtm()
393 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_long_tagrtm()
433 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_read_msgrtm()
440 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_read_tagrtm()
744 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_proc_matched_medium_rtm()
778 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_proc_matched_rtm()
[all …]
|
| H A D | rxr_pkt_type_misc.c | 52 struct rxr_pkt_entry *pkt_entry, in rxr_pkt_init_handshake()
75 struct rxr_pkt_entry *pkt_entry; in rxr_pkt_post_handshake() local
109 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_handshake_recv()
166 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_cts()
197 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_cts_sent()
247 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_readrsp()
309 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_readrsp_recv()
332 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_write_context()
473 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_eor_send_completion()
531 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_atomrsp()
[all …]
|
| H A D | rxr_pkt_entry.c | 52 struct rxr_pkt_entry *pkt_entry; in rxr_pkt_entry_alloc() local
110 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_entry_release_tx()
123 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_entry_release_single_rx()
147 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_entry_release_rx()
300 struct rxr_pkt_entry *pkt_entry, in rxr_pkt_entry_sendv()
320 struct rxr_pkt_entry *pkt_entry, in rxr_pkt_entry_send_with_flags()
340 struct rxr_pkt_entry *pkt_entry, in rxr_pkt_entry_send()
347 struct rxr_pkt_entry *pkt_entry, in rxr_pkt_entry_inject()
364 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_rx_map_lookup()
376 struct rxr_pkt_entry *pkt_entry, in rxr_pkt_rx_map_insert()
[all …]
|
| H A D | rxr_pkt_type_data.c | 50 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_send_data()
120 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_send_data_desc()
212 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_data_send_completion()
229 struct rxr_pkt_entry *pkt_entry, in rxr_pkt_proc_data()
294 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_data_recv()
|
| H A D | rxr_pkt_cmd.c | 52 struct rxr_pkt_entry *pkt_entry; in rxr_pkt_post_data() local
106 int ctrl_type, struct rxr_pkt_entry *pkt_entry) in rxr_pkt_init_ctrl()
184 void rxr_pkt_handle_ctrl_sent(struct rxr_ep *rxr_ep, struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_ctrl_sent()
244 struct rxr_pkt_entry *pkt_entry; in rxr_pkt_post_ctrl_once() local
361 struct rxr_pkt_entry *pkt_entry; in rxr_pkt_handle_send_completion() local
443 fi_addr_t rxr_pkt_insert_addr(struct rxr_ep *ep, struct rxr_pkt_entry *pkt_entry) in rxr_pkt_insert_addr()
490 struct rxr_pkt_entry *pkt_entry; in rxr_pkt_handle_recv_completion() local
|
| H A D | rxr_cq.c | 87 struct rxr_pkt_entry *pkt_entry; in rxr_cq_handle_rx_error() local
174 struct rxr_pkt_entry *pkt_entry; in rxr_cq_handle_tx_error() local
239 struct rxr_pkt_entry *pkt_entry) in rxr_cq_queue_pkt()
305 struct rxr_pkt_entry *pkt_entry; in rxr_cq_handle_cq_error() local
517 struct rxr_pkt_entry *pkt_entry, in rxr_cq_handle_rx_completion()
592 struct rxr_pkt_entry *pkt_entry) in rxr_cq_reorder_msg()
|
| H A D | rxr_pkt_type_req.h | 124 uint32_t rxr_pkt_msg_id(struct rxr_pkt_entry *pkt_entry) in rxr_pkt_msg_id()
137 uint64_t rxr_pkt_rtm_tag(struct rxr_pkt_entry *pkt_entry) in rxr_pkt_rtm_tag()
153 void rxr_pkt_rtm_settag(struct rxr_pkt_entry *pkt_entry, uint64_t tag) in rxr_pkt_rtm_settag()
288 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_eager_rtm_sent()
302 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_read_rtm_sent()
320 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_read_rtm_send_completion()
424 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_eager_rtw_sent()
435 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_read_rtw_sent()
450 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_read_rtw_send_completion()
556 struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_rta_sent()
|
| H A D | rxr_pkt_entry.h | 92 static inline void *rxr_pkt_start(struct rxr_pkt_entry *pkt_entry) in rxr_pkt_start()
|
| H A D | rxr_read.c | 303 struct rxr_pkt_entry *pkt_entry; in rxr_read_post() local
|
| H A D | rxr_ep.c | 206 struct rxr_pkt_entry *pkt_entry) in rxr_ep_split_rx_entry()
1313 struct rxr_pkt_entry *pkt_entry; in rxr_ep_send_queued_pkts() local
|
| H A D | rxr_msg.c | 492 struct rxr_pkt_entry *pkt_entry; in rxr_msg_handle_unexp_match() local
873 struct rxr_pkt_entry *pkt_entry; in rxr_msg_peek_trecv() local
|
| H A D | rxr_rma.c | 159 struct rxr_pkt_entry *pkt_entry; in rxr_rma_post_shm_write() local
|
| H A D | rxr_pkt_type.h | 349 void rxr_pkt_handle_eor_sent(struct rxr_ep *ep, struct rxr_pkt_entry *pkt_entry) in rxr_pkt_handle_eor_sent()
|
| H A D | rxr.h | 475 #define RXR_GET_X_ENTRY_TYPE(pkt_entry) \ argument
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxd/src/ |
| H A D | rxd_ep.c | 41 struct rxd_pkt_entry *pkt_entry; in rxd_get_tx_pkt() local
228 struct rxd_pkt_entry *pkt_entry; in rxd_ep_post_buf() local
377 struct rxd_pkt_entry *pkt_entry) in rxd_insert_unacked()
386 struct rxd_pkt_entry *pkt_entry; in rxd_ep_post_data_pkts() local
436 struct rxd_pkt_entry *pkt_entry; in rxd_ep_send_rts() local
557 struct rxd_pkt_entry *pkt_entry; in rxd_ep_send_ack() local
599 struct rxd_pkt_entry *pkt_entry; in rxd_close_peer() local
633 struct rxd_pkt_entry *pkt_entry; in rxd_cleanup_unexp_msg() local
658 struct rxd_pkt_entry *pkt_entry; in rxd_ep_close() local
883 struct rxd_pkt_entry *pkt_entry; in rxd_peer_timeout() local
[all …]
|
| H A D | rxd_cq.c | 98 static void rxd_remove_rx_pkt(struct rxd_ep *ep, struct rxd_pkt_entry *pkt_entry) in rxd_remove_rx_pkt()
208 struct rxd_pkt_entry *pkt_entry; in rxd_verify_active() local
339 struct rxd_pkt_entry *pkt_entry; in rxd_send_cts() local
389 struct rxd_pkt_entry *pkt_entry, in rxd_init_unexp()
483 struct rxd_pkt_entry *pkt_entry, in rxd_match_rx()
743 struct rxd_pkt_entry *pkt_entry, in rxd_unpack_init_rx()
826 struct rxd_pkt_entry *pkt_entry, in rxd_progress_op()
888 struct rxd_pkt_entry *pkt_entry; in rxd_progress_buf_pkts() local
1068 struct rxd_pkt_entry *pkt_entry; in rxd_handle_ack() local
1109 struct rxd_pkt_entry *pkt_entry = in rxd_handle_send_comp() local
[all …]
|
| H A D | rxd.h | 308 struct rxd_pkt_entry *pkt_entry; member
318 static inline int rxd_pkt_type(struct rxd_pkt_entry *pkt_entry) in rxd_pkt_type()
323 static inline struct rxd_base_hdr *rxd_get_base_hdr(struct rxd_pkt_entry *pkt_entry) in rxd_get_base_hdr()
329 struct rxd_pkt_entry *pkt_entry) in rxd_set_pkt_seq()
336 static inline struct rxd_ext_hdr *rxd_get_ext_hdr(struct rxd_pkt_entry *pkt_entry) in rxd_get_ext_hdr()
341 static inline struct rxd_sar_hdr *rxd_get_sar_hdr(struct rxd_pkt_entry *pkt_entry) in rxd_get_sar_hdr()
347 static inline void rxd_set_tx_pkt(struct rxd_ep *ep, struct rxd_pkt_entry *pkt_entry) in rxd_set_tx_pkt()
353 static inline void rxd_set_rx_pkt(struct rxd_ep *ep, struct rxd_pkt_entry *pkt_entry) in rxd_set_rx_pkt()
359 static inline void *rxd_pkt_start(struct rxd_pkt_entry *pkt_entry) in rxd_pkt_start()
370 static inline void rxd_remove_free_pkt_entry(struct rxd_pkt_entry *pkt_entry) in rxd_remove_free_pkt_entry()
|
| H A D | rxd_msg.c | 78 struct rxd_pkt_entry *pkt_entry; in rxd_progress_unexp_msg() local
|
| /dports/net/mlvpn/MLVPN-2.3.1/src/ |
| H A D | buffer.h | 26 struct pkt_entry { struct
28 TAILQ_ENTRY(pkt_entry) entries; argument
|