- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 900 for makeAs (0.2 sec)
-
src/arena/arena.go
// slice after free may result in a fault, but this fault is also not guaranteed. func MakeSlice[T any](a *Arena, len, cap int) []T { var sl []T runtime_arena_arena_Slice(a.a, &sl, cap) return sl[:len] } // Clone makes a shallow copy of the input value that is no longer bound to any // arena it may have been allocated from, returning the copy. If it was not // allocated from an arena, it is returned untouched. This function is useful
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Wed Oct 12 20:23:36 UTC 2022 - 4.3K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleJavadocsPlugin.java
// TODO: Staging directory should be a part of the Javadocs extension // TODO: Pull out more of this configuration into the extension if it makes sense // TODO: in a typical project, this may need to be the regular javadoc task vs javadocAll ObjectFactory objects = project.getObjects(); // TODO: This breaks if version is changed later
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Tue Aug 20 14:11:17 UTC 2024 - 7.3K bytes - Viewed (0) -
docs/en/docs/tutorial/middleware.md
* It takes each **request** that comes to your application. * It can then do something to that **request** or run any needed code. * Then it passes the **request** to be processed by the rest of the application (by some *path operation*). * It then takes the **response** generated by the application (by some *path operation*).
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 3.2K bytes - Viewed (0) -
internal/s3select/jstream/scanner_test.go
package jstream import ( "bufio" "bytes" "fmt" "io" "sync/atomic" "testing" ) var ( smallInput = make([]byte, 1024*12) // 12K mediumInput = make([]byte, 1024*1024*12) // 12MB largeInput = make([]byte, 1024*1024*128) // 128MB ) func TestScanner(t *testing.T) { data := []byte("abcdefghijklmnopqrstuvwxyz0123456789") var i int r := bytes.NewReader(data) scanner := newScanner(r)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 3.2K bytes - Viewed (0) -
internal/s3select/csv/reader.go
} // Create queue r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.input = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.readerWg.Add(1) // Start splitter go func() { defer close(r.input) defer close(r.queue) defer r.readerWg.Done() for { q := queueItem{ input: next, dst: make(chan [][]string, 1), err: nextErr, } select {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/local-locker_test.go
t.Fatalf("lockUID len, got %d, want %d", len(l.lockUID), 0) } } func TestLocalLockerUnlock(t *testing.T) { const n = 1000 const m = 5 wResources := make([][m]string, n) rResources := make([]string, n) wUIDs := make([]string, n) rUIDs := make([]string, 0, n*2) l := newLocker() ctx := context.Background() quorum := 0 for i := range wResources { names := [m]string{} for j := range names {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 11.9K bytes - Viewed (0) -
cmd/peer-s3-server.go
globalLocalDrivesMu.RUnlock() // Initialize sync waitgroup. g := errgroup.WithNErrs(len(localDrives)) // Disk states slices beforeState := make([]string, len(localDrives)) afterState := make([]string, len(localDrives)) // Make a volume entry on all underlying storage disks. for index := range localDrives { index := index g.Go(func() (serr error) { if localDrives[index] == nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 22 21:57:20 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/erasure-healing.go
copyPartsMetadata := make([]FileInfo, len(partsMetadata)) for i := range latestDisks { if latestDisks[i] == nil { continue } copyPartsMetadata[i] = partsMetadata[i] } for i := range outDatedDisks { if outDatedDisks[i] == nil { continue } // Make sure to write the FileInfo information // that is expected to be in quorum.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Oct 02 17:50:41 UTC 2024 - 34.4K bytes - Viewed (0) -
src/bytes/buffer_test.go
} rlen := rand.Intn(len(testString)) fub := make([]byte, rlen) n, _ := buf.Read(fub) s = s[n:] } empty(t, "TestMixedReadsAndWrites (2)", &buf, s, make([]byte, buf.Len())) } func TestCapWithPreallocatedSlice(t *testing.T) { buf := NewBuffer(make([]byte, 10)) n := buf.Cap() if n != 10 { t.Errorf("expected 10, got %d", n) } }
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Tue Sep 03 20:55:15 UTC 2024 - 18.6K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_test.go
m0.incrementBytes(0) m1MiBPS := newBucketMeasurement(start) m1MiBPS.incrementBytes(oneMiB) test1Want := make(map[BucketOptions]Details) test1Want[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{LimitInBytesPerSecond: 1024 * 1024, CurrentBandwidthInBytesPerSecond: 0} test1Want2 := make(map[BucketOptions]Details) test1Want2[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Sep 06 03:21:59 UTC 2023 - 4.3K bytes - Viewed (0)