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

Examples of org.apache.uima.ducc.transport.event.common.DuccWorkReservation.stateChange()

831
832
833
834
835
836
837
838
839
840
841
        long elapsed = t1 - t0;
        if(elapsed > Constants.SYNC_LIMIT) {
          logger.debug(methodName, null, "elapsed msecs: "+elapsed);
        }
        // state: Received
        duccWorkReservation.stateChange(ReservationState.Received);
        OrchestratorCheckpoint.getInstance().saveState();
        // state: WaitingForResources
        duccWorkReservation.stateChange(ReservationState.WaitingForResources);
        OrchestratorCheckpoint.getInstance().saveState();
        int counter = 0;
View Full Code Here
834
835
836
837
838
839
840
841
842
843
844
        }
        // state: Received
        duccWorkReservation.stateChange(ReservationState.Received);
        OrchestratorCheckpoint.getInstance().saveState();
        // state: WaitingForResources
        duccWorkReservation.stateChange(ReservationState.WaitingForResources);
        OrchestratorCheckpoint.getInstance().saveState();
        int counter = 0;
        while(duccWorkReservation.isPending()) {
          counter++;
          if(counter > 5) {
View Full Code Here
912
913
914
915
916
917
918
919
920
921
922
          String tgtUser = duccWorkReservation.getStandardInfo().getUser().trim();
          if(isAuthorized(dwid, reqUser, tgtUser, reqRole)) {
            logger.debug(methodName, dwid, "reqUser:"+reqUser+" "+"reqRole:"+reqRole+" "+"tgtUser:"+tgtUser);
            duccWorkReservation.getStandardInfo().setCancelUser(reqUser);
            duccWorkReservation.getStandardInfo().setDateOfCompletion(TimeStamp.getCurrentMillis());
            duccWorkReservation.stateChange(ReservationState.Completed);
            duccWorkReservation.complete(ReservationCompletionType.CanceledByUser);
            String u1 = duccWorkReservation.getStandardInfo().getUser();
            String u2 = duccWorkReservation.getStandardInfo().getCancelUser();
            if(u1 != null) {
              if(u2 != null) {
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.