fernando/luos
1
0
Fork 0
Code Releases Activity

CODE STYLE class.memcached.php

Browse Source
This commit is contained in:
Fernando Ontiveros
2012-10-09 12:53:37 -04:00
parent a12343f7a8
commit 8c638de652
1 changed files with 143 additions and 130 deletions
Download Patch File Download Diff File Expand all files Collapse all files

123
workflow/engine/classes/class.memcached.php
View File

@@ -1,6 +1,8 @@
<?php <?php
/** /**
* class.memcached.php * class.memcached.php
*
* @package workflow.engine.ProcessMaker * @package workflow.engine.ProcessMaker
* *
* ProcessMaker Open Source Edition * ProcessMaker Open Source Edition
@@ -30,7 +32,8 @@
* @package workflow.engine.ProcessMaker * @package workflow.engine.ProcessMaker
*/ */
class PMmemcached { class PMmemcached
{
const ONE_MINUTE = 60; const ONE_MINUTE = 60;
const ONE_HOUR = 3600; const ONE_HOUR = 3600;
const TWO_HOURS = 7200; const TWO_HOURS = 7200;
@@ -44,37 +47,36 @@ class PMmemcached {
private static $instance = NULL; private static $instance = NULL;
public function __construct($workspace) { public function __construct ($workspace)
{
$this->enabled = MEMCACHED_ENABLED; $this->enabled = MEMCACHED_ENABLED;
$this->connected = false; $this->connected = false;
$this->workspace = $workspace; $this->workspace = $workspace;
if (class_exists ( 'Memcached' )) { if (class_exists( 'Memcached' )) {
$this->mem = new Memcached (); $this->mem = new Memcached();
$this->class = 'Memcached'; $this->class = 'Memcached';
$this->connected = true; $this->connected = true;
} } else {
else { if (class_exists( 'Memcache' )) {
if (class_exists ( 'Memcache' )) { $this->mem = new Memcache();
$this->mem = new Memcache ();
$this->class = 'Memcache'; $this->class = 'Memcache';
$this->supported = true; $this->supported = true;
$this->connected = @$this->mem->connect ( MEMCACHED_SERVER, 11211 ); $this->connected = @$this->mem->connect( MEMCACHED_SERVER, 11211 );
if ($this->connected) { if ($this->connected) {
$this->version = $this->mem->getVersion (); $this->version = $this->mem->getVersion();
} }
} } else {
else { G::Loadclass( 'fileCache' );
G::Loadclass ( 'fileCache' );
// create cache folder // create cache folder
$cacheFolder = PATH_DATA . "sites/" . $workspace . "/cachefiles/"; $cacheFolder = PATH_DATA . "sites/" . $workspace . "/cachefiles/";
if (! file_exists ( $cacheFolder )) { if (! file_exists( $cacheFolder )) {
if (! mkdir ( $cacheFolder )) { if (! mkdir( $cacheFolder )) {
return false; return false;
} }
} }
$this->class = 'fileCache'; $this->class = 'fileCache';
$this->connected = true; $this->connected = true;
$this->mem = new FileCache ( $cacheFolder ); $this->mem = new FileCache( $cacheFolder );
} }
} }
@@ -91,95 +93,106 @@ class PMmemcached {
* @access public * @access public
* @return object * @return object
*/ */
public static function getSingleton($workspace) { public static function getSingleton ($workspace)
{
if (! self::$instance instanceof self) { if (! self::$instance instanceof self) {
self::$instance = new PMmemcached ( $workspace ); self::$instance = new PMmemcached( $workspace );
} }
return self::$instance; return self::$instance;
} }
public function __clone() { public function __clone ()
throw new Exception ( "Clone is not allowed." ); {
throw new Exception( "Clone is not allowed." );
} }
public function __wakeup() { public function __wakeup ()
throw new Exception ( "Deserializing is not allowed." ); {
throw new Exception( "Deserializing is not allowed." );
} }
function set($key, $object, $timeout = 0) { function set ($key, $object, $timeout = 0)
{
if (! $this->connected) if (! $this->connected)
return false; return false;
if ($this->class != 'filecache') if ($this->class != 'filecache')
$this->mem->set ( $this->workspace . '_' . $key, $object, false, $timeout ); $this->mem->set( $this->workspace . '_' . $key, $object, false, $timeout );
else else
$this->mem->set ( $this->workspace . '_' . $key, $object ); $this->mem->set( $this->workspace . '_' . $key, $object );
} }
function get($key) { function get ($key)
{
if (! $this->connected) if (! $this->connected)
return false; return false;
return $this->mem->get ( $this->workspace . '_' . $key ); return $this->mem->get( $this->workspace . '_' . $key );
} }
function add($key, $value) { function add ($key, $value)
{
if ((! $this->connected) || ($this->class == 'filecache')) if ((! $this->connected) || ($this->class == 'filecache'))
return false; return false;
return $this->mem->add ( $this->workspace . '_' . $key, $value ); return $this->mem->add( $this->workspace . '_' . $key, $value );
} }
function increment($key, $value) { function increment ($key, $value)
{
if ((! $this->connected) || ($this->class == 'filecache')) if ((! $this->connected) || ($this->class == 'filecache'))
return false; return false;
return $this->mem->increment ( $this->workspace . '_' . $key, $value ); return $this->mem->increment( $this->workspace . '_' . $key, $value );
} }
function delete($key) { function delete ($key)
{
if ((! $this->connected) || ($this->class == 'filecache')) if ((! $this->connected) || ($this->class == 'filecache'))
return false; return false;
return $this->mem->delete ( $this->workspace . '_' . $key ); return $this->mem->delete( $this->workspace . '_' . $key );
} }
function flush() { function flush ()
{
if ((! $this->connected) || ($this->class == 'filecache')) if ((! $this->connected) || ($this->class == 'filecache'))
return false; return false;
return $this->mem->flush (); return $this->mem->flush();
} }
function getStats() { function getStats ()
{
if ((! $this->connected) || ($this->class == 'filecache')) if ((! $this->connected) || ($this->class == 'filecache'))
return false; return false;
return $status = $this->mem->getStats (); return $status = $this->mem->getStats();
} }
function printDetails() { function printDetails ()
{
if ((! $this->connected) || ($this->class == 'filecache')) if ((! $this->connected) || ($this->class == 'filecache'))
return false; return false;
$status = $this->mem->getStats (); $status = $this->mem->getStats();
echo "<table border='1'>"; echo "<table border='1'>";
echo "<tr><td>Memcache Server version:</td><td> " . $status ["version"] . "</td></tr>"; echo "<tr><td>Memcache Server version:</td><td> " . $status["version"] . "</td></tr>";
echo "<tr><td>Number of hours this server has been running </td><td>" . ($status ["uptime"] / 3660) . "</td></tr>"; echo "<tr><td>Number of hours this server has been running </td><td>" . ($status["uptime"] / 3660) . "</td></tr>";
echo "<tr><td>Total number of items stored by this server ever since it started </td><td>" . $status ["total_items"] . "</td></tr>"; echo "<tr><td>Total number of items stored by this server ever since it started </td><td>" . $status["total_items"] . "</td></tr>";
echo "<tr><td>Number of open connections </td><td>" . $status ["curr_connections"] . "</td></tr>"; echo "<tr><td>Number of open connections </td><td>" . $status["curr_connections"] . "</td></tr>";
echo "<tr><td>Total number of connections opened since the server started running </td><td>" . $status ["total_connections"] . "</td></tr>"; echo "<tr><td>Total number of connections opened since the server started running </td><td>" . $status["total_connections"] . "</td></tr>";
echo "<tr><td>Number of connection structures allocated by the server </td><td>" . $status ["connection_structures"] . "</td></tr>"; echo "<tr><td>Number of connection structures allocated by the server </td><td>" . $status["connection_structures"] . "</td></tr>";
echo "<tr><td>Cumulative number of retrieval requests </td><td>" . $status ["cmd_get"] . "</td></tr>"; echo "<tr><td>Cumulative number of retrieval requests </td><td>" . $status["cmd_get"] . "</td></tr>";
echo "<tr><td> Cumulative number of storage requests </td><td>" . $status ["cmd_set"] . "</td></tr>"; echo "<tr><td> Cumulative number of storage requests </td><td>" . $status["cmd_set"] . "</td></tr>";
$percCacheHit = (( real ) $status ["get_hits"] / ( real ) $status ["cmd_get"] * 100); $percCacheHit = ((real) $status["get_hits"] / (real) $status["cmd_get"] * 100);
$percCacheHit = round ( $percCacheHit, 3 ); $percCacheHit = round( $percCacheHit, 3 );
$percCacheMiss = 100 - $percCacheHit; $percCacheMiss = 100 - $percCacheHit;
echo "<tr><td>Number of keys that have been requested and found present </td><td>" . $status ["get_hits"] . " ($percCacheHit%)</td></tr>"; echo "<tr><td>Number of keys that have been requested and found present </td><td>" . $status["get_hits"] . " ($percCacheHit%)</td></tr>";
echo "<tr><td>Number of items that have been requested and not found </td><td>" . $status ["get_misses"] . "($percCacheMiss%)</td></tr>"; echo "<tr><td>Number of items that have been requested and not found </td><td>" . $status["get_misses"] . "($percCacheMiss%)</td></tr>";
$MBRead = ( real ) $status ["bytes_read"] / (1024 * 1024); $MBRead = (real) $status["bytes_read"] / (1024 * 1024);
echo "<tr><td>Total number of bytes read by this server from network </td><td>" . $MBRead . " Mega Bytes</td></tr>"; echo "<tr><td>Total number of bytes read by this server from network </td><td>" . $MBRead . " Mega Bytes</td></tr>";
$MBWrite = ( real ) $status ["bytes_written"] / (1024 * 1024); $MBWrite = (real) $status["bytes_written"] / (1024 * 1024);
echo "<tr><td>Total number of bytes sent by this server to network </td><td>" . $MBWrite . " Mega Bytes</td></tr>"; echo "<tr><td>Total number of bytes sent by this server to network </td><td>" . $MBWrite . " Mega Bytes</td></tr>";
$MBSize = ( real ) $status ["limit_maxbytes"] / (1024 * 1024); $MBSize = (real) $status["limit_maxbytes"] / (1024 * 1024);
echo "<tr><td>Number of bytes this server is allowed to use for storage.</td><td>" . $MBSize . " Mega Bytes</td></tr>"; echo "<tr><td>Number of bytes this server is allowed to use for storage.</td><td>" . $MBSize . " Mega Bytes</td></tr>";
echo "<tr><td>Number of valid items removed from cache to free memory for new items.</td><td>" . $status ["evictions"] . "</td></tr>"; echo "<tr><td>Number of valid items removed from cache to free memory for new items.</td><td>" . $status["evictions"] . "</td></tr>";
echo "</table>"; echo "</table>";
} }