Package com.cloudbees.groovy.cps

Examples of com.cloudbees.groovy.cps.Outcome

202
203
204
205
206
207
208
209
210
        }
    }

    @Override
    public void onFailure(Throwable t) {
        for (FutureCallback<Object> c : grabCallbacks(new Outcome(null,t))) {
            c.onFailure(t);
        }
    }
View Full Code Here
310
311
312
313
314
315
316
317
                // beyond this point, StepContext can receive a result at any time and
                // that would result in a call to scheduleNextChunk(). So we the call to
                // switchToAsyncMode to happen inside 'synchronized(lock)', so that
                // the 'executing' variable gets set to null before the scheduleNextChunk call starts going.

                return suspendWith(new Outcome(context,null));
            }
        }
View Full Code Here
93
94
95
96
97
98
99
100
                this.name = name;
            }

            @Override
            public void onSuccess(Object result) {
                handler.outcomes.put(name, new Outcome(result, null));
                checkAllDone();
            }
View Full Code Here
99
100
101
102
103
104
105
106
                checkAllDone();
            }

            @Override
            public void onFailure(Throwable t) {
                handler.outcomes.put(name, new Outcome(null, t));
                checkAllDone();
            }
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
            private void checkAllDone() {
                Map<String,Object> success = new HashMap<String, Object>();
                Entry<String,Outcome> failure = null;
                for (Entry<String,Outcome> e : handler.outcomes.entrySet()) {
                    Outcome o = e.getValue();

                    if (o==null)
                        return; // some of the results are not yet ready
                    if (o.isFailure()) {
                        failure= e;
                    } else {
                        success.put(e.getKey(), o.getNormal());
                    }
                }

                // all done
                if (failure!=null) {
View Full Code Here
324
325
326
327
328
329
330
331
332
333
334
        final SettableFuture<CpsThreadGroup> f = SettableFuture.create();
        g.runner.submit(new Runnable() {
            @Override
            public void run() {
                CpsThread t = g.addThread(new Continuable(s,createInitialEnv()),h,null);
                t.resume(new Outcome(null, null));
                f.set(g);
            }

            /**
             * Environment to start executing the script in.
View Full Code Here
463
464
465
466
467
468
469
470
471
472
473
                CpsThread t = g.addThread(
                        new Continuable(new ThrowBlock(new ConstantBlock(
                            new IOException("Failed to load persisted workflow state", problem)))),
                        head_, null
                );
                t.resume(new Outcome(null,null));
            }
            @Override public void onFailure(Throwable t) {
                LOGGER.log(Level.WARNING, null, t);
            }
        });
View Full Code Here
120
121
122
123
124
125
126
    /**
     * Runs one step in this thread and returns a new state.
     */
    /*package*/ GreenThreadState tick(Object o) {
        return resumeFrom(new Outcome(o,null));
    }
View Full Code Here
120
121
122
123
124
125
126
    /**
     * Runs one step in this thread and returns a new state.
     */
    /*package*/ GreenThreadState tick(Object o) {
        return resumeFrom(new Outcome(o,null));
    }
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
     *
     * We'll build an updated {@link GreenWorld} then return it.
     */
    Next update(GreenThreadState g) {
        GreenWorld d = this.with(g);
        Outcome y = g.n.yield;

        if (y==null) {
            // no yield. rotate to next thread and keep going
            return d.withNewCur().asNext(null);
        }

        if (y.getNormal() instanceof ThreadTask) {
            // a task that needs to update/access the state
            ThreadTask task = (ThreadTask)y.getNormal();

            Result r = task.eval(d);
            d = r.w;
            if (r.suspend)  // yield the value, then come back to the current thread later
                return d.asNext(r.value);
View Full Code Here
TOP

Related Classes of com.cloudbees.groovy.cps.Outcome

  • com.cloudbees.groovy.cps.green.GreenThread
  • com.cloudbees.groovy.cps.green.GreenThreadState
  • com.cloudbees.groovy.cps.green.GreenWorld
  • com.cloudbees.groovy.cps.impl.ConstantBlock
  • com.cloudbees.groovy.cps.impl.ThrowBlock
  • org.jenkinsci.plugins.workflow.cps.CpsBodyExecution
  • org.jenkinsci.plugins.workflow.cps.CpsFlowExecution
  • org.jenkinsci.plugins.workflow.cps.CpsStepContext
  • org.jenkinsci.plugins.workflow.cps.CpsThread
  • org.jenkinsci.plugins.workflow.cps.CpsThreadGroup
    • Copyright © 2018 www.massapicom. 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.