- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 81 for irides (0.15 sec)
-
internal/grid/grid.go
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. // The context both allows returning errors on writes and to ensure that // this isn't abandoned if the channel is no longer being read from. func WriterToChannel(ctx context.Context, ch chan<- []byte) io.Writer {
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) -
cmd/healthcheck-handler.go
} result := objLayer.Health(ctx, opts) w.Header().Set(xhttp.MinIOWriteQuorum, strconv.Itoa(result.WriteQuorum)) w.Header().Set(xhttp.MinIOStorageClassDefaults, strconv.FormatBool(result.UsingDefaults)) // return how many drives are being healed if any if result.HealingDrives > 0 { w.Header().Set(xhttp.MinIOHealingDrives, strconv.Itoa(result.HealingDrives)) } if !result.Healthy { // As a maintenance call we are purposefully asked to be taken
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
internal/store/queuestore.go
return errLimitExceeded } // Generate a new UUID for the key. key, err := uuid.NewRandom() if err != nil { return err } return store.multiWrite(key.String(), item) } // multiWrite - writes an item to the directory. func (store *QueueStore[I]) multiWrite(key string, item []I) error { buf := bytebufferpool.Get() defer bytebufferpool.Put(buf)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 7.1K bytes - Viewed (0) -
src/archive/tar/reader.go
} return n, err } // writeTo writes the content of the current file to w. // The bytes written matches the number of remaining bytes in the current file. // // If the current file is sparse and w is an io.WriteSeeker, // then writeTo uses Seek to skip past holes defined in Header.SparseHoles, // assuming that skipped regions are filled with NULs. // This always writes the last byte to ensure w is the right size. //
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
cmd/local-locker.go
} type lockStats struct { Total int Writes int Reads int } func (l *localLocker) stats() lockStats { l.mutex.Lock() defer l.mutex.Unlock() st := lockStats{Total: len(l.lockMap)} for _, v := range l.lockMap { if len(v) == 0 { continue } entry := v[0] if entry.Writer { st.Writes++ } else { st.Reads += len(v) } } return st
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 10.6K bytes - Viewed (0) -
cni/pkg/install/install.go
return copiedFiles, fmt.Errorf("copy binaries: %v", err) } // Install kubeconfig (if needed) - we write/update this in the shared node CNI netdir, // which may be watched by other CNIs, and so we don't want to trigger writes to this file // unless it's missing or the contents are not what we expect. if err := maybeWriteKubeConfigFile(in.cfg); err != nil { cniInstalls.With(resultLabel.Value(resultCreateKubeConfigFailure)).Increment()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
src/bufio/scan_test.go
type slowReader struct { max int buf io.Reader } func (sr *slowReader) Read(p []byte) (n int, err error) { if len(p) > sr.max { p = p[0:sr.max] } return sr.buf.Read(p) } // genLine writes to buf a predictable but non-trivial line of text of length // n, including the terminal newline and an occasional carriage return. // If addNewline is false, the \r and \n are not emitted.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Viewed (0) -
internal/http/response-recorder.go
if (lrw.LogErrBody && lrw.StatusCode >= http.StatusBadRequest) || lrw.LogAllBody { return lrw.body.Bytes() } // ... otherwise we return the <BLOB> place holder return blobBody } // WriteHeader - writes http status code func (lrw *ResponseRecorder) WriteHeader(code int) { if !lrw.headersLogged { lrw.StatusCode = code lrw.writeHeaders(&lrw.headers, code, lrw.ResponseWriter.Header()) lrw.headersLogged = true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 00:13:19 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/bitrot-streaming.go
package cmd import ( "bytes" "context" "hash" "io" "sync" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/ioutil" ) // Calculates bitrot in chunks and writes the hash into the stream. type streamingBitrotWriter struct { iow io.WriteCloser closeWithErr func(err error) error h hash.Hash shardSize int64 canClose *sync.WaitGroup }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
src/bytes/buffer.go
if n < 0 || n > b.Len() { panic("bytes.Buffer: truncation out of range") } b.buf = b.buf[:b.off+n] } // Reset resets the buffer to be empty, // but it retains the underlying storage for use by future writes. // Reset is the same as [Buffer.Truncate](0). func (b *Buffer) Reset() { b.buf = b.buf[:0] b.off = 0 b.lastRead = opInvalid }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 15.7K bytes - Viewed (0)