- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 58 for startm (0.57 sec)
-
src/time/tick_test.go
t.Helper() const N = 1e4 var stats runtime.MemStats runtime.GC() runtime.GC() runtime.GC() runtime.ReadMemStats(&stats) before := int64(stats.Mallocs - stats.Frees) for j := 0; j < N; j++ { f() } runtime.GC() runtime.GC() runtime.GC() runtime.ReadMemStats(&stats) after := int64(stats.Mallocs - stats.Frees)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
cmd/object-api-utils.go
if oi.Size == 0 || len(oi.Parts) == 0 { return nil } var start int64 end := int64(-1) for i := 0; i < len(oi.Parts) && i < partNumber; i++ { start = end + 1 end = start + oi.Parts[i].ActualSize - 1 } return &HTTPRangeSpec{Start: start, End: end} } // Returns the compressed offset which should be skipped.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 36.3K 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) -
pilot/pkg/bootstrap/istio_ca.go
} 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) -
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) -
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) -
platforms/core-runtime/daemon-server/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonMain.java
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(); try { DaemonContext daemonContext = daemonServices.get(DaemonContext.class);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 9.8K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
return } } } func (conn *Connection) sendDelta(res *discovery.DeltaDiscoveryResponse, newResourceNames []string) error { sendResonse := func() error { start := time.Now() defer func() { xds.RecordSendTime(time.Since(start)) }() return conn.deltaStream.Send(res) } err := sendResonse() if err == nil { if !strings.HasPrefix(res.TypeUrl, v3.DebugType) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0)