Searched defs:sink (Results 76 - 100 of 185) sorted by relevance

12345678

/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
H A DMultipartBuilder.java224 * Either writes this request to {@code sink} or measures its content length. We have one method
229 private long writeOrCountBytes(BufferedSink sink, boolean countBytes) throws IOException { argument
234 sink = byteCountBuffer = new Buffer();
241 sink.write(DASHDASH);
242 sink.write(boundary);
243 sink.write(CRLF);
247 sink.writeUtf8(headers.name(h))
256 sink.writeUtf8("Content-Type: ")
263 sink.writeUtf8("Content-Length: ")
272 sink
296 writeTo(BufferedSink sink) argument
[all...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
H A DSocksProxy.java103 BufferedSink fromSink = Okio.buffer(Okio.sink(from));
194 BufferedSink toSink = Okio.buffer(Okio.sink(toSocket));
205 final BufferedSource source, final BufferedSink sink) {
213 sink.write(buffer, byteCount);
214 sink.emit();
229 sink.close();
204 transfer(final InetAddress fromAddress, final InetAddress toAddress, final BufferedSource source, final BufferedSink sink) argument
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/
H A DRealWebSocket.java55 public RealWebSocket(boolean isClient, BufferedSource source, BufferedSink sink, Random random, argument
59 writer = new WebSocketWriter(isClient, sink, random);
128 BufferedSink sink = Okio.buffer(writer.newMessageSink(formatOpcode));
130 message.writeTo(sink);
131 sink.close();
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);
H A DWebSocketWriter.java51 private final BufferedSink sink; field in class:WebSocketWriter
63 public WebSocketWriter(boolean isClient, BufferedSink sink, Random random) { argument
64 if (sink == null) throw new NullPointerException("sink == null");
67 this.sink = sink;
131 sink.writeByte(b0);
136 sink.writeByte(b1);
139 sink.write(maskKey);
145 sink
[all...]
/external/okhttp/okio/okio/src/main/java/okio/
H A DBufferedSource.java110 * Removes up to {@code sink.length} bytes from this and copies them into {@code sink}.
113 int read(byte[] sink) throws IOException; argument
116 * Removes exactly {@code sink.length} bytes from this and copies them into {@code sink}.
119 void readFully(byte[] sink) throws IOException; argument
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; argument
129 * {@code sink}. Throws an {@link java.io.EOFException} if the requested
132 void readFully(Buffer sink, lon argument
139 readAll(Sink sink) argument
[all...]
H A DGzipSource.java53 * decompressed sink buffers.
67 @Override public long read(Buffer sink, long byteCount) throws IOException { argument
79 long offset = sink.size;
80 long result = inflaterSource.read(sink, byteCount);
82 updateCrc(sink, offset, result);
H A DRealBufferedSink.java25 public final Sink sink; field in class:RealBufferedSink
28 public RealBufferedSink(Sink sink, Buffer buffer) { argument
29 if (sink == null) throw new IllegalArgumentException("sink == null");
31 this.sink = sink;
34 public RealBufferedSink(Sink sink) { argument
35 this(sink, new Buffer());
176 if (byteCount > 0) sink.write(buffer, byteCount);
183 if (byteCount > 0) sink
[all...]
H A DRealBufferedSource.java44 @Override public long read(Buffer sink, long byteCount) throws IOException { argument
45 if (sink == null) throw new IllegalArgumentException("sink == null");
55 return buffer.read(sink, toRead);
101 @Override public int read(byte[] sink) throws IOException { argument
102 return read(sink, 0, sink.length);
105 @Override public void readFully(byte[] sink) throws IOException { argument
107 require(sink.length);
112 int read = buffer.read(sink, offse
121 read(byte[] sink, int offset, int byteCount) argument
133 readFully(Buffer sink, long byteCount) argument
144 readAll(Sink sink) argument
[all...]
/external/okhttp/okio/okio/src/test/java/okio/
H A DBufferedSinkTest.java79 private BufferedSink sink; field in class:BufferedSinkTest
83 sink = factory.create(data);
87 sink.writeUtf8("");
88 sink.flush();
93 sink.writeByte(0xab);
94 sink.writeByte(0xcd);
95 sink.flush();
100 sink.writeUtf8(repeat('a', Segment.SIZE - 1));
101 sink.writeByte(0x20);
102 sink
[all...]
/external/protobuf/src/google/protobuf/stubs/
H A Dbytestream.cc40 void ByteSource::CopyTo(ByteSink* sink, size_t n) { argument
48 sink->Append(fragment.data(), fragment_size);
188 void LimitByteSource::CopyTo(ByteSink *sink, size_t n) { argument
190 source_->CopyTo(sink, n);
/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/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/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/webrtc/webrtc/modules/video_coding/test/
H A Dvcm_payload_sink_factory.cc156 rtc::scoped_ptr<VcmPayloadSink> sink(
159 sinks_.push_back(sink.get());
160 return sink.release();
195 void VcmPayloadSinkFactory::Remove(VcmPayloadSink* sink) { argument
196 assert(sink);
198 Sinks::iterator it = std::find(sinks_.begin(), sinks_.end(), sink);
/external/bsdiff/
H A Dbspatch.cc266 // Patch |old_data| with |patch_data| and save it by calling sink function.
272 const sink_func& sink) {
274 std::unique_ptr<FileInterface> new_file(new SinkFile(sink));
268 bspatch(const uint8_t* old_data, size_t old_size, const uint8_t* patch_data, size_t patch_size, const sink_func& sink) argument
/external/clang/test/SemaCXX/
H A Dlinkage-spec.cpp114 int sink; member in struct:PR9162::_ArtsSink
/external/guava/guava/src/com/google/common/io/
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/icu/android_icu4j/src/main/java/android/icu/impl/coll/
H A DContractionsAndExpansions.java32 private CESink sink; field in class:ContractionsAndExpansions
49 sink = s;
120 if (sink != null) {
121 sink.handleCE(Collation.ceFromSimpleCE32(ce32));
136 if (sink != null) {
137 sink.handleCE(Collation.ceFromLongPrimaryCE32(ce32));
141 if (sink != null) {
142 sink.handleCE(Collation.ceFromLongSecondaryCE32(ce32));
146 if (sink != null) {
149 sink
[all...]
/external/icu/icu4j/main/classes/collate/src/com/ibm/icu/impl/coll/
H A DContractionsAndExpansions.java28 private CESink sink; field in class:ContractionsAndExpansions
45 sink = s;
116 if (sink != null) {
117 sink.handleCE(Collation.ceFromSimpleCE32(ce32));
132 if (sink != null) {
133 sink.handleCE(Collation.ceFromLongPrimaryCE32(ce32));
137 if (sink != null) {
138 sink.handleCE(Collation.ceFromLongSecondaryCE32(ce32));
142 if (sink != null) {
145 sink
[all...]
/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/io/
H A DRealConnection.java83 public BufferedSink sink; field in class:RealConnection
119 sink = null;
146 sink = Okio.buffer(Okio.sink(rawSocket));
159 .socket(socket, route.getAddress().url().host(), source, sink)
218 sink = Okio.buffer(Okio.sink(socket));
265 Http1xStream tunnelConnection = new Http1xStream(null, source, sink);
267 sink.timeout().timeout(writeTimeout, MILLISECONDS);
287 if (!source.buffer().exhausted() || !sink
[all...]
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/
H A DRealWebSocketTest.java67 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();
165 sink
477 BufferedSink sink() { method in class:RealWebSocketTest.MemorySocket
[all...]
/external/protobuf/php/ext/google/protobuf/
H A Dmessage.c83 upb_bytessink sink; member in struct:__anon16191
89 stringsink *sink = _sink; local
90 sink->len = 0;
91 return sink;
96 stringsink *sink = _sink; local
97 size_t new_size = sink->size;
102 while (sink->len + len > new_size) {
106 if (new_size != sink->size) {
107 sink->ptr = realloc(sink
117 stringsink_init(stringsink *sink) argument
129 stringsink_uninit(stringsink *sink) argument
190 stringsink sink; local
[all...]
/external/skia/src/views/
H A DSkEventSink.cpp52 SkEventSink* sink = globals.fSinkHead; local
56 SkEventSink* next = sink->fNextSink;
57 if (sink == this) {
65 prev = sink;
66 sink = next;
161 void SkEventSink::copyListeners(const SkEventSink& sink) argument
163 SkListenersTagList* sinkList = (SkListenersTagList*)sink.findTagList(kListeners_SkTagList);
225 SkEventSink* sink = SkEventSink::FindSink(evt.getTargetID()); local
226 if (sink) {
227 return sink
240 SkEventSink* sink = globals.fSinkHead; local
[all...]

Completed in 1485 milliseconds

12345678