Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv15958
Modified Files:
RepositoryTest.java
Log Message:
no message
Index: RepositoryTest.java
===================================================================
RCS file: /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository/RepositoryTest.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** RepositoryTest.java 17 Mar 2006 05:16:09 -0000 1.1
--- RepositoryTest.java 17 Mar 2006 22:36:39 -0000 1.2
***************
*** 8,18 ****
package org.jmonks.batchserver.framework.repository;
import junit.framework.*;
! import java.lang.reflect.Constructor;
! import java.lang.reflect.InvocationTargetException;
! import java.util.Map;
! import org.apache.log4j.Logger;
import org.jmonks.batchserver.framework.config.*;
! import org.jmonks.batchserver.framework.controller.JobController;
--- 8,18 ----
package org.jmonks.batchserver.framework.repository;
+ import java.util.ArrayList;
+ import java.util.Calendar;
+ import java.util.Date;
import junit.framework.*;
! import org.jmonks.batchserver.framework.JobStatistics;
import org.jmonks.batchserver.framework.config.*;
!
***************
*** 39,43 ****
public static Test suite()
{
! TestSuite suite = new TestSuite(RepositoryTest.class);
return suite;
}
--- 39,45 ----
public static Test suite()
{
! //TestSuite suite = new TestSuite(RepositoryTest.class);
! TestSuite suite=new TestSuite();
! suite.addTest(new RepositoryTest("testJobDataTransfer"));
return suite;
}
***************
*** 80,82 ****
--- 82,187 ----
}
+ /**
+ * Test method to test the logJobStatistics API of repository.
+ */
+ public void testLogJobStatistics()
+ {
+ FrameworkConfig frameworkConfig=FrameworkConfig.getInstance();
+ assertNotNull(frameworkConfig);
+ FrameworkConfig.RepositoryConfig repositoryConfig=frameworkConfig.getRepositoryConfig();
+ assertNotNull(repositoryConfig);
+ Repository repository=Repository.getRepository(repositoryConfig);
+ assertNotNull(repository);
+ JobStatistics statistics=new JobStatistics("process_file_xyz");
+ statistics.setStartTime(Calendar.getInstance().getTime());
+ statistics.setEndTime(Calendar.getInstance().getTime());
+ statistics.setMaxMemeoryUsage(1000);
+ statistics.setRecordsProcessed(50000);
+ boolean logged=repository.logStatistics(statistics);
+ assertTrue(logged);
+ }
+
+ /**
+ * Test method to test the getJobStatistics API of repository.
+ */
+ public void testGetJobStatistics()
+ {
+ FrameworkConfig frameworkConfig=FrameworkConfig.getInstance();
+ assertNotNull(frameworkConfig);
+ FrameworkConfig.RepositoryConfig repositoryConfig=frameworkConfig.getRepositoryConfig();
+ assertNotNull(repositoryConfig);
+ Repository repository=Repository.getRepository(repositoryConfig);
+ assertNotNull(repository);
+
+ JobStatistics[] recvdStats=repository.getStatistics("not_valid_job_name");
+ assertNotNull(recvdStats);
+ assertEquals(0,recvdStats.length);
+
+ String jobName="process_"+Calendar.getInstance().getTimeInMillis();
+ JobStatistics statistics1=this.getJobStatistics(jobName, Calendar.getInstance().getTime(), Calendar.getInstance().getTime() , 234, 5000);
+ JobStatistics statistics2=this.getJobStatistics(jobName, Calendar.getInstance().getTime(), Calendar.getInstance().getTime() , 236, 5004);
+ boolean logged=repository.logStatistics(statistics1);
+ assertTrue(logged);
+ logged=repository.logStatistics(statistics2);
+ assertTrue(logged);
+
+ recvdStats=repository.getStatistics(jobName);
+ assertNotNull(recvdStats);
+ assertEquals(2,recvdStats.length);
+ for(int i=0;i<recvdStats.length;i++)
+ System.out.println(recvdStats[i]);
+ }
+
+ private JobStatistics getJobStatistics(String jobName,Date startTime,Date endTime,int memory,int records)
+ {
+ JobStatistics statistics=new JobStatistics(jobName);
+ statistics.setStartTime(startTime);
+ statistics.setEndTime(endTime);
+ statistics.setMaxMemeoryUsage(memory);
+ statistics.setRecordsProcessed(records);
+
+ return statistics;
+ }
+
+ public void testJobDataTransfer()
+ {
+ FrameworkConfig frameworkConfig=FrameworkConfig.getInstance();
+ assertNotNull(frameworkConfig);
+ FrameworkConfig.RepositoryConfig repositoryConfig=frameworkConfig.getRepositoryConfig();
+ assertNotNull(repositoryConfig);
+ Repository repository=Repository.getRepository(repositoryConfig);
+ assertNotNull(repository);
+
+ String id1="first_data";
+ String sourceJob="process_file_abc";
+ String targetJob="process_file_xyz";
+
+ boolean sent=repository.sendDataToNextJob(id1, sourceJob, targetJob, Calendar.getInstance());
+ assertTrue(sent);
+ Calendar cal1=(Calendar)repository.getDataFromPreviousJob(id1, sourceJob, targetJob);
+ assertNotNull(cal1);
+ boolean cleared=repository.clearDataTransferredToNextJob(sourceJob);
+ assertTrue(cleared);
+ Calendar cal2=(Calendar)repository.getDataFromPreviousJob(id1, sourceJob, targetJob);
+ assertNull(cal2);
+
+ sent=repository.sendDataToNextJob(id1, sourceJob, targetJob, Calendar.getInstance());
+ assertTrue(sent);
+ sent=repository.sendDataToNextJob(id1, sourceJob, targetJob, new ArrayList());
+ assertTrue(sent);
+ ArrayList list=(ArrayList)repository.getDataFromPreviousJob(id1, sourceJob, targetJob);
+ assertNotNull(cal1);
+ cleared=repository.clearDataTransferredToNextJob(sourceJob);
+ assertTrue(cleared);
+ }
+
+ public void testJobMgmtMntrInfoHolder()
+ {
+
+ }
+
+ public void testJobControllerHolder()
+ {
+
+ }
}
|
