- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 46 for newTree (0.16 sec)
-
src/hash/marshal_test.go
var marshalTests = []struct { name string new func() hash.Hash golden []byte }{ {"adler32", func() hash.Hash { return adler32.New() }, fromHex("61646c01460a789d")}, {"crc32", func() hash.Hash { return crc32.NewIEEE() }, fromHex("63726301ca87914dc956d3e8")}, {"crc64", func() hash.Hash { return crc64.New(crc64.MakeTable(crc64.ISO)) }, fromHex("6372630273ba8484bbcd5def5d51c83c581695be")},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Dec 06 07:45:46 UTC 2017 - 5.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go
h.Transport = h.defaultProxyTransport(req.URL, h.Transport) } // WithContext creates a shallow clone of the request with the same context. newReq := req.WithContext(req.Context()) newReq.Header = utilnet.CloneHeader(req.Header) if !h.UseRequestLocation { newReq.URL = &loc } if h.UseLocationHost {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 19.6K bytes - Viewed (0) -
src/hash/crc32/crc32_test.go
func TestCastagnoliRace(t *testing.T) { // The MakeTable(Castagnoli) lazily initializes castagnoliTable, // which races with the switch on tab during Write to check // whether tab == castagnoliTable. ieee := NewIEEE() go MakeTable(Castagnoli) ieee.Write([]byte("hello")) } type test struct { ieee, castagnoli uint32 in string
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 12.1K bytes - Viewed (0) -
src/net/http/client_test.go
{lastReq: "http://gopher:******@****.***", newReq: "http://link.com", want: "http://test.com"}, {lastReq: "https://gopher:******@****.***", newReq: "https://link.com", want: "https://test.com"}, // nothing to do: {lastReq: "http://test.com", newReq: "http://link.com", want: "http://test.com"}, {lastReq: "https://test.com", newReq: "https://link.com", want: "https://test.com"}, // https to http doesn't send a referer:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
location := &url.URL{} location.Scheme = "https" location.Host = host location.Path = req.URL.Path location.RawQuery = req.URL.Query().Encode() newReq, cancelFn := apiserverproxyutil.NewRequestForProxy(location, req) newReq.Header.Add(PeerProxiedHeader, "true") defer cancelFn() proxyRoundTripper := transport.NewAuthProxyRoundTripper(user.GetName(), user.GetGroups(), user.GetExtra(), h.proxyTransport)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
isUnblocked := c.newRef.BlockOwnerDeletion == nil || (c.newRef.BlockOwnerDeletion != nil && !*c.newRef.BlockOwnerDeletion) if wasBlocked && isUnblocked { node, found := gb.uidToNode.Read(c.newRef.UID) if !found { logger.V(5).Info("cannot find uid in uidToNode", "uid", c.newRef.UID) continue } gb.attemptToDelete.Add(node) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
cmd/admin-handlers-users.go
// root user. if newCred.ParentUser != globalActiveCred.AccessKey { replLogIf(ctx, globalSiteReplicationSys.IAMChangeHook(ctx, madmin.SRIAMItem{ Type: madmin.SRIAMItemSvcAcc, SvcAccChange: &madmin.SRSvcAccChange{ Create: &madmin.SRSvcAccCreate{ Parent: newCred.ParentUser, AccessKey: newCred.AccessKey, SecretKey: newCred.SecretKey, Groups: newCred.Groups,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 28 17:19:04 UTC 2024 - 78.6K bytes - Viewed (0) -
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) -
pkg/log/uds.go
buffers: make([]*buffer.Buffer, 0), } for l := zapcore.DebugLevel; l <= zapcore.FatalLevel; l++ { if baseCore.Enabled(l) { uc.minimumLevel = l break } } return zapcore.NewTee(baseCore, uc) } // Enabled implements zapcore.Core. func (u *udsCore) Enabled(l zapcore.Level) bool { return l >= u.minimumLevel } // With implements zapcore.Core.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 16 00:20:01 UTC 2024 - 3.4K bytes - Viewed (0) -
internal/grid/README.md
instance := grid.NewStream[*Payload, *Req, *Resp](h, newPayload, newReq, newResp) // Tweakable options instance.WithPayload = true // default true when newPayload != nil instance.OutCapacity = 1 // default instance.InCapacity = 1 // default true when newReq != nil // Register the handler on the manager instance.Register(manager, handler, "asubroute")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0)