- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for register_handler (2.11 sec)
-
src/cmd/cgo/internal/testsanitizers/testdata/tsan11.go
#cgo LDFLAGS: -g -fsanitize=thread #include <signal.h> #include <stdio.h> #include <stdlib.h> #include <string.h> static void raise_usr2(int signo) { raise(SIGUSR2); } static void register_handler(int signo) { struct sigaction sa; memset(&sa, 0, sizeof(sa)); sigemptyset(&sa.sa_mask); sa.sa_flags = SA_ONSTACK; sa.sa_handler = raise_usr2; if (sigaction(SIGUSR1, &sa, NULL) != 0) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 1.2K bytes - Viewed (0) -
src/cmd/cgo/internal/testsanitizers/testdata/tsan_shared.go
abort(); } } // Set up the signal handler in a high priority constructor, so // that it is installed before the Go code starts. static void register_handler(void) __attribute__ ((constructor (200))); static void register_handler() { struct sigaction sa; memset(&sa, 0, sizeof(sa)); sigemptyset(&sa.sa_mask); sa.sa_flags = SA_SIGINFO; sa.sa_sigaction = check_params;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/kube/multicluster/fake.go
// limitations under the License. package multicluster import ( "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/kube" ) type Fake struct { handlers []handler } func (f *Fake) registerHandler(h handler) { f.handlers = append(f.handlers, h) } func (f *Fake) Add(id cluster.ID, client kube.Client, stop chan struct{}) { for _, handler := range f.handlers { handler.clusterAdded(&Cluster{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 1.2K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
comp := &Component[T]{ constructor: constructor, clusters: make(map[cluster.ID]T), } c.registerHandler(comp) return comp } func (c *Controller) registerHandler(h handler) { // Intentionally no lock. The controller today requires that handlers are registered before execution and not in parallel. c.handlers = append(c.handlers, h) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
registerHandlers[*v1.Service](c, c.services, "Services", c.onServiceEvent, nil) c.endpoints = newEndpointSliceController(c) // This is for getting the node IPs of a selected set of nodes c.nodes = kclient.NewFiltered[*v1.Node](kubeClient, kclient.Filter{ObjectTransform: kubelib.StripNodeUnusedFields}) registerHandlers[*v1.Node](c, c.nodes, "Nodes", c.onNodeEvent, nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/tfrt_fallback/batch_function_fallback_benchmark_test.cc
CHECK(corert); auto fallback_op_handler = tensorflow::tfd::CreateKernelFallbackOpHandler( corert->get(), corert->get()->GetHostContext()->GetHostDeviceRef()); CHECK(fallback_op_handler); corert.get()->RegisterOpHandler("tfkernel", fallback_op_handler.get()); return std::move(corert.get()); } tfrt::RCArray<tfrt::AsyncValue> CreateTestArguments(const tfrt::Function* func,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Dec 08 08:08:48 UTC 2023 - 6.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go
ObjectFilter: ec.client.ObjectFilter(), }) // Register callbacks for events. registerHandlers(ec.Controller, ec.serviceExports, "ServiceExports", ec.onServiceExportEvent, nil) // Set the discoverability policy for the clusterset.local host.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.5K bytes - Viewed (0) -
internal/grid/README.md
From this connection individual requests can be made. Each handler, with optional subroutes can be registered with the manager using `Manager.RegisterXHandler(handlerID, handler, subroutes...)`. A `Handler()` function provides an HTTP handler, which should be hooked up to the appropriate route on the server.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
ObjectFilter: sic.client.ObjectFilter(), }) // Register callbacks for events. registerHandlers(sic.Controller, sic.serviceImports, "ServiceImports", sic.onServiceImportEvent, nil) sic.opts.MeshServiceController.AppendServiceHandlerForCluster(sic.Cluster(), sic.onServiceEvent) return sic }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
n.gatewayResourceClient = kclient.NewDelayedInformer[*v1beta1.Gateway](c.client, gvr.KubernetesGateway, kubetypes.StandardInformer, kubetypes.Filter{}) // conditionally register this handler registerHandlers(c, n.gatewayResourceClient, "Gateways", n.handleGatewayResource, nil) } return n } // setNetworkFromNamespace sets network got from system namespace, returns whether it has changed
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0)