| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| RealWebSocketTest.java | 31 import okio.Sink;
67 client = new RealWebSocket(true, server2client.source(), client2Server.sink(), random,
80 server = new RealWebSocket(false, client2Server.source(), server2client.sink(), random,
144 @Override public void writeTo(BufferedSink sink) throws IOException {
145 sink.writeUtf8("Hel").flush();
146 sink.writeUtf8("lo!").flush();
147 sink.close();
161 @Override public void writeTo(BufferedSink sink) throws IOException {
162 sink.writeUtf8("Hel").flush();
164 sink.writeUtf8("lo!").flush()
477 BufferedSink sink() { method
[all...] |
| /external/tensorflow/tensorflow/compiler/tf2xla/ |
| functionalize_control_flow_test.cc | 221 auto sink = ops::Identity(scope.WithOpName("sink"), exit); local
230 // Regression test: control edges from an Enter node to the graph sink should
254 auto sink = ops::Identity(scope.WithOpName("sink"), while_op[0]); local
701 auto sink = ops::Identity(scope.WithOpName("sink"), exit_i); local
739 auto sink = ops::Identity(scope.WithOpName("sink"), while_op[0]); local
[all...] |
| /external/tensorflow/tensorflow/core/graph/ |
| graph.cc | 100 strings::StrAppend(&ret, " sink}");
277 // Source and sink have no endpoints, just control edges.
287 Node* sink = AddNode(def, &status); local
289 CHECK_EQ(sink->id(), kSinkId);
291 AddControlEdge(source, sink);
380 // source/sink must only be linked via control slots, and
|
| /external/valgrind/coregrind/ |
| m_libcprint.c | 115 /* Ok, the logging sink is running now. Print a suitable preamble.
327 static void revert_sink_to_stderr ( OutputSink *sink )
329 sink->fd = 2; /* stderr */
330 sink->type = VgLogTo_Fd;
331 VG_(free)(sink->fsname_expanded);
332 sink->fsname_expanded = NULL;
335 static Int prepare_sink_fd(const HChar *clo_fname_unexpanded, OutputSink *sink,
351 sink->fsname_expanded = logfilename;
352 sink->type = VgLogTo_File;
364 OutputSink *sink, Bool is_xml
605 OutputSink* sink; member in struct:__anon42338
932 OutputSink* sink; member in struct:__anon42340
[all...] |
| /external/webrtc/webrtc/base/ |
| socket_unittest.cc | 193 testing::StreamSink sink; local
199 sink.Monitor(client.get());
206 sink.Monitor(server.get());
212 EXPECT_FALSE(sink.Check(server.get(), testing::SSE_READ));
223 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN));
224 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
227 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout);
240 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN));
241 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
248 testing::StreamSink sink; local
296 testing::StreamSink sink; local
329 testing::StreamSink sink; local
389 testing::StreamSink sink; local
431 testing::StreamSink sink; local
459 testing::StreamSink sink; local
497 testing::StreamSink sink; local
570 testing::StreamSink sink; local
625 testing::StreamSink sink; local
675 testing::StreamSink sink; local
795 testing::StreamSink sink; local
[all...] |
| virtualsocket_unittest.cc | 240 testing::StreamSink sink; local
248 sink.Monitor(client);
255 sink.Monitor(server);
263 EXPECT_FALSE(sink.Check(server, testing::SSE_READ));
275 EXPECT_FALSE(sink.Check(client, testing::SSE_OPEN));
276 EXPECT_FALSE(sink.Check(client, testing::SSE_CLOSE));
282 EXPECT_FALSE(sink.Check(client, testing::SSE_OPEN));
283 EXPECT_FALSE(sink.Check(client, testing::SSE_CLOSE));
286 EXPECT_TRUE(sink.Check(server, testing::SSE_READ));
300 EXPECT_TRUE(sink.Check(client, testing::SSE_OPEN))
307 testing::StreamSink sink; local
342 testing::StreamSink sink; local
429 testing::StreamSink sink; local
479 testing::StreamSink sink; local
743 testing::StreamSink sink; local
[all...] |
| /frameworks/av/services/audiopolicy/common/managerdefinitions/src/ |
| Serializer.cpp | 260 // Sink role
352 const char RouteTraits::Attributes::sink[] = "sink"; member in class:android::RouteTraits::Attributes
370 string sinkAttr = getXmlAttribute(root, Attributes::sink);
372 ALOGE("%s: No %s found", __FUNCTION__, Attributes::sink);
375 // Convert Sink name to port pointer
376 sp<AudioPort> sink = ctx->findPortByTagName(String8(sinkAttr.c_str())); local
377 if (sink == NULL) {
378 ALOGE("%s: no sink found with name=%s", __FUNCTION__, sinkAttr.c_str());
381 element->setSink(sink);
[all...] |
| /frameworks/base/tests/AccessoryDisplay/sink/src/com/android/accessorydisplay/sink/ |
| SinkActivity.java | 17 package com.android.accessorydisplay.sink;
54 "com.android.accessorydisplay.sink.ACTION_USB_DEVICE_PERMISSION";
58 private static final String DESCRIPTION = "Accessory Display Sink Test Application";
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/sysroot/usr/include/pulse/ |
| introspect.h | 84 * The server can have an arbitrary number of sinks and sources. Each sink
98 * \subsection siso_subsec Sink Inputs and Source Outputs
100 * Sink inputs and source outputs are the representations of the client ends
104 * Sink inputs and source outputs only have an index to identify them. As
156 * It is also possible to mute a sink or source:
163 * \subsection siso_subsec Sink Inputs and Source Outputs
167 * of its associated sink input or source output, using
170 * It is also possible to remove sink inputs and source outputs, terminating
173 * \li Sink input - pa_context_kill_sink_input()
198 /** Stores information about a specific port of a sink. Pleas
517 uint32_t sink; \/**< Index of the connected sink *\/ member in struct:pa_sink_input_info
[all...] |
| /prebuilts/go/darwin-x86/test/ |
| live.go | 192 var sink *int var
196 sink = p // prevent stack allocation, otherwise p is rematerializeable
671 sink = a[0]
|
| /prebuilts/go/linux-x86/test/ |
| live.go | 192 var sink *int var
196 sink = p // prevent stack allocation, otherwise p is rematerializeable
671 sink = a[0]
|
| /external/icu/android_icu4j/src/main/java/android/icu/text/ |
| RuleBasedCollator.java | 1118 CollationKeyByteSink sink = new CollationKeyByteSink(key); local
[all...] |
| Collator.java | 974 KeywordsSink sink = new KeywordsSink(); local
[all...] |
| DateIntervalInfo.java | 407 * Sink for enumerating all of the date interval skeletons.
409 private static final class DateIntervalSink extends UResource.Sink {
581 // Instantiate the sink to process the data and the resource bundle
582 DateIntervalSink sink = new DateIntervalSink(this); local
605 resource.getAllItemsWithFallback(pathToIntervalFormats, sink);
608 calendarTypeToUse = sink.getAndResetNextCalendarType();
[all...] |
| RelativeDateTimeFormatter.java | 828 * Sink for enumerating all of the relative data time formatter names.
833 private static final class RelDateTimeDataSink extends UResource.Sink {
1174 RelDateTimeDataSink sink = new RelDateTimeDataSink(); local
[all...] |
| /external/icu/icu4j/main/classes/collate/src/com/ibm/icu/text/ |
| RuleBasedCollator.java | 1144 CollationKeyByteSink sink = new CollationKeyByteSink(key); local
[all...] |
| /external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/ |
| ResponseCacheTest.java | 1797 BufferedSink sink = Okio.buffer(new GzipSink(result)); local
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/ |
| DiskLruCacheTest.java | 389 BufferedSink sink = Okio.buffer(fileSystem.sink(journalFile)); local
390 sink.writeUtf8(MAGIC + "\n" + VERSION_1 + "\n100\n2\n\nCLEAN k1 1 1"); // no trailing newline
391 sink.close();
1211 BufferedSink sink = Okio.buffer(editor.newSink(0)); local
1252 BufferedSink sink = Okio.buffer(fileSystem.sink(journalFile)); local
1291 BufferedSink sink = Okio.buffer(fileSystem.sink(file)); local
1391 BufferedSink sink = Okio.buffer(fileSystem.sink(to)); local
[all...] |
| /frameworks/base/packages/PrintSpooler/src/com/android/printspooler/model/ |
| RemotePrintDocument.java | 1032 ParcelFileDescriptor sink = null; local
[all...] |
| /prebuilts/tools/common/m2/repository/com/squareup/okhttp/mockwebserver/2.7.4/ |
| mockwebserver-2.7.4.jar | |
| /prebuilts/tools/common/m2/repository/com/squareup/okhttp/okhttp-ws/2.7.4/ |
| okhttp-ws-2.7.4.jar | |
| /prebuilts/tools/common/m2/repository/org/apache/maven/doxia/doxia-module-xdoc/1.0/ |
| doxia-module-xdoc-1.0.jar | |
| /bionic/libc/kernel/uapi/linux/ |
| media.h | 136 struct media_pad_desc sink; member in struct:media_link_desc
|
| /external/icu/android_icu4j/src/main/java/android/icu/impl/ |
| ICUResourceBundle.java | 371 public void getAllItemsWithFallbackNoFail(String path, UResource.Sink sink) {
373 getAllItemsWithFallback(path, sink);
379 public void getAllItemsWithFallback(String path, UResource.Sink sink)
402 rb.getAllItemsWithFallback(key, readerValue, sink);
406 UResource.Key key, ReaderValue readerValue, UResource.Sink sink) {
409 // The sink needs to store a placeholder value for the no-fallback/no-inheritance marker
414 // When the sink sees the no-fallback/no-inheritance marker
[all...] |
| LocaleDisplayNamesImpl.java | 114 private final class CapitalizationContextSink extends UResource.Sink {
219 CapitalizationContextSink sink = new CapitalizationContextSink(); local
221 rb.getAllItemsWithFallback("contextTransforms", sink);
226 needBrkIter = sink.hasCapitalizationUsage;
|
