Bredbandskollen CLI
1.2
Asynchronous network task engine
|
This is the complete list of members for LoadBalancer, 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 |
bytesReceived() const | Task | inline |
bytesSent() const | Task | inline |
cancelConnection(SocketConnection *s) | Task | inline |
connAdded(SocketConnection *) | Task | inlinevirtual |
connectionReady(SocketConnection *) | Task | 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 |
doPass(int fd, size_t wid, ServerSocket *srv) | LoadBalancer | protected |
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 |
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 |
killChildTaskWhenFinished() | Task | inline |
label() const | Logger | inline |
LoadBalancer(const TaskConfig &tc) (defined in LoadBalancer) | LoadBalancer | |
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 &) | Task | virtual |
msSince(const TimePoint &t) | Logger | static |
msTo(const TimePoint &t) | Logger | static |
new_worker(size_t i) | LoadBalancer | protected |
newClient(int fd, const char *, uint16_t, ServerSocket *) override | LoadBalancer | virtual |
newWorkerChannel(SocketReceiver *, unsigned int) | Task | inlinevirtual |
nextWorker() const | LoadBalancer | inlineprotected |
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) override | LoadBalancer | virtual |
removeWorker(pid_t pid) | LoadBalancer | protected |
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 |
rotateNextWorker() | LoadBalancer | inlineprotected |
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 |
serverAdded(ServerSocket *) | Task | inlinevirtual |
serverRemoved(ServerSocket *s) override | LoadBalancer | virtual |
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 |
setMaxRetries(unsigned int n) | LoadBalancer | inlineprotected |
setMessage(const std::string &msg) | Task | protected |
setResult(const std::string &res) | Task | protected |
setTimeout() | Task | inlineprotectedvirtual |
start() override | LoadBalancer | virtual |
startObserving(Task *to) | Task | inline |
Task(const std::string &task_name) | Task | |
taskFinished(Task *task) | Task | inlineprotectedvirtual |
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) override | LoadBalancer | virtual |
toUs(double t) | Logger | inlinestatic |
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 |
workerConfig(unsigned int i=0) const | LoadBalancer | inlineprotected |
workerMessage(SocketReceiver *, const char *buf, size_t len) | Task | inlinevirtual |
~LoadBalancer() override (defined in LoadBalancer) | LoadBalancer | |
~Task() | Task | virtual |