- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 663 for startm (0.53 sec)
-
pkg/kubelet/cm/dra/plugin/noderesources.go
} } // run is running in the background. It handles blocking initialization (like // syncing the informer) and then syncs the actual with the desired state. func (c *nodeResourcesController) run(ctx context.Context) { logger := klog.FromContext(ctx) // When kubelet starts, we have two choices: // - Sync immediately, which in practice will delete all ResourceSlices
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/text/TreeFormatter.java
throw new IllegalStateException("Not visiting any node."); } if (current.state == State.CollectValue) { current.state = State.Done; current = current.parent; } if (current.state != State.TraverseChildren) { throw new IllegalStateException("Cannot end children."); } if (current.isTopLevelNode()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 22 14:04:39 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
// AddReference is called from RegisterPod thus it needs to be efficient. // Thus, it is only increasing refCount and in case of first registration // of a given object it starts corresponding reflector. // It's responsibility of the first Get operation to wait until the // reflector propagated the store. c.lock.Lock() defer c.lock.Unlock() item, exists := c.items[key] if !exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
src/cmd/link/internal/ld/main.go
dwarfGenerateDebugInfo(ctxt) bench.Start("callgraph") ctxt.callgraph() bench.Start("doStackCheck") ctxt.doStackCheck() bench.Start("mangleTypeSym") ctxt.mangleTypeSym() if ctxt.IsELF { bench.Start("doelf") ctxt.doelf() } if ctxt.IsDarwin() { bench.Start("domacho") ctxt.domacho() } if ctxt.IsWindows() { bench.Start("dope")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 16:59:50 UTC 2024 - 16.6K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorIntegrationTest.groovy
assertDifferentDaemonsWereUsed("startDaemon2", "startDaemon3") assertDifferentDaemonsWereUsed("startDaemon1", "startDaemon3") } def "starts a new worker daemon when there are no idle compatible worker daemons available"() { blockingServer.start() blockingServer.expectConcurrent("runInDaemon", "startNewDaemon") fixture.withWorkActionClassInBuildSrc()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 06 13:00:39 UTC 2024 - 31K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/webui.go
http.StatusNotImplemented) ui.options.UI.PrintErr("Failed to execute dot. Is Graphviz installed?\n", err) return } // Get all node names into an array. nodes := []string{""} // dot starts with node numbered 1 for _, n := range g.Nodes { nodes = append(nodes, n.Info.Name) } ui.render(w, req, "graph", rpt, errList, legend, webArgs{ HTMLBody: template.HTML(string(svg)), Nodes: nodes,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 14K bytes - Viewed (0) -
src/crypto/tls/quic.go
conn: conn, } } // Start starts the client or server handshake protocol. // It may produce connection events, which may be read with [QUICConn.NextEvent]. // // Start must be called at most once. func (q *QUICConn) Start(ctx context.Context) error { if q.conn.quic.started { return quicError(errors.New("tls: Start called more than once")) } q.conn.quic.started = true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/compile.go
stats = fmt.Sprintf("[%d ns %d allocs %d bytes]", time, nAllocs, nBytes) } else { stats = fmt.Sprintf("[%d ns]", time) } if f.Log() { f.Logf(" pass %s end %s\n", p.name, stats) printFunc(f) } f.HTMLWriter.WritePhase(phaseName, fmt.Sprintf("%s <span class=\"stats\">%s</span>", phaseName, stats)) } if p.time || p.mem {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:55:18 UTC 2024 - 18.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
thread = new Thread(new JoinTarget(expectedCompletionWaitMillis)); thread.start(); } void joinSuccessfully() { Uninterruptibles.joinUninterruptibly(thread); completed.assertCompletionExpected(); assertEquals(Thread.State.TERMINATED, thread.getState()); } void joinSuccessfully(long timeoutMillis) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 16:06:39 UTC 2024 - 31.7K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/binutils/binutils.go
return nil, fmt.Errorf("could not identify base for %s: no __TEXT segment", name) } if textSegment.Addr > start { return nil, fmt.Errorf("could not identify base for %s: __TEXT segment address (0x%x) > mapping start address (0x%x)", name, textSegment.Addr, start) } base := start - textSegment.Addr if b.fast || (!b.addr2lineFound && !b.llvmSymbolizerFound) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 22.3K bytes - Viewed (0)