Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 329 for goio (0.06 sec)

  1. src/internal/trace/testdata/generators/go122-syscall-steal-proc-reacquire-new-proc.go

    	b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning)
    	b0.Event("GoSyscallBegin", testgen.Seq(1), testgen.NoStack)
    	b0.Event("ProcStart", trace.ProcID(1), testgen.Seq(1))
    	b0.Event("GoSyscallEndBlocked")
    
    	// A running goroutine steals proc 0.
    	b1 := g.Batch(trace.ThreadID(1), 0)
    	b1.Event("ProcStatus", trace.ProcID(2), go122.ProcRunning)
    	b1.Event("GoStatus", trace.GoID(2), trace.ThreadID(1), go122.GoRunning)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  2. src/runtime/os3_plan9.go

    		print("sighandler: ureg ", _ureg, " note ", note, "\n")
    		goto Throw
    	}
    	// Check that the note is no more than ERRMAX bytes (including
    	// the trailing NUL). We should never receive a longer note.
    	if len(notestr) > _ERRMAX-1 {
    		print("sighandler: note is longer than ERRMAX\n")
    		goto Throw
    	}
    	if isAbortPC(c.pc()) {
    		// Never turn abort into a panic.
    		goto Throw
    	}
    	// See if the note matches one of the patterns in sigtab.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. src/runtime/mgcmark.go

    //go:systemstack
    func scanstack(gp *g, gcw *gcWork) int64 {
    	if readgstatus(gp)&_Gscan == 0 {
    		print("runtime:scanstack: gp=", gp, ", goid=", gp.goid, ", gp->atomicstatus=", hex(readgstatus(gp)), "\n")
    		throw("scanstack - bad status")
    	}
    
    	switch readgstatus(gp) &^ _Gscan {
    	default:
    		print("runtime: gp=", gp, ", goid=", gp.goid, ", gp->atomicstatus=", readgstatus(gp), "\n")
    		throw("mark - bad status")
    	case _Gdead:
    		return 0
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  4. src/internal/trace/testdata/generators/go122-syscall-steal-proc-gen-boundary-reacquire-new-proc.go

    }
    
    func gen(t *testgen.Trace) {
    	g := t.Generation(1)
    
    	// One goroutine is exiting with a syscall. It already
    	// acquired a new P.
    	b0 := g.Batch(trace.ThreadID(0), 0)
    	b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoSyscall)
    	b0.Event("ProcStatus", trace.ProcID(1), go122.ProcIdle)
    	b0.Event("ProcStart", trace.ProcID(1), testgen.Seq(1))
    	b0.Event("GoSyscallEndBlocked")
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  5. src/internal/trace/testdata/generators/go122-syscall-steal-proc-gen-boundary.go

    	b0.Event("ProcStatus", trace.ProcID(1), go122.ProcRunning)
    	b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoSyscall)
    	b0.Event("GoSyscallEndBlocked")
    
    	// A running goroutine stole P0 at the generation boundary.
    	b1 := g.Batch(trace.ThreadID(1), 0)
    	b1.Event("ProcStatus", trace.ProcID(2), go122.ProcRunning)
    	b1.Event("GoStatus", trace.GoID(2), trace.ThreadID(1), go122.GoRunning)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  6. src/syscall/exec_plan9.go

    	dupdevfd = int(r1)
    	if dupdevfd == -1 {
    		goto childerror
    	}
    dirloop:
    	for {
    		r1, _, _ = RawSyscall6(SYS_PREAD, uintptr(dupdevfd), uintptr(unsafe.Pointer(&statbuf[0])), uintptr(len(statbuf)), ^uintptr(0), ^uintptr(0), 0)
    		n = int(r1)
    		switch n {
    		case -1:
    			goto childerror
    		case 0:
    			break dirloop
    		}
    		for b = statbuf[:n]; len(b) > 0; {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 21:03:59 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. pkg/proxy/nftables/proxier_test.go

    		add element ip kube-proxy service-ips { 172.30.0.42 . tcp . 80 : goto service-42NFTM6N-ns2/svc2/tcp/p80 }
    		add element ip kube-proxy service-ips { 192.168.99.22 . tcp . 80 : goto external-42NFTM6N-ns2/svc2/tcp/p80 }
    		add element ip kube-proxy service-ips { 1.2.3.4 . tcp . 80 : goto external-42NFTM6N-ns2/svc2/tcp/p80 }
    		add element ip kube-proxy service-nodeports { tcp . 3001 : goto external-42NFTM6N-ns2/svc2/tcp/p80 }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  8. src/internal/trace/testdata/generators/go122-task-across-generations.go

    func gen(t *testgen.Trace) {
    	g1 := t.Generation(1)
    
    	// A running goroutine emits a task begin.
    	b1 := g1.Batch(trace.ThreadID(0), 0)
    	b1.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning)
    	b1.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning)
    	b1.Event("UserTaskBegin", trace.TaskID(2), trace.TaskID(0) /* 0 means no parent, not background */, "my task", testgen.NoStack)
    
    	g2 := t.Generation(2)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  9. src/internal/trace/testdata/generators/go122-syscall-steal-proc-ambiguous.go

    	// One goroutine does a syscall without blocking, then another one where
    	// it's P gets stolen.
    	b0 := g.Batch(trace.ThreadID(0), 0)
    	b0.Event("ProcStatus", trace.ProcID(0), go122.ProcRunning)
    	b0.Event("GoStatus", trace.GoID(1), trace.ThreadID(0), go122.GoRunning)
    	b0.Event("GoSyscallBegin", testgen.Seq(1), testgen.NoStack)
    	b0.Event("GoSyscallEnd")
    	b0.Event("GoSyscallBegin", testgen.Seq(2), testgen.NoStack)
    	b0.Event("GoSyscallEndBlocked")
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/types2/expr.go

    			goto Error
    		}
    		if isTypeParam(x.typ) {
    			check.errorf(x, InvalidAssert, invalidOp+"cannot use type assertion on type parameter value %s", x)
    			goto Error
    		}
    		if _, ok := under(x.typ).(*Interface); !ok {
    			check.errorf(x, InvalidAssert, invalidOp+"%s is not an interface", x)
    			goto Error
    		}
    		T := check.varType(e.Type)
    		if !isValid(T) {
    			goto Error
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 02:09:54 UTC 2024
    - 51.7K bytes
    - Viewed (0)
Back to top