00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019 #ifndef CONEXUSGTKDATAPROGRESSWATCHER_H
00020 #define CONEXUSGTKDATAPROGRESSWATCHER_H
00021
00022 #include <set>
00023 #include <map>
00024
00025 #include <conexus/endpoint.h>
00026
00027 namespace ConexusGtk {
00028
00032 class DataProgressWatcher{
00033 public:
00034 DataProgressWatcher();
00035
00036 ~DataProgressWatcher();
00037
00038 void add_endpoint( Conexus::Endpoint& endpoint, Conexus::ReadWrite readwrite=Conexus::READWRITE );
00039
00040 void remove_endpoint( Conexus::Endpoint& endpoint );
00041
00042 protected:
00043 unsigned m_data_count;
00044
00045 typedef std::set<Conexus::Endpoint*> Endpoints;
00046 typedef std::map<Conexus::Endpoint*, sigc::connection> ConnectionMap;
00047
00048 Endpoints m_endpoints;
00049
00050 ConnectionMap m_read_connections;
00051 ConnectionMap m_write_connections;
00052
00053 virtual void on_read_data( size_t n ) = 0;
00054
00055 virtual void on_write_data( size_t n ) = 0;
00056
00057 private:
00058 virtual void on_read_data_proxy( size_t n );
00059
00060 virtual void on_write_data_proxy( size_t n );
00061
00062
00063 };
00064
00065 }
00066
00067 #endif