Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for blocking (0.16 sec)

  1. cmd/xl-storage.go

    			targetPath2,
    		} {
    			if target == "" {
    				continue
    			}
    			select {
    			case s.immediatePurge <- target:
    			default:
    				// Too much back pressure, we will perform the delete
    				// blocking at this point we need to serialize operations.
    				removeAll(target)
    			}
    		}
    	}
    
    	return nil
    }
    
    // DeleteVersion - deletes FileInfo metadata for path at `xl.meta`. forceDelMarker
    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)
  2. android/guava/src/com/google/common/collect/Sets.java

       * java.util.TreeMap}).
       *
       * <p>Each method invocation on the set returned by this method results in exactly one method
       * invocation on the backing map or its {@code keySet} view, with one exception. The {@code
       * addAll} method is implemented as a sequence of {@code put} invocations on the backing map.
       *
       * <p>The specified map must be empty at the time this method is invoked, and should not be
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed May 01 18:44:57 GMT 2024
    - 77.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Multimaps.java

          }
        }
    
        // can't use Serialization writeMultimap and populateMultimap methods since
        // there's no way to generate the empty backing map.
    
        /**
         * @serialData the factory and the backing map
         */
        @GwtIncompatible // java.io.ObjectOutputStream
        @J2ktIncompatible
        private void writeObject(ObjectOutputStream stream) throws IOException {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed May 01 18:44:57 GMT 2024
    - 86.4K bytes
    - Viewed (0)
  4. cmd/api-errors.go

    	},
    	ErrInvalidLifecycleWithObjectLock: {
    		Code:           "InvalidLifecycleWithObjectLock",
    		Description:    "The lifecycle configuration containing MaxNoncurrentVersions is not supported with object locking",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrNoSuchBucketSSEConfig: {
    		Code:           "ServerSideEncryptionConfigurationNotFoundError",
    		Description:    "The server side encryption configuration was not found",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  5. cmd/bucket-handlers.go

    	if s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	if objectLockEnabled {
    		// Creating a bucket with locking requires the user having more permissions
    		for _, action := range []policy.Action{policy.PutBucketObjectLockConfigurationAction, policy.PutBucketVersioningAction} {
    			if !globalIAMSys.IsAllowed(policy.Args{
    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)
  6. android/guava/src/com/google/common/collect/Iterators.java

     * {@link Iterables} class.
     *
     * <p><i>Performance notes:</i> Unless otherwise noted, all of the iterators produced in this class
     * are <i>lazy</i>, which means that they only advance the backing iteration when absolutely
     * necessary.
     *
     * <p>See the Guava User Guide section on <a href=
     * "https://github.com/google/guava/wiki/CollectionUtilitiesExplained#iterables">{@code
     * Iterators}</a>.
     *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Apr 30 18:43:01 GMT 2024
    - 51.1K bytes
    - Viewed (0)
  7. cmd/iam-store.go

    //
    // In LDAP users mode, the server does not store any group membership
    // information in IAM (i.e sys.iam*Map) - this info is stored only in the STS
    // generated credentials. Thus we skip looking up group memberships, user map,
    // and group map and check the appropriate policy maps directly.
    func (c *iamCache) policyDBGet(store *IAMStoreSys, name string, isGroup bool) ([]string, time.Time, error) {
    	if isGroup {
    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)
  8. cmd/admin-handlers-users.go

    					Versioning:          globalBucketVersioningSys.Enabled(bucket.Name),
    					VersioningSuspended: globalBucketVersioningSys.Suspended(bucket.Name),
    					Replication:         rcfg != nil,
    					Locking:             lcfg.LockEnabled,
    					Quota:               quota,
    					Tagging:             tcfg,
    				},
    				Access: madmin.AccountAccess{
    					Read:  rd,
    					Write: wr,
    				},
    			})
    		}
    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)
  9. cmd/erasure-server-pool.go

    	if contextCanceled(ctx) {
    		return ListObjectVersionsInfo{}, ctx.Err()
    	}
    
    	if versionMarker == "" {
    		o := listPathOptions{Marker: marker}
    		// If we are not looking for a specific version skip it.
    
    		o.parseMarker()
    		merged.forwardPast(o.Marker)
    	}
    	objects := merged.fileInfoVersions(bucket, prefix, delimiter, versionMarker)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
Back to top