- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 105 for bstart (0.12 sec)
-
src/time/tick_test.go
// should produce a time from start+10ms, not start+500ms. // Make sure it does. // To avoid flakes due to very long scheduling delays, // require 10 failures in a row before deciding something is wrong. for range 10 { start := Now() c := After(10 * Millisecond) Sleep(500 * Millisecond) dt := (<-c).Sub(start) if dt < 400*Millisecond { return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheDependencyResolutionFeaturesIntegrationTest.groovy
List<RepoFixture> repos = scenario == DynamicVersionScenario.SINGLE_REPO ? [defaultRepo] : [defaultRepo, repoWithout('thing', 'lib')] server.start() remoteRepo.module("thing", "lib", "1.2").publish() def v3 = remoteRepo.module("thing", "lib", "1.3").publish() taskTypeLogsInputFileCollectionContent() buildFile << """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 33K bytes - Viewed (0) -
platforms/core-runtime/gradle-cli-main/build.gradle.kts
* limitations under the License. */ plugins { id("gradlebuild.distribution.implementation-java") id("gradlebuild.launchable-jar") id("gradlebuild.start-scripts") } description = "Java 6-compatible entry point of the `gradle` command. Boostraps the Gradle client implementation in :launcher." gradlebuildJava.usedForStartup() app {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 1.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} // join() tests public void testJoinWithNoWait() throws InterruptedException { Stopwatch stopwatch = Stopwatch.createStarted(); Thread thread = new Thread(new JoinTarget(15)); thread.start(); thread.join(); assertFalse(thread.isAlive()); joinUninterruptibly(thread); joinUninterruptibly(thread, 0, MILLISECONDS); joinUninterruptibly(thread, -42, MILLISECONDS);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/istio_ca.go
enableJitterForRootCertRotator = env.Register("CITADEL_ENABLE_JITTER_FOR_ROOT_CERT_ROTATOR", true, "If true, set up a jitter to start root cert rotator. "+ "Jitter selects a backoff time in seconds to start root cert rotator, "+ "and the back off time is below root cert check interval.") k8sInCluster = env.Register("KUBERNETES_SERVICE_HOST", "",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 20.6K bytes - Viewed (0) -
pilot/pkg/bootstrap/server_test.go
}) g := NewWithT(t) s, err := NewServer(args, func(s *Server) { s.kubeClient = kube.NewFakeClient() }) g.Expect(err).To(Succeed()) stop := make(chan struct{}) g.Expect(s.Start(stop)).To(Succeed()) defer func() { close(stop) s.WaitUntilCompletion() }() if c.expNewCert { if istiodCert, err := s.getIstiodCertificate(nil); istiodCert == nil || err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 23.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
WaiterThread waiter = new WaiterThread(future); waiter.start(); waiter.awaitWaiting(); PollingThread poller = new PollingThread(future); poller.start(); PollingThread poller2 = new PollingThread(future); poller2.start(); PollingThread poller3 = new PollingThread(future); poller3.start(); poller.awaitInLoop(); poller2.awaitInLoop(); poller3.awaitInLoop();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
cmd/api-response.go
} // MarshalXML - marshal ObjectVersion func (o ObjectVersion) MarshalXML(e *xxml.Encoder, start xxml.StartElement) error { if o.isDeleteMarker { start.Name.Local = "DeleteMarker" } else { start.Name.Local = "Version" } type objectVersionWrapper ObjectVersion return e.EncodeElement(objectVersionWrapper(o), start) } // DeleteMarkerVersion container for delete marker metadata
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.5K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheSkipCacheIntegrationTest.groovy
} tasks.register("myTask", MyTask) { // use an undeclared input so we can test --refresh-dependencies // URL.text is not tracked for now; we'll have to change it once we start to track it message.set(file("message").toPath().toUri().toURL().text) } """ file("message") << "foo" when: configurationCacheRun "myTask"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 2.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
WaiterThread waiter = new WaiterThread(future); waiter.start(); waiter.awaitWaiting(); PollingThread poller = new PollingThread(future); poller.start(); PollingThread poller2 = new PollingThread(future); poller2.start(); PollingThread poller3 = new PollingThread(future); poller3.start(); poller.awaitInLoop(); poller2.awaitInLoop(); poller3.awaitInLoop();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0)