| /external/jetty/src/java/org/eclipse/jetty/continuation/ |
| D | ContinuationSupport.java | 19 package org.eclipse.jetty.continuation;
110 Continuation continuation = (Continuation) request.getAttribute(Continuation.ATTRIBUTE); in getContinuation() local
111 if (continuation!=null) in getContinuation()
112 return continuation; in getContinuation()
121 continuation=__newServlet3Continuation.newInstance(request); in getContinuation()
122 request.setAttribute(Continuation.ATTRIBUTE,continuation); in getContinuation()
123 return continuation; in getContinuation()
137 continuation=new FauxContinuation(request); in getContinuation()
139 continuation= __newJetty6Continuation.newInstance(request,c); in getContinuation()
140 request.setAttribute(Continuation.ATTRIBUTE,continuation); in getContinuation()
[all …]
|
| D | ContinuationListener.java | 19 package org.eclipse.jetty.continuation;
43 public void onComplete(Continuation continuation); in onComplete() argument
53 public void onTimeout(Continuation continuation); in onTimeout() argument
|
| D | Jetty6Continuation.java | 19 package org.eclipse.jetty.continuation;
58 … public Jetty6Continuation(ServletRequest request, org.mortbay.util.ajax.Continuation continuation) in Jetty6Continuation() argument
66 _j6Continuation=continuation; in Jetty6Continuation()
|
| D | ContinuationThrowable.java | 20 package org.eclipse.jetty.continuation;
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/demos/tunes_db/client/ |
| D | main.py | 85 continuation = self.request.get('c', '')
86 if continuation:
92 continuation=continuation or None,
101 'continuation': response.continuation or '',
102 'this_page': continuation,
173 continuation = self.request.get('c', '')
178 if continuation:
184 continuation=continuation or None,
194 'continuation': response.continuation or '',
195 'this_page': continuation,
[all …]
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/demos/tunes_db/server/ |
| D | tunes_db.py | 162 continuation = messages.StringField(1) variable in SearchArtistsRequest
180 continuation = messages.StringField(2) variable in SearchArtistsResponse
281 continuation = messages.StringField(1) variable in SearchAlbumsRequest
300 continuation = messages.StringField(2) variable in SearchAlbumsResponse
367 if request.continuation:
368 encoded_search, continuation = request.continuation.split(':', 1)
372 continuation = None
383 if continuation:
386 query.with_cursor(continuation)
392 continuation = None
[all …]
|
| D | tunes_db_test.py | 200 request.continuation = response.continuation
211 request.continuation = response.continuation
231 request.continuation = response.continuation
237 self.assertEquals(None, response.continuation)
303 request.continuation = response.continuation
313 request.continuation = response.continuation
318 self.assertEquals(None, response.continuation)
335 request.continuation = response.continuation
341 self.assertEquals(None, response.continuation)
|
| /external/jetty/src/java/org/eclipse/jetty/server/handler/ |
| D | RequestLogHandler.java | 28 import org.eclipse.jetty.continuation.Continuation;
29 import org.eclipse.jetty.continuation.ContinuationListener;
60 AsyncContinuation continuation = baseRequest.getAsyncContinuation(); in handle() local
61 if (!continuation.isInitial()) in handle()
74 if (continuation.isAsync()) in handle()
76 if (continuation.isInitial()) in handle()
77 continuation.addContinuationListener(new ContinuationListener() in handle()
80 public void onTimeout(Continuation continuation) in handle()
85 public void onComplete(Continuation continuation) in handle()
|
| D | StatisticsHandler.java | 29 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(); in handle() local
109 if (continuation.isInitial()) in handle()
120 if (continuation.isResumed()) in handle()
136 if (continuation.isSuspended()) in handle()
[all …]
|
| D | GzipHandler.java | 36 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); in handle() local
270 if (continuation.isSuspended() && continuation.isResponseWrapped()) in handle()
272 continuation.addContinuationListener(new ContinuationListener() in handle()
274 public void onComplete(Continuation continuation) in handle()
286 public void onTimeout(Continuation continuation) in handle()
|
| /external/jetty/src/java/org/eclipse/jetty/servlets/ |
| D | QoSFilter.java | 38 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) in init()
125 public void onTimeout(Continuation continuation) in init()
127 _queue[priority].remove(continuation); in init()
173 Continuation continuation = ContinuationSupport.getContinuation(request); in doFilter() local
175 continuation.setTimeout(_suspendMs); in doFilter()
176 continuation.suspend(); in doFilter()
177 continuation.addContinuationListener(_listener[priority]); in doFilter()
[all …]
|
| D | DoSFilter.java | 49 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) in init()
204 public void onTimeout(Continuation continuation) in init()
206 _queue[priority].remove(continuation); in init()
378 Continuation continuation = ContinuationSupport.getContinuation(request); in doFilter() local
381 continuation.setTimeout(delayMs); in doFilter()
382 continuation.suspend(); in doFilter()
398 final Continuation continuation = ContinuationSupport.getContinuation(request); in doFilter() local
[all …]
|
| D | ProxyServlet.java | 49 import org.eclipse.jetty.continuation.Continuation;
50 import org.eclipse.jetty.continuation.ContinuationSupport;
422 final Continuation continuation = ContinuationSupport.getContinuation(request); in service() local
424 if (!continuation.isInitial()) in service()
461 continuation.complete(); in service()
518 if (!continuation.isInitial()) in service()
520 continuation.complete(); in service()
536 if (!continuation.isInitial()) in service()
538 continuation.complete(); in service()
546 continuation.complete(); in service()
[all …]
|
| D | GzipFilter.java | 42 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); in doFilter() local
300 if (continuation.isSuspended() && continuation.isResponseWrapped()) in doFilter()
302 …continuation.addContinuationListener(new ContinuationListenerWaitingForWrappedResponseToFinish(wra… in doFilter()
507 public void onComplete(Continuation continuation) in onComplete() argument
519 public void onTimeout(Continuation continuation) in onTimeout() argument
|
| /external/libedit/examples/ |
| D | tc1.c | 69 static int continuation = 0; variable
83 return (continuation ? b : a); in prompt()
202 if (!continuation && num == 1) in main()
209 continuation = 0; in main()
217 if (continuation) { in main()
231 history(hist, &ev, continuation ? H_APPEND : H_ENTER, buf); in main()
234 continuation = ncontinuation; in main()
236 if (continuation) in main()
|
| D | wtc1.c | 16 static int continuation; variable
26 return continuation ? b : a; in prompt()
178 if(!continuation && numc == 1) in main()
185 continuation = 0; in main()
193 history_w(hist, &ev, continuation ? H_APPEND : H_ENTER, line); in main()
195 continuation = ncontinuation; in main()
197 if(continuation) in main()
|
| /external/v8/benchmarks/ |
| D | base.js | 106 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) {
|
| /external/llvm/test/Transforms/ConstantHoisting/X86/ |
| D | phi.ll | 79 i64 462, label %continuation
81 i64 443, label %continuation
85 br label %continuation
87 continuation:
101 i64 462, label %continuation
103 i64 443, label %continuation
107 br label %continuation
109 continuation:
|
| /external/v8/test/mjsunit/compiler/ |
| D | inline-closures.js | 32 function mkClosure(continuation) { argument
34 if (continuation == 'g') return this.g(value);
35 if (continuation == 'h') return this.h(value);
|
| /external/v8/test/js-perf-test/ |
| D | base.js | 119 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) {
|
| /external/e2fsprogs/lib/et/ |
| D | et_c.awk | 138 (continuation == 1) && ($0 ~ /\\[ \t]*$/) {
144 (continuation == 1) && ($0 ~ /"[ \t]*$/) {
147 continuation = 0;
180 continuation++;
188 continuation++;
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | Http2.java | 89 private final ContinuationSource continuation; field in Http2.Reader
98 this.continuation = new ContinuationSource(this.source); in Reader()
99 this.hpackReader = new Hpack.Reader(headerTableSize, continuation); in Reader()
205 continuation.length = continuation.left = length; in readHeaderBlock()
206 continuation.padding = padding; in readHeaderBlock()
207 continuation.flags = flags; in readHeaderBlock()
208 continuation.streamId = streamId; in readHeaderBlock()
|
| /external/v8/src/arm64/ |
| D | deoptimizer-arm64.cc | 277 Register continuation = x7; in Generate() local
278 saved_registers.Remove(continuation); in Generate()
288 __ Ldr(continuation, MemOperand(last_output_frame, in Generate()
292 __ Br(continuation); in Generate()
|
| /external/autotest/server/site_tests/bluetooth_SDP_ServiceSearchRequestBasic/ |
| D | control | 20 In order to verify the correct behaviour of continuation state, some number of
23 to use this continuation state functionality.
|
| /external/v8/src/runtime/ |
| D | runtime-generator.cc | 59 DCHECK_LT(0, generator_object->continuation()); in RUNTIME_FUNCTION()
130 return Smi::FromInt(generator->continuation()); in RUNTIME_FUNCTION()
|