| /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 {
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/http/ |
| StreamAllocation.java | 35 import com.android.okhttp.okio.Sink;
106 resultConnection.sink.timeout().timeout(writeTimeout, MILLISECONDS);
107 resultStream = new Http1xStream(this, resultConnection.source, resultConnection.sink);
335 public boolean recover(IOException e, Sink requestBodyOut) {
|
| HttpEngine.java | 52 import com.android.okhttp.okio.Sink;
163 private Sink requestBodyOut;
316 public Sink getRequestBody() {
324 Sink requestBody = getRequestBody();
378 public HttpEngine recover(IOException e, Sink requestBodyOut) {
729 Sink requestBodyOut = httpStream.createRequestBody(request, request.body().contentLength());
780 Sink cacheBodyUnbuffered = cacheRequest.body();
789 @Override public long read(Buffer sink, long byteCount) throws IOException {
792 bytesRead = source.read(sink, byteCount);
809 sink.copyTo(cacheBody.buffer(), sink.size() - bytesRead, bytesRead)
[all...] |
| Http2xStream.java | 41 import com.android.okhttp.okio.Sink;
124 @Override public Sink createRequestBody(Request request, long contentLength) throws IOException {
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| CronetClientStream.java | 80 private final Sink sink = new Sink(); field in class:CronetClientStream
121 protected Sink abstractClientStreamSink() {
122 return sink;
130 class Sink implements AbstractClientStream.Sink {
|
| /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/repackaged/okhttp/src/main/java/com/android/okhttp/internal/ |
| DiskLruCache.java | 41 import com.android.okhttp.okio.Sink;
303 Sink fileSink = fileSystem.appendingSink(journalFile);
304 Sink faultHidingSink = new FaultHidingSink(fileSink) {
384 BufferedSink writer = Okio.buffer(fileSystem.sink(journalFileTmp));
812 private static final Sink NULL_SINK = new Sink() {
886 public Sink newSink(int index) throws IOException {
898 Sink sink; local
900 sink = fileSystem.sink(dirtyFile)
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| MessageFramerTest.java | 52 private MessageFramer.Sink sink; field in class:MessageFramerTest
74 framer = new MessageFramer(sink, allocator, statsTraceCtx);
80 verifyNoMoreInteractions(sink);
83 verify(sink).deliverFrame(toWriteBuffer(new byte[] {0, 0, 0, 0, 2, 3, 14}), false, true, 1);
85 verifyNoMoreInteractions(sink);
94 verify(sink).deliverFrame(toWriteBuffer(new byte[] {0, 0, 0, 0, 2}), false, false, 0);
95 verify(sink).deliverFrame(toWriteBuffer(new byte[] {3, 14}), false, true, 1);
97 verifyNoMoreInteractions(sink);
104 verifyNoMoreInteractions(sink);
[all...] |
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| FramedStream.java | 29 import com.android.okhttp.okio.Sink;
67 final FramedDataSink sink; field in class:FramedStream
88 this.sink = new FramedDataSink();
90 this.sink.finished = outFinished;
113 && (sink.finished || sink.closed)
177 this.sink.finished = true;
202 * Returns a sink that can be used to write data to the peer.
207 public Sink getSink() {
210 throw new IllegalStateException("reply before requesting the sink");
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| Cache.java | 46 import okio.Sink;
426 private Sink cacheOut;
428 private Sink body;
463 @Override public Sink body() {
579 BufferedSink sink = Okio.buffer(editor.newSink(ENTRY_METADATA)); local
581 sink.writeUtf8(url);
582 sink.writeByte('\n');
583 sink.writeUtf8(requestMethod);
584 sink.writeByte('\n');
585 sink.writeDecimalLong(varyHeaders.size())
[all...] |
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| Cache.java | 47 import com.android.okhttp.okio.Sink;
428 private Sink cacheOut;
430 private Sink body;
465 @Override public Sink body() {
581 BufferedSink sink = Okio.buffer(editor.newSink(ENTRY_METADATA)); local
583 sink.writeUtf8(url);
584 sink.writeByte('\n');
585 sink.writeUtf8(requestMethod);
586 sink.writeByte('\n');
587 sink.writeDecimalLong(varyHeaders.size())
[all...] |
| /external/icu/android_icu4j/src/main/java/android/icu/impl/ |
| DayPeriodRules.java | 80 private static final class DayPeriodRulesDataSink extends UResource.Sink {
214 private static class DayPeriodRulesCountSink extends UResource.Sink {
307 DayPeriodRulesDataSink sink = new DayPeriodRulesDataSink(data); local
308 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/skqp/dm/ |
| DM.cpp | 303 Gold(const SkString& sink, const SkString& src,
307 this->append(sink);
374 struct TaggedSink : public std::unique_ptr<Sink> {
834 static void push_sink(const SkCommandLineConfig& config, Sink* s) {
835 std::unique_ptr<Sink> sink(s);
837 // Try a simple Src as a canary. If it fails, skip this sink.
850 Error err = sink->draw(justOneRect, &bitmap, &stream, &log);
857 ts.reset(sink.release());
861 static Sink* create_sink(const GrContextOptions& grCtxOptions, const SkCommandLineConfig* config)
985 Sink* sink = create_sink(grCtxOptions, &config); local
1096 const TaggedSink& sink; member in struct:Task
[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::__anon36095
[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::__anon36154
[all...] |
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| RealWebSocketTest.java | 31 import okio.Sink;
68 client = new RealWebSocket(true, server2client.source(), client2Server.sink(), random,
81 server = new RealWebSocket(false, client2Server.source(), server2client.sink(), random,
145 @Override public void writeTo(BufferedSink sink) throws IOException {
146 sink.writeUtf8("Hel").flush();
147 sink.writeUtf8("lo!").flush();
148 sink.close();
162 @Override public void writeTo(BufferedSink sink) throws IOException {
163 sink.writeUtf8("Hel").flush();
165 sink.writeUtf8("lo!").flush()
478 BufferedSink sink() { method
[all...] |
| /external/skia/dm/ |
| DM.cpp | 305 Gold(const SkString& sink, const SkString& src,
309 this->append(sink);
376 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());
858 static Sink* create_sink(const GrContextOptions& grCtxOptions, const SkCommandLineConfig* config)
981 Sink* sink = create_sink(grCtxOptions, &config); local
1093 const TaggedSink& sink; member in struct:Task
[all...] |
| /external/llvm/lib/Target/Mips/ |
| MipsSEISelLowering.cpp | [all...] |
