- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 3,379 for startm (1.15 sec)
-
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
def build1 = executer.withStackTraceChecksDisabled().withArguments("-d").withTasks("lock").start() def build2 = executer.withStackTraceChecksDisabled().withArguments("-d").withTasks("lock").start() def build3 = executer.withStackTraceChecksDisabled().withArguments("-d").withTasks("lock").start() poll(120) { assert requestReceived assertConfirmationCount(build1)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/GradleExecuter.java
* * @return The result. */ ExecutionFailure runWithFailure(); /** * Starts executing the build asynchronously. * * @return the handle, never null. */ GradleHandle start(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 20.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go
} // Run starts the controller and blocks until context is killed. func (c *DynamicCertKeyPairContent) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.InfoS("Starting controller", "name", c.name) defer klog.InfoS("Shutting down controller", "name", c.name) // doesn't matter what workers say, only start one.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.9K bytes - Viewed (0) -
src/go/doc/comment/parse.go
forceIndent = end end-- } if start == end && forceIndent > start { i = start continue Spans } } // Span is either paragraph or heading. if end-start == 1 && isHeading(lines[start]) { kind = spanHeading } else if end-start == 1 && isOldHeading(lines[start], lines, start) { kind = spanOldHeading } else { kind = spanPara }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:03 UTC 2023 - 33.5K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
}) } } } for _, start := range cases { t.Run(fmt.Sprint(start), func(t *testing.T) { checkCycles(t, start, cases, nil) }) } } func alreadyHit(cur instance, chain []instance) bool { for _, cc := range chain { if cur == cc { return true } } return false } func checkCycles(t *testing.T, start instance, cases []instance, chain []instance) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/ServeDocs.java
import org.gradle.work.DisableCachingByDefault; import javax.inject.Inject; import java.util.Arrays; /** * Serves the given directory with a simple HTTP server. */ @DisableCachingByDefault(because = "This task starts a HTTP server and should not be cached.") public abstract class ServeDocs extends DefaultTask { @InputFiles @PathSensitive(PathSensitivity.RELATIVE) protected abstract DirectoryProperty getDocsDirectory();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 12:38:47 UTC 2024 - 2.9K bytes - Viewed (0) -
src/cmd/vendor/rsc.io/markdown/inline.go
d = 1 } del := p.Text[0] == '~' x := &Emph{Marker: p.Text[:d], Inner: append([]Inline(nil), dst[start.i+1:]...)} start.Text = start.Text[:len(start.Text)-d] p.Text = p.Text[d:] if start.Text == "" { dst = dst[:start.i] } else { dst = dst[:start.i+1] } trimStack() if del { dst = append(dst, (*Del)(x)) } else if d == 2 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 21.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/Daemon.java
return this.daemonRegistry; } /** * Starts the daemon, receiving connections asynchronously (i.e. returns immediately). * * @throws IllegalStateException if this daemon is already running, or has already been stopped. */ public void start() { LOGGER.info("start() called on daemon - {}", daemonContext); lifecycleLock.lock(); try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 12.9K bytes - Viewed (0) -
pkg/envoy/agent_test.go
ctx, cancel := context.WithCancel(context.Background()) start := func(_ <-chan error) error { return nil } cleanup := func() { cancel() } a := NewAgent(TestProxy{run: start, cleanup: cleanup}, 0, 0, "", 0, 0, 0, true) go func() { a.Run(ctx) }() <-ctx.Done() } func TestActiveConnections(t *testing.T) { cases := []struct { name string stats string expected int }{ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 19 20:22:09 UTC 2023 - 4.3K bytes - Viewed (0) -
src/cmd/compile/internal/liveness/intervals.go
} if i == 0 { continue } // check for badly ordered starts pst := is[i-1].st pen := is[i-1].en if pst >= st { return fmt.Errorf("range start not ordered %d:%d less than prev %d:%d", st, en, pst, pen) } // check end of last range against start of this range if pen > st { return fmt.Errorf("bad range elem %d:%d overlaps prev %d:%d", st, en,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 21:55:27 UTC 2024 - 10K bytes - Viewed (0)