- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 92 for St (0.02 sec)
-
src/cmd/go/internal/modfetch/fetch.go
goSum.mu.Lock() inited, err := initGoSum() if err != nil { goSum.mu.Unlock() return err } done := inited && haveModSumLocked(mod, h) if inited { st := goSum.status[modSum{mod, h}] st.used = true goSum.status[modSum{mod, h}] = st } goSum.mu.Unlock() if done { return nil } // Not listed, so we want to add them. // Consult checksum database if appropriate.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 14:56:56 UTC 2024 - 30.3K bytes - Viewed (0) -
src/cmd/trace/pprof.go
stack := ev.Stack() if stack == trace.NoStack { continue } // The state transition has to apply to a goroutine. st := ev.StateTransition() if st.Resource.Kind != trace.ResourceGoroutine { continue } id := st.Resource.Goroutine() _, new := st.Goroutine() // Check if we're tracking this goroutine. startEv := tracking[id] if startEv == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.1K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
}, }, }, waitSchedulingPods: []*v1.Pod{ st.MakePod().Name("pod1").UID("pod1").SchedulerName(testSchedulerProfile1).Obj(), st.MakePod().Name("pod2").UID("pod2").SchedulerName(testSchedulerProfile1).Obj(), st.MakePod().Name("pod3").UID("pod3").SchedulerName(testSchedulerProfile2).Obj(), st.MakePod().Name("pod4").UID("pod4").SchedulerName(testSchedulerProfile3).Obj(), },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
case <-GlobalContext.Done(): return } } } func (r *ReplicationStats) updateMovingAvg() { r.RLock() for _, s := range r.Cache { for _, st := range s.Stats { st.XferRateLrg.measure.updateExponentialMovingAverage(time.Now()) st.XferRateSml.measure.updateExponentialMovingAverage(time.Now()) } } r.RUnlock() } // ActiveWorkers returns worker stats
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0) -
src/runtime/cgocall.go
if !top && !isPinned(ss.str) { panic(errorString(msg)) } case abi.Struct: st := (*structtype)(unsafe.Pointer(t)) if !indir { if len(st.Fields) != 1 { throw("can't happen") } cgoCheckArg(st.Fields[0].Typ, p, st.Fields[0].Typ.Kind_&abi.KindDirectIface == 0, top, msg) return } for _, f := range st.Fields { if !f.Typ.Pointers() { continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:47 UTC 2024 - 24.2K bytes - Viewed (0) -
cmd/local-locker.go
} func (l *localLocker) stats() lockStats { l.mutex.Lock() defer l.mutex.Unlock() st := lockStats{Total: len(l.lockMap)} for _, v := range l.lockMap { if len(v) == 0 { continue } entry := v[0] if entry.Writer { st.Writes++ } else { st.Reads += len(v) } } return st } type localLockMap map[string][]lockRequesterInfo
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 10.6K bytes - Viewed (0) -
pkg/scheduler/framework/types_test.go
} }) } } func TestNewNodeInfo(t *testing.T) { nodeName := "test-node" pods := []*v1.Pod{ st.MakePod().UID("test-1").Namespace("node_info_cache_test").Name("test-1").Node(nodeName). Containers([]v1.Container{st.MakeContainer().ResourceRequests(map[v1.ResourceName]string{ v1.ResourceCPU: "100m", v1.ResourceMemory: "500", }).ContainerPort([]v1.ContainerPort{{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
src/cmd/compile/internal/inline/inlheur/scoring.go
} if inlined && indprom { st += "|INDPROM" } if inlined && !expinl { st += "|[NI?]" } else if !inlined && expinl { st += "|[IN?]" } if isPGO { st += "|PGO" } return st } if base.Debug.DumpInlCallSiteScores != 0 { var sl []*CallSite for _, cs := range allCallSites { sl = append(sl, cs) } sort.Slice(sl, func(i, j int) bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 20:42:52 UTC 2024 - 24.2K bytes - Viewed (0) -
src/net/http/httptest/server.go
// https://golang.org/cl/15151) so now we just // forcefully close StateNew. The docs for Server.Close say // we wait for "outstanding requests", so we don't close things // in StateActive. if st == http.StateIdle || st == http.StateNew { s.closeConn(c) } } // If this server doesn't shut down in 5 seconds, tell the user why. t := time.AfterFunc(5*time.Second, s.logCloseHangDebugInfo) defer t.Stop() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
cmd/metacache-walk.go
// behavior. if err := send(metaCacheEntry{ name: opts.BaseDir, metadata: metadata, }); err != nil { return err } } else { st, sterr := Lstat(pathJoin(volumeDir, opts.BaseDir, xlStorageFormatFile)) if sterr == nil && st.Mode().IsRegular() { return errFileNotFound } } } prefix := opts.FilterPrefix var scanDir func(path string) error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0)