| /external/chromium-trace/catapult/telemetry/third_party/webpagereplay/third_party/dns/rdtypes/ |
| mxbase.py | 30 @ivar exchange: the exchange name
31 @type exchange: dns.name.Name object"""
33 __slots__ = ['preference', 'exchange']
35 def __init__(self, rdclass, rdtype, preference, exchange):
38 self.exchange = exchange
41 exchange = self.exchange.choose_relativity(origin, relativize)
42 return '%d %s' % (self.preference, exchange)
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ExchangerTest.java | 33 * exchange exchanges objects across two threads
39 assertSame(one, e.exchange(two));
40 assertSame(two, e.exchange(one));
44 assertSame(two, e.exchange(one));
45 assertSame(one, e.exchange(two));
53 * timed exchange exchanges objects across two threads
59 assertSame(one, e.exchange(two, LONG_DELAY_MS, MILLISECONDS));
60 assertSame(two, e.exchange(one, LONG_DELAY_MS, MILLISECONDS));
64 assertSame(two, e.exchange(one, LONG_DELAY_MS, MILLISECONDS));
65 assertSame(one, e.exchange(two, LONG_DELAY_MS, MILLISECONDS))
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/client/ |
| AsyncHttpConnection.java | 74 HttpExchange exchange=_exchange; local
76 LOG.debug("exchange {} on {}",exchange,this);
81 if (!_generator.isCommitted() && exchange!=null && exchange.getStatus() == HttpExchange.STATUS_WAITING_FOR_COMMIT)
83 LOG.debug("commit {}",exchange);
102 _requestContentChunk = exchange.getRequestContentChunk(null);
106 LOG.debug("complete {}",exchange);
109 if (exchange.getStatus() < HttpExchange.STATUS_WAITING_FOR_RESPONSE)
110 exchange.setStatus(HttpExchange.STATUS_WAITING_FOR_RESPONSE)
[all...] |
| BlockingHttpConnection.java | 59 protected void exchangeExpired(HttpExchange exchange)
63 super.exchangeExpired(exchange);
115 HttpExchange exchange; local
118 exchange=_exchange;
119 while (exchange == null)
124 exchange=_exchange;
138 LOG.debug("exchange {}",exchange);
143 if (!_generator.isCommitted() && exchange!=null && exchange.getStatus() == HttpExchange.STATUS_WAITING_FOR_COMMIT
[all...] |
| AbstractHttpConnection.java | 65 // The current exchange waiting for a response
134 // Adjusts the idle timeout in case the default or exchange timeout
147 // Make it larger than the exchange timeout so that there are
148 // no races between the idle timeout and the exchange timeout
271 HttpExchange exchange = _exchange; local
272 if (exchange==null)
274 LOG.warn("No exchange for response");
284 exchange.setEventListener(new NonFinalResponseListener(exchange));
289 if (HttpMethods.CONNECT.equalsIgnoreCase(exchange.getMethod())
304 HttpExchange exchange = _exchange; local
318 HttpExchange exchange = _exchange; local
330 HttpExchange exchange = _exchange; local
338 HttpExchange exchange = _exchange; local
346 HttpExchange exchange = _exchange; local
378 HttpExchange exchange = _exchange; local
[all...] |
| HttpDestination.java | 376 // Another connection stole the exchange that caused the creation of this connection ?
385 HttpExchange exchange = _exchanges.remove(0); local
386 send(connection, exchange);
552 // Schedule the timeout here, before we queue the exchange
579 protected void exchangeExpired(HttpExchange exchange)
581 // The exchange may expire while waiting in the
585 _exchanges.remove(exchange);
589 protected void send(AbstractHttpConnection connection, HttpExchange exchange) throws IOException
593 // If server closes the connection, put the exchange back
594 // to the exchange queue and recycle the connectio
728 HttpExchange exchange = null; local
741 HttpExchange exchange = null; local
[all...] |
| /art/tools/ahat/src/ |
| StaticHandler.java | 38 public void handle(HttpExchange exchange) throws IOException {
42 exchange.getResponseHeaders().add("Content-Type", "text/html");
43 exchange.sendResponseHeaders(404, 0);
44 PrintStream ps = new PrintStream(exchange.getResponseBody());
49 exchange.getResponseHeaders().add("Content-Type", mContentType);
50 exchange.sendResponseHeaders(200, 0);
51 OutputStream os = exchange.getResponseBody();
|
| BitmapHandler.java | 36 public void handle(HttpExchange exchange) throws IOException {
38 Query query = new Query(exchange.getRequestURI());
47 exchange.getResponseHeaders().add("Content-Type", "image/png");
48 exchange.sendResponseHeaders(200, 0);
49 OutputStream os = exchange.getResponseBody();
53 exchange.getResponseHeaders().add("Content-Type", "text/html");
54 exchange.sendResponseHeaders(404, 0);
55 PrintStream ps = new PrintStream(exchange.getResponseBody());
63 System.err.println("Exception when handling " + exchange.getRequestURI() + ": ");
|
| AhatHttpHandler.java | 38 public void handle(HttpExchange exchange) throws IOException {
39 exchange.getResponseHeaders().add("Content-Type", "text/html;charset=utf-8");
40 exchange.sendResponseHeaders(200, 0);
41 PrintStream ps = new PrintStream(exchange.getResponseBody());
45 mAhatHandler.handle(doc, new Query(exchange.getRequestURI()));
50 System.err.println("Exception when handling " + exchange.getRequestURI() + ": ");
|
| HelpHandler.java | 34 public void handle(HttpExchange exchange) throws IOException {
36 exchange.getResponseHeaders().add("Content-Type", "text/html;charset=utf-8");
37 exchange.sendResponseHeaders(200, 0);
38 PrintStream ps = new PrintStream(exchange.getResponseBody());
|
| /external/libcxx/test/std/utilities/utility/exchange/ |
| exchange.pass.cpp | 12 // exchange
23 assert ( std::exchange ( v, 23 ) == 12 );
25 assert ( std::exchange ( v, 67.2 ) == 23 );
28 assert ((std::exchange<int, float> ( v, {} )) == 67 );
35 assert ( !std::exchange ( b, true ));
43 assert ( std::exchange ( s3, s2 ) == s1 );
45 assert ( std::exchange ( s3, "Hi Mom!" ) == s2 );
49 assert ( std::exchange ( s3, {} ) == s2 );
53 assert ( std::exchange ( s3, "" ) == s2 );
|
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/utilities/utility/exchange/ |
| exchange.pass.cpp | 12 // exchange
23 assert ( std::exchange ( v, 23 ) == 12 );
25 assert ( std::exchange ( v, 67.2 ) == 23 );
28 assert ((std::exchange<int, float> ( v, {} )) == 67 );
35 assert ( !std::exchange ( b, true ));
43 assert ( std::exchange ( s3, s2 ) == s1 );
45 assert ( std::exchange ( s3, "Hi Mom!" ) == s2 );
49 assert ( std::exchange ( s3, {} ) == s2 );
53 assert ( std::exchange ( s3, "" ) == s2 );
|
| /external/v8/test/mjsunit/asm/ |
| 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;
|
| /dalvik/dx/ |
| README.txt | 1 Home of Dalvik eXchange, the thing that takes in class files and
|
| /external/libxml2/test/catalogs/ |
| catal.script | 3 public "-//OASIS//DTD XML Exchange Table Model 19990315//EN"
|
| whites.script | 3 public " -//OASIS//DTD XML Exchange Table Model 19990315//EN"
|
| whites.sgml | 2 PUBLIC "-//OASIS//DTD XML Exchange Table Model 19990315//EN " "soextblx.dtd"
|
| catal3.sgml | 2 PUBLIC "-//OASIS//DTD XML Exchange Table Model 19990315//EN" "soextblx.dtd"
|
| /toolchain/binutils/binutils-2.25/gas/testsuite/gas/z80/ |
| misc.s | 3 ;;; exchange instructions
|
| /external/clang/test/CodeGen/ |
| ms-intrinsics.c | 24 // CHECK: %[[EXCHANGE:[0-9]+]] = atomicrmw xchg [[iPTR]]* %[[TARGET]], [[iPTR]] %[[VALUE]] seq_cst
25 // CHECK: %[[RESULT:[0-9]+]] = inttoptr [[iPTR]] %[[EXCHANGE]] to i8*
30 void *Exchange, void *Comparand) {
31 return _InterlockedCompareExchangePointer(Destination, Exchange, Comparand);
34 // CHECK: define{{.*}}i8* @test_InterlockedCompareExchangePointer(i8** %Destination, i8* %Exchange, i8* %Comparand){{.*}}{
36 // CHECK: %[[EXCHANGE:[0-9]+]] = ptrtoint i8* %Exchange to [[iPTR]]
38 // CHECK: %[[XCHG:[0-9]+]] = cmpxchg volatile [[iPTR]]* %[[DEST:[0-9]+]], [[iPTR]] %[[COMPARAND:[0-9]+]], [[iPTR]] %[[EXCHANGE:[0-9]+]] seq_cst seq_cst
49 // CHECK: %[[EXCHANGE:[0-9]+]] = atomicrmw xchg i32* %Target, i32 %Value seq_cst
50 // CHECK: ret i32 %[[EXCHANGE:[0-9]+]
[all...] |
| /system/core/metricsd/uploader/ |
| crash_counters.cc | 27 return kernel_crashes_.exchange(0);
35 return unclean_shutdowns_.exchange(0);
43 return user_crashes_.exchange(0);
|
| /external/chromium-trace/catapult/telemetry/third_party/webpagereplay/third_party/dns/rdtypes/ANY/ |
| AFSDB.py | 27 # "preference" attribute, and "hostname" an alias for the "exchange"
46 return self.exchange
49 self.exchange = hostname
|
| /external/autotest/client/common_lib/cros/bluetooth/ |
| bluetooth_gatt_server.py | 42 """Handle exchange MTU request.
44 Exchange MTU request/response usually initiates client-server
45 communication. The method sends exchange MTU response back to client.
53 'Invalid MTU size: expected 2 bytes for Exchange MTU Request')
|
| /external/jetty/src/java/org/eclipse/jetty/client/security/ |
| DigestAuthentication.java | 44 public void setCredentials( HttpExchange exchange )
55 buffer.append(", ").append("uri").append('=').append('"').append(exchange.getURI()).append('"');
59 String cnonce = newCnonce(exchange, securityRealm, details);
62 exchange, securityRealm, details)).append('"');
71 exchange.setRequestHeader( HttpHeaders.AUTHORIZATION,
75 protected String newResponse(String cnonce, HttpExchange exchange, Realm securityRealm, Map details)
89 md.update(exchange.getMethod().getBytes(StringUtil.__ISO_8859_1));
91 md.update(exchange.getURI().getBytes(StringUtil.__ISO_8859_1));
116 protected String newCnonce(HttpExchange exchange, Realm securityRealm, Map details)
|
| /packages/services/Telephony/src/com/android/phone/ |
| ProcessOutgoingCallTest.java | 71 String exchange = number.substring(length - 7, length - 4); local
72 Log.v(TAG, "exchange = " + exchange);
73 if (exchange.equals("555")) {
|
