Hi sai and Eugene,
Please go through the testprogram which i have written and give me ur valid feed back. Tell me that is it enought to be sure that my FBN program works fine.
Here in the following iam sure first three are working.
1) Available seats are getting reduced based on the book request
2) You don't allow over booking of flights.
3) Block clients who are trying to book the seats in the same flight.
4) Unreferenced locks are getting removed
package test.db;
import java.io.*;
import java.util.*;
import test.db.DataInterface;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;
import java.net.MalformedURLException;
/**
* TestClient --
*
* @author Rameshkumar.km
* @version$Name$
* @see
* @bugs
*/
public class TestClient
{
public TestClient()
{
}
private static class ThreadOne implements Runnable
{
static DataInterface dataInterfaceOne;
public int recNo,seatNo;
public ThreadOne(
String str)
{
StringTokenizer st=new StringTokenizer(str,",");
this.recNo=Integer.parseInt((String)st.nextToken());
this.seatNo=Integer.parseInt((String)st.nextToken());
}
static
{
try
{
dataInterfaceOne=(DataInterface) Naming.lookup("rmi://localhost:2099/FBNServer");
}
catch(Exception ex)
{
ex.printStackTrace();
}
}
public void run()
{
try
{
{
Thread.yield();
dataInterfaceOne.lock(recNo);
boolean bool=dataInterfaceOne.modifyRec(recNo,seatNo);
dataInterfaceOne.unlock(recNo);
System.out.println("Thread one Seat booked----For "+recNo+" Seats :"+seatNo+"Status :"+bool);
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
}
private static class ThreadTwo implements Runnable
{
static DataInterface dataInterfaceTwo;
public int recNo,seatNo;
public ThreadTwo(String str)
{
StringTokenizer st=new StringTokenizer(str,",");
this.recNo=Integer.parseInt((String)st.nextToken());
this.seatNo=Integer.parseInt((String)st.nextToken());
}
static{
try
{
dataInterfaceTwo=(DataInterface) Naming.lookup("rmi://localhost:2099/FBNServer");
}
catch(Exception ex)
{
ex.printStackTrace();
}
}
public void run()
{
try
{
//while(true)
{
Thread.yield();
dataInterfaceTwo.lock(recNo);
boolean bool=dataInterfaceTwo.modifyRec(recNo,seatNo);
dataInterfaceTwo.unlock(recNo);
System.out.println("Thread Two Seat booked----For "+recNo+" Seats :"+seatNo+"Status :"+bool);
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
}
public Vector readConf(String str) throws Exception
{
FileReader fr=new FileReader(str);
BufferedReader br=new BufferedReader(fr);
Vector vec=new Vector();
String tempStr="";
while((tempStr=br.readLine())!=null)
{
vec.addElement(tempStr);
tempStr="";
}
return vec;
}
public void displayValues(DataInfo[] dInfo)
{
for(int i=0;i<dInfo.length;i++)
{
DataInfo dataInfo=dInfo[i];
String []values=dataInfo.getValues();
StringBuffer sb=new StringBuffer();
for(int j=0;j<values.length; j++)
{
sb.append(values[j]+" : ");
}
System.out.println(sb);
}
}
//}
public static void main(String args[])
{
try
{
TestClient tc= new TestClient();
Vector vec=tc.readConf("Lock.txt");
for(int i=0;i<vec.size();i++)
{
String lock=(String)vec.elementAt(i);
ThreadOne tClient=(new TestClient()).new ThreadOne(lock);
ThreadTwo tClient1=(new TestClient()).new ThreadTwo(lock);
new Thread(tClient,new Integer(i).toString()).start();
new Thread(tClient1,new Integer(i).toString()).start();
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
}
