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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
<?php defined('SYSPATH') OR die('No direct access allowed.');
/**
* Memcache-based Cache driver.
*
* $Id$
*
* @package Cache
* @author Kohana Team
* @copyright (c) 2007-2009 Kohana Team
* @license http://kohanaphp.com/license
*/
class Cache_Memcache_Driver extends Cache_Driver {
protected $config;
protected $backend;
protected $flags;
public function __construct($config)
{
if ( ! extension_loaded('memcache'))
throw new Cache_Exception('The memcache PHP extension must be loaded to use this driver.');
ini_set('memcache.allow_failover', (isset($config['allow_failover']) AND $config['allow_failover']) ? TRUE : FALSE);
$this->config = $config;
$this->backend = new Memcache;
$this->flags = (isset($config['compression']) AND $config['compression']) ? MEMCACHE_COMPRESSED : FALSE;
foreach ($config['servers'] as $server)
{
// Make sure all required keys are set
$server += array('host' => '127.0.0.1',
'port' => 11211,
'persistent' => FALSE,
'weight' => 1,
'timeout' => 1,
'retry_interval' => 15
);
// Add the server to the pool
$this->backend->addServer($server['host'], $server['port'], (bool) $server['persistent'], (int) $server['weight'], (int) $server['timeout'], (int) $server['retry_interval'], TRUE, array($this,'_memcache_failure_callback'));
}
}
public function _memcache_failure_callback($host, $port)
{
$this->backend->setServerParams($host, $port, 1, -1, FALSE);
Kohana_Log::add('error', __('Cache: Memcache server down: :host:::port:',array(':host:' => $host,':port:' => $port)));
}
public function set($items, $tags = NULL, $lifetime = NULL)
{
if ($lifetime !== 0)
{
// Memcache driver expects unix timestamp
$lifetime += time();
}
if ($tags !== NULL)
throw new Cache_Exception('Memcache driver does not support tags');
foreach ($items as $key => $value)
{
if (is_resource($value))
throw new Cache_Exception('Caching of resources is impossible, because resources cannot be serialised.');
if ( ! $this->backend->set($key, $value, $this->flags, $lifetime))
{
return FALSE;
}
}
return TRUE;
}
public function get($keys, $single = FALSE)
{
$items = $this->backend->get($keys);
if ($single)
{
if ($items === FALSE)
return NULL;
return (count($items) > 0) ? current($items) : NULL;
}
else
{
return ($items === FALSE) ? array() : $items;
}
}
/**
* Get cache items by tag
*/
public function get_tag($tags)
{
throw new Cache_Exception('Memcache driver does not support tags');
}
/**
* Delete cache item by key
*/
public function delete($keys)
{
foreach ($keys as $key)
{
if ( ! $this->backend->delete($key))
{
return FALSE;
}
}
return TRUE;
}
/**
* Delete cache items by tag
*/
public function delete_tag($tags)
{
throw new Cache_Exception('Memcache driver does not support tags');
}
/**
* Empty the cache
*/
public function delete_all()
{
return $this->backend->flush();
}
} // End Cache Memcache Driver
|
