Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 61 for listener (0.08 sec)

  1. internal/http/listener.go

    		return
    	}
    
    	listener = &httpListener{
    		listeners: listeners,
    		acceptCh:  make(chan acceptResult, len(listeners)),
    		opts:      opts,
    	}
    	listener.ctx, listener.ctxCanceler = context.WithCancel(ctx)
    	if opts.Trace != nil {
    		opts.Trace(fmt.Sprint("opening ", len(listener.listeners), " listeners"))
    	}
    	listener.start()
    
    	return
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. internal/grid/debug.go

    		listeners = append(listeners, l)
    	}
    	return
    }
    
    func startHTTPServer(listener net.Listener, handler http.Handler) (server *httptest.Server) {
    	server = httptest.NewUnstartedServer(handler)
    	server.Config.Addr = listener.Addr().String()
    	server.Listener = listener
    	server.Start()
    	return server
    }
    
    func dummyRequestValidate(r *http.Request) error {
    	return nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

            client.deletePits(deletePITRequest, listener);
        }
    
        @Override
        public void getAllPits(final GetAllPitNodesRequest getAllPitNodesRequest, final ActionListener<GetAllPitNodesResponse> listener) {
            client.getAllPits(getAllPitNodesRequest, listener);
        }
    
        @Override
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sun Oct 20 02:08:03 UTC 2024
    - 86.1K bytes
    - Viewed (0)
  4. internal/http/server.go

    	// Create new HTTP listener.
    	var listener *httpListener
    	listener, listenErrs := newHTTPListener(
    		listenCtx,
    		srv.Addrs,
    		srv.TCPOptions,
    	)
    
    	var interfaceFound bool
    	for i := range listenErrs {
    		if listenErrs[i] != nil {
    			listenErrCallback(srv.Addrs[i], listenErrs[i])
    		} else {
    			interfaceFound = true
    		}
    	}
    	if !interfaceFound {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. internal/http/listener_test.go

    	}
    
    	for testIdx, testCase := range testCases {
    		listener, listenErrs := newHTTPListener(context.Background(),
    			testCase.serverAddrs,
    			TCPOptions{},
    		)
    		for i, expectedListenErr := range testCase.expectedListenErrs {
    			if !expectedListenErr {
    				if listenErrs[i] != nil {
    					t.Fatalf("Test %d:, listenErrs[%d] error: expected = <nil>, got = %v", testIdx+1, i, listenErrs[i])
    				}
    			} else if listenErrs[i] == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. internal/grid/connection_test.go

    		}
    		t.Logf("host %q should connect to %d hosts", hosts[x], should)
    	}
    }
    
    func startServer(t testing.TB, listener net.Listener, handler http.Handler) (server *httptest.Server) {
    	t.Helper()
    	server = httptest.NewUnstartedServer(handler)
    	server.Config.Addr = listener.Addr().String()
    	server.Listener = listener
    	server.Start()
    	// t.Cleanup(server.Close)
    	t.Log("Started server on", server.Config.Addr, "URL:", server.URL)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 08 21:44:00 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  7. src/main/webapp/WEB-INF/web.xml

      <!--                                                                  Servlet Listener -->
      <!--                                                                  ================ -->
      <listener>
        <listener-class>org.apache.commons.fileupload2.jakarta.servlet6.JakartaFileCleaner</listener-class>
      </listener>
    
      <!-- ================================================================================= -->
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Mon Jul 29 02:54:01 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/cni-watcher.go

    			// If the cniListener exits, at least we should record an error log
    			log.Errorf("CNI listener server exiting unexpectedly: %v", err)
    		}
    	}()
    
    	context.AfterFunc(s.ctx, func() {
    		if err := s.cniListenServer.Close(); err != nil {
    			log.Errorf("CNI listen server terminated with error: %v", err)
    		} else {
    			log.Debug("CNI listen server terminated")
    		}
    	})
    	return nil
    }
    
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/ztunnelserver.go

    	if err != nil {
    		return nil, fmt.Errorf("failed to listen unix: %w", err)
    	}
    
    	return &ztunnelServer{
    		listener: l,
    		conns: &connMgr{
    			connectionSet: map[*ZtunnelConnection]struct{}{},
    		},
    		pods: pods,
    	}, nil
    }
    
    func (z *ztunnelServer) Close() error {
    	return z.listener.Close()
    }
    
    func (z *ztunnelServer) Run(ctx context.Context) {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  10. istioctl/pkg/proxyconfig/proxyconfig.go

      # Retrieve listener summary for listeners with port 9080.
      istioctl proxy-config listeners <pod-name[.namespace]> --port 9080
    
      # Retrieve full listener dump for HTTP listeners with a wildcard address (0.0.0.0).
      istioctl proxy-config listeners <pod-name[.namespace]> --type HTTP --address 0.0.0.0 -o json
    
      # Retrieve listener summary without using Kubernetes API
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
Back to top