blob: 896ec85d4dbddc2629ab6aaf8d81163c1e7a12ea (
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
|
/**
* 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 "../stdafx.h"
#include "../grid/message.h"
void jniCallback(Message& m, Message& out);
extern boost::mutex dbMutex;
extern int dbLocked;
struct dblock {
boostlock bl;
dblock() : bl(dbMutex) {
dbLocked++;
assert( dbLocked == 1 );
}
~dblock() {
dbLocked--;
assert( dbLocked == 0 );
}
};
/* a scoped release of a mutex temporarily -- like a scopedlock but reversed.
*/
struct temprelease {
boost::mutex& m;
temprelease(boost::mutex& _m) : m(_m) {
boost::detail::thread::lock_ops<boost::mutex>::unlock(m);
}
~temprelease() {
boost::detail::thread::lock_ops<boost::mutex>::lock(m);
}
};
#include "pdfile.h"
struct dbtemprelease {
string clientname;
dbtemprelease() {
if( client )
clientname = client->name;
dbLocked--;
assert( dbLocked == 0 );
boost::detail::thread::lock_ops<boost::mutex>::unlock(dbMutex);
}
~dbtemprelease() {
boost::detail::thread::lock_ops<boost::mutex>::lock(dbMutex);
dbLocked++;
assert( dbLocked == 1 );
if( clientname.empty() )
client = 0;
else
setClient(clientname.c_str());
}
};
|
