Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for Kasten (0.15 sec)

  1. internal/http/listener.go

    	listenCfg := net.ListenConfig{
    		Control: setTCPParametersFn(opts),
    	}
    
    	for i, serverAddr := range serverAddrs {
    		l, e := listenCfg.Listen(ctx, "tcp", serverAddr)
    		if e != nil {
    			if opts.Trace != nil {
    				opts.Trace(fmt.Sprint("listenCfg.Listen: ", e))
    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		if opts.Trace != nil {
    			opts.Trace(fmt.Sprint("adding listener to ", l.Addr()))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  2. cmd/sftp-server.go

    		SSHConfig:            sshConfig,
    		HandleSFTPSession:    handleSFTPSession,
    	})
    	if err != nil {
    		logger.Fatal(err, "Unable to start SFTP Server")
    	}
    
    	err = sftpServer.Listen()
    	if err != nil {
    		logger.Fatal(err, "SFTP Server had an unrecoverable error while accepting connections")
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  3. cmd/metacache-entries.go

    		return metaCacheEntriesSorted{o: m}
    	}
    	sort.Slice(m, m.less)
    	return metaCacheEntriesSorted{o: m}
    }
    
    // isSorted returns whether the objects are sorted.
    // This is usually orders of magnitude faster than actually sorting.
    func (m metaCacheEntries) isSorted() bool {
    	return sort.SliceIsSorted(m, m.less)
    }
    
    // shallowClone will create a shallow clone of the array objects,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    	queryValue := url.Values{}
    	queryValue.Set("uploadId", uploadID)
    	return makeTestTargetURL(endPoint, bucketName, objectName, queryValue)
    }
    
    // return URL for listen bucket notification.
    func getListenNotificationURL(endPoint, bucketName string, prefixes, suffixes, events []string) string {
    	queryValue := url.Values{}
    
    	queryValue["prefix"] = prefixes
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  5. internal/logger/logrotate.go

    	w.pw.CloseWithError(nil)
    
    	if w.f != nil {
    		if err := w.closeCurrentFile(); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    var stdErrEnc = json.NewEncoder(os.Stderr)
    
    func (w *Writer) listen() {
    	for {
    		var r io.Reader = w.pr
    		if w.opts.MaximumFileSize > 0 {
    			r = io.LimitReader(w.pr, w.opts.MaximumFileSize)
    		}
    		if _, err := io.Copy(w.f, r); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 11:38:40 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  6. istioctl/pkg/dashboard/dashboard.go

    			cmd.HelpFunc()(cmd, args)
    			return nil
    		},
    	}
    
    	dashboardCmd.PersistentFlags().IntVarP(&listenPort, "port", "p", 0, "Local port to listen to")
    	dashboardCmd.PersistentFlags().StringVar(&bindAddress, "address", "localhost",
    		"Address to listen on. Only accepts IP address or localhost as a value. "+
    			"When localhost is supplied, istioctl will try to bind on both 127.0.0.1 and ::1 "+
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 20.5K bytes
    - Viewed (0)
  7. cmd/common-main.go

    			fmt.Println("You need to open cmd.exe/PowerShell and run it from the command line")
    			fmt.Println("Refer to the docs here on how to run it as a Windows Service https://github.com/minio/minio-service/tree/master/windows")
    			fmt.Println("Press the Enter Key to Exit")
    			fmt.Scanln()
    			os.Exit(1)
    		}
    	}
    
    	logger.Init(GOPATH, GOROOT)
    	logger.RegisterError(config.FmtError)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  8. cmd/tier.go

    		return NewPutObjReader(hr), &ObjectOptions{MaxParity: true}, nil
    	}
    
    	// Note: Local variables with names ek, oek, etc are named inline with
    	// acronyms defined here -
    	// https://github.com/minio/minio/blob/master/docs/security/README.md#acronyms
    
    	// Encrypt json encoded tier configurations
    	metadata := make(map[string]string)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    		}
    		if dataDir != "" {
    			versionID := fi.VersionID
    			if versionID == "" {
    				versionID = nullVersionID
    			}
    
    			// PR #11758 used DataDir, preserve it
    			// for users who might have used master
    			// branch
    			xlMeta.data.remove(versionID, dataDir)
    
    			// We need to attempt delete "dataDir" on the disk
    			// due to a CopyObject() bug where it might have
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  10. cmd/update.go

    }
    
    // IsDocker - returns if the environment minio is running in docker or
    // not. The check is a simple file existence check.
    //
    // https://github.com/moby/moby/blob/master/daemon/initlayer/setup_unix.go
    // https://github.com/containers/podman/blob/master/libpod/runtime.go
    //
    //	"/.dockerenv":        "file",
    //	"/run/.containerenv": "file",
    func IsDocker() bool {
    	var err error
    	for _, envfile := range []string{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
Back to top