Bredbandskollen CLI  1.2
Asynchronous network task engine
HttpRequestEngine Member List

This is the complete list of members for HttpRequestEngine, 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() (defined in HttpClientTask)HttpClientTaskinlinevirtual
cancelConnection(SocketConnection *s)Taskinline
connectionLost() (defined in HttpRequestEngine)HttpRequestEngineinlinevirtual
connectionReady(SocketConnection *)Taskvirtual
contents() const (defined in HttpRequestEngine)HttpRequestEngineinline
contentType() const (defined in HttpRequestEngine)HttpRequestEngineinline
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
currentUrl() const (defined in HttpRequestEngine)HttpRequestEngineinline
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
getJob(Task *task, const std::string &event_name, const std::string &url) (defined in HttpRequestEngine)HttpRequestEngineinline
getLocalAddress() (defined in HttpClientTask)HttpClientTaskinlinestatic
getMyConnections() constTask
getMyTasks(std::set< Task * > &tset)Taskinlineprotected
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
HttpRequestEngine(const std::string &name, const HttpHost &host, unsigned int min_conn=0, unsigned int max_conn=10, double tick_duration=0.5) (defined in HttpRequestEngine)HttpRequestEngineinline
httpStatus() const (defined in HttpRequestEngine)HttpRequestEngineinline
HttpTask(const std::string &name) (defined in HttpTask)HttpTaskinline
inError()Loggerinlinestatic
isActive(Socket *conn) constTaskinline
killChildTaskWhenFinished()Taskinline
label() constLoggerinline
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
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
payload(HttpClientConnection *, char *, size_t)HttpClientTaskinlinevirtual
postJob(Task *task, const std::string &event_name, const std::string &url, const std::string &data) (defined in HttpRequestEngine)HttpRequestEngine
processFinished(int pid, int wstatus)Taskprotectedvirtual
proxyHost() const (defined in HttpClientTask)HttpClientTaskinlineprotected
proxyPort() const (defined in HttpClientTask)HttpClientTaskinlineprotected
redoJob() (defined in HttpRequestEngine)HttpRequestEngineinline
redoJob(const std::string &url) (defined in HttpRequestEngine)HttpRequestEngineinline
redoJob(const std::string &url, const std::string &data) (defined in HttpRequestEngine)HttpRequestEngineinline
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
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
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
startObserving(Task *to)Taskinline
Task(const std::string &task_name)Task
taskFinished(Task *t) overrideHttpRequestEnginevirtual
taskMessage(Task *task)Taskinlineprotectedvirtual
terminated() constTaskinlineprotected
timeAfter(double s)Loggerinlinestatic
timeMax()Loggerinlinestatic
timeNow()Loggerinlinestatic
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 *)HttpClientTaskvirtual
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 *, const std::string &msg)HttpTaskvirtual
~Task()Taskvirtual