/external/apache-http/src/org/apache/http/impl/io/ |
H A D | ContentLengthInputStream.java | 42 * gets called. Instead, it will read until the "end" of its chunking on 44 * requests, while not requiring the client to remember to read the entire 80 * The maximum number of bytes that can be read from the stream. Subsequent 81 * read operations will return -1. 100 * @param contentLength The maximum number of bytes that can be read from 101 * the stream. Subsequent read operations will return -1. 126 while (read(buffer) >= 0) { 130 // to read after closed! 141 * @see java.io.InputStream#read() 143 public int read() throw method in class:ContentLengthInputStream 167 public int read (byte[] b, int off, int len) throws java.io.IOException { method in class:ContentLengthInputStream 192 public int read(byte[] b) throws IOException { method in class:ContentLengthInputStream [all...] |
H A D | ChunkedInputStream.java | 50 * transfer coding. After the stream is read to the end, it provides access 54 * gets called. Instead, it will read until the "end" of its chunking on 56 * requests, while not requiring the client to remember to read the entire 115 * <p> Trailer headers are read automcatically at the end of the stream and 122 public int read() throws IOException { method in class:ChunkedInputStream 124 throw new IOException("Attempted read from closed stream."); 136 return in.read(); 147 * @see java.io.InputStream#read(byte[], int, int) 150 public int read (byte[] b, int off, int len) throws IOException { method in class:ChunkedInputStream 153 throw new IOException("Attempted read fro 179 public int read (byte[] b) throws IOException { method in class:ChunkedInputStream [all...] |
/external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/ |
H A D | IndefiniteLengthInputStream.java | 22 _b1 = in.read(); 23 _b2 = in.read(); 51 public int read(byte[] b, int off, int len) method in class:IndefiniteLengthInputStream 57 return super.read(b, off, len); 65 int numRead = _in.read(b, off + 2, len - 2); 76 _b1 = _in.read(); 77 _b2 = _in.read(); 88 public int read() method in class:IndefiniteLengthInputStream 96 int b = _in.read();
|
/external/chromium_org/android_webview/java/src/org/chromium/android_webview/ |
H A D | InputStreamUtil.java | 52 public static int read(InputStream stream, byte[] b, int off, int len) { method in class:InputStreamUtil 54 return Math.max(CALL_FAILED_STATUS, stream.read(b, off, len)); 56 Log.e(LOGTAG, logMessage("read"), e);
|
/external/chromium_org/chrome/common/ |
H A D | partial_circular_buffer_unittest.cc | 132 uint32 read = 0; local 133 for (; read + size_per_read <= sizeof(output_data); read += size_per_read) { 135 pcb_read_->Read(output_data + read, size_per_read)); 137 EXPECT_EQ(sizeof(output_data) - read, 138 pcb_read_->Read(output_data + read, size_per_read));
|
H A D | partial_circular_buffer.cc | 70 uint32 read = 0; local 80 read += to_read; 83 // We've read all the beginning part, set the position to the middle part. 88 if (read >= buffer_size) { 89 DCHECK_EQ(read, buffer_size); 90 return read; 92 if (read >= to_eow) { 93 DCHECK_EQ(read, to_eow); 95 return read; 102 uint32 remaining_buffer_size = buffer_size - read; [all...] |
/external/chromium_org/chrome/test/ext_auto/auto_provider/ |
H A D | server.js | 7 // Stream encapsulates read/write operations over socket. 24 read: function(callback) { 25 socket.read(this.socketId_, function(readInfo) {
|
/external/chromium_org/remoting/host/native_messaging/ |
H A D | native_messaging_writer_unittest.cc | 46 int read = read_file_.ReadAtCurrentPos(reinterpret_cast<char*>(&length), 4); local 47 EXPECT_EQ(4, read); 49 read = read_file_.ReadAtCurrentPos(string_as_array(&content), length); 50 EXPECT_EQ(static_cast<int>(length), read); local 57 // and verify the read end immediately hits EOF. 60 read = read_file_.ReadAtCurrentPos(&unused, 1); 61 EXPECT_LE(read, 0); 74 int read; local 77 read = read_file_.ReadAtCurrentPos(reinterpret_cast<char*>(&length), 4); 78 EXPECT_EQ(4, read) << " [all...] |
/external/chromium_org/third_party/cython/src/Cython/Plex/ |
H A D | Scanners.py | 20 A Scanner is used to read tokens from a stream of characters 34 read() --> (value, text) 38 Returns the position of the last token read using the 39 read() method. 55 # next_pos = 0 # position in input of next char to read 62 # text = None # text of last token read 76 compatible read() method. 108 def read(self): member in class:Scanner 113 string read from the stream. Returns (None, '') on end of file. 141 print("Scanner: read [all...] |
/external/chromium_org/third_party/libpng/ |
H A D | pngrio.c | 30 * to read more then 64K on a 16 bit machine. 40 png_error(png_ptr, "Call to NULL read function"); 105 png_size_t read, remaining, err; local 110 read = MIN(NEAR_BUF_SIZE, remaining); 112 if ( !ReadFile((HANDLE)(io_ptr), buf, read, &err, NULL) ) 115 err = fread(buf, (png_size_t)1, read, io_ptr); 117 png_memcpy(data, buf, read); /* copy far buffer to near buffer */ 118 if (err != read) 122 data += read; 123 remaining -= read; [all...] |
/external/chromium_org/third_party/skia/src/core/ |
H A D | SkFlate.cpp | 82 size_t read = src->read(&inputBuffer, kBufferSize); local 83 if (read == 0) 86 flateData.avail_in = SkToUInt(read);
|
/external/chromium_org/third_party/skia/tests/ |
H A D | FlateTest.cpp | 17 virtual size_t read(void* buffer, size_t size) { function in class:SkZeroSizeMemStream 22 return SkMemoryStream::read(buffer, size); 53 inputSize = testStream->read(NULL, SkZeroSizeMemStream::kGetSizeKey); 74 inputSize = testStream->read(NULL, SkZeroSizeMemStream::kGetSizeKey);
|
/external/deqp/framework/platform/android/ |
H A D | tcuAndroidAssets.cpp | 58 void AssetResource::read (deUint8* dst, int numBytes) function in class:tcu::Android::AssetResource
|
/external/emma/core/java12/com/vladium/util/ |
H A D | ByteArrayIStream.java | 45 public final int read () method in class:ByteArrayIStream 53 public final int read (final byte [] buf, final int offset, int length) method in class:ByteArrayIStream
|
/external/guava/guava/src/com/google/common/io/ |
H A D | CountingInputStream.java | 26 * An {@link InputStream} that counts the number of bytes read. 38 * Wraps another input stream, counting the number of bytes read. 46 /** Returns the number of bytes read. */ 51 @Override public int read() throws IOException { method in class:CountingInputStream 52 int result = in.read(); 59 @Override public int read(byte[] b, int off, int len) throws IOException { method in class:CountingInputStream 60 int result = in.read(b, off, len);
|
H A D | LimitInputStream.java | 27 * An InputStream that limits the number of bytes which can be read. 39 * Wraps another input stream, limiting the number of bytes which can be read. 42 * @param limit the maximum number of bytes to be read 61 @Override public int read() throws IOException { method in class:LimitInputStream 66 int result = in.read(); 73 @Override public int read(byte[] b, int off, int len) throws IOException { method in class:LimitInputStream 79 int result = in.read(b, off, len);
|
H A D | MultiInputStream.java | 78 @Override public int read() throws IOException { method in class:MultiInputStream 82 int result = in.read(); 85 return read(); 90 @Override public int read(byte[] b, int off, int len) throws IOException { method in class:MultiInputStream 94 int result = in.read(b, off, len); 97 return read(b, off, len); 110 if (read() == -1) {
|
H A D | MultiReader.java | 51 @Override public int read(char cbuf[], int off, int len) throws IOException { method in class:MultiReader 55 int result = current.read(cbuf, off, len); 58 return read(cbuf, off, len);
|
/external/guava/guava-tests/test/com/google/common/io/ |
H A D | CountingInputStreamTest.java | 38 assertEquals(0, counter.read()); 43 assertEquals(10, counter.read(new byte[10])); 48 assertEquals(3, counter.read(new byte[10], 1, 3)); 64 assertEquals(-1, counter.read()); 69 assertEquals(20, counter.read(new byte[30])); 71 assertEquals(-1, counter.read(new byte[30])); 77 assertEquals(10, counter.read(new byte[10])); 80 counter.read(); 110 public int read() throws IOException { method in class:CountingInputStreamTest.UnmarkableInputStream
|
/external/lldb/source/Plugins/Process/POSIX/ |
H A D | RegisterContextPOSIX.h | 63 bool read, bool write, 62 SetHardwareWatchpointWithIndex(lldb::addr_t addr, size_t size, bool read, bool write, uint32_t hw_index) argument
|
/external/lldb/source/Utility/ |
H A D | KQueue.cpp | 63 KQueue::AddFDEvent (int fd, bool read, bool write, bool vnode) argument 71 if (read)
|
/external/skia/src/core/ |
H A D | SkFlate.cpp | 82 size_t read = src->read(&inputBuffer, kBufferSize); local 83 if (read == 0) 86 flateData.avail_in = SkToUInt(read);
|
/external/skia/tests/ |
H A D | FlateTest.cpp | 20 virtual size_t read(void* buffer, size_t size) { function in class:SkZeroSizeMemStream 25 return SkMemoryStream::read(buffer, size); 50 inputSize = testStream->read(NULL, SkZeroSizeMemStream::kGetSizeKey); 72 inputSize = testStream->read(NULL, SkZeroSizeMemStream::kGetSizeKey);
|
/external/apache-http/src/org/apache/http/conn/ |
H A D | EofSensorInputStream.java | 85 * All read operations will indicate EOF without accessing 86 * the underlying stream. After closing this stream, read 122 * Checks whether the underlying stream can be read from. 132 throw new IOException("Attempted read on closed stream."); 140 public int read() throws IOException { method in class:EofSensorInputStream 145 l = wrappedStream.read(); 159 public int read(byte[] b, int off, int len) throws IOException { method in class:EofSensorInputStream 164 l = wrappedStream.read(b, off, len); 178 public int read(byte[] b) throws IOException { method in class:EofSensorInputStream 183 l = wrappedStream.read( [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
H A D | mock.py | 66 This enables tests to specify what should be read from a (mock) mp_conn as 74 read_data: bytes that should be returned when read* methods are 92 def read(self, length): member in class:MockConn 93 """Override mod_python.apache.mp_conn.read.""" 109 This enables tests to specify what should be read from a (mock) mp_conn as 111 Callers of read* methods will block if there is no bytes available. 127 def read(self, length): member in class:MockBlockingConn 128 """Override mod_python.apache.mp_conn.read.""" 136 """Put bytes to be read from this mock. 139 bytes: bytes to be read [all...] |