Home
last modified time | relevance | path

Searched refs:router_port (Results 1 – 25 of 60) sorted by relevance

123

/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/tests/component/
H A Dtest_routing_strategy.cc121 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 Dtest_routing.cc71 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 Dtest_metadata_ttl.cc81 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 Dtest_state_file.cc113 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 Dtest_metadata_http_auth_backend.cc86 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 Dtest_master_key_reader_writer.cc102 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 Dtest_gr_notifications.cc101 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 Dtest_logging.cc372 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 Dtest_shutdown.cc200 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 Dtest_config.cc52 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 Dnxt_external.c70 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 Dnxt_application.c1016 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 Dnxt_external.c70 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 Dnxt_application.c1016 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 Dnxt_external.c70 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 Dnxt_application.c1016 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 Dnxt_external.c70 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 Dnxt_application.c1016 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 Dnxt_external.c70 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 Dnxt_application.c1016 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 Dnxt_external.c70 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 Dnxt_application.c1016 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 DTUNNEL.java61 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 DRouterStub.java31 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 Dtest_routing.cc370 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()

123