mcproxy/mcproxy/include/proxy/proxy.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
00030 #ifndef PROXY_HPP
00031 #define PROXY_HPP
00032 
00033 #include "include/utils/addr_storage.hpp"
00034 #include "include/utils/mroute_socket.hpp"
00035 #include "include/utils/if_prop.hpp"
00036 #include "include/proxy/proxy_instance.hpp"
00037 #include "include/proxy/receiver.hpp"
00038
00039 #include <map>
00040 #include <vector>
00041 #include <string>
00042 using namespace std;
00043
00044 //--------------------------------------------------
00050 typedef map<int, int> vif_map;
00051
00057 typedef pair<int, int> vif_pair;
00058
00059 //--------------------------------------------------
00060
00065 typedef vector<int> down_vector;
00070 typedef vector<int> down_vector;
00076 typedef map<int, down_vector > up_down_map; //map<upstream, downstreams>
00077
00083 typedef pair<int, down_vector > up_down_pair;
00084
00085 //--------------------------------------------------
00086
00092 typedef map<int,int > interface_map; //map< interface, proxyinstance{index}>
00093
00099 typedef pair<int,int> interface_pair;
00100
00101 //--------------------------------------------------
00105 #define PROXY_CONFIG_LINE_LENGTH 200
00106 
00110 #define PROXY_DEBUG_MSG_TIMEOUT 3000 //msec
00111 
00115 #define PROXY_RP_FILTER_PATH "/proc/sys/net/ipv4/conf/"
00116 
00120 #define PROXY_DEFAULT_CONIG_PATH "mcproxy.conf"
00121 
00125 class proxy{
00126 private:
00127      //control data
00128      static bool m_running;
00129      int m_verbose_lvl;
00130      bool m_print_status;
00131
00132      bool m_rest_rp_filter;
00133      vector<string> m_restore_rp_filter_vector; //save interface who musst set to true after end
00134
00135      string m_config_path;
00136      int m_addr_family; //AF_INET or AF_INET6
00137      int m_version; //for AF_INET (1,2,3) to use IGMPv1/2/3, for AF_INET6 (1,2) to use MLDv1/2
00138
00139      //--
00140      vector<proxy_instance*> m_proxy_instances;
00141      interface_map m_interface_map;
00142      up_down_map m_up_down_map;
00143      vif_map m_vif_map;
00144
00145      receiver* m_receiver;
00146      mroute_socket m_mrt_sock;
00147      if_prop m_if_prop;
00148
00149      int get_free_vif_number();
00150
00151      //map< instance, map < interface, vector< group_state> > > state_table
00152      vector<int> all_if_to_list();
00153
00154      //##############
00155      //##-- Init --##
00156      //##############
00157
00158      bool prozess_commandline_args(int arg_count, char* args[]);
00159      void help_output();
00160      bool get_rp_filter(string interface);
00161      bool set_rp_filter(string interface, bool to);
00162      bool restore_rp_filter();
00163
00164      bool load_config(string path); //load the config file and add the interfaces to state_table
00165
00166
00167      //check the state_table for valid input, interfaces can only used on time ==> true = check ok, false = double interfaces
00168      bool check_double_used_if(const vector<int>* new_interfaces);
00169      bool init_vif_map();
00170      bool init_if_prop();
00171      bool check_and_set_flags(vector<int>& interface_list); //check up and running flag, set multicast and allMulti flag
00172      bool init_mrt_socket(); //create ipv4/ipv6 socket and set mrt-flag
00173      bool start_proxy_instances();
00174
00175
00176      //bool init_routing_table(); //add all interfaces from state_table to ip_mr_vif (phyint or tunnel) , allocate memory for m_vif
00177      static void signal_handler(int sig);
00178      void close();
00179
00180
00181 public:
00185      proxy();
00186
00190      ~proxy();
00191
00195      string get_state_table();
00196
00221      bool init(int arg_count, char* args[]);
00222
00227      bool start();
00228
00232      void end();
00233 };
00234
00235 #endif // PROXY_HPP
00236