Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Remove Hans accidentally committed.

This commit is contained in:
Max Neunhoeffer 2014-06-10 15:20:42 +02:00
parent 7f867a0940
commit f07cba1cc3
1 changed files with 0 additions and 79 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

79
arangod/Wal/Hans.h
View File

@ -1,79 +0,0 @@
struct LogfileInfo {
TRI_voc_fid_t _fid;
std::atomic<int> _counter = 0;
std::atomic<bool> _wantCompaction = false;
};
class MasterPointerCollector {
public:
MasterPointerCollector (TRI_voc_fid_t fid)
: _fid(fid) {
while (true) {
{
MutexLocker locker(_lock);
if (_fidMist[fid]->_refCount == 0) {
_fidMist[fid]->_wantCompaction = true;
break;
}
}
usleep(1000);
}
// refCount == 0 && wantCompaction == true
// compaction is done
MutexLocker locker(_lock);
_fidMist[fid]->_wantDeletion = true;
}
~MasterPointerCollector () {
}
};
class MasterPointerUser {
public:
MasterPointerUser (TRI_doc_mptr_t* mptr) {
TRI_voc_fid_t fid = mptr->_fid;
while (true) {
{
MutexLocker locker(_lock);
if (_fidMist[fid]->_wantDeletion ||
! exists(_fidMist[fid])) {
fid = mptr->_fid;
continue;
}
if (! _fidMist[fid]->_wantCompaction) {
++_fidMist[fid]->_refCount;
break;
}
}
usleep(1000);
}
// refCount > 0 && wantCompaction == false
// use mptr->_data etc.
}
typedef struct Mist {
bool _wantCompaction;
bool _wantDeletion;
int _refCount;
};
basics::Mutex _lock;
std::map<TRI_voc_fid_t, Mist> _fidMist;
};