| /prebuilts/go/linux-x86/src/encoding/hex/ |
| hex.go | 169 func (d *decoder) Read(p []byte) (n int, err error) {
174 numRead, d.err = d.r.Read(d.arr[numCopy:])
|
| /prebuilts/go/linux-x86/src/internal/poll/ |
| fd_plan9.go | 21 // Lock sysfd and serialize access to Read and Write methods.
31 rtimedout atomicBool // set true when read deadline has been reached
60 // Read implements io.Reader.
61 func (fd *FD) Read(fn func([]byte) (int, error), b []byte) (int, error) {
102 // SetDeadline sets the read and write deadlines associated with fd.
107 // SetReadDeadline sets the read deadline associated with fd.
208 // RawRead invokes the user-defined function f for a read operation.
|
| fd_unix.go | 18 // Lock sysfd and serialize access to Read and Write methods.
37 // Whether a zero byte read indicates EOF. This is false for a
125 // Darwin and FreeBSD can't read or write 2GB+ files at a time,
132 // Read implements io.Reader.
133 func (fd *FD) Read(p []byte) (int, error) {
139 // If the caller wanted a zero byte read, return immediately
141 // Otherwise syscall.Read returns 0, nil which looks like
153 n, err := syscall.Read(fd.Sysfd, p)
438 // WaitWrite waits until data can be read from fd.
463 // RawRead invokes the user-defined function f for a read operation
[all...] |
| /prebuilts/go/linux-x86/src/io/ |
| multi_test.go | 34 n, gerr := mr.Read(buf[0:size])
223 func (f readerFunc) Read(p []byte) (int, error) {
238 // Test that MultiReader properly flattens chained multiReaders when Read is called
243 var readDepth int // will contain the depth from which fakeReader.Read was called
255 r.Read(nil) // don't care about errors, just want to check the call-depth for Read
257 if readDepth != myDepth+2 { // 2 should be multiReader.Read and fakeReader.Read
264 // byte) and io.EOF at once in its Read call.
267 func (b byteAndEOFReader) Read(p []byte) (n int, err error)
[all...] |
| /prebuilts/go/linux-x86/src/math/rand/ |
| rand.go | 53 // generation during most recent Read call.
54 // It is saved so next Read call can start where the previous
254 // Read generates len(p) random bytes and writes them into p. It
256 // Read should not be called concurrently with any other Rand method.
257 func (r *Rand) Read(p []byte) (n int, err error) {
259 return lk.read(p, &r.readVal, &r.readPos)
261 return read(p, r.Int63, &r.readVal, &r.readPos)
264 func read(p []byte, int63 func() int64, readVal *int64, readPos *int8) (n int, err error) { func
345 // Read generates len(p) random bytes from the default Source and
347 // Read, unlike the Rand.Read method, is safe for concurrent use
405 func (r *lockedSource) read(p []byte, readVal *int64, readPos *int8) (n int, err error) { func
[all...] |
| /prebuilts/go/linux-x86/src/mime/multipart/ |
| multipart.go | 42 // during Read calls.
56 total int64 // total data bytes read already
58 readErr error // read error observed from mr.bufReader
110 // stickyErrorReader is an io.Reader which never calls Read on its
113 // Read calls after an error, yet this package does do multiple Reads
120 func (r *stickyErrorReader) Read(p []byte) (n int, _ error) {
124 n, r.err = r.r.Read(p)
154 // Read reads the body of a part, after its headers and before the
156 func (p *Part) Read(d []byte) (n int, err error) {
157 return p.r.Read(d
[all...] |
| /prebuilts/go/linux-x86/src/net/ |
| fd_unix.go | 201 func (fd *netFD) Read(p []byte) (n int, err error) {
202 n, err = fd.pfd.Read(p)
204 return n, wrapSyscallError("read", err)
|
| pipe.go | 95 // Used by local Read to interact with remote Write.
100 // Used by local Write to interact with remote Read.
146 func (p *pipe) Read(b []byte) (int, error) {
147 n, err := p.read(b)
149 err = &OpError{Op: "read", Net: "pipe", Err: err}
154 func (p *pipe) read(b []byte) (n int, err error) { func
|
| /prebuilts/go/linux-x86/src/net/http/ |
| client.go | 131 // read fields of the request in a separate goroutine. Callers
591 // read at least some of the body so if it's
810 // 1) on Read error or close, the stop func is called.
811 // 2) On Read failure, if reqDidTimeout is true, the error is wrapped and
819 func (b *cancelTimerBody) Read(p []byte) (n int, err error) {
820 n, err = b.rc.Read(p)
|
| requestwrite_test.go | 842 // Ensure all the body is read; otherwise
864 func (r *delegateReader) Read(p []byte) (int, error) {
868 return r.r.Read(p)
|
| /prebuilts/go/linux-x86/src/net/http/fcgi/ |
| fcgi_test.go | 36 t.Errorf("%d expected %d, read %d", i, test.size, size)
83 if err := rec.read(buf); err != nil {
98 t.Errorf("%s: read wrong content", test.desc)
127 func (c *writeOnlyConn) Read(p []byte) (int, error) {
322 // read by a handler. Ensures that variables not set will not
|
| /prebuilts/go/linux-x86/src/os/ |
| timeout_test.go | 56 // Tests that read deadlines work, even if there's data ready
57 // to be read.
73 if _, err := w.Write([]byte("READ TIMEOUT TEST")); err != nil {
84 n, err := r.Read(b[:])
95 t.Fatalf("#%d/%d: read %d; want 0", i, j, n)
127 _, err := r.Read(b[:])
133 t.Fatalf("expected Read to not return, but it returned with %v", err)
245 n, err = r.Read(b)
248 err = fmt.Errorf("Read did not return (0, timeout): (%d, %v)", n, err)
252 err = fmt.Errorf("Read took %s; expected %s", dt, d
[all...] |
| /system/core/fastboot/ |
| tcp.cpp | 64 ssize_t Read(void* data, size_t length) override;
127 ssize_t TcpTransport::Read(void* data, size_t length) {
132 // Unless we're mid-message, read the next 8-byte message length.
142 // Now read the message (up to |length| bytes).
|
| /system/core/libbacktrace/ |
| BacktraceCurrent.cpp | 56 size_t BacktraceCurrent::Read(uint64_t addr, uint8_t* buffer, size_t bytes) {
|
| UnwindStack.cpp | 190 size_t UnwindStackPtrace::Read(uint64_t addr, uint8_t* buffer, size_t bytes) {
191 return memory_.Read(addr, buffer, bytes);
232 size_t UnwindStackOffline::Read(uint64_t, uint8_t*, size_t) {
|
| /system/core/libunwindstack/ |
| RegsArm.cpp | 113 Regs* RegsArm::Read(void* remote_data) {
132 // Read from elf memory since it is usually more expensive to read from
|
| RegsArm64.cpp | 107 Regs* RegsArm64::Read(void* remote_data) {
129 // Read from elf memory since it is usually more expensive to read from
|
| RegsMips.cpp | 108 Regs* RegsMips::Read(void* remote_data) {
135 // Read from elf memory since it is usually more expensive to read from
137 if (!elf_memory->Read(rel_pc, &data, sizeof(data))) {
149 // vdso_rt_sigreturn => read rt_sigframe
153 // vdso_sigreturn => read sigframe
160 // read sc_pc and sc_regs[32] from stack
162 if (!process_memory->Read(regs_[MIPS_REG_SP] + offset, values, sizeof(values))) {
|
| RegsMips64.cpp | 108 Regs* RegsMips64::Read(void* remote_data) {
132 // Read from elf memory since it is usually more expensive to read from
134 if (!elf_memory->Read(rel_pc, &data, sizeof(data))) {
146 // vdso_rt_sigreturn => read rt_sigframe
148 // read 64 bit sc_regs[32] from stack into 64 bit regs_
150 if (!process_memory->Read(sp + 24 + 128 + 40, regs_.data(),
156 // read 64 bit sc_pc from stack into 64 bit regs_[MIPS64_REG_PC]
157 if (!process_memory->Read(sp + 24 + 128 + 40 + 576, ®s_[MIPS64_REG_PC], sizeof(uint64_t))) {
|
| RegsX86.cpp | 84 Regs* RegsX86::Read(void* user_data) {
125 // Read from elf memory since it is usually more expensive to read from
171 // Only read the portion of the data structure we care about.
|
| RegsX86_64.cpp | 92 Regs* RegsX86_64::Read(void* remote_data) {
144 // Read from elf memory since it is usually more expensive to read from
160 // Read the mcontext data from the stack.
161 // sp points to the ucontext data structure, read only the mcontext part.
|
| /system/tpm/attestation/server/ |
| database_impl.cc | 92 if (!io_->Read(&buffer)) {
98 bool DatabaseImpl::Read(std::string* data) {
108 PLOG(ERROR) << "Failed to read attestation database";
|
| /system/update_engine/payload_consumer/ |
| mtd_file_descriptor.cc | 61 LOG(ERROR) << "Cannot read " << sysfs_node + kReservedEbs;
66 LOG(ERROR) << "Cannot read " << sysfs_node + kUsableEbSize;
105 // This File Descriptor does not support read and write.
108 // during write, we need to read back to verify the write actually sticks or
138 ssize_t MtdFileDescriptor::Read(void* buf, size_t count) {
183 // This File Descriptor does not support read and write.
217 ssize_t UbiFileDescriptor::Read(void* buf, size_t count) {
219 return EintrSafeFileDescriptor::Read(buf, count);
|
| /bionic/libc/system_properties/ |
| system_properties.cpp | 121 // Make sure this read fulfilled before __system_property_serial
143 int SystemProperties::Read(const prop_info* pi, char* name, char* value) {
164 " to read this property. (the name is truncated to \"%s\")",
185 // Read only properties don't need to copy the value to a temporary buffer, since it can never
205 // TODO: see todo in Read function
218 return Read(pi, nullptr, value);
|
| /build/soong/third_party/zip/ |
| reader.go | 111 // Return the readDirectoryHeader error if we read
155 // Multiple files may be read concurrently.
184 nread uint64 // number of bytes read so far
186 desr io.Reader // if non-nil, where to read the data descriptor
190 func (r *checksumReader) Read(b []byte) (n int, err error) {
194 n, err = r.rc.Read(b)
216 // the CRC32 of what we've read against the file header
246 // readDirectoryHeader attempts to read a directory header from r.
247 // It returns io.ErrUnexpectedEOF if it cannot read a complete header,
300 // They should only be consulted if the sizes read earlie
[all...] |
