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
|
// lockstat.cpp
/**
* Copyright (C) 2008 10gen Inc.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License, version 3,
* as published by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "mongo/pch.h"
#include "lockstat.h"
#include "mongo/db/jsobj.h"
namespace mongo {
BSONObj LockStat::report() const {
BSONObjBuilder b;
BSONObjBuilder t( b.subobjStart( "timeLockedMicros" ) );
_append( b , timeLocked );
t.done();
BSONObjBuilder a( b.subobjStart( "timeAcquiringMicros" ) );
_append( a , timeAcquiring );
a.done();
return b.obj();
}
void LockStat::report( StringBuilder& builder ) const {
bool prefixPrinted = false;
for ( int i=0; i < N; i++ ) {
if ( timeLocked[i].load() == 0 )
continue;
if ( ! prefixPrinted ) {
builder << "locks(micros)";
prefixPrinted = true;
}
builder << ' ' << nameFor( i ) << ':' << timeLocked[i].load();
}
}
void LockStat::_append( BSONObjBuilder& builder, const AtomicInt64* data ) {
if ( data[0].load() || data[1].load() ) {
builder.append( "R" , data[0].load() );
builder.append( "W" , data[1].load() );
}
if ( data[2].load() || data[3].load() ) {
builder.append( "r" , data[2].load() );
builder.append( "w" , data[3].load() );
}
}
unsigned LockStat::mapNo(char type) {
switch( type ) {
case 'R' : return 0;
case 'W' : return 1;
case 'r' : return 2;
case 'w' : return 3;
default: ;
}
fassert(16146,false);
return 0;
}
char LockStat::nameFor(unsigned offset) {
switch ( offset ) {
case 0: return 'R';
case 1: return 'W';
case 2: return 'r';
case 3: return 'w';
}
fassertFailed(16339);
}
void LockStat::recordAcquireTimeMicros( char type , long long micros ) {
timeAcquiring[mapNo(type)].fetchAndAdd( micros );
}
void LockStat::recordLockTimeMicros( char type , long long micros ) {
timeLocked[mapNo(type)].fetchAndAdd( micros );
}
void LockStat::reset() {
for ( int i = 0; i < N; i++ ) {
timeAcquiring[i].store(0);
timeLocked[i].store(0);
}
}
}
|
