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
|
<?php
# Movable Type (r) Open Source (C) 2001-2012 Six Apart, Ltd.
# This program is distributed under the terms of the
# GNU General Public License, version 2.
#
# $Id$
require_once('class.basecache.php');
class CacheMemcached extends BaseCache {
private static $_server = null;
public function __construct($ttl = 0) {
parent::__construct($ttl);
if (empty(self::$_server)) {
$mt = MT::get_instance();
$servers = $mt->config('MemcachedServers');
if (!empty($servers)) {
if (extension_loaded('memcache')) {
self::$_server = new Memcache;
$this->connect($servers);
} else {
require_once('class.exception.php');
throw new MTException("Can't load memcached extension.");
}
} else {
require_once('class.exception.php');
throw new MTException("Can't load memcached extension.");
}
}
}
private function connect ($servers) {
if (is_array($servers)) {
foreach ($servers as $server) {
$this->_connect($server);
}
} else
$this->_connect($servers);
}
# param: $server = hostname:portno
private function _connect($server) {
list ($host, $port) = explode(":", $server);
if ($host == '') {
require_once('class.exception.php');
throw new MTConfigException("Can't connect to memcached server. (" . $server . ")");
}
if ($port == '')
$port = 11211; # Assigns default port.
else {
if (!is_numeric($port)) {
require_once('class.exception.php');
throw new MTConfigException("Can't connect to memcached server. (" . $server . ")");
} else
$port = intval($port);
}
# Connect to memcached server
$ret = self::$_server->connect($host, $port);
if (!$ret) {
require_once('class.exception.php');
throw new MTConfigException("Can't connect to memcached server. (" . $server . ")");
}
}
public function get ($key, $ttl = null) {
return self::$_server->get($key);
}
public function get_multi ($keys, $ttl = null) {
return self::$_server->get($key);
}
public function delete ($key) {
return self::$_server->delete($key);
}
public function add ($key, $val, $ttl = null) {
$expire = empty($ttl)
? $this->ttl
: $ttl;
return self::$_server->add($key, $val, false, $expire);
}
public function replace ($key, $val, $ttl = null) {
$expire = empty($ttl)
? $this->ttl
: $ttl;
return self::$_server->replace($key, $val, false, $expire);
}
public function set ($key, $val, $ttl = null) {
$expire = empty($ttl)
? $this->ttl
: $ttl;
return self::$_server->set($key, $val, false, $expire);
}
public function flush_all() {
return self::$_server->flush();
}
}
?>
|
