32 enum BufferedSocketState
47 enum BufferedSocketError
96 virtual void Tick(time_t now);
109 std::deque<std::string> sendq;
118 inline Module* GetIOHook();
119 inline void AddIOHook(
Module* m);
120 inline void DelIOHook();
124 virtual void HandleEvent(EventType et,
int errornum = 0);
126 virtual void DoRead();
128 virtual void DoWrite();
131 void SetError(
const std::string& err) {
if (error.empty()) error = err; }
134 const std::string&
getError()
const {
return error; }
139 virtual void OnError(BufferedSocketError e) = 0;
143 void WriteData(
const std::string& data);
149 bool GetNextLine(std::string& line,
char delim =
'\n');
156 virtual void Close();
202 void DoConnect(
const std::string &ipaddr,
int aport,
unsigned long maxtime,
const std::string &connectbindip);
207 virtual void OnConnected();
223 virtual void OnTimeout();
229 BufferedSocketError BeginConnect(
const std::string &ipaddr,
int aport,
unsigned long maxtime,
const std::string &connectbindip);
234 inline Module* StreamSocket::GetIOHook() {
return IOHook; }
235 inline void StreamSocket::AddIOHook(
Module* m) { IOHook = m; }
236 inline void StreamSocket::DelIOHook() { IOHook = NULL; }
BufferedSocketState state
Definition: inspsocket.h:181
virtual void OnDataReady()=0
virtual void HandleEvent(EventType et, int errornum=0)=0
virtual CullResult cull()
Definition: base.cpp:34
Definition: socketengine.h:165
const std::string & getError() const
Definition: inspsocket.h:134
Definition: inspsocket.h:104
void SetError(const std::string &err)
Definition: inspsocket.h:131
virtual void OnDataReady()=0
Definition: inspsocket.h:170
virtual void OnError(BufferedSocketError e)=0
Definition: inspsocket.h:75
SocketTimeout(int fd, BufferedSocket *thesock, long secs_from_now, time_t now)
Definition: inspsocket.h:92
Definition: modules.h:351
virtual void Tick(time_t TIME)=0
size_t getSendQSize() const
Definition: inspsocket.h:151
virtual void DoWrite()
Definition: inspsocket.cpp:222
SocketTimeout * Timeout
Definition: inspsocket.h:174