Examples of advanceProcessState()

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

931
932
933
934
935
936
937
938
939
940
941
          // allocation unnecessary if job is already completed
          case Completing:
          case Completed:
            process.setResourceState(ResourceState.Deallocated);
            process.setProcessDeallocationType(ProcessDeallocationType.Voluntary);
            process.advanceProcessState(ProcessState.Stopped);
            logger.warn(methodName, duccWorkJob.getDuccId(),
                messages.fetch("resource allocated for completed job")
                +" "+
                messages.fetchLabel("process")+duccId.getFriendly()
                );
View Full Code Here

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

943
944
945
946
947
948
949
950
951
952
953
          default:
            // allocation unnecessary if job has excess capacity
            if(isExcessCapacity(duccWorkJob,driverStatusReportMap.get(duccId))) {
              process.setResourceState(ResourceState.Deallocated);
              process.setProcessDeallocationType(ProcessDeallocationType.Voluntary);
              process.advanceProcessState(ProcessState.Stopped);
              logger.warn(methodName, duccWorkJob.getDuccId(),
                  messages.fetch("resource allocated for over capacity job")
                  +" "+
                  messages.fetchLabel("process")+duccId.getFriendly()
                  );
View Full Code Here

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

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

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

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

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

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

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.