/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
H A D | MultipartBuilder.java | 224 * 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 D | SocksProxy.java | 103 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 D | RealWebSocket.java | 55 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 D | WebSocketReader.java | 265 @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 D | WebSocketWriter.java | 51 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 D | 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; 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 D | GzipSource.java | 53 * 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 D | RealBufferedSink.java | 25 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 D | RealBufferedSource.java | 44 @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 D | BufferedSinkTest.java | 79 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 D | bytestream.cc | 40 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 D | parseConst.cpp | 23 TConstTraverser(ConstantUnion* cUnion, bool singleConstParam, TOperator constructType, TInfoSink& sink, TType& t) argument 30 infoSink(sink),
|
/external/webrtc/talk/app/webrtc/ |
H A D | rtpsender.cc | 56 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 D | audio_receive_stream.cc | 238 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 D | vcm_payload_sink_factory.cc | 156 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 D | bspatch.cc | 266 // 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 D | linkage-spec.cpp | 114 int sink; member in struct:PR9162::_ArtsSink
|
/external/guava/guava/src/com/google/common/io/ |
H A D | ByteSource.java | 232 * 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 D | ContractionsAndExpansions.java | 32 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 D | ContractionsAndExpansions.java | 28 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 D | memtoy.c | 323 unsigned long *memend, *pp, sink; local 341 sink = *pp;
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/io/ |
H A D | RealConnection.java | 83 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 D | RealWebSocketTest.java | 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(); 165 sink 477 BufferedSink sink() { method in class:RealWebSocketTest.MemorySocket [all...] |
/external/protobuf/php/ext/google/protobuf/ |
H A D | message.c | 83 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 D | SkEventSink.cpp | 52 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...] |