Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for gopark (0.76 sec)

  1. src/runtime/mgc.go

    	gp guintptr
    
    	// Release this m on park. This is used to communicate with the unlock
    	// function, which cannot access the G's stack. It is unused outside of
    	// gcBgMarkWorker().
    	m muintptr
    }
    
    func gcBgMarkWorker(ready chan struct{}) {
    	gp := getg()
    
    	// We pass node to a gopark unlock function, so it can't be on
    	// the stack (see gopark). Prevent deadlock from recursively
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  2. src/runtime/pprof/pprof_test.go

    		{"block", []string{"runtime.chanrecv1", "runtime/pprof.blockChanDeep"}},
    		{"mutex", []string{"sync.(*Mutex).Unlock", "runtime/pprof.blockMutexDeep"}},
    		{"goroutine", []string{"runtime.gopark", "runtime.chanrecv", "runtime.chanrecv1", "runtime/pprof.goroutineDeep"}},
    	}
    
    	for _, test := range tests {
    		t.Run(test.profiler, func(t *testing.T) {
    			var buf bytes.Buffer
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 68.8K bytes
    - Viewed (0)
  3. src/runtime/mgcscavenge.go

    		}
    	}
    	if s.gomaxprocs == nil {
    		s.gomaxprocs = func() int32 {
    			return gomaxprocs
    		}
    	}
    }
    
    // park parks the scavenger goroutine.
    func (s *scavengerState) park() {
    	lock(&s.lock)
    	if getg() != s.g {
    		throw("tried to park scavenger from another goroutine")
    	}
    	s.parked = true
    	goparkunlock(&s.lock, waitReasonGCScavengeWait, traceBlockSystemGoroutine, 2)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:48:45 UTC 2024
    - 52.3K bytes
    - Viewed (0)
  4. src/cmd/dist/build.go

    	}
    
    	// Set GOPATH to an internal directory. We shouldn't actually
    	// need to store files here, since the toolchain won't
    	// depend on modules outside of vendor directories, but if
    	// GOPATH points somewhere else (e.g., to GOROOT), the
    	// go tool may complain.
    	os.Setenv("GOPATH", pathf("%s/pkg/obj/gopath", goroot))
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 20 18:34:40 UTC 2024
    - 54K bytes
    - Viewed (0)
  5. src/cmd/go/internal/modload/init.go

    func FindGoWork(wd string) string {
    	if RootMode == NoRoot {
    		return ""
    	}
    
    	switch gowork := cfg.Getenv("GOWORK"); gowork {
    	case "off":
    		return ""
    	case "", "auto":
    		return findWorkspaceFile(wd)
    	default:
    		if !filepath.IsAbs(gowork) {
    			base.Fatalf("go: invalid GOWORK: not an absolute path")
    		}
    		return gowork
    	}
    }
    
    // WorkFilePath returns the absolute path of the go.work file, or "" if not in
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 18:36:30 UTC 2024
    - 69.8K bytes
    - Viewed (0)
  6. src/cmd/go/go_test.go

    	tg.run("env", "GOPATH")
    	tg.grepStdout(regexp.QuoteMeta(tg.path("home/go")), "want GOPATH=$HOME/go")
    
    	tg.setenv("GOROOT", tg.path("home/go"))
    	tg.run("env", "GOPATH")
    	tg.grepStdoutNot(".", "want unset GOPATH because GOROOT=$HOME/go")
    
    	tg.setenv("GOROOT", tg.path("home/go")+"/")
    	tg.run("env", "GOPATH")
    	tg.grepStdoutNot(".", "want unset GOPATH because GOROOT=$HOME/go/")
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 81.1K bytes
    - Viewed (0)
  7. src/go/build/build.go

    		} else {
    			paths = append(paths, "\t($GOROOT not set)")
    		}
    		format = "\t%s (from $GOPATH)"
    		for _, dir := range tried.gopath {
    			paths = append(paths, fmt.Sprintf(format, dir))
    			format = "\t%s"
    		}
    		if len(tried.gopath) == 0 {
    			paths = append(paths, "\t($GOPATH not set. For more details see: 'go help gopath')")
    		}
    		return p, fmt.Errorf("cannot find package %q in any of:\n%s", path, strings.Join(paths, "\n"))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62.3K bytes
    - Viewed (0)
  8. src/cmd/go/internal/modget/get.go

    	}
    
    	newReqs := reqsFromGoMod(modload.ModFile())
    	r.reportChanges(oldReqs, newReqs)
    
    	if gowork := modload.FindGoWork(base.Cwd()); gowork != "" {
    		wf, err := modload.ReadWorkFile(gowork)
    		if err == nil && modload.UpdateWorkGoVersion(wf, modload.MainModules.GoVersion()) {
    			modload.WriteWorkFile(gowork, wf)
    		}
    	}
    }
    
    // parseArgs parses command-line arguments and reports errors.
    //
    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. guava/src/com/google/common/util/concurrent/AbstractFuture.java

        // field.
        void setNext(@CheckForNull Waiter next) {
          ATOMIC_HELPER.putNext(this, next);
        }
    
        void unpark() {
          // This is racy with removeWaiter. The consequence of the race is that we may spuriously call
          // unpark even though the thread has already removed itself from the list. But even if we did
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
  10. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        // field.
        void setNext(@CheckForNull Waiter next) {
          ATOMIC_HELPER.putNext(this, next);
        }
    
        void unpark() {
          // This is racy with removeWaiter. The consequence of the race is that we may spuriously call
          // unpark even though the thread has already removed itself from the list. But even if we did
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
Back to top