blob: 10d4b508ae79ca6a3040693fbd98899ebab7d00a (
plain)
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
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
|
<?php
namespace SMW\Utils;
use Onoi\BlobStore\BlobStore;
use SMW\ApplicationFactory;
/**
* Collect statistics in a provisional schema-free storage that depends on the
* availability of the cache back-end.
*
* @license GNU GPL v2+
* @since 2.5
*
* @author mwjames
*/
class BufferedStatsdCollector {
/**
* Update this version number when the serialization format
* changes.
*/
const VERSION = '0.2';
/**
* Available operations
*/
const STATS_INIT = 'init';
const STATS_INCR = 'incr';
const STATS_SET = 'set';
const STATS_MEDIAN = 'median';
/**
* Namespace occupied by the BlobStore
*/
const CACHE_NAMESPACE = 'smw:stats:store';
/**
* @var BlobStore
*/
private $blobStore;
/**
* @var string|integer
*/
private $statsdId;
/**
* @var boolean
*/
private $shouldRecord = true;
/**
* @var array
*/
private $stats = [];
/**
* Identifies an update fingerprint to compare invoked deferred updates
* against each other and filter those with the same print to avoid recording
* duplicate stats.
*
* @var string
*/
private $fingerprint = null;
/**
* @var array
*/
private $operations = [];
/**
* @since 2.5
*
* @param BlobStore $blobStore
* @param string $statsdId
*/
public function __construct( BlobStore $blobStore, $statsdId ) {
$this->blobStore = $blobStore;
$this->statsdId = $statsdId;
$this->fingerprint = $statsdId . uniqid();
}
/**
* @since 2.5
*
* @param boolean $shouldRecord
*/
public function shouldRecord( $shouldRecord ) {
$this->shouldRecord = (bool)$shouldRecord;
}
/**
* @since 2.5
*
* @return array
*/
public function getStats() {
$container = $this->blobStore->read(
md5( $this->statsdId . self::VERSION )
);
return StatsFormatter::getStatsFromFlatKey( $container->getData(), '.' );
}
/**
* @since 2.5
*
* @param string|array $key
*/
public function incr( $key ) {
if ( !isset( $this->stats[$key] ) ) {
$this->stats[$key] = 0;
}
$this->stats[$key]++;
$this->operations[$key] = self::STATS_INCR;
}
/**
* @since 2.5
*
* @param string|array $key
* @param string|integer $default
*/
public function init( $key, $default ) {
$this->stats[$key] = $default;
$this->operations[$key] = self::STATS_INIT;
}
/**
* @since 2.5
*
* @param string|array $key
* @param string|integer $value
*/
public function set( $key, $value ) {
$this->stats[$key] = $value;
$this->operations[$key] = self::STATS_SET;
}
/**
* @since 2.5
*
* @param string|array $key
* @param integer $value
*/
public function calcMedian( $key, $value ) {
if ( !isset( $this->stats[$key] ) ) {
$this->stats[$key] = $value;
} else {
$this->stats[$key] = ( $this->stats[$key] + $value ) / 2;
}
$this->operations[$key] = self::STATS_MEDIAN;
}
/**
* @since 2.5
*/
public function saveStats() {
if ( $this->stats === [] ) {
return;
}
$container = $this->blobStore->read(
md5( $this->statsdId . self::VERSION )
);
foreach ( $this->stats as $key => $value ) {
$old = $container->has( $key ) ? $container->get( $key ) : 0;
if ( $this->operations[$key] === self::STATS_INIT && $old != 0 ) {
$value = $old;
}
if ( $this->operations[$key] === self::STATS_INCR ) {
$value = $old + $value;
}
// Use as-is
// $this->operations[$key] === self::STATS_SET
if ( $this->operations[$key] === self::STATS_MEDIAN ) {
$value = $old > 0 ? ( $old + $value ) / 2 : $value;
}
$container->set( $key, $value );
}
$this->blobStore->save(
$container
);
$this->stats = [];
}
/**
* @since 2.5
*
* @param boolean $asPending
*/
public function recordStats( $asPending = false ) {
if ( $this->shouldRecord === false ) {
return $this->stats = [];
}
// #2046
// __destruct as event trigger has shown to be unreliable in a MediaWiki
// environment therefore rely on the deferred update and any caller
// that invokes the recordStats method
$deferredTransactionalUpdate = ApplicationFactory::getInstance()->newDeferredTransactionalCallableUpdate(
function() { $this->saveStats();
}
);
$deferredTransactionalUpdate->setOrigin( __METHOD__ );
$deferredTransactionalUpdate->waitOnTransactionIdle();
$deferredTransactionalUpdate->setFingerprint(
__METHOD__ . $this->fingerprint
);
$deferredTransactionalUpdate->markAsPending( $asPending );
$deferredTransactionalUpdate->pushUpdate();
}
}
|
