- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 217 for picard (0.15 sec)
-
cmd/kubeadm/app/util/patches/patches_test.go
if err != nil { t.Errorf("error creating temporary file: %v", err) } defer utiltesting.CloseAndRemove(t, tempFile) _, _, _, err = getPatchSetsFromPath(tempFile.Name(), testKnownTargets, io.Discard) var pathErr *os.PathError if !errors.As(err, &pathErr) { t.Fatalf("expected os.PathError for non-directory path %q, but got %v", tempFile.Name(), err) } } func TestGetPatchSetsForPath(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 09 14:24:11 UTC 2023 - 11.9K bytes - Viewed (0) -
src/bufio/bufio.go
err = ErrBufferFull } } return b.buf[b.r : b.r+n], err } // Discard skips the next n bytes, returning the number of bytes discarded. // // If Discard skips fewer than n bytes, it also returns an error. // If 0 <= n <= b.Buffered(), Discard is guaranteed to succeed without // reading from the underlying io.Reader. func (b *Reader) Discard(n int) (discarded int, err error) { if n < 0 { return 0, ErrNegativeCount }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:08 UTC 2023 - 21.8K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
} // SiteReplicationDevNull - everything goes to io.Discard // [POST] /minio/admin/v3/site-replication/devnull func (a adminAPIHandlers) SiteReplicationDevNull(w http.ResponseWriter, r *http.Request) { ctx := r.Context() globalSiteNetPerfRX.Connect() defer globalSiteNetPerfRX.Disconnect() connectTime := time.Now() for { n, err := io.CopyN(xioutil.Discard, r.Body, 128*humanize.KiByte)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.4K bytes - Viewed (0) -
src/archive/tar/reader.go
// one or more "header files" until it finds a "normal file". format := FormatUSTAR | FormatPAX | FormatGNU for { // Discard the remainder of the file and any padding. if err := discard(tr.r, tr.curr.physicalRemaining()); err != nil { return nil, err } if _, err := tryReadFull(tr.r, tr.blk[:tr.pad]); err != nil { return nil, err } tr.pad = 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 01:59:14 UTC 2024 - 26.8K bytes - Viewed (0) -
internal/s3select/select.go
return bytes.NewBuffer(make([]byte, 0, maxRecordSize)) }, } var bufioWriterPool = sync.Pool{ New: func() interface{} { // io.Discard is just used to create the writer. Actual destination // writer is set later by Reset() before using it. return bufio.NewWriter(xioutil.Discard) }, } // UnmarshalXML - decodes XML data. func (c *CompressionType) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 21K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} // If the peer sends more data than we can handle, discard it and close the connection. if (flowControlError) { source.skip(remainingByteCount) closeLater(ErrorCode.FLOW_CONTROL_ERROR) return } // Discard data received after the stream is finished. It's probably a benign race. if (finished) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
}() } } // testRacyWrite tests that it is safe to mutate the input Write buffer // immediately after cancelation has occurred. func testRacyWrite(t *testing.T, c1, c2 net.Conn) { go chunkedCopy(io.Discard, c2) var wg sync.WaitGroup defer wg.Wait() c1.SetWriteDeadline(time.Now().Add(time.Millisecond)) for i := 0; i < 10; i++ { wg.Add(1) go func() { defer wg.Done()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0) -
cmd/data-usage_test.go
size: 200, }, } createUsageTestFiles(t, base, bucket, files) err = os.RemoveAll(filepath.Join(base, bucket, "dir1/dira/dirasub/dcfile")) if err != nil { t.Fatal(err) } // Changed dir must be picked up in this many cycles. for i := 0; i < dataUsageUpdateDirCycles; i++ { got, err = scanDataFolder(context.Background(), nil, base, got, getSize, 0, weSleep) got.Info.NextCycle++ if err != nil { t.Fatal(err)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Mar 27 15:10:40 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubelet/metrics/metrics.go
// ref: https://github.com/kubernetes/community/blob/master/sig-scalability/slos/pod_startup_latency.md // // The histogram bucket boundaries for pod startup latency metrics, measured in seconds. These are hand-picked // so as to be roughly exponential but still round numbers in everyday units. This is to minimise the number // of buckets while allowing accurate measurement of thresholds which might be used in SLOs
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 15:13:25 UTC 2024 - 45.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/LongRunningOperation.java
*/ public interface LongRunningOperation { /** * Sets the {@link java.io.OutputStream} which should receive standard output logging generated while running the operation. * The default is to discard the output. * * @param outputStream The output stream. The system default character encoding will be used to encode characters written to this stream. * @return this * @since 1.0-milestone-7 */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 14K bytes - Viewed (0)