Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for isIdle (2.41 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top