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
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
|
<?php
/**
* A wrapper class for the pure-PHP memcached client, exposing a BagOStuff interface.
*/
class MemcachedPhpBagOStuff extends BagOStuff {
/**
* @var MemCachedClientforWiki
*/
protected $client;
/**
* Constructor.
*
* Available parameters are:
* - servers: The list of IP:port combinations holding the memcached servers.
* - debug: Whether to set the debug flag in the underlying client.
* - persistent: Whether to use a persistent connection
* - compress_threshold: The minimum size an object must be before it is compressed
* - timeout: The read timeout in microseconds
* - connect_timeout: The connect timeout in seconds
*
* @param $params array
*/
function __construct( $params ) {
if ( !isset( $params['servers'] ) ) {
$params['servers'] = $GLOBALS['wgMemCachedServers'];
}
if ( !isset( $params['debug'] ) ) {
$params['debug'] = $GLOBALS['wgMemCachedDebug'];
}
if ( !isset( $params['persistent'] ) ) {
$params['persistent'] = $GLOBALS['wgMemCachedPersistent'];
}
if ( !isset( $params['compress_threshold'] ) ) {
$params['compress_threshold'] = 1500;
}
if ( !isset( $params['timeout'] ) ) {
$params['timeout'] = $GLOBALS['wgMemCachedTimeout'];
}
if ( !isset( $params['connect_timeout'] ) ) {
$params['connect_timeout'] = 0.1;
}
$this->client = new MemCachedClientforWiki( $params );
$this->client->set_servers( $params['servers'] );
$this->client->set_debug( $params['debug'] );
}
/**
* @param $debug bool
*/
public function setDebug( $debug ) {
$this->client->set_debug( $debug );
}
/**
* @param $key string
* @return Mixed
*/
public function get( $key ) {
return $this->client->get( $this->encodeKey( $key ) );
}
/**
* @param $key string
* @param $value
* @param $exptime int
* @return bool
*/
public function set( $key, $value, $exptime = 0 ) {
return $this->client->set( $this->encodeKey( $key ), $value, $exptime );
}
/**
* @param $key string
* @param $time int
* @return bool
*/
public function delete( $key, $time = 0 ) {
return $this->client->delete( $this->encodeKey( $key ), $time );
}
/**
* @param $key
* @param $timeout int
* @return
*/
public function lock( $key, $timeout = 0 ) {
return $this->client->lock( $this->encodeKey( $key ), $timeout );
}
/**
* @param $key string
* @return Mixed
*/
public function unlock( $key ) {
return $this->client->unlock( $this->encodeKey( $key ) );
}
/**
* @param $key string
* @param $value int
* @return Mixed
*/
public function add( $key, $value, $exptime = 0 ) {
return $this->client->add( $this->encodeKey( $key ), $value, $exptime );
}
/**
* @param $key string
* @param $value int
* @param $exptime
* @return Mixed
*/
public function replace( $key, $value, $exptime = 0 ) {
return $this->client->replace( $this->encodeKey( $key ), $value, $exptime );
}
/**
* @param $key string
* @param $value int
* @return Mixed
*/
public function incr( $key, $value = 1 ) {
return $this->client->incr( $this->encodeKey( $key ), $value );
}
/**
* @param $key string
* @param $value int
* @return Mixed
*/
public function decr( $key, $value = 1 ) {
return $this->client->decr( $this->encodeKey( $key ), $value );
}
/**
* Get the underlying client object. This is provided for debugging
* purposes.
*
* @return MemCachedClientforWiki
*/
public function getClient() {
return $this->client;
}
/**
* Encode a key for use on the wire inside the memcached protocol.
*
* We encode spaces and line breaks to avoid protocol errors. We encode
* the other control characters for compatibility with libmemcached
* verify_key. We leave other punctuation alone, to maximise backwards
* compatibility.
*/
public function encodeKey( $key ) {
return preg_replace_callback( '/[\x00-\x20\x25\x7f]+/',
array( $this, 'encodeKeyCallback' ), $key );
}
protected function encodeKeyCallback( $m ) {
return rawurlencode( $m[0] );
}
/**
* Decode a key encoded with encodeKey(). This is provided as a convenience
* function for debugging.
*
* @param $key string
*
* @return string
*/
public function decodeKey( $key ) {
return urldecode( $key );
}
}
|
