CAC message when nbCalls>100

adumas
1 parent 45f930d8
Showing 2 changed files with 39 additions and 1 deletions
src/main/java/net/floodlightcontroller/pelstats/PELStats.java
src/main/java/org/openflow/protocol/Pel/statistics/StatisticVoIP_CAC.java
@@ -71,6 +71,7 @@ public class PELStats implements IFloodlightModule, IOFMessageListener, RestAPIP
 	public static ConcurrentHashMap<IOFSwitch,List<double[][]>> voipStatsMap;
  
 	public static ConcurrentHashMap<IOFSwitch,List<double[]>> cacStatsMap;
+	public static ConcurrentHashMap<IOFSwitch,Boolean> cacEnabledMap;
  
 	public static ConcurrentHashMap<IOFSwitch, List<Integer>> queueInfos;
 	public static ConcurrentHashMap<IOFSwitch, List<Integer>> portsCallsMap;
@@ -217,6 +218,42 @@ public class PELStats implements IFloodlightModule, IOFMessageListener, RestAPIP
 									//System.out.println("@PELStats \tOK");
  
  
+									if (cacEnabledMap.get(sw)==null){
+										cacEnabledMap.put(sw,false);
+									}
+									if (((StatisticVoIP_CAC)srb.getStatistic()).getStats()[1]>100 ){//nbCalls>100
+										if (cacEnabledMap.get(sw)==false){
+											int nb= 2*16777216+7*65536+1*4096+1;
+											PelVendorHeader message= new PelVendorHeader(nb);
+											try {
+												sw.write(message, null);
+												cacEnabledMap.put(sw,true);
+												System.out.println("Enabling CAC");
+												
+											} catch (IOException e) {
+												e.printStackTrace();
+											}	
+										}
+									}
+									else
+									{
+										if(cacEnabledMap.get(sw)==true){
+											int nb= 2*16777216+7*65536+1*4096+0;
+											PelVendorHeader message= new PelVendorHeader(nb);
+											try {
+												sw.write(message, null);
+												cacEnabledMap.put(sw,false);
+												System.out.println("Disabling CAC");
+												
+											} catch (IOException e) {
+												e.printStackTrace();
+											}
+											
+										}
+									}
+									
+									
+									
 								}
  
 								if(enabledStatistics.containsKey(sw)){
@@ -657,6 +694,7 @@ public class PELStats implements IFloodlightModule, IOFMessageListener, RestAPIP
         PELStats.callStatsMap=new ConcurrentHashMap<Integer, List<double[]>>() ;
         PELStats.voipStatsMap=new ConcurrentHashMap<IOFSwitch, List<double[][]>>() ;
         PELStats.cacStatsMap=new ConcurrentHashMap<IOFSwitch, List<double[]>>() ;
+        PELStats.cacEnabledMap=new ConcurrentHashMap<IOFSwitch, Boolean>() ;
         requestThread.start();
 	}
  
@@ -31,7 +31,7 @@ public class StatisticVoIP_CAC extends Statistic{
 		date=new Date();
  
 		//TODO Change the condition
-		if (nbCalls>100 || (averageMos<3 &&nbCalls>50)){
+		if (nbCalls>100 ){
 			cacStatus="Too much calls";
 		}
 		else