X-Git-Url: http://developer.intra2net.com/git/?p=libt2n;a=blobdiff_plain;f=src%2Fcommand_client.hxx;h=49f28199d4bb489e656f393242f51b227babdc43;hp=257b0a88dc6a0c1ccc02d93f4cad215ed3f098cf;hb=56f3994d74dbc36d10bfa83b50b016bf269ac563;hpb=a64066eb0e456c92c4c06959616443e531d4b39d diff --git a/src/command_client.hxx b/src/command_client.hxx index 257b0a8..49f2819 100644 --- a/src/command_client.hxx +++ b/src/command_client.hxx @@ -19,6 +19,9 @@ #ifndef __LIBT2N_COMMAND_CLIENT #define __LIBT2N_COMMAND_CLIENT +#include +#include + #include "client.hxx" #include "container.hxx" @@ -33,7 +36,7 @@ class command_client static const long long hello_timeout_usec_default=30000000; private: - client_connection &c; + client_connection *c; long long hello_timeout_usec; long long command_timeout_usec; @@ -42,12 +45,17 @@ class command_client std::string read_packet(const long long &usec_timeout); bool check_hello(const std::string& hellostr); + // TODO: Deny access to copy constructor or use boost::shared_ptr + std::auto_ptr constructorException; + public: - command_client(client_connection& _c, + command_client(client_connection* _c, long long _command_timeout_usec=command_timeout_usec_default, long long _hello_timeout_usec=hello_timeout_usec_default); virtual ~command_client() {} + void replace_connection(client_connection* _c); + void send_command(command* cmd, result_container &res); void set_command_timeout_usec(long long _command_timeout_usec=command_timeout_usec_default) @@ -58,6 +66,10 @@ class command_client { return command_timeout_usec; } long long get_hello_timeout_usec(void) { return hello_timeout_usec; } + bool is_connection_closed(void) + { return c->is_closed(); } + t2n_exception* get_constuctor_exception(void) + { return constructorException.get(); } }; }