X-Git-Url: http://developer.intra2net.com/git/?p=libt2n;a=blobdiff_plain;f=src%2Fconnection.hxx;h=2343984ae80a466142bee8a3a8f50dcf3f3ef250;hp=94506e28f0d3b5e54ef3ff667743c071700d811a;hb=8104c8f70605ee24230e5988d7bf68e3fce7465a;hpb=07e98688a1a8c3e915ce923f79261a88251a9edd diff --git a/src/connection.hxx b/src/connection.hxx index 94506e2..2343984 100644 --- a/src/connection.hxx +++ b/src/connection.hxx @@ -21,9 +21,15 @@ #include +#include + +#include "types.hxx" + namespace libt2n { +/** @brief a connection between client and server. abstact. +*/ class connection { private: @@ -31,28 +37,41 @@ class connection protected: connection() - { closed=false; } + { closed=false; } std::string buffer; - typedef unsigned int packet_size_indicator; + typedef uint32_t packet_size_indicator; packet_size_indicator bytes_available(); virtual void real_write(const std::string& data)=0; + virtual std::ostream* get_logstream(log_level_values level)=0; + public: virtual ~connection() { close(); } + /// is this connection closed or not bool is_closed() { return closed; } + /// close this connection virtual void close() { closed=true; } + /** @brief look for new data and store it in the local buffer + @param usec_timeout wait until new data is found, max timeout usecs. + -1: wait endless + NULL: no timeout + @retval true if new data was found (does not mean that the received data + is a complete packet though) + */ virtual bool fill_buffer(long long usec_timeout=-1)=0; bool get_packet(std::string& data); + + /// returns true if a complete data packet is in the buffer. retrieve it with get_packet(). bool packet_available() { return bytes_available(); }