Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 33 for Ferris (0.28 sec)

  1. cmd/bucket-metadata-sys.go

    			meta, err := loadBucketMetadata(ctx, sys.objAPI, buckets[index].Name)
    			if err != nil {
    				return err
    			}
    			bucketMetas[index] = meta
    			return nil
    		}, index)
    	}
    
    	errs := g.Wait()
    	for index, err := range errs {
    		if err != nil {
    			internalLogOnceIf(ctx, fmt.Errorf("Unable to load bucket metadata, will be retried: %w", err),
    				"load-bucket-metadata-"+buckets[index].Name, logger.WarningKind)
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 19.8K bytes
    - Viewed (0)
  2. cmd/object-handlers-common.go

    					VersionID: dobj.VersionID,
    				},
    				UserAgent: "Internal: [ILM-Expiry]",
    				Host:      globalLocalNodeName,
    			}
    			if errs[i] != nil {
    				evArgs.RespElements = map[string]string{
    					"error": fmt.Sprintf("failed to delete %s(%s), with error %v", dobj.ObjectName, dobj.VersionID, errs[i]),
    				}
    			}
    			sendEvent(evArgs)
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 08:17:49 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  3. cmd/bucket-policy-handlers_test.go

    					return
    				}
    				mu.Lock()
    				errs++
    				mu.Unlock()
    				return
    			}
    			mu.Lock()
    			ok++
    			mu.Unlock()
    		}()
    	}
    	close(start)
    	wg.Wait()
    	if ok != 1 {
    		t.Fatalf("want 1 ok, got %d", ok)
    	}
    	if errs != n-1 {
    		t.Fatalf("want %d errors, got %d", n-1, errs)
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 32.7K bytes
    - Viewed (0)
  4. internal/s3select/sql/funceval.go

    	}
    }
    
    func intCast(v *Value) (int64, error) {
    	// This conversion truncates floating point numbers to
    	// integer.
    	strToInt := func(s string) (int64, bool) {
    		i, errI := strconv.ParseInt(s, 10, 64)
    		if errI == nil {
    			return i, true
    		}
    		f, errF := strconv.ParseFloat(s, 64)
    		if errF == nil {
    			return int64(f), true
    		}
    		return 0, false
    	}
    
    	switch x := v.value.(type) {
    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)
  5. cmd/prepare-storage.go

    				}
    			}
    		}
    	}
    
    	if err := checkDiskFatalErrs(errs); err != nil {
    		return nil, nil, err
    	}
    
    	// Attempt to load all `format.json` from all disks.
    	formatConfigs, sErrs := loadFormatErasureAll(storageDisks, false)
    
    	// Check if we have
    	for i, sErr := range sErrs {
    		// print the error, nonetheless, which is perhaps unhandled
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  6. cmd/erasure-metadata-utils.go

    // the corresponding error in errs slice is not nil
    func evalDisks(disks []StorageAPI, errs []error) []StorageAPI {
    	if len(errs) != len(disks) {
    		bugLogIf(GlobalContext, errors.New("unexpected drives/errors slice length"))
    		return nil
    	}
    	newDisks := make([]StorageAPI, len(disks))
    	for index := range errs {
    		if errs[index] == nil {
    			newDisks[index] = disks[index]
    		} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  7. cmd/erasure-healing_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    		if countErrs(errs, nil) != len(fileInfos) {
    			t.Fatal("Expected all xl.meta healed, but partial heal detected")
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", minioMetaBucket, cfgFile, "", false, true)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  8. cmd/erasure-healing.go

    	if err != nil {
    		m, err := er.deleteIfDangling(ctx, bucket, object, partsMetadata, errs, nil, ObjectOptions{
    			VersionID: versionID,
    		})
    		errs = make([]error, len(errs))
    		for i := range errs {
    			errs[i] = err
    		}
    		if err == nil {
    			// Dangling object successfully purged, size is '0'
    			m.Size = 0
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  9. cmd/object-api-utils_test.go

    	// returned by the server).
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    	erasureDisks := xl.getDisks()
    	parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName, "", false, false)
    	for i := range parts {
    		if errs[i] == nil {
    			if parts[i].Name == objectName {
    				t.Errorf("path traversal allowed to allow writing to minioMetaBucket: %s", instanceType)
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 23.4K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    		drive := endpoints.GetString(i)
    		state := madmin.DriveStateCorrupt
    		switch {
    		case format != nil:
    			state = madmin.DriveStateOk
    		case sErrs[i] == errUnformattedDisk:
    			state = madmin.DriveStateMissing
    		case sErrs[i] == errDiskNotFound:
    			state = madmin.DriveStateOffline
    		}
    		beforeDrives[i] = madmin.HealDriveInfo{
    			UUID: func() string {
    				if format != nil {
    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)
Back to top