Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for ListDir (0.06 sec)

  1. cmd/naughty-disk_test.go

    		return err
    	}
    	return d.disk.WalkDir(ctx, opts, wr)
    }
    
    func (d *naughtyDisk) ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) (entries []string, err error) {
    	if err := d.calcError(); err != nil {
    		return []string{}, err
    	}
    	return d.disk.ListDir(ctx, origvolume, volume, dirPath, count)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. cmd/ftp-server-driver.go

    	}
    
    	isDir := strings.HasSuffix(objInfo.Key, SlashSeparator)
    	return &minioFileInfo{
    		p:     pathClean(object),
    		info:  objInfo,
    		isDir: isDir,
    	}, nil
    }
    
    // ListDir implements ftpDriver
    func (driver *ftpDriver) ListDir(ctx *ftp.Context, objPath string, callback func(os.FileInfo) error) (err error) {
    	stopFn := globalFtpMetrics.log(ctx, objPath)
    	defer stopFn(0, err)
    
    	clnt, err := driver.getMinIOClient(ctx)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	RenameData(ctx context.Context, srcVolume, srcPath string, fi FileInfo, dstVolume, dstPath string, opts RenameOptions) (RenameDataResp, error)
    
    	// File operations.
    	ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) ([]string, error)
    	ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    	if err != nil {
    		return 0, err
    	}
    	defer xhttp.DrainBody(respBody)
    	n, err := io.ReadFull(respBody, buf)
    	return int64(n), toStorageErr(err)
    }
    
    // ListDir - lists a directory.
    func (client *storageRESTClient) ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) (entries []string, err error) {
    	values := grid.NewMSS()
    	values.Set(storageRESTVolume, volume)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. cmd/storage-rest_test.go

    		expectErr      bool
    	}{
    		{"foo", "path", []string{"to/"}, false},
    		// prefix not found error.
    		{"foo", "nodir", nil, true},
    	}
    
    	for i, testCase := range testCases {
    		result, err := storage.ListDir(context.Background(), "", testCase.volumeName, testCase.prefix, -1)
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    			t.Fatalf("case %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. cmd/metacache-walk.go

    		if contextCanceled(ctx) {
    			return ctx.Err()
    		}
    		if opts.Limit > 0 && objsReturned >= opts.Limit {
    			return nil
    		}
    
    		if s.walkMu != nil {
    			s.walkMu.Lock()
    		}
    		entries, err := s.ListDir(ctx, "", opts.Bucket, current, -1)
    		if s.walkMu != nil {
    			s.walkMu.Unlock()
    		}
    		if err != nil {
    			// Folder could have gone away in-between
    			if err != errVolumeNotFound && err != errFileNotFound {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. cmd/erasure-object_test.go

    	_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(buf), int64(len(buf)), "", ""), opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	for _, disk := range xl.getDisks() {
    		files, _ := disk.ListDir(ctx, "", bucket, object, -1)
    		for _, file := range files {
    			if file != "xl.meta" {
    				disk.Delete(ctx, bucket, pathJoin(object, file), DeleteOptions{
    					Recursive: true,
    					Immediate: false,
    				})
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  8. cmd/storage-datatypes.go

    type CheckPartsResp struct {
    	Results []int `msg:"r"`
    }
    
    // LocalDiskIDs - GetLocalIDs response.
    type LocalDiskIDs struct {
    	IDs []string `msg:"i"`
    }
    
    // ListDirResult - ListDir()'s response.
    type ListDirResult struct {
    	Entries []string `msg:"e"`
    }
    
    // ReadPartsReq - send multiple part paths to read from
    type ReadPartsReq struct {
    	Paths []string `msg:"p"`
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  9. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) (s []string, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricListDir, volume, dirPath)
    	if err != nil {
    		return nil, err
    	}
    	defer done(0, &err)
    
    	return p.storage.ListDir(ctx, origvolume, volume, dirPath, count)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  10. configure.py

                     'subdirectories "platforms" and "build-tools".'))
    
      platforms = os.path.join(android_sdk_home_path, 'platforms')
      api_levels = sorted(os.listdir(platforms))
      api_levels = [x.replace('android-', '') for x in api_levels]
    
      def valid_api_level(api_level):
        return os.path.exists(
            os.path.join(android_sdk_home_path, 'platforms',
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Oct 02 22:16:02 UTC 2024
    - 48.2K bytes
    - Viewed (0)
Back to top