- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for ftpserver (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)