Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 46 of 46 for Cook (1.44 sec)

  1. internal/logger/logonce.go

    func unwrapErrs(err error) (leafErr error) {
    	uerr := errors.Unwrap(err)
    	depth := 1
    	for uerr != nil {
    		// Save the current `uerr`
    		leafErr = uerr
    		// continue to look for leaf errors underneath
    		uerr = errors.Unwrap(leafErr)
    		depth++
    		if depth == unwrapErrsDepth {
    			// If we have reached enough depth we
    			// do not further recurse down, this
    			// is done to avoid any unnecessary
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  2. cmd/bucket-handlers.go

    	if err := objectAPI.MakeBucket(ctx, bucket, opts); err != nil {
    		if _, ok := err.(BucketExists); ok {
    			// Though bucket exists locally, we send the site-replication
    			// hook to ensure all sites have this bucket. If the hook
    			// succeeds, the client will still receive a bucket exists
    			// message.
    			globalSiteReplicationSys.MakeBucketHook(ctx, bucket, opts)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  3. cmd/server-startup-msg.go

    	var mcMessage string
    	onlineDisks, offlineDisks := getOnlineOfflineDisksStats(storageInfo.Disks)
    	if storageInfo.Backend.Type == madmin.Erasure {
    		if offlineDisks.Sum() > 0 {
    			mcMessage = "Use `mc admin info` to look for latest server/drive info\n"
    		}
    
    		diskInfo := fmt.Sprintf(" %d Online, %d Offline. ", onlineDisks.Sum(), offlineDisks.Sum())
    		msg += color.Blue("Status:") + fmt.Sprintf(getFormatStr(len(diskInfo), 8), diskInfo)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 6.8K bytes
    - Viewed (0)
  4. internal/grid/muxserver.go

    	start := time.Now()
    	defer func() {
    		if debugPrint {
    			fmt.Println("Mux", m.ID, "Handler took", time.Since(start).Round(time.Millisecond))
    		}
    		if r := recover(); r != nil {
    			gridLogIf(ctx, fmt.Errorf("grid handler (%v) panic: %v", msg.Handler, r))
    			err := RemoteErr(fmt.Sprintf("handler panic: %v", r))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  5. cmd/ftp-server-driver.go

    			// mapping.
    			updatedAt, err := globalIAMSys.SetTempUser(context.Background(), cred.AccessKey, cred, "")
    			if err != nil {
    				return nil, err
    			}
    
    			// Call hook for site replication.
    			replLogIf(context.Background(), globalSiteReplicationSys.IAMChangeHook(context.Background(), madmin.SRIAMItem{
    				Type: madmin.SRIAMItemSTSAcc,
    				STSCredential: &madmin.SRSTSCredential{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  6. cmd/utils.go

    		ObjectName:   object,
    		VersionID:    strings.TrimSpace(r.Form.Get(xhttp.VersionID)),
    	}
    
    	return logger.SetReqInfo(r.Context(), reqInfo)
    }
    
    // Used for registering with rest handlers (have a look at registerStorageRESTHandlers for usage example)
    // If it is passed ["aaaa", "bbbb"], it returns ["aaaa", "{aaaa:.*}", "bbbb", "{bbbb:.*}"]
    func restQueries(keys ...string) []string {
    	var accumulator []string
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
Back to top