|
1548.4.113
by Zimin
remove table lock, add FilesystemLock to this storage engine |
1 |
/*
|
2 |
Copyright (C) 2010 Zimin
|
|
3 |
||
4 |
This program is free software; you can redistribute it and/or
|
|
5 |
modify it under the terms of the GNU General Public License
|
|
6 |
as published by the Free Software Foundation; either version 2
|
|
7 |
of the License, or (at your option) any later version.
|
|
8 |
||
9 |
This program is distributed in the hope that it will be useful,
|
|
10 |
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
11 |
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
12 |
GNU General Public License for more details.
|
|
13 |
||
14 |
You should have received a copy of the GNU General Public License
|
|
15 |
along with this program; if not, write to the Free Software
|
|
16 |
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
17 |
*/
|
|
18 |
||
|
1548.4.120
by Zimin
modify macros to be in line with the change of the filesystem directory name |
19 |
#ifndef PLUGIN_FILESYSTEM_ENGINE_FILESYSTEMLOCK_H
|
20 |
#define PLUGIN_FILESYSTEM_ENGINE_FILESYSTEMLOCK_H
|
|
|
1548.4.113
by Zimin
remove table lock, add FilesystemLock to this storage engine |
21 |
|
|
1548.4.115
by Zimin
use RAII techniques to remove several pthread_mutex_unlock() statement. |
22 |
#include <pthread.h> |
23 |
||
|
1548.4.113
by Zimin
remove table lock, add FilesystemLock to this storage engine |
24 |
class FilesystemLock |
25 |
{
|
|
26 |
public: |
|
27 |
FilesystemLock(); |
|
28 |
~FilesystemLock(); |
|
29 |
||
30 |
void scan_begin(); |
|
31 |
void scan_end(); |
|
32 |
void scan_update_begin(); |
|
33 |
void scan_update_end(); |
|
34 |
private: |
|
35 |
pthread_cond_t condition; |
|
36 |
pthread_mutex_t mutex; |
|
37 |
int scanner_count; |
|
38 |
int updater_count; |
|
39 |
};
|
|
40 |
||
|
1548.4.115
by Zimin
use RAII techniques to remove several pthread_mutex_unlock() statement. |
41 |
class Guard |
42 |
{
|
|
43 |
public: |
|
44 |
Guard(pthread_mutex_t& mutex) : mutex_(&mutex) |
|
45 |
{
|
|
46 |
pthread_mutex_lock(mutex_); |
|
47 |
}
|
|
48 |
||
49 |
~Guard() |
|
50 |
{
|
|
51 |
if (mutex_) |
|
52 |
{
|
|
53 |
pthread_mutex_unlock(mutex_); |
|
54 |
}
|
|
55 |
}
|
|
56 |
private: |
|
57 |
pthread_mutex_t *mutex_; |
|
58 |
};
|
|
59 |
||
|
1548.4.120
by Zimin
modify macros to be in line with the change of the filesystem directory name |
60 |
#endif /* PLUGIN_FILESYSTEM_ENGINE_FILESYSTEMLOCK_H */ |