- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for error_handler_ (0.38 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/jvm/jvm-services/src/main/java/org/gradle/jvm/toolchain/internal/MavenToolchainsInstallationSupplier.java
import org.gradle.api.provider.ProviderFactory; import org.gradle.internal.xml.XmlFactories; import org.gradle.util.internal.MavenUtil; import org.w3c.dom.Node; import org.w3c.dom.NodeList; import org.xml.sax.ErrorHandler; import org.xml.sax.SAXException; import org.xml.sax.SAXParseException; import javax.inject.Inject; import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilderFactory;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 22:17:53 UTC 2024 - 6.5K bytes - Viewed (0) -
tests/test_ws_router.py
""" @websocket_middleware async def errorhandler(websocket: WebSocket, call_next): try: return await call_next() except Exception as e: await websocket.close(code=status.WS_1006_ABNORMAL_CLOSURE, reason=repr(e)) myapp = make_app(middleware=[Middleware(errorhandler)]) client = TestClient(myapp) with pytest.raises(WebSocketDisconnect) as e:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Jun 11 19:08:14 UTC 2023 - 7.5K 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) -
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) -
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) -
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) -
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) -
tensorflow/compiler/mlir/tf2xla/api/v1/compile_mlir_util.cc
mlir::StatusScopedDiagnosticHandler error_handler(module.getContext()); mlir::LogicalResult result = mlir::TF::InferShapeForFunction( main_func, arg_shapes_copy, producer_version); if (failed(result)) { return error_handler.Combine( errors::Internal("MLIR Shape refinement failed")); } return error_handler.ConsumeStatus(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 21 17:24:39 UTC 2024 - 45.3K bytes - Viewed (0)