Home
last modified time | relevance | path

Searched defs:sink (Results 1 – 25 of 285) sorted by relevance

12345678910>>...12

/external/okhttp/okio/okio/src/test/java/okio/
DRealBufferedSinkTest.java32 RealBufferedSink sink = new RealBufferedSink(new Buffer()); in inputStreamCloses() local
44 Buffer sink = new Buffer(); in bufferedSinkEmitsTailWhenItIsComplete() local
54 Buffer sink = new Buffer(); in bufferedSinkEmitMultipleSegments() local
62 Buffer sink = new Buffer(); in bufferedSinkFlush() local
72 Buffer sink = new Buffer(); in bytesEmittedToSinkWithFlush() local
80 Buffer sink = new Buffer(); in bytesNotEmittedToSinkWithoutFlush() local
87 Buffer sink = new Buffer(); in bytesEmittedToSinkWithEmit() local
95 Buffer sink = new Buffer(); in completeSegmentsEmitted() local
102 Buffer sink = new Buffer(); in incompleteSegmentsNotEmitted() local
DOkioTest.java38 BufferedSink sink = Okio.buffer(Okio.sink(file)); in readWriteFile() local
52 BufferedSink sink = Okio.buffer(Okio.appendingSink(file)); in appendFile() local
91 Sink sink = Okio.sink(out); in sinkFromOutputStream() local
104 Buffer sink = new Buffer(); in sourceFromInputStream() local
DDeflaterSinkTest.java35 Buffer sink = new Buffer(); in deflateWithClose() local
47 Buffer sink = new Buffer(); in deflateWithSyncFlush() local
59 Buffer sink = new Buffer(); in deflateWellCompressed() local
71 Buffer sink = new Buffer(); in deflatePoorlyCompressed() local
96 Buffer sink = new Buffer().writeUtf8(repeat('a', i)); in deflateIntoNonemptySink() local
DBufferedSourceTest.java91 BufferedSink sink; field in BufferedSourceTest.Pipe
113 private BufferedSink sink; field in BufferedSourceTest
222 Buffer sink = new Buffer(); in readAll() local
236 Buffer sink = new Buffer(); in readExhaustedSource() local
244 Buffer sink = new Buffer(); in readZeroBytesFromSource() local
256 Buffer sink = new Buffer(); in readFully() local
264 Buffer sink = new Buffer(); in readFullyTooShortThrows() local
DBufferTest.java177 Buffer sink = new Buffer(); in writeSplitSourceBufferLeft() local
192 Buffer sink = new Buffer(); in writeSplitSourceBufferRight() local
204 Buffer sink = new Buffer(); in writePrefixDoesntSplit() local
218 Buffer sink = new Buffer(); in writePrefixDoesntSplitButRequiresCompact() local
303 Buffer sink = new Buffer(); in moveAllRequestedBytesWithRead() local
316 Buffer sink = new Buffer(); in moveFewerThanRequestedBytesWithRead() local
367 Buffer sink = new Buffer(); in writePrefixToEmptyBuffer() local
506 Buffer sink = new Buffer(); in writeAllMultipleSegments() local
/external/guava/guava-tests/test/com/google/common/hash/
DAbstractStreamingHasherTest.java44 Sink sink = new Sink(4); // byte order insignificant here in testBytes() local
57 Sink sink = new Sink(4); in testShort() local
65 Sink sink = new Sink(4); in testInt() local
73 Sink sink = new Sink(8); in testLong() local
81 Sink sink = new Sink(4); in testChar() local
104 Sink sink = new Sink(4); in testFloat() local
112 Sink sink = new Sink(8); in testDouble() local
120 Sink sink = new Sink(4); in testCorrectExceptions() local
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/
DWebSocketWriterTest.java64 BufferedSink sink = Okio.buffer(serverWriter.newMessageSink(OPCODE_TEXT)); in serverTextMessage() local
77 BufferedSink sink = Okio.buffer(serverWriter.newMessageSink(OPCODE_TEXT)); in closeFlushes() local
87 Sink sink = serverWriter.newMessageSink(OPCODE_TEXT); in noWritesAfterClose() local
103 BufferedSink sink = Okio.buffer(clientWriter.newMessageSink(OPCODE_TEXT)); in clientTextMessage() local
116 BufferedSink sink = Okio.buffer(serverWriter.newMessageSink(OPCODE_BINARY)); in serverBinaryMessage() local
131 Sink sink = serverWriter.newMessageSink(OPCODE_BINARY); in serverMessageLengthShort() local
151 Sink sink = serverWriter.newMessageSink(OPCODE_BINARY); in serverMessageLengthLong() local
178 BufferedSink sink = Okio.buffer(clientWriter.newMessageSink(OPCODE_BINARY)); in clientBinary() local
/external/libbrillo/brillo/dbus/
Ddbus_signal_handler_unittest.cc50 void CallSignal(SignalHandlerSink* sink, Args... args) { in CallSignal()
84 } sink; in TEST_F() local
95 } sink; in TEST_F() local
105 } sink; in TEST_F() local
115 } sink; in TEST_F() local
126 } sink; in TEST_F() local
137 } sink; in TEST_F() local
/external/icu/icu4c/source/common/
Dbytesinkutil.cpp21 ByteSink &sink, Edits *edits, UErrorCode &errorCode) { in appendChange()
60 ByteSink &sink, Edits *edits, UErrorCode &errorCode) { in appendChange()
70 ByteSinkUtil::appendCodePoint(int32_t length, UChar32 c, ByteSink &sink, Edits *edits) { in appendCodePoint()
89 ByteSinkUtil::appendTwoBytes(UChar32 c, ByteSink &sink) { in appendTwoBytes()
97 ByteSink &sink, uint32_t options, Edits *edits, in appendUnchanged()
113 ByteSink &sink, uint32_t options, Edits *edits, in appendUnchanged()
Ducasemap.cpp141 ByteSink &sink, uint32_t options, icu::Edits *edits, UErrorCode &errorCode) { in appendResult()
210 icu::ByteSink &sink, icu::Edits *edits, in _caseMap()
238 ByteSink &sink, icu::Edits *edits, in ucasemap_internalUTF8ToTitle()
384 ByteSink &sink, Edits *edits, in toUpper()
536 icu::ByteSink &sink, icu::Edits *edits, in ucasemap_internalUTF8ToLower()
550 icu::ByteSink &sink, icu::Edits *edits, in ucasemap_internalUTF8ToUpper()
568 icu::ByteSink &sink, icu::Edits *edits, in ucasemap_internalUTF8Fold()
592 icu::ByteSink &sink, icu::Edits *edits, in ucasemap_mapUTF8()
654 CheckedArrayByteSink sink(dest, destCapacity); in ucasemap_mapUTF8() local
713 StringPiece src, ByteSink &sink, Edits *edits, in utf8ToLower()
[all …]
/external/perfetto/src/ftrace_reader/
Dftrace_controller_unittest.cc284 std::unique_ptr<FtraceSink> sink = controller->CreateSink(config, &delegate); in TEST() local
307 std::unique_ptr<FtraceSink> sink = controller->CreateSink(config, &delegate); in TEST() local
361 std::unique_ptr<FtraceSink> sink = controller->CreateSink(config, &delegate); in TEST() local
385 std::unique_ptr<FtraceSink> sink = controller->CreateSink(config, &delegate); in TEST() local
433 std::unique_ptr<FtraceSink> sink = controller->CreateSink(config, &delegate); in TEST() local
515 auto sink = controller->CreateSink(config, &delegate); in TEST() local
524 auto sink = controller->CreateSink(config, &delegate); in TEST() local
534 auto sink = controller->CreateSink(config, &delegate); in TEST() local
543 auto sink = controller->CreateSink(config, &delegate); in TEST() local
552 auto sink = controller->CreateSink(config, &delegate); in TEST() local
[all …]
/external/compiler-rt/test/asan/TestCases/Linux/
Dscariness_score_test.cc52 static T sink; in HeapBuferOverflow() local
63 static T sink; in HeapUseAfterFree() local
75 static T sink; in StackBufferOverflow() local
93 static T sink; in StackUseAfterReturn() local
125 static volatile int sink; in UseAfterPoison() local
/external/icu/android_icu4j/src/main/java/android/icu/impl/number/
DCompactData.java48 CompactDataSink sink = new CompactDataSink(this); in populate() local
57 rb.getAllItemsWithFallbackNoFail(resourceKey.toString(), sink); in populate() local
60 rb.getAllItemsWithFallbackNoFail(resourceKey.toString(), sink); in populate() local
64 rb.getAllItemsWithFallbackNoFail(resourceKey.toString(), sink); in populate() local
68 rb.getAllItemsWithFallbackNoFail(resourceKey.toString(), sink); in populate() local
/external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/number/
DCompactData.java44 CompactDataSink sink = new CompactDataSink(this); in populate() local
53 rb.getAllItemsWithFallbackNoFail(resourceKey.toString(), sink); in populate() local
56 rb.getAllItemsWithFallbackNoFail(resourceKey.toString(), sink); in populate() local
60 rb.getAllItemsWithFallbackNoFail(resourceKey.toString(), sink); in populate() local
64 rb.getAllItemsWithFallbackNoFail(resourceKey.toString(), sink); in populate() local
/external/webrtc/webrtc/base/
Dsocket_unittest.cc193 testing::StreamSink sink; in ConnectInternal() local
248 testing::StreamSink sink; in ConnectWithDnsLookupInternal() local
296 testing::StreamSink sink; in ConnectFailInternal() local
329 testing::StreamSink sink; in ConnectWithDnsLookupFailInternal() local
389 testing::StreamSink sink; in ConnectWhileNotClosedInternal() local
431 testing::StreamSink sink; in ServerCloseDuringConnectInternal() local
459 testing::StreamSink sink; in ClientCloseDuringConnectInternal() local
497 testing::StreamSink sink; in ServerCloseInternal() local
570 testing::StreamSink sink; in CloseInClosedCallbackInternal() local
625 testing::StreamSink sink; in SocketServerWaitInternal() local
[all …]
/external/okhttp/okio/okio/src/main/java/okio/
DOkio.java55 public static BufferedSink buffer(Sink sink) { in buffer()
61 public static Sink sink(OutputStream out) { in sink() method in Okio
65 private static Sink sink(final OutputStream out, final Timeout timeout) { in sink() method in Okio
DBufferedSource.java113 int read(byte[] sink) throws IOException; in read()
119 void readFully(byte[] sink) throws IOException; in readFully()
125 int read(byte[] sink, int offset, int byteCount) throws IOException; in read()
132 void readFully(Buffer sink, long byteCount) throws IOException; in readFully()
139 long readAll(Sink sink) throws IOException; in readAll()
DDeflaterSink.java38 private final BufferedSink sink; field in DeflaterSink
42 public DeflaterSink(Sink sink, Deflater deflater) { in DeflaterSink()
51 DeflaterSink(BufferedSink sink, Deflater deflater) { in DeflaterSink()
DRealBufferedSource.java44 @Override public long read(Buffer sink, long byteCount) throws IOException { in read()
101 @Override public int read(byte[] sink) throws IOException { in read()
105 @Override public void readFully(byte[] sink) throws IOException { in readFully()
121 @Override public int read(byte[] sink, int offset, int byteCount) throws IOException { in read()
133 @Override public void readFully(Buffer sink, long byteCount) throws IOException { in readFully()
144 @Override public long readAll(Sink sink) throws IOException { in readAll()
/external/protobuf/src/google/protobuf/stubs/
Dbytestream_unittest.cc68 StringByteSink sink(&str); in TEST() local
79 StringByteSink sink(&str); in TEST() local
96 StringByteSink sink(&str); in TEST() local
105 StringByteSink sink(&str); in TEST() local
116 StringByteSink sink(&str); in TEST() local
/external/protobuf/php/ext/google/protobuf/
Dmessage.c83 upb_bytessink sink; member
89 stringsink *sink = _sink; in stringsink_start() local
96 stringsink *sink = _sink; in stringsink_string() local
117 void stringsink_init(stringsink *sink) { in stringsink_init()
129 void stringsink_uninit(stringsink *sink) { free(sink->ptr); } in stringsink_uninit()
190 stringsink sink; in PHP_METHOD() local
/external/autotest/client/cros/chameleon/
Daudio_widget_link.py39 def __init__(self, source, link, sink): argument
149 def connect(self, source, sink): argument
160 def disconnect(self, source, sink): argument
356 def connect(self, source, sink): argument
368 def disconnect(self, source, sink): argument
446 def connect(self, source, sink): argument
459 def disconnect(self, source, sink): argument
492 def connect(self, source, sink): argument
510 def disconnect(self, source, sink): argument
/external/webrtc/talk/app/webrtc/
Dlocalaudiosource.h56 void AddSink(AudioTrackSinkInterface* sink) override {} in AddSink()
57 void RemoveSink(AudioTrackSinkInterface* sink) override {} in RemoveSink()
/external/libmojo/mojo/public/cpp/bindings/lib/
Dfilter_chain.cc13 FilterChain::FilterChain(MessageReceiver* sink) : sink_(sink) { in FilterChain()
30 void FilterChain::SetSink(MessageReceiver* sink) { in SetSink()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
DRequestBody.java40 public abstract void writeTo(BufferedSink sink) throws IOException; in writeTo()
70 @Override public void writeTo(BufferedSink sink) throws IOException { in create()

12345678910>>...12