Profiler::begin() - Code Metrics - Inspection of "Initial code rework (#2)" - yiisoft/profiler - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 0ba500...61251f )

by Alexander

created 2020-01-09 10:10 UTC

Profiler::begin() A

↳ Parent: Profiler

Complexity

Conditions	2
Paths	2

Size

Total Lines	18
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	12
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	11
c	1
b	0
f	0
dl	0
loc	18
ccs	12
cts	12
cp	1
rs	9.9
cc	2
nc	2
nop	2
crap	2

<?php
declare(strict_types=1);

namespace Yiisoft\Profiler;

use Psr\Log\LogLevel;
use Psr\Log\LoggerInterface;

/**
 * Profiler provides profiling support. It stores profiling messages in the memory and sends them to different targets
 * according to {@see targets}.
 *
 * For more details and usage information on Profiler, see the [guide article on profiling](guide:runtime-profiling)
 */
class Profiler implements ProfilerInterface
{
    /**
     * @var bool whether to profiler is enabled. Defaults to true.
     * You may use this field to disable writing of the profiling messages and thus save the memory usage.
     */
    private bool $enabled = true;

    /**
     * @var array[] complete profiling messages.
     * Each message has a following keys:
     *
     * - token: string, profiling token.
     * - category: string, message category.
     * - nestedLevel: int, profiling message nested level.
     * - beginTime: float, profiling begin timestamp obtained by microtime(true).
     * - endTime: float, profiling end timestamp obtained by microtime(true).
     * - duration: float, profiling block duration in milliseconds.
     * - beginMemory: int, memory usage at the beginning of profile block in bytes, obtained by `memory_get_usage()`.
     * - endMemory: int, memory usage at the end of profile block in bytes, obtained by `memory_get_usage()`.
     * - memoryDiff: int, a diff between 'endMemory' and 'beginMemory'.
     */
    private array $messages = [];

    /**
     * @var LoggerInterface logger to be used for message export.
     */
    private LoggerInterface $logger;

    /**
     * @var array pending profiling messages, e.g. the ones which have begun but not ended yet.
     */
    private array $pendingMessages = [];

    /**
     * @var int current profiling messages nested level.
     */
    private int $nestedLevel = 0;

    /**
     * @var array|Target[] the profiling targets. Each array element represents a single {@see Target|profiling target}
     * instance or the configuration for creating the profiling target instance.
     */
    private array $targets = [];

    /**
     * @var bool whether {@see targets} have been initialized, e.g. ensured to be objects.
     */
    private bool $isTargetsInitialized = false;


    /**
     * Initializes the profiler by registering {@see flush()} as a shutdown function.
     */
    public function __construct(LoggerInterface $logger)
    {
        $this->logger = $logger;
        register_shutdown_function([$this, 'flush']);
    }

    /**
     * @return bool the profile enabled.
     *
     * {@see enabled}
     */
    public function getEnabled(): bool
    {
        return $this->enabled;
    }

    /**
     * @return array the messages profiler.
     */
    public function getMessages(): array
    {
        return $this->messages;
    }

    /**
     * @return Target[] the profiling targets. Each array element represents a single {@see Target|profiling target}
     * instance.
     */
    public function getTargets(): array
    {
        if (!$this->isTargetsInitialized) {
            foreach ($this->targets as $name => $target) {
                if (!$target instanceof Target) {
                    $this->targets[$name] = new $target['__class']($target['logger'], $target['level']);
                }
            }
            $this->isTargetsInitialized = true;
        }

        return $this->targets;
    }

    /**
     * Set the profiler enabled or disabled.
     *
     * @param bool $value
     *
     * @return void
     *
     * {@see enabled}
     */
    public function setEnabled(bool $value): void
    {
        $this->enabled = $value;
    }

    /**
     * Set messages profiler.
     *
     * @param array $value
     *
     * @return void
     *
     * {@see messages}
     */
    public function setMessages(array $value): void
    {
        $this->messages = $value;

        $this->dispatch($this->messages);
    }

    /**
     * @param array|Target[] $targets the profiling targets. Each array element represents a single
     * {@see Target|profiling target} instance or the configuration for creating the profiling target instance.
     */
    public function setTargets(array $targets): void
    {
        $this->targets = $targets;
        $this->isTargetsInitialized = false;
    }

    /**
     * Adds extra target to {@see targets}.
     *
     * @param Target|array $target the log target instance or its DI compatible configuration.
     * @param string|null $name array key to be used to store target, if `null` is given target will be append
     * to the end of the array by natural integer key.
     */
    public function addTarget($target, ?string $name = null): void
    {
        if (!$target instanceof Target) {
            $this->isTargetsInitialized = false;
        }

        if ($name === null) {
            $this->targets[] = $target;
        } else {
            $this->targets[$name] = $target;
        }
    }

    public function begin(string $token, array $context = []): void
    {
        if (!$this->enabled) {
            return;
        }

        $category = $context['category'] ?? 'application';

        $message = array_merge($context, [
            'token' => $token,
            'category' => $category,
            'nestedLevel' => $this->nestedLevel,
            'beginTime' => microtime(true),
            'beginMemory' => memory_get_usage(),
        ]);

        $this->pendingMessages[$category][$token][] = $message;
        $this->nestedLevel++;
    }

    public function end(string $token, array $context = []): void
    {
        if (!$this->enabled) {
            return;
        }

        $category = $context['category'] ?? 'application';

        if (empty($this->pendingMessages[$category][$token])) {
            throw new \InvalidArgumentException(
                'Unexpected ' . static::class .
                '::end() call for category "' .
                $category .
                '" token "' .
                $token . '". A matching begin() is not found.'
            );
        }

        $message = array_pop($this->pendingMessages[$category][$token]);
        if (empty($this->pendingMessages[$category][$token])) {
            unset($this->pendingMessages[$category][$token]);

            if (empty($this->pendingMessages[$category])) {
                unset($this->pendingMessages[$category]);
            }
        }

        $message = array_merge(
            $message,
            $context,
            [
                'endTime' => microtime(true),
                'endMemory' => memory_get_usage(),
            ]
        );

        $message['duration'] = $message['endTime'] - $message['beginTime'];
        $message['memoryDiff'] = $message['endMemory'] - $message['beginMemory'];

        $this->messages[] = $message;
        $this->nestedLevel--;
    }

    public function flush(): void
    {
        foreach ($this->pendingMessages as $category => $categoryMessages) {
            foreach ($categoryMessages as $token => $messages) {
                if (!empty($messages)) {
                    $this->logger->log(
                        LogLevel::WARNING,
                        'Unclosed profiling entry detected: category "' . $category . '" token "' . $token . '"' . ' ' .
                        __METHOD__
                    );
                }
            }
        }

        $this->pendingMessages = [];
        $this->nestedLevel = 0;

        if (empty($this->messages)) {
            return;
        }

        $messages = $this->messages;

        // new messages could appear while the existing ones are being handled by targets
        $this->messages = [];

        $this->dispatch($messages);
    }

    /**
     * Dispatches the profiling messages to {@see targets}.
     *
     * @param array $messages the profiling messages.
     */
    protected function dispatch(array $messages): void
    {
        foreach ($this->getTargets() as $target) {
            $target->collect($messages);
        }
    }
}


1		<?php
2		declare(strict_types=1);
3
4		namespace Yiisoft\Profiler;
5
6		use Psr\Log\LogLevel;
7		use Psr\Log\LoggerInterface;
8
9		/**
10		* Profiler provides profiling support. It stores profiling messages in the memory and sends them to different targets
11		* according to {@see targets}.
12		*
13		* For more details and usage information on Profiler, see the [guide article on profiling](guide:runtime-profiling)
14		*/
15		class Profiler implements ProfilerInterface
16		{
17		/**
18		* @var bool whether to profiler is enabled. Defaults to true.
19		* You may use this field to disable writing of the profiling messages and thus save the memory usage.
20		*/
21		private bool $enabled = true;
22
23		/**
24		* @var array[] complete profiling messages.
25		* Each message has a following keys:
26		*
27		* - token: string, profiling token.
28		* - category: string, message category.
29		* - nestedLevel: int, profiling message nested level.
30		* - beginTime: float, profiling begin timestamp obtained by microtime(true).
31		* - endTime: float, profiling end timestamp obtained by microtime(true).
32		* - duration: float, profiling block duration in milliseconds.
33		* - beginMemory: int, memory usage at the beginning of profile block in bytes, obtained by `memory_get_usage()`.
34		* - endMemory: int, memory usage at the end of profile block in bytes, obtained by `memory_get_usage()`.
35		* - memoryDiff: int, a diff between 'endMemory' and 'beginMemory'.
36		*/
37		private array $messages = [];
38
39		/**
40		* @var LoggerInterface logger to be used for message export.
41		*/
42		private LoggerInterface $logger;
43
44		/**
45		* @var array pending profiling messages, e.g. the ones which have begun but not ended yet.
46		*/
47		private array $pendingMessages = [];
48
49		/**
50		* @var int current profiling messages nested level.
51		*/
52		private int $nestedLevel = 0;
53
54		/**
55		* @var array\|Target[] the profiling targets. Each array element represents a single {@see Target\|profiling target}
56		* instance or the configuration for creating the profiling target instance.
57		*/
58		private array $targets = [];
59
60		/**
61		* @var bool whether {@see targets} have been initialized, e.g. ensured to be objects.
62		*/
63		private bool $isTargetsInitialized = false;
64
65
66		/**
67		* Initializes the profiler by registering {@see flush()} as a shutdown function.
68		*/
69	4	public function __construct(LoggerInterface $logger)
70		{
71	4	$this->logger = $logger;
72	4	register_shutdown_function([$this, 'flush']);
73		}
74
75		/**
76		* @return bool the profile enabled.
77		*
78		* {@see enabled}
79		*/
80		public function getEnabled(): bool
81		{
82		return $this->enabled;
83		}
84
85		/**
86		* @return array the messages profiler.
87		*/
88	3	public function getMessages(): array
89		{
90	3	return $this->messages;
91		}
92
93		/**
94		* @return Target[] the profiling targets. Each array element represents a single {@see Target\|profiling target}
95		* instance.
96		*/
97	2	public function getTargets(): array
98		{
99	2	if (!$this->isTargetsInitialized) {
100	2	foreach ($this->targets as $name => $target) {
101	2	if (!$target instanceof Target) {
102	1	$this->targets[$name] = new $target['__class']($target['logger'], $target['level']);
103		}
104		}
105	2	$this->isTargetsInitialized = true;
106		}
107
108	2	return $this->targets;
109		}
110
111		/**
112		* Set the profiler enabled or disabled.
113		*
114		* @param bool $value
115		*
116		* @return void
117		*
118		* {@see enabled}
119		*/
120	1	public function setEnabled(bool $value): void
121		{
122	1	$this->enabled = $value;
123		}
124
125		/**
126		* Set messages profiler.
127		*
128		* @param array $value
129		*
130		* @return void
131		*
132		* {@see messages}
133		*/
134		public function setMessages(array $value): void
135		{
136		$this->messages = $value;
137
138		$this->dispatch($this->messages);
139		}
140
141		/**
142		* @param array\|Target[] $targets the profiling targets. Each array element represents a single
143		* {@see Target\|profiling target} instance or the configuration for creating the profiling target instance.
144		*/
145	1	public function setTargets(array $targets): void
146		{
147	1	$this->targets = $targets;
148	1	$this->isTargetsInitialized = false;
149		}
150
151		/**
152		* Adds extra target to {@see targets}.
153		*
154		* @param Target\|array $target the log target instance or its DI compatible configuration.
155		* @param string\|null $name array key to be used to store target, if `null` is given target will be append
156		* to the end of the array by natural integer key.
157		*/
158	2	public function addTarget($target, ?string $name = null): void
159		{
160	2	if (!$target instanceof Target) {
161		$this->isTargetsInitialized = false;
162		}
163
164	2	if ($name === null) {
165	2	$this->targets[] = $target;
166		} else {
167	1	$this->targets[$name] = $target;
168		}
169		}
170
171	4	public function begin(string $token, array $context = []): void
172		{
173	4	if (!$this->enabled) {
174	1	return;
175		}
176
177	4	$category = $context['category'] ?? 'application';
178
179	4	$message = array_merge($context, [
180	4	'token' => $token,
181	4	'category' => $category,
182	4	'nestedLevel' => $this->nestedLevel,
183	4	'beginTime' => microtime(true),
184	4	'beginMemory' => memory_get_usage(),
185		]);
186
187	4	$this->pendingMessages[$category][$token][] = $message;
188	4	$this->nestedLevel++;
189		}
190
191	4	public function end(string $token, array $context = []): void
192		{
193	4	if (!$this->enabled) {
194	1	return;
195		}
196
197	4	$category = $context['category'] ?? 'application';
198
199	4	if (empty($this->pendingMessages[$category][$token])) {
200		throw new \InvalidArgumentException(
201		'Unexpected ' . static::class .
202		'::end() call for category "' .
203		$category .
204		'" token "' .
205		$token . '". A matching begin() is not found.'
206		);
207		}
208
209	4	$message = array_pop($this->pendingMessages[$category][$token]);
210	4	if (empty($this->pendingMessages[$category][$token])) {
211	4	unset($this->pendingMessages[$category][$token]);
212
213	4	if (empty($this->pendingMessages[$category])) {
214	4	unset($this->pendingMessages[$category]);
215		}
216		}
217
218	4	$message = array_merge(
219	4	$message,
220		$context,
221		[
222	4	'endTime' => microtime(true),
223	4	'endMemory' => memory_get_usage(),
224		]
225		);
226
227	4	$message['duration'] = $message['endTime'] - $message['beginTime'];
228	4	$message['memoryDiff'] = $message['endMemory'] - $message['beginMemory'];
229
230	4	$this->messages[] = $message;
231	4	$this->nestedLevel--;
232		}
233
234	2	public function flush(): void
235		{
236	2	foreach ($this->pendingMessages as $category => $categoryMessages) {
237		foreach ($categoryMessages as $token => $messages) {
238		if (!empty($messages)) {
239		$this->logger->log(
240		LogLevel::WARNING,
241		'Unclosed profiling entry detected: category "' . $category . '" token "' . $token . '"' . ' ' .
242		__METHOD__
243		);
244		}
245		}
246		}
247
248	2	$this->pendingMessages = [];
249	2	$this->nestedLevel = 0;
250
251	2	if (empty($this->messages)) {
252		return;
253		}
254
255	2	$messages = $this->messages;
256
257		// new messages could appear while the existing ones are being handled by targets
258	2	$this->messages = [];
259
260	2	$this->dispatch($messages);
261		}
262
263		/**
264		* Dispatches the profiling messages to {@see targets}.
265		*
266		* @param array $messages the profiling messages.
267		*/
268	1	protected function dispatch(array $messages): void
269		{
270	1	foreach ($this->getTargets() as $target) {
271	1	$target->collect($messages);
272		}
273		}
274		}
275

yiisoft / profiler

Push — master ( 0ba500...61251f )

Profiler::begin() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like