- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 385 for Stopping (0.45 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service_unix_test.go
if err != nil { t.Fatalf("failed when execute encrypt, error: %v", err) } t.Log("Connected to KMSPlugin") // Stop KMS Plugin - simulating connection loss t.Log("KMS Plugin is stopping") f.CleanUp() 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: Fri Jul 21 19:25:52 UTC 2023 - 12.7K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/services/internal/DefaultBuildServicesRegistryTest.groovy
then: def e = thrown(ServiceLifecycleException) e.suppressed != null && e.suppressed.length > 0 } def "exception from stop action does not prevent other services from stopping"() { given: def providerA = registerService("A", StoppableServiceImpl) def providerB = registerService("B", StoppableServiceImpl) Consumer<Object> actionB = Mock()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 19:15:46 UTC 2024 - 16.4K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/CLIManager.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:59 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager_test.go
assert.Equal(t, test.ExpectedPrepareCalls, draServerInfo.server.prepareResourceCalls.Load()) if test.wantErr { assert.Error(t, err) return // PrepareResources returned an error so stopping the subtest here } else if test.wantResourceSkipped { assert.NoError(t, err) return // resource skipped so no need to continue } assert.NoError(t, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:29 UTC 2024 - 42K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
c.queue.Add(key) } } func (c *MetaAllocator) run() { defer runtime.HandleCrash() defer c.queue.ShutDown() klog.Info("Starting ServiceCIDR Allocator Controller") defer klog.Info("Stopping ServiceCIDR Allocator Controllerr") // Wait for all involved caches to be synced, before processing items from the queue is started if !cache.WaitForCacheSync(c.internalStopCh, c.serviceCIDRSynced, c.ipAddressSynced) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
s.XDSServer.ConfigUpdate(&model.PushRequest{ Full: true, Reason: model.NewReasonStats(model.GlobalUpdate), }) <-leaderStop log.Infof("Stopping gateway status writer") gwc.SetStatusWrite(false, nil) }). Run(stop) return nil }) if features.EnableGatewayAPIDeploymentController {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
} // FirstRequestAndProcessXds returns all XDS responses from 1 central or 1..N K8s cluster-based XDS servers, // stopping after the first response that returns any resources. // nolint: lll func FirstRequestAndProcessXds(dr *discovery.DiscoveryRequest, centralOpts clioptions.CentralControlPlaneOptions, istioNamespace string,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc.go
klog.V(4).InfoS("Removing sandbox", "sandboxID", sandboxID) // In normal cases, kubelet should've already called StopPodSandbox before // GC kicks in. To guard against the rare cases where this is not true, try // stopping the sandbox before removing it. if err := cgc.client.StopPodSandbox(ctx, sandboxID); err != nil { klog.ErrorS(err, "Failed to stop sandbox before removing", "sandboxID", sandboxID) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 15.3K bytes - Viewed (0) -
pilot/test/mock/config.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 13.2K bytes - Viewed (0) -
src/runtime/mgc.go
// 966-975. // For journal quality proofs that these steps are complete, correct, and terminate see // Hudson, R., and Moss, J.E.B. Copying Garbage Collection without stopping the world. // Concurrency and Computation: Practice and Experience 15(3-5), 2003. // // 1. GC performs sweep termination. // // a. Stop the world. This causes all Ps to reach a GC safe-point. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0)