Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 54 for _Gwaiting (0.14 sec)

  1. src/runtime/mgcmark.go

    		if (status == _Gwaiting || status == _Gsyscall) && gp.waitsince == 0 {
    			gp.waitsince = work.tstart
    		}
    
    		// scanstack must be done on the system stack in case
    		// we're trying to scan our own stack.
    		systemstack(func() {
    			// If this is a self-scan, put the user G in
    			// _Gwaiting to prevent self-deadlock. It may
    			// already be in _Gwaiting if this is a mark
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  2. src/runtime/traceback.go

    		status = gStatusStrings[gpstatus]
    	} else {
    		status = "???"
    	}
    
    	// Override.
    	if gpstatus == _Gwaiting && gp.waitreason != waitReasonZero {
    		status = gp.waitreason.String()
    	}
    
    	// approx time the G is blocked, in minutes
    	var waitfor int64
    	if (gpstatus == _Gwaiting || gpstatus == _Gsyscall) && gp.waitsince != 0 {
    		waitfor = (nanotime() - gp.waitsince) / 60e9
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  3. src/runtime/mgc.go

    		// rather than starting all in a batch and then waiting once
    		// afterwards. By running one goroutine at a time, we can take
    		// advantage of runnext to bounce back and forth between
    		// workers and this goroutine. In an overloaded application,
    		// this can reduce GC start latency by prioritizing these
    		// goroutines rather than waiting on the end of the run queue.
    		<-ready
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  4. pkg/kubelet/status/status_manager_test.go

    				pod.Status.InitContainerStatuses = []v1.ContainerStatus{
    					{Name: "init-0", State: v1.ContainerState{Waiting: &v1.ContainerStateWaiting{}}},
    					{Name: "init-1", State: v1.ContainerState{Waiting: &v1.ContainerStateWaiting{}}},
    				}
    				pod.Status.ContainerStatuses = []v1.ContainerStatus{
    					{Name: "0", State: v1.ContainerState{Waiting: &v1.ContainerStateWaiting{}}},
    				}
    			}),
    			expectFn: func(t *testing.T, status v1.PodStatus) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	result := &example.PodList{}
    
    	if !utilfeature.DefaultFeatureGate.Enabled(features.ResilientWatchCacheInitialization) {
    		if err := cacher.ready.wait(context.Background()); err != nil {
    			t.Fatalf("unexpected error waiting for the cache to be ready")
    		}
    	}
    
    	// Inject error to underlying layer and check if cacher is not bypassed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  6. src/net/http/transport.go

    }
    
    type connOrError struct {
    	pc     *persistConn
    	err    error
    	idleAt time.Time
    }
    
    // waiting reports whether w is still waiting for an answer (connection or error).
    func (w *wantConn) waiting() bool {
    	w.mu.Lock()
    	defer w.mu.Unlock()
    
    	return !w.done
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/testdata/v1.30.0/core.v1.Pod.json

          {
            "ip": "ipValue"
          }
        ],
        "startTime": "2007-01-01T01:01:01Z",
        "initContainerStatuses": [
          {
            "name": "nameValue",
            "state": {
              "waiting": {
                "reason": "reasonValue",
                "message": "messageValue"
              },
              "running": {
                "startedAt": "2001-01-01T01:01:01Z"
              },
              "terminated": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 52K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/testdata/HEAD/core.v1.Pod.json

          {
            "ip": "ipValue"
          }
        ],
        "startTime": "2007-01-01T01:01:01Z",
        "initContainerStatuses": [
          {
            "name": "nameValue",
            "state": {
              "waiting": {
                "reason": "reasonValue",
                "message": "messageValue"
              },
              "running": {
                "startedAt": "2001-01-01T01:01:01Z"
              },
              "terminated": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 52.6K bytes
    - Viewed (0)
  9. pkg/kubelet/pod_workers_test.go

    		t.Fatalf("unexpected started static pods: %s", cmp.Diff(e, a))
    	}
    	// no static pods shoud be waiting
    	if e, a := map[string][]types.UID{}, podWorkers.waitingToStartStaticPodsByFullname; !reflect.DeepEqual(e, a) {
    		t.Fatalf("unexpected waiting static pods: %s", cmp.Diff(e, a))
    	}
    	// prove 6-static synced
    	if expected, actual :=
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  10. src/internal/trace/order.go

    		// Goroutine stopped (yielded). It's runnable but not running on this M.
    		state.status = go122.GoRunnable
    		newCtx.G = NoGoroutine
    	case go122.EvGoBlock:
    		// Goroutine blocked. It's waiting now and not running on this M.
    		state.status = go122.GoWaiting
    		newCtx.G = NoGoroutine
    	}
    	o.queue.push(Event{table: evt, ctx: curCtx, base: *ev})
    	return newCtx, true, nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 52.4K bytes
    - Viewed (0)
Back to top