- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 365 for pStates (0.12 sec)
-
src/runtime/sigqueue.go
// variable. It can be in three states: // * sigReceiving means that signal_recv is blocked on sig.Note and there are // no new pending signals. // * sigSending means that sig.mask *may* contain new pending signals, // signal_recv can't be blocked in this state. // * sigIdle means that there are no new pending signals and signal_recv is not // blocked. // // Transitions between states are done atomically with CAS. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/latency_tracker.go
// // If an API request involves N (N>=1) round trips to etcd, then we will sum // up the latenciy incurred in each roundtrip. // It uses the context associated with the request in flight, so there // are no states shared among the requests in flight, and so there is no // concurrency overhead. // If the goroutine executing the request handler makes concurrent calls // to the underlying storage layer, that is protected since the latency
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 3.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java
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 * - Terminated: runningTasks == 0 and shutdown == true */ @GuardedBy("lock") private int runningTasks = 0;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
} } else { oldContainerStateCount := getContainerStateCount(cachedPodStatus) currentContainerStateCount := getContainerStateCount(podStatus) // old and new set of container states may vary; // get a unique set of container states combining both containerStates := make(map[kubecontainer.State]bool) for state := range oldContainerStateCount { containerStates[state] = true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/core/ModelNode.java
import java.util.Set; public interface ModelNode { boolean hasLink(String name); boolean hasLink(String name, ModelType<?> type); // Note: order is crucial here. Nodes are traversed through these states in the order defined below enum State { Registered(true), // Initial state. Only path and some projections are known here Discovered(true), // All projections are defined
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 3.5K bytes - Viewed (0) -
maven-slf4j-provider/src/main/java/org/apache/maven/slf4j/MavenFailOnSeverityLogger.java
import org.slf4j.event.Level; /** * A proxy which enhances the MavenSimpleLogger with functionality to track whether a logging threshold is hit. * Currently only support WARN and ERROR states, since it's been used for the --fail-on-severity flag. */ public class MavenFailOnSeverityLogger extends MavenSimpleLogger { private final LogLevelRecorder logLevelRecorder;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jan 09 06:36:58 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
containerID, err := findContainerIDByName(&pstatus, container.Name) if err != nil { klog.V(4).InfoS("ReconcileState: skipping container; ID not found in pod status", "pod", klog.KObj(pod), "containerName", container.Name, "err", err) failure = append(failure, reconciledContainer{pod.Name, container.Name, ""}) continue } cstatus, err := findContainerStatusByName(&pstatus, container.Name) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 19.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
} func (cfgCtlr *configController) updateBorrowingLocked(setCompleters bool, plStates map[string]*priorityLevelState) { items := make([]allocProblemItem, 0, len(plStates)) plNames := make([]string, 0, len(plStates)) for plName, plState := range plStates { obs := plState.seatDemandIntegrator.Reset() plState.seatDemandStats.update(obs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
guava/src/com/google/common/cache/ReferenceEntry.java
import com.google.common.cache.LocalCache.ValueReference; import javax.annotation.CheckForNull; /** * An entry in a reference map. * * <p>Entries in the map can be in the following states: * * <p>Valid: * * <ul> * <li>Live: valid key/value are set * <li>Loading: loading is pending * </ul> * * <p>Invalid: * * <ul>
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 3.5K bytes - Viewed (0) -
src/os/dir_darwin.go
} if entptr == nil { // EOF break } // Darwin may return a zero inode when a directory entry has been // deleted but not yet removed from the directory. The man page for // getdirentries(2) states that programs are responsible for skipping // those entries: // // Users of getdirentries() should skip entries with d_fileno = 0, // as such entries represent files which have been deleted but not
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 20:52:06 UTC 2024 - 3.5K bytes - Viewed (0)