Package org.apache.uima.ducc.transport.event.common

Examples of org.apache.uima.ducc.transport.event.common.IDuccProcess.advanceProcessState()

177
178
179
180
181
182
183
184
185
186
187
          }
          else {
            if(!process.isComplete()) {
              String nodeName = process.getNodeIdentity().getName();
              if(!NodeAccounting.getInstance().isAlive(nodeName)) {
                process.advanceProcessState(ProcessState.Stopped);
                logger.info(methodName, job.getDuccId(), process.getDuccId(), ProcessState.Stopped);
                ckpt = true;
              }
            }
          }
View Full Code Here
875
876
877
878
879
880
881
882
883
884
885
              String rState = process.getResourceState().toString();
              String pState = process.getProcessState().toString();
              logger.info(methodName, job.getDuccId(), duccId, "rState:"+rState+" "+"pState"+pState);
              process.setResourceState(ResourceState.Deallocated);
              process.setProcessDeallocationType(ProcessDeallocationType.Purged);
              process.advanceProcessState(ProcessState.Stopped);
            }
          }
        }
      }
    }
View Full Code Here
812
813
814
815
816
817
818
819
820
821
822
          process.setResourceState(ResourceState.Deallocated);
          process.setProcessDeallocationType(processDeallocationType);
          logger.info(methodName, job.getDuccId(), process.getDuccId(), type);
          if(processState != null) {
            logger.debug(methodName, job.getDuccId(), process.getProcessState()+" -> "+processState);
            process.advanceProcessState(processState);
          }
          break;
        case Deallocated: 
          if(processState != null) {
            logger.debug(methodName, job.getDuccId(), process.getProcessState()+" -> "+processState);
View Full Code Here
818
819
820
821
822
823
824
825
826
827
828
          }
          break;
        case Deallocated: 
          if(processState != null) {
            logger.debug(methodName, job.getDuccId(), process.getProcessState()+" -> "+processState);
            process.advanceProcessState(processState);
          }
          break;
        }
      }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.