Bredbandskollen CLI
1.2
Asynchronous network task engine
|
This is the complete list of members for UnixDomainBridge, including all inherited members.
abortAllTasks() | Task | inlineprotected |
abortMyTasks() | Task | inlineprotected |
abortTask(Task *task) | Task | inlineprotected |
addConnected(SocketConnection *conn) | Task | protected |
addConnection(SocketConnection *conn) | Task | protected |
addNewTask(Task *task, Task *parent=nullptr) | Task | inlineprotected |
addNewThread(Task *task, const std::string &name="ThreadLoop", std::ostream *log_file=nullptr, Task *parent=nullptr) | Task | inlineprotected |
addServer(ServerSocket *conn) | Task | protected |
adoptConnection(Socket *conn) | Task | virtual |
agentTerminatedMessage(const std::string &err_msg) | BridgeTask | inlinestatic |
BridgeTask(Task *agent=nullptr) | BridgeTask | inline |
bytesReceived() const | Task | inline |
bytesSent() const | Task | inline |
cancelConnection(SocketConnection *s) | Task | inline |
connAdded(SocketConnection *) | Task | inlinevirtual |
connectionReady(SocketConnection *) override | UnixDomainBridge | virtual |
connRemoved(SocketConnection *) | Task | inlinevirtual |
createHashKey(unsigned int length=20) | Logger | static |
createWorker(std::ostream *log_file=nullptr, unsigned int channels=1, unsigned int wno=0) | Task | inlineprotected |
createWorker(const std::string &log_file_name, unsigned int channels=1, unsigned int wno=0) | Task | inlineprotected |
createWorkerTask(unsigned int wno) | Task | inlinevirtual |
dateString(time_t t=0) | Logger | static |
dateString2(time_t t=0) | Logger | static |
dbg_log() const | Logger | inlineprotected |
die() | BridgeTask | inline |
elapsed() const | Task | inline |
err_log(const std::string &label) | Logger | inlinestatic |
err_log() const | Logger | inlineprotected |
errno_log() const | Logger | protected |
executeHandler(Task *receiver, const std::string &message) | Task | inline |
finishedOK() const | Task | inline |
finishWorkerTask(unsigned int) | Task | inlinevirtual |
flushLogFile() | Logger | inlinestatic |
getAgentSocket() const | UnixDomainBridge | |
getClientSocket() const | UnixDomainBridge | |
getMyConnections() const | Task | |
getMyTasks(std::set< Task * > &tset) | Task | inlineprotected |
handleExecution(Task *sender, const std::string &message) | Task | inlineprotectedvirtual |
hasExpired(const TimePoint &t) | Logger | inlinestatic |
hasStarted() const | Task | inline |
inError() | Logger | inlinestatic |
isActive(Socket *conn) const | Task | inline |
isAgentTerminatedMessage(const std::string &msg) | BridgeTask | inlinestatic |
killChildTaskWhenFinished() | Task | inline |
label() const | Logger | inline |
log(const std::string &label) | Logger | inlinestatic |
log() const | Logger | inlineprotected |
Logger(std::string label) | Logger | inline |
message() const | Task | inline |
msgFromConnection(SocketConnection *, const std::string &msg) override | UnixDomainBridge | virtual |
msgToAgent(const std::string &method, const std::string &jsonobj="{}") | BridgeTask | inlinestatic |
msSince(const TimePoint &t) | Logger | static |
msTo(const TimePoint &t) | Logger | static |
newClient(int, const char *, uint16_t, ServerSocket *) | Task | inlinevirtual |
newWorkerChannel(SocketReceiver *, unsigned int) | Task | inlinevirtual |
notifyBytesReceived(uint64_t n) | Task | inline |
notifyBytesSent(uint64_t n) | Task | inline |
parseListen(const TaskConfig &tc, const std::string &log_label) | Task | protected |
pauseLogging() | Logger | inlinestatic |
processFinished(int pid, int wstatus) | Task | protectedvirtual |
reopenLogFile(const std::string &filename) | Logger | static |
resetByteCount() | Task | inline |
resetLabel(const std::string &new_label) | Logger | inline |
resetTimer(double s) | Task | inline |
result() const | Task | inline |
runProcess(const char *const argv[]) | Task | protected |
sayTime(std::ostream &stream) | Logger | static |
secondsSince(const TimePoint &t) | Logger | static |
secondsTo(const TimePoint &t) | Logger | static |
sendMsgToAgent(const std::string &msg) | BridgeTask | inlineprotected |
sendMsgToAgent(const std::string &method, const std::string &jsonobj) | BridgeTask | inlineprotected |
sendMsgToClient(const std::string &msg) override | UnixDomainBridge | virtual |
BridgeTask::sendMsgToClient(const std::string &method, const std::string &jsonobj) | BridgeTask | inline |
serverAdded(ServerSocket *) | Task | inlinevirtual |
serverRemoved(ServerSocket *) | Task | inlinevirtual |
setAgent(Task *agent) | BridgeTask | inline |
setError(const std::string &msg) | Task | inlineprotectedvirtual |
setLogFile(std::ostream &stream) | Logger | static |
setLogLimit(unsigned int loglines=0, unsigned int warnlines=0, unsigned int errlines=0) | Logger | static |
setMessage(const std::string &msg) | Task | protected |
setResult(const std::string &res) | Task | protected |
setTimeout() | Task | inlineprotectedvirtual |
start() override | UnixDomainBridge | virtual |
startObserving(Task *to) | Task | inline |
Task(const std::string &task_name) | Task | |
taskFinished(Task *task) override | BridgeTask | inlinevirtual |
taskMessage(Task *task) | Task | inlineprotectedvirtual |
terminated() const | Task | inlineprotected |
timeAfter(double s) | Logger | inlinestatic |
timeMax() | Logger | inlinestatic |
timeNow() | Logger | inlinestatic |
timerEvent() | Task | inlinevirtual |
tlsSetKey(ServerSocket *conn, const std::string &crt_path, const std::string &key_path, const std::string &password) | Task | inlineprotectedvirtual |
toUs(double t) | Logger | inlinestatic |
UnixDomainBridge(Task *agent=nullptr) | UnixDomainBridge | |
wakeUp() | Task | |
wakeUpConnection(SocketConnection *s) | Task | inline |
warn_log(const std::string &label) | Logger | inlinestatic |
warn_log() const | Logger | inlineprotected |
wasError() const | Task | inline |
wasKilled() const | Task | inline |
wasTimeout() const | Task | inline |
workerMessage(SocketReceiver *, const char *buf, size_t len) | Task | inlinevirtual |
~BridgeTask() override (defined in BridgeTask) | BridgeTask | virtual |
~Task() | Task | virtual |