Bredbandskollen CLI  1.2
Asynchronous network task engine
LoadBalancer Member List

This is the complete list of members for LoadBalancer, 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
bytesReceived() constTaskinline
bytesSent() constTaskinline
cancelConnection(SocketConnection *s)Taskinline
connAdded(SocketConnection *)Taskinlinevirtual
connectionReady(SocketConnection *)Taskvirtual
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
doPass(int fd, size_t wid, ServerSocket *srv)LoadBalancerprotected
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
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
killChildTaskWhenFinished()Taskinline
label() constLoggerinline
LoadBalancer(const TaskConfig &tc) (defined in LoadBalancer)LoadBalancer
log(const std::string &label)Loggerinlinestatic
log() constLoggerinlineprotected
Logger(std::string label)Loggerinline
message() constTaskinline
msgFromConnection(SocketConnection *, const std::string &)Taskvirtual
msSince(const TimePoint &t)Loggerstatic
msTo(const TimePoint &t)Loggerstatic
new_worker(size_t i)LoadBalancerprotected
newClient(int fd, const char *, uint16_t, ServerSocket *) overrideLoadBalancervirtual
newWorkerChannel(SocketReceiver *, unsigned int)Taskinlinevirtual
nextWorker() constLoadBalancerinlineprotected
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) overrideLoadBalancervirtual
removeWorker(pid_t pid)LoadBalancerprotected
reopenLogFile(const std::string &filename)Loggerstatic
resetByteCount()Taskinline
resetLabel(const std::string &new_label)Loggerinline
resetTimer(double s)Taskinline
result() constTaskinline
rotateNextWorker()LoadBalancerinlineprotected
runProcess(const char *const argv[])Taskprotected
sayTime(std::ostream &stream)Loggerstatic
secondsSince(const TimePoint &t)Loggerstatic
secondsTo(const TimePoint &t)Loggerstatic
serverAdded(ServerSocket *)Taskinlinevirtual
serverRemoved(ServerSocket *s) overrideLoadBalancervirtual
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
setMaxRetries(unsigned int n)LoadBalancerinlineprotected
setMessage(const std::string &msg)Taskprotected
setResult(const std::string &res)Taskprotected
setTimeout()Taskinlineprotectedvirtual
start() overrideLoadBalancervirtual
startObserving(Task *to)Taskinline
Task(const std::string &task_name)Task
taskFinished(Task *task)Taskinlineprotectedvirtual
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) overrideLoadBalancervirtual
toUs(double t)Loggerinlinestatic
wakeUp()Task
wakeUpConnection(SocketConnection *s)Taskinline
warn_log(const std::string &label)Loggerinlinestatic
warn_log() constLoggerinlineprotected
wasError() constTaskinline
wasKilled() constTaskinline
wasTimeout() constTaskinline
workerConfig(unsigned int i=0) constLoadBalancerinlineprotected
workerMessage(SocketReceiver *, const char *buf, size_t len)Taskinlinevirtual
~LoadBalancer() override (defined in LoadBalancer)LoadBalancer
~Task()Taskvirtual