| /external/jetty/src/java/org/eclipse/jetty/client/ |
| D | AsyncHttpConnection.java | 74 HttpExchange exchange=_exchange; in handle() local
76 LOG.debug("exchange {} on {}",exchange,this); in handle()
81 …if (!_generator.isCommitted() && exchange!=null && exchange.getStatus() == HttpExchange.STATUS_WAI… in handle()
83 LOG.debug("commit {}",exchange); in handle()
102 _requestContentChunk = exchange.getRequestContentChunk(null); in handle()
106 LOG.debug("complete {}",exchange); in handle()
109 if (exchange.getStatus() < HttpExchange.STATUS_WAITING_FOR_RESPONSE) in handle()
110 exchange.setStatus(HttpExchange.STATUS_WAITING_FOR_RESPONSE); in handle()
117 _requestContentChunk=exchange.getRequestContentChunk(null); in handle()
120 exchange.setStatus(HttpExchange.STATUS_WAITING_FOR_RESPONSE); in handle()
[all …]
|
| D | BlockingHttpConnection.java | 59 protected void exchangeExpired(HttpExchange exchange) in exchangeExpired() argument
63 super.exchangeExpired(exchange); in exchangeExpired()
115 HttpExchange exchange; in handle() local
118 exchange=_exchange; in handle()
119 while (exchange == null) in handle()
124 exchange=_exchange; in handle()
138 LOG.debug("exchange {}",exchange); in handle()
143 …if (!_generator.isCommitted() && exchange!=null && exchange.getStatus() == HttpExchange.STATUS_WAI… in handle()
162 _requestContentChunk = exchange.getRequestContentChunk(null); in handle()
173 _requestContentChunk=exchange.getRequestContentChunk(null); in handle()
[all …]
|
| D | AbstractHttpConnection.java | 271 HttpExchange exchange = _exchange; in startResponse() local
272 if (exchange==null) in startResponse()
284 exchange.setEventListener(new NonFinalResponseListener(exchange)); in startResponse()
289 if (HttpMethods.CONNECT.equalsIgnoreCase(exchange.getMethod())) in startResponse()
296 exchange.getEventListener().onResponseStatus(version,status,reason); in startResponse()
297 exchange.setStatus(HttpExchange.STATUS_PARSING_HEADERS); in startResponse()
304 HttpExchange exchange = _exchange; in parsedHeader() local
305 if (exchange!=null) in parsedHeader()
311 exchange.getEventListener().onResponseHeader(name,value); in parsedHeader()
318 HttpExchange exchange = _exchange; in headerComplete() local
[all …]
|
| D | HttpDestination.java | 385 HttpExchange exchange = _exchanges.remove(0); in onNewConnection() local
386 send(connection, exchange); in onNewConnection()
579 protected void exchangeExpired(HttpExchange exchange) in exchangeExpired() argument
585 _exchanges.remove(exchange); in exchangeExpired()
589 protected void send(AbstractHttpConnection connection, HttpExchange exchange) throws IOException in send() argument
595 if (!connection.send(exchange)) in send()
597 if (exchange.getStatus() <= HttpExchange.STATUS_WAITING_FOR_CONNECTION) in send()
598 _exchanges.add(0, exchange); in send()
728 HttpExchange exchange = null; in onException() local
732 exchange = _exchanges.remove(0); in onException()
[all …]
|
| D | HttpClient.java | 160 public void send(HttpExchange exchange) throws IOException in send() argument
162 boolean ssl = HttpSchemes.HTTPS_BUFFER.equalsIgnoreCase(exchange.getScheme()); in send()
163 HttpDestination destination = getDestination(exchange.getAddress(), ssl); in send()
164 destination.send(exchange); in send()
|
| /external/chromium-trace/catapult/telemetry/third_party/webpagereplay/third_party/dns/rdtypes/ |
| D | mxbase.py | 35 def __init__(self, rdclass, rdtype, preference, exchange): argument
38 self.exchange = exchange
41 exchange = self.exchange.choose_relativity(origin, relativize)
42 return '%d %s' % (self.preference, exchange)
46 exchange = tok.get_name()
47 exchange = exchange.choose_relativity(origin, relativize)
49 return cls(rdclass, rdtype, preference, exchange)
56 self.exchange.to_wire(file, compress, origin)
60 self.exchange.to_digestable(origin)
66 (exchange, cused) = dns.name.from_wire(wire[: current + rdlen],
[all …]
|
| /external/libcxx/test/std/utilities/utility/exchange/ |
| D | exchange.pass.cpp | 23 assert ( std::exchange ( v, 23 ) == 12 ); in main()
25 assert ( std::exchange ( v, 67.2 ) == 23 ); in main()
28 assert ((std::exchange<int, float> ( v, {} )) == 67 ); in main()
35 assert ( !std::exchange ( b, true )); in main()
43 assert ( std::exchange ( s3, s2 ) == s1 ); in main()
45 assert ( std::exchange ( s3, "Hi Mom!" ) == s2 ); in main()
49 assert ( std::exchange ( s3, {} ) == s2 ); in main()
53 assert ( std::exchange ( s3, "" ) == s2 ); in main()
|
| /external/deqp/framework/delibs/dethread/ |
| D | deAtomic.h | 100 …t32 deAtomicCompareExchangeUint32 (volatile deUint32* dstAddr, deUint32 compare, deUint32 exchange) in deAtomicCompareExchangeUint32() argument
103 return _InterlockedCompareExchange((volatile long*)dstAddr, exchange, compare); in deAtomicCompareExchangeUint32()
105 return __sync_val_compare_and_swap(dstAddr, compare, exchange); in deAtomicCompareExchangeUint32()
184 …t64 deAtomicCompareExchangeUint64 (volatile deUint64* dstAddr, deUint64 compare, deUint64 exchange) in deAtomicCompareExchangeUint64() argument
187 return _InterlockedCompareExchange64((volatile long long*)dstAddr, exchange, compare); in deAtomicCompareExchangeUint64()
189 return __sync_val_compare_and_swap(dstAddr, compare, exchange); in deAtomicCompareExchangeUint64()
243 DE_INLINE void* deAtomicCompareExchangePtr (void* volatile* dstAddr, void* compare, void* exchange) in deAtomicCompareExchangePtr() argument
246 …)deAtomicCompareExchangeUint64((volatile deUint64*)dstAddr, (deUint64)compare, (deUint64)exchange); in deAtomicCompareExchangePtr()
248 …)deAtomicCompareExchangeUint32((volatile deUint32*)dstAddr, (deUint32)compare, (deUint32)exchange); in deAtomicCompareExchangePtr()
|
| /external/v8/test/mjsunit/asm/ |
| D | atomics-exchange.js | 15 var exchange = stdlib.Atomics.exchange;
21 return exchange(MEM8, i, x)|0;
27 return exchange(MEM16, i, x)|0;
33 return exchange(MEM32, i, x)|0;
39 return exchange(MEMU8, i, x)>>>0;
45 return exchange(MEMU16, i, x)>>>0;
51 return exchange(MEMU32, i, x)>>>0;
|
| /external/jetty/src/java/org/eclipse/jetty/client/security/ |
| D | DigestAuthentication.java | 44 public void setCredentials( HttpExchange exchange ) in setCredentials() argument
55 … buffer.append(", ").append("uri").append('=').append('"').append(exchange.getURI()).append('"'); in setCredentials()
59 String cnonce = newCnonce(exchange, securityRealm, details); in setCredentials()
62 exchange, securityRealm, details)).append('"'); in setCredentials()
71 exchange.setRequestHeader( HttpHeaders.AUTHORIZATION, in setCredentials()
75 …protected String newResponse(String cnonce, HttpExchange exchange, Realm securityRealm, Map detail… in newResponse() argument
89 md.update(exchange.getMethod().getBytes(StringUtil.__ISO_8859_1)); in newResponse()
91 md.update(exchange.getURI().getBytes(StringUtil.__ISO_8859_1)); in newResponse()
116 protected String newCnonce(HttpExchange exchange, Realm securityRealm, Map details) in newCnonce() argument
|
| D | BasicAuthentication.java | 53 public void setCredentials( HttpExchange exchange ) throws IOException in setCredentials() argument
55 exchange.setRequestHeader( HttpHeaders.AUTHORIZATION_BUFFER, _authorization); in setCredentials()
|
| D | ProxyAuthorization.java | 53 public void setCredentials( HttpExchange exchange ) throws IOException in setCredentials() argument
55 exchange.setRequestHeader( HttpHeaders.PROXY_AUTHORIZATION_BUFFER, _authorization); in setCredentials()
|
| D | Authentication.java | 32 public void setCredentials( HttpExchange exchange) throws IOException; in setCredentials() argument
|
| /external/jetty/src/java/org/eclipse/jetty/servlets/ |
| D | ProxyServlet.java | 444 HttpExchange exchange = new HttpExchange() in service() local
551 …exchange.setScheme(HttpSchemes.HTTPS.equals(request.getScheme())?HttpSchemes.HTTPS_BUFFER:HttpSche… in service()
552 exchange.setMethod(request.getMethod()); in service()
553 exchange.setURL(url.toString()); in service()
554 exchange.setVersion(request.getProtocol()); in service()
571 exchange.setRequestHeader("Host",_hostHeader); in service()
602 … exchange.setRequestHeader(HttpHeaders.CONTENT_LENGTH,Long.toString(contentLength)); in service()
618 exchange.setRequestHeader(hdr,val); in service()
624 exchange.setRequestHeader("Via","1.1 (jetty)"); in service()
627 exchange.addRequestHeader("X-Forwarded-For",request.getRemoteAddr()); in service()
[all …]
|
| /external/libcxx/test/std/atomics/atomics.types.generic/ |
| D | bool.pass.cpp | 77 assert(obj.exchange(false) == true); in main()
79 assert(obj.exchange(true, std::memory_order_relaxed) == false); in main()
132 assert(obj.exchange(false) == true); in main()
134 assert(obj.exchange(true, std::memory_order_relaxed) == false); in main()
187 assert(obj.exchange(false) == true); in main()
189 assert(obj.exchange(true, std::memory_order_relaxed) == false); in main()
|
| D | address.pass.cpp | 97 assert(obj.exchange(T(2)) == T(1)); in do_test()
99 assert(obj.exchange(T(3), std::memory_order_relaxed) == T(2)); in do_test()
|
| D | integral.pass.cpp | 113 assert(obj.exchange(T(2)) == T(1)); in do_test()
115 assert(obj.exchange(T(3), std::memory_order_relaxed) == T(2)); in do_test()
|
| /external/chromium-trace/catapult/telemetry/third_party/webpagereplay/third_party/dns/rdtypes/ANY/ |
| D | AFSDB.py | 46 return self.exchange
49 self.exchange = hostname
|
| /external/v8/test/mjsunit/harmony/ |
| D | atomics.js | 59 assertThrows(function() { Atomics.exchange(o, 0, 0); }, TypeError);
95 testAtomicOp(Atomics.exchange, si32a, i, 0, name);
110 assertEquals(undefined, Atomics.exchange(si32a, i, 0), name);
124 assertEquals(undefined, Atomics.exchange(si32a2, i, 0), name);
139 assertEquals(undefined, Atomics.exchange(si32a, i, 0), name);
162 testAtomicOp(Atomics.exchange, array, i, 3, name);
350 assertEquals(0x30, Atomics.exchange(array, i, 0x1c), name);
353 assertEquals(0x1c, Atomics.exchange(array, i, 0x09), name);
426 assertEquals(0x09, Atomics.exchange(sta, 0, v), name);
524 assertEquals(val, Atomics.exchange(sta, 0, operand), name);
|
| /external/llvm/test/CodeGen/PowerPC/ |
| D | atomic-1.ll | 21 define i32 @exchange(i32* %mem, i32 %val) nounwind {
22 ; CHECK-LABEL: exchange:
|
| /external/llvm/test/CodeGen/SystemZ/ |
| D | atomicrmw-xchg-01.ll | 1 ; Test 8-bit atomic exchange.
6 ; Check exchange with a variable.
43 ; Check exchange with a constant. We should force the constant into
|
| D | atomicrmw-xchg-02.ll | 1 ; Test 16-bit atomic exchange.
6 ; Check exchange with a variable.
43 ; Check exchange with a constant. We should force the constant into
|
| D | atomicrmw-xchg-04.ll | 1 ; Test 64-bit atomic exchange.
5 ; Check register exchange.
76 ; Check exchange of a constant. We should force it into a register and
|
| D | atomicrmw-xchg-03.ll | 1 ; Test 32-bit atomic exchange.
5 ; Check register exchange.
109 ; Check exchange of a constant. We should force it into a register and
|
| /external/pdfium/ |
| D | update_pdfium.py | 104 def exchange(currentDir, newDir, oldDir): function
126 exchange(targetDir, newDir, oldDir)
|