- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 46 for newTree (0.25 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/endpoints/openapi/openapi.go
v1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/kube-openapi/pkg/util" "k8s.io/kube-openapi/pkg/validation/spec" ) var verbs = util.NewTrie([]string{"get", "log", "read", "replace", "patch", "delete", "deletecollection", "watch", "connect", "proxy", "list", "create", "patch"}) const ( extensionGVK = "x-kubernetes-group-version-kind" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 09 18:11:41 UTC 2022 - 5.5K bytes - Viewed (0) -
src/cmd/vendor/rsc.io/markdown/code.go
} } else { fmt.Fprintf(buf, "%s%s\n", prefix1, b.Fence) for _, line := range b.Text { fmt.Fprintf(buf, "%s%s\n", s.prefix, line) } fmt.Fprintf(buf, "%s%s\n", s.prefix, b.Fence) } } func newPre(p *parseState, s line) (line, bool) { peek2 := s if p.para() == nil && peek2.trimSpace(4, 4, false) && !peek2.isBlank() { b := &preBuilder{ /*indent: strings.TrimSuffix(s.string(), peek2.string())*/ } p.addBlock(b)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 4.8K 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) -
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)