Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ftpserver (0.16 sec)

  1. cmd/ftp-server.go

    		tlsPublicCert = getPublicCertFile()
    	}
    
    	tls := tlsPrivateKey != "" && tlsPublicCert != ""
    
    	name := "MinIO FTP Server"
    	if tls {
    		name = "MinIO FTP(Secure) Server"
    	}
    
    	ftpServer, err := ftp.NewServer(&ftp.Options{
    		Name:           name,
    		WelcomeMessage: fmt.Sprintf("Welcome to '%s' FTP Server Version='%s' License='%s'", MinioStoreName, MinioLicense, Version),
    		Driver:         NewFTPDriver(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 09 03:07:08 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/cni-watcher_test.go

    		util.GetPodIPsIfPresent(pod),
    		valid.Netns,
    	).Return(nil)
    
    	dpServer := getFakeDP(fs, client.Kube())
    
    	handlers := setupHandlers(ctx, client, dpServer, "istio-system")
    
    	// We are not going to start the server, so the sockpath is irrelevant
    	pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer)
    
    	// label the namespace
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  3. cmd/signals.go

    		// before stopping s3 operations
    
    		// send signal to various go-routines that they need to quit.
    		cancelGlobalContext()
    
    		if httpServer := newHTTPServerFn(); httpServer != nil {
    			if err := httpServer.Shutdown(); err != nil && !errors.Is(err, http.ErrServerClosed) {
    				shutdownLogIf(context.Background(), err)
    			}
    		}
    
    		if objAPI := newObjectLayerFn(); objAPI != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. cmd/background-heal-ops.go

    				return
    			}
    			time.Sleep(waitTick)
    			tmpMaxWait -= waitTick
    		}
    		if tmpMaxWait <= 0 {
    			return
    		}
    	}
    }
    
    func currentHTTPIO() int {
    	httpServer := newHTTPServerFn()
    	if httpServer == nil {
    		return 0
    	}
    
    	return httpServer.GetRequestCount() - activeListeners()
    }
    
    func waitForLowHTTPReq() {
    	maxIO, maxWait, _ := globalHealConfig.Clone()
    	waitForLowIO(maxIO, maxWait, currentHTTPIO)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. internal/http/server.go

    	return srv
    }
    
    // NewServer - creates new HTTP server using given arguments.
    func NewServer(addrs []string) *Server {
    	httpServer := &Server{
    		Addrs: addrs,
    	}
    	// This is not configurable for now.
    	httpServer.MaxHeaderBytes = DefaultMaxHeaderBytes
    	return httpServer
    }
    
    // SetMinIOVersion -- MinIO version from the main package is set here
    func SetMinIOVersion(version string) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. tensorflow/c/c_api_internal.h

    #endif  // !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
      bool update_docs_called TF_GUARDED_BY(lock);
      tensorflow::mutex lock;
    };
    
    #if !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
    struct TF_Server {
      TF_Server(std::unique_ptr<tensorflow::ServerInterface> server);
    
      const tensorflow::string target;
      std::unique_ptr<tensorflow::ServerInterface> server;
    };
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat May 13 00:49:12 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  7. build-logic/documentation/src/main/groovy/gradlebuild/docs/ServeDocs.java

                JavaExecHandleBuilder builder = getExecActionFactory().newJavaExec();
                builder.setExecutable(getJavaLauncher().get().getExecutablePath().getAsFile());
                builder.getMainModule().set("jdk.httpserver");
                builder.setStandardOutput(System.out);
                builder.setErrorOutput(System.err);
                builder.setArgs(Arrays.asList("-p", getPort().get(), "-d", getDocsDirectory().get().getAsFile().getAbsolutePath()));
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Apr 18 12:38:47 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top