- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 141 for MUX (1.27 sec)
-
staging/src/k8s.io/apiserver/pkg/server/routes/debugsocket.go
s.mux.HandleFunc("/debug/pprof/cmdline", pprof.Cmdline) s.mux.HandleFunc("/debug/pprof/profile", pprof.Profile) s.mux.HandleFunc("/debug/pprof/symbol", pprof.Symbol) s.mux.HandleFunc("/debug/pprof/trace", pprof.Trace) } // InstallDebugFlag installs debug flag endpoints in the socket. func (s *DebugSocket) InstallDebugFlag(flag string, handler func(http.ResponseWriter, *http.Request)) { f := DebugFlags{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 08 00:33:16 UTC 2022 - 2.2K bytes - Viewed (0) -
pkg/controller/util/selectors/bimultimap.go
func (m *BiMultimap) Exists(key Key) bool { m.mux.RLock() defer m.mux.RUnlock() _, exists := m.labeledObjects[key] return exists } // PutSelector inserts or updates an object with a selector. Associations // are created or updated based on the selector. func (m *BiMultimap) PutSelector(key Key, selector pkglabels.Selector) { m.mux.Lock() defer m.mux.Unlock() selectorKey := selectorKey{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 21:41:32 UTC 2023 - 9.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/instrumented_services_test.go
assert.NoError(t, err) defer l.Close() prometheusURL := "http://" + l.Addr().String() + "/metrics" mux := http.NewServeMux() handler := compbasemetrics.HandlerFor(gather, compbasemetrics.HandlerOpts{}) mux.Handle("/metrics", handler) server := &http.Server{ Addr: l.Addr().String(), Handler: mux, } go func() { server.Serve(l) }() recordOperation("create_container", time.Now())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go
defer timer.Stop() for { stopped := func() bool { pr.mux.Lock() defer pr.mux.Unlock() for pr.waiting == 0 && !pr.stopped { pr.cond.Wait() } return pr.stopped }() if stopped { return } select { case <-timer.C(): shouldRequest := func() bool { pr.mux.Lock() defer pr.mux.Unlock() return pr.waiting > 0 && !pr.stopped }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 09:56:38 UTC 2024 - 3K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_checkpoint.go
sc.mux.RLock() defer sc.mux.RUnlock() res, ok := sc.cache.GetCPUSet(podUID, containerName) return res, ok } // GetDefaultCPUSet returns default CPU set func (sc *stateCheckpoint) GetDefaultCPUSet() cpuset.CPUSet { sc.mux.RLock() defer sc.mux.RUnlock() return sc.cache.GetDefaultCPUSet() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 00:59:30 UTC 2023 - 7.9K bytes - Viewed (0) -
src/cmd/trace/main.go
{Type: traceviewer.ViewThread, Ranges: ranges}, })) // Catapult handlers. mux.Handle("/trace", traceviewer.TraceHandler()) mux.Handle("/jsontrace", JSONTraceHandler(parsed)) mux.Handle("/static/", traceviewer.StaticHandler()) // Goroutines handlers. mux.HandleFunc("/goroutines", GoroutinesHandlerFunc(parsed.summary.Goroutines)) mux.HandleFunc("/goroutine", GoroutineHandler(parsed.summary.Goroutines)) // MMU handler.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/routes/openapi.go
type OpenAPI struct { Config *common.Config V3Config *common.OpenAPIV3Config } // Install adds the SwaggerUI webservice to the given mux. func (oa OpenAPI) InstallV2(c *restful.Container, mux *mux.PathRecorderMux) (*handler.OpenAPIService, *spec.Swagger) { spec, err := builder2.BuildOpenAPISpecFromRoutes(restfuladapter.AdaptWebServices(c.RegisteredWebServices()), oa.Config) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 19:05:13 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/kubelet/config/mux_test.go
ctx, cancel := context.WithCancel(context.Background()) defer cancel() mux := newMux(nil) channelOne := mux.ChannelWithContext(ctx, "one") if channelOne != mux.ChannelWithContext(ctx, "one") { t.Error("Didn't get the same muxuration channel back with the same name") } channelTwo := mux.ChannelWithContext(ctx, "two") if channelOne == channelTwo {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 20:02:23 UTC 2024 - 2.5K bytes - Viewed (0) -
internal/grid/muxclient.go
fmt.Println("Client sending disconnect to mux", m.MuxID) } m.addErrorNonBlockingClose(errResp, context.Cause(m.ctx)) errState = true continue case <-pingTimer: if !m.doPing(errResp) { errState = true continue } case req, ok := <-requests: if !ok { // Done send EOF if debugPrint { fmt.Println("Client done, sending EOF to mux", m.MuxID) } msg := message{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/routes/index.go
type Index struct{} // Install adds the Index webservice to the given mux. func (i Index) Install(pathProvider ListedPathProvider, mux *mux.PathRecorderMux) { handler := IndexLister{StatusCode: http.StatusOK, PathProvider: pathProvider} mux.UnlistedHandle("/", handler) mux.UnlistedHandle("/index.html", handler) } // IndexLister lists the available indexes with the status code provided
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 20:21:45 UTC 2017 - 2.1K bytes - Viewed (0)