/dports/net/openmpi3/openmpi-3.1.6/opal/mca/btl/openib/ |
H A D | btl_openib_xrc.c | 123 ib_addr->key = NULL; 124 ib_addr->subnet_id = 0; 125 ib_addr->lid = 0; 127 ib_addr->qp = NULL; 128 ib_addr->max_wqe = 0; 139 free(ib_addr->key); 160 ib_addr->lid = lid; 185 ib_addr->key, 189 ib_addr->key, SIZE_OF3(s_id, lid, ep_jobid), (void*)ib_addr); 198 ep->ib_addr = ib_addr; [all …]
|
H A D | btl_openib_endpoint.c | 189 opal_mutex_lock (&ep->ib_addr->addr_lock); in endpoint_init_qp_xrc() 191 ep_qp->qp = ep->ib_addr->qp; in endpoint_init_qp_xrc() 192 if (ep->ib_addr->max_wqe + incr > max) { in endpoint_init_qp_xrc() 194 incr = max - ep->ib_addr->max_wqe; in endpoint_init_qp_xrc() 197 wqe = ep->ib_addr->max_wqe + incr + in endpoint_init_qp_xrc() 201 ep->ib_addr->max_wqe += incr; in endpoint_init_qp_xrc() 218 ep_qp->qp->sd_wqe = ep->ib_addr->max_wqe; in endpoint_init_qp_xrc() 221 opal_mutex_unlock (&ep->ib_addr->addr_lock); in endpoint_init_qp_xrc() 245 if (NULL == ep->ib_addr->qp) { in endpoint_init_qp() 246 ep->ib_addr->qp = endpoint_alloc_qp(); in endpoint_init_qp() [all …]
|
/dports/net/openmpi/openmpi-4.1.1/opal/mca/btl/openib/ |
H A D | btl_openib_xrc.c | 123 ib_addr->key = NULL; 124 ib_addr->subnet_id = 0; 125 ib_addr->lid = 0; 127 ib_addr->qp = NULL; 128 ib_addr->max_wqe = 0; 139 free(ib_addr->key); 160 ib_addr->lid = lid; 185 ib_addr->key, 189 ib_addr->key, SIZE_OF3(s_id, lid, ep_jobid), (void*)ib_addr); 198 ep->ib_addr = ib_addr; [all …]
|
H A D | btl_openib_endpoint.c | 189 opal_mutex_lock (&ep->ib_addr->addr_lock); in endpoint_init_qp_xrc() 191 ep_qp->qp = ep->ib_addr->qp; in endpoint_init_qp_xrc() 192 if (ep->ib_addr->max_wqe + incr > max) { in endpoint_init_qp_xrc() 194 incr = max - ep->ib_addr->max_wqe; in endpoint_init_qp_xrc() 197 wqe = ep->ib_addr->max_wqe + incr + in endpoint_init_qp_xrc() 201 ep->ib_addr->max_wqe += incr; in endpoint_init_qp_xrc() 218 ep_qp->qp->sd_wqe = ep->ib_addr->max_wqe; in endpoint_init_qp_xrc() 221 opal_mutex_unlock (&ep->ib_addr->addr_lock); in endpoint_init_qp_xrc() 245 if (NULL == ep->ib_addr->qp) { in endpoint_init_qp() 246 ep->ib_addr->qp = endpoint_alloc_qp(); in endpoint_init_qp() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/include/rdma/ |
H A D | ib.h | 15 struct ib_addr { struct 31 static inline bool ib_addr_any(const struct ib_addr *a) in ib_addr_any() argument 36 static inline bool ib_addr_loopback(const struct ib_addr *a) in ib_addr_loopback() 42 static inline void ib_addr_set(struct ib_addr *addr, in ib_addr_set() 51 static inline int ib_addr_cmp(const struct ib_addr *a1, const struct ib_addr *a2) in ib_addr_cmp() 53 return memcmp(a1, a2, sizeof(struct ib_addr)); in ib_addr_cmp() 60 struct ib_addr sib_addr;
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/include/rdma/ |
H A D | ib.h | 15 struct ib_addr { struct 31 static inline bool ib_addr_any(const struct ib_addr *a) in ib_addr_any() argument 36 static inline bool ib_addr_loopback(const struct ib_addr *a) in ib_addr_loopback() 42 static inline void ib_addr_set(struct ib_addr *addr, in ib_addr_set() 51 static inline int ib_addr_cmp(const struct ib_addr *a1, const struct ib_addr *a2) in ib_addr_cmp() 53 return memcmp(a1, a2, sizeof(struct ib_addr)); in ib_addr_cmp() 60 struct ib_addr sib_addr;
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/include/rdma/ |
H A D | ib.h | 15 struct ib_addr { struct 31 static inline bool ib_addr_any(const struct ib_addr *a) in ib_addr_any() argument 36 static inline bool ib_addr_loopback(const struct ib_addr *a) in ib_addr_loopback() 42 static inline void ib_addr_set(struct ib_addr *addr, in ib_addr_set() 51 static inline int ib_addr_cmp(const struct ib_addr *a1, const struct ib_addr *a2) in ib_addr_cmp() 53 return memcmp(a1, a2, sizeof(struct ib_addr)); in ib_addr_cmp() 60 struct ib_addr sib_addr;
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/base/ |
H A D | ib_iface.c | 322 uct_ib_address_t *ib_addr) in uct_ib_address_pack() argument 324 void *ptr = ib_addr + 1; in uct_ib_address_pack() 342 ib_addr->flags = 0; in uct_ib_address_pack() 371 ib_addr->flags |= UCT_IB_ADDRESS_FLAG_PATH_MTU; in uct_ib_address_pack() 383 ib_addr->flags |= UCT_IB_ADDRESS_FLAG_PKEY; in uct_ib_address_pack() 433 uct_ib_address_pack(¶ms, ib_addr); in uct_ib_iface_address_pack() 439 const void *ptr = ib_addr + 1; in uct_ib_address_unpack() 500 if (ib_addr->flags & UCT_IB_ADDRESS_FLAG_PKEY) { in uct_ib_address_unpack() 515 uct_ib_address_unpack(ib_addr, ¶ms); in uct_ib_address_str() 611 uct_ib_address_unpack(ib_addr, ¶ms); in uct_ib_iface_is_reachable() [all …]
|
H A D | ib_iface.h | 408 uct_ib_address_t *ib_addr); 420 void uct_ib_iface_address_pack(uct_ib_iface_t *iface, uct_ib_address_t *ib_addr); 430 void uct_ib_address_unpack(const uct_ib_address_t *ib_addr, 437 const char *uct_ib_address_str(const uct_ib_address_t *ib_addr, char *buf, 512 const uct_ib_address_t *ib_addr,
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/test/gtest/uct/ib/ |
H A D | test_ud_ds.cc | 54 …void test_cep_insert(entity *e, uct_ib_address_t *ib_addr, uct_ud_iface_addr_t *if_addr, unsigned … 94 void test_ud_ds::test_cep_insert(entity *e, uct_ib_address_t *ib_addr, in test_cep_insert() argument 104 EXPECT_UCS_OK(uct_ud_iface_cep_insert(iface(e), ib_addr, if_addr, in test_cep_insert() 110 my_ep = uct_ud_iface_cep_lookup(iface(e), ib_addr, if_addr, 3333, 0); in test_cep_insert() 113 my_ep = uct_ud_iface_cep_lookup(iface(e), ib_addr, if_addr, i, 0); in test_cep_insert()
|
H A D | test_ib_pkey.cc | 120 uct_ib_address_t *ib_addr) { in test_pack_unpack_ib_address() argument 123 uct_ib_iface_address_pack(iface, ib_addr); in test_pack_unpack_ib_address() 124 uct_ib_address_unpack(ib_addr, ¶ms); in test_pack_unpack_ib_address()
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/ud/accel/ |
H A D | ud_mlx5_common.c | 37 const uct_ib_address_t *ib_addr, in uct_ud_mlx5_iface_get_av() argument 49 uct_ib_iface_fill_ah_attr_from_addr(iface, ib_addr, path_index, &ah_attr, in uct_ud_mlx5_iface_get_av()
|
H A D | ud_mlx5.c | 568 const uct_ib_address_t *ib_addr, unsigned path_index, in uct_ud_mlx5_ep_create_ah() argument 576 ib_addr, path_index, &ep->av, &ep->grh_av, in uct_ud_mlx5_ep_create_ah() 598 const uct_ib_address_t *ib_addr = (const uct_ib_address_t *)dev_addr; in uct_ud_mlx5_ep_create_connected() local 603 status = uct_ud_ep_create_connected_common(&iface->super, ib_addr, if_addr, in uct_ud_mlx5_ep_create_connected() 620 status_ah = uct_ud_mlx5_ep_create_ah(iface, ep, ib_addr, in uct_ud_mlx5_ep_create_connected() 623 uct_ud_ep_destroy_connected(&ep->super, ib_addr, if_addr); in uct_ud_mlx5_ep_create_connected() 664 const uct_ib_address_t *ib_addr = (const uct_ib_address_t *)dev_addr; in uct_ud_mlx5_ep_connect_to_ep() local 667 status = uct_ud_ep_connect_to_ep(&ep->super, ib_addr, ep_addr); in uct_ud_mlx5_ep_connect_to_ep() 672 status = uct_ud_mlx5_ep_create_ah(iface, ep, ib_addr, ep->super.path_index, in uct_ud_mlx5_ep_connect_to_ep()
|
/dports/net/openmpi/openmpi-4.1.1/opal/mca/btl/openib/connect/ |
H A D | btl_openib_connect_udcm.c | 574 lcl_ep->ib_addr->remote_xrc_rcv_qp_num = recv_qpn; in udcm_endpoint_init_self_xrc() 2382 opal_mutex_lock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_start_connect() 2387 opal_mutex_unlock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_start_connect() 2395 lcl_ep->ib_addr->status, lcl_ep->ib_addr->lid)); in udcm_xrc_start_connect() 2397 switch (lcl_ep->ib_addr->status) { in udcm_xrc_start_connect() 2425 opal_mutex_unlock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_start_connect() 2437 opal_mutex_lock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_restart_connect() 2441 lcl_ep->ib_addr->lid, lcl_ep->ib_addr->status)); in udcm_xrc_restart_connect() 2447 lcl_ep->ib_addr->status = MCA_BTL_IB_ADDR_CLOSED; in udcm_xrc_restart_connect() 2457 opal_mutex_unlock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_restart_connect() [all …]
|
/dports/net/openmpi3/openmpi-3.1.6/opal/mca/btl/openib/connect/ |
H A D | btl_openib_connect_udcm.c | 573 lcl_ep->ib_addr->remote_xrc_rcv_qp_num = recv_qpn; in udcm_endpoint_init_self_xrc() 2374 opal_mutex_lock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_start_connect() 2379 opal_mutex_unlock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_start_connect() 2387 lcl_ep->ib_addr->status, lcl_ep->ib_addr->lid)); in udcm_xrc_start_connect() 2389 switch (lcl_ep->ib_addr->status) { in udcm_xrc_start_connect() 2417 opal_mutex_unlock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_start_connect() 2429 opal_mutex_lock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_restart_connect() 2433 lcl_ep->ib_addr->lid, lcl_ep->ib_addr->status)); in udcm_xrc_restart_connect() 2439 lcl_ep->ib_addr->status = MCA_BTL_IB_ADDR_CLOSED; in udcm_xrc_restart_connect() 2449 opal_mutex_unlock (&lcl_ep->ib_addr->addr_lock); in udcm_xrc_restart_connect() [all …]
|
/dports/databases/proftpd-mod_sql_postgres/proftpd-1.3.7c/src/ |
H A D | bindings.c | 305 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_close() 450 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_create() 488 ipbind->ib_addr = addr; in pr_ipbind_create() 496 ipbind, pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_create() 572 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0) { in pr_ipbind_find() 770 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_listen() 1322 res = pr_namebind_open(c->argv[0], ipbind->ib_addr, ipbind->ib_port); in process_serveralias() 1333 (char *) c->argv[0], pr_netaddr_get_ipstr(ipbind->ib_addr), in process_serveralias() 1372 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port); in trace_ipbind_table()
|
/dports/databases/proftpd-mod_sql_odbc/proftpd-1.3.7c/src/ |
H A D | bindings.c | 305 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_close() 450 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_create() 488 ipbind->ib_addr = addr; in pr_ipbind_create() 496 ipbind, pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_create() 572 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0) { in pr_ipbind_find() 770 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_listen() 1322 res = pr_namebind_open(c->argv[0], ipbind->ib_addr, ipbind->ib_port); in process_serveralias() 1333 (char *) c->argv[0], pr_netaddr_get_ipstr(ipbind->ib_addr), in process_serveralias() 1372 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port); in trace_ipbind_table()
|
/dports/databases/proftpd-mod_sql_tds/proftpd-1.3.7c/src/ |
H A D | bindings.c | 305 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_close() 450 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_create() 488 ipbind->ib_addr = addr; in pr_ipbind_create() 496 ipbind, pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_create() 572 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0) { in pr_ipbind_find() 770 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_listen() 1322 res = pr_namebind_open(c->argv[0], ipbind->ib_addr, ipbind->ib_port); in process_serveralias() 1333 (char *) c->argv[0], pr_netaddr_get_ipstr(ipbind->ib_addr), in process_serveralias() 1372 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port); in trace_ipbind_table()
|
/dports/databases/proftpd-mod_sql_sqlite/proftpd-1.3.7c/src/ |
H A D | bindings.c | 305 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_close() 450 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_create() 488 ipbind->ib_addr = addr; in pr_ipbind_create() 496 ipbind, pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_create() 572 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0) { in pr_ipbind_find() 770 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_listen() 1322 res = pr_namebind_open(c->argv[0], ipbind->ib_addr, ipbind->ib_port); in process_serveralias() 1333 (char *) c->argv[0], pr_netaddr_get_ipstr(ipbind->ib_addr), in process_serveralias() 1372 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port); in trace_ipbind_table()
|
/dports/databases/proftpd-mod_sql_mysql/proftpd-1.3.7c/src/ |
H A D | bindings.c | 305 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_close() 450 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_create() 488 ipbind->ib_addr = addr; in pr_ipbind_create() 496 ipbind, pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_create() 572 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0) { in pr_ipbind_find() 770 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_listen() 1322 res = pr_namebind_open(c->argv[0], ipbind->ib_addr, ipbind->ib_port); in process_serveralias() 1333 (char *) c->argv[0], pr_netaddr_get_ipstr(ipbind->ib_addr), in process_serveralias() 1372 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port); in trace_ipbind_table()
|
/dports/net/proftpd-mod_ldap/proftpd-1.3.7c/src/ |
H A D | bindings.c | 305 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_close() 450 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_create() 488 ipbind->ib_addr = addr; in pr_ipbind_create() 496 ipbind, pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_create() 572 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0) { in pr_ipbind_find() 770 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_listen() 1322 res = pr_namebind_open(c->argv[0], ipbind->ib_addr, ipbind->ib_port); in process_serveralias() 1333 (char *) c->argv[0], pr_netaddr_get_ipstr(ipbind->ib_addr), in process_serveralias() 1372 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port); in trace_ipbind_table()
|
/dports/security/proftpd-mod_clamav/proftpd-1.3.7c/src/ |
H A D | bindings.c | 305 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_close() 450 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_create() 488 ipbind->ib_addr = addr; in pr_ipbind_create() 496 ipbind, pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_create() 572 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0) { in pr_ipbind_find() 770 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_listen() 1322 res = pr_namebind_open(c->argv[0], ipbind->ib_addr, ipbind->ib_port); in process_serveralias() 1333 (char *) c->argv[0], pr_netaddr_get_ipstr(ipbind->ib_addr), in process_serveralias() 1372 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port); in trace_ipbind_table()
|
/dports/ftp/proftpd/proftpd-1.3.7c/src/ |
H A D | bindings.c | 305 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_close() 450 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_create() 488 ipbind->ib_addr = addr; in pr_ipbind_create() 496 ipbind, pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_create() 572 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0) { in pr_ipbind_find() 770 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_listen() 1322 res = pr_namebind_open(c->argv[0], ipbind->ib_addr, ipbind->ib_port); in process_serveralias() 1333 (char *) c->argv[0], pr_netaddr_get_ipstr(ipbind->ib_addr), in process_serveralias() 1372 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port); in trace_ipbind_table()
|
/dports/ftp/proftpd-mod_vroot/proftpd-1.3.7c/src/ |
H A D | bindings.c | 305 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_close() 450 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0 && in pr_ipbind_create() 488 ipbind->ib_addr = addr; in pr_ipbind_create() 496 ipbind, pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_create() 572 if (pr_netaddr_cmp(ipbind->ib_addr, addr) == 0) { in pr_ipbind_find() 770 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port, in pr_ipbind_listen() 1322 res = pr_namebind_open(c->argv[0], ipbind->ib_addr, ipbind->ib_port); in process_serveralias() 1333 (char *) c->argv[0], pr_netaddr_get_ipstr(ipbind->ib_addr), in process_serveralias() 1372 pr_netaddr_get_ipstr(ipbind->ib_addr), ipbind->ib_port); in trace_ipbind_table()
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/ud/verbs/ |
H A D | ud_verbs.c | 469 const uct_ib_address_t *ib_addr = (const uct_ib_address_t *)dev_addr; in uct_ud_verbs_ep_create_connected() local 477 status = uct_ud_ep_create_connected_common(&iface->super, ib_addr, if_addr, in uct_ud_verbs_ep_create_connected() 496 uct_ib_iface_fill_ah_attr_from_addr(ib_iface, ib_addr, ep->super.path_index, in uct_ud_verbs_ep_create_connected() 500 uct_ud_ep_destroy_connected(&ep->super, ib_addr, if_addr); in uct_ud_verbs_ep_create_connected() 526 const uct_ib_address_t *ib_addr = (const uct_ib_address_t *)dev_addr; in uct_ud_verbs_ep_connect_to_ep() local 532 status = uct_ud_ep_connect_to_ep(&ep->super, ib_addr, ud_ep_addr); in uct_ud_verbs_ep_connect_to_ep() 539 uct_ib_iface_fill_ah_attr_from_addr(iface, ib_addr, ep->super.path_index, in uct_ud_verbs_ep_connect_to_ep()
|