- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 2,373 for startm (0.42 sec)
-
internal/http/listener.go
ctx context.Context ctxCanceler context.CancelFunc } // start - starts separate goroutine for each TCP listener. A valid new connection is passed to httpListener.acceptCh. func (listener *httpListener) start() { // Closure to send acceptResult to acceptCh. // It returns true if the result is sent else false if returns when doneCh is closed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/logging/comparison/DiffUtils.java
break; } // Calculate the start line index of the current block in fullDiff start = max(0, next - contextSize); // Record the start line number in original and revised file of the current block startLineOrigin = lineNumOrigin - (next - start - 1); startLineRevised = lineNumRevised - (next - start - 1);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 9.4K bytes - Viewed (0) -
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) -
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) -
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)