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;
 
 
 class TaskContext extends AsyncContextBase implements AsyncParentContext {
 
     private final Task task;
 
     private boolean canceled;
 
     private final String parentTaskMethodName;
 
     private final boolean hideStartFromMethod;
 
     public TaskContext(Task taskBoolean daemon, Promise<?>[] waitFor) {
         super(daemonwaitFor, 7);
         this. = task;
         this. = null;
         this. = false;
     }
 
     public TaskContext(AsyncParentContext parentTask taskBoolean daemon, Promise<?>[] waitFor) {
         super(parentdaemonwaitFor, 5);
         this. = task;
         this. = null;
         this. = false;
     }
 
     public TaskContext(AsyncParentContext parentTask taskBoolean daemonString parentTaskMethodNameboolean hideParentTaskMethodNameint skipStackLines,
             Promise<?>[] waitFor) {
         super(parentdaemonwaitForskipStackLines);
         this. = task;
         this. = parentTaskMethodName;
         this. = hideParentTaskMethodName;
     }
 
     public TaskContext(Task taskBoolean daemonString parentTaskMethodNameboolean hideParentTaskMethodNameint skipStackLines, Promise<?>[] waitFor) {
         super(daemonwaitForskipStackLines);
         this. = task;
         this. = parentTaskMethodName;
         this. = hideParentTaskMethodName;
     }
 
     public void cancel(Throwable cause) {
          = true;
         .remove(this);
     }
 
     @Override
     public void run() {
         if () {
             return;
         }
         setCurrent(this);
         try {
             .doExecute();
             .remove(this);
         }
         catch (Throwable e) {
             if ( != null && !.isRethrown(e)) {
                 AsyncStackTrace merged = new AsyncStackTrace(e.getStackTrace(), 0);
                 merged.setStartFrom(getParentTaskMethodName());
                 merged.setHideStartFromMethod();
                 e.setStackTrace(merged.getStackTrace());
             }
             .fail(thise);
         }
         finally {
             setCurrent(null);
         }
     }
 
     @Override
     public void add(AsyncContextBase asyncPromise<?> waitFor) {
         .add(asyncwaitFor);
     }
 
     @Override
     public void remove(AsyncContextBase async) {
         .remove(async);
     }
 
     @Override
     public void fail(AsyncContextBase asyncThrowable e) {
         .fail(asynce);
    }
    @Override
    public Executor getExecutor() {
        return .getExecutor();
    }
    @Override
    public boolean isRethrown(Throwable e) {
        return .isRethrown(e);
    }
    @Override
        return ;
    }
    @Override
    public boolean getDaemonFlagForHeir() {
        return isDaemon();
    }
    @Override
    public String getParentTaskMethodName() {
        return  == null ? "doExecute" : ;
    }
    
    @Override
    public boolean getHideStartFromMethod() {
        return ;
    }
    public String toString() {
        if ( != null) {
            return .toString();
        }
        return super.toString();
    }
New to GrepCode? Check out our FAQ X