Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 1,262 for server1 (0.08 sec)

  1. cni/pkg/nodeagent/healthServer_test.go

    	installReady, watchReady := initRouter(router)
    
    	assert.Equal(t, installReady.Load(), false)
    	assert.Equal(t, watchReady.Load(), false)
    
    	server := httptest.NewServer(router)
    	defer server.Close()
    
    	makeReq(t, server.URL, constants.LivenessEndpoint, http.StatusOK)
    	makeReq(t, server.URL, constants.ReadinessEndpoint, http.StatusServiceUnavailable)
    
    	installReady.Store(true)
    	watchReady.Store(true)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 2K bytes
    - Viewed (0)
  2. cni/pkg/plugin/cnieventclient_test.go

    		Gateway: fakeGW,
    	}
    )
    
    func TestPushCNIAddEventSucceed(t *testing.T) {
    	// Fake out a test HTTP server and use that instead of a real HTTP server over gRPC to validate  req/resp flows
    	testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) {
    		res.WriteHeader(http.StatusOK)
    		res.Write([]byte("server happy"))
    	}))
    	defer func() { testServer.Close() }()
    
    	cniC := fakeCNIEventClient(testServer.URL)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/cni-watcher.go

    		dataplane: dataplane,
    		cniListenServer: &http.Server{
    			Handler: mux,
    		},
    		cniListenServerCancel: cancel,
    		sockAddress:           pluginSocket,
    		ctx:                   ctx,
    	}
    
    	mux.HandleFunc(pconstants.CNIAddEventPath, s.handleAddEvent)
    	return s
    }
    
    func (s *CniPluginServer) Stop() {
    	s.cniListenServerCancel()
    }
    
    // Start starts up a UDS server which receives events from the CNI chain plugin.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. buildscripts/disable-root.sh

    rm -rf /tmp/multisitea/
    rm -rf /tmp/multisiteb/
    
    echo "Setup site-replication and then disable root credentials"
    
    minio server --address 127.0.0.1:9001 "http://127.0.0.1:9001/tmp/multisitea/data/disterasure/xl{1...4}" \
    	"http://127.0.0.1:9002/tmp/multisitea/data/disterasure/xl{5...8}" >/tmp/sitea_1.log 2>&1 &
    minio server --address 127.0.0.1:9002 "http://127.0.0.1:9001/tmp/multisitea/data/disterasure/xl{1...4}" \
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/RequestWithPath.java

    
        /**
         * @param path
         */
        void setPath ( String path );
    
    
        /**
         * 
         * @param domain
         * @param server
         * @param fullPath
         */
        void setFullUNCPath ( String domain, String server, String fullPath );
    
    
        /**
         * @param resolve
         * 
         */
        void setResolveInDfs ( boolean resolve );
    
    
        /**
         * 
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.7K bytes
    - Viewed (0)
  6. docs/en/docs/deployment/index.md

    This is in contrast to the **development** stages, where you are constantly changing the code, breaking it and fixing it, stopping and restarting the development server, etc.
    
    ## Deployment Strategies
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Jan 11 16:31:18 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  7. istioctl/pkg/multicluster/remote_secret.go

    	}
    	server := restCfg.Host
    	if strings.Contains(server, "127.0.0.1") || strings.Contains(server, "localhost") {
    		return server, fmt.Errorf(
    			"server in Kubeconfig is %s. This is likely not reachable from inside the cluster, "+
    				"if you're using Kubernetes in Docker, pass --server with the container IP for the API Server",
    			server), nil
    	}
    	return server, nil, nil
    }
    
    const (
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/CacheCorruptionTest.kt

      private val cookieManager = CookieManager()
      private lateinit var server: MockWebServer
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
    
        platform.assumeNotOpenJSSE()
        server.protocolNegotiationEnabled = false
        val loggingFileSystem = LoggingFilesystem(fileSystem)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpAuthentication.java

        private String server;
    
        private int port;
    
        private String username;
    
        private String password;
    
        public String getServer() {
            return server;
        }
    
        public void setServer(final String server) {
            this.server = server;
        }
    
        public int getPort() {
            return port;
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:40:57 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  10. src/main/java/jcifs/http/NetworkExplorer.java

            Address dc;
            String msg, pathInfo, server = null;
            boolean offerBasic, possibleWorkgroup = true;
            NtlmPasswordAuthentication ntlm = null;
            HttpSession ssn = req.getSession(false);
    
            if ( ( pathInfo = req.getPathInfo() ) != null ) {
                int i;
                server = parseServerAndShare(pathInfo);
                if ( server != null && ( i = server.indexOf('/') ) > 0 ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 21.3K bytes
    - Viewed (0)
Back to top