- Sort Score
- Result 10 results
- Languages All
Results 211 - 220 of 4,772 for startm (0.12 sec)
-
pkg/controller/resourcequota/resource_quota_monitor.go
} // we're waiting until after the informer start that happens once all the controllers are initialized. This ensures // that they don't get unexpected events on their work queues. <-qm.informersStarted monitors := qm.monitors started := 0 for _, monitor := range monitors { if monitor.stopCh == nil { monitor.stopCh = make(chan struct{}) qm.informerFactory.Start(qm.stopCh) go monitor.Run() started++
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
src/index/suffixarray/sais.go
} } // We recorded the LMS-substring starts but really want the ends. // Luckily, with two differences, the start indexes and the end indexes are the same. // The first difference is that the rightmost LMS-substring's end index is len(text), // so the caller must pretend that sa[-1] == len(text), as noted above. // The second difference is that the first leftmost LMS-substring start index
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 23:57:18 UTC 2024 - 32.4K bytes - Viewed (0) -
src/runtime/trace/annotation.go
defer userRegion(id, regionEndCode, regionType) fn() } // StartRegion starts a region and returns it. // The returned Region's [Region.End] method must be called // from the same goroutine where the region was started. // Within each goroutine, regions must nest. That is, regions started // after this region must be ended before this region can be ended. // Recommended usage is //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 20 00:47:09 UTC 2023 - 6.1K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser.go
g := gs[ev.G] p := ps[ev.P] if g.state != gRunnable { return fmt.Errorf("g %d is not runnable before start (time %d)", ev.G, ev.Ts) } if p.g != 0 { return fmt.Errorf("p %d is already running g %d while start g %d (time %d)", ev.P, p.g, ev.G, ev.Ts) } g.state = gRunning g.evStart = ev p.g = ev.G if g.evCreate != nil { ev.StkID = uint32(g.evCreate.Args[1])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 46.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor_test.go
ch, quit := make(chan interface{}), make(chan interface{}) return ch, quit, NewOperationExecutor(newFakeOperationGenerator(ch, quit)) } // This function starts by writing to ch and blocks on the quit channel // until it is closed by the currently running test func startOperationAndBlock(ch chan<- interface{}, quit <-chan interface{}) { ch <- nil <-quit
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 26.9K bytes - Viewed (0) -
pkg/kubelet/server/stats/volume_stat_calculator.go
} } } // Store the new stats s.latest.Store(PodVolumeStats{EphemeralVolumes: ephemeralStats, PersistentVolumes: persistentStats}) } // parsePodVolumeStats converts (internal) volume.Metrics to (external) stats.VolumeStats structures func (s *volumeStatCalculator) parsePodVolumeStats(podName string, pvcRef *stats.PVCReference, metric *volume.Metrics, volSpec v1.Volume) stats.VolumeStats { var (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 29 00:55:10 UTC 2022 - 7.1K bytes - Viewed (0) -
platforms/jvm/scala/src/main/java/org/gradle/api/tasks/scala/ScalaDocOptions.java
* Returns the additional parameters passed to the compiler. * Each parameter starts with '-'. */ @Nullable @Optional @Input public List<String> getAdditionalParameters() { return additionalParameters; } /** * Sets the additional parameters passed to the compiler. * Each parameter must start with '-'. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 15:43:33 UTC 2023 - 4.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
object WebSocketProtocol { /** Magic value which must be appended to the key in a response header. */ internal const val ACCEPT_MAGIC = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11" /* Each frame starts with two bytes of data. 0 1 2 3 4 5 6 7 0 1 2 3 4 5 6 7 +-+-+-+-+-------+ +-+-------------+ |F|R|R|R| OP | |M| LENGTH | |I|S|S|S| CODE | |A| | |N|V|V|V| | |S| |
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
if quit { return false } defer c.queue.Done(key) // log slow aggregations start := time.Now() defer func() { elapsed := time.Since(start) if elapsed > time.Second { klog.Warningf("slow openapi aggregation of %q: %s", key, elapsed) } }() err := c.syncFn(key) if err == nil { c.queue.Forget(key) return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
src/net/http/transport_dial_test.go
rt2 := dt.roundTrip() c2 := dt.wantDial() rt1.finish() rt2.wantDone(c1) // This section is a bit overfitted to the current Transport implementation: // A third request starts. We have an in-progress dial that was started by rt2, // but this new request (rt3) is going to ignore it and make a dial of its own. // rt3 will use the first of these dials that completes. rt3 := dt.roundTrip() c3 := dt.wantDial()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0)