| /external/okhttp/okio/okio/src/test/java/okio/ |
| InflaterSourceTest.java | 98 Sink sink = Okio.sink(new DeflaterOutputStream(result.outputStream())); local
99 sink.write(new Buffer().write(source), source.size());
100 sink.close();
|
| OkioTest.java | 38 BufferedSink sink = Okio.buffer(Okio.sink(file)); local
39 sink.writeUtf8("Hello, java.io file!");
40 sink.close();
52 BufferedSink sink = Okio.buffer(Okio.appendingSink(file)); local
53 sink.writeUtf8("Hello, ");
54 sink.close();
58 sink = Okio.buffer(Okio.appendingSink(file));
59 sink.writeUtf8("java.io file!");
60 sink.close()
91 Sink sink = Okio.sink(out); local
104 Buffer sink = new Buffer(); local
[all...] |
| /external/scapy/scapy/ |
| pipetool.py | 89 if isinstance(pipe, Sink):
355 class Sink(Pipe):
410 class ConsoleSink(Sink):
423 class RawConsoleSink(Sink):
432 Sink.__init__(self, name=name)
496 class TermSink(Sink):
505 Sink.__init__(self, name=name)
577 class QueueSink(Sink):
586 Sink.__init__(self, name=name)
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| StreamAllocation.java | 34 import okio.Sink;
104 resultConnection.sink.timeout().timeout(writeTimeout, MILLISECONDS);
105 resultStream = new Http1xStream(this, resultConnection.source, resultConnection.sink);
333 public boolean recover(IOException e, Sink requestBodyOut) {
|
| HttpEngine.java | 51 import okio.Sink;
156 private Sink requestBodyOut;
307 public Sink getRequestBody() {
315 Sink requestBody = getRequestBody();
367 public HttpEngine recover(IOException e, Sink requestBodyOut) {
716 Sink requestBodyOut = httpStream.createRequestBody(request, request.body().contentLength());
767 Sink cacheBodyUnbuffered = cacheRequest.body();
776 @Override public long read(Buffer sink, long byteCount) throws IOException {
779 bytesRead = source.read(sink, byteCount);
796 sink.copyTo(cacheBody.buffer(), sink.size() - bytesRead, bytesRead)
[all...] |
| Http2xStream.java | 40 import okio.Sink;
122 @Override public Sink createRequestBody(Request request, long contentLength) throws IOException {
|
| /prebuilts/tools/common/m2/repository/com/squareup/okio/okio/1.9.0/ |
| okio-1.9.0.jar | |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| DiskLruCache.java | 40 import okio.Sink;
301 Sink fileSink = fileSystem.appendingSink(journalFile);
302 Sink faultHidingSink = new FaultHidingSink(fileSink) {
382 BufferedSink writer = Okio.buffer(fileSystem.sink(journalFileTmp));
809 private static final Sink NULL_SINK = new Sink() {
882 public Sink newSink(int index) throws IOException {
894 Sink sink; local
896 sink = fileSystem.sink(dirtyFile)
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| Cache.java | 46 import okio.Sink;
425 private Sink cacheOut;
427 private Sink body;
462 @Override public Sink body() {
578 BufferedSink sink = Okio.buffer(editor.newSink(ENTRY_METADATA)); local
580 sink.writeUtf8(url);
581 sink.writeByte('\n');
582 sink.writeUtf8(requestMethod);
583 sink.writeByte('\n');
584 sink.writeDecimalLong(varyHeaders.size())
[all...] |
| /prebuilts/tools/common/m2/repository/com/squareup/okio/okio/1.6.0/ |
| okio-1.6.0.jar | |
| /prebuilts/tools/common/m2/repository/com/squareup/okio/okio/1.8.0/ |
| okio-1.8.0.jar | |
| /external/icu/android_icu4j/src/main/java/android/icu/impl/ |
| DayPeriodRules.java | 77 private static final class DayPeriodRulesDataSink extends UResource.Sink {
211 private static class DayPeriodRulesCountSink extends UResource.Sink {
304 DayPeriodRulesDataSink sink = new DayPeriodRulesDataSink(data); local
305 rb.getAllItemsWithFallback("", sink);
|
| /external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/ |
| DayPeriodRules.java | 73 private static final class DayPeriodRulesDataSink extends UResource.Sink {
207 private static class DayPeriodRulesCountSink extends UResource.Sink {
300 DayPeriodRulesDataSink sink = new DayPeriodRulesDataSink(data); local
301 rb.getAllItemsWithFallback("", sink);
|
| /external/okhttp/okcurl/src/main/java/com/squareup/okhttp/curl/ |
| Main.java | 54 import okio.Sink;
157 Sink out = Okio.sink(System.out);
|
| /external/skia/dm/ |
| DM.cpp | 320 Gold(const SkString& sink, const SkString& src,
324 this->append(sink);
391 struct TaggedSink : public std::unique_ptr<Sink> {
839 static void push_sink(const SkCommandLineConfig& config, Sink* s) {
840 std::unique_ptr<Sink> sink(s);
842 // Try a simple Src as a canary. If it fails, skip this sink.
855 Error err = sink->draw(justOneRect, &bitmap, &stream, &log);
862 ts.reset(sink.release());
874 static Sink* create_sink(const GrContextOptions& grCtxOptions, const SkCommandLineConfig* config)
982 Sink* sink = create_sink(grCtxOptions, &config); local
1089 const TaggedSink& sink; member in struct:Task
[all...] |
| /external/skqp/dm/ |
| DM.cpp | 308 Gold(const SkString& sink, const SkString& src,
312 this->append(sink);
379 struct TaggedSink : public std::unique_ptr<Sink> {
827 static void push_sink(const SkCommandLineConfig& config, Sink* s) {
828 std::unique_ptr<Sink> sink(s);
830 // Try a simple Src as a canary. If it fails, skip this sink.
843 Error err = sink->draw(justOneRect, &bitmap, &stream, &log);
850 ts.reset(sink.release());
862 static Sink* create_sink(const GrContextOptions& grCtxOptions, const SkCommandLineConfig* config)
965 Sink* sink = create_sink(grCtxOptions, &config); local
1072 const TaggedSink& sink; member in struct:Task
[all...] |
| /libcore/ojluni/src/main/java/java/util/stream/ |
| StreamSpliterators.java | 87 * Sink chain for the downstream stages of the pipeline, ultimately
90 Sink<P_IN> bufferSink;
148 * Get an element from the source, pushing it into the sink chain,
182 * Initializes buffer, sink chain, and pusher for a shape-specific
200 * If the buffer is empty, push elements into the sink chain until
312 ph.wrapAndCopyInto((Sink<P_OUT>) consumer::accept, spliterator);
346 bufferSink = ph.wrapSink((Sink.OfInt) b::accept);
370 ph.wrapAndCopyInto((Sink.OfInt) consumer::accept, spliterator);
404 bufferSink = ph.wrapSink((Sink.OfLong) b::accept);
428 ph.wrapAndCopyInto((Sink.OfLong) consumer::accept, spliterator)
[all...] |
| Nodes.java | [all...] |
| /external/protobuf/php/ext/google/protobuf/ |
| upb.h | 7466 upb_sink sink; member in struct:upb::HandlerAttributes::upb::BufferHandle::upb::Handlers::upb::BytesHandler::upb::BytesSink::upb::BufferSource::__anon32175
[all...] |
| /external/protobuf/ruby/ext/google/protobuf_c/ |
| upb.h | 7769 upb_sink sink; member in struct:upb::HandlerAttributes::upb::BufferHandle::upb::Handlers::upb::BytesHandler::upb::BytesSink::upb::BufferSource::__anon32234
[all...] |
| /prebuilts/go/darwin-x86/test/ |
| escape_param.go | 14 var sink interface{} var
28 sink = param0(&i) // ERROR "&i escapes to heap$" "param0\(&i\) escapes to heap"
39 sink, _ = param1(&i, &j) // ERROR "&i escapes to heap$" "caller1 &j does not escape$"
58 sink = p // ERROR "p escapes to heap$"
84 sink = p // ERROR "p escapes to heap$"
103 sink = p // ERROR "p escapes to heap$"
108 sink = i // ERROR "i escapes to heap$"
118 sink = *i // ERROR "\*i escapes to heap$"
130 sink = **i // ERROR "\* \(\*i\) escapes to heap"
142 sink = **i // ERROR "\* \(\*i\) escapes to heap
[all...] |
| /prebuilts/go/linux-x86/test/ |
| escape_param.go | 14 var sink interface{} var
28 sink = param0(&i) // ERROR "&i escapes to heap$" "param0\(&i\) escapes to heap"
39 sink, _ = param1(&i, &j) // ERROR "&i escapes to heap$" "caller1 &j does not escape$"
58 sink = p // ERROR "p escapes to heap$"
84 sink = p // ERROR "p escapes to heap$"
103 sink = p // ERROR "p escapes to heap$"
108 sink = i // ERROR "i escapes to heap$"
118 sink = *i // ERROR "\*i escapes to heap$"
130 sink = **i // ERROR "\* \(\*i\) escapes to heap"
142 sink = **i // ERROR "\* \(\*i\) escapes to heap
[all...] |
| /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...] |
| /hardware/qcom/neuralnetworks/hvxservice/1.0/hexagon_nn_controller/ |
| ops.def | 220 DEF_OP(Sink)
|
| /external/llvm/lib/Target/Mips/ |
| MipsSEISelLowering.cpp | [all...] |
