Home
last modified time | relevance | path

Searched +refs:close +refs:connection (Results 201 – 225 of 45626) sorted by relevance

12345678910>>...1826

/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/diameter/src/transport/
H A Ddiameter_etcp.erl38 close/1,
60 -record(connection, record
109 close(Pid) -> function
110 Pid ! close,
152 {ok, #connection{parent = Parent,
284 #connection{parent = Parent,
296 #connection{parent = Parent,
310 transition(close = T, #connection{peer = Peer})
312 Peer ! {close, self()},
316 transition(close = T, #connection{}) ->
[all …]
/dports/lang/erlang/otp-OTP-24.1.7/lib/diameter/src/transport/
H A Ddiameter_etcp.erl38 close/1,
60 -record(connection, record
109 close(Pid) -> function
110 Pid ! close,
152 {ok, #connection{parent = Parent,
284 #connection{parent = Parent,
296 #connection{parent = Parent,
310 transition(close = T, #connection{peer = Peer})
312 Peer ! {close, self()},
316 transition(close = T, #connection{}) ->
[all …]
/dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/lib/diameter/src/transport/
H A Ddiameter_etcp.erl38 close/1,
60 -record(connection, record
109 close(Pid) -> function
110 Pid ! close,
152 {ok, #connection{parent = Parent,
284 #connection{parent = Parent,
296 #connection{parent = Parent,
310 transition(close = T, #connection{peer = Peer})
312 Peer ! {close, self()},
316 transition(close = T, #connection{}) ->
[all …]
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/diameter/src/transport/
H A Ddiameter_etcp.erl38 close/1,
60 -record(connection, record
109 close(Pid) -> function
110 Pid ! close,
152 {ok, #connection{parent = Parent,
284 #connection{parent = Parent,
296 #connection{parent = Parent,
310 transition(close = T, #connection{peer = Peer})
312 Peer ! {close, self()},
316 transition(close = T, #connection{}) ->
[all …]
/dports/databases/py-mysql-connector-python/mysql-connector-python-8.0.27/tests/
H A Dtest_bugs.py116 cur.close()
138 cur.close()
153 cur.close()
177 cur.close()
195 cur.close()
266 cur.close()
328 cnx.close()
428 cnx.close()
824 @foreach_cnx(connection.MySQLConnection)
871 @foreach_cnx(connection.MySQLConnection)
[all …]
/dports/textproc/py-elasticsearch5/elasticsearch-py-719a94ab4/elasticsearch/
H A Dconnection_pool.py127 def mark_dead(self, connection, now=None): argument
151 def mark_live(self, connection): argument
159 del self.dead_count[connection]
202 self.connections.append(connection)
204 return connection
231 def close(self): member in ConnectionPool
236 conn.close()
245 self.connection = connections[0][0]
249 return self.connection
251 def close(self): member in DummyConnectionPool
[all …]
/dports/textproc/py-elasticsearch6/elasticsearch-6.8.2/elasticsearch/
H A Dconnection_pool.py179 connection,
184 def mark_live(self, connection): argument
192 del self.dead_count[connection]
235 self.connections.append(connection)
237 return connection
264 def close(self): member in ConnectionPool
269 conn.close()
280 self.connection = connections[0][0]
284 return self.connection
286 def close(self): member in DummyConnectionPool
[all …]
/dports/devel/websocketpp/websocketpp-0.8.2/tutorials/utility_client/
H A Dutility_client.md535 #### Getting connection close information out of WebSocket++
544 - `connection::get_remote_close_code()`: Get the close code as reported by the remote endpoint
545 - `connection::get_remote_close_reason()`: Get the close reason as reported by the remote endpoint
546 - `connection::get_local_close_code()`: Get the close code that this endpoint sent.
547 - `connection::get_local_close_reason()`: Get the close reason that this endpoint sent.
550 …close codes that will report a code that was not actually sent on the wire. For example 1005/"no c…
568 …nd `on_fail`, `websocket_endpoint::connect` registers this close handler when a new connection is …
572 …connection ID in the connection list. Next a close request is sent to the connection's handle wit…
575 void close(int id, websocketpp::close::status::value code) {
657 > Error/close reason: close code: 1001 (Going away), close reason: example message
[all …]
/dports/science/dftbplus/dftbplus-19.1/test/prog/dftb+/sockets/H2O_cluster/
H A Dprerun.py33 file.close()
37 file.close()
44 return connection
59 connection = connect()
64 connection.sendall(latvecs)
72 connection.sendall(coords)
76 buf = receive_all(connection, 12)
81 buf = receive_all(connection, 12)
98 buf = receive_all(connection, 4)
102 connection.shutdown(socket.SHUT_RDWR)
[all …]
/dports/www/middleman/middleman/src/
H A Dexternal.c441 close(fd); in external_exec()
449 close(ipipe[1]); in external_exec()
450 close(opipe[0]); in external_exec()
507 close(opipe[1]); in external_exec()
508 close(ipipe[0]); in external_exec()
562 close(opipe[0]); in external_exec()
574 close(opipe[0]); in external_exec()
575 close(opipe[1]); in external_exec()
578 close(ipipe[0]); in external_exec()
579 close(ipipe[1]); in external_exec()
[all …]
/dports/net/py-kombu/kombu-4.6.11/kombu/
H A Dcompat.py24 yield connection.drain_events()
41 connection = channel
63 def close(self): member in Publisher
64 super(Publisher, self).close()
71 self.close()
93 self.backend = connection.channel()
124 def close(self): member in Consumer
126 self.backend.close()
133 self.close()
210 def close(self): member in ConsumerSet
[all …]
/dports/www/glassfish/glassfish5/mq/examples/jms/
H A DSynchTopicExample.java60 connection = in run()
67 if (connection != null) { in run()
69 connection.close(); in run()
84 connection.start(); in run()
102 if (connection != null) { in run()
104 connection.close(); in run()
143 connection = in run()
150 if (connection != null) { in run()
152 connection.close(); in run()
168 connection.start(); in run()
[all …]
/dports/www/payara/payara5/mq/examples/jms/
H A DSynchTopicExample.java90 connection = in run()
97 if (connection != null) { in run()
99 connection.close(); in run()
114 connection.start(); in run()
132 if (connection != null) { in run()
134 connection.close(); in run()
173 connection = in run()
180 if (connection != null) { in run()
182 connection.close(); in run()
198 connection.start(); in run()
[all …]
/dports/net-im/ricochet/ricochet-1.1.4/src/core/
H A DIncomingRequestManager.cpp263 if (connection) { in setChannel()
265 connection->close(); in setChannel()
271 if (connection == channel->connection() && in setChannel()
275 connection->close(); in setChannel()
290 channel->connection()->close(); in setChannel()
296 newConnection->close(); in setChannel()
302 if (connection && !connection->isConnected()) in setChannel()
328 if (connection) { in accept()
335 connection->close(); in accept()
353 if (connection) { in reject()
[all …]
/dports/databases/hsqldb/hsqldb-2.3.4/hsqldb/src/org/hsqldb/jdbc/
H A DJDBCStatementBase.java89 protected JDBCConnection connection; field in JDBCStatementBase
134 public synchronized void close() throws SQLException {} in close() method in JDBCStatementBase
147 if (connection.isClosed) { in checkClosed()
148 close(); in checkClosed()
153 if (connectionIncarnation != connection.incarnation) { in checkClosed()
196 connection.setWarnings(rootWarning); in performPostExecute()
215 if(!connection.isCloseResultSet) { in getResultSet()
251 currentResultSet.close(); in getMoreResults()
270 generatedResultSet.close(); in getGeneratedResultSet()
290 currentResultSet.close(); in closeResultData()
[all …]
/dports/www/moodle310/moodle/auth/ldap/tests/
H A Dplugin_test.php174 $sink->close();
206 $this->delete_ldap_user($connection, $topdn, 1);
212 $sink->close();
234 $sink->close();
255 $sink->close();
275 $sink->close();
300 $sink->close();
323 $sink->close();
342 ldap_close($connection);
374 $sink->close();
[all …]
/dports/www/moodle39/moodle/auth/ldap/tests/
H A Dplugin_test.php174 $sink->close();
206 $this->delete_ldap_user($connection, $topdn, 1);
212 $sink->close();
234 $sink->close();
255 $sink->close();
275 $sink->close();
300 $sink->close();
323 $sink->close();
342 ldap_close($connection);
374 $sink->close();
[all …]
/dports/www/moodle311/moodle/auth/ldap/tests/
H A Dplugin_test.php174 $sink->close();
206 $this->delete_ldap_user($connection, $topdn, 1);
212 $sink->close();
234 $sink->close();
255 $sink->close();
275 $sink->close();
300 $sink->close();
323 $sink->close();
342 ldap_close($connection);
374 $sink->close();
[all …]
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/
H A DTestRegionReplicaReplicationEndpoint.java136 admin.close(); in testRegionReplicaReplicationPeerIsCreated()
170 admin.close(); in testRegionReplicaReplicationPeerIsCreatedForModifyTable()
200 table.close(); in testRegionReplicaReplication()
203 connection.close(); in testRegionReplicaReplication()
291 table.close(); in testRegionReplicaWithoutMemstoreReplication()
292 connection.close(); in testRegionReplicaWithoutMemstoreReplication()
325 table.close(); in testRegionReplicaReplicationForFlushAndCompaction()
326 connection.close(); in testRegionReplicaReplicationForFlushAndCompaction()
408 admin.close(); in testRegionReplicaReplicationIgnoresDisabledTables()
410 rl.close(); in testRegionReplicaReplicationIgnoresDisabledTables()
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/lib/cpp/src/thrift/server/
H A DTNonblockingServer.cpp238 void close();
296 close(); in forceClose()
441 close(); in workSocket()
450 close(); in workSocket()
474 close(); in workSocket()
497 close(); in workSocket()
531 close(); in workSocket()
551 close(); in workSocket()
776 close(); in transition()
1065 assert(connection && connection->getServer() && connection->getState() == APP_WAIT_TASK); in drainPendingTask()
[all …]
/dports/devel/thrift-c_glib/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTNonblockingServer.cpp238 void close();
296 close(); in forceClose()
441 close(); in workSocket()
450 close(); in workSocket()
474 close(); in workSocket()
497 close(); in workSocket()
531 close(); in workSocket()
551 close(); in workSocket()
776 close(); in transition()
1065 assert(connection && connection->getServer() && connection->getState() == APP_WAIT_TASK); in drainPendingTask()
[all …]
/dports/devel/thrift-cpp/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTNonblockingServer.cpp238 void close();
296 close(); in forceClose()
441 close(); in workSocket()
450 close(); in workSocket()
474 close(); in workSocket()
497 close(); in workSocket()
531 close(); in workSocket()
551 close(); in workSocket()
776 close(); in transition()
1065 assert(connection && connection->getServer() && connection->getState() == APP_WAIT_TASK); in drainPendingTask()
[all …]
/dports/devel/thrift/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTNonblockingServer.cpp238 void close();
296 close(); in forceClose()
441 close(); in workSocket()
450 close(); in workSocket()
474 close(); in workSocket()
497 close(); in workSocket()
531 close(); in workSocket()
551 close(); in workSocket()
776 close(); in transition()
1065 assert(connection && connection->getServer() && connection->getState() == APP_WAIT_TASK); in drainPendingTask()
[all …]
/dports/devel/node-thrift/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTNonblockingServer.cpp238 void close();
296 close(); in forceClose()
441 close(); in workSocket()
450 close(); in workSocket()
474 close(); in workSocket()
497 close(); in workSocket()
531 close(); in workSocket()
551 close(); in workSocket()
776 close(); in transition()
1065 assert(connection && connection->getServer() && connection->getState() == APP_WAIT_TASK); in drainPendingTask()
[all …]
/dports/devel/py-thrift/thrift-0.14.0/lib/cpp/src/thrift/server/
H A DTNonblockingServer.cpp238 void close();
296 close(); in forceClose()
441 close(); in workSocket()
450 close(); in workSocket()
474 close(); in workSocket()
497 close(); in workSocket()
531 close(); in workSocket()
551 close(); in workSocket()
776 close(); in transition()
1065 assert(connection && connection->getServer() && connection->getState() == APP_WAIT_TASK); in drainPendingTask()
[all …]

12345678910>>...1826