| /external/guava/guava/src/com/google/common/hash/ |
| Funnels.java | 226 public static OutputStream asOutputStream(PrimitiveSink sink) {
227 return new SinkAsStream(sink);
231 final PrimitiveSink sink; field in class:Funnels.SinkAsStream
232 SinkAsStream(PrimitiveSink sink) {
233 this.sink = Preconditions.checkNotNull(sink);
237 sink.putByte((byte) b);
241 sink.putBytes(bytes);
245 sink.putBytes(bytes, off, len);
249 return "Funnels.asOutputStream(" + sink + ")"
[all...] |
| /external/icu/android_icu4j/src/main/java/android/icu/impl/coll/ |
| BOCSU.java | 103 public static int writeIdenticalLevelRun(int prev, CharSequence s, int i, int length, ByteArrayWrapper sink) {
106 // but we do not want to force the sink to allocate
108 ensureAppendCapacity(sink, 16, s.length() * 2);
109 byte[] buffer = sink.bytes;
111 int p = sink.size;
132 sink.size = p;
137 private static void ensureAppendCapacity(ByteArrayWrapper sink, int minCapacity, int desiredCapacity) {
138 int remainingCapacity = sink.bytes.length - sink.size;
141 sink.ensureCapacity(sink.size + desiredCapacity)
[all...] |
| /external/icu/icu4j/main/classes/collate/src/com/ibm/icu/impl/coll/ |
| BOCSU.java | 102 public static int writeIdenticalLevelRun(int prev, CharSequence s, int i, int length, ByteArrayWrapper sink) {
105 // but we do not want to force the sink to allocate
107 ensureAppendCapacity(sink, 16, s.length() * 2);
108 byte[] buffer = sink.bytes;
110 int p = sink.size;
131 sink.size = p;
136 private static void ensureAppendCapacity(ByteArrayWrapper sink, int minCapacity, int desiredCapacity) {
137 int remainingCapacity = sink.bytes.length - sink.size;
140 sink.ensureCapacity(sink.size + desiredCapacity)
[all...] |
| /external/okhttp/okio/okio/src/test/java/okio/ |
| SocketTimeoutTest.java | 60 Sink sink = Okio.buffer(Okio.sink(socket)); local
61 sink.timeout().timeout(500, TimeUnit.MILLISECONDS);
63 sink.write(new Buffer().write(data), data.length);
64 sink.flush();
70 Sink sink = Okio.sink(socket); local
71 sink.timeout().timeout(500, TimeUnit.MILLISECONDS)
[all...] |
| /external/okhttp/okio/okio/src/main/java/okio/ |
| BufferedSource.java | 110 * Removes up to {@code sink.length} bytes from this and copies them into {@code sink}.
113 int read(byte[] sink) throws IOException;
116 * Removes exactly {@code sink.length} bytes from this and copies them into {@code sink}.
119 void readFully(byte[] sink) throws IOException;
122 * Removes up to {@code byteCount} bytes from this and copies them into {@code sink} at
125 int read(byte[] sink, int offset, int byteCount) throws IOException;
129 * {@code sink}. Throws an {@link java.io.EOFException} if the requested
132 void readFully(Buffer sink, long byteCount) throws IOException
[all...] |
| RealBufferedSink.java | 25 public final Sink sink; field in class:RealBufferedSink
28 public RealBufferedSink(Sink sink, Buffer buffer) {
29 if (sink == null) throw new IllegalArgumentException("sink == null");
31 this.sink = sink;
34 public RealBufferedSink(Sink sink) {
[all...] |
| /external/protobuf/ruby/ext/google/protobuf_c/ |
| encode_decode.c | 717 upb_sink sink; local
721 upb_sink_reset(&sink, h, msg);
722 decoder = upb_pbdecoder_create(&se.env, method, &sink);
760 upb_sink sink; local
764 upb_sink_reset(&sink, get_fill_handlers(desc), msg);
765 parser = upb_json_parser_create(&se.env, method, &sink);
788 upb_bytessink sink; member in struct:__anon32184
794 stringsink *sink = _sink; local
795 sink->len = 0;
796 return sink;
801 stringsink *sink = _sink; local
1084 putsubmsg(DEREF(msg, offset, VALUE), f, sink, depth); local
1158 stringsink sink; local
1194 stringsink sink; local
[all...] |
| /prebuilts/go/darwin-x86/test/fixedbugs/ |
| issue12588.go | 67 var sink *uint64 var
79 sink = h(&b1) // ERROR "main &b1 does not escape"
81 sink = h2(&b1) // ERROR "main &b1 does not escape"
84 println("*sink=", *sink) // Verify that sink addresses x1
86 sink = k(b3)
87 println("*sink=", *sink) // Verify that sink addresses x
[all...] |
| issue16095.go | 14 var sink *[20]byte var
23 sink = &x
24 sink = nil
40 sink = y
59 sink = &x
60 sink = nil
76 sink = y
|
| issue14725.go | 21 var sink *int var
24 sink = &x
33 sink = &x
|
| issue16008.go | 49 var sink interface{} var
53 sink = tx
54 sink = n
|
| /prebuilts/go/linux-x86/test/fixedbugs/ |
| issue12588.go | 67 var sink *uint64 var
79 sink = h(&b1) // ERROR "main &b1 does not escape"
81 sink = h2(&b1) // ERROR "main &b1 does not escape"
84 println("*sink=", *sink) // Verify that sink addresses x1
86 sink = k(b3)
87 println("*sink=", *sink) // Verify that sink addresses x
[all...] |
| issue16095.go | 14 var sink *[20]byte var
23 sink = &x
24 sink = nil
40 sink = y
59 sink = &x
60 sink = nil
76 sink = y
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| LongPipeline.java | 96 * Adapt a {@code Sink<Long> to an {@code LongConsumer}, ideally simply
99 private static LongConsumer adapt(Sink<Long> sink) {
100 if (sink instanceof LongConsumer) {
101 return (LongConsumer) sink;
105 "using LongStream.adapt(Sink<Long> s)");
106 return sink::accept;
158 public final void forEachWithCancel(Spliterator<Long> spliterator, Sink<Long> sink) {
160 LongConsumer adaptedSink = adapt(sink);
[all...] |
| DoublePipeline.java | 95 * Adapt a {@code Sink<Double> to a {@code DoubleConsumer}, ideally simply
98 private static DoubleConsumer adapt(Sink<Double> sink) {
99 if (sink instanceof DoubleConsumer) {
100 return (DoubleConsumer) sink;
104 "using DoubleStream.adapt(Sink<Double> s)");
105 return sink::accept;
157 public final void forEachWithCancel(Spliterator<Double> spliterator, Sink<Double> sink) {
159 DoubleConsumer adaptedSink = adapt(sink);
[all...] |
| /prebuilts/go/darwin-x86/test/ |
| escape_level.go | 11 var sink interface{} var
18 sink = &p2 // ERROR "&p2 escapes to heap"
26 sink = p2 // ERROR "p2 escapes to heap"
34 sink = *p2 // ERROR "\*p2 escapes to heap"
42 sink = **p2 // ERROR "\* \(\*p2\) escapes to heap"
50 sink = &p2 // ERROR "&p2 escapes to heap"
58 sink = p2 // ERROR "p2 escapes to heap"
66 sink = *p2 // ERROR "\*p2 escapes to heap"
75 sink = &p2 // ERROR "&p2 escapes to heap"
83 sink = p2 // ERROR "p2 escapes to heap
[all...] |
| escape_field.go | 11 var sink interface{} var
27 sink = x.p1 // ERROR "x\.p1 escapes to heap"
35 sink = x.p2 // ERROR "x\.p2 escapes to heap"
42 sink = x // ERROR "x escapes to heap"
50 sink = x // ERROR "x escapes to heap"
58 sink = x.a[1] // ERROR "x\.a\[1\] escapes to heap"
63 sink = x.p2 // ERROR "x\.p2 escapes to heap"
91 sink = y1.x.p1 // ERROR "y1\.x\.p1 escapes to heap"
101 sink = y1.x // ERROR "y1\.x escapes to heap"
112 sink = y1.x.p2 // ERROR "y1\.x\.p2 escapes to heap
[all...] |
| /prebuilts/go/linux-x86/test/ |
| escape_level.go | 11 var sink interface{} var
18 sink = &p2 // ERROR "&p2 escapes to heap"
26 sink = p2 // ERROR "p2 escapes to heap"
34 sink = *p2 // ERROR "\*p2 escapes to heap"
42 sink = **p2 // ERROR "\* \(\*p2\) escapes to heap"
50 sink = &p2 // ERROR "&p2 escapes to heap"
58 sink = p2 // ERROR "p2 escapes to heap"
66 sink = *p2 // ERROR "\*p2 escapes to heap"
75 sink = &p2 // ERROR "&p2 escapes to heap"
83 sink = p2 // ERROR "p2 escapes to heap
[all...] |
| escape_field.go | 11 var sink interface{} var
27 sink = x.p1 // ERROR "x\.p1 escapes to heap"
35 sink = x.p2 // ERROR "x\.p2 escapes to heap"
42 sink = x // ERROR "x escapes to heap"
50 sink = x // ERROR "x escapes to heap"
58 sink = x.a[1] // ERROR "x\.a\[1\] escapes to heap"
63 sink = x.p2 // ERROR "x\.p2 escapes to heap"
91 sink = y1.x.p1 // ERROR "y1\.x\.p1 escapes to heap"
101 sink = y1.x // ERROR "y1\.x escapes to heap"
112 sink = y1.x.p2 // ERROR "y1\.x\.p2 escapes to heap
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| Http1xStream.java | 34 import okio.Sink;
47 * <li>Open a sink to write the request body. Either {@link
49 * <li>Write to and then close that sink.
73 private final BufferedSink sink; field in class:Http1xStream
77 public Http1xStream(StreamAllocation streamAllocation, BufferedSource source, BufferedSink sink) {
80 this.sink = sink;
87 @Override public Sink createRequestBody(Request request, long contentLength) throws IOException {
161 sink.flush();
167 sink.writeUtf8(requestLine).writeUtf8("\r\n")
[all...] |
| /external/webrtc/talk/app/webrtc/ |
| remoteaudiosource.cc | 57 class RemoteAudioSource::Sink : public AudioSinkInterface {
59 explicit Sink(RemoteAudioSource* source) : source_(source) {}
60 ~Sink() override { source_->OnAudioProviderGone(); }
69 RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(Sink);
100 ssrc, rtc::scoped_ptr<AudioSinkInterface>(new Sink(this)));
132 void RemoteAudioSource::AddSink(AudioTrackSinkInterface* sink) {
134 RTC_DCHECK(sink);
137 LOG(LS_ERROR) << "Can't register sink as the source isn't live.";
142 RTC_DCHECK(std::find(sinks_.begin(), sinks_.end(), sink) == sinks_.end());
143 sinks_.push_back(sink);
[all...] |
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| StatefulTestOp.java | 40 public Sink opWrapSink(int flags, Sink sink) {
41 return op.opWrapSink(flags, isParallel(), sink);
60 public Sink opWrapSink(int flags, Sink sink) {
61 return op.opWrapSink(flags, isParallel(), sink);
80 public Sink opWrapSink(int flags, Sink sink)
[all...] |
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| StatefulTestOp.java | 41 public Sink opWrapSink(int flags, Sink sink) {
42 return op.opWrapSink(flags, isParallel(), sink);
61 public Sink opWrapSink(int flags, Sink sink) {
62 return op.opWrapSink(flags, isParallel(), sink);
81 public Sink opWrapSink(int flags, Sink sink)
[all...] |
| /external/guava/guava-tests/test/com/google/common/io/ |
| ByteSinkTester.java | 75 private ByteSink sink; field in class:ByteSinkTester
84 sink = factory.createSink();
88 OutputStream out = sink.openStream();
99 OutputStream out = sink.openBufferedStream();
110 sink.write(data);
116 sink.writeFrom(new ByteArrayInputStream(data));
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/ |
| SourceChannelTest.java | 38 private Pipe.SinkChannel sink; field in class:SourceChannelTest
49 sink = pipe.sink();
68 sink.write(ByteBuffer.allocate(1));
91 sink.write(buffer);
92 sink.close();
160 sink = pipe.sink();
162 sink.configureBlocking(sinkBlockingMode[i]);
167 long writeCount = sink.write(bufArray)
[all...] |
