- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for errorHandler (0.44 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHub.java
/** * @param errorHandler Notified when some async activity fails. Must be thread-safe. */ public MessageHub(String displayName, ExecutorFactory executorFactory, Action<? super Throwable> errorHandler) { this.displayName = displayName; this.errorHandler = errorHandler; workers = executorFactory.create(displayName + " workers"); } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 16.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/groovy/scripts/internal/DefaultScriptCompilationHandler.java
private final TransformErrorHandler errorHandler; InstrumentingScriptClassLoader(ScriptSource scriptSource, ClassLoader parent, TransformedClassPath classPath, HashCode implementationHash) { super(scriptSource, parent, classPath, implementationHash); replacer = new TransformReplacer(classPath); errorHandler = new TransformErrorHandler(getName()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 20.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
import java.util.concurrent.LinkedBlockingQueue @Timeout(60) class MessageHubTest extends ConcurrentSpec { final Action<Throwable> errorHandler = Mock() final MessageHub hub = new MessageHub("<hub>", executorFactory, errorHandler) def cleanup() { hub.stop() } def "creates a separate dispatcher for each outgoing type"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy.go
// If the backend is unreachable, the optional ErrorHandler is // called without any call to ModifyResponse. // // If ModifyResponse returns an error, ErrorHandler is called // with its error value. If ErrorHandler is nil, its default // implementation is used. ModifyResponse func(*http.Response) error // ErrorHandler is an optional function that handles errors
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 23:37:42 UTC 2024 - 24.9K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
}) writeJSON(w, configs, req) } // SidecarScope debugging func (s *DiscoveryServer) sidecarz(w http.ResponseWriter, req *http.Request) { proxyID, con := s.getDebugConnection(req) if con == nil { s.errorHandler(w, proxyID, con) return } writeJSON(w, con.proxy.SidecarScope, req) } // Resource debugging. func (s *DiscoveryServer) resourcez(w http.ResponseWriter, req *http.Request) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/runtime/runtime.go
} } // ErrorHandlers is a list of functions which will be invoked when a nonreturnable // error occurs. // TODO(lavalamp): for testability, this and the below HandleError function // should be packaged up into a testable and reusable object. var ErrorHandlers = []ErrorHandler{ logError, func(_ context.Context, _ error, _ string, _ ...interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 9.9K bytes - Viewed (0) -
subprojects/diagnostics/src/main/java/org/gradle/api/tasks/diagnostics/DependencyInsightReportTask.java
// a value of `configuration.getAttributes()`. // TODO:configuration-cache find a way to clean up this #23732 private Provider<AttributeContainer> zConfigurationAttributes; private ResolutionErrorRenderer errorHandler; private String configurationName; private String configurationDescription; /** * The root component of the dependency graph to be inspected. * * @since 7.5 */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:29:40 UTC 2024 - 32.3K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/branches.go
// - bad labeled breaks and continues // - invalid, unused, duplicate, and missing labels // - gotos jumping over variable declarations and into blocks func checkBranches(body *BlockStmt, errh ErrorHandler) { if body == nil { return } // scope of all labels in this body ls := &labelScope{errh: errh} fwdGotos := ls.blockBranches(nil, targets{}, nil, body.Pos(), body.List)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Jun 26 00:21:29 UTC 2022 - 9.8K bytes - Viewed (0) -
src/go/scanner/scanner.go
"go/token" "path/filepath" "strconv" "unicode" "unicode/utf8" ) // An ErrorHandler may be provided to [Scanner.Init]. If a syntax error is // encountered and a handler was installed, the handler is called with a // position and an error message. The position points to the beginning of // the offending token. type ErrorHandler func(pos token.Position, msg string) // A Scanner holds the scanner's internal state while processing
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:03 UTC 2023 - 24.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/request_deadline_test.go
t.Run(test.name, func(t *testing.T) { var ( errorHandlerCallCountGot int rwGot http.ResponseWriter requestGot *http.Request ) errorHandler := http.HandlerFunc(func(rw http.ResponseWriter, req *http.Request) { http.Error(rw, "error serving request", http.StatusBadRequest) errorHandlerCallCountGot++ requestGot = req rwGot = rw })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 14 23:04:34 UTC 2022 - 16.7K bytes - Viewed (0)