Bredbandskollen CLI  1.2
Asynchronous network task engine
UnixDomainBridge Member List

This is the complete list of members for UnixDomainBridge, including all inherited members.

abortAllTasks()Taskinlineprotected
abortMyTasks()Taskinlineprotected
abortTask(Task *task)Taskinlineprotected
addConnected(SocketConnection *conn)Taskprotected
addConnection(SocketConnection *conn)Taskprotected
addNewTask(Task *task, Task *parent=nullptr)Taskinlineprotected
addNewThread(Task *task, const std::string &name="ThreadLoop", std::ostream *log_file=nullptr, Task *parent=nullptr)Taskinlineprotected
addServer(ServerSocket *conn)Taskprotected
adoptConnection(Socket *conn)Taskvirtual
agentTerminatedMessage(const std::string &err_msg)BridgeTaskinlinestatic
BridgeTask(Task *agent=nullptr)BridgeTaskinline
bytesReceived() constTaskinline
bytesSent() constTaskinline
cancelConnection(SocketConnection *s)Taskinline
connAdded(SocketConnection *)Taskinlinevirtual
connectionReady(SocketConnection *) overrideUnixDomainBridgevirtual
connRemoved(SocketConnection *)Taskinlinevirtual
createHashKey(unsigned int length=20)Loggerstatic
createWorker(std::ostream *log_file=nullptr, unsigned int channels=1, unsigned int wno=0)Taskinlineprotected
createWorker(const std::string &log_file_name, unsigned int channels=1, unsigned int wno=0)Taskinlineprotected
createWorkerTask(unsigned int wno)Taskinlinevirtual
dateString(time_t t=0)Loggerstatic
dateString2(time_t t=0)Loggerstatic
dbg_log() constLoggerinlineprotected
die()BridgeTaskinline
elapsed() constTaskinline
err_log(const std::string &label)Loggerinlinestatic
err_log() constLoggerinlineprotected
errno_log() constLoggerprotected
executeHandler(Task *receiver, const std::string &message)Taskinline
finishedOK() constTaskinline
finishWorkerTask(unsigned int)Taskinlinevirtual
flushLogFile()Loggerinlinestatic
getAgentSocket() constUnixDomainBridge
getClientSocket() constUnixDomainBridge
getMyConnections() constTask
getMyTasks(std::set< Task * > &tset)Taskinlineprotected
handleExecution(Task *sender, const std::string &message)Taskinlineprotectedvirtual
hasExpired(const TimePoint &t)Loggerinlinestatic
hasStarted() constTaskinline
inError()Loggerinlinestatic
isActive(Socket *conn) constTaskinline
isAgentTerminatedMessage(const std::string &msg)BridgeTaskinlinestatic
killChildTaskWhenFinished()Taskinline
label() constLoggerinline
log(const std::string &label)Loggerinlinestatic
log() constLoggerinlineprotected
Logger(std::string label)Loggerinline
message() constTaskinline
msgFromConnection(SocketConnection *, const std::string &msg) overrideUnixDomainBridgevirtual
msgToAgent(const std::string &method, const std::string &jsonobj="{}")BridgeTaskinlinestatic
msSince(const TimePoint &t)Loggerstatic
msTo(const TimePoint &t)Loggerstatic
newClient(int, const char *, uint16_t, ServerSocket *)Taskinlinevirtual
newWorkerChannel(SocketReceiver *, unsigned int)Taskinlinevirtual
notifyBytesReceived(uint64_t n)Taskinline
notifyBytesSent(uint64_t n)Taskinline
parseListen(const TaskConfig &tc, const std::string &log_label)Taskprotected
pauseLogging()Loggerinlinestatic
processFinished(int pid, int wstatus)Taskprotectedvirtual
reopenLogFile(const std::string &filename)Loggerstatic
resetByteCount()Taskinline
resetLabel(const std::string &new_label)Loggerinline
resetTimer(double s)Taskinline
result() constTaskinline
runProcess(const char *const argv[])Taskprotected
sayTime(std::ostream &stream)Loggerstatic
secondsSince(const TimePoint &t)Loggerstatic
secondsTo(const TimePoint &t)Loggerstatic
sendMsgToAgent(const std::string &msg)BridgeTaskinlineprotected
sendMsgToAgent(const std::string &method, const std::string &jsonobj)BridgeTaskinlineprotected
sendMsgToClient(const std::string &msg) overrideUnixDomainBridgevirtual
BridgeTask::sendMsgToClient(const std::string &method, const std::string &jsonobj)BridgeTaskinline
serverAdded(ServerSocket *)Taskinlinevirtual
serverRemoved(ServerSocket *)Taskinlinevirtual
setAgent(Task *agent)BridgeTaskinline
setError(const std::string &msg)Taskinlineprotectedvirtual
setLogFile(std::ostream &stream)Loggerstatic
setLogLimit(unsigned int loglines=0, unsigned int warnlines=0, unsigned int errlines=0)Loggerstatic
setMessage(const std::string &msg)Taskprotected
setResult(const std::string &res)Taskprotected
setTimeout()Taskinlineprotectedvirtual
start() overrideUnixDomainBridgevirtual
startObserving(Task *to)Taskinline
Task(const std::string &task_name)Task
taskFinished(Task *task) overrideBridgeTaskinlinevirtual
taskMessage(Task *task)Taskinlineprotectedvirtual
terminated() constTaskinlineprotected
timeAfter(double s)Loggerinlinestatic
timeMax()Loggerinlinestatic
timeNow()Loggerinlinestatic
timerEvent()Taskinlinevirtual
tlsSetKey(ServerSocket *conn, const std::string &crt_path, const std::string &key_path, const std::string &password)Taskinlineprotectedvirtual
toUs(double t)Loggerinlinestatic
UnixDomainBridge(Task *agent=nullptr)UnixDomainBridge
wakeUp()Task
wakeUpConnection(SocketConnection *s)Taskinline
warn_log(const std::string &label)Loggerinlinestatic
warn_log() constLoggerinlineprotected
wasError() constTaskinline
wasKilled() constTaskinline
wasTimeout() constTaskinline
workerMessage(SocketReceiver *, const char *buf, size_t len)Taskinlinevirtual
~BridgeTask() override (defined in BridgeTask)BridgeTaskvirtual
~Task()Taskvirtual