appname_ | DQMNet | private |
communicate_ | DQMNet | private |
copydata(Bucket *b, const void *data, size_t len) | DQMNet | protectedstatic |
createPeer(lat::Socket *s) override | DQMImplNet< ObjType > | inlineprotectedvirtual |
DataBlob typedef | DQMNet | |
debug(bool doit) | DQMNet | |
debug_ | DQMNet | protected |
delay(int delay) | DQMNet | |
delay_ | DQMNet | private |
DirMap typedef | DQMImplNet< ObjType > | |
discard(Bucket *&b) | DQMNet | protectedstatic |
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_EFFICIENCY_PLOT | DQMNet | static |
DQM_PROP_HAS_REFERENCE | DQMNet | static |
DQM_PROP_LUMI | DQMNet | static |
DQM_PROP_MARKTODELETE | 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 | inlinestatic |
DQMImplNet(const std::string &appname="") | DQMImplNet< ObjType > | inline |
DQMNet(const std::string &appname="") | DQMNet | |
DQMNet(const DQMNet &)=delete | DQMNet | |
findObject(Peer *p, const std::string &name, Peer **owner=nullptr) override | DQMImplNet< ObjType > | inlineprotectedvirtual |
flush_ | DQMNet | private |
getPeer(lat::Socket *s) override | DQMImplNet< ObjType > | inlineprotectedvirtual |
listenToCollector(const std::string &host, int port) | DQMNet | |
lock() | DQMNet | |
lock_ | DQMNet | protected |
logme() | DQMNet | protected |
losePeer(const char *reason, Peer *peer, lat::IOSelectEvent *event, lat::Error *err=nullptr) | DQMNet | private |
makeObject(Peer *p, const std::string &name) override | DQMImplNet< ObjType > | inlineprotectedvirtual |
markObjectsDead(Peer *p) override | DQMImplNet< ObjType > | inlineprotectedvirtual |
MAX_PEER_WAITREQS | DQMNet | static |
ObjectMap typedef | DQMImplNet< ObjType > | |
onLocalNotify(lat::IOSelectEvent *ev) | DQMNet | private |
onMessage(Bucket *msg, Peer *p, unsigned char *data, size_t len) | DQMNet | protectedvirtual |
onPeerConnect(lat::IOSelectEvent *ev) | DQMNet | private |
onPeerData(lat::IOSelectEvent *ev, Peer *p) | DQMNet | private |
operator=(const DQMNet &)=delete | DQMNet | |
packQualityData(std::string &into, const QReports &qr) | DQMNet | static |
PeerMap typedef | DQMImplNet< ObjType > | |
peers_ | DQMImplNet< ObjType > | protected |
pid_ | DQMNet | private |
purgeDeadObjects(Peer *p) override | DQMImplNet< ObjType > | inlineprotectedvirtual |
QReports typedef | DQMNet | |
QValue typedef | DQMNet | |
releaseFromWait(Bucket *msg, WaitObject &w, Object *o) | DQMNet | protectedvirtual |
releaseFromWait(WaitList::iterator i, Object *o) | DQMNet | private |
releaseWaiters(const std::string &name, Object *o) | DQMNet | private |
removePeer(Peer *p, lat::Socket *s) override | DQMImplNet< ObjType > | inlineprotectedvirtual |
requestObjectData(Peer *p, const char *name, size_t len) | DQMNet | private |
run() | DQMNet | |
sel_ | DQMNet | private |
sendLocalChanges() | DQMNet | |
sendObjectListToPeer(Bucket *msg, bool all, bool clear) override | DQMImplNet< ObjType > | inlineprotectedvirtual |
sendObjectListToPeers(bool all) override | DQMImplNet< ObjType > | inlineprotectedvirtual |
sendObjectToPeer(Bucket *msg, Object &o, bool data) | DQMNet | protectedvirtual |
server_ | DQMNet | private |
setOrder(const CoreObject &a, const CoreObject &b) | DQMNet | inlinestatic |
shouldStop() | DQMNet | protectedvirtual |
shutdown() | DQMNet | |
shutdown_ | DQMNet | private |
staleObjectWaitLimit(lat::TimeSpan time) | DQMNet | |
start() | DQMNet | |
startLocalServer(int port) | DQMNet | |
startLocalServer(const char *path) | DQMNet | |
TagList typedef | DQMNet | |
unlock() | DQMNet | |
unpackQualityData(QReports &qr, uint32_t &flags, const char *from) | DQMNet | static |
updateMask(Peer *p) | DQMNet | protected |
updatePeerMasks() override | DQMImplNet< ObjType > | inlineprotectedvirtual |
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 |
~DQMImplNet() override=default | DQMImplNet< ObjType > | |
~DQMNet() | DQMNet | virtual |