- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 385 for Stopping (0.17 sec)
-
guava/src/com/google/common/io/CharStreams.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 10.9K bytes - Viewed (0) -
src/runtime/mklockrank.go
< TRACEGLOBAL # Below TRACEGLOBAL manages the global tracing buffer. # Note that traceBuf eventually chains to MALLOC, but we never get that far # in the situation where there's no P. < traceBuf; # Starting/stopping tracing traces strings. traceBuf < traceStrings; # Malloc allg, allocmR, allp, # procresize execR, # May grow stack execW, # May allocate after BeforeFork hchan, notifyList,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.1K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/join/kubelet.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
type Manager interface { // AddPod creates new probe workers for every container probe. This should be called for every // pod created. AddPod(pod *v1.Pod) // StopLivenessAndStartup handles stopping liveness and startup probes during termination. StopLivenessAndStartup(pod *v1.Pod) // RemovePod handles cleaning up the removed pod state, including terminating probe workers and // deleting cached results.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h
/// The cache pruning thread that removes files with expired blocks. std::unique_ptr<TF_Thread, std::function<void(TF_Thread*)>> pruning_thread_; /// Notification for stopping the cache pruning thread. absl::Notification stop_pruning_thread_; /// Guards access to the block map, LRU list, and cached byte count. mutable absl::Mutex mu_; /// The block map (map from Key to Block).
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Aug 31 04:46:34 UTC 2020 - 10.6K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/driver/driver.go
// corresponding to the start address. Open(file string, start, limit, offset uint64, relocationSymbol string) (ObjFile, error) // Disasm disassembles the named object file, starting at // the start address and stopping at (before) the end address. Disasm(file string, start, end uint64, intelSyntax bool) ([]Inst, error) } // An Inst is a single instruction in an assembly listing. type Inst struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 9.8K bytes - Viewed (0) -
platforms/jvm/code-quality/src/main/groovy/org/gradle/api/plugins/quality/Pmd.java
*/ @Override @Nested public final PmdReports getReports() { return reports; } /** * The maximum number of failures to allow before stopping the build. * * Defaults to 0, which will stop the build on any failure. Values 0 and * above are valid. If <pre>ignoreFailures</pre> is set, this is ignored
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jul 19 14:14:11 UTC 2023 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go
if err != nil { t.Fatalf("failed when execute encrypt, error: %v", err) } t.Log("Connected to KMSPlugin") f.CleanUp() // Stop KMS Plugin - simulating connection loss t.Log("KMS Plugin is stopping") time.Sleep(2 * time.Second) wg1.Add(1) wg2.Add(1) go func() { defer wg2.Done() // Call service to encrypt data. t.Log("Sending encrypt request") wg1.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 10K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/vfs/impl/WatchingVirtualFileSystem.java
updateRootUnderLock(this::stopWatchingAndInvalidateHierarchyAfterError); } private SnapshotHierarchy stopWatchingAndInvalidateHierarchyAfterError(SnapshotHierarchy currentRoot) { warningLogger.error("Stopping file watching and invalidating VFS after an error happened"); return stopWatchingAndInvalidateHierarchy(currentRoot); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 02 16:22:15 UTC 2024 - 25.2K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
func (qm *QuotaMonitor) Run(ctx context.Context) { defer utilruntime.HandleCrash() logger := klog.FromContext(ctx) logger.Info("QuotaMonitor running") defer logger.Info("QuotaMonitor stopping") // Set up the stop channel. qm.monitorLock.Lock() qm.stopCh = ctx.Done() qm.running = true qm.monitorLock.Unlock() // Start monitors and begin change processing until the stop channel is
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0)