- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 461 for Writes (0.23 sec)
-
internal/logger/logrotate.go
opts Options // f is the currently open file used for appends. // Writes to f are only synchronized once Close() is called, // or when files are being rotated. f *os.File pw *xioutil.PipeWriter pr *xioutil.PipeReader } // Write writes p into the current file, rotating if necessary. // Write is non-blocking, if the writer's queue is not full. // Write is blocking otherwise.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/local-locker_gen.go
// EncodeMsg implements msgp.Encodable func (z lockStats) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "Total" err = en.Append(0x83, 0xa5, 0x54, 0x6f, 0x74, 0x61, 0x6c) if err != nil { return } err = en.WriteInt(z.Total) if err != nil { err = msgp.WrapError(err, "Total") return } // write "Writes" err = en.Append(0xa6, 0x57, 0x72, 0x69, 0x74, 0x65, 0x73) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/erasure-encode.go
import ( "context" "fmt" "io" "sync" ) // Writes in parallel to writers type parallelWriter struct { writers []io.Writer writeQuorum int errs []error } // Write writes data to writers in parallel. func (p *parallelWriter) Write(ctx context.Context, blocks [][]byte) error { var wg sync.WaitGroup for i := range p.writers { if p.writers[i] == nil { p.errs[i] = errDiskNotFound continue
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3K bytes - Viewed (0) -
cmd/metrics-v3-system-drive.go
// iostat related driveReadsPerSec = "reads_per_sec" driveReadsKBPerSec = "reads_kb_per_sec" driveReadsAwait = "reads_await" driveWritesPerSec = "writes_per_sec" driveWritesKBPerSec = "writes_kb_per_sec" driveWritesAwait = "writes_await" drivePercUtil = "perc_util" ) var ( driveUsedBytesMD = NewGaugeMD(driveUsedBytes, "Total storage used on a drive in bytes", allDriveLabels...)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 7.8K bytes - Viewed (0) -
docs/distributed/SIZING.md
If one or more drives are offline at the start of a PutObject or NewMultipartUpload operation the object will have additional data protection bits added automatically to provide the regular safety for these objects up to 50% of the number of drives. This will allow normal write operations to take place on systems that exceed the write tolerance.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 15 23:04:20 GMT 2023 - 3.9K bytes - Viewed (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/util/ReproduciblePropertiesWriter.kt
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Sat Sep 30 16:17:28 GMT 2023 - 1.6K bytes - Viewed (0) -
src/bufio/bufio.go
// accepted and all subsequent writes, and [Writer.Flush], will return the error. // After all data has been written, the client should call the // [Writer.Flush] method to guarantee all data has been forwarded to // the underlying [io.Writer]. type Writer struct { err error buf []byte n int wr io.Writer }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
src/archive/tar/writer.go
"path" "sort" "strings" "time" ) // Writer provides sequential writing of a tar archive. // [Writer.WriteHeader] begins a new file with the provided [Header], // and then Writer can be treated as an io.Writer to supply that file's data. type Writer struct { w io.Writer pad int64 // Amount of padding to write after current file entry curr fileWriter // Writer for current file entry
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 19.6K bytes - Viewed (0) -
cmd/metrics-resource.go
totalInodes MetricName = "total_inodes" readsPerSec MetricName = "reads_per_sec" writesPerSec MetricName = "writes_per_sec" readsKBPerSec MetricName = "reads_kb_per_sec" writesKBPerSec MetricName = "writes_kb_per_sec" readsAwait MetricName = "reads_await" writesAwait MetricName = "writes_await" percUtil MetricName = "perc_util" usedInodes MetricName = "used_inodes" // network stats
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
internal/grid/grid.go
ctx context.Context } func (w *writerWrapper) Write(p []byte) (n int, err error) { buf := GetByteBufferCap(len(p)) buf = buf[:len(p)] copy(buf, p) select { case w.ch <- buf: return len(p), nil case <-w.ctx.Done(): return 0, context.Cause(w.ctx) } } // WriterToChannel will return an io.Writer that writes to the given channel.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0)