Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for blocked (0.08 sec)

  1. cmd/erasure-object.go

    	}
    
    	return dfi.ToObjectInfo(bucket, object, opts.Versioned || opts.VersionSuspended), nil
    }
    
    // Send the successful but partial upload/delete, however ignore
    // if the channel is blocked by other items.
    func (er erasureObjects) addPartial(bucket, object, versionID string) {
    	globalMRFState.addPartialOp(PartialOperation{
    		Bucket:    bucket,
    		Object:    object,
    		VersionID: versionID,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  2. docs/en/data/github_sponsors.yml

        url: https://github.com/andrew-propelauth
      - login: blockbee-io
        avatarUrl: https://avatars.githubusercontent.com/u/115143449?u=1b8620c2d6567c4df2111a371b85a51f448f9b85&v=4
        url: https://github.com/blockbee-io
      - login: zuplo
        avatarUrl: https://avatars.githubusercontent.com/u/85497839?v=4
        url: https://github.com/zuplo
      - login: coderabbitai
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 08:58:22 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    		lc, err = globalLifecycleSys.Get(bucket)
    		if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bucket}) {
    			return err
    		}
    
    		// Check if bucket is object locked.
    		lr, err = globalBucketObjectLockSys.Get(bucket)
    		if err != nil {
    			return err
    		}
    
    		rcfg, err = getReplicationConfig(ctx, bucket)
    		if err != nil {
    			return err
    		}
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    			userDefined[minIOErasureUpgraded] = strconv.Itoa(parityOrig) + "->" + strconv.Itoa(parityDrives)
    		}
    	}
    
    	dataDrives := len(onlineDisks) - parityDrives
    
    	// we now know the number of blocks this object needs for data and parity.
    	// establish the writeQuorum using this data
    	writeQuorum := dataDrives
    	if dataDrives == parityDrives {
    		writeQuorum++
    	}
    
    	// Initialize parts metadata
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  5. cmd/object-multipart-handlers.go

    			}
    			copy(objectEncryptionKey[:], key)
    
    			partEncryptionKey := objectEncryptionKey.DerivePartKey(uint32(partID))
    			in := io.Reader(hashReader)
    			if size > encryptBufferThreshold {
    				// The encryption reads in blocks of 64KB.
    				// We add a buffer on bigger files to reduce the number of syscalls upstream.
    				in = bufio.NewReaderSize(hashReader, encryptBufferSize)
    			}
    
    			var nonce [12]byte
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  6. docs/en/docs/release-notes.md

    ```Python
    async def do_something():
        try:
            yield something
        finally:
            some_cleanup()
    ```
    
    ...that way the `finally` block is run regardless of any exception that might happen.
    
    ### Features
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:45 UTC 2025
    - 544.1K bytes
    - Viewed (0)
Back to top