| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/test/ |
| H A D | HTTPSessionAcceptorTest.cpp | 113 acceptor_->expectedProto_ = "http/1.1"; in TEST_P()
115 acceptor_->expectedProto_ = "http/2"; in TEST_P()
117 acceptor_->expectedProto_ = proto; in TEST_P()
124 acceptor_->connectionReady( in TEST_P()
126 EXPECT_EQ(acceptor_->sessionsCreated_, 1); in TEST_P()
141 acceptor_->expectedProto_ = "http/2"; in TEST_P()
143 acceptor_->expectedProto_ = proto; in TEST_P()
148 acceptor_->connectionReady( in TEST_P()
166 acceptor_->connectionReady( in TEST_F()
175 acceptor_->expectedProto_ = "http/1.1"; in TEST_F()
[all …]
|
| /dports/net/kea/kea-2.0.1/src/lib/asiolink/ |
| H A D | io_acceptor.h | 42 acceptor_(new typename ProtocolType::acceptor(io_service.get_io_service())) { in IOAcceptor()
51 return (acceptor_->native()); in getNative()
53 return (acceptor_->native_handle()); in getNative()
65 acceptor_->open(endpoint.getASIOEndpoint().protocol()); in open()
76 acceptor_->bind(endpoint.getASIOEndpoint()); in bind()
87 acceptor_->set_option(socket_option); in setOption()
92 acceptor_->listen(); in listen()
99 return (acceptor_->is_open()); in isOpen()
104 acceptor_->close(); in close()
123 acceptor_->async_accept(socket.getASIOSocket(), callback); in asyncAcceptInternal()
[all …]
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_io/src/io/network/ |
| H A D | doorman_impl.cpp | 16 : doorman(network::accept_hdl_from_socket(sockfd)), acceptor_(mx, sockfd) { in doorman_impl()
28 auto& dm = acceptor_.backend(); in new_connection()
29 auto sptr = dm.new_scribe(acceptor_.accepted_socket()); in new_connection()
37 acceptor_.graceful_shutdown(); in graceful_shutdown()
38 detach(&acceptor_.backend(), false); in graceful_shutdown()
43 acceptor_.start(this); in launch()
47 auto x = local_addr_of_fd(acceptor_.fd()); in addr()
54 auto x = local_port_of_fd(acceptor_.fd()); in port()
61 acceptor_.activate(this); in add_to_loop()
65 acceptor_.passivate(); in remove_from_loop()
|
| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/ |
| H A D | SimpleController.cpp | 18 : acceptor_(acceptor) { in SimpleController()
23 CHECK(acceptor_) << "Requires an acceptor, or override this method"; in getRequestHandler()
24 return acceptor_->newHandler(txn, msg); in getRequestHandler()
36 auto errorPage = acceptor_ ? acceptor_->getErrorPage(localAddress) : nullptr; in getParseErrorHandler()
46 auto errorPage = acceptor_ ? acceptor_->getErrorPage(localAddress) : nullptr; in getTransactionTimeoutHandler()
65 return acceptor_ ? acceptor_->getGracefulShutdownTimeout() in getGracefulShutdownTimeout()
|
| /dports/net/kea/kea-2.0.1/src/lib/asiolink/tests/ |
| H A D | tls_acceptor_unittest.cc | 184 TestTLSAcceptor& acceptor_; member in __anonea67af9a0111::Acceptor
209 : io_service_(), acceptor_(io_service_), in TLSAcceptorTest()
250 acceptor_.open(endpoint_); in acceptorOpen()
317 TestTLSAcceptor acceptor_; member in __anonea67af9a0111::TLSAcceptorTest
351 acceptor_.bind(endpoint_); in TEST_F()
352 acceptor_.listen(); in TEST_F()
411 ASSERT_LT(acceptor_.getNative(), 0); in TEST_F()
414 EXPECT_GE(acceptor_.getNative(), 0); in TEST_F()
425 acceptor_.bind(endpoint_); in TEST_F()
426 acceptor_.listen(); in TEST_F()
[all …]
|
| H A D | tcp_acceptor_unittest.cc | 179 TestTCPAcceptor& acceptor_; member in __anon88803aee0111::Acceptor
204 : io_service_(), acceptor_(io_service_), in TCPAcceptorTest()
245 acceptor_.open(endpoint_); in acceptorOpen()
311 TestTCPAcceptor acceptor_; member in __anon88803aee0111::TCPAcceptorTest
345 acceptor_.bind(endpoint_); in TEST_F()
346 acceptor_.listen(); in TEST_F()
405 ASSERT_LT(acceptor_.getNative(), 0); in TEST_F()
408 EXPECT_GE(acceptor_.getNative(), 0); in TEST_F()
419 acceptor_.bind(endpoint_); in TEST_F()
420 acceptor_.listen(); in TEST_F()
[all …]
|
| /dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/net/asio/asio-1.16.0/src/examples/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/devel/boost-docs/boost_1_72_0/doc/html/boost_asio/example/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/devel/boost-docs/boost_1_72_0/libs/asio/example/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/devel/boost-python-libs/boost_1_72_0/libs/asio/example/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/devel/boost-libs/boost_1_72_0/doc/html/boost_asio/example/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/devel/boost-libs/boost_1_72_0/libs/asio/example/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/net/kea/kea-2.0.1/src/lib/http/ |
| H A D | listener_impl.cc | 26 : io_service_(io_service), tls_context_(tls_context), acceptor_(), in HttpListenerImpl()
32 acceptor_.reset(new HttpAcceptor(io_service)); in HttpListenerImpl()
34 acceptor_.reset(new HttpsAcceptor(io_service)); in HttpListenerImpl()
73 acceptor_->open(*endpoint_); in start()
74 acceptor_->setOption(HttpAcceptor::ReuseAddress(true)); in start()
75 acceptor_->bind(*endpoint_); in start()
76 acceptor_->listen(); in start()
90 acceptor_->close(); in stop()
118 conn(new HttpConnection(io_service_, acceptor_, tls_context_, in createConnection()
|
| /dports/devel/boost-python-libs/boost_1_72_0/doc/html/boost_asio/example/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/devel/hyperscan/boost_1_75_0/doc/html/boost_asio/example/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/devel/hyperscan/boost_1_75_0/libs/asio/example/cpp17/coroutines_ts/ |
| H A D | range_based_for.cpp | 28 tcp::acceptor* acceptor_ = nullptr; member in connection_iter
32 : acceptor_(&a), socket_(std::move(s)) {} in connection_iter()
42 socket_ = co_await acceptor_->async_accept(use_awaitable); in operator ++()
58 tcp::acceptor& acceptor_; member in connections
61 explicit connections(tcp::acceptor& a) : acceptor_(a) {} in connections()
65 tcp::socket s = co_await acceptor_.async_accept(use_awaitable); in begin()
66 co_return connection_iter(acceptor_, std::move(s)); in begin()
71 return connection_iter(acceptor_, in end()
72 tcp::socket(acceptor_.get_executor())); in end()
|
| /dports/devel/boost-docs/boost_1_72_0/libs/asio/example/cpp11/http/server/ |
| H A D | server.cpp | 22 acceptor_(io_context_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept( in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|
| /dports/devel/boost-python-libs/boost_1_72_0/libs/asio/example/cpp11/http/server/ |
| H A D | server.cpp | 22 acceptor_(io_context_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept( in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/doc/html/boost_asio/example/cpp11/http/server/ |
| H A D | server.cpp | 22 acceptor_(io_service_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept(socket_, in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/libs/asio/example/cpp11/http/server/ |
| H A D | server.cpp | 22 acceptor_(io_service_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept(socket_, in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|
| /dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp11/http/server/ |
| H A D | server.cpp | 22 acceptor_(io_context_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept( in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|
| /dports/databases/percona57-server/boost_1_59_0/doc/html/boost_asio/example/cpp11/http/server/ |
| H A D | server.cpp | 22 acceptor_(io_service_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept(socket_, in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|
| /dports/databases/percona57-server/boost_1_59_0/libs/asio/example/cpp11/http/server/ |
| H A D | server.cpp | 22 acceptor_(io_service_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept(socket_, in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|
| /dports/databases/xtrabackup/boost_1_59_0/doc/html/boost_asio/example/cpp11/http/server/ |
| H A D | server.cpp | 22 acceptor_(io_service_), in server()
41 acceptor_.open(endpoint.protocol()); in server()
42 acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); in server()
43 acceptor_.bind(endpoint); in server()
44 acceptor_.listen(); in server()
60 acceptor_.async_accept(socket_, in do_accept()
65 if (!acceptor_.is_open()) in do_accept()
88 acceptor_.close(); in do_await_stop()
|