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;
 
 
 
 
 public class CheckpointManager {
 	private final static String sourceClass = CheckpointManager.class.getName();
 	private final static Logger logger = Logger.getLogger();
 
 	private ServicesManager servicesManager = ServicesManagerImpl.getInstance();
 	
 	private ItemReaderProxy readerProxy = null;
 	private ItemWriterProxy writerProxy = null;
 	int commitInterval = 0;
 	private boolean ckptStarted;
 	private long executionId = 0;
 	private String stepId = null;
 	private long jobInstanceID = 0;
 	
 
 			long executionIdlong jobInstanceIDString  stepId) {
 		this. = reader;
 		this. = writer;
 		this. = chkptAlg;
 		this. = executionId;
 		this. = stepId;
 		this. = jobInstanceID;
 		
 	}
 
 	public void beginCheckpoint(int timeoutVal)
 	{
 		String method = "startCheckpoint";
 
          = true;
 
 	}
 
 	public void beginCheckpoint()
 	{
 		String method = "beginCheckpoint";
         if(.isLoggable(.)) { .fine("executionId=" +  );}
          = true;
 
 
 	}
 
 
 	public boolean ApplyCheckPointPolicy(/*boolean forceCheckpoint*/)
 	{
 		String method = "ApplyCheckPointPolicy";
 
 		boolean checkpoint = false;
 		
 		try {
 		} catch (Exception e) {
 		    throw new BatchContainerRuntimeException("Checkpoint algorithm failed"e);
 		}
 
 		if (.isLoggable(.) && checkpoint)
 			.fine("ApplyCheckPointPolicy - " + checkpoint);
 
		return checkpoint;
	}
	public boolean isStarted()
	{
		return ;
	}
	public void checkpoint()
	{
		String method = "checkpoint";
		if(.isLoggable(.)) { .entering(method" [executionId " +  + "] "); }
		ObjectOutputStream readerOOS = nullwriterOOS = null;
		CheckpointDataKey readerChkptDK = nullwriterChkptDK = null;
		try{
			readerOOS = new ObjectOutputStream(readerChkptBA);
			readerOOS.close();
			CheckpointData readerChkptData  = new CheckpointData("READER");
			readerChkptData.setRestartToken(readerChkptBA.toByteArray());
			readerChkptDK = new CheckpointDataKey("READER");
			writerOOS = new ObjectOutputStream(writerChkptBA);
			writerOOS.close();
			CheckpointData writerChkptData = new CheckpointData("WRITER");
			writerChkptData.setRestartToken(writerChkptBA.toByteArray());
			writerChkptDK = new CheckpointDataKey("WRITER");
		}
		catch (Exception ex){
			// is this what I should be throwing here?
			throw new BatchContainerServiceException("Cannot persist the checkpoint data for [" +  + "]"ex);
		}
		if(.isLoggable(.)) { .exiting(method" [executionId " +  + "] ");}
	}
	public int checkpointTimeout() {
		int returnTimeout = 0; 
        try {
            returnTimeout = this..checkpointTimeout();
        } catch (Exception e) {
            throw new BatchContainerRuntimeException("Checkpoint algorithm checkpointTimeout() failed"e);
        }
        return returnTimeout;
	}
New to GrepCode? Check out our FAQ X