mcproxy/mcproxy/include/proxy/timing.hpp

00001 /*
00002  * This file is part of mcproxy.
00003  *
00004  * mcproxy is free software; you can redistribute it and/or modify
00005  * it under the terms of the GNU Lesser General Public License as published by
00006  * the Free Software Foundation; either version 3 of the License, or (at your
00007  * option) any later version.
00008  *
00009  * mcproxy is distributed in the hope that it will be useful, but
00010  * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
00011  * or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public
00012  * License for more details.
00013  *
00014  * You should have received a copy of the GNU Lesser General Public License
00015  * along with mcproxy; see the file COPYING.LESSER.
00016  *
00017  * written by Sebastian Woelke, in cooperation with:
00018  * INET group, Hamburg University of Applied Sciences,
00019  * Website: http://mcproxy.realmv6.org/
00020  */
00021
00028 #ifndef TIME_HPP
00029 #define TIME_HPP
00030 
00031 #include "include/proxy/message_format.hpp"
00032
00033 #include <list>
00034 #include <boost/thread.hpp>
00035
00039 #define  TIME_POLL_INTERVAL 500 //msec
00040 
00041 class proxy_instance;
00042
00046 class timing{
00047 private:
00048      struct timehandling {
00049           timehandling(struct timeval time, proxy_instance* pr_i, proxy_msg pr_msg);
00050           struct timeval m_time;
00051           proxy_instance* m_pr_i;
00052           proxy_msg m_pr_msg;
00053      };
00054
00055      bool m_running;
00056      boost::thread* m_worker_thread;
00057      static void worker_thread(timing* t);
00058
00059      boost::mutex m_global_lock;
00060      std::list<struct timehandling> m_time_list;
00061
00062      //GOF singleton
00063      timing();
00064      timing(const timing&);
00065      timing& operator=(const timing&);
00066      ~timing();
00067 public:
00071      static timing* getInstance();
00072
00080      void add_time(int msec, proxy_instance* pr_i, proxy_msg& pr_msg);
00081
00086      void stop_all_time(proxy_instance* pr_i);
00087
00091      void start();
00092
00096      void stop();
00097
00101      void join();
00102
00106      static void test_timing();
00107 };
00108
00109
00110
00111 #endif // TIME_HPP
00112