- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 355 for read (0.15 sec)
-
internal/ioutil/read_file.go
_, err = io.ReadFull(f, dst) return dst, st, err } // ReadFile reads the named file and returns the contents. // A successful call returns err == nil, not err == EOF. // Because ReadFile reads the whole file, it does not treat an EOF from Read // as an error to be reported. // // passes NOATIME flag for reads on Unix systems to avoid atime updates. func ReadFile(name string) ([]byte, error) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 09 18:17:51 GMT 2023 - 2.3K bytes - Viewed (0) -
internal/ioutil/read_file_noatime_supported.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 937 bytes - Viewed (0) -
internal/ioutil/read_file_noatime_notsupported.go
Harshavardhana <******@****.***> 1629336922 -0700
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 893 bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
func (c *DeadlineConn) setWriteDeadline() { if c.writeDeadline > 0 { c.SetWriteDeadline(time.Now().UTC().Add(c.writeDeadline)) } } // Read - reads data from the connection using wrapped buffered reader. func (c *DeadlineConn) Read(b []byte) (n int, err error) { c.setReadDeadline() n, err = c.Conn.Read(b) return n, err } // Write - writes data to the connection. func (c *DeadlineConn) Write(b []byte) (n int, err error) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 2.3K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
type MonitorReaderOptions struct { BucketOptions HeaderSize int } // Read implements a throttled read func (r *MonitoredReader) Read(buf []byte) (n int, err error) { if r.throttle == nil { return r.r.Read(buf) } if r.lastErr != nil { err = r.lastErr return } b := r.throttle.Burst() // maximum available tokens
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/s3select/csv/reader.go
dst chan [][]string // result of block decode err error // any error encountered will be set here } // Read - reads single record. // Once Read is called the previous record should no longer be referenced. func (r *Reader) Read(dst sql.Record) (sql.Record, error) { // If we have have any records left, return these before any error. for len(r.current) <= r.recordsRead { if r.err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/config/certs.go
certPEMBlock, err := os.ReadFile(certFile) if err != nil { return tls.Certificate{}, ErrTLSReadError(nil).Msg("Unable to read the public key: %s", err) } keyPEMBlock, err := os.ReadFile(keyFile) if err != nil { return tls.Certificate{}, ErrTLSReadError(nil).Msg("Unable to read the private key: %s", err) } key, rest := pem.Decode(keyPEMBlock) if len(rest) > 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.8K bytes - Viewed (0) -
internal/hash/reader.go
return nil } r.contentHasher = cs.Type.Hasher() if r.contentHasher == nil { return ErrInvalidChecksum } return nil } func (r *Reader) Read(p []byte) (int, error) { n, err := r.src.Read(p) r.bytesRead += int64(n) if r.sha256 != nil { r.sha256.Write(p[:n]) } if r.contentHasher != nil { r.contentHasher.Write(p[:n]) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
internal/dsync/locker.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import "context" // NetLocker is dsync compatible locker interface. type NetLocker interface { // Do read lock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of lock request operation. RLock(ctx context.Context, args LockArgs) (bool, error)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_system_drive_reads_per_sec` | `gauge` | Reads per second on a drive | `drive,set_index,drive_index,pool_index,server` | | `minio_system_drive_reads_kb_per_sec` | `gauge` | Kilobytes read per second on a drive | `drive,set_index,drive_index,pool_index,server` |
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 26K bytes - Viewed (0)