- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 23 for newTree (0.16 sec)
-
pkg/kube/inject/webhook.go
if len(pair[0]) > 0 && len(pair) == 2 { newRes = append(newRes, pair...) } } return newRes } newRes = strings.Split(parts[2], "/") } for i, value := range newRes { if i%2 != 0 { // Replace --slash-- with / in values. newRes[i] = strings.ReplaceAll(value, "--slash--", "/") } } return newRes }(path) newEnvs := make(map[string]string)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
cmd/main.go
func newApp(name string) *cli.App { // Collection of minio commands currently supported are. commands := []cli.Command{} // Collection of minio commands currently supported in a trie tree. commandsTree := trie.NewTrie() // registerCommand registers a cli command. registerCommand := func(command cli.Command) { commands = append(commands, command) commandsTree.Insert(command.Name) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.4K bytes - Viewed (0) -
cmd/test-utils_test.go
hexChunkSize, chunkSignature)) newChunk, err := io.ReadAll(bufReader) if err != nil { return nil, err } newReq := req newReq.Body = io.NopCloser( bytes.NewReader(bytes.Join([][]byte{newChunkHdr, newChunk[:len(newChunk)/2]}, []byte(""))), ) return newReq, nil } // Malform data given a request signed using streaming signature V4.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
defer timeout(60 * time.Second)() const debug = false var readBytes int var wroteBytes int var readBuf bytes.Buffer var wroteBuf bytes.Buffer readHash := crc32.NewIEEE() wroteHash := crc32.NewIEEE() read := io.Writer(readHash) wrote := io.Writer(wroteHash) if debug { read = io.MultiWriter(read, &readBuf) wrote = io.MultiWriter(wrote, &wroteBuf) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
} oldReq := oldPVC.Spec.Resources.Requests[v1.ResourceStorage] oldCap := oldPVC.Status.Capacity[v1.ResourceStorage] newPVC, ok := new.(*v1.PersistentVolumeClaim) if !ok { return } newReq := newPVC.Spec.Resources.Requests[v1.ResourceStorage] newCap := newPVC.Status.Capacity[v1.ResourceStorage] // PVC will be enqueued under 2 circumstances
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
internal/hash/checksum.go
} // Hasher returns a hasher corresponding to the checksum type. // Returns nil if no checksum. func (c ChecksumType) Hasher() hash.Hash { switch { case c.Is(ChecksumCRC32): return crc32.NewIEEE() case c.Is(ChecksumCRC32C): return crc32.New(crc32.MakeTable(crc32.Castagnoli)) case c.Is(ChecksumSHA1): return sha1.New() case c.Is(ChecksumSHA256): return sha256.New() } return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 08 16:18:34 UTC 2024 - 12.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/internal/passes/tpu_cluster_formation.cc
for (auto ret_vals : llvm::zip(results, cluster.getResults())) { Value old_ret = std::get<0>(ret_vals); Value new_ret = std::get<1>(ret_vals); for (auto& use : llvm::make_early_inc_range(old_ret.getUses())) { Operation* user = use.getOwner(); if (!body->findAncestorOpInBlock(*user)) use.set(new_ret); } } // Move ops that depend on something in the cluster behind the cluster.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 02 22:03:30 UTC 2024 - 39.3K bytes - Viewed (0) -
src/net/http/transport.go
// does not have GetBody but the body hasn't been read at all yet. func setupRewindBody(req *Request) *Request { if req.Body == nil || req.Body == NoBody { return req } newReq := *req newReq.Body = &readTrackingBody{ReadCloser: req.Body} return &newReq } // rewindBody returns a new request with the body rewound. // It returns req unmodified if the body does not need rewinding.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/net/http/transport_test.go
} } srvWG.Wait() ts.Close() } } // A cancelTest is a test of request cancellation. type cancelTest struct { mode testMode newReq func(req *Request) *Request // prepare the request to cancel cancel func(tr *Transport, req *Request) // cancel the request checkErr func(when string, err error) // verify the expected error }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
cmd/object-api-utils_test.go
t.Errorf("Test %d - expected %v but received %v", i+1, test.result, got) } } } func BenchmarkGetPartFileWithTrie(b *testing.B) { b.ResetTimer() entriesTrie := trie.NewTrie() for i := 1; i <= 10000; i++ { entriesTrie.Insert(fmt.Sprintf("%.5d.8a034f82cb9cb31140d87d3ce2a9ede3.67108864", i)) } for i := 1; i <= 10000; i++ {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.4K bytes - Viewed (0)