/libcore/luni/src/main/java/libcore/net/http/ |
FixedLengthInputStream.java | 39 @Override public int read(byte[] buffer, int offset, int count) throws IOException { method in class:FixedLengthInputStream 45 int read = in.read(buffer, offset, Math.min(count, bytesRemaining)); local 46 if (read == -1) { 50 bytesRemaining -= read; 51 cacheWrite(buffer, offset, read); 55 return read;
|
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/io/ |
InputStreamReaderTest.java | 41 // A ByteArrayInputStream that only returns a single byte per read 69 public int read() { method in class:InputStreamReaderTest.LimitedByteArrayInputStream 78 public int read(byte[] buffer, int offset, int length) { method in class:InputStreamReaderTest.LimitedByteArrayInputStream 145 is.read(); 172 int count = reader.read(new char[1]); 178 reader.read(); 326 * @tests java.io.InputStreamReader#read() 329 assertEquals('T', (char) reader.read()); 330 assertEquals('h', (char) reader.read()); 331 assertEquals('i', (char) reader.read()); [all...] |
BufferedInputStreamTest.java | 50 str.read(); 63 str.read(); 73 // Ensure buffer gets filled by evaluating one read 74 is.read(); 78 // Read the remaining buffered characters, no IOException should 81 is.read(); 83 // is.read should now throw an exception because it will have to 85 is.read(); 86 fail("Exception should have been triggered by read()"); 150 public int read() { [all...] |
FileInputStreamTest.java | 116 is.read(); 128 fis1.read(); 142 stdin.read(); 159 * @tests java.io.FileInputStream#read() 163 int c = isr.read(); 165 assertTrue("read returned incorrect char", c == fileString.charAt(0)); 169 * @tests java.io.FileInputStream#read(byte[]) 175 is.read(buf1); 177 assertTrue("Failed to read correct data", new String(buf1, 0, 182 * @tests java.io.FileInputStream#read(byte[], int, int [all...] |
PushbackInputStreamTest.java | 58 str.read(); 99 str.read(); 128 * @tests java.io.PushbackInputStream#read() 131 // Test for method int java.io.PushbackInputStream.read() 133 assertTrue("Incorrect byte read", pis.read() == fileString 136 fail("Exception during read test : " + e.getMessage()); 141 * @tests java.io.PushbackInputStream#read(byte[], int, int) 144 // Test for method int java.io.PushbackInputStream.read(byte [], int, 148 pis.read(buf, 0, buf.length) [all...] |
SequenceInputStreamTest.java | 90 si.read(buf, 0, s1.length()); 91 si.read(buf, s1.length(), s2.length()); 92 assertTrue("Read incorrect bytes: " + new String(buf), new String( 95 fail("IOException during read test : " + e.getMessage()); 124 * @tests java.io.SequenceInputStream#read() 127 // Test for method int java.io.SequenceInputStream.read() 129 si.read(); 130 assertTrue("Read incorrect char", (char) si.read() == s1.charAt(1)); 132 fail("IOException during read test: " + e.getMessage()) [all...] |
/external/guava/guava-tests/test/com/google/common/io/ |
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/srec/tools/thirdparty/OpenFst/fst/lib/ |
expanded-fst.h | 37 // Read an ExpandedFst from an input stream; return NULL on error. 38 static ExpandedFst<A> *Read(istream &strm, const FstReadOptions &opts) { 44 if (!hdr.Read(strm, opts.source)) 49 LOG(ERROR) << "ExpandedFst::Read: Not an ExpandedFst: " << ropts.source; 56 LOG(ERROR) << "ExpandedFst::Read: Unknown FST type \"" << hdr.FstType() 65 // Read an ExpandedFst from a file; return NULL on error. 66 static ExpandedFst<A> *Read(const string &filename) { 69 LOG(ERROR) << "ExpandedFst::Read: Can't open file: " << filename; 72 return Read(strm, FstReadOptions(filename));
|
/packages/apps/Email/src/org/apache/james/mime4j/ |
CloseShieldInputStream.java | 48 * @see java.io.InputStream#read()
50 public int read() throws IOException {
method in class:CloseShieldInputStream 52 return is.read();
105 * @see java.io.FilterInputStream#read(byte[])
107 public int read(byte b[]) throws IOException {
method in class:CloseShieldInputStream 109 return is.read(b);
113 * @see java.io.FilterInputStream#read(byte[], int, int)
115 public int read(byte b[], int off, int len) throws IOException {
method in class:CloseShieldInputStream 117 return is.read(b, off, len);
|
/system/extras/tests/ext4/ |
corrupt_gdt_free_blocks.c | 35 fprintf(stderr, "%s: Cannot lseek to superblock to read\n", me); 39 if (read(fd, &sb, sizeof(sb)) != sizeof(sb)) { 40 fprintf(stderr, "%s: Cannot read superblock\n", me); 64 /* read first block group descriptor, decrement free block count, and 68 fprintf(stderr, "%s: Cannot lseek to block group descriptor table to read\n", me); 72 /* Read in block group descriptors till we read one that has at least one free block */ 75 if (read(fd, &gd, sizeof(gd)) != sizeof(gd)) { 76 fprintf(stderr, "%s: Cannot read group descriptor %d\n", me, i);
|
/cts/tests/tests/os/src/android/os/cts/ |
ParcelFileDescriptorTest.java | 50 // read the data that was wrote previously 51 assertEquals(0, in.read()); 52 assertEquals(1, in.read()); 53 assertEquals(2, in.read()); 54 assertEquals(3, in.read()); 86 assertEquals(DATA, in.read()); 119 int count = is.read(observed); 121 assertEquals(-1, is.read()); 138 assertEquals(41, is.read()); 139 assertEquals(42, is.read()); [all...] |
/libcore/luni/src/main/java/java/lang/ |
Readable.java | 23 * Represents a sequence of characters that can be incrementally read (copied) 30 * number of characters read is {@code CharBuffer.remaining()}. 33 * the buffer to be filled with characters read. 34 * @return the number of characters actually read, or -1 if this 39 int read(CharBuffer cb) throws IOException; method in interface:Readable
|
/packages/apps/Email/src/org/apache/commons/io/input/ |
TeeInputStream.java | 24 * InputStream proxy that transparently writes a copy of all bytes read
40 * The output stream that will receive a copy of all bytes read from the
53 * and copies all read bytes to the given {@link OutputStream}. The given
57 * @param branch output stream that will receive a copy of all bytes read
65 * and copies all read bytes to the given {@link OutputStream}. The given
70 * @param branch output stream that will receive a copy of all bytes read
103 * @throws IOException if the stream could not be read (or written)
105 public int read() throws IOException {
method in class:TeeInputStream 106 int ch = super.read();
114 * Reads bytes from the proxied input stream and writes the read bytes 123 public int read(byte[] bts, int st, int end) throws IOException { method in class:TeeInputStream 139 public int read(byte[] bts) throws IOException { method in class:TeeInputStream [all...] |
ProxyReader.java | 30 * methods being called, such as read(char[]) to read(char[], int, int).
48 * Invokes the delegate's <code>read()</code> method.
49 * @return the character read or -1 if the end of stream
52 public int read() throws IOException {
method in class:ProxyReader 53 return in.read();
57 * Invokes the delegate's <code>read(char[])</code> method.
58 * @param chr the buffer to read the characters into
59 * @return the number of characters read or -1 if the end of stream
62 public int read(char[] chr) throws IOException { method in class:ProxyReader 74 public int read(char[] chr, int st, int end) throws IOException { method in class:ProxyReader [all...] |
/libcore/luni/src/test/java/libcore/java/io/ |
OldInputStreamReaderTest.java | 74 reader.read(new char[3], -1, 0); 80 reader.read(new char[3], 0, -1); 86 reader.read(new char[3], 4, 0); 92 reader.read(new char[3], 3, 1); 98 reader.read(new char[3], 1, 3); 104 reader.read(new char[3], 0, 4); 111 reader.read(null, 0, 0); 117 assertEquals(0, reader.read(new char[3], 3, 0)); 119 assertEquals(0, reader.read(chars, 0, 0)); 121 assertEquals(3, reader.read(chars, 0, 3)) [all...] |
OldPushbackInputStreamTest.java | 111 assertEquals("Test 1: Incorrect byte read;", 66, tobj.read()); 114 tobj.read(); 120 assertEquals("Test 3: Incorrect byte read;", 121 fileString.getBytes()[0], pis.read()); 129 tobj.read(buf, 6, 5); 130 assertEquals("Wrong value read!", "BEGIN", new String(buf, 6, 5)); 131 assertEquals("Too much read!", "012345BEGIN123456789", new String(buf)); 134 tobj.read(buf, 6, 5); 147 tobj.read(buf, -1, 1) [all...] |
/external/apache-http/src/org/apache/http/impl/io/ |
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 75 * The maximum number of bytes that can be read from the stream. Subsequent 76 * read operations will return -1. 95 * @param contentLength The maximum number of bytes that can be read from 96 * the stream. Subsequent read operations will return -1. 121 while (read(buffer) >= 0) { 125 // to read after closed! 133 * Read the next byte from the stream 136 * @see java.io.InputStream#read() 138 public int read() throws IOException { method in class:ContentLengthInputStream 162 public int read (byte[] b, int off, int len) throws java.io.IOException { method in class:ContentLengthInputStream 187 public int read(byte[] b) throws IOException { method in class:ContentLengthInputStream [all...] |
/external/llvm/lib/Target/MBlaze/ |
MBlazeSchedule3.td | 19 // two source operands are read during the decode stage and the result is 26 , 1 // first operand read after one cycle 27 , 1 ]>, // second operand read after one cycle 33 // two source operands are read during the decode stage and the result is 40 , 1 // first operand read after one cycle 41 , 1 ]>, // second operand read after one cycle 46 // source operands are read during the decode stage and the result is ready 53 , 1 // first operand read after one cycle 54 , 1 ]>, // second operand read after one cycle 60 // are read during the decode stage and the result is ready after the execut [all...] |
MBlazeSchedule5.td | 19 // two source operands are read during the decode stage and the result is 28 , 1 // first operand read after one cycle 29 , 1 ]>, // second operand read after one cycle 34 // pipeline stages. The two source operands are read during the decode stage 43 , 1 // first operand read after one cycle 44 , 1 ]>, // second operand read after one cycle 49 // source operands are read during the decode stage and the result is ready 58 , 1 // first operand read after one cycle 59 , 1 ]>, // second operand read after one cycle 64 // The two source operands are read during the decode stage and the result i [all...] |
/libcore/luni/src/main/java/java/io/ |
Reader.java | 29 * needs to be subclassed, and at least the {@link #read(char[], int, int)} and 80 * indicates how many characters can be read before the mark is invalidated. 88 * the number of characters that can be read before the mark is 117 * @return the character read or -1 if the end of the reader has been 122 public int read() throws IOException { method in class:Reader 125 if (read(charArray, 0, 1) != -1) { 135 * actually read or -1 if the end of the reader has been reached. 138 * character array to store the characters read. 139 * @return the number of characters read or -1 if the end of the reader has 144 public int read(char[] buf) throws IOException method in class:Reader 166 public abstract int read(char[] buf, int offset, int count) throws IOException; method in class:Reader [all...] |
FilterReader.java | 22 * input data while it is being read. Transformations can be anything from a 63 * indicates how many bytes can be read before the mark is invalidated. 70 * the number of bytes that can be read from this reader before 106 * @return The character read or -1 if the end of the filtered reader has 112 public int read() throws IOException { method in class:FilterReader 114 return in.read(); 121 * number of characters actually read or -1 if no characters were read and 125 * the char array in which to store the characters read. 128 * read from this reader 137 public int read(char[] buffer, int offset, int count) throws IOException { method in class:FilterReader [all...] |
/libcore/luni/src/main/java/java/sql/ |
DataTruncation.java | 36 private boolean read = false; field in class:DataTruncation 62 * @param read 63 * {@code true} if the truncation occurred on a read operation, 70 public DataTruncation(int index, boolean parameter, boolean read, 75 this.read = read; 91 * @param read 92 * true if the truncation occurred on a read operation, false 103 public DataTruncation(int index, boolean parameter, boolean read, 105 super(THE_REASON, read ? THE_SQLSTATE_READ : THE_SQLSTATE_WRITE [all...] |
/cts/suite/audio_quality/lib/src/ |
ClientSocket.cpp | 75 // make non-blocking mode only during read. This allows supporting time-out for read 96 int read; local 112 LOGE("socket read timeout"); 117 read = recv(mSocket, (void*)data, toRead, 0); 118 if (read > 0) { 119 toRead -= read; 120 data += read; 121 } else if (read == 0) { 122 // in blocking mode, zero read mean's peer closed [all...] |
/external/chromium/net/tools/flip_server/ |
buffer_interface.h | 14 // Returns the bytes which can be read from the buffer. There is no 45 // bytes - bytes which are read, and copied into the buffer. 46 // size - number of bytes which are read and copied. 53 // recv() or read(), etc. 62 // Gets a pointer which can be read from 68 // ptr - assigned a pointer from which we may read 69 // size - the amount of data (in bytes) that it is safe to read 74 // Returns the number of bytes read. 78 // bytes - the pointer into which bytes are read from this buffer 80 // size - number of bytes which are read and copied [all...] |
/external/qemu/slirp/ |
sbuf.h | 4 * Please read the file COPYRIGHT for the 19 char *sb_rptr; /* read pointer. points to where the next 20 * byte should be read from the sbuf */
|