Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 536 for goroutines (0.22 sec)

  1. src/cmd/trace/pprof.go

    			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 {
    				// We're not. Start tracking if the new state
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. src/runtime/runtime2.go

    }
    
    // ancestorInfo records details of where a goroutine was started.
    type ancestorInfo struct {
    	pcs  []uintptr // pcs from the stack of this goroutine
    	goid uint64    // goroutine id of this goroutine; original goroutine possibly dead
    	gopc uintptr   // pc of go statement that created this goroutine
    }
    
    // A waitReason explains why a goroutine has been stopped.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  3. src/internal/trace/testdata/testprog/stacks.go

    	}
    	defer trace.Stop() // in case of early return
    
    	// Now we will do a bunch of things for which we verify stacks later.
    	// It is impossible to ensure that a goroutine has actually blocked
    	// on a channel, in a select or otherwise. So we kick off goroutines
    	// that need to block first in the hope that while we are executing
    	// the rest of the test, they will block.
    	go func() { // func1
    		select {}
    	}()
    	go func() { // func2
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. src/runtime/debug/garbage.go

    // The initial setting is 10,000 threads.
    //
    // The limit controls the number of operating system threads, not the number
    // of goroutines. A Go program creates a new thread only when a goroutine
    // is ready to run but all the existing threads are blocked in system calls, cgo calls,
    // or are locked to other goroutines due to use of runtime.LockOSThread.
    //
    // SetMaxThreads is useful mainly for limiting the damage done by
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  5. src/internal/trace/trace_test.go

    				delete(gs, ev.Goroutine())
    			}
    			// Track state transitions for goroutines we care about.
    			//
    			// The goroutines we care about will advance through the state machine
    			// of entered -> blocked -> runnable -> running. If in the running state
    			// we block, then we have a futile wakeup. Because of the runtime.Gosched
    			// on these specially marked goroutines, we should end up back in runnable
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  6. doc/next/6-stdlib/99-minor/runtime/debug/42888.md

    file to which the runtime should write its fatal crash report.
    It may be used to construct an automated reporting mechanism for all
    unexpected crashes, not just those in goroutines that explicitly use
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 20:49:22 UTC 2024
    - 282 bytes
    - Viewed (0)
  7. internal/http/server.go

    			if atomic.LoadInt32(&srv.requestCount) <= 0 {
    				return nil
    			}
    
    			// Write all running goroutines.
    			tmp, err := os.CreateTemp("", "minio-goroutines-*.txt")
    			if err == nil {
    				_ = pprof.Lookup("goroutine").WriteTo(tmp, 1)
    				tmp.Close()
    				return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name())
    			}
    			return errors.New("timed out. some connections are still active")
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Feb 09 21:25:16 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  8. src/internal/trace/testdata/generators/go122-go-create-without-running-g.go

    // the time of writing, one such example is goroutines created by expiring
    // timers.
    
    package main
    
    import (
    	"internal/trace"
    	"internal/trace/event/go122"
    	testgen "internal/trace/internal/testgen/go122"
    )
    
    func main() {
    	testgen.Main(gen)
    }
    
    func gen(t *testgen.Trace) {
    	g1 := t.Generation(1)
    
    	// A goroutine gets created on a running P, then starts running.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 996 bytes
    - Viewed (0)
  9. src/cmd/trace/main.go

    	mux.Handle("/jsontrace", JSONTraceHandler(parsed))
    	mux.Handle("/static/", traceviewer.StaticHandler())
    
    	// Goroutines handlers.
    	mux.HandleFunc("/goroutines", GoroutinesHandlerFunc(parsed.summary.Goroutines))
    	mux.HandleFunc("/goroutine", GoroutineHandler(parsed.summary.Goroutines))
    
    	// MMU handler.
    	mux.HandleFunc("/mmu", traceviewer.MMUHandlerFunc(ranges, mutatorUtil))
    
    	// Basic pprof endpoints.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  10. src/internal/runtime/atomic/atomic_andor_test.go

    		}
    	}
    
    	// Set every bit in array to 1.
    	a := make([]uint32, 1<<12)
    	for i := range a {
    		a[i] = 0xffffffff
    	}
    
    	// Clear array bit-by-bit in different goroutines.
    	done := make(chan bool)
    	for i := 0; i < 32; i++ {
    		m := ^uint32(1 << i)
    		go func() {
    			for i := range a {
    				atomic.And(&a[i], m)
    			}
    			done <- true
    		}()
    	}
    	for i := 0; i < 32; i++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Apr 27 20:49:32 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top