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
|
<?php
/**
* A cache class that replicates all writes to multiple child caches. Reads
* are implemented by reading from the caches in the order they are given in
* the configuration until a cache gives a positive result.
*/
class MultiWriteBagOStuff extends BagOStuff {
var $caches;
/**
* Constructor. Parameters are:
*
* - caches: This should have a numbered array of cache parameter
* structures, in the style required by $wgObjectCaches. See
* the documentation of $wgObjectCaches for more detail.
*
* @param $params array
*/
public function __construct( $params ) {
if ( !isset( $params['caches'] ) ) {
throw new MWException( __METHOD__.': the caches parameter is required' );
}
$this->caches = array();
foreach ( $params['caches'] as $cacheInfo ) {
$this->caches[] = ObjectCache::newFromParams( $cacheInfo );
}
}
public function setDebug( $debug ) {
$this->doWrite( 'setDebug', $debug );
}
public function get( $key ) {
foreach ( $this->caches as $cache ) {
$value = $cache->get( $key );
if ( $value !== false ) {
return $value;
}
}
return false;
}
public function set( $key, $value, $exptime = 0 ) {
return $this->doWrite( 'set', $key, $value, $exptime );
}
public function delete( $key, $time = 0 ) {
return $this->doWrite( 'delete', $key, $time );
}
public function add( $key, $value, $exptime = 0 ) {
return $this->doWrite( 'add', $key, $value, $exptime );
}
public function replace( $key, $value, $exptime = 0 ) {
return $this->doWrite( 'replace', $key, $value, $exptime );
}
public function incr( $key, $value = 1 ) {
return $this->doWrite( 'incr', $key, $value );
}
public function decr( $key, $value = 1 ) {
return $this->doWrite( 'decr', $key, $value );
}
public function lock( $key, $timeout = 0 ) {
// Lock only the first cache, to avoid deadlocks
if ( isset( $this->caches[0] ) ) {
return $this->caches[0]->lock( $key, $timeout );
} else {
return true;
}
}
public function unlock( $key ) {
if ( isset( $this->caches[0] ) ) {
return $this->caches[0]->unlock( $key );
} else {
return true;
}
}
protected function doWrite( $method /*, ... */ ) {
$ret = true;
$args = func_get_args();
array_shift( $args );
foreach ( $this->caches as $cache ) {
if ( !call_user_func_array( array( $cache, $method ), $args ) ) {
$ret = false;
}
}
return $ret;
}
/**
* Delete objects expiring before a certain date.
*
* Succeed if any of the child caches succeed.
*/
public function deleteObjectsExpiringBefore( $date, $progressCallback = false ) {
$ret = false;
foreach ( $this->caches as $cache ) {
if ( $cache->deleteObjectsExpiringBefore( $date, $progressCallback ) ) {
$ret = true;
}
}
return $ret;
}
}
|
