, including all inherited members.
appname_ | DQMNet | [private] |
communicate_ | DQMNet | [private] |
copydata(Bucket *b, const void *data, size_t len) | DQMNet | [protected, static] |
createPeer(lat::Socket *s)=0 | DQMNet | [protected, pure virtual] |
DataBlob typedef | DQMNet | |
debug(bool doit) | DQMNet | |
debug_ | DQMNet | [protected] |
delay(int delay) | DQMNet | |
delay_ | DQMNet | [private] |
discard(Bucket *&b) | DQMNet | [protected, static] |
downstream_ | DQMNet | [private] |
DQM_MSG_GET_OBJECT | DQMNet | [static] |
DQM_MSG_HELLO | DQMNet | [static] |
DQM_MSG_LIST_OBJECTS | DQMNet | [static] |
DQM_MSG_UPDATE_ME | DQMNet | [static] |
DQM_PROP_ACCUMULATE | DQMNet | [static] |
DQM_PROP_DEAD | DQMNet | [static] |
DQM_PROP_HAS_REFERENCE | DQMNet | [static] |
DQM_PROP_LUMI | DQMNet | [static] |
DQM_PROP_NEW | DQMNet | [static] |
DQM_PROP_RECEIVED | DQMNet | [static] |
DQM_PROP_REPORT_ALARM | DQMNet | [static] |
DQM_PROP_REPORT_CLEAR | DQMNet | [static] |
DQM_PROP_REPORT_ERROR | DQMNet | [static] |
DQM_PROP_REPORT_MASK | DQMNet | [static] |
DQM_PROP_REPORT_OTHER | DQMNet | [static] |
DQM_PROP_REPORT_WARN | DQMNet | [static] |
DQM_PROP_RESET | DQMNet | [static] |
DQM_PROP_STALE | DQMNet | [static] |
DQM_PROP_TAGGED | DQMNet | [static] |
DQM_PROP_TYPE_DATABLOB | DQMNet | [static] |
DQM_PROP_TYPE_INT | DQMNet | [static] |
DQM_PROP_TYPE_INVALID | DQMNet | [static] |
DQM_PROP_TYPE_MASK | DQMNet | [static] |
DQM_PROP_TYPE_REAL | DQMNet | [static] |
DQM_PROP_TYPE_SCALAR | DQMNet | [static] |
DQM_PROP_TYPE_STRING | DQMNet | [static] |
DQM_PROP_TYPE_TH1D | DQMNet | [static] |
DQM_PROP_TYPE_TH1F | DQMNet | [static] |
DQM_PROP_TYPE_TH1S | DQMNet | [static] |
DQM_PROP_TYPE_TH2D | DQMNet | [static] |
DQM_PROP_TYPE_TH2F | DQMNet | [static] |
DQM_PROP_TYPE_TH2S | DQMNet | [static] |
DQM_PROP_TYPE_TH3D | DQMNet | [static] |
DQM_PROP_TYPE_TH3F | DQMNet | [static] |
DQM_PROP_TYPE_TH3S | DQMNet | [static] |
DQM_PROP_TYPE_TPROF | DQMNet | [static] |
DQM_PROP_TYPE_TPROF2D | DQMNet | [static] |
DQM_REPLY_LIST_BEGIN | DQMNet | [static] |
DQM_REPLY_LIST_END | DQMNet | [static] |
DQM_REPLY_NONE | DQMNet | [static] |
DQM_REPLY_OBJECT | DQMNet | [static] |
dqmhash(const void *key, size_t keylen) | DQMNet | [inline, static] |
DQMNet(const std::string &appname="") | DQMNet | |
DQMNet(const DQMNet &) | DQMNet | [private] |
findObject(Peer *p, const std::string &name, Peer **owner=0)=0 | DQMNet | [protected, pure virtual] |
flush_ | DQMNet | [private] |
getPeer(lat::Socket *s)=0 | DQMNet | [protected, pure virtual] |
listenToCollector(const std::string &host, int port) | DQMNet | |
lock(void) | DQMNet | |
lock_ | DQMNet | [protected] |
logme(void) | DQMNet | [protected] |
losePeer(const char *reason, Peer *peer, lat::IOSelectEvent *event, lat::Error *err=0) | DQMNet | [private] |
makeObject(Peer *p, const std::string &name)=0 | DQMNet | [protected, pure virtual] |
markObjectsDead(Peer *p)=0 | DQMNet | [protected, pure virtual] |
MAX_PEER_WAITREQS | DQMNet | [static] |
onLocalNotify(lat::IOSelectEvent *ev) | DQMNet | [private] |
onMessage(Bucket *msg, Peer *p, unsigned char *data, size_t len) | DQMNet | [protected, virtual] |
onPeerConnect(lat::IOSelectEvent *ev) | DQMNet | [private] |
onPeerData(lat::IOSelectEvent *ev, Peer *p) | DQMNet | [private] |
operator=(const DQMNet &) | DQMNet | [private] |
packQualityData(std::string &into, const QReports &qr) | DQMNet | [static] |
pid_ | DQMNet | [private] |
purgeDeadObjects(Peer *p)=0 | DQMNet | [protected, pure virtual] |
QReports typedef | DQMNet | |
releaseFromWait(Bucket *msg, WaitObject &w, Object *o) | DQMNet | [protected, virtual] |
releaseFromWait(WaitList::iterator i, Object *o) | DQMNet | [private] |
releaseWaiters(const std::string &name, Object *o) | DQMNet | [private] |
removePeer(Peer *p, lat::Socket *s)=0 | DQMNet | [protected, pure virtual] |
requestObjectData(Peer *p, const char *name, size_t len) | DQMNet | [private] |
run(void) | DQMNet | |
sel_ | DQMNet | [private] |
sendLocalChanges(void) | DQMNet | |
sendObjectListToPeer(Bucket *msg, bool all, bool clear)=0 | DQMNet | [protected, pure virtual] |
sendObjectListToPeers(bool all)=0 | DQMNet | [protected, pure virtual] |
sendObjectToPeer(Bucket *msg, Object &o, bool data) | DQMNet | [protected, virtual] |
server_ | DQMNet | [private] |
setOrder(const CoreObject &a, const CoreObject &b) | DQMNet | [inline, static] |
shouldStop(void) | DQMNet | [protected, virtual] |
shutdown(void) | DQMNet | |
shutdown_ | DQMNet | [private] |
staleObjectWaitLimit(lat::TimeSpan time) | DQMNet | |
start(void) | DQMNet | |
startLocalServer(int port) | DQMNet | |
startLocalServer(const char *path) | DQMNet | |
TagList typedef | DQMNet | |
unlock(void) | DQMNet | |
unpackQualityData(QReports &qr, uint32_t &flags, const char *from) | DQMNet | [static] |
updateMask(Peer *p) | DQMNet | [protected] |
updatePeerMasks(void)=0 | DQMNet | [protected, pure virtual] |
updateToCollector(const std::string &host, int port) | DQMNet | |
upstream_ | DQMNet | [private] |
version_ | DQMNet | [private] |
waitForData(Peer *p, const std::string &name, const std::string &info, Peer *owner) | DQMNet | [protected] |
waiting_ | DQMNet | [private] |
WaitList typedef | DQMNet | |
waitMax_ | DQMNet | [private] |
waitStale_ | DQMNet | [private] |
wakeup_ | DQMNet | [private] |
~DQMNet(void) | DQMNet | [virtual] |