X-Git-Url: http://developer.intra2net.com/git/?p=libt2n;a=blobdiff_plain;f=src%2Fclient_wrapper.hxx;h=672308e7cd17484e3f46393eec95a8de654aa52f;hp=4bd15406b853e04d099b446704a3658b0a0d15df;hb=e1614a6d1d9c022b83c0aa8cdb948bd7dc98ff23;hpb=ffbbf9abeb195a4017c1ede383cc9ab906aa4a0c diff --git a/src/client_wrapper.hxx b/src/client_wrapper.hxx index 4bd1540..672308e 100644 --- a/src/client_wrapper.hxx +++ b/src/client_wrapper.hxx @@ -38,27 +38,47 @@ namespace libt2n class ConnectionWrapper { - public: + private: + long long command_timeout_usec; + long long hello_timeout_usec; - virtual client_connection* get_connection()=0; + protected: + log_level_values log_level; + std::ostream *logstream; + void set_logging_on_connection(client_connection& c); - virtual long long get_command_timeout_usec(void) - { - return command_client::command_timeout_usec_default; - } + public: + ConnectionWrapper() + : log_level(none), logstream(NULL), + command_timeout_usec(command_client::command_timeout_usec_default), + hello_timeout_usec(command_client::hello_timeout_usec_default) + { } - virtual long long get_hello_timeout_usec(void) - { - return command_client::hello_timeout_usec_default; - } + virtual ~ConnectionWrapper() + { } + + virtual client_connection* get_connection()=0; virtual void handle(command_client* stubBase, boost::function< void() > f) { f(); } - virtual ~ConnectionWrapper() - { } + long long get_command_timeout_usec(void) + { return command_timeout_usec; } + + void set_command_timeout_usec(long long _command_timeout_usec) + { command_timeout_usec=_command_timeout_usec; } + + long long get_hello_timeout_usec(void) + { return hello_timeout_usec; } + + void set_hello_timeout_usec(long long _hello_timeout_usec) + { hello_timeout_usec=_hello_timeout_usec; } + + void set_logging(std::ostream *_logstream, log_level_values _log_level); + + std::ostream* get_logstream(log_level_values level); }; // contains the internal stuff needed for T2nWrapper @@ -188,7 +208,7 @@ class T2nSingletonWrapper : public T2nSingletonWrapperMessages if (SingletonObject.get() != NULL) SingletonObject.reset(); } - static ConnectionWrapper* get_connection(void) + static ConnectionWrapper* get_connection_wrapper(void) { return WrappedConnection.get(); } static void ensure_singleton_there(void)