ApcEngine.php 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183
  1. <?php
  2. /**
  3. * APC storage engine for cache.
  4. *
  5. *
  6. * PHP 5
  7. *
  8. * CakePHP(tm) : Rapid Development Framework (http://cakephp.org)
  9. * Copyright 2005-2012, Cake Software Foundation, Inc. (http://cakefoundation.org)
  10. *
  11. * Licensed under The MIT License
  12. * Redistributions of files must retain the above copyright notice.
  13. *
  14. * @copyright Copyright 2005-2012, Cake Software Foundation, Inc. (http://cakefoundation.org)
  15. * @link http://cakephp.org CakePHP(tm) Project
  16. * @package Cake.Cache.Engine
  17. * @since CakePHP(tm) v 1.2.0.4933
  18. * @license MIT License (http://www.opensource.org/licenses/mit-license.php)
  19. */
  20. /**
  21. * APC storage engine for cache
  22. *
  23. * @package Cake.Cache.Engine
  24. */
  25. class ApcEngine extends CacheEngine {
  26. /**
  27. * Contains the compiled group names
  28. * (prefixed witht the global configuration prefix)
  29. *
  30. * @var array
  31. **/
  32. protected $_compiledGroupNames = array();
  33. /**
  34. * Initialize the Cache Engine
  35. *
  36. * Called automatically by the cache frontend
  37. * To reinitialize the settings call Cache::engine('EngineName', [optional] settings = array());
  38. *
  39. * @param array $settings array of setting for the engine
  40. * @return boolean True if the engine has been successfully initialized, false if not
  41. * @see CacheEngine::__defaults
  42. */
  43. public function init($settings = array()) {
  44. parent::init(array_merge(array('engine' => 'Apc', 'prefix' => Inflector::slug(APP_DIR) . '_'), $settings));
  45. return function_exists('apc_dec');
  46. }
  47. /**
  48. * Write data for key into cache
  49. *
  50. * @param string $key Identifier for the data
  51. * @param mixed $value Data to be cached
  52. * @param integer $duration How long to cache the data, in seconds
  53. * @return boolean True if the data was successfully cached, false on failure
  54. */
  55. public function write($key, $value, $duration) {
  56. if ($duration == 0) {
  57. $expires = 0;
  58. } else {
  59. $expires = time() + $duration;
  60. }
  61. apc_store($key . '_expires', $expires, $duration);
  62. return apc_store($key, $value, $duration);
  63. }
  64. /**
  65. * Read a key from the cache
  66. *
  67. * @param string $key Identifier for the data
  68. * @return mixed The cached data, or false if the data doesn't exist, has expired, or if there was an error fetching it
  69. */
  70. public function read($key) {
  71. $time = time();
  72. $cachetime = intval(apc_fetch($key . '_expires'));
  73. if ($cachetime !== 0 && ($cachetime < $time || ($time + $this->settings['duration']) < $cachetime)) {
  74. return false;
  75. }
  76. return apc_fetch($key);
  77. }
  78. /**
  79. * Increments the value of an integer cached key
  80. *
  81. * @param string $key Identifier for the data
  82. * @param integer $offset How much to increment
  83. * @return New incremented value, false otherwise
  84. */
  85. public function increment($key, $offset = 1) {
  86. return apc_inc($key, $offset);
  87. }
  88. /**
  89. * Decrements the value of an integer cached key
  90. *
  91. * @param string $key Identifier for the data
  92. * @param integer $offset How much to subtract
  93. * @return New decremented value, false otherwise
  94. */
  95. public function decrement($key, $offset = 1) {
  96. return apc_dec($key, $offset);
  97. }
  98. /**
  99. * Delete a key from the cache
  100. *
  101. * @param string $key Identifier for the data
  102. * @return boolean True if the value was successfully deleted, false if it didn't exist or couldn't be removed
  103. */
  104. public function delete($key) {
  105. return apc_delete($key);
  106. }
  107. /**
  108. * Delete all keys from the cache. This will clear every cache config using APC.
  109. *
  110. * @param boolean $check If true, nothing will be cleared, as entries are removed
  111. * from APC as they expired. This flag is really only used by FileEngine.
  112. * @return boolean True Returns true.
  113. */
  114. public function clear($check) {
  115. if ($check) {
  116. return true;
  117. }
  118. $info = apc_cache_info('user');
  119. $cacheKeys = $info['cache_list'];
  120. unset($info);
  121. foreach ($cacheKeys as $key) {
  122. if (strpos($key['info'], $this->settings['prefix']) === 0) {
  123. apc_delete($key['info']);
  124. }
  125. }
  126. return true;
  127. }
  128. /**
  129. * Returns the `group value` for each of the configured groups
  130. * If the group initial value was not found, then it initializes
  131. * the group accordingly.
  132. *
  133. * @return array
  134. **/
  135. public function groups() {
  136. $groups = $this->_compiledGroupNames;
  137. if (empty($groups)) {
  138. foreach ($this->settings['groups'] as $group) {
  139. $groups[] = $this->settings['prefix'] . $group;
  140. }
  141. $this->_compiledGroupNames = $groups;
  142. }
  143. $groups = apc_fetch($groups);
  144. if (count($groups) !== count($this->settings['groups'])) {
  145. foreach ($this->_compiledGroupNames as $group) {
  146. if (!isset($groups[$group])) {
  147. apc_store($group, 1);
  148. $groups[$group] = 1;
  149. }
  150. }
  151. ksort($groups);
  152. }
  153. $result = array();
  154. foreach ($groups as $group => $value) {
  155. $result[] = $group . $value;
  156. }
  157. return $result;
  158. }
  159. /**
  160. * Increments the group value to simulate deletion of all keys under a group
  161. * old values will remain in storage until they expire.
  162. *
  163. * @return boolean success
  164. **/
  165. public function clearGroup($group) {
  166. apc_inc($this->settings['prefix'] . $group, 1, $success);
  167. return $success;
  168. }
  169. }