| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/lib/gitlab/database/ |
| H A D | shared_model_spec.rb | 12 described_class.using_connection(new_connection) do
13 expect(described_class.connection).to be(new_connection)
20 described_class.using_connection(new_connection) do
21 expect(described_class.connection).to be(new_connection)
35 described_class.using_connection(new_connection) do
36 expect(described_class.connection).to be(new_connection)
38 described_class.using_connection(new_connection) do
42 expect(described_class.connection).to be(new_connection)
49 described_class.using_connection(new_connection) do
66 described_class.using_connection(new_connection) do
[all …]
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libnghttp2-sys-0.1.7+1.45.0/nghttp2/src/ |
| H A D | asio_server.cc | 137 new_connection->socket().lowest_layer(), in start_accept()
139 new_connection](const boost::system::error_code &e) { in start_accept()
141 new_connection->socket().lowest_layer().set_option( in start_accept()
143 new_connection->start_tls_handshake_deadline(); in start_accept()
144 new_connection->socket().async_handshake( in start_accept()
148 new_connection->stop(); in start_accept()
153 new_connection->stop(); in start_accept()
157 new_connection->start(); in start_accept()
176 new_connection->socket(), [this, &acceptor, &mux, new_connection]( in start_accept()
180 new_connection->start_read_deadline(); in start_accept()
[all …]
|
| /dports/net/proby/proby-1.0.2/cargo-crates/libnghttp2-sys-0.1.4+1.41.0/nghttp2/src/ |
| H A D | asio_server.cc | 137 new_connection->socket().lowest_layer(), in start_accept()
139 new_connection](const boost::system::error_code &e) { in start_accept()
141 new_connection->socket().lowest_layer().set_option( in start_accept()
143 new_connection->start_tls_handshake_deadline(); in start_accept()
144 new_connection->socket().async_handshake( in start_accept()
148 new_connection->stop(); in start_accept()
153 new_connection->stop(); in start_accept()
157 new_connection->start(); in start_accept()
176 new_connection->socket(), [this, &acceptor, &mux, new_connection]( in start_accept()
180 new_connection->start_read_deadline(); in start_accept()
[all …]
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/libnghttp2-sys-0.1.6+1.43.0/nghttp2/src/ |
| H A D | asio_server.cc | 137 new_connection->socket().lowest_layer(), in start_accept()
139 new_connection](const boost::system::error_code &e) { in start_accept()
141 new_connection->socket().lowest_layer().set_option( in start_accept()
143 new_connection->start_tls_handshake_deadline(); in start_accept()
144 new_connection->socket().async_handshake( in start_accept()
148 new_connection->stop(); in start_accept()
153 new_connection->stop(); in start_accept()
157 new_connection->start(); in start_accept()
176 new_connection->socket(), [this, &acceptor, &mux, new_connection]( in start_accept()
180 new_connection->start_read_deadline(); in start_accept()
[all …]
|
| /dports/www/libnghttp2/nghttp2-1.46.0/src/ |
| H A D | asio_server.cc | 137 new_connection->socket().lowest_layer(), in start_accept()
139 new_connection](const boost::system::error_code &e) { in start_accept()
141 new_connection->socket().lowest_layer().set_option( in start_accept()
143 new_connection->start_tls_handshake_deadline(); in start_accept()
144 new_connection->socket().async_handshake( in start_accept()
148 new_connection->stop(); in start_accept()
153 new_connection->stop(); in start_accept()
157 new_connection->start(); in start_accept()
176 new_connection->socket(), [this, &acceptor, &mux, new_connection]( in start_accept()
180 new_connection->start_read_deadline(); in start_accept()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/libnghttp2-sys/nghttp2/src/ |
| H A D | asio_server.cc | 137 new_connection->socket().lowest_layer(), in start_accept()
139 new_connection](const boost::system::error_code &e) { in start_accept()
141 new_connection->socket().lowest_layer().set_option( in start_accept()
143 new_connection->start_tls_handshake_deadline(); in start_accept()
144 new_connection->socket().async_handshake( in start_accept()
148 new_connection->stop(); in start_accept()
153 new_connection->stop(); in start_accept()
157 new_connection->start(); in start_accept()
176 new_connection->socket(), [this, &acceptor, &mux, new_connection]( in start_accept()
180 new_connection->start_read_deadline(); in start_accept()
[all …]
|
| /dports/www/nghttp2/nghttp2-1.46.0/src/ |
| H A D | asio_server.cc | 137 new_connection->socket().lowest_layer(), in start_accept()
139 new_connection](const boost::system::error_code &e) { in start_accept()
141 new_connection->socket().lowest_layer().set_option( in start_accept()
143 new_connection->start_tls_handshake_deadline(); in start_accept()
144 new_connection->socket().async_handshake( in start_accept()
148 new_connection->stop(); in start_accept()
153 new_connection->stop(); in start_accept()
157 new_connection->start(); in start_accept()
176 new_connection->socket(), [this, &acceptor, &mux, new_connection]( in start_accept()
180 new_connection->start_read_deadline(); in start_accept()
[all …]
|
| /dports/devel/cpp-netlib/cpp-netlib-cpp-netlib-0.13.0-final/boost/network/protocol/http/server/ |
| H A D | async_server.hpp | 54 new_connection(), in async_server_base()
131 connection_ptr new_connection; member
158 socket_options_base::socket_options(new_connection->socket().next_layer()); in handle_accept()
160 socket_options_base::socket_options(new_connection->socket()); in handle_accept()
163 new_connection->start(); in handle_accept()
164 new_connection.reset(new connection(service_, handler, *thread_pool, ctx_)); in handle_accept()
167 new_connection->socket().next_layer(), in handle_accept()
169 new_connection->socket(), in handle_accept()
216 new_connection.reset(new connection(service_, handler, *thread_pool, ctx_)); in start_listening()
219 new_connection->socket().next_layer(), in start_listening()
[all …]
|
| /dports/math/freefem++/FreeFem-sources-4.6/src/ffgraphics/server/ |
| H A D | ffServer.hpp | 99 void handle_accept(Connection::pointer new_connection, const std::error_code & err) in handle_accept() argument
102 m_Connection.push_back(new_connection); in handle_accept()
103 new_connection->start(); in handle_accept()
110 Connection::pointer new_connection = Connection::create(m_ioService); in start_accept() local
112 m_Acceptor.async_accept(new_connection->socket(), in start_accept()
113 std::bind(&ffServer::handle_accept, this, new_connection, std::placeholders::_1)); in start_accept()
|
| /dports/devel/php-libawl/awl-827fbfed7dab0ca339998ca6cdcffb328246d83b/inc/ |
| H A D | AwlQuery.php | 244 * @param resource $new_connection The database connection to use.
246 function SetConnection( $new_connection, $options = null ) { argument
247 if ( is_string($new_connection) || is_array($new_connection) ) {
250 if ( is_array($new_connection) ) {
251 $dsn = $new_connection['dsn'];
252 if ( isset($new_connection['dbuser']) ) $dbuser = $new_connection['dbuser'];
253 if ( isset($new_connection['dbpass']) ) $dbpass = $new_connection['dbpass'];
255 …elseif ( preg_match( '/^(\S+:)?(.*)( user=(\S+))?( password=(\S+))?$/', $new_connection, $matches …
266 if ( ! $new_connection = new AwlDatabase( $dsn, $dbuser, $dbpass, $options ) ) return;
268 $this->connection = $new_connection;
[all …]
|
| /dports/textproc/redland/redland-1.0.17/examples/ |
| H A D | redland_dbus.c | 103 DBusConnection *new_connection, in new_connection_callback() argument
111 dbus_connection_ref (new_connection); in new_connection_callback()
113 dbus_connection_setup_with_g_main (new_connection, NULL); in new_connection_callback()
121 if (!dbus_connection_register_handler (new_connection, in new_connection_callback()
126 if (!dbus_connection_set_data (new_connection, in new_connection_callback()
132 if (!dbus_connection_register_handler (new_connection, in new_connection_callback()
|
| /dports/ftp/php-fastdfs/fastdfs-6.06/client/ |
| H A D | storage_client.c | 133 bool *new_connection) in storage_get_upload_connection() argument
220 bool new_connection; in storage_get_metadata() local
290 if (new_connection) in storage_get_metadata()
323 bool new_connection; in storage_query_file_info_ex() local
412 if (new_connection) in storage_query_file_info_ex()
454 bool new_connection; in storage_delete_file() local
507 if (new_connection) in storage_delete_file()
544 bool new_connection; in storage_do_download_file_ex() local
685 if (new_connection) in storage_do_download_file_ex()
1036 if (new_connection) in storage_do_upload_file()
[all …]
|
| /dports/ftp/fastdfs/fastdfs-6.06/client/ |
| H A D | storage_client.c | 133 bool *new_connection) in storage_get_upload_connection() argument
220 bool new_connection; in storage_get_metadata() local
290 if (new_connection) in storage_get_metadata()
323 bool new_connection; in storage_query_file_info_ex() local
412 if (new_connection) in storage_query_file_info_ex()
454 bool new_connection; in storage_delete_file() local
507 if (new_connection) in storage_delete_file()
544 bool new_connection; in storage_do_download_file_ex() local
685 if (new_connection) in storage_do_download_file_ex()
1036 if (new_connection) in storage_do_upload_file()
[all …]
|
| /dports/emulators/mess/mame-mame0226/3rdparty/asio/src/examples/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 81 tcp_connection::pointer new_connection = in start_accept() local
84 acceptor_.async_accept(new_connection->socket(), in start_accept()
85 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
89 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
94 new_connection->start(); in handle_accept()
|
| /dports/emulators/mame/mame-mame0226/3rdparty/asio/src/examples/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 81 tcp_connection::pointer new_connection = in start_accept() local
84 acceptor_.async_accept(new_connection->socket(), in start_accept()
85 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
89 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
94 new_connection->start(); in handle_accept()
|
| /dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/modules/asio-standalone/asio/src/examples/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 81 tcp_connection::pointer new_connection = in start_accept() local
84 acceptor_.async_accept(new_connection->socket(), in start_accept()
85 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
89 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
94 new_connection->start(); in handle_accept()
|
| /dports/multimedia/obs-websocket/obs-websocket-4.8.0/deps/asio/asio/src/examples/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 81 tcp_connection::pointer new_connection = in start_accept() local
84 acceptor_.async_accept(new_connection->socket(), in start_accept()
85 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
89 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
94 new_connection->start(); in handle_accept()
|
| /dports/net/asio/asio-1.16.0/src/examples/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 82 tcp_connection::pointer new_connection = in start_accept() local
85 acceptor_.async_accept(new_connection->socket(), in start_accept()
86 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
90 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
95 new_connection->start(); in handle_accept()
|
| /dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 82 tcp_connection::pointer new_connection = in start_accept() local
85 acceptor_.async_accept(new_connection->socket(), in start_accept()
86 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
90 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
95 new_connection->start(); in handle_accept()
|
| /dports/sysutils/glogg/glogg-1.1.4/src/ |
| H A D | signalmux.cpp | 36 Connection new_connection = { in connect() local
42 connectionList_.push_back( new_connection ); in connect()
44 connect( new_connection ); in connect()
73 Connection new_connection = { in connect() local
79 connectionList_.push_back( new_connection ); in connect()
81 connect( new_connection ); in connect()
|
| /dports/www/osrm-backend/osrm-backend-5.26.0/include/server/ |
| H A D | server.hpp | 47 new_connection(std::make_shared<Connection>(io_service, request_handler)) in Server()
67 new_connection->socket(), in Server()
98 new_connection->start(); in HandleAccept()
99 new_connection = std::make_shared<Connection>(io_service, request_handler); in HandleAccept()
101 new_connection->socket(), in HandleAccept()
113 std::shared_ptr<Connection> new_connection; member in osrm::server::Server
|
| /dports/devel/boost-docs/boost_1_72_0/libs/asio/example/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 82 tcp_connection::pointer new_connection = in start_accept() local
85 acceptor_.async_accept(new_connection->socket(), in start_accept()
86 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
90 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
95 new_connection->start(); in handle_accept()
|
| /dports/devel/boost-python-libs/boost_1_72_0/libs/asio/example/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 82 tcp_connection::pointer new_connection = in start_accept() local
85 acceptor_.async_accept(new_connection->socket(), in start_accept()
86 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
90 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
95 new_connection->start(); in handle_accept()
|
| /dports/databases/percona57-pam-for-mysql/boost_1_59_0/libs/asio/example/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 81 tcp_connection::pointer new_connection = in start_accept() local
84 acceptor_.async_accept(new_connection->socket(), in start_accept()
85 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
89 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
94 new_connection->start(); in handle_accept()
|
| /dports/databases/mysqlwsrep57-server/boost_1_59_0/libs/asio/example/cpp03/tutorial/daytime3/ |
| H A D | server.cpp | 81 tcp_connection::pointer new_connection = in start_accept() local
84 acceptor_.async_accept(new_connection->socket(), in start_accept()
85 boost::bind(&tcp_server::handle_accept, this, new_connection, in start_accept()
89 void handle_accept(tcp_connection::pointer new_connection, in handle_accept() argument
94 new_connection->start(); in handle_accept()
|