| /prebuilts/go/darwin-x86/src/text/scanner/ |
| scanner_test.go | 16 // A StringReader delivers its data one string segment at a time via Read.
22 func (r *StringReader) Read(p []byte) (n int, err error) {
490 func (errReader) Read(b []byte) (int, error) {
622 func (r *countReader) Read([]byte) (int, error) {
644 t.Errorf("scanner called Read %d times, not once", r)
665 t.Errorf("scanner called Read %d times, not once", r)
|
| /prebuilts/go/darwin-x86/src/vendor/golang_org/x/text/transform/ |
| transform.go | 44 // Transform writes to dst the transformed bytes read from src, and
45 // returns the number of dst bytes written and src bytes read. The
111 // Reader wraps another io.Reader by transforming the bytes read.
118 // not yet copied out via Read.
122 // src[src0:src1] contains bytes that have been read from r but not
134 // NewReader returns a new Reader that wraps r by transforming the bytes read
146 // Read implements the io.Reader interface.
147 func (r *Reader) Read(p []byte) (int, error) {
163 // are out of source bytes. We do this even if r.r.Read returned an error.
177 // cannot read more bytes into src
[all...] |
| /prebuilts/go/linux-x86/src/archive/zip/ |
| reader.go | 112 // Return the readDirectoryHeader error if we read
156 // Multiple files may be read concurrently.
185 nread uint64 // number of bytes read so far
187 desr io.Reader // if non-nil, where to read the data descriptor
191 func (r *checksumReader) Read(b []byte) (n int, err error) {
195 n, err = r.rc.Read(b)
217 // the CRC32 of what we've read against the file header
247 // readDirectoryHeader attempts to read a directory header from r.
248 // It returns io.ErrUnexpectedEOF if it cannot read a complete header,
322 // They should only be consulted if the sizes read earlie
[all...] |
| zip_test.go | 547 // read back zip file and check that we get to the end of it
561 t.Fatal("read:", err)
567 t.Fatal("read:", err)
572 t.Fatal("read end:", err)
771 func (zeros) Read(p []byte) (int, error) {
|
| /prebuilts/go/linux-x86/src/bufio/ |
| scan_test.go | 143 func (sr *slowReader) Read(p []byte) (n int, err error) {
147 return sr.buf.Read(p)
325 // Read the data.
371 func (alwaysError) Read(p []byte) (int, error) {
378 t.Fatal("read should fail")
389 func (endlessZeros) Read(p []byte) (int, error) {
396 t.Fatal("read should fail")
525 // Make sure we can read a huge token if a big enough buffer is provided.
|
| /prebuilts/go/linux-x86/src/bytes/ |
| buffer_test.go | 22 func (r *negativeReader) Read([]byte) (int, error) { return -1, nil }
107 n, err := buf.Read(fub)
232 n, _ := buf.Read(fub)
280 wantError := "bytes.Buffer: reader returned negative count from Read"
327 // Read it back with ReadRune
375 n, _ := buf.Read(tmp[0:i])
377 t.Fatalf("Read %d returned %d", i, n)
475 // If we read, this affects buf.off, which is good to test.
476 readBytes, _ := buf.Read(tmp)
514 n, err := b.Read(slice
[all...] |
| /prebuilts/go/linux-x86/src/compress/flate/ |
| deflate_test.go | 134 func (r *sparseReader) Read(b []byte) (n int, err error) {
181 func (b *syncBuffer) Read(p []byte) (n int, err error) {
184 n, err = b.buf.Read(p)
237 // Write half the input and read back.
263 t.Logf("#%d: read %d", i, m)
265 t.Errorf("testSync/%d (%d, %d, %s): read %d: %d, %v (%d left)", i, level, len(input), name, hi-lo, m, err, buf.buf.Len())
269 t.Errorf("testSync/%d: read wrong bytes: %x vs %x", i, input[lo:hi], out[:hi-lo])
274 // in the read buffer (buf.buf.Len() != 0) but that is
279 // the background goroutine had usually read even
286 if n, err := r.Read(out); n > 0 || err != io.EOF
[all...] |
| inflate.go | 49 Err error // error returned by underlying Read
53 return "flate: read error at offset " + strconv.FormatInt(e.Offset, 10) + ": " + e.Err.Error()
258 // The actual read interface needed by NewReader.
334 func (f *decompressor) Read(b []byte) (int, error) {
463 // As an optimization, we can initialize the min bits to read at a time
466 // we never read any extra bytes after the end of the DEFLATE stream.
492 // Read literal and/or (length, distance) according to RFC section 3.2.3.
707 // Read the next Huffman-encoded symbol from f according to h.
778 // to read the uncompressed version of r.
780 // the decompressor may read more data than necessary from r
[all...] |
| /prebuilts/go/linux-x86/src/encoding/base32/ |
| base32.go | 409 nn, err = r.Read(buf[n:])
418 func (d *decoder) Read(p []byte) (n int, err error) {
419 // Use leftover decoded output from last read.
433 // Read a chunk.
470 // invocation of Read, so we return a nil error to ensure that Read
483 func (r *newlineFilteringReader) Read(p []byte) (int, error) {
484 n, err := r.wrapped.Read(p)
498 // Previous buffer entirely whitespace, read again
499 n, err = r.wrapped.Read(p
[all...] |
| /prebuilts/go/linux-x86/src/encoding/base64/ |
| base64.go | 276 // It returns the number of bytes read from src, the number of bytes written
382 readErr error // error from r.Read
391 func (d *decoder) Read(p []byte) (n int, err error) {
392 // Use leftover decoded output from last read.
414 nn, d.readErr = d.r.Read(d.buf[d.nbuf:nn])
581 func (r *newlineFilteringReader) Read(p []byte) (int, error) {
582 n, err := r.wrapped.Read(p)
596 // Previous buffer entirely whitespace, read again
597 n, err = r.wrapped.Read(p)
|
| base64_test.go | 171 count, err := decoder.Read(dbuf)
173 t.Fatal("Read failed", err)
175 testEqual(t, "Read from %q = length %v, want %v", p.encoded, count, len(p.decoded))
178 count, err = decoder.Read(dbuf)
180 testEqual(t, "Read from %q = %v, want %v", p.encoded, err, io.EOF)
192 n, err = decoder.Read(buf[total : total+bs])
196 t.Errorf("Read from %q at pos %d = %d, unexpected error %v", bigtest.encoded, total, n, err)
368 func (r *faultInjectReader) Read(p []byte) (int, error) {
|
| /prebuilts/go/linux-x86/src/encoding/binary/ |
| binary.go | 145 // Read reads structured binary data from r into data.
148 // Bytes read from r are decoded using the specified byte order
156 // or Read may panic.
158 // The error is EOF only if no bytes were read.
160 // Read returns ErrUnexpectedEOF.
161 func Read(r io.Reader, order ByteOrder, data interface{}) error {
242 return errors.New("binary.Read: invalid type " + reflect.TypeOf(data).String())
257 // and read from successive fields of the data.
661 // It returns zero if the type cannot be implemented by the fast path in Read or Write.
|
| /prebuilts/go/linux-x86/src/io/ |
| io_test.go | 102 // while the ReaderFrom must read until EOF, potentially allocating when running out of buffer.
120 func (r zeroErrReader) Read(p []byte) (int, error) {
132 // In case a Read results in an error with non-zero bytes read, and
208 func (wantedAndErrReader) Read(p []byte) (int, error) {
228 n, err = CopyN(b, strings.NewReader("foo"), 3) // b has read from
233 n, err = CopyN(b, strings.NewReader("foo"), 4) // b has read from
254 // A version of bytes.Buffer that returns n > 0, err on Read
261 func (r *dataAndErrorBuffer) Read(p []byte) (n int, err error) {
262 n, err = r.Buffer.Read(p
[all...] |
| /prebuilts/go/linux-x86/src/mime/multipart/ |
| multipart_test.go | 102 never read data
270 func (mr *maliciousReader) Read(b []byte) (n int, err error) {
273 mr.t.Fatal("too much was read")
284 t.Errorf("unexpected part read")
290 t.Errorf("expected to read < %d bytes; read %d", maxReadThreshold, mr.n)
320 func (s *slowReader) Read(p []byte) (int, error) {
322 return s.r.Read(p)
324 return s.r.Read(p[:1])
328 // done is closed when this reader is read from
[all...] |
| /prebuilts/go/linux-x86/src/net/http/httputil/ |
| reverseproxy_test.go | 352 // http: proxy error: read tcp 127.0.0.1:44643: use of closed network connection
370 // Get http://127.0.0.1:58079: read tcp 127.0.0.1:58079:
530 t.Errorf("Backend body read = %v", err)
533 t.Errorf("Backend read %d request body bytes; want %d", len(slurp), len(requestBody))
536 t.Error("Backend read wrong request body.") // 1MB; omitting details
634 // Issue 16659: log errors from short read
666 "read",
813 func (cc *checkCloser) Read(b []byte) (int, error) {
|
| /prebuilts/go/linux-x86/src/net/textproto/ |
| reader.go | 122 // Read the first line.
142 // ReadByte or the next readLineSlice will flush the read buffer;
146 // Read continuation lines.
164 // Bufio will keep err until next read.
281 // decoded text of a dot-encoded block read from r.
292 // The decoded form returned by the Reader's Read method
307 // Read satisfies reads by decoding dot-encoded data read from d.r.
308 func (d *dotReader) Read(b []byte) (n int, err error) {
314 stateDot // read . at beginning of lin
[all...] |
| /prebuilts/go/linux-x86/src/net/ |
| timeout_test.go | 301 // Tests that read deadlines work, even if there's data ready
302 // to be read.
315 c.Write([]byte("READ TIMEOUT TEST"))
340 n, err := c.Read(b[:])
354 t.Fatalf("#%d/%d: read %d; want 0", i, j, n)
396 _, err := c.Read(b[:])
405 t.Fatalf("expected Read to not return, but it returned with %v", err)
425 // Tests that read deadlines work, even if there's data ready
426 // to be read.
486 t.Fatalf("#%d/%d: read %d; want 0", i, j, n
[all...] |
| /prebuilts/go/linux-x86/src/os/exec/ |
| exec_test.go | 458 // therefore we test that the read end of this pipe (which is what
511 n, err := stderr.Read(buf)
513 t.Errorf("Read: %s", err)
523 t.Errorf("Read: '%s' not '%s'", m, expected)
526 t.Errorf("Read timedout")
750 fmt.Fprintf(os.Stderr, "Error: Read %q, want %q", s, stdinCloseTestString)
754 case "read3": // read fd 3
838 n, err := r.Read(buf)
840 fmt.Fprintf(os.Stderr, "Child: read error: %v on pipe %d\n", err, i)
888 func (delayedInfiniteReader) Read(b []byte) (int, error)
[all...] |
| /prebuilts/go/linux-x86/src/os/ |
| file.go | 18 // file, err := os.Open("file.go") // For read access.
27 // The file's data can then be read into a slice of bytes. Read and
31 // count, err := file.Read(data)
35 // fmt.Printf("read %d bytes: %q\n", count, data[:count])
67 O_RDONLY int = syscall.O_RDONLY // open the file read-only.
69 O_RDWR int = syscall.O_RDWR // open the file read-write.
100 // Read reads up to len(b) bytes from the File.
101 // It returns the number of bytes read and any error encountered.
102 // At end of file, Read returns 0, io.EOF
[all...] |
| /prebuilts/go/linux-x86/src/syscall/ |
| fd_nacl.go | 35 read([]byte) (int, error)
43 // with active operations such as blocked read or write calls.
158 func Read(fd int, b []byte) (int, error) {
163 return f.impl.read(b)
210 func (*defaultFileImpl) read([]byte) (int, error) { return 0, ENOSYS } func
226 func (f *naclFile) read(b []byte) (int, error) { func
269 return f.prw(b, offset, f.read)
300 func (f *pipeFile) read(b []byte) (int, error) { func
304 n, err := f.rd.read(b, 0)
|
| /prebuilts/go/linux-x86/src/text/scanner/ |
| scanner_test.go | 16 // A StringReader delivers its data one string segment at a time via Read.
22 func (r *StringReader) Read(p []byte) (n int, err error) {
490 func (errReader) Read(b []byte) (int, error) {
622 func (r *countReader) Read([]byte) (int, error) {
644 t.Errorf("scanner called Read %d times, not once", r)
665 t.Errorf("scanner called Read %d times, not once", r)
|
| /prebuilts/go/linux-x86/src/vendor/golang_org/x/text/transform/ |
| transform.go | 44 // Transform writes to dst the transformed bytes read from src, and
45 // returns the number of dst bytes written and src bytes read. The
111 // Reader wraps another io.Reader by transforming the bytes read.
118 // not yet copied out via Read.
122 // src[src0:src1] contains bytes that have been read from r but not
134 // NewReader returns a new Reader that wraps r by transforming the bytes read
146 // Read implements the io.Reader interface.
147 func (r *Reader) Read(p []byte) (int, error) {
163 // are out of source bytes. We do this even if r.r.Read returned an error.
177 // cannot read more bytes into src
[all...] |
| /system/core/fastboot/ |
| usb_windows.cpp | 59 /// Handle to USB read pipe (endpoint)
74 ssize_t Read(void* data, size_t len) override;
112 // Open read pipe (endpoint)
193 ssize_t WindowsUsbTransport::Read(void* data, size_t len) {
195 unsigned long read = 0; local
203 ret = AdbReadEndpointSync(handle_->adb_read_pipe, data, xfer, &read, time_out);
205 DBG("usb_read got: %ld, expected: %d, errno: %d\n", read, xfer, errno);
207 return read;
298 // read serial number (if there is one)
|
| /system/core/libappfuse/ |
| FuseBuffer.cc | 54 : TEMP_FAILURE_RETRY(read(fd, buf, sizeof(T)));
64 PLOG(ERROR) << "Failed to read a FUSE message";
70 LOG(ERROR) << "Read bytes " << result << " are shorter than header size " << sizeof(header);
74 if (!CheckHeaderLength<T>(self, "Read", sizeof(T))) {
79 LOG(ERROR) << "Read bytes " << result << " are different from header.len " << header.len;
164 bool FuseMessage<T>::Read(int fd) {
|
| /system/core/libziparchive/ |
| zip_archive_stream_entry.cc | 19 // Read-only stream access to Zip Archive entries.
52 const std::vector<uint8_t>* Read() override;
79 const std::vector<uint8_t>* ZipArchiveStreamEntryUncompressed::Read() {
91 ALOGE("Short read of zip file, possibly corrupted zip?");
116 const std::vector<uint8_t>* Read() override;
194 const std::vector<uint8_t>* ZipArchiveStreamEntryCompressed::Read() {
213 ALOGE("Short read of zip file, possibly corrupted zip?");
|
