- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for read_bytes (0.06 sec)
-
docs/metrics/prometheus/list.md
| `minio_node_io_read_bytes` | Total bytes read by the process from the underlying storage system, /proc/[pid]/io read_bytes. | | `minio_node_io_wchar_bytes` | Total bytes written by the process to the underlying storage system including page cache, /proc/[pid]/io wchar. |
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:48:51 UTC 2024 - 43.3K bytes - Viewed (0) -
docs/metrics/v3.md
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Aug 02 22:30:11 UTC 2024 - 45.2K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
n, err := rb.Read(buf[:readRng.Intn(len(buf))]) readBytes += n read.Write(buf[:n]) debugln("READ 1\t", n, readBytes) if err != nil { readErr = err break } // ReadByte b, err := rb.ReadByte() if err != nil { readErr = err break } readBytes++ read.Write([]byte{b}) debugln("READ 2\t", 1, readBytes) // TryRead
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
src/bytes/buffer_test.go
} // after successful read if _, err := b.ReadBytes('m'); err != nil { t.Fatalf("ReadBytes: %v", err) } if err := b.UnreadByte(); err != nil { t.Fatalf("UnreadByte: %v", err) } c, err := b.ReadByte() if err != nil { t.Fatalf("ReadByte: %v", err) } if c != 'm' { t.Errorf("ReadByte = %q; want %q", c, 'm') } }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Sep 03 20:55:15 UTC 2024 - 18.6K bytes - Viewed (0) -
cmd/metacache-stream.go
if r.current.name, err = r.mr.ReadString(); err != nil { if err == io.EOF { err = io.ErrUnexpectedEOF } r.err = err return metaCacheEntry{}, err } r.current.metadata, err = r.mr.ReadBytes(r.current.metadata[:0]) if err == io.EOF { err = io.ErrUnexpectedEOF } r.err = err return r.current, err } // next will read one entry from the stream.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
src/bytes/buffer.go
if b.off > 0 { b.off-- } return nil } // ReadBytes reads until the first occurrence of delim in the input, // returning a slice containing the data up to and including the delimiter. // If ReadBytes encounters an error before finding a delimiter, // it returns the data read before the error and the error itself (often [io.EOF]). // ReadBytes returns err != nil if and only if the returned data does not end in // delim.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Oct 29 16:47:05 UTC 2024 - 15.7K bytes - Viewed (0) -
src/bufio/bufio.go
totalLen += len(frag) return fullBuffers, frag, totalLen, err } // ReadBytes reads until the first occurrence of delim in the input, // returning a slice containing the data up to and including the delimiter. // If ReadBytes encounters an error before finding a delimiter, // it returns the data read before the error and the error itself (often io.EOF). // ReadBytes returns err != nil if and only if the returned data does not end in // delim.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Oct 12 14:39:08 UTC 2023 - 21.8K bytes - Viewed (0) -
cmd/bucket-metadata_gen.go
z.LifecycleConfigXML, err = dc.ReadBytes(z.LifecycleConfigXML) if err != nil { err = msgp.WrapError(err, "LifecycleConfigXML") return } case "ObjectLockConfigXML": z.ObjectLockConfigXML, err = dc.ReadBytes(z.ObjectLockConfigXML) if err != nil { err = msgp.WrapError(err, "ObjectLockConfigXML") return } case "VersioningConfigXML": z.VersioningConfigXML, err = dc.ReadBytes(z.VersioningConfigXML)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 25.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
val length = source.readMedium() if (length > INITIAL_MAX_FRAME_SIZE) { throw IOException("FRAME_SIZE_ERROR: $length") } val type = source.readByte() and 0xff val flags = source.readByte() and 0xff val streamId = source.readInt() and 0x7fffffff // Ignore reserved bit. if (type != TYPE_WINDOW_UPDATE && logger.isLoggable(FINE)) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
} var lengthBits = source.readByte().toLong() and 0xff if (lengthBits == 0L || lengthBytes == 1 && lengthBits and 0b1000_0000 == 0L) { throw ProtocolException("invalid encoding for length") } for (i in 1 until lengthBytes) { lengthBits = lengthBits shl 8 lengthBits += source.readByte().toInt() and 0xff }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0)