1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
/* |
4
|
|
|
* This file is part of php-cache\cache-bundle package. |
5
|
|
|
* |
6
|
|
|
* (c) 2015 Aaron Scherer <[email protected]>, Tobias Nyholm <[email protected]> |
7
|
|
|
* |
8
|
|
|
* This source file is subject to the MIT license that is bundled |
9
|
|
|
* with this source code in the file LICENSE. |
10
|
|
|
*/ |
11
|
|
|
|
12
|
|
|
namespace Cache\CacheBundle\DataCollector; |
13
|
|
|
|
14
|
|
|
use Symfony\Component\HttpFoundation\Request; |
15
|
|
|
use Symfony\Component\HttpFoundation\Response; |
16
|
|
|
use Symfony\Component\HttpKernel\DataCollector\DataCollector; |
17
|
|
|
use Symfony\Component\VarDumper\Caster\CutStub; |
18
|
|
|
use Symfony\Component\VarDumper\Cloner\Stub; |
19
|
|
|
use Symfony\Component\VarDumper\Cloner\VarCloner; |
20
|
|
|
|
21
|
|
|
/** |
22
|
|
|
* @author Aaron Scherer <[email protected]> |
23
|
|
|
* @author Tobias Nyholm <[email protected]> |
24
|
|
|
* |
25
|
|
|
* @internal |
26
|
|
|
*/ |
27
|
|
|
class CacheDataCollector extends DataCollector |
28
|
|
|
{ |
29
|
|
|
/** |
30
|
|
|
* @type CacheProxyInterface[] |
31
|
|
|
*/ |
32
|
|
|
private $instances = []; |
33
|
|
|
|
34
|
|
|
/** |
35
|
|
|
* @type VarCloner |
36
|
|
|
*/ |
37
|
|
|
private $cloner = null; |
|
|
|
|
38
|
|
|
|
39
|
|
|
/** |
40
|
|
|
* @param string $name |
41
|
|
|
* @param CacheProxyInterface $instance |
42
|
|
|
*/ |
43
|
|
|
public function addInstance($name, CacheProxyInterface $instance) |
44
|
|
|
{ |
45
|
|
|
$this->instances[$name] = $instance; |
46
|
|
|
} |
47
|
|
|
|
48
|
|
|
/** |
49
|
|
|
* {@inheritdoc} |
50
|
|
|
*/ |
51
|
|
|
public function collect(Request $request, Response $response, \Exception $exception = null) |
52
|
|
|
{ |
53
|
|
|
$empty = ['calls' => [], 'config' => [], 'options' => [], 'statistics' => []]; |
54
|
|
|
$this->data = ['instances' => $empty, 'total' => $empty]; |
55
|
|
|
foreach ($this->instances as $name => $instance) { |
56
|
|
|
$calls = $instance->__getCalls(); |
57
|
|
|
foreach ($calls as $call) { |
58
|
|
|
if (isset($call->result)) { |
59
|
|
|
$call->result = $this->cloneData($call->result); |
60
|
|
|
} |
61
|
|
|
if (isset($call->argument)) { |
62
|
|
|
$call->argument = $this->cloneData($call->argument); |
63
|
|
|
} |
64
|
|
|
} |
65
|
|
|
$this->data['instances']['calls'][$name] = $calls; |
66
|
|
|
} |
67
|
|
|
|
68
|
|
|
$this->data['instances']['statistics'] = $this->calculateStatistics(); |
69
|
|
|
$this->data['total']['statistics'] = $this->calculateTotalStatistics(); |
70
|
|
|
} |
71
|
|
|
|
72
|
|
|
/** |
73
|
|
|
* {@inheritdoc} |
74
|
|
|
*/ |
75
|
|
|
public function reset() |
76
|
|
|
{ |
77
|
|
|
$empty = ['calls' => [], 'config' => [], 'options' => [], 'statistics' => []]; |
78
|
|
|
$this->data = ['instances' => $empty, 'total' => $empty]; |
79
|
|
|
} |
80
|
|
|
|
81
|
|
|
/** |
82
|
|
|
* To be compatible with many versions of Symfony. |
83
|
|
|
* |
84
|
|
|
* @param $var |
85
|
|
|
*/ |
86
|
|
|
private function cloneData($var) |
87
|
|
|
{ |
88
|
|
|
if (method_exists($this, 'cloneVar')) { |
89
|
|
|
// Symfony 3.2 or higher |
90
|
|
|
return $this->cloneVar($var); |
91
|
|
|
} |
92
|
|
|
|
93
|
|
|
if (null === $this->cloner) { |
94
|
|
|
$this->cloner = new VarCloner(); |
95
|
|
|
$this->cloner->setMaxItems(-1); |
96
|
|
|
$this->cloner->addCasters($this->getCloneCasters()); |
97
|
|
|
} |
98
|
|
|
|
99
|
|
|
return $this->cloner->cloneVar($var); |
100
|
|
|
} |
101
|
|
|
|
102
|
|
|
/** |
103
|
|
|
* {@inheritdoc} |
104
|
|
|
*/ |
105
|
|
|
public function getName() |
106
|
|
|
{ |
107
|
|
|
return 'php-cache'; |
108
|
|
|
} |
109
|
|
|
|
110
|
|
|
/** |
111
|
|
|
* Method returns amount of logged Cache reads: "get" calls. |
112
|
|
|
* |
113
|
|
|
* @return array |
114
|
|
|
*/ |
115
|
|
|
public function getStatistics() |
116
|
|
|
{ |
117
|
|
|
return $this->data['instances']['statistics']; |
118
|
|
|
} |
119
|
|
|
|
120
|
|
|
/** |
121
|
|
|
* Method returns the statistic totals. |
122
|
|
|
* |
123
|
|
|
* @return array |
124
|
|
|
*/ |
125
|
|
|
public function getTotals() |
126
|
|
|
{ |
127
|
|
|
return $this->data['total']['statistics']; |
128
|
|
|
} |
129
|
|
|
|
130
|
|
|
/** |
131
|
|
|
* Method returns all logged Cache call objects. |
132
|
|
|
* |
133
|
|
|
* @return mixed |
134
|
|
|
*/ |
135
|
|
|
public function getCalls() |
136
|
|
|
{ |
137
|
|
|
return $this->data['instances']['calls']; |
138
|
|
|
} |
139
|
|
|
|
140
|
|
|
/** |
141
|
|
|
* @return array |
142
|
|
|
*/ |
143
|
|
|
private function calculateStatistics() |
144
|
|
|
{ |
145
|
|
|
$statistics = []; |
146
|
|
|
foreach ($this->data['instances']['calls'] as $name => $calls) { |
147
|
|
|
$statistics[$name] = [ |
148
|
|
|
'calls' => 0, |
149
|
|
|
'time' => 0, |
150
|
|
|
'reads' => 0, |
151
|
|
|
'writes' => 0, |
152
|
|
|
'deletes' => 0, |
153
|
|
|
'hits' => 0, |
154
|
|
|
'misses' => 0, |
155
|
|
|
]; |
156
|
|
|
/** @type TraceableAdapterEvent $call */ |
157
|
|
|
foreach ($calls as $call) { |
158
|
|
|
$statistics[$name]['calls'] += 1; |
159
|
|
|
$statistics[$name]['time'] += $call->end - $call->start; |
160
|
|
|
if ('getItem' === $call->name) { |
161
|
|
|
$statistics[$name]['reads'] += 1; |
162
|
|
View Code Duplication |
if ($call->hits) { |
|
|
|
|
163
|
|
|
$statistics[$name]['hits'] += 1; |
164
|
|
|
} else { |
165
|
|
|
$statistics[$name]['misses'] += 1; |
166
|
|
|
} |
167
|
|
|
} elseif ('getItems' === $call->name) { |
168
|
|
|
$count = $call->hits + $call->misses; |
169
|
|
|
$statistics[$name]['reads'] += $count; |
170
|
|
|
$statistics[$name]['hits'] += $call->hits; |
171
|
|
|
$statistics[$name]['misses'] += $count - $call->misses; |
172
|
|
|
} elseif ('hasItem' === $call->name) { |
173
|
|
|
$statistics[$name]['reads'] += 1; |
174
|
|
View Code Duplication |
if (false === $call->result) { |
|
|
|
|
175
|
|
|
$statistics[$name]['misses'] += 1; |
176
|
|
|
} else { |
177
|
|
|
$statistics[$name]['hits'] += 1; |
178
|
|
|
} |
179
|
|
|
} elseif ('save' === $call->name) { |
180
|
|
|
$statistics[$name]['writes'] += 1; |
181
|
|
|
} elseif ('deleteItem' === $call->name) { |
182
|
|
|
$statistics[$name]['deletes'] += 1; |
183
|
|
|
} |
184
|
|
|
} |
185
|
|
|
if ($statistics[$name]['reads']) { |
186
|
|
|
$statistics[$name]['hit_read_ratio'] = round(100 * $statistics[$name]['hits'] / $statistics[$name]['reads'], 2); |
187
|
|
|
} else { |
188
|
|
|
$statistics[$name]['hit_read_ratio'] = null; |
189
|
|
|
} |
190
|
|
|
} |
191
|
|
|
|
192
|
|
|
return $statistics; |
193
|
|
|
} |
194
|
|
|
|
195
|
|
|
/** |
196
|
|
|
* @return array |
197
|
|
|
*/ |
198
|
|
|
private function calculateTotalStatistics() |
199
|
|
|
{ |
200
|
|
|
$statistics = $this->getStatistics(); |
201
|
|
|
$totals = [ |
202
|
|
|
'calls' => 0, |
203
|
|
|
'time' => 0, |
204
|
|
|
'reads' => 0, |
205
|
|
|
'writes' => 0, |
206
|
|
|
'deletes' => 0, |
207
|
|
|
'hits' => 0, |
208
|
|
|
'misses' => 0, |
209
|
|
|
]; |
210
|
|
|
foreach ($statistics as $name => $values) { |
211
|
|
|
foreach ($totals as $key => $value) { |
212
|
|
|
$totals[$key] += $statistics[$name][$key]; |
213
|
|
|
} |
214
|
|
|
} |
215
|
|
|
if ($totals['reads']) { |
216
|
|
|
$totals['hit_read_ratio'] = round(100 * $totals['hits'] / $totals['reads'], 2); |
217
|
|
|
} else { |
218
|
|
|
$totals['hit_read_ratio'] = null; |
219
|
|
|
} |
220
|
|
|
|
221
|
|
|
return $totals; |
222
|
|
|
} |
223
|
|
|
|
224
|
|
|
/** |
225
|
|
|
* @return callable[] The casters to add to the cloner |
226
|
|
|
*/ |
227
|
|
|
private function getCloneCasters() |
228
|
|
|
{ |
229
|
|
|
return [ |
230
|
|
|
'*' => function ($v, array $a, Stub $s, $isNested) { |
|
|
|
|
231
|
|
|
if (!$v instanceof Stub) { |
232
|
|
|
foreach ($a as $k => $v) { |
233
|
|
|
if (is_object($v) && !$v instanceof \DateTimeInterface && !$v instanceof Stub) { |
234
|
|
|
$a[$k] = new CutStub($v); |
235
|
|
|
} |
236
|
|
|
} |
237
|
|
|
} |
238
|
|
|
|
239
|
|
|
return $a; |
240
|
|
|
}, |
241
|
|
|
]; |
242
|
|
|
} |
243
|
|
|
} |
244
|
|
|
|