Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 106 for Walker (0.15 sec)

  1. cmd/bucket-metadata-sys.go

    		return errInvalidArgument
    	}
    
    	if err := meta.Save(ctx, objAPI); err != nil {
    		return err
    	}
    
    	sys.Set(meta.Name, meta)
    	globalNotificationSys.LoadBucketMetadata(bgContext(ctx), meta.Name) // Do not use caller context here
    	return nil
    }
    
    // Delete delete the bucket metadata for the specified bucket.
    // must be used by all callers instead of using Update() with nil configData.
    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/generic-handlers.go

    // such as ".." and "."
    func hasBadPathComponent(path string) bool {
    	if len(path) > 4096 {
    		// path cannot be greater than Linux PATH_MAX
    		// this is to avoid a busy loop, that can happen
    		// if the caller sends path of following style
    		// a/a/a/a/a/a/a/a...
    		return true
    	}
    	path = filepath.ToSlash(strings.TrimSpace(path)) // For windows '\' must be converted to '/'
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:08:52 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  3. cmd/xl-storage-free-version.go

    		vID, err := uuid.Parse(fi.TierFreeVersionID())
    		if err != nil {
    			panic(fmt.Errorf("Invalid Tier Object delete marker versionId %s %v", fi.TierFreeVersionID(), err))
    		}
    		freeEntry := xlMetaV2Version{Type: DeleteType, WrittenByVersion: globalVersionUnix}
    		freeEntry.DeleteMarker = &xlMetaV2DeleteMarker{
    			VersionID: vID,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  4. internal/ioutil/ioutil.go

    		timeout: timeout,
    	}
    	return dw
    }
    
    // Run runs the given function, passing it a stopper channel. If the deadline passes before
    // the function finishes executing, Run returns context.DeadlineExceeded to the caller.
    // channel so that the work function can attempt to exit gracefully.
    // Multiple calls to Run will run independently of each other.
    func (d *DeadlineWorker) Run(work func() error) error {
    	c := make(chan ioret[struct{}], 1)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    		// in the beginning of erasure set healing
    		if _, err := objAPI.HealBucket(ctx, bucket, madmin.HealOpts{
    			ScanMode: scanMode,
    		}); err != nil {
    			// Set this such that when we return this function
    			// we let the caller retry this disk again for the
    			// buckets that failed healing.
    			retErr = err
    			healingLogIf(ctx, err)
    			continue
    		}
    
    		var (
    			vc   *versioning.Versioning
    			lc   *lifecycle.Lifecycle
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  6. cmd/admin-handlers-users_test.go

    		c.Fatalf("user must not be allowed to delete")
    	}
    
    	err = client.RemoveObject(ctx, bucket, "some-object", minio.RemoveObjectOptions{})
    	if err != nil {
    		c.Fatal("user must be able to create delete marker")
    	}
    }
    
    func (c *check) mustDownload(ctx context.Context, client *minio.Client, bucket string) {
    	c.Helper()
    	rd, err := client.GetObject(ctx, bucket, "some-object", minio.GetObjectOptions{})
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 16:36:16 GMT 2024
    - 45.7K bytes
    - Viewed (0)
  7. cmd/os_windows.go

    			typ = fi.Mode()
    		case data.FileAttributes&syscall.FILE_ATTRIBUTE_DIRECTORY != 0:
    			typ = os.ModeDir
    		}
    
    		if err = filter(name, typ); err == errDoneForNow {
    			// filtering requested to return by caller.
    			return nil
    		}
    	}
    
    	return nil
    }
    
    // Return N entries at the directory dirPath.
    func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Oct 18 18:08:15 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  8. internal/crypto/sse-s3.go

    	}
    
    	// There are two possibilities:
    	// - We use a KMS -> There must be non-empty key ID and a KMS data key.
    	// - We use a K/V -> There must be no key ID and no KMS data key.
    	// Otherwise, the caller has passed an invalid argument combination.
    	if keyID == "" && len(kmsKey) != 0 {
    		logger.CriticalIf(context.Background(), errors.New("The key ID must not be empty if a KMS data key is present"))
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 8.5K bytes
    - Viewed (0)
  9. cmd/erasure-healing_test.go

    				errFileNotFound,
    				errFileNotFound,
    				nil,
    			},
    			dataErrs:         nil,
    			expectedMeta:     ifi,
    			expectedDangling: true,
    		},
    		{
    			name: "FileInfoDecided-case2-delete-marker",
    			metaArr: []FileInfo{
    				{},
    				{},
    				{},
    				{Deleted: true},
    			},
    			errs: []error{
    				errFileNotFound,
    				errFileNotFound,
    				errFileNotFound,
    				nil,
    			},
    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)
  10. internal/config/identity/plugin/config.go

    func (h *metrics) setConnFailure(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckFailure = reqStartTime
    }
    
    func (h *metrics) updateLastFullMinute(currReqMinute time.Time) {
    	// Assumes the caller has h.Lock()'ed
    	h.lastFullMinute = h.currentMinute
    	h.currentMinute = serviceRTTMinuteStats{
    		statsTime: currReqMinute,
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.3K bytes
    - Viewed (3)
Back to top