X-Git-Url: http://developer.intra2net.com/git/?p=libt2n;a=blobdiff_plain;f=src%2Fcommand_client.hxx;h=257b0a88dc6a0c1ccc02d93f4cad215ed3f098cf;hp=640faace78703b9d0abc0dfe90646024e08c2d6c;hb=a64066eb0e456c92c4c06959616443e531d4b39d;hpb=7087e18783f91d2b889e880462d1d1da24831c28 diff --git a/src/command_client.hxx b/src/command_client.hxx index 640faac..257b0a8 100644 --- a/src/command_client.hxx +++ b/src/command_client.hxx @@ -28,15 +28,36 @@ namespace libt2n /// a client sending out commands to a server class command_client { + public: + static const long long command_timeout_usec_default=90000000; + static const long long hello_timeout_usec_default=30000000; + private: client_connection &c; + long long hello_timeout_usec; + long long command_timeout_usec; + + void read_hello(); + std::string read_packet(const long long &usec_timeout); + bool check_hello(const std::string& hellostr); + public: - command_client(client_connection& _c) - : c(_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 send_command(command* cmd, result_container &res); + + void set_command_timeout_usec(long long _command_timeout_usec=command_timeout_usec_default) + { command_timeout_usec=_command_timeout_usec; } + void set_hello_timeout_usec(long long _hello_timeout_usec=hello_timeout_usec_default) + { hello_timeout_usec=_hello_timeout_usec; } + long long get_command_timeout_usec(void) + { return command_timeout_usec; } + long long get_hello_timeout_usec(void) + { return hello_timeout_usec; } }; }