#include <writeback_listener.h>
Classes | |
struct | WBStatus |
Static Public Member Functions | |
static void | init (const string &host) |
static void | init (DBClientBase &conn) |
static BSONObj | waitFor (ConnectionId connectionId, const OID &oid) |
Protected Member Functions | |
string | name () const |
void | run () |
WriteBackListener (const string &addr) | |
Private Attributes | |
string | _addr |
Static Private Attributes | |
static map< string, WriteBackListener * > | _cache |
static mongo::mutex | _cacheLock |
static set< string > | _seenSets |
static map< ConnectionId, WBStatus > | _seenWritebacks |
static mongo::mutex | _seenWritebacksLock |
Definition at line 36 of file writeback_listener.h.
mongo::WriteBackListener::WriteBackListener | ( | const string & | addr | ) | [protected] |
static void mongo::WriteBackListener::init | ( | const string & | host | ) | [static] |
static void mongo::WriteBackListener::init | ( | DBClientBase & | conn | ) | [static] |
string mongo::WriteBackListener::name | ( | ) | const [inline, protected, virtual] |
Implements mongo::BackgroundJob.
Definition at line 46 of file writeback_listener.h.
void mongo::WriteBackListener::run | ( | ) | [protected, virtual] |
define this to do your work. after this returns, state is set to done. after this returns, deleted if deleteSelf true.
NOTE: if run() throws, the exception will be caught within 'this' object and will ultimately lead to the BackgroundJob's thread being finished, as if run() returned.
Implements mongo::BackgroundJob.
static BSONObj mongo::WriteBackListener::waitFor | ( | ConnectionId | connectionId, | |
const OID & | oid | |||
) | [static] |
string mongo::WriteBackListener::_addr [private] |
Definition at line 50 of file writeback_listener.h.
map<string,WriteBackListener*> mongo::WriteBackListener::_cache [static, private] |
Definition at line 53 of file writeback_listener.h.
mongo::mutex mongo::WriteBackListener::_cacheLock [static, private] |
Definition at line 52 of file writeback_listener.h.
set<string> mongo::WriteBackListener::_seenSets [static, private] |
Definition at line 54 of file writeback_listener.h.
map<ConnectionId,WBStatus> mongo::WriteBackListener::_seenWritebacks [static, private] |
Definition at line 62 of file writeback_listener.h.
mongo::mutex mongo::WriteBackListener::_seenWritebacksLock [static, private] |
Definition at line 61 of file writeback_listener.h.