Searched refs:sink (Results 176 - 200 of 325) sorted by relevance

1234567891011>>

/external/clang/test/SemaCXX/
H A Dlambda-expressions.cpp173 struct sink {
174 template<typename...Ts> sink(Ts &&...) {}
178 sink {
/external/guava/guava/src/com/google/common/io/
H A DCharSource.java119 * Copies the contents of this source to the given sink.
122 * writing to {@code sink}
124 public long copyTo(CharSink sink) throws IOException { argument
125 checkNotNull(sink);
130 Writer writer = closer.register(sink.openStream());
H A DByteSource.java232 * writing to {@code sink}
234 public long copyTo(ByteSink sink) throws IOException { argument
235 checkNotNull(sink);
240 OutputStream out = closer.register(sink.openStream());
/external/guava/guava-tests/test/com/google/common/io/
H A DCharSourceTester.java117 TestCharSink sink = new TestCharSink();
119 assertEquals(expected.length(), source.copyTo(sink));
121 assertExpectedString(sink.getString());
/external/webrtc/talk/app/webrtc/
H A Drtpsender.cc56 void LocalAudioSinkAdapter::SetSink(cricket::AudioRenderer::Sink* sink) { argument
58 ASSERT(!sink || !sink_);
59 sink_ = sink;
194 // Use the renderer if the audio track has one, otherwise use the sink
/external/icu/icu4c/source/i18n/
H A Ddcfmtsym.cpp400 // Now load the rest of the data from the data sink.
402 DecFmtSymDataSink sink(*this);
410 ures_getAllItemsWithFallback(resource.getAlias(), path.data(), sink, status);
422 if (!sink.seenAll()) {
423 ures_getAllItemsWithFallback(resource.getAlias(), gNumberElementsLatnSymbols, sink, status);
428 sink.resolveMissingMonetarySeparators(fSymbols);
H A Dcollationruleparser.cpp63 sink(NULL), importer(NULL),
201 sink->addReset(resetStrength, str, errorReason, errorCode);
284 sink->addRelation(strength, prefix, str, extension, errorReason, errorCode);
307 sink->addRelation(strength, empty, UnicodeString(c), empty, errorReason, errorCode);
349 sink->addRelation(strength, empty, s, empty, errorReason, errorCode);
669 sink->optimize(set, errorReason, errorCode);
674 sink->suppressContractions(set, errorReason, errorCode);
H A Dcompactdecimalformat.cpp712 CmptDecDataSink sink(*result);
713 sink.isFallback = FALSE;
717 sink.isLatin = FALSE;
722 ures_getAllItemsWithFallback(resource.getAlias(), path.data(), sink, status);
729 sink.isFallback = TRUE;
733 sink.isLatin = TRUE;
734 ures_getAllItemsWithFallback(resource.getAlias(), gLatnPath, sink, status);
/external/v8/src/runtime/
H A Druntime-strings.cc323 uc16* sink = answer->GetChars(); local
325 uc16* end = sink + length;
333 String::WriteToFlat(first, sink, 0, first_length);
334 sink += first_length;
337 DCHECK(sink + separator_length <= end);
338 String::WriteToFlat(separator_raw, sink, 0, separator_length);
339 sink += separator_length;
344 DCHECK(sink + element_length <= end);
345 String::WriteToFlat(element, sink, 0, element_length);
346 sink
[all...]
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/
H A DWebSocketReader.java265 @Override public long read(Buffer sink, long byteCount) throws IOException { argument
289 sink.write(maskBuffer, 0, (int) read);
291 read = source.read(sink, toRead);
/external/v8/src/snapshot/
H A Dserializer.h12 #include "src/snapshot/snapshot-source-sink.h"
216 const SnapshotByteSink* sink() const { return &sink_; } function in class:v8::internal::Serializer
273 SnapshotByteSink* sink, HowToCode how_to_code,
277 sink_(sink),
272 ObjectSerializer(Serializer* serializer, HeapObject* obj, SnapshotByteSink* sink, HowToCode how_to_code, WhereToPoint where_to_point) argument
/external/icu/icu4c/source/common/
H A Duresimp.h231 icu::ResourceSink &sink, UErrorCode &errorCode);
/external/okhttp/okhttp-android-support/src/main/java/com/squareup/okhttp/internal/huc/
H A DCacheAdapter.java64 return body != null ? Okio.sink(body) : null;
/external/deqp/android/scripts/
H A Dcommon.py115 def readApplyPrefixAndPrint (source, prefix, sink):
120 sink.write(prefix + line)
/external/icu/android_icu4j/src/main/java/android/icu/impl/coll/
H A DCollationRuleParser.java103 sink = sinkAlias;
238 sink.addReset(resetStrength, rawBuilder);
323 sink.addRelation(strength, prefix, rawBuilder, extension);
348 sink.addRelation(strength, empty, UTF16.valueOf(c), empty);
388 sink.addRelation(strength, empty, UTF16.valueOf(prev), empty);
686 sink.optimize(set);
694 sink.suppressContractions(set);
916 private Sink sink; field in class:CollationRuleParser
/external/icu/icu4j/main/classes/collate/src/com/ibm/icu/impl/coll/
H A DCollationRuleParser.java99 sink = sinkAlias;
234 sink.addReset(resetStrength, rawBuilder);
319 sink.addRelation(strength, prefix, rawBuilder, extension);
344 sink.addRelation(strength, empty, UTF16.valueOf(c), empty);
384 sink.addRelation(strength, empty, UTF16.valueOf(prev), empty);
682 sink.optimize(set);
690 sink.suppressContractions(set);
912 private Sink sink; field in class:CollationRuleParser
/external/ltp/testcases/kernel/hotplug/memory_hotplug/
H A Dmemtoy.c323 unsigned long *memend, *pp, sink; local
341 sink = *pp;
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
H A DStreamAllocation.java104 resultConnection.sink.timeout().timeout(writeTimeout, MILLISECONDS);
105 resultStream = new Http1xStream(this, resultConnection.source, resultConnection.sink);
/external/okhttp/okio/okio/src/test/java/okio/
H A DGzipSourceTest.java219 @Override public long read(Buffer sink, long byteCount) throws IOException { argument
220 long result = source.read(sink, byteCount);
/external/protobuf/src/google/protobuf/util/
H A Djson_util.cc147 internal::ZeroCopyStreamByteSink sink(binary_output);
149 converter::ProtoStreamObjectWriter proto_writer(resolver, type, &sink,
/external/skia/src/utils/
H A DSkTextBox.cpp261 CanvasVisitor sink(canvas);
262 this->visit(sink, text, len, paint);
/external/swiftshader/src/OpenGL/compiler/
H A DparseConst.cpp23 TConstTraverser(ConstantUnion* cUnion, bool singleConstParam, TOperator constructType, TInfoSink& sink, TType& t) argument
30 infoSink(sink),
/external/webrtc/webrtc/audio/
H A Daudio_receive_stream.cc238 void AudioReceiveStream::SetSink(rtc::scoped_ptr<AudioSinkInterface> sink) { argument
240 channel_proxy_->SetSink(std::move(sink));
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
H A DSpdy3ConnectionTest.java852 BufferedSink sink = Okio.buffer(stream.getSink());
854 sink.writeByte(0);
855 sink.flush();
963 Sink sink = stream.getSink();
964 sink.write(new Buffer().writeUtf8("abcde"), 5);
967 sink.write(new Buffer().writeUtf8("f"), 1);
969 sink.flush(); // This will time out waiting on the write window.
1005 Sink sink = stream.getSink();
1007 sink.write(new Buffer().writeUtf8("abcdef"), 6);
1010 sink
[all...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
H A DInterceptorTest.java619 @Override public void writeTo(BufferedSink sink) throws IOException {
620 Sink uppercase = uppercase(sink);
643 @Override public long read(Buffer sink, long byteCount) throws IOException {
646 sink.writeUtf8(mixedCase.readUtf8().toUpperCase(Locale.US));
654 BufferedSink sink = Okio.buffer(new GzipSink(result));
655 sink.writeUtf8(data);
656 sink.close();

Completed in 529 milliseconds

1234567891011>>