Searched refs:continuation (Results 1 - 25 of 59) sorted by relevance

123

/external/jetty/src/java/org/eclipse/jetty/continuation/
H A DContinuationListener.java19 package org.eclipse.jetty.continuation;
37 * Called when a continuation life cycle is complete and after
41 * @param continuation
43 public void onComplete(Continuation continuation); argument
47 * Called when a suspended continuation has timed out.
51 * @param continuation
53 public void onTimeout(Continuation continuation); argument
H A DContinuationThrowable.java20 package org.eclipse.jetty.continuation;
H A DContinuationSupport.java19 package org.eclipse.jetty.continuation;
30 * native to the container (jetty >= 6), a servlet 3.0 or a faux continuation.
49 Class<? extends Continuation> s3c = ContinuationSupport.class.getClassLoader().loadClass("org.eclipse.jetty.continuation.Servlet3Continuation").asSubclass(Continuation.class);
70 Class<? extends Continuation> j6c = ContinuationSupport.class.getClassLoader().loadClass("org.eclipse.jetty.continuation.Jetty6Continuation").asSubclass(Continuation.class);
104 * or a real implementation like {@link org.eclipse.jetty.continuation.Servlet3Continuation}.
110 Continuation continuation = (Continuation) request.getAttribute(Continuation.ATTRIBUTE);
111 if (continuation!=null)
112 return continuation;
121 continuation=__newServlet3Continuation.newInstance(request);
122 request.setAttribute(Continuation.ATTRIBUTE,continuation);
[all...]
H A DContinuation.java19 package org.eclipse.jetty.continuation;
32 * A continuation is a mechanism by which a HTTP Request can be suspended and
35 * The continuation mechanism is a portable mechanism that will work
43 * provided by the servlet-3.0 and an enhancement of the continuation
48 * A continuation object is obtained for a request by calling the
50 * The continuation type returned will depend on the servlet container
54 * There are two distinct style of operation of the continuation API.
67 * Continuation continuation = ContinuationSupport.getContinuation(request);
68 * continuation.suspend();
69 * myAsyncHandler.register(continuation);
[all...]
H A DJetty6Continuation.java19 package org.eclipse.jetty.continuation;
35 * This continuation requires the {@link ContinuationFilter} to be deployed.
58 public Jetty6Continuation(ServletRequest request, org.mortbay.util.ajax.Continuation continuation) argument
66 _j6Continuation=continuation;
90 * @see org.eclipse.jetty.continuation.Continuation#getAttribute(java.lang.String)
99 * @see org.eclipse.jetty.continuation.Continuation#removeAttribute(java.lang.String)
108 * @see org.eclipse.jetty.continuation.Continuation#setAttribute(java.lang.String, java.lang.Object)
166 * @see org.eclipse.jetty.continuation.Continuation#suspend(javax.servlet.ServletResponse)
211 * @see org.eclipse.jetty.continuation.Continuation#undispatch()
H A DFauxContinuation.java20 package org.eclipse.jetty.continuation;
28 import org.eclipse.jetty.continuation.ContinuationFilter.FilteredContinuation;
35 * when there are is no native or asynchronous continuation type available.
86 * @see org.eclipse.jetty.continuation.Continuation#isResponseWrapped()
263 * @see org.eclipse.jetty.continuation.Continuation#getServletResponse()
273 * @see org.eclipse.jetty.continuation.Continuation#getServletResponse()
468 * @see org.eclipse.jetty.continuation.Continuation#getAttribute(java.lang.String)
477 * @see org.eclipse.jetty.continuation.Continuation#removeAttribute(java.lang.String)
486 * @see org.eclipse.jetty.continuation.Continuation#setAttribute(java.lang.String, java.lang.Object)
495 * @see org.eclipse.jetty.continuation
[all...]
H A DContinuationFilter.java19 package org.eclipse.jetty.continuation;
/external/v8/test/mjsunit/compiler/
H A Dinline-closures.js32 function mkClosure(continuation) {
34 if (continuation == 'g') return this.g(value);
35 if (continuation == 'h') return this.h(value);
/external/clang/test/SemaCXX/
H A Dmember-expr-static.cpp6 extern void kernel_thread_start(thread_continue_t continuation);
/external/jetty/src/java/org/eclipse/jetty/server/handler/
H A DRequestLogHandler.java28 import org.eclipse.jetty.continuation.Continuation;
29 import org.eclipse.jetty.continuation.ContinuationListener;
60 AsyncContinuation continuation = baseRequest.getAsyncContinuation();
61 if (!continuation.isInitial())
74 if (continuation.isAsync())
76 if (continuation.isInitial())
77 continuation.addContinuationListener(new ContinuationListener()
80 public void onTimeout(Continuation continuation)
85 public void onComplete(Continuation continuation)
H A DStatisticsHandler.java29 import org.eclipse.jetty.continuation.Continuation;
30 import org.eclipse.jetty.continuation.ContinuationListener;
59 public void onComplete(Continuation continuation)
61 final Request request = ((AsyncContinuation)continuation).getBaseRequest();
69 if (!continuation.isResumed())
73 public void onTimeout(Continuation continuation)
108 AsyncContinuation continuation = request.getAsyncContinuation();
109 if (continuation.isInitial())
120 if (continuation.isResumed())
136 if (continuation
[all...]
H A DGzipHandler.java36 import org.eclipse.jetty.continuation.Continuation;
37 import org.eclipse.jetty.continuation.ContinuationListener;
38 import org.eclipse.jetty.continuation.ContinuationSupport;
269 Continuation continuation = ContinuationSupport.getContinuation(request);
270 if (continuation.isSuspended() && continuation.isResponseWrapped())
272 continuation.addContinuationListener(new ContinuationListener()
274 public void onComplete(Continuation continuation)
286 public void onTimeout(Continuation continuation)
/external/jetty/src/java/org/eclipse/jetty/servlets/
H A DQoSFilter.java38 import org.eclipse.jetty.continuation.Continuation;
39 import org.eclipse.jetty.continuation.ContinuationListener;
40 import org.eclipse.jetty.continuation.ContinuationSupport;
122 public void onComplete(Continuation continuation)
125 public void onTimeout(Continuation continuation)
127 _queue[priority].remove(continuation);
173 Continuation continuation = ContinuationSupport.getContinuation(request);
175 continuation.setTimeout(_suspendMs);
176 continuation.suspend();
177 continuation
[all...]
H A DProxyServlet.java49 import org.eclipse.jetty.continuation.Continuation;
50 import org.eclipse.jetty.continuation.ContinuationSupport;
422 final Continuation continuation = ContinuationSupport.getContinuation(request);
424 if (!continuation.isInitial())
461 continuation.complete();
517 // continuation.suspend()
518 if (!continuation.isInitial())
520 continuation.complete();
535 // continuation.suspend()
536 if (!continuation
750 customizeContinuation(Continuation continuation) argument
[all...]
H A DGzipFilter.java42 import org.eclipse.jetty.continuation.Continuation;
43 import org.eclipse.jetty.continuation.ContinuationListener;
44 import org.eclipse.jetty.continuation.ContinuationSupport;
299 Continuation continuation = ContinuationSupport.getContinuation(request);
300 if (continuation.isSuspended() && continuation.isResponseWrapped())
302 continuation.addContinuationListener(new ContinuationListenerWaitingForWrappedResponseToFinish(wrappedResponse));
507 public void onComplete(Continuation continuation) argument
519 public void onTimeout(Continuation continuation) argument
H A DDoSFilter.java49 import org.eclipse.jetty.continuation.Continuation;
50 import org.eclipse.jetty.continuation.ContinuationListener;
51 import org.eclipse.jetty.continuation.ContinuationSupport;
200 public void onComplete(Continuation continuation)
204 public void onTimeout(Continuation continuation)
206 _queue[priority].remove(continuation);
378 Continuation continuation = ContinuationSupport.getContinuation(request);
381 continuation.setTimeout(delayMs);
382 continuation.suspend();
398 final Continuation continuation
[all...]
/external/v8/benchmarks/
H A Dbase.js106 var continuation = null;
112 while (continuation || index < length) {
113 if (continuation) {
114 continuation = continuation();
118 continuation = suite.RunStep(runner);
120 if (continuation && typeof window != 'undefined' && window.setTimeout) {
232 // individual benchmark in the suite and returns a continuation
/external/libedit/examples/
H A Dtc1.c69 static int continuation = 0; variable
83 return (continuation ? b : a);
202 if (!continuation && num == 1)
209 continuation = 0;
217 if (continuation) {
231 history(hist, &ev, continuation ? H_APPEND : H_ENTER, buf);
234 continuation = ncontinuation;
236 if (continuation)
H A Dwtc1.c16 static int continuation; variable
26 return continuation ? b : a;
178 if(!continuation && numc == 1)
185 continuation = 0;
193 history_w(hist, &ev, continuation ? H_APPEND : H_ENTER, line);
195 continuation = ncontinuation;
197 if(continuation)
/external/v8/test/perf-test/Collections/
H A Dbase.js119 var continuation = null;
125 while (continuation || index < length) {
126 if (continuation) {
127 continuation = continuation();
134 continuation = suite.RunStep(runner);
137 if (continuation && typeof window != 'undefined' && window.setTimeout) {
314 // individual benchmark in the suite and returns a continuation
/external/e2fsprogs/lib/et/
H A Det_c.awk138 (continuation == 1) && ($0 ~ /\\[ \t]*$/) {
144 (continuation == 1) && ($0 ~ /"[ \t]*$/) {
147 continuation = 0;
180 continuation++;
188 continuation++;
/external/kernel-headers/original/uapi/linux/
H A Dsom.h136 unsigned int continuation :1; member in struct:subspace_dictionary_record
/external/v8/test/mjsunit/es6/
H A Dgenerators-debug-scopes.js9 function RunTest(name, formals_and_body, args, handler, continuation) {
29 if (continuation)
30 continuation(res);
/external/v8/src/arm64/
H A Ddeoptimizer-arm64.cc285 // continuation address.
286 Register continuation = x7; local
287 saved_registers.Remove(continuation);
297 __ Ldr(continuation, MemOperand(last_output_frame,
301 __ Br(continuation);
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/
H A DHttp2.java69 static final byte FLAG_END_HEADERS = 0x4; // Used for headers and continuation.
89 private final ContinuationSource continuation; field in class:Http2.Reader
98 this.continuation = new ContinuationSource(this.source);
99 this.hpackReader = new Hpack.Reader(headerTableSize, continuation);
205 continuation.length = continuation.left = length;
206 continuation.padding = padding;
207 continuation.flags = flags;
208 continuation.streamId = streamId;
591 * class lazily reads continuation frame
[all...]

Completed in 619 milliseconds

123