[Batchserver-cvs] batchserver/test/org/jmonks/batchserver/framework/repository RepositoryTest.java,1.1,1.2

[Suresh <sur...@us...>]

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()
+     {
+         
+     }
  }