- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for TimeoutHandler (0.21 sec)
-
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/timeout/TimeoutHandler.java
import javax.annotation.Nullable; import java.time.Duration; /** * Manages timeouts for threads, interrupting them if the timeout is exceeded. */ public interface TimeoutHandler extends Stoppable { /** * Starts a timeout for the given thread. The thread is interrupted if the given timeout is exceeded.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:46:15 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/steps/TimeoutStep.java
public TimeoutStep( TimeoutHandler timeoutHandler, CurrentBuildOperationRef currentBuildOperationRef, Step<? super C, ? extends R> delegate ) { this.timeoutHandler = timeoutHandler; this.currentBuildOperationRef = currentBuildOperationRef; this.delegate = delegate; } @Override public R execute(UnitOfWork work, C context) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:33 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/core-execution/execution/src/test/groovy/org/gradle/internal/execution/steps/TimeoutStepTest.groovy
import org.gradle.internal.execution.timeout.TimeoutHandler import org.gradle.internal.operations.CurrentBuildOperationRef import org.gradle.internal.operations.DefaultBuildOperationRef import org.gradle.internal.operations.OperationIdentifier import java.time.Duration import java.time.temporal.ChronoUnit class TimeoutStepTest extends StepSpec<Context> { def timeoutHandler = Mock(TimeoutHandler)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:46:15 UTC 2023 - 3.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/ExecutionGradleServices.java
OutputSnapshotter outputSnapshotter, OverlappingOutputDetector overlappingOutputDetector, StartParameter startParameter, TimeoutHandler timeoutHandler, ValidateStep.ValidationWarningRecorder validationWarningRecorder, VirtualFileSystem virtualFileSystem ) { UniqueId buildId = buildInvocationScopeId.getId();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 11.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
// a timeout happens. func WithTimeout(h http.Handler, timeoutFunc timeoutFunc) http.Handler { return &timeoutHandler{h, timeoutFunc} } type timeoutHandler struct { handler http.Handler timeout timeoutFunc } func (t *timeoutHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { r, longRunning, postTimeoutFn, err := t.timeout(r) if longRunning { t.handler.ServeHTTP(w, r)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/timeout/impl/DefaultTimeoutHandler.java
import org.gradle.internal.concurrent.ManagedScheduledExecutor; import org.gradle.internal.concurrent.Stoppable; import org.gradle.internal.execution.timeout.Timeout; import org.gradle.internal.execution.timeout.TimeoutHandler; import org.gradle.internal.operations.BuildOperationRef; import org.gradle.internal.operations.CurrentBuildOperationRef; import org.gradle.internal.time.CountdownTimer; import org.gradle.internal.time.Time;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:46:15 UTC 2023 - 7.3K bytes - Viewed (0) -
src/net/http/main_test.go
var bad string badSubstring := map[string]string{ ").readLoop(": "a Transport", ").writeLoop(": "a Transport", "created by net/http/httptest.(*Server).Start": "an httptest.Server", "timeoutHandler": "a TimeoutHandler", "net.(*netFD).connect(": "a timing out dial", ").noteClientGone(": "a closenotifier sender", } var stacks string for i := 0; i < 2500; i++ { bad = ""
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 22:49:46 UTC 2024 - 4.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/DependencyManagementBuildScopeServices.java
FileSystemAccess fileSystemAccess, ListenerManager listenerManager, ImmutableWorkspaceMetadataStore immutableWorkspaceMetadataStore, OutputSnapshotter outputSnapshotter, TimeoutHandler timeoutHandler, ValidateStep.ValidationWarningRecorder validationWarningRecorder, VirtualFileSystem virtualFileSystem ) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 28.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/GradleUserHomeScopeServices.java
import org.gradle.internal.concurrent.ExecutorFactory; import org.gradle.internal.event.ListenerManager; import org.gradle.internal.event.ScopedListenerManager; import org.gradle.internal.execution.timeout.TimeoutHandler; import org.gradle.internal.execution.timeout.impl.DefaultTimeoutHandler; import org.gradle.internal.file.FileAccessTimeJournal; import org.gradle.internal.hash.ClassLoaderHierarchyHasher;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 13.8K bytes - Viewed (0) -
src/net/http/export_test.go
t.Cleanup(func() { testHookProxyConnectTimeout = orig }) testHookProxyConnectTimeout = f } func NewTestTimeoutHandler(handler Handler, ctx context.Context) Handler { return &timeoutHandler{ handler: handler, testContext: ctx, // (no body) } } func ResetCachedEnvironment() { resetProxyConfig() } func (t *Transport) NumPendingRequestsForTesting() int {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 8.7K bytes - Viewed (0)