| /prebuilts/go/darwin-x86/src/io/ |
| pipe.go | 28 // ErrClosedPipe is the error used for read or write operations on a closed pipe.
29 var ErrClosedPipe = errors.New("io: read/write on closed pipe")
43 func (p *pipe) Read(b []byte) (n int, err error) {
116 // A PipeReader is the read half of a pipe.
121 // Read implements the standard Read interface:
126 func (r *PipeReader) Read(data []byte) (n int, err error) {
127 return r.p.Read(data)
149 // have consumed all the data or the read end is closed.
150 // If the read end is closed with an error, that err i
[all...] |
| /prebuilts/go/darwin-x86/src/net/ |
| fd_plan9.go | 81 func (fd *netFD) Read(b []byte) (n int, err error) {
85 n, err = fd.pfd.Read(fd.data.Read, b)
|
| fd_windows.go | 150 func (fd *netFD) Read(buf []byte) (int, error) {
151 n, err := fd.pfd.Read(buf)
|
| /prebuilts/go/darwin-x86/src/net/http/ |
| http.go | 86 // NoBody is an io.ReadCloser with no bytes. Read always returns EOF
94 func (noBody) Read([]byte) (int, error) { return 0, io.EOF }
|
| /prebuilts/go/darwin-x86/src/net/http/httputil/ |
| dump.go | 56 func (b neverEnding) Read(p []byte) (n int, err error) {
118 // Ensure all the body is read; otherwise
154 func (r *delegateReader) Read(p []byte) (int, error) {
158 return r.r.Read(p)
269 // Read. It's swapped in when we don't actually want to consume
274 func (failureToReadBody) Read([]byte) (int, error) { return 0, errNoBody }
|
| /prebuilts/go/darwin-x86/src/net/http/internal/ |
| chunked.go | 23 // NewChunkedReader returns a new chunkedReader that translates the data read from r
25 // The chunkedReader returns io.EOF when the final 0-length chunk is read.
70 func (cr *chunkedReader) Read(b []uint8) (n int, err error) {
89 // We've read enough. Don't potentially block
104 n0, cr.err = cr.r.Read(rbuf)
108 // If we're at the end of a chunk, read the next two
117 // Read a line of bytes (up to \n) from b.
120 // so they are only valid until the next bufio read.
|
| /prebuilts/go/darwin-x86/test/fixedbugs/ |
| issue15528.go | 19 func (x *RWS) Read(p []byte) (n int, err error) { return }
|
| /prebuilts/go/linux-x86/src/archive/tar/ |
| reader_test.go | 533 // Ensure that we can read back the original Header as written with
650 _, err = io.CopyBuffer(h, tr, rdbuf) // Effectively an incremental read
690 cnt int // Number of bytes to read
691 output string // Expected value of string read
751 _, err = tr.Read([]byte{})
788 cnt int // Expected number of headers read
884 // TestReadHeaderOnly tests that Reader does not attempt to read special
906 // If a special flag, we should read nothing.
[all...] |
| tar_test.go | 35 func (f *testFile) Read(b []byte) (int, error) {
44 return 0, errors.New("unexpected Read operation")
320 // Read it back.
331 t.Fatalf("Read: %v", err)
839 // Read from the byte buffer.
|
| /prebuilts/go/linux-x86/src/archive/zip/ |
| register.go | 80 mu sync.Mutex // guards Close and Read
84 func (r *pooledFlateReader) Read(p []byte) (n int, err error) {
88 return 0, errors.New("Read after Close")
90 return r.fr.Read(p)
|
| /prebuilts/go/linux-x86/src/compress/bzip2/ |
| bzip2.go | 45 // the decompressor may read more data than necessary from r.
85 func (bz2 *reader) Read(buf []byte) (n int, err error) {
102 n, err = bz2.read(buf)
163 func (bz2 *reader) read(buf []byte) (int, error) { func
|
| /prebuilts/go/linux-x86/src/crypto/ecdsa/ |
| ecdsa.go | 276 // Read replaces the contents of dst with zeros.
277 func (z *zr) Read(dst []byte) (n int, err error) {
|
| /prebuilts/go/linux-x86/src/encoding/csv/ |
| reader.go | 101 // first call to Read or ReadAll.
123 // If FieldsPerRecord is positive, Read requires each record to
124 // have the given number of fields. If FieldsPerRecord is 0, Read sets it to
138 // ReuseRecord controls whether calls to Read may return a slice sharing
140 // By default, each call to Read returns newly allocated memory owned by the caller.
147 // numLine is the current line being read in the CSV file.
175 // Read reads one record (a slice of fields) from r.
177 // Read returns the record along with the error ErrFieldCount.
178 // Except for that case, Read always returns either a non-nil
180 // If there is no data left to be read, Read returns nil, io.EOF
[all...] |
| /prebuilts/go/linux-x86/src/io/ |
| pipe.go | 28 // ErrClosedPipe is the error used for read or write operations on a closed pipe.
29 var ErrClosedPipe = errors.New("io: read/write on closed pipe")
43 func (p *pipe) Read(b []byte) (n int, err error) {
116 // A PipeReader is the read half of a pipe.
121 // Read implements the standard Read interface:
126 func (r *PipeReader) Read(data []byte) (n int, err error) {
127 return r.p.Read(data)
149 // have consumed all the data or the read end is closed.
150 // If the read end is closed with an error, that err i
[all...] |
| /prebuilts/go/linux-x86/src/net/ |
| fd_plan9.go | 81 func (fd *netFD) Read(b []byte) (n int, err error) {
85 n, err = fd.pfd.Read(fd.data.Read, b)
|
| fd_windows.go | 150 func (fd *netFD) Read(buf []byte) (int, error) {
151 n, err := fd.pfd.Read(buf)
|
| /prebuilts/go/linux-x86/src/net/http/ |
| http.go | 86 // NoBody is an io.ReadCloser with no bytes. Read always returns EOF
94 func (noBody) Read([]byte) (int, error) { return 0, io.EOF }
|
| /prebuilts/go/linux-x86/src/net/http/httputil/ |
| dump.go | 56 func (b neverEnding) Read(p []byte) (n int, err error) {
118 // Ensure all the body is read; otherwise
154 func (r *delegateReader) Read(p []byte) (int, error) {
158 return r.r.Read(p)
269 // Read. It's swapped in when we don't actually want to consume
274 func (failureToReadBody) Read([]byte) (int, error) { return 0, errNoBody }
|
| /prebuilts/go/linux-x86/src/net/http/internal/ |
| chunked.go | 23 // NewChunkedReader returns a new chunkedReader that translates the data read from r
25 // The chunkedReader returns io.EOF when the final 0-length chunk is read.
70 func (cr *chunkedReader) Read(b []uint8) (n int, err error) {
89 // We've read enough. Don't potentially block
104 n0, cr.err = cr.r.Read(rbuf)
108 // If we're at the end of a chunk, read the next two
117 // Read a line of bytes (up to \n) from b.
120 // so they are only valid until the next bufio read.
|
| /prebuilts/go/linux-x86/test/fixedbugs/ |
| issue15528.go | 19 func (x *RWS) Read(p []byte) (n int, err error) { return }
|
| /system/core/adb/ |
| transport_usb.cpp | 73 // so don't read any more packets than needed.
97 D("remote usb: read terminated (message)");
101 D("remote usb: read received unexpected header length %d", n);
111 D("remote usb: read payload failed (need %u bytes, give %d bytes), skip it",
121 // On Android devices, we rely on the kernel to provide buffered read.
125 PLOG(ERROR) << "remote usb: read terminated (message)";
131 PLOG(ERROR) << "remote usb: read overflow (data length = " << p->msg.data_length << ")";
150 bool UsbConnection::Read(apacket* packet) {
|
| /system/core/fastboot/ |
| udp_test.cpp | 302 // Fixture class to test UDP Transport read/write functionality.
334 bool Read(const std::string& message) {
336 return transport_->Read(&buffer[0], buffer.length()) ==
359 EXPECT_TRUE(Read("bar"));
372 EXPECT_TRUE(Read("bar"));
388 EXPECT_TRUE(Read("foo bar baz"));
389 EXPECT_TRUE(Read("\x01\x02\x03\x04\x05"));
421 // at the socket layer, a single call to Transport::Read() and Transport::Write() is all the
453 EXPECT_TRUE(Read(data));
464 EXPECT_TRUE(Read("foobar"))
[all...] |
| /external/zlib/src/contrib/delphi/ |
| ZLib.pas | 26 total_in: Longint; // total nb of input bytes read so far
54 property OnProgress: TNotifyEvent read FOnProgress write FOnProgress;
91 function Read(var Buffer; Count: Longint): Longint; override;
94 property CompressionRate: Single read GetCompressionRate;
98 { TDecompressionStream decompresses data on the fly as data is read from it.
101 is read-only and unidirectional; you can seek forward in the stream, but not
109 have been read from the stream so far.
112 compressed data is exhausted and the next block is read from the input stream.
120 function Read(var Buffer; Count: Longint): Longint; override;
439 function TCompressionStream.Read(var Buffer; Count: Longint): Longint
[all...] |
| /toolchain/binutils/binutils-2.27/zlib/contrib/delphi/ |
| ZLib.pas | 26 total_in: Longint; // total nb of input bytes read so far
54 property OnProgress: TNotifyEvent read FOnProgress write FOnProgress;
91 function Read(var Buffer; Count: Longint): Longint; override;
94 property CompressionRate: Single read GetCompressionRate;
98 { TDecompressionStream decompresses data on the fly as data is read from it.
101 is read-only and unidirectional; you can seek forward in the stream, but not
109 have been read from the stream so far.
112 compressed data is exhausted and the next block is read from the input stream.
120 function Read(var Buffer; Count: Longint): Longint; override;
439 function TCompressionStream.Read(var Buffer; Count: Longint): Longint
[all...] |
| /device/google/cuttlefish_common/common/vsoc/lib/ |
| circqueue_impl.h | 112 intptr_t CircularByteQueue<SizeLog2>::Read(RegionSignalingInterface* r,
158 intptr_t CircularPacketQueue<SizeLog2, MaxPacketSize>::Read(
|
