Bredbandskollen CLI  1.2
Asynchronous network task engine
RpingTask Member List

This is the complete list of members for RpingTask, 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
cacheLabel() override (defined in MeasurementTask)MeasurementTaskinlinevirtual
calc_local_result() (defined in RpingTask)RpingTask
calculateLatency(std::vector< double > &samples) (defined in MeasurementTask)MeasurementTaskstatic
cancelConnection(SocketConnection *s)Taskinline
checkConnectionCount() (defined in MeasurementTask)MeasurementTaskprotected
connectionLost() (defined in MeasurementTask)MeasurementTaskinlinevirtual
connectionReady(SocketConnection *)Taskvirtual
cookieMgr() const (defined in HttpClientTask)HttpClientTaskinlineprotected
createHashKey(unsigned int length=20)Loggerstatic
createNewConnection() (defined in HttpClientTask)HttpClientTaskprotected
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
currentNoConnections() const (defined in MeasurementTask)MeasurementTaskinlineprotected
dateString(time_t t=0)Loggerstatic
dateString2(time_t t=0)Loggerstatic
dbg_log() constLoggerinlineprotected
doPost(HttpClientConnection *conn, size_t len)HttpClientTaskvirtual
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
fValue(double x) (defined in MeasurementTask)MeasurementTaskinlinestatic
getLocalAddress() (defined in HttpClientTask)HttpClientTaskinlinestatic
getMyConnections() constTask
getMyTasks(std::set< Task * > &tset)Taskinlineprotected
getNoConnections() const (defined in MeasurementTask)MeasurementTaskinlineprotected
handleExecution(Task *sender, const std::string &message)Taskinlineprotectedvirtual
hasExpired(const TimePoint &t)Loggerinlinestatic
hasStarted() constTaskinline
headerComplete(HttpClientConnection *)HttpClientTaskvirtual
HttpClientTask(const std::string &name, const HttpHost &httpserver) (defined in HttpClientTask)HttpClientTask
httpHeaderLines(const std::string &uri) constHttpClientTaskinlinevirtual
HttpTask(const std::string &name) (defined in HttpTask)HttpTaskinline
inError()Loggerinlinestatic
isActive(Socket *conn) constTaskinline
json_obj(const std::string &attr, const std::string &value) (defined in MeasurementTask)MeasurementTaskstatic
killChildTaskWhenFinished()Taskinline
label() constLoggerinline
log(const std::string &label)Loggerinlinestatic
log() constLoggerinlineprotected
Logger(std::string label)Loggerinline
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)MeasurementTaskinline
message() constTaskinline
msgFromConnection(SocketConnection *, const std::string &)Taskvirtual
msSince(const TimePoint &t)Loggerstatic
msTo(const TimePoint &t)Loggerstatic
newClient(int, const char *, uint16_t, ServerSocket *)Taskinlinevirtual
newRequest(HttpClientConnection *) overrideRpingTaskvirtual
newWorkerChannel(SocketReceiver *, unsigned int)Taskinlinevirtual
noMoreConnections() (defined in MeasurementTask)MeasurementTaskinlineprotected
notifyBytesReceived(uint64_t n)Taskinline
notifyBytesSent(uint64_t n)Taskinline
parseListen(const TaskConfig &tc, const std::string &log_label)Taskprotected
pauseLogging()Loggerinlinestatic
payload(HttpClientConnection *, char *, size_t)HttpClientTaskinlinevirtual
processFinished(int pid, int wstatus)Taskprotectedvirtual
proxyHost() const (defined in HttpClientTask)HttpClientTaskinlineprotected
proxyPort() const (defined in HttpClientTask)HttpClientTaskinlineprotected
reopenLogFile(const std::string &filename)Loggerstatic
requestComplete(HttpClientConnection *) overrideRpingTaskinlinevirtual
resetByteCount()Taskinline
resetLabel(const std::string &new_label)Loggerinline
resetTimer(double s)Taskinline
result() constTaskinline
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)RpingTaskinline
runProcess(const char *const argv[])Taskprotected
sayTime(std::ostream &stream)Loggerstatic
secondsSince(const TimePoint &t)Loggerstatic
secondsTo(const TimePoint &t)Loggerstatic
sendWsData(HttpConnection *conn)HttpTaskvirtual
serverAdded(ServerSocket *)Taskinlinevirtual
serverHost() constHttpClientTaskinline
serverRemoved(ServerSocket *)Taskinlinevirtual
setCookie(const std::string &header_line, const std::string &uri) (defined in HttpClientTask)HttpClientTaskinline
setError(const std::string &msg)Taskinlineprotectedvirtual
setLocalAddress(const std::string &addr, uint16_t iptype)HttpClientTaskstatic
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
setNoConnections(unsigned int no) (defined in MeasurementTask)MeasurementTaskinlineprotected
setResult(const std::string &res)Taskprotected
setServer(const std::string hostname, uint16_t port_number=80) (defined in HttpClientTask)HttpClientTaskinlineprotected
setTimeout()Taskinlineprotectedvirtual
setUserAgentString(const std::string &s) (defined in HttpClientTask)HttpClientTaskinline
start() overrideMeasurementTaskinlinevirtual
startObserving(Task *to)Taskinline
t() (defined in MeasurementTask)MeasurementTaskinline
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
timeout() (defined in MeasurementTask)MeasurementTaskinlineprotected
timeout_s() (defined in MeasurementTask)MeasurementTaskinlineprotected
timerEvent()Taskinlinevirtual
tlsSetKey(ServerSocket *conn, const std::string &crt_path, const std::string &key_path, const std::string &password)Taskinlineprotectedvirtual
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
websocketUpgrade(HttpClientConnection *) overrideRpingTaskvirtual
workerMessage(SocketReceiver *, const char *buf, size_t len)Taskinlinevirtual
wsBinData(HttpConnection *, const char *, size_t)HttpTaskinlinevirtual
wsBinHeader(HttpConnection *, size_t)HttpTaskinlinevirtual
wsBinMessage(HttpConnection *, const std::string &msg)HttpTaskvirtual
wsTextData(HttpConnection *, const char *, size_t)HttpTaskinlinevirtual
wsTextHeader(HttpConnection *, size_t)HttpTaskinlinevirtual
wsTextMessage(HttpConnection *conn, const std::string &msg) overrideRpingTaskvirtual
~Task()Taskvirtual