Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 110 for ErasureM (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/storage-datatypes_gen.go

    	for za0003 := range z.Parts {
    		err = z.Parts[za0003].DecodeMsg(dc)
    		if err != nil {
    			err = msgp.WrapError(err, "Parts", za0003)
    			return
    		}
    	}
    	err = z.Erasure.DecodeMsg(dc)
    	if err != nil {
    		err = msgp.WrapError(err, "Erasure")
    		return
    	}
    	z.MarkDeleted, err = dc.ReadBool()
    	if err != nil {
    		err = msgp.WrapError(err, "MarkDeleted")
    		return
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 151.7K bytes
    - Click Count (0)
  2. cmd/object-api-listobjects_test.go

    			}
    		})
    	}
    }
    
    // Wrapper for calling ListObjectsOnVersionedBuckets tests for both
    // Erasure multiple disks and single node setup.
    func TestListObjectsOnVersionedBuckets(t *testing.T) {
    	ExecObjectLayerTest(t, testListObjectsOnVersionedBuckets)
    }
    
    // Wrapper for calling ListObjects tests for both Erasure multiple
    // disks and single node setup.
    func TestListObjects(t *testing.T) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 76.1K bytes
    - Click Count (0)
  3. cmd/notification.go

    func (sys *NotificationSys) Netperf(ctx context.Context, duration time.Duration) []madmin.NetperfNodeResult {
    	length := len(sys.allPeerClients)
    	if length == 0 {
    		// For single node erasure setup.
    		return nil
    	}
    	results := make([]madmin.NetperfNodeResult, length)
    
    	scheme := "http"
    	if globalIsTLS {
    		scheme = "https"
    	}
    
    	var wg sync.WaitGroup
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  4. cmd/xl-storage_test.go

    	}
    }
    
    func TestXLStorageReadVersionLegacy(t *testing.T) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 66K bytes
    - Click Count (0)
  5. cmd/server-main.go

    	}
    	globalIsErasureSD = (setupType == ErasureSDSetupType)
    	if globalDynamicAPIPort && globalIsDistErasure {
    		logger.FatalIf(errInvalidArgument, "Invalid --address=\"%s\", port '0' is not allowed in a distributed erasure coded setup", ctxt.Addr)
    	}
    
    	globalLocalNodeName = GetLocalPeer(globalEndpoints, globalMinioHost, globalMinioPort)
    	nodeNameSum := sha256.Sum256([]byte(globalLocalNodeName))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  6. cmd/server_test.go

    		{serverType: "ErasureSD", signer: signerV2},
    		// Init and run test on ErasureSD backend, with tls enabled.
    		{serverType: "ErasureSD", signer: signerV4, secure: true},
    		// Init and run test on Erasure backend.
    		{serverType: "Erasure", signer: signerV4},
    		// Init and run test on ErasureSet backend.
    		{serverType: "ErasureSet", signer: signerV4},
    	}
    	globalServerCtxt.StrictS3Compat = true
    	for i, testCase := range testCases {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 118.1K bytes
    - Click Count (0)
  7. cmd/utils.go

    }
    
    // Helper method to return total number of nodes in cluster
    func totalNodeCount() int {
    	totalNodesCount := len(globalEndpoints.Hostnames())
    	if totalNodesCount == 0 {
    		totalNodesCount = 1 // For standalone erasure coding
    	}
    	return totalNodesCount
    }
    
    // AuditLogOptions takes options for audit logging subsystem activity
    type AuditLogOptions struct {
    	Event     string
    	APIName   string
    	Status    string
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  8. cmd/encryption-v1.go

    			_, err := sio.DecryptedSize(uint64(part.Size))
    			if err != nil {
    				return false
    			}
    		}
    	}
    
    	// Further check if this object is uploaded using multipart mechanism
    	// by the user and it is not about Erasure internally splitting the
    	// object into parts in PutObject()
    	return len(o.ETag) != 32
    }
    
    // ParseSSECopyCustomerRequest parses the SSE-C header fields of the provided request.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 38K bytes
    - Click Count (0)
  9. cmd/object-api-utils.go

    	return res
    }
    
    // hasSpaceFor returns whether the disks in `di` have space for and object of a given size.
    func hasSpaceFor(di []*DiskInfo, size int64) (bool, error) {
    	// We multiply the size by 2 to account for erasure coding.
    	size *= 2
    	if size < 0 {
    		// If no size, assume diskAssumeUnknownSize.
    		size = diskAssumeUnknownSize
    	}
    
    	var available uint64
    	var total uint64
    	var nDisks int
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  10. cmd/sts-handlers_test.go

    		{serverType: "ErasureSD", signer: signerV4},
    		// Init and run test on ErasureSD backend, with tls enabled.
    		{serverType: "ErasureSD", signer: signerV4, secure: true},
    		// Init and run test on Erasure backend.
    		{serverType: "Erasure", signer: signerV4},
    		// Init and run test on ErasureSet backend.
    		{serverType: "ErasureSet", signer: signerV4},
    	}
    	testCases := []*TestSuiteIAM{}
    	for _, bt := range baseTestCases {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 103.4K bytes
    - Click Count (1)
Back to Top