Blame view
sources/apps/files_external/3rdparty/irodsphp/prods/src/RODSConnManager.class.php
2.38 KB
03e52840d
Init
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 |
<?php
/**#@+
* Constants
*/
/**
* Maximum number of connection per user per server
*/
define("MAX_NUM_CONN_PER_USER_SERVER", 5);
/**#@-*/
if (!isset($GLOBALS['RODSConnManager']))
$GLOBALS['RODSConnManager'] = new RODSConnManager();
class RODSConnManager
{
private $waiting_queue;
private $conn_map;
public function __construct()
{
$this->waiting_queue = array();
$this->conn_map = array();
}
public static function getConn(RODSAccount $account)
{
$manager = $GLOBALS['RODSConnManager'];
$conn = new RODSConn($account);
$conn_sig = $conn->getSignature();
if (!isset($manager->conn_map[$conn_sig]))
$manager->conn_map[$conn_sig] = array();
//check if there is any opened connection idle
foreach ($manager->conn_map[$conn_sig] as &$opened_conn) {
if ($opened_conn->isIdle()) {
//$opened_conn->lock();
$account = $opened_conn->getAccount(); //update account if needed...
return $opened_conn;
}
}
//check if there is any more new connection allowed
if (count($manager->conn_map[$conn_sig]) < MAX_NUM_CONN_PER_USER_SERVER) {
$conn->connect();
$id = count($manager->conn_map[$conn_sig]);
$manager->conn_map[$conn_sig][$id] = $conn;
$conn->setId($id);
//$conn->lock();
$account = $conn->getAccount(); //update account if needed...
return $conn;
}
//because PHP doesn't support multithread, if we run out of connections,
//there is probably something went wrong.
throw new RODSException("Unexpectedly ran out of connections. Maybe some connections are not released??? ",
"PERR_INTERNAL_ERR");
//if no connection are available, sleep for 100ms and retry
usleep(100);
echo "i am sleeping... <br/>
";
return RODSConnManager::getConn($account);
}
public static function releaseConn(RODSConn $conn)
{
$manager = $GLOBALS['RODSConnManager'];
$conn_sig = $conn->getSignature();
//echo "id:".$conn->getId()." ".implode(",",array_keys($manager->conn_map[$conn_sig]))."<br/>
";
if (isset($manager->conn_map[$conn_sig][$conn->getId()])) {
$manager->conn_map[$conn_sig][$conn->getId()]->unlock();
}
}
}
|