Bredbandskollen CLI
1.2
Asynchronous network task engine
|
This is the complete list of members for RpingTask, 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 |
cacheLabel() override (defined in MeasurementTask) | MeasurementTask | inlinevirtual |
calc_local_result() (defined in RpingTask) | RpingTask | |
calculateLatency(std::vector< double > &samples) (defined in MeasurementTask) | MeasurementTask | static |
cancelConnection(SocketConnection *s) | Task | inline |
checkConnectionCount() (defined in MeasurementTask) | MeasurementTask | protected |
connectionLost() (defined in MeasurementTask) | MeasurementTask | inlinevirtual |
connectionReady(SocketConnection *) | Task | virtual |
cookieMgr() const (defined in HttpClientTask) | HttpClientTask | inlineprotected |
createHashKey(unsigned int length=20) | Logger | static |
createNewConnection() (defined in HttpClientTask) | HttpClientTask | protected |
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 |
currentNoConnections() const (defined in MeasurementTask) | MeasurementTask | inlineprotected |
dateString(time_t t=0) | Logger | static |
dateString2(time_t t=0) | Logger | static |
dbg_log() const | Logger | inlineprotected |
doPost(HttpClientConnection *conn, size_t len) | HttpClientTask | virtual |
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 |
fValue(double x) (defined in MeasurementTask) | MeasurementTask | inlinestatic |
getLocalAddress() (defined in HttpClientTask) | HttpClientTask | inlinestatic |
getMyConnections() const | Task | |
getMyTasks(std::set< Task * > &tset) | Task | inlineprotected |
getNoConnections() const (defined in MeasurementTask) | MeasurementTask | inlineprotected |
handleExecution(Task *sender, const std::string &message) | Task | inlineprotectedvirtual |
hasExpired(const TimePoint &t) | Logger | inlinestatic |
hasStarted() const | Task | inline |
headerComplete(HttpClientConnection *) | HttpClientTask | virtual |
HttpClientTask(const std::string &name, const HttpHost &httpserver) (defined in HttpClientTask) | HttpClientTask | |
httpHeaderLines(const std::string &uri) const | HttpClientTask | inlinevirtual |
HttpTask(const std::string &name) (defined in HttpTask) | HttpTask | inline |
inError() | Logger | inlinestatic |
isActive(Socket *conn) const | Task | inline |
json_obj(const std::string &attr, const std::string &value) (defined in MeasurementTask) | MeasurementTask | static |
killChildTaskWhenFinished() | Task | inline |
label() const | Logger | inline |
log(const std::string &label) | Logger | inlinestatic |
log() const | Logger | inlineprotected |
Logger(std::string label) | Logger | inline |
MeasurementTask(const std::string &name, const std::string &ticket, const HttpHost &httpserver, unsigned int no_conn=1, unsigned int max_conn=3, double timeout=25.0) (defined in MeasurementTask) | MeasurementTask | inline |
message() const | Task | inline |
msgFromConnection(SocketConnection *, const std::string &) | Task | virtual |
msSince(const TimePoint &t) | Logger | static |
msTo(const TimePoint &t) | Logger | static |
newClient(int, const char *, uint16_t, ServerSocket *) | Task | inlinevirtual |
newRequest(HttpClientConnection *) override | RpingTask | virtual |
newWorkerChannel(SocketReceiver *, unsigned int) | Task | inlinevirtual |
noMoreConnections() (defined in MeasurementTask) | MeasurementTask | 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 |
payload(HttpClientConnection *, char *, size_t) | HttpClientTask | inlinevirtual |
processFinished(int pid, int wstatus) | Task | protectedvirtual |
proxyHost() const (defined in HttpClientTask) | HttpClientTask | inlineprotected |
proxyPort() const (defined in HttpClientTask) | HttpClientTask | inlineprotected |
reopenLogFile(const std::string &filename) | Logger | static |
requestComplete(HttpClientConnection *) override | RpingTask | inlinevirtual |
resetByteCount() | Task | inline |
resetLabel(const std::string &new_label) | Logger | inline |
resetTimer(double s) | Task | inline |
result() const | Task | inline |
RpingTask(const std::string &label, const std::string &ticket_string, const HttpHost &server, unsigned int no_conn=1, unsigned int max_conn=20, double duration=25.0) (defined in RpingTask) | RpingTask | 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 |
sendWsData(HttpConnection *conn) | HttpTask | virtual |
serverAdded(ServerSocket *) | Task | inlinevirtual |
serverHost() const | HttpClientTask | inline |
serverRemoved(ServerSocket *) | Task | inlinevirtual |
setCookie(const std::string &header_line, const std::string &uri) (defined in HttpClientTask) | HttpClientTask | inline |
setError(const std::string &msg) | Task | inlineprotectedvirtual |
setLocalAddress(const std::string &addr, uint16_t iptype) | HttpClientTask | static |
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 |
setNoConnections(unsigned int no) (defined in MeasurementTask) | MeasurementTask | inlineprotected |
setResult(const std::string &res) | Task | protected |
setServer(const std::string hostname, uint16_t port_number=80) (defined in HttpClientTask) | HttpClientTask | inlineprotected |
setTimeout() | Task | inlineprotectedvirtual |
setUserAgentString(const std::string &s) (defined in HttpClientTask) | HttpClientTask | inline |
start() override | MeasurementTask | inlinevirtual |
startObserving(Task *to) | Task | inline |
t() (defined in MeasurementTask) | MeasurementTask | 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 |
timeout() (defined in MeasurementTask) | MeasurementTask | inlineprotected |
timeout_s() (defined in MeasurementTask) | MeasurementTask | inlineprotected |
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 |
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 |
websocketUpgrade(HttpClientConnection *) override | RpingTask | virtual |
workerMessage(SocketReceiver *, const char *buf, size_t len) | Task | inlinevirtual |
wsBinData(HttpConnection *, const char *, size_t) | HttpTask | inlinevirtual |
wsBinHeader(HttpConnection *, size_t) | HttpTask | inlinevirtual |
wsBinMessage(HttpConnection *, const std::string &msg) | HttpTask | virtual |
wsTextData(HttpConnection *, const char *, size_t) | HttpTask | inlinevirtual |
wsTextHeader(HttpConnection *, size_t) | HttpTask | inlinevirtual |
wsTextMessage(HttpConnection *conn, const std::string &msg) override | RpingTask | virtual |
~Task() | Task | virtual |