- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 4,772 for startm (0.15 sec)
-
src/html/template/js.go
case '+', '-': // ++ and -- are not regexp preceders, but + and - are whether // they are used as infix or prefix operators. start := n - 1 // Count the number of adjacent dashes or pluses. for start > 0 && s[start-1] == c { start-- } if (n-start)&1 == 1 { // Reached for trailing minus signs since "---" is the // same as "-- -". return jsCtxRegexp } return jsCtxDivOp case '.':
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 14.1K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorParallelIntegrationTest.groovy
executer.withTasks("parallelWorkTask") def gradle = executer.start() then: workItems.times { handler.waitForAllPendingCalls() handler.release(1) } then: gradle.waitForFinish() } def "does not start more daemons than max-workers"() { def maxWorkers = 3 given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 31.7K bytes - Viewed (0) -
src/runtime/coro.go
c := new(coro) c.f = f pc := getcallerpc() gp := getg() systemstack(func() { mp := gp.m start := corostart startfv := *(**funcval)(unsafe.Pointer(&start)) gp = newproc1(startfv, gp, pc, true, waitReasonCoroutine) // Scribble down locked thread state if needed and/or donate // thread-lock state to the new goroutine. if mp.lockedExt+mp.lockedInt != 0 { c.mp = mp c.lockedExt = mp.lockedExt
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:18 UTC 2024 - 7.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
// we have a personal informer that is narrowly scoped, start it. go c.configMapInformer.Run(ctx.Done()) // wait for your secondary caches to fill before starting your work if !cache.WaitForNamedCacheSync(c.name, ctx.Done(), c.preRunCaches...) { return } // doesn't matter what workers say, only start one. go wait.Until(c.runWorker, time.Second, ctx.Done())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/unicode/norm/iter.go
break } else if v == ssOverflow { i.next = nextCGJCompose break } if i.info.ccc < prevCC { goto doNorm } } return i.returnSlice(startp, i.p) doNorm: // reset to start position i.p = startp i.info = i.rb.f.info(i.rb.src, i.p) i.rb.ss.first(i.info) if i.info.multiSegment() { d := i.info.Decomposition() info := i.rb.f.info(input{bytes: d}, 0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 11K bytes - Viewed (0) -
tests/util/leak/check.go
// Check adds a check to a test to ensure there are no leaked goroutines // To use, simply call leak.Check(t) at the start of a test; Do not call it in defer. // It is recommended to call this as the first step, as Cleanup is called in LIFO order; this ensures any // Cleanup's called in the test happen first. // Any existing goroutines before the test starts are filtered out. This ensures a single test failing doesn't
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 10:22:38 UTC 2023 - 6.9K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
return s } func (s *CniPluginServer) Stop() { s.cniListenServerCancel() } // Start starts up a UDS server which receives events from the CNI chain plugin. func (s *CniPluginServer) Start() error { if s.sockAddress == "" { return fmt.Errorf("no socket address provided") } log.Info("Start a listen server for CNI plugin events") unixListener, err := pluginlistener.NewListener(s.sockAddress) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
key, quit := c.queue.Get() 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 - 7.9K bytes - Viewed (0) -
pkg/proxy/ipvs/README.md
Similar to local-up cluster, kube-proxy in [clusters running on GCE](https://kubernetes.io/docs/getting-started-guides/gce/) run in IPTABLES mode by default. Users need to export the env `KUBE_PROXY_MODE=ipvs` before [starting a cluster](https://kubernetes.io/docs/getting-started-guides/gce/#starting-a-cluster): ```shell #before running one of the commands chosen to start a cluster: # curl -sS https://get.k8s.io | bash # wget -q -O - https://get.k8s.io | bash
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 02:32:29 UTC 2021 - 18.8K bytes - Viewed (0) -
architecture/networking/controllers.md
Construction should NOT actually start running all of these things, do I/O, or block in anyway. Running the controller actually starts processing things. Normally, this just means running the queue. All informers created by `kube.Client` are kept track in the client, and started in one go with `RunAndWait` in one centralized call.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K bytes - Viewed (0)