- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for isIdle (2.41 sec)
-
src/cmd/go/internal/par/queue_test.go
q := NewQueue(1) select { case <-q.Idle(): default: t.Errorf("NewQueue(1) is not initially idle.") } started := make(chan struct{}) unblock := make(chan struct{}) q.Add(func() { close(started) <-unblock }) <-started idle := q.Idle() select { case <-idle: t.Errorf("NewQueue(1) is marked idle while processing work.") default: } close(unblock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 24 21:08:46 UTC 2020 - 1.4K bytes - Viewed (0) -
src/cmd/dist/build.go
if b == "" { b = "power8" } goppc64 = b b = os.Getenv("GORISCV64") if b == "" { b = "rva20u64" } goriscv64 = b if p := pathf("%s/src/all.bash", goroot); !isfile(p) { fatalf("$GOROOT is not set correctly or not exported\n"+ "\tGOROOT=%s\n"+ "\t%s does not exist", goroot, p) } b = os.Getenv("GOHOSTARCH") if b != "" { gohostarch = b }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 18:34:40 UTC 2024 - 54K bytes - Viewed (0) -
src/cmd/go/internal/modload/load.go
allPatternIsRoot bool // Is the "all" pattern an additional root? listRoots func(rs *Requirements) []string } func (ld *loader) reset() { select { case <-ld.work.Idle(): default: panic("loader.reset when not idle") } ld.roots = nil ld.pkgCache = new(par.Cache[string, *loadPkg]) ld.pkgs = nil } // error reports an error via either os.Stderr or base.Error,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 14:56:56 UTC 2024 - 84K bytes - Viewed (0) -
src/cmd/go/internal/modload/buildlist.go
enqueue(r, nextPruning) } } }) } mustHaveGoRoot(roots) for _, m := range roots { enqueue(m, pruning) } <-loadQueue.Idle() // Reload any dependencies of the main modules which are not // at their selected versions at workspace mode, because the // requirements don't accurately reflect the transitive imports. if pruning == workspace {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 16:04:44 UTC 2024 - 53.8K bytes - Viewed (0) -
api/go1.11.txt
pkg crypto/tls, method (*ConnectionState) ExportKeyingMaterial(string, []uint8, int) ([]uint8, error) pkg database/sql, method (IsolationLevel) String() string pkg database/sql, type DBStats struct, Idle int pkg database/sql, type DBStats struct, InUse int pkg database/sql, type DBStats struct, MaxIdleClosed int64 pkg database/sql, type DBStats struct, MaxLifetimeClosed int64
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 22 03:48:56 UTC 2018 - 25K bytes - Viewed (0) -
src/cmd/go/internal/modload/search.go
return filepath.SkipDir } return nil }) if err != nil { m.AddError(err) } } // Wait for all in-flight operations to complete before returning. defer func() { <-q.Idle() sort.Strings(m.Pkgs) // sort everything we added for determinism }() if filter == includeStd { walkPkgs(cfg.GOROOTsrc, "", pruneGoMod) if treeCanMatch("cmd") {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:15 UTC 2023 - 7.9K bytes - Viewed (0) -
api/go1.23.txt
pkg net, type KeepAliveConfig struct #62254 pkg net, type KeepAliveConfig struct, Count int #62254 pkg net, type KeepAliveConfig struct, Enable bool #62254 pkg net, type KeepAliveConfig struct, Idle time.Duration #62254 pkg net, type KeepAliveConfig struct, Interval time.Duration #62254 pkg net, type ListenConfig struct, KeepAliveConfig KeepAliveConfig #62254 pkg net/http, func ParseCookie(string) ([]*Cookie, error) #66008
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 05 20:48:49 UTC 2024 - 8.4K bytes - Viewed (0) -
src/cmd/go/internal/modget/get.go
for _, q := range r.wildcardQueries { q := q r.work.Add(func() { if q.version == "none" { r.queryNone(ctx, q) } else { r.queryWildcard(ctx, q) } }) } <-r.work.Idle() } // queryWildcard adds a candidate set to q for each module for which: // - some version of the module is already in the build list, and // - that module exists at some version matching q.version, and
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:26:32 UTC 2024 - 66.5K bytes - Viewed (0) -
src/cmd/go/internal/par/queue.go
if len(st.backlog) == 0 { if st.active--; st.active == 0 && st.idle != nil { close(st.idle) } q.st <- st return } f, st.backlog = st.backlog[0], st.backlog[1:] q.st <- st } }() } // Idle returns a channel that will be closed when q has no (active or enqueued) // work outstanding. func (q *Queue) Idle() <-chan struct{} { st := <-q.st defer func() { q.st <- st }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 24 21:08:46 UTC 2020 - 1.9K bytes - Viewed (0) -
src/cmd/dist/util.go
} return real } // isdir reports whether p names an existing directory. func isdir(p string) bool { fi, err := os.Stat(p) return err == nil && fi.IsDir() } // isfile reports whether p names an existing file. func isfile(p string) bool { fi, err := os.Stat(p) return err == nil && fi.Mode().IsRegular() } // mtime returns the modification time of the file p. func mtime(p string) time.Time {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 23 17:50:29 UTC 2023 - 11.2K bytes - Viewed (0)