- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 39 for errorHandler (0.38 sec)
-
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) -
tensorflow/compiler/mlir/tensorflow/utils/mlprogram_util.cc
"tf-lower-to-mlprogram-and-hlo", "Lower TF to ml_program + mhlo", [](mlir::OpPassManager& pm, llvm::StringRef options, llvm::function_ref<mlir::LogicalResult(const llvm::Twine&)> errorHandler) { tensorflow::PopulateLowerToMlProgramAndHloPipeline(pm); return mlir::success(); }, [](llvm::function_ref<void(const mlir::detail::PassOptions&)>) {}); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 22 22:13:50 UTC 2024 - 1.6K bytes - Viewed (0) -
pilot/pkg/util/informermetric/informerutil.go
"Total number of errorMetric syncing controllers.", ) mu sync.RWMutex handlers = map[cluster.ID]cache.WatchErrorHandler{} ) // ErrorHandlerForCluster fetches or creates an ErrorHandler that emits a metric // and logs when a watch error occurs. For use with SetWatchErrorHandler on SharedInformer. func ErrorHandlerForCluster(clusterID cluster.ID) cache.WatchErrorHandler { mu.RLock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K 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) -
staging/src/k8s.io/apimachinery/pkg/util/runtime/runtime_test.go
panic("test") }() if result != "test" { t.Errorf("did not receive custom handler") } } func TestCustomHandleError(t *testing.T) { old := ErrorHandlers defer func() { ErrorHandlers = old }() var result error ErrorHandlers = []ErrorHandler{ func(_ context.Context, err error, msg string, keysAndValues ...interface{}) { result = err }, } err := fmt.Errorf("test") HandleError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 4.5K 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)