Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2012 International Business Machines Corp.
   * 
   * See the NOTICE file distributed with this work for additional information
   * regarding copyright ownership. Licensed under the Apache License, 
   * Version 2.0 (the "License"); you may not use this file except in compliance
   * with the License. You may obtain a copy of the License at
   * 
   *   http://www.apache.org/licenses/LICENSE-2.0
  * 
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
 */
 package com.ibm.jbatch.container.persistence;
 
 import java.util.Date;
 
 
 public final class ItemCheckpointAlgorithm implements CheckpointAlgorithm {
 
 	private static final String className = ItemCheckpointAlgorithm.class.getName();
 	private static Logger logger  = Logger.getLogger(ItemCheckpointAlgorithm.class.getPackage().getName());;
 		
     CheckpointAlgorithm ichkp = null;
     boolean inCheckpoint = false;
     private static final int defaultRecordValue = 10;
     private static final int defaultTimeValue = 10;
 	private static final int defaultTimeoutValue = 60;
     int threshold = ;
     long requests = 0;
     int timeout = ;
     
     java.util.Date date = null;
     long checkpointBeginTime = 0;
     int interval = 10;  // 10 sec interval?
     long numTimes = 0;
     
     int time
     int item;
     
     public ItemCheckpointAlgorithm(){
     	 = new java.util.Date();
         .finer("ITEMTIME: in ctor, ts = " + );
 
     }
 
 	public void endCheckpoint() throws Exception {
     	 = false
 	}
 
 	public int getCheckpointTimeOut(int timeOutthrows Exception {
     	return ;
 	}
 
 	public boolean isReadyToCheckpointItem() throws Exception {
        	String method = "isReadyToCheckpoint";
     	if(.isLoggable(.)) { .entering(method); }
 
         ++;
 
         boolean itemready = ( >= );
 
         if ( itemready) {
         	.finer("ITEMTIMECHKPT: item checkpoint hit");
             long millis =  Long.valueOf( (new Date().getTime()) -  );
             if ( millis>0 ) { 
                 String rate =  Integer.valueOf ( Long.valueOf( (*1000/millis) ).intValue()).toString();
                 if(.isLoggable(.)) { .fine(" - true [requests/second " + rate + "]"); }
 
             } else {
             	if(.isLoggable(.)) { .fine(" - true [requests " +  + "]"); }
 
             }
         }
 
         if ( itemready )  = 0;
 
         return itemready;
 	}
 	
 	public boolean isReadyToCheckpointTime() throws Exception {
     	String method = "isReadyToCheckpoint";
     	if(.isLoggable(.)) { .entering(method); }
 
         boolean timeready = false;
         ++;
         java.util.Date curDate = new java.util.Date();
         long curts = curDate.getTime();
         long curdiff = curts - ;
         int diff = (int)curdiff / 1000;
         
         if (diff >= ) {
        	.finer("ITEMTIMECHKPT: time checkpoint hit");
            timeready = true;
            if(.isLoggable(.)) { .fine("Num of requests="++" at a rate="+/diff+" req/sec");}
         
             = 0;
            
             = new java.util.Date();
             = .getTime();
            
        }
           
        if(.isLoggable(.)) { .exiting(methodtimeready); }
        return timeready;
	}
	public void setThreshold(int INthreshHold){
		 = INthreshHold;
	}
	public boolean isReadyToCheckpoint() throws Exception {
		boolean ready = false
		if ( == 0){ // no time limit, just check if item count has been reached
				ready = true;
			}
			ready = true;
		}
		return ready;
	}
	public void setThresholds(int itemthresholdint timethreshold) {
		 = itemthreshold;
         = timethreshold;
	}
	public void beginCheckpoint() throws Exception {
         = .getTime();
	}
	public int checkpointTimeout() throws Exception {
		// TODO Auto-generated method stub
		return 0;
	}
	// Old Item only chkpt code
	/*
	private static final String className = ItemCheckpointAlgorithm.class.getName();
	private static Logger logger  = Logger.getLogger(ItemCheckpointAlgorithm.class.getPackage().getName());;
    CheckpointAlgorithm ichkp = null;
    boolean inCheckpoint = false;
    private static final int defaultRecordValue = 10;
	private static final int defaultTimeoutValue = 60;
    int itemthreshold = defaultRecordValue;
    int timethreshold = 0; // default time threshold is 0
    long timeStarted = 0;
    long requests = 0;
    int timeout = defaultTimeoutValue;
    
	//@BeginCheckpoint
	public void beginCheckpoint() throws Exception {
        inCheckpoint = true;
        timeStarted = new Date().getTime();
	}
	//@EndCheckpoint
	public void endCheckpoint() throws Exception {
    	inCheckpoint = false; 
	}
	//@GetCheckpointTimeout
	public int getCheckpointTimeOut(int timeOut) throws Exception {
    	return timeout;
	}
	//@IsReadyToCheckpoint
	public boolean isReadyToCheckpoint() throws Exception {
       	String method = "ShouldCheckpointBeExecuted";
    	if(logger.isLoggable(Level.FINER)) { logger.entering(className, method); }
        requests++;
        boolean ready = (requests >= itemthreshold);
        if ( ready) {
            long millis =  Long.valueOf( (new Date().getTime()) - timeStarted );
            if ( millis>0 ) { 
                String rate =  Integer.valueOf ( Long.valueOf( (requests*1000/millis) ).intValue()).toString();
                if(logger.isLoggable(Level.FINE)) { logger.fine(" - true [requests/second " + rate + "]"); }
            } else {
            	if(logger.isLoggable(Level.FINE)) { logger.fine(" - true [requests " + requests + "]"); }
            }
        }
        if ( ready ) requests = 0;
        return ready;
	}
	public void setThreshold(int INthreshHold){
		itemthreshold = INthreshHold;
	}
	//@Override
	public void setThresholds(int itemthreshold, int timethreshold) {
		this.itemthreshold = itemthreshold; 		
	}
	@Override
	public int checkpointTimeout(int timeout) throws Exception {
		this.timeout = timeout;
		return this.timeout;
	}
*/
New to GrepCode? Check out our FAQ X