CN 12 - LEAKY BUCKET ALGORITHM

12. Write a program for congestion control using leaky bucket algorithm.

Leaky.java - PROGRAM

import java.util.Scanner;

public class Leaky 
{
public static void main(String[] args) 
{
Scanner sc = new Scanner(System.in);
int bcktsize, iter, rate, line, total = 0;
int[] pkt = new int[25];

System.out.print("Enter the bucket size and output rate(both in MB):");
bcktsize = sc.nextInt();
rate = sc.nextInt();

System.out.println("Enter the number of input lines");
line = sc.nextInt();

System.out.println("Enter input packet rate of " + line + " lines");
for(int i = 0; i < line; i++)
pkt[i] = sc.nextInt();

System.out.println("Enter the number of iterations");
iter = sc.nextInt();

for(int i = 0; i < iter; i++) 
{
System.out.println("\nIteration " + (i + 1));
for(int j = 0; j < line; j++) 
{
total += pkt[j];
if(total <= bcktsize)
System.out.println("\nInput from line "+(j+1)+" withrate "+pkt[j]+
" is added to the bucket\nCurrent bucket size(Mb) is " + total);
else 
{
total -= pkt[j];
System.out.println("\nInput from line " + (j + 1) +" withrate " + pkt[j] + 
" is thrown out of bucket\nCurrent bucket size(Mb)is " + total);
}
}
if(total <= rate) 
{
System.out.print("packet sent to outputline at rate " + total);
total = 0;
System.out.print("current bucket size is " + total);
}
else
{
total -= rate;
System.out.println("\npacket sent to output line at rate " + rate +
" \n Current bucket size(Mb)is " + total);
}
}
}

}

OUTPUT :

( click on image to zoom )