1
# Copyright (C) 2007, 2009, 2010, 2011 Canonical Ltd
3
# This program is free software; you can redistribute it and/or modify
4
# it under the terms of the GNU General Public License as published by
5
# the Free Software Foundation; either version 2 of the License, or
6
# (at your option) any later version.
8
# This program is distributed in the hope that it will be useful,
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11
# GNU General Public License for more details.
13
# You should have received a copy of the GNU General Public License
14
# along with this program; if not, write to the Free Software
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
17
"""Tests for profiling data collection."""
21
import cPickle as pickle
27
from .. import errors, tests
33
_TXT_HEADER = " CallCount Recursive Total(ms) " + \
34
"Inline(ms) module:lineno(function)\n"
38
"A simple routine to profile."
39
result = sorted(['abc', 'def', 'ghi'])
43
"Collect and return some dummy profile data."
44
from breezy.lsprof import profile
45
ret, stats = profile(_junk_callable)
49
class TestStatsSave(tests.TestCaseInTempDir):
51
_test_needs_features = [features.lsprof_feature]
54
super(tests.TestCaseInTempDir, self).setUp()
55
self.stats = _collect_stats()
57
def _tempfile(self, ext):
59
return breezy.osutils.pathjoin(dir, "tmp_profile_data." + ext)
61
def test_stats_save_to_txt(self):
62
f = self._tempfile("txt")
64
lines = open(f).readlines()
65
self.assertEqual(lines[0], _TXT_HEADER)
67
def test_stats_save_to_callgrind(self):
68
f = self._tempfile("callgrind")
70
lines = open(f).readlines()
71
self.assertEqual(lines[0], "events: Ticks\n")
72
f = breezy.osutils.pathjoin(self.test_dir, "callgrind.out.foo")
74
lines = open(f).readlines()
75
self.assertEqual(lines[0], "events: Ticks\n")
76
# Test explicit format nommination
77
f2 = self._tempfile("txt")
78
self.stats.save(f2, format="callgrind")
79
lines2 = open(f2).readlines()
80
self.assertEqual(lines2[0], "events: Ticks\n")
82
def test_stats_save_to_pickle(self):
83
f = self._tempfile("pkl")
85
data1 = pickle.load(open(f))
86
self.assertEqual(type(data1), breezy.lsprof.Stats)
89
class TestBzrProfiler(tests.TestCase):
91
_test_needs_features = [features.lsprof_feature]
93
def test_start_call_stuff_stop(self):
94
profiler = breezy.lsprof.BzrProfiler()
101
stats = profiler.stop()
103
lines = [str(data) for data in stats.data]
104
lines = [line for line in lines if 'a_function' in line]
105
self.assertLength(1, lines)
107
def test_block_0(self):
108
# When profiler_block is 0, reentrant profile requests fail.
109
self.overrideAttr(breezy.lsprof.BzrProfiler, 'profiler_block', 0)
112
profiler = breezy.lsprof.BzrProfiler()
113
self.assertRaises(errors.BzrError, profiler.start)
114
inner_calls.append(True)
115
breezy.lsprof.profile(inner)
116
self.assertLength(1, inner_calls)
118
def test_block_1(self):
119
# When profiler_block is 1, concurrent profiles serialise.
120
# This is tested by manually acquiring the profiler lock, then
121
# starting a thread that tries to profile, and releasing the lock.
122
# We know due to test_block_0 that two profiles at once hit the lock,
123
# so while this isn't perfect (we'd want a callback on the lock being
124
# entered to allow lockstep evaluation of the actions), its good enough
125
# to be confident regressions would be caught. Alternatively, if this
126
# is flakey, a fake Lock object can be used to trace the calls made.
129
calls.append('profiled')
131
breezy.lsprof.profile(profiled)
132
calls.append('after_profiled')
133
thread = threading.Thread(target=do_profile)
134
breezy.lsprof.BzrProfiler.profiler_lock.acquire()
139
breezy.lsprof.BzrProfiler.profiler_lock.release()
142
self.assertLength(2, calls)