- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,550 for statDep (0.13 sec)
-
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/DefaultModelRegistry.java
public ModelNode atState(ModelPath path, ModelNode.State state) { return atStateOrMaybeLater(path, state, false); } @Override public ModelNode atStateOrLater(ModelPath path, ModelNode.State state) { return atStateOrMaybeLater(path, state, true); } @Override public <T> T atStateOrLater(ModelPath path, ModelType<T> type, ModelNode.State state) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 15:40:00 UTC 2024 - 45.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java
final class DirectExecutorService extends AbstractListeningExecutorService { /** Lock used whenever accessing the state variables (runningTasks, shutdown) of the executor */ private final Object lock = new Object(); /* * Conceptually, these two variables describe the executor being in * one of three states: * - Active: shutdown == false * - Shutdown: runningTasks > 0 and shutdown == true
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java
ComponentGraphResolveState state = potentialEdge.state; VirtualPlatformState virtualPlatformState = null; if (state == null || state instanceof LenientPlatformGraphResolveState) { virtualPlatformState = potentialEdge.component.getModule().getPlatformState(); virtualPlatformState.participatingModule(component.getModule()); } if (state == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 58.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_test.go
input: &runtimeapi.ContainerStatus{ Id: cid.ID, Metadata: meta, Image: imageSpec, State: runtimeapi.ContainerState_CONTAINER_CREATED, CreatedAt: createdAt, }, expected: &kubecontainer.Status{ ID: *cid, Image: imageSpec.Image, State: kubecontainer.ContainerStateCreated, CreatedAt: time.Unix(0, createdAt), }, }, "running container": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 28K bytes - Viewed (0) -
src/internal/trace/resources.go
func (d StateTransition) Goroutine() (from, to GoState) { if d.Resource.Kind != ResourceGoroutine { panic("Goroutine called on non-Goroutine state transition") } return GoState(d.oldState), GoState(d.newState) } // Proc returns the state transition for a proc. // // Transitions to and from states that are Executing are special in that // they change the future execution context. In other words, future events
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
// it immediately from volume manager. Instead, check the kubelet // pod state provider to verify that all containers in the pod have been // terminated. if !dswp.podStateProvider.ShouldPodRuntimeBeRemoved(volumeToMount.Pod.UID) { klog.V(4).InfoS("Pod still has one or more containers in the non-exited state and will not be removed from desired state", "pod", klog.KObj(volumeToMount.Pod)) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pilot/pkg/request/command_test.go
if err := util.Compare(body, p.States[0].wantBody); err == nil { w.WriteHeader(p.States[0].StatusCode) w.Write([]byte(p.States[0].Response)) } else { w.WriteHeader(http.StatusBadRequest) w.Write([]byte(fmt.Sprintf("wanted body %q got %q", string(p.States[0].wantBody), string(body)))) } } else { w.WriteHeader(http.StatusBadRequest) w.Write([]byte(fmt.Sprintf("wanted path %q got %q", p.States[0].wantPath, r.URL.Path))) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 11 19:11:01 UTC 2023 - 4.1K bytes - Viewed (0) -
cmd/peer-s3-server.go
globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrives) globalLocalDrivesMu.RUnlock() // Initialize sync waitgroup. g := errgroup.WithNErrs(len(localDrives)) // Disk states slices beforeState := make([]string, len(localDrives)) afterState := make([]string, len(localDrives)) // Make a volume entry on all underlying storage disks. for index := range localDrives { index := index
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.4K bytes - Viewed (0) -
src/html/template/context.go
// // is a single token in HTML's grammar but in a template spans several nodes. type state uint8 //go:generate stringer -type state const ( // stateText is parsed character data. An HTML parser is in // this state when its parse position is outside an HTML tag, // directive, comment, and special element body. stateText state = iota // stateTag occurs before an HTML attribute or the end of a tag. stateTag
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 16 03:29:27 UTC 2023 - 9.4K bytes - Viewed (0) -
pkg/kubelet/pleg/generic_test.go
for len(ch) > 0 { e := <-ch events = append(events, e) } return events } func createTestContainer(ID string, state kubecontainer.State) *kubecontainer.Container { return &kubecontainer.Container{ ID: kubecontainer.ContainerID{Type: testContainerRuntimeType, ID: ID}, State: state, } } type sortableEvents []*PodLifecycleEvent func (a sortableEvents) Len() int { return len(a) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 24.8K bytes - Viewed (0)