00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019 #ifndef CONEXUSENDPOINTSERVER_H
00020 #define CONEXUSENDPOINTSERVER_H
00021
00022 #include <conexus/server.h>
00023 #include <conexus/endpoint.h>
00024
00025 namespace Conexus
00026 {
00027
00038 class EndpointServer : public Server
00039 {
00040 public:
00041 EndpointServer();
00042
00043 virtual ~EndpointServer();
00044
00050 virtual void start();
00051
00056 virtual void start(bool use_dispatcher);
00057
00059 virtual void stop();
00060
00065 sigc::signal<void, Endpoint::pointer> signal_new_endpoint();
00066
00068 virtual const std::string& object_type() { static std::string s("Conexus::EndpointServer"); return s; }
00069
00070 protected:
00071 sigc::signal<void, Endpoint::pointer> m_signal_new_endpoint;
00072 sigc::connection m_dispatcher_connection;
00073 std::queue<Endpoint::pointer> m_endpoint_queue;
00074
00075 Glib::Mutex m_mutex_signal_endpoint;
00076 Glib::Mutex m_mutex_endpoint_queue;
00077
00078 void queue_endpoint( Endpoint::pointer endpoint );
00079 void emit_endpoints( );
00080
00081 };
00082
00083 }
00084
00085 #endif