dbxe
/
fusionpbx
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #1343 from moteus/cache_reuse_esl 

Change. Reuse same esl connection to send cache event and command.
This commit is contained in:
FusionPBX 2015-12-25 09:51:53 -07:00
parent 63a9a830d2 8ac7d708d3
commit 2897ab7fdd
1 changed files with 68 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

118
resources/classes/cache.php
View File

@ -33,17 +33,23 @@ class cache {
* @var string $value string to be cached * @var string $value string to be cached
*/ */
public function set($key, $value) { public function set($key, $value) {
//send a custom event // connect to event socket
//run the memcache
$fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']); $fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']);
if ($fp) { if ($fp === false) {
$command = "memcache set ".$key." ".$value;
return event_socket_request($fp, 'api '.$command);
}
else {
return false; return false;
} }
//send a custom event
//run the memcache
$command = "memcache set ".$key." ".$value;
$result = event_socket_request($fp, 'api '.$command);
//close event socket
fclose($fp);
// return result
return $result;
} }
/** /**
@ -51,17 +57,23 @@ class cache {
* @var string $key cache id * @var string $key cache id
*/ */
public function get($key) { public function get($key) {
//send a custom event // connect to event socket
//run the memcache
$fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']); $fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']);
if ($fp) { if ($fp === false) {
$command = "memcache get ".$key;
return event_socket_request($fp, 'api '.$command);
}
else {
return false; return false;
} }
//send a custom event
//run the memcache
$command = "memcache get ".$key;
$result = event_socket_request($fp, 'api '.$command);
//close event socket
fclose($fp);
// return result
return $result;
} }
/** /**
@ -69,52 +81,58 @@ class cache {
* @var string $key cache id * @var string $key cache id
*/ */
public function delete($key) { public function delete($key) {
//send a custom event // connect to event socket
$fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']); $fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']);
if ($fp) { if ($fp === false) {
$event = "sendevent CUSTOM\n";
$event .= "Event-Name: MEMCACHE\n";
$event .= "Event-Subclass: delete\n";
$event .= "API-Command: memcache\n";
$event .= "API-Command-Argument: delete ".$key."\n";
echo event_socket_request($fp, $event);
}
//run the memcache
$fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']);
if ($fp) {
$command = "memcache delete ".$key;
return event_socket_request($fp, 'api '.$command);
}
else {
return false; return false;
} }
//send a custom event
$event = "sendevent CUSTOM\n";
$event .= "Event-Name: MEMCACHE\n";
$event .= "Event-Subclass: delete\n";
$event .= "API-Command: memcache\n";
$event .= "API-Command-Argument: delete ".$key."\n";
event_socket_request($fp, $event);
//run the memcache
$command = "memcache delete ".$key;
$result = event_socket_request($fp, 'api '.$command);
//close event socket
fclose($fp);
// return result
return $result;
} }
/** /**
* Delete the entire cache * Delete the entire cache
*/ */
public function flush() { public function flush() {
//send a custom event // connect to event socket
$fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']); $fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']);
if ($fp) { if ($fp === false) {
$event = "sendevent CUSTOM\n";
$event .= "Event-Name: MEMCACHE\n";
$event .= "Event-Subclass: flush\n";
$event .= "API-Command: memcache\n";
$event .= "API-Command-Argument: flush\n";
echo event_socket_request($fp, $event);
}
//run the memcache
$fp = event_socket_create($_SESSION['event_socket_ip_address'], $_SESSION['event_socket_port'], $_SESSION['event_socket_password']);
if ($fp) {
$command = "memcache flush";
return event_socket_request($fp, 'api '.$command);
}
else {
return false; return false;
} }
//send a custom event
$event = "sendevent CUSTOM\n";
$event .= "Event-Name: MEMCACHE\n";
$event .= "Event-Subclass: flush\n";
$event .= "API-Command: memcache\n";
$event .= "API-Command-Argument: flush\n";
event_socket_request($fp, $event);
//run the memcache
$command = "memcache flush";
$result = event_socket_request($fp, 'api '.$command);
//close event socket
fclose($fp);
// return result
return $result;
} }
} }