- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for STARTED (0.11 sec)
-
pilot/pkg/config/kube/crdclient/client.go
} // Run the queue and all informers. Callers should wait for HasSynced() before depending on results. func (cl *Client) Run(stop <-chan struct{}) { if cl.started.Swap(true) { // was already started by other thread return } t0 := time.Now() cl.logger.Infof("Starting Pilot K8S CRD controller") if !kube.WaitForCacheSync("crdclient", stop, cl.informerSynced) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
src/os/exec.go
// released" rather than "process done". p.state.CompareAndSwap(0, uint64(reason)) } // ProcAttr holds the attributes that will be applied to a new process // started by StartProcess. type ProcAttr struct { // If Dir is non-empty, the child changes into the directory before // creating the process. Dir string // If Env is non-nil, it gives the environment variables for the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 12.8K bytes - Viewed (0) -
platforms/core-runtime/daemon-server/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonMain.java
ProcessEnvironment processEnvironment = daemonServices.get(ProcessEnvironment.class); processEnvironment.maybeDetachProcess(); LOGGER.debug("Assuming the daemon was started with following jvm opts: {}", startupOpts); daemonServices.get(AgentInitializer.class).maybeConfigureInstrumentationAgent(); Daemon daemon = daemonServices.get(Daemon.class); daemon.start();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 9.8K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/inputs/process/instrument/ProcessInstrumentationInStaticGroovyIntegrationTest.groovy
problems.assertFailureHasProblems(failure) { def line = 7 + command.readLines().size() withProblem("Build file 'build.gradle': line $line: external process started") } where: varInitializer | processCreator | expectedPwdSuffix | expectedEnvVar
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 12.2K bytes - Viewed (0) -
pilot/test/xds/fake.go
ConfigTemplateInput any // If provided, this mesh config will be used MeshConfig *meshconfig.MeshConfig NetworksWatcher mesh.NetworksWatcher // Callback to modify the kube client before it is started KubeClientModifier func(c kubelib.Client) // Override the default kube client constructor KubeClientBuilder func(objects ...runtime.Object) kubelib.Client
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/inputs/process/ProcessInTaskIntegrationTest.groovy
configurationCacheFails(":sneakyTask") then: failure.assertOutputContains("Hello") problems.assertFailureHasProblems(failure) { withProblem("$location: external process started") } where: snippetsFactory | location exec("getProject()").java | "Unknown location" // TODO(mlopatkin): Fix location there
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 12.5K bytes - Viewed (0) -
pilot/pkg/bootstrap/istio_ca.go
log.Fatalf("failed to create istio ca server: %v", startErr) } s.caServer = caServer } // RunCA will start the cert signing GRPC service on an existing server. // Protected by installer options: the CA will be started only if the JWT token in /var/run/secrets // is mounted. If it is missing - for example old versions of K8S that don't support such tokens - // we will not start the cert-signing server, since pods will have no way to authenticate.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 20.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
public TestThread(L lockLikeObject, String threadName) { super(threadName); this.lockLikeObject = checkNotNull(lockLikeObject); start(); } // Thread.stop() is okay because all threads started by a test are dying at the end of the test, // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
} caOpts.Authenticators = authenticators // Start CA or RA server. This should be called after CA and Istiod certs have been created. s.startCA(caOpts) // TODO: don't run this if galley is started, one ctlz is enough if args.CtrlZOptions != nil { _, _ = ctrlz.Run(args.CtrlZOptions, nil) } // This must be last, otherwise we will not know which informers to register if s.kubeClient != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
public TestThread(L lockLikeObject, String threadName) { super(threadName); this.lockLikeObject = checkNotNull(lockLikeObject); start(); } // Thread.stop() is okay because all threads started by a test are dying at the end of the test, // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0)