Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2012-2015 Amazon.com, Inc. or its affiliates. All Rights Reserved.
   * 
   * Licensed under the Apache License, Version 2.0 (the "License"). You may not
   * use this file except in compliance with the License. A copy of the License is
   * located at
   * 
   * http://aws.amazon.com/apache2.0
   * 
  * or in the "license" file accompanying this file. This file 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.amazonaws.services.simpleworkflow.flow.core;
 
 import java.util.List;
 
 
     private final class RootTryCatchFinally extends TryCatchFinally {
 
         private RootTryCatchFinally(boolean daemonint skipStackLines) {
             super(daemon"doAsync"skipStackLinesnew Promise<?>[0]);
         }
 
         @Override
         protected void doTry() throws Throwable {
             .doAsync();
         }
 
         @Override
         protected void doCatch(Throwable ethrows Throwable {
             throw e;
         }
 
         @Override
         protected void doFinally() {
         }
 
         @Override
         AsyncParentContext getContext() {
             if (super.getState() != .. && super.getState() != ..) {
                 throw new IllegalStateException("Already executed");
             }
             return super.getContext();
         }
 
     }
 
     private final class RootAsyncContext implements AsyncParentContext {
 
         @Override
         public void remove(AsyncContextBase async) {
             assert !;
              = true;
         }
 
         @Override
         public Executor getExecutor() {
             return ;
         }
 
         @Override
         public void fail(AsyncContextBase asyncThrowable e) {
             assert !;
              = e;
              = true;
         }
 
         @Override
         public void add(AsyncContextBase asyncPromise<?> waitFor) {
             if (waitFor != null) {
                 throw new IllegalArgumentException();
             }
             .execute(async);
         }
 
         @Override
         public AsyncStackTrace getStackTrace() {
             return ;
         }
 
         @Override
         public boolean isRethrown(Throwable e) {
             throw new IllegalStateException("should not be called");
         }
 
         @Override
             throw new IllegalStateException("should not be called");
         }
 
         @Override
         public boolean getDaemonFlagForHeir() {
             return false;
         }
 
        @Override
        public String getParentTaskMethodName() {
            return null;
        }
        @Override
        public boolean getHideStartFromMethod() {
            return false;
        }
        @Override
        public String getName() {
            return ;
        }
    }
    private final AsyncScope asyncScope;
    private boolean complete;
    private Throwable failure;
    private AsyncEventLoop executor;
    private TryCatchFinally root;
    private AsyncStackTrace stackTrace;
    
    private String name;
    public AsyncScopeContext(AsyncScope asyncScopeboolean disableAsyncStackTraceboolean excludeAsyncScopeStack) {
        this. = asyncScope;
        if (!disableAsyncStackTrace) {
             = new AsyncStackTrace(nullnew StackTraceElement[0], 0);
        }
         = new AsyncEventLoop();
        AsyncParentContext rootContext = new RootAsyncContext();
        AsyncContextBase.setCurrent(rootContext);
        try {
            int skipStackLines = excludeAsyncScopeStack ? . : 10;
             = new RootTryCatchFinally(falseskipStackLines);
        }
        finally {
            AsyncContextBase.setCurrent(null);
        }
    }
    public boolean eventLoop() throws Throwable {
        if () {
            throw new IllegalStateException("already complete");
        }
        .executeAllQueued();
        if ( &&  != null) {
            throw ;
        }
        return ;
    }
    
    public boolean isComplete() {
        return ;
    }
    public Throwable getFailure() {
        return ;
    }
    public void cancel(Throwable cause) {
        .cancel(cause);
    }
    public boolean isCancelRequested() {
        return .isCancelRequested();
    }
        return .getAsynchronousStackTraceDump();
    }
    }
        return .getContext();
    }
    public String getName() {
        return ;
    }
    
    public void setName(String name) {
        this. = name;
    }
    
New to GrepCode? Check out our FAQ X