Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 239 for pstatus (0.21 sec)

  1. src/internal/trace/testdata/tests/go122-annotations-stress.test

    ProcStatus dt=67 p=1 pstatus=1
    GoStatus dt=4 g=1 m=1986492 gstatus=2
    ProcsChange dt=220 procs_value=8 stack=1
    STWBegin dt=127 kind_string=21 stack=2
    HeapGoal dt=3 heapgoal_value=4194304
    ProcStatus dt=2 p=0 pstatus=2
    ProcStatus dt=2 p=2 pstatus=2
    ProcStatus dt=1 p=3 pstatus=2
    ProcStatus dt=1 p=4 pstatus=2
    ProcStatus dt=1 p=5 pstatus=2
    ProcStatus dt=1 p=6 pstatus=2
    ProcStatus dt=1 p=7 pstatus=2
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 38.3K bytes
    - Viewed (0)
  2. src/internal/trace/event/go122/event.go

    	EvGoCreateBlocked // goroutine creation (starts blocked) [timestamp, new goroutine ID, new stack ID, stack ID]
    
    	// GoStatus with stack. Added in Go 1.23.
    	EvGoStatusStack // goroutine status at the start of a generation, with a stack [timestamp, goroutine ID, M ID, status, stack ID]
    
    	// Batch event for an experimental batch with a custom format. Added in Go 1.23.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  3. pilot/pkg/config/kube/gateway/conversion_test.go

    		case gvk.GatewayClass:
    			c.Status = kstatus.Wrap(&k8s.GatewayClassStatus{})
    		case gvk.KubernetesGateway:
    			c.Status = kstatus.Wrap(&k8s.GatewayStatus{})
    		case gvk.HTTPRoute:
    			c.Status = kstatus.Wrap(&k8s.HTTPRouteStatus{})
    		case gvk.GRPCRoute:
    			c.Status = kstatus.Wrap(&k8s.GRPCRouteStatus{})
    		case gvk.TCPRoute:
    			c.Status = kstatus.Wrap(&k8salpha.TCPRouteStatus{})
    		case gvk.TLSRoute:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 20:24:52 UTC 2024
    - 34.9K bytes
    - Viewed (0)
  4. pilot/pkg/config/kube/gateway/conditions.go

    	obj.Status.(*kstatus.WrappedStatus).Mutate(func(s config.Status) config.Status {
    		gs := s.(*k8s.GatewayStatus)
    		for index >= len(gs.Listeners) {
    			gs.Listeners = append(gs.Listeners, k8s.ListenerStatus{})
    		}
    		status := gs.Listeners[index]
    		status.AttachedRoutes = i
    		gs.Listeners[index] = status
    		return gs
    	})
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 13:05:41 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  5. tests/integration/pilot/gateway_test.go

    		gw, _ := client.Get(context.Background(), "managed-owner", metav1.GetOptions{})
    		if gw == nil {
    			return fmt.Errorf("failed to find gateway")
    		}
    		cond := kstatus.GetCondition(gw.Status.Conditions, string(k8sv1.GatewayConditionProgrammed))
    		if cond.Status != metav1.ConditionTrue {
    			return fmt.Errorf("failed to find programmed condition: %+v", cond)
    		}
    		if cond.ObservedGeneration != gw.Generation {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  6. cmd/http-stats.go

    		return 0
    	}
    
    	stats.RLock()
    	defer stats.RUnlock()
    
    	val, ok := stats.apiStats[api]
    	if ok {
    		return val
    	}
    
    	return 0
    }
    
    // Load returns the recorded stats.
    func (stats *HTTPAPIStats) Load(toLower bool) map[string]int {
    	if stats == nil {
    		return map[string]int{}
    	}
    
    	stats.RLock()
    	defer stats.RUnlock()
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 06:25:13 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  7. cmd/object-api-interface.go

    func (o *ObjectOptions) PutReplicationState() (r ReplicationState) {
    	rstatus, ok := o.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus]
    	if !ok {
    		return
    	}
    	r.ReplicationStatusInternal = rstatus
    	r.Targets = replicationStatusesMap(rstatus)
    	return
    }
    
    // SetEvalMetadataFn sets the metadata evaluation function
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 06 20:27:52 UTC 2024
    - 17K bytes
    - Viewed (0)
  8. pkg/kubelet/kuberuntime/kuberuntime_container_test.go

    				},
    			},
    		},
    	}
    
    	testLifeCycleHook(t, testPod, &testPod.Spec.InitContainers[0])
    }
    
    func TestStartSpec(t *testing.T) {
    	podStatus := &kubecontainer.PodStatus{
    		ContainerStatuses: []*kubecontainer.Status{
    			{
    				ID: kubecontainer.ContainerID{
    					Type: "docker",
    					ID:   "docker-something-something",
    				},
    				Name: "target",
    			},
    		},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 28K bytes
    - Viewed (0)
  9. tests/integration/ambient/waypoint_test.go

    				if gwc == nil {
    					return fmt.Errorf("failed to find GatewayClass %v", constants.WaypointGatewayClassName)
    				}
    				cond := kstatus.GetCondition(gwc.Status.Conditions, string(k8s.GatewayClassConditionStatusAccepted))
    				if cond.Status != metav1.ConditionTrue {
    					return fmt.Errorf("failed to find accepted condition: %+v", cond)
    				}
    				if cond.ObservedGeneration != gwc.Generation {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  10. pkg/kubelet/status/status_manager.go

    	// clobbering each other so the phase of a pod progresses monotonically.
    	if isCached && isPodStatusByKubeletEqual(&cachedStatus.status, &status) && !forceUpdate {
    		klog.V(3).InfoS("Ignoring same status for pod", "pod", klog.KObj(pod), "status", status)
    		return
    	}
    
    	newStatus := versionedPodStatus{
    		status:        status,
    		version:       cachedStatus.version + 1,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
Back to top