/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/tests/component/ |
H A D | test_routing_strategy.cc | 121 unsigned router_port, const std::string &role, in get_metadata_cache_routing_section() argument 126 std::to_string(router_port) + "\n" + in get_metadata_cache_routing_section() 168 void connect_client_and_query_port(unsigned router_port, in connect_client_and_query_port() argument 529 connect_client_and_query_port(router_port, node_port); in TEST_P() 531 connect_client_and_query_port(router_port, node_port); in TEST_P() 533 connect_client_and_query_port(router_port, node_port); in TEST_P() 535 connect_client_and_query_port(router_port, node_port); in TEST_P() 591 connect_client_and_query_port(router_port, node_port); in TEST_P() 593 connect_client_and_query_port(router_port, node_port); in TEST_P() 723 router_port, {1, 2}, "invalid", "read-only"); in TEST_F() [all …]
|
H A D | test_routing.cc | 71 const auto router_port = port_pool_.get_next_available(); in TEST_F() local 86 std::to_string(router_port) + in TEST_F() 123 const auto router_port = port_pool_.get_next_available(); in TEST_F() local 136 std::to_string(router_port) + in TEST_F() 217 std::to_string(router_port) + in TEST_F() 272 [&client1, router_port]() { in TEST_F() 362 std::to_string(router_port) + in TEST_F() 484 std::to_string(router_port) + in TEST_F() 508 make_bad_connection(router_port); in TEST_F() 509 make_bad_connection(router_port); in TEST_F() [all …]
|
H A D | test_metadata_ttl.cc | 81 uint16_t router_port, const std::string &role, in get_metadata_cache_routing_section() argument 88 std::to_string(router_port) + "\n" + in get_metadata_cache_routing_section() 243 router_port, "PRIMARY", "first-available"); in TEST_P() 349 router_port, "PRIMARY", "first-available"); in TEST_P() 433 router_port, "PRIMARY", "first-available"); in TEST_P() 507 router_port, "PRIMARY", "first-available"); in TEST_P() 559 router_port, "PRIMARY", "first-available"); in TEST_F() 631 router_port, "PRIMARY", "first-available"); in TEST_P() 730 router_port, "PRIMARY", "first-available"); in TEST_P() 809 router_port, "PRIMARY", "first-available"); in TEST_P() [all …]
|
H A D | test_state_file.cc | 113 std::to_string(router_port) + "\n" + in get_metadata_cache_routing_section() 354 const uint16_t router_port = port_pool_.get_next_available(); in TEST_P() local 356 router_port, "PRIMARY", "first-available"); in TEST_P() 489 const uint16_t router_port = port_pool_.get_next_available(); in TEST_P() local 491 router_port, "PRIMARY", "first-available"); in TEST_P() 577 router_port, "PRIMARY", "first-available"); in TEST_P() 690 router_port, "PRIMARY", "first-available"); in TEST_P() 752 router_port, "PRIMARY", "first-available"); in TEST_F() 758 wait_for_port_ready(router_port); in TEST_F() 824 router_port, "PRIMARY", "first-available"); in TEST_P() [all …]
|
H A D | test_metadata_http_auth_backend.cc | 86 const uint16_t router_port) const { in get_metadata_cache_routing_section() 88 std::to_string(router_port) + in get_metadata_cache_routing_section() 149 get_metadata_cache_routing_section(router_port); in launch_router() 270 router_port = port_pool_.get_next_available(); in SetUp() 273 std::to_string(router_port) + "/status"; in SetUp() 295 uint16_t router_port; member in MetadataHttpAuthTest 352 wait_for_port_ready(router_port); in TEST_F() 373 wait_for_port_ready(router_port); in TEST_F() 397 wait_for_port_ready(router_port); in TEST_P() 502 ASSERT_NO_FATAL_FAILURE(wait_for_port_ready(router_port)); in TEST_F() [all …]
|
H A D | test_master_key_reader_writer.cc | 102 unsigned router_port) { in get_metadata_cache_routing_section() argument 105 std::to_string(router_port) + "\n" + in get_metadata_cache_routing_section() 549 auto router_port = port_pool_.get_next_available(); in TEST_F() local 552 get_metadata_cache_routing_section("PRIMARY", "round-robin", router_port); in TEST_F() 574 ASSERT_NO_FATAL_FAILURE(check_port_ready(router, router_port, 10000ms)); in TEST_F() 594 unsigned router_port = port_pool_.get_next_available(); in TEST_F() local 597 get_metadata_cache_routing_section("PRIMARY", "round-robin", router_port); in TEST_F() 617 ASSERT_NO_FATAL_FAILURE(check_port_ready(router, router_port, 10000ms)); in TEST_F() 635 auto router_port = port_pool_.get_next_available(); in TEST_F() local 638 get_metadata_cache_routing_section("PRIMARY", "round-robin", router_port); in TEST_F() [all …]
|
H A D | test_gr_notifications.cc | 101 uint16_t router_port, const std::string &role, in get_metadata_cache_routing_section() argument 107 std::to_string(router_port) + "\n" + in get_metadata_cache_routing_section() 383 const uint16_t router_port = port_pool_.get_next_available(); in TEST_P() local 385 router_port, "PRIMARY", "first-available"); in TEST_P() 650 const uint16_t router_port = port_pool_.get_next_available(); in TEST_P() local 652 router_port, "PRIMARY", "first-available"); in TEST_P() 735 const uint16_t router_port = port_pool_.get_next_available(); in TEST_P() local 737 router_port, "PRIMARY", "first-available"); in TEST_P() 803 router_port, "PRIMARY", "first-available"); in TEST_P() 885 router_port, "PRIMARY", "first-available"); in TEST_P() [all …]
|
H A D | test_logging.cc | 372 const auto router_port = port_pool.get_next_available(); in TEST_P() local 389 std::to_string(router_port) + in TEST_P() 409 ASSERT_NO_FATAL_FAILURE(check_port_ready(router, router_port)); in TEST_P() 1187 const auto router_port = port_pool.get_next_available(); in TEST_P() local 1197 std::to_string(router_port) + in TEST_P() 1217 ASSERT_NO_FATAL_FAILURE(check_port_ready(router, router_port)); in TEST_P() 1939 router_port = port_pool_.get_next_available(); in SetUp() 1969 std::to_string(router_port) + "\n" + in get_metadata_cache_routing_section() 1995 uint16_t router_port; member in MetadataCacheLoggingTest 2011 ASSERT_NO_FATAL_FAILURE(check_port_ready(router, router_port, 10000ms)); in TEST_F() [all …]
|
H A D | test_shutdown.cc | 200 const uint16_t router_port = port_pool_.get_next_available(); in TEST_F() local 245 std::to_string(router_port) + in TEST_F() 254 ASSERT_NO_FATAL_FAILURE(check_port_ready(router, router_port)); in TEST_F()
|
H A D | test_config.cc | 52 const auto router_port = port_pool_.get_next_available(); in TEST_F() local 58 std::to_string(router_port) + in TEST_F()
|
/dports/devel/libunit/unit-1.26.1/src/ |
H A D | nxt_external.c | 70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start() local 80 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_external_start() 84 || router_port == NULL)) in nxt_external_start() 94 rc = nxt_external_fd_no_cloexec(task, router_port->pair[1]); in nxt_external_start() 119 router_port->pid, router_port->id, router_port->pair[1], in nxt_external_start()
|
H A D | nxt_application.c | 1016 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init() local 1028 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_unit_default_init() 1029 if (nxt_slow_path(router_port == NULL)) { in nxt_unit_default_init() 1045 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init() 1046 init->router_port.id.id = router_port->id; in nxt_unit_default_init() 1047 init->router_port.in_fd = -1; in nxt_unit_default_init() 1048 init->router_port.out_fd = router_port->pair[1]; in nxt_unit_default_init()
|
/dports/www/unit/unit-1.26.1/src/ |
H A D | nxt_external.c | 70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start() local 80 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_external_start() 84 || router_port == NULL)) in nxt_external_start() 94 rc = nxt_external_fd_no_cloexec(task, router_port->pair[1]); in nxt_external_start() 119 router_port->pid, router_port->id, router_port->pair[1], in nxt_external_start()
|
H A D | nxt_application.c | 1016 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init() local 1028 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_unit_default_init() 1029 if (nxt_slow_path(router_port == NULL)) { in nxt_unit_default_init() 1045 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init() 1046 init->router_port.id.id = router_port->id; in nxt_unit_default_init() 1047 init->router_port.in_fd = -1; in nxt_unit_default_init() 1048 init->router_port.out_fd = router_port->pair[1]; in nxt_unit_default_init()
|
/dports/www/unit-php/unit-1.26.1/src/ |
H A D | nxt_external.c | 70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start() local 80 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_external_start() 84 || router_port == NULL)) in nxt_external_start() 94 rc = nxt_external_fd_no_cloexec(task, router_port->pair[1]); in nxt_external_start() 119 router_port->pid, router_port->id, router_port->pair[1], in nxt_external_start()
|
H A D | nxt_application.c | 1016 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init() local 1028 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_unit_default_init() 1029 if (nxt_slow_path(router_port == NULL)) { in nxt_unit_default_init() 1045 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init() 1046 init->router_port.id.id = router_port->id; in nxt_unit_default_init() 1047 init->router_port.in_fd = -1; in nxt_unit_default_init() 1048 init->router_port.out_fd = router_port->pair[1]; in nxt_unit_default_init()
|
/dports/www/unit-python/unit-1.26.1/src/ |
H A D | nxt_external.c | 70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start() local 80 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_external_start() 84 || router_port == NULL)) in nxt_external_start() 94 rc = nxt_external_fd_no_cloexec(task, router_port->pair[1]); in nxt_external_start() 119 router_port->pid, router_port->id, router_port->pair[1], in nxt_external_start()
|
H A D | nxt_application.c | 1016 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init() local 1028 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_unit_default_init() 1029 if (nxt_slow_path(router_port == NULL)) { in nxt_unit_default_init() 1045 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init() 1046 init->router_port.id.id = router_port->id; in nxt_unit_default_init() 1047 init->router_port.in_fd = -1; in nxt_unit_default_init() 1048 init->router_port.out_fd = router_port->pair[1]; in nxt_unit_default_init()
|
/dports/www/unit-java/unit-1.26.1/src/ |
H A D | nxt_external.c | 70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start() local 80 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_external_start() 84 || router_port == NULL)) in nxt_external_start() 94 rc = nxt_external_fd_no_cloexec(task, router_port->pair[1]); in nxt_external_start() 119 router_port->pid, router_port->id, router_port->pair[1], in nxt_external_start()
|
H A D | nxt_application.c | 1016 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init() local 1028 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_unit_default_init() 1029 if (nxt_slow_path(router_port == NULL)) { in nxt_unit_default_init() 1045 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init() 1046 init->router_port.id.id = router_port->id; in nxt_unit_default_init() 1047 init->router_port.in_fd = -1; in nxt_unit_default_init() 1048 init->router_port.out_fd = router_port->pair[1]; in nxt_unit_default_init()
|
/dports/www/unit-perl/unit-1.26.1/src/ |
H A D | nxt_external.c | 70 nxt_port_t *my_port, *proto_port, *router_port; in nxt_external_start() local 80 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_external_start() 84 || router_port == NULL)) in nxt_external_start() 94 rc = nxt_external_fd_no_cloexec(task, router_port->pair[1]); in nxt_external_start() 119 router_port->pid, router_port->id, router_port->pair[1], in nxt_external_start()
|
H A D | nxt_application.c | 1016 nxt_port_t *my_port, *proto_port, *router_port; in nxt_unit_default_init() local 1028 router_port = rt->port_by_type[NXT_PROCESS_ROUTER]; in nxt_unit_default_init() 1029 if (nxt_slow_path(router_port == NULL)) { in nxt_unit_default_init() 1045 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init() 1046 init->router_port.id.id = router_port->id; in nxt_unit_default_init() 1047 init->router_port.in_fd = -1; in nxt_unit_default_init() 1048 init->router_port.out_fd = router_port->pair[1]; in nxt_unit_default_init()
|
/dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/protocols/ |
H A D | TUNNEL.java | 61 private int router_port = 0; field in TUNNEL 115 return router_port; in getRouterPort() 119 public void setRouterPort(int router_port) { in setRouterPort() argument 120 this.router_port = router_port; in setRouterPort() 156 if ((router_host == null || router_port == 0) && gossip_router_hosts.isEmpty()) { in init() 160 if (router_host != null && router_port != 0 && !gossip_router_hosts.isEmpty()) { in init() 164 if (router_host != null && router_port != 0 && gossip_router_hosts.isEmpty()) { in init() 165 gossip_router_hosts.add(new InetSocketAddress(router_host, router_port)); in init()
|
/dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/stack/ |
H A D | RouterStub.java | 31 private final int router_port; // port on which router listens on field in RouterStub 69 router_port=routerPort; in RouterStub() 159 … Util.connect(sock, new InetSocketAddress(router_host, router_port), sock_conn_timeout); in doConnect() 253 return new InetSocketAddress(router_host, router_port); in getGossipRouterAddress() 258 : "null")+ ",router_host=" + router_host + "::" + router_port in toString()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/routing/tests/ |
H A D | test_routing.cc | 370 const uint16_t router_port = port_pool_.get_next_available(); in TEST_F() local 380 routing::RoutingStrategy::kNextAvailable, router_port, in TEST_F() 406 sock1_res = connect_local(router_port); in TEST_F() 409 auto sock2_res = connect_local(router_port); in TEST_F() 434 auto sock11_res = connect_local(router_port); in TEST_F() 435 auto sock12_res = connect_local(router_port); in TEST_F()
|