Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for blocked (0.09 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. 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)
  3. 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)
Back to top