- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 140 for startm (0.15 sec)
-
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) -
pkg/kubelet/cm/qos_container_manager_linux.go
BestEffort: qosClasses[v1.PodQOSBestEffort], } m.getNodeAllocatable = getNodeAllocatable m.activePods = activePods // update qos cgroup tiers on startup and in periodic intervals // to ensure desired state is in sync with actual state. go wait.Until(func() { err := m.UpdateCgroups() if err != nil { klog.InfoS("Failed to reserve QoS requests", "err", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 20:42:59 UTC 2024 - 13.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/CurrentProcess.java
// TODO(mlopatkin) figure out a nicer way of handling the presence of agent in the foreground daemon. // Currently it is hard to have a proper "-javaagent:/path/to/jar" in clients that start the daemon, so all code deals with a boolean flag shouldApplyAgent instead. // It is also possible to have the agent attached at runtime, without the flag, so flag checking is preferred.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 2.6K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheRemoteBuildScriptIntegrationTest.groovy
@Rule HttpServer server = new HttpServer() String scriptUrl TestFile scriptFile String scriptName = "remote-script.gradle" def configurationCache def setup() { server.start() scriptUrl = "${server.uri}/${scriptName}" scriptFile = file("remote-script.gradle") << """ println 'loaded remote script' """ server.expectGet "/$scriptName", scriptFile
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
tracker := assert.NewTracker[string](t) wasm.AddEventHandler(clienttest.TrackerHandler(tracker)) go constantlyAccessForRaceDetection(stop, wasm) // CRD and Delayed client are ready to go by the time we start informers clienttest.MakeCRD(t, c, gvr.WasmPlugin) c.RunAndWait(stop) wt.Create(&istioclient.WasmPlugin{ ObjectMeta: metav1.ObjectMeta{Name: "name", Namespace: "default"}, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
platforms/software/maven/src/integTest/groovy/org/gradle/api/publish/maven/MavenPublishHttpIntegTest.groovy
final String group = "org.gradle" final String name = "publish" final String version = "2" MavenHttpRepository mavenRemoteRepo MavenHttpModule module def setup() { server.start() mavenRemoteRepo = new MavenHttpRepository(server, repoPath, mavenRepo) module = mavenRemoteRepo.module(group, name, version).withModuleMetadata() settingsFile << "rootProject.name = '$name'"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 19.2K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/inputs/process/instrument/UnrelatedMethodInstrumentationInDynamicGroovyIntegrationTest.groovy
e.exec(["some", "string"] as String[], ["array"] as String[], file("test")) def s = new ProcessBuilderStart() s.start() """, enableIndy) when: configurationCacheRun("-q", ":help") then: configurationCache.assertStateStored() where: enableIndy << [true, false]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 3.7K bytes - Viewed (0) -
src/cmd/link/internal/ld/data.go
ldr := state.ctxt.loader for _, s := range syms { state.datsize = aligner(state, state.datsize, s) ldr.SetSymSect(s, sect) if forceType != sym.Sxxx { state.setSymType(s, forceType) } ldr.SetSymValue(s, int64(uint64(state.datsize)-sect.Vaddr)) state.datsize += ldr.SymSize(s) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 12 15:10:50 UTC 2024 - 100.5K bytes - Viewed (0) -
src/os/exec.go
panic("handleTransientRelease called in invalid mode") } for { state := p.state.Load() refs := state &^ processStatusMask status := processStatus(state & processStatusMask) if refs == 0 { // This should never happen because // handleTransientRelease is always paired with // handleTransientAcquire. panic("release of handle with refcount 0") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
// otherwise send. // See kclient.applyDynamicFilter for rationale. f.namespaceDeletedLocked(ns.ObjectMeta) }, }) // Start namespaces and wait for it to be ready now. This is required for subsequent users, so we want to block namespaces.Start(stop) kube.WaitForCacheSync("discovery filter", stop, namespaces.HasSynced) f.selectorsChanged(mesh.Mesh().GetDiscoverySelectors(), false) return f }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0)