- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 265 for curry (0.2 sec)
-
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/AssembleDslDocTask.groovy
linkRepository.put(name, new ClassLinkMetaData(metaData)) } // workaround to IBM JDK bug def createDslDocModelClosure = this.&createDslDocModel.curry(classDocbookDirectory.get().asFile, mainDocbookTemplate, classRepository) def doc = mainDocbookTemplate use(BuildableDOMCategory) {
Groovy - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 9.8K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
sma *SMA `json:"-"` } // Clone returns a copy of XferStats func (rx *XferStats) Clone() *XferStats { curr := rx.curr() peak := rx.Peak if curr > peak { peak = curr } return &XferStats{ Curr: curr, Avg: rx.Avg, Peak: peak, N: rx.N, measure: rx.measure, } } func newXferStats() *XferStats { return &XferStats{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen.go
err = msgp.WrapError(err, "Curr") return } for zb0002 > 0 { zb0002-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err, "Curr") return } switch msgp.UnsafeString(field) { case "Count": z.Curr.Count, err = dc.ReadFloat64() if err != nil { err = msgp.WrapError(err, "Curr", "Count") return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 33.3K bytes - Viewed (0) -
src/archive/tar/writer.go
/* // Write the sparse map and setup the sparse writer if necessary. if len(spd) > 0 { // Use tw.curr since the sparse map is accounted for in hdr.Size. if _, err := tw.curr.Write(spb); err != nil { return err } tw.curr = &sparseFileWriter{tw.curr, spd, 0} } */ return nil } func (tw *Writer) writeGNUHeader(hdr *Header) error {
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) -
src/archive/tar/reader.go
if isHeaderOnlyType(hdr.Typeflag) { nb = 0 } if nb < 0 { return ErrHeader } tr.pad = blockPadding(nb) tr.curr = ®FileReader{r: tr.r, nb: nb} return nil } // handleSparseFile checks if the current file is a sparse format of any type // and sets the curr reader appropriately. func (tr *Reader) handleSparseFile(hdr *Header, rawHdr *block) error { var spd sparseDatas var err error
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/bucket-stats.go
lpeak = math.Max(math.Max(v[Large].Peak, lpeak), v[Large].Curr) speak = math.Max(math.Max(v[Small].Peak, speak), v[Small].Curr) if lpeak > 0 || speak > 0 { count++ } } if count > 0 { lrg := XferStats{ Avg: lavg / float64(count), Curr: lcurr / float64(count), Peak: lpeak, } sml := XferStats{ Avg: savg / float64(count), Curr: scurr / float64(count),
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
// If the host exactly matches, we're done: this connection can carry the address. if (address.url.host == this.route().address.url.host) { return true // This connection is a perfect match. } // At this point we don't have a hostname match. But we still be able to carry the request if // our connection coalescing requirements are met. See also:
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/bucket-targets.go
} type latencyStat struct { lastmin lastMinuteLatency curr time.Duration avg time.Duration peak time.Duration N int64 } func (l *latencyStat) update(d time.Duration) { l.lastmin.add(d) l.N++ if d > l.peak { l.peak = d } l.curr = l.lastmin.getTotal().avg() l.avg = time.Duration((int64(l.avg)*(l.N-1) + int64(l.curr)) / l.N) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.9K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/aether/ReverseTreeRepositoryListener.java
.listIterator(collectStepTrace.getPath().size()); while (iter.hasPrevious()) { DependencyNode curr = iter.previous(); indent += " "; trackingData.add(indent + curr + " (" + collectStepTrace.getContext() + ")"); } } } if (trackingFile == null) { return;
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Apr 12 11:08:37 GMT 2023 - 9.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
SettableFuture<String> orig = SettableFuture.create(); SettableFuture<String> prev = orig; for (int i = 0; i < 100000; i++) { SettableFuture<String> curr = SettableFuture.create(); prev.setFuture(curr); prev = curr; } // prev represents the 'innermost' future prev.set("done"); assertTrue(orig.isDone()); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0)