Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for errorHandler (0.2 sec)

  1. pkg/util/filesystem/watcher.go

    	return w.watcher.Add(path)
    }
    
    func (w *fsnotifyWatcher) Init(eventHandler FSEventHandler, errorHandler FSErrorHandler) error {
    	var err error
    	w.watcher, err = fsnotify.NewWatcher()
    	if err != nil {
    		return err
    	}
    
    	w.eventHandler = eventHandler
    	w.errorHandler = errorHandler
    	return nil
    }
    
    func (w *fsnotifyWatcher) Run() {
    	go func() {
    		defer w.watcher.Close()
    		for {
    			select {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 23:09:15 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. pilot/pkg/xds/debug_test.go

    	attempts := 5
    	for i := 0; i < attempts; i++ {
    		gotStatus := getSyncStatus(t, s)
    		var errorHandler func(string, ...any)
    		if i == attempts-1 {
    			errorHandler = t.Errorf
    		} else {
    			errorHandler = t.Logf
    		}
    		for _, ss := range gotStatus {
    			if ss.ProxyID == nodeID {
    				if ss.ProxyVersion == "" {
    					errorHandler("ProxyVersion should always be set for %v", nodeID)
    				}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  3. pkg/bootstrap/platform/aws_test.go

    	cases := []struct {
    		name     string
    		handlers map[string]handlerFunc
    		want     *core.Locality
    	}{
    		{
    			"error",
    			map[string]handlerFunc{"/placement/region": errorHandler, "/placement/availability-zone": errorHandler},
    			&core.Locality{},
    		},
    		{
    			"locality",
    			map[string]handlerFunc{"/placement/region": regionHandler, "/placement/availability-zone": zoneHandler},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 18 13:10:06 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  4. src/cmd/compile/internal/syntax/syntax.go

    	Msg string
    }
    
    func (err Error) Error() string {
    	return fmt.Sprintf("%s: %s", err.Pos, err.Msg)
    }
    
    var _ error = Error{} // verify that Error implements error
    
    // An ErrorHandler is called for each error encountered reading a .go file.
    type ErrorHandler func(err error)
    
    // A Pragma value augments a package, import, const, func, type, or var declaration.
    // Its meaning is entirely up to the PragmaHandler,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 01 18:18:07 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  5. internal/handlers/forwarder.go

    			f.modifyRequest(req, inReq.URL)
    		},
    		BufferPool:    newBufPool(128 << 10),
    		Transport:     f.RoundTripper,
    		FlushInterval: defaultFlushInterval,
    		ErrorHandler:  f.customErrHandler,
    	}
    
    	if f.ErrorHandler != nil {
    		revproxy.ErrorHandler = f.ErrorHandler
    	}
    
    	revproxy.ServeHTTP(w, outReq)
    }
    
    // customErrHandler is originally implemented to avoid having the following error
    //
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  6. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/VisitableURLClassLoader.java

            private final TransformReplacer replacer;
            private final TransformErrorHandler errorHandler;
    
            public InstrumentingVisitableURLClassLoader(String name, ClassLoader parent, TransformedClassPath classPath) {
                super(name, parent, classPath);
                replacer = new TransformReplacer(classPath);
                errorHandler = new TransformErrorHandler(name);
            }
    
            @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top