Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for plating (0.15 sec)

  1. cmd/metacache-server-pool.go

    				go func(meta metacache) {
    					// Continuously update while we wait.
    					t := time.NewTicker(metacacheMaxClientWait / 10)
    					defer t.Stop()
    					select {
    					case <-ctx.Done():
    						// Request is done, stop updating.
    						return
    					case <-t.C:
    						meta.lastHandout = time.Now()
    						meta, _ = rpc.UpdateMetacacheListing(ctx, meta)
    					}
    				}(*c)
    			}
    		}
    	}
    
    	if o.ID != "" && !o.Transient {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  2. cmd/iam-store.go

    		delete(cache.iamGroupsMap, group)
    		cache.iamGroupPolicyMap.Delete(group)
    
    		cache.updatedAt = time.Now()
    		return nil
    	}
    
    	gi := cache.iamGroupsMap[group]
    
    	// Updating the group memberships cache happens in two steps:
    	//
    	// 1. Remove the group from each user's list of memberships.
    	// 2. Add the group to each member's list of memberships.
    	//
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  3. internal/s3select/sql/funceval.go

    		return x, nil
    	case string:
    		// Parse as number, truncate floating point if
    		// needed.
    		// String might contain trimming spaces, which
    		// needs to be trimmed.
    		res, ok := strToInt(strings.TrimSpace(x))
    		if !ok {
    			return 0, errCastFailure("could not parse as int")
    		}
    		return res, nil
    	case []byte:
    		// Parse as number, truncate floating point if
    		// needed.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 13.2K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    		if errors.Is(err, errVolumeNotFound) {
    			return pi, toObjectErr(err, bucket)
    		}
    		return pi, toObjectErr(err, bucket, object, uploadID)
    	}
    
    	// Write lock for this part ID, only hold it if we are planning to read from the
    	// streamto avoid any concurrent updates.
    	//
    	// Must be held throughout this call.
    	partIDLock := er.NewNSLock(bucket, pathJoin(object, uploadID, strconv.Itoa(partID)))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    				continue
    			}
    
    			// An online-disk means its a valid disk but it may be a re-connected disk
    			// we verify that here based on LastConn(), however we make sure to avoid
    			// putting it back into the s.erasureDisks by re-placing the disk again.
    			_, setIndex, _ := cdisk.GetDiskLoc()
    			if setIndex != -1 {
    				continue
    			}
    		}
    		if cdisk != nil {
    			// Close previous offline disk.
    			cdisk.Close()
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  6. cmd/admin-handlers-users.go

    		return
    	}
    
    	user, exists := globalIAMSys.GetUser(ctx, accessKey)
    	if exists && (user.Credentials.IsTemp() || user.Credentials.IsServiceAccount()) {
    		// Updating STS credential is not allowed, and this API does not
    		// support updating service accounts.
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAddUserInvalidArgument), r.URL)
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
Back to top