Home
last modified time | relevance | path

Searched refs:connection (Results 1 – 25 of 151) sorted by relevance

1234567

/plugin/openid/Auth/OpenID/
H A DMDB2Store.php52 * @param connection $connection This must be an established
65 function Auth_OpenID_MDB2Store($connection, argument
74 if (!is_object($connection) ||
82 $this->connection = $connection;
125 switch ($this->connection->phptype) {
130 $r = $this->connection->exec(
195 switch ($this->connection->phptype) {
306 return $this->connection->exec(
313 return $this->connection->exec(
359 $r = $this->connection->execParam(
[all …]
H A DSQLStore.php64 * @param connection $connection This must be an established
87 if (!(is_object($connection) &&
89 is_subclass_of($connection,
97 $this->connection = $connection;
345 $this->connection->commit();
347 $this->connection->rollback();
389 $this->connection->commit();
391 $this->connection->rollback();
463 $this->connection->commit();
543 $this->connection->commit();
[all …]
H A DMemcachedStore.php46 $this->connection = $connection;
64 $serverAssociations = $this->connection->get($serverKey);
74 $this->connection->set(
80 $this->connection->set(
96 $association = $this->connection->get(
106 $serverAssociations = $this->connection->get($serverKey);
118 $association = $this->connection->get($lastKey);
134 $serverAssociations = $this->connection->get($serverKey);
151 $this->connection->set(
158 return $this->connection->delete($associationKey);
[all …]
/plugin/fedauth/Auth/OpenID/
H A DMDB2Store.php52 * @param connection $connection This must be an established
65 function Auth_OpenID_MDB2Store($connection, argument
74 if (!is_object($connection) ||
82 $this->connection = $connection;
125 switch ($this->connection->phptype) {
130 $r = $this->connection->exec(
195 switch ($this->connection->phptype) {
306 return $this->connection->exec(
313 return $this->connection->exec(
359 $r = $this->connection->execParam(
[all …]
H A DSQLStore.php64 * @param connection $connection This must be an established
87 if (!(is_object($connection) &&
89 is_subclass_of($connection,
97 $this->connection = $connection;
345 $this->connection->commit();
347 $this->connection->rollback();
389 $this->connection->commit();
391 $this->connection->rollback();
463 $this->connection->commit();
543 $this->connection->commit();
[all …]
H A DMemcachedStore.php46 $this->connection = $connection;
64 $serverAssociations = $this->connection->get($serverKey);
74 $this->connection->set(
80 $this->connection->set(
96 $association = $this->connection->get(
106 $serverAssociations = $this->connection->get($serverKey);
118 $association = $this->connection->get($lastKey);
134 $serverAssociations = $this->connection->get($serverKey);
151 $this->connection->set(
158 return $this->connection->delete($associationKey);
[all …]
/plugin/swiftmail/Swift/Authenticator/
H A D@PopB4Smtp.php23 protected $connection = null; variable in Swift_Authenticator_PopB4Smtp
32 if (is_object($conn)) $this->connection = $conn;
56 $this->connection->start();
57 $this->connection->assertOk($this->connection->read());
58 $this->connection->write("USER " . $user);
59 $this->connection->assertOk($this->connection->read());
60 $this->connection->write("PASS " . $pass);
61 $this->connection->assertOk($this->connection->read());
62 $this->connection->write("QUIT");
63 $this->connection->assertOk($this->connection->read());
[all …]
/plugin/elasticsearch/vendor/elasticsearch/elasticsearch/src/Elasticsearch/ConnectionPool/
H A DStaticConnectionPool.php44 if ($connection->isAlive() === true) {
45 return $connection;
48 if ($this->readyToRevive($connection) === true) {
49 if ($connection->ping() === true) {
50 return $connection;
53 $skipped[] = $connection;
58 foreach ($skipped as $connection) {
59 if ($connection->ping() === true) {
60 return $connection;
69 foreach ($this->connections as $connection) {
[all …]
H A DSniffingConnectionPool.php46 $connection = $this->selector->select($this->connections);
47 if ($connection->isAlive() === true || $connection->ping() === true) {
48 return $connection;
76 $connection = $this->selector->select($this->connections);
78 if ($connection->isAlive() xor $force) {
82 if ($this->sniffConnection($connection) === true) {
91 foreach ($this->seedConnections as $connection) {
92 if ($this->sniffConnection($connection) === true) {
98 private function sniffConnection(Connection $connection): bool argument
101 $response = $connection->sniff();
[all …]
H A DStaticNoPingConnectionPool.php40 $connection = $this->selector->select($this->connections);
41 if ($connection->isAlive() === true) {
42 return $connection;
45 if ($this->readyToRevive($connection) === true) {
46 return $connection;
57 private function readyToRevive(Connection $connection): bool argument
60 $this->pingTimeout * pow(2, $connection->getPingFailures()),
64 if ($connection->getLastPing() + $timeout < time()) {
/plugin/elasticsearch/vendor/ruflin/elastica/lib/Elastica/Transport/
H A DGuzzle.php55 $connection = $this->getConnection();
60 'base_uri' => $this->_getBaseUrl($connection),
66 if ($connection->getTimeout()) {
70 $proxy = $connection->getProxy();
118 * @param Connection $connection
127 $connection->hasConfig('headers') && \is_array($connection->getConfig('headers'))
128 ? $connection->getConfig('headers')
173 * @param Connection $connection
180 $url = $connection->hasConfig('url') ? $connection->getConfig('url') : '';
187 'host' => $connection->getHost(),
[all …]
H A DHttpAdapter.php33 * @param Connection $connection
38 parent::__construct($connection);
58 $connection = $this->getConnection();
60 if ($timeout = $connection->getTimeout()) {
64 $httpAdapterRequest = $this->_createHttpAdapterRequest($elasticaRequest, $connection);
103 * @param Connection $connection
112 $headers = $connection->hasConfig('headers') ?: [];
130 $url = $this->_getUri($elasticaRequest, $connection);
142 protected function _getUri(ElasticaRequest $request, Connection $connection): string argument
144 $url = $connection->hasConfig('url') ? $connection->getConfig('url') : '';
[all …]
H A DAwsAuthV4.php31 protected function _getBaseUrl(Connection $connection): string argument
35 return parent::_getBaseUrl($connection);
56 $connection = $this->getConnection();
57 if ($connection->hasParam('aws_secret_access_key')) {
59 $connection->getParam('aws_access_key_id'),
60 $connection->getParam('aws_secret_access_key'),
61 $connection->hasParam('aws_session_token')
72 $connection = $this->getConnection();
73 if (true === $this->isSslRequired($connection)) {
75 $connection->setPort(443);
[all …]
H A DHttp.php51 $connection = $this->getConnection();
53 $conn = $this->_getConnection($connection->isPersistent());
56 $url = $connection->hasConfig('url') ? $connection->getConfig('url') : '';
61 …$baseUri = $this->_scheme.'://'.$connection->getHost().':'.$connection->getPort().'/'.$connection-…
89 $connectTimeout = $connection->getConnectTimeout();
94 $proxy = $connection->getProxy();
105 $username = $connection->getUsername();
106 $password = $connection->getPassword();
114 $headersConfig = $connection->hasConfig('headers') ? $connection->getConfig('headers') : [];
144 if ($connection->hasCompression()) {
[all …]
H A DAbstractTransport.php26 * @param Connection $connection Connection object
28 public function __construct(Connection $connection = null) argument
30 if ($connection) {
31 $this->setConnection($connection);
44 * @param Connection $connection Connection object
48 public function setConnection(Connection $connection): AbstractTransport argument
50 $this->_connection = $connection;
95 * @param Connection $connection A connection instance
102 …public static function create($transport, Connection $connection, array $params = []): AbstractTra… argument
133 $transport->setConnection($connection);
H A DHttps.php22 * @param resource $connection Curl connection resource
24 protected function _setupCurl($connection) argument
26 parent::_setupCurl($connection);
/plugin/elasticsearch/vendor/ruflin/elastica/lib/Elastica/Connection/
H A DConnectionPool.php48 * @param Connection $connection
52 public function addConnection(Connection $connection): self argument
54 $this->_connections[] = $connection;
76 foreach ($this->_connections as $connection) {
77 if ($connection->isEnabled()) {
104 * @param Connection $connection
108 public function onFail(Connection $connection, Exception $e, Client $client) argument
110 $connection->setEnabled(false);
113 \call_user_func($this->_callback, $connection, $e, $client);
/plugin/authgoogle/google/cache/
H A DGoogle_MemcacheCache.php27 private $connection = false; variable in Google_MemcacheCache
43 if ((@memcache_get($this->connection, $key . '.lock')) === false) {
53 @memcache_add($this->connection, $key . '.lock', '', 0, 5);
59 @memcache_delete($this->connection, $key . '.lock');
81 if (! $this->connection = @memcache_pconnect($this->host, $this->port)) {
87 if (! $this->connection) {
97 if (($ret = @memcache_get($this->connection, $key)) === false) {
116 if (@memcache_set($this->connection, $key, array('time' => time(),
128 @memcache_delete($this->connection, $key);
/plugin/jplayer/vendor/james-heinrich/getid3/getid3/
H A Dextension.cache.mysql.php84 private $connection; variable in getID3_cached_mysql
112 $this->connection = mysql_pconnect($host, $username, $password);
113 if (!$this->connection) {
118 if (!mysql_select_db($database, $this->connection)) {
136 if ($this->cursor = mysql_query($SQLquery, $this->connection)) {
153 …ursor = mysql_query('DELETE FROM `'.mysql_real_escape_string($this->table).'`', $this->connection);
154 …ble).'` VALUES (\''.getID3::VERSION.'\', -1, -1, -1, \''.getID3::VERSION.'\')', $this->connection);
184 $this->cursor = mysql_query($SQLquery, $this->connection);
203 $this->cursor = mysql_query($SQLquery, $this->connection);
224 $this->cursor = mysql_query($SQLquery, $this->connection);
[all …]
/plugin/swiftmail/Swift/Events/
H A DDisconnectEvent.php24 protected $connection = null; variable in Swift_Events_DisconnectEvent
30 public function __construct(Swift_Connection $connection) argument
32 $this->connection = $connection;
40 return $this->connection;
H A DConnectEvent.php24 protected $connection = null; variable in Swift_Events_ConnectEvent
30 public function __construct(Swift_Connection $connection) argument
32 $this->connection = $connection;
40 return $this->connection;
/plugin/elasticsearch/vendor/elasticsearch/elasticsearch/tests/Elasticsearch/Tests/Connections/
H A DConnectionTest.php33 $connection = new Connection(
43 $this->assertInstanceOf(Connection::class, $connection);
53 $connection = new Connection(
63 $headers = $connection->getHeaders();
76 $connection = new Connection(
84 $result = $connection->performRequest('GET', '/');
85 $request = $connection->getLastRequestInfo()['request'];
/plugin/elasticsearch/vendor/ruflin/elastica/lib/Elastica/
H A DRequest.php34 * @param Connection $connection
39 …$path, $method = self::GET, $data = [], array $query = [], Connection $connection = null, $content… argument
46 if ($connection) {
47 $this->setConnection($connection);
143 public function setConnection(Connection $connection) argument
145 $this->_connection = $connection;
/plugin/sqlcomp/
H A Dsyntax.php387 $rs = odbc_exec($connection,$Query);
393 odbc_close($connection);
406 pg_close($connection);
412 if(!$connection = mysqli_connect($Server, $User, $Pass) or false)
415 if (!mysqli_select_db($connection, $Database))
416 throw new Exception(mysqli_error($connection));
418 $rs = mysqli_query($connection, $Query);
428 mysqli_close($connection);
456 if(!$connection = oci_connect($User, $Pass, $Server) or false)
460 $rs = oci_parse($connection, $Query);
[all …]
/plugin/elasticsearch/vendor/ruflin/elastica/lib/Elastica/Connection/Strategy/
H A DSimple.php20 foreach ($connections as $connection) {
21 if ($connection->isEnabled()) {
22 return $connection;

1234567