- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for newTree (0.19 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) -
src/net/http/cgi/host.go
// second request? newReq := &http.Request{ Method: "GET", URL: url, Proto: "HTTP/1.1", ProtoMajor: 1, ProtoMinor: 1, Header: make(http.Header), Host: url.Host, RemoteAddr: req.RemoteAddr, TLS: req.TLS, } h.PathLocationHandler.ServeHTTP(rw, newReq) } func upperCaseAndUnderscore(r rune) rune { switch {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 20:46:32 UTC 2024 - 10.4K 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) -
guava/src/com/google/common/util/concurrent/Striped.java
if (existing != null) { return existing; } L created = supplier.get(); ArrayReference<L> newRef = new ArrayReference<>(created, index, queue); while (!locks.compareAndSet(index, existingRef, newRef)) { // we raced, we need to re-read and try again existingRef = locks.get(index); existing = existingRef == null ? null : existingRef.get();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 10 20:55:18 UTC 2023 - 20.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Striped.java
if (existing != null) { return existing; } L created = supplier.get(); ArrayReference<L> newRef = new ArrayReference<>(created, index, queue); while (!locks.compareAndSet(index, existingRef, newRef)) { // we raced, we need to re-read and try again existingRef = locks.get(index); existing = existingRef == null ? null : existingRef.get();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 10 20:55:18 UTC 2023 - 20.3K bytes - Viewed (0) -
src/net/http/client.go
} // refererForURL returns a referer without any authentication info or // an empty string if lastReq scheme is https and newReq scheme is http. // If the referer was explicitly set, then it will continue to be used. func refererForURL(lastReq, newReq *url.URL, explicitRef string) string { // https://tools.ietf.org/html/rfc7231#section-5.5.2 // "Clients SHOULD NOT include a Referer header field in a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 06:06:11 UTC 2024 - 33.7K 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) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/validation/validation.go
if err != nil { return err } out.Definitions, err = convertMapOfJSONSchemaProps(in.Definitions, postProcess) if err != nil { return err } if in.Ref != nil { out.Ref, err = spec.NewRef(*in.Ref) if err != nil { return err } } if in.AdditionalProperties != nil { in, out := &in.AdditionalProperties, &out.AdditionalProperties *out = new(spec.SchemaOrBool)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 18:23:28 UTC 2023 - 15K bytes - Viewed (0)