Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ListDir (0.04 sec)

  1. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  2. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  3. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

            Thread.sleep(200);
    
            // Test string array listing with fresh context
            CIFSContext listContext = createFreshContext();
            SmbFile listDir = new SmbFile(baseUrl + "shared/listdir_" + timestamp + "/", listContext);
            String[] names = listDir.list();
            assertNotNull(names, "List should not be null");
            assertEquals(3, names.length, "Should list 3 items");
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 56K bytes
    - Viewed (0)
  5. cmd/erasure-multipart.go

    			disks = er.getOnlineDisks()
    		}
    	}
    
    	for _, disk = range disks {
    		if disk == nil {
    			continue
    		}
    		if !disk.IsOnline() {
    			continue
    		}
    		uploadIDs, err = disk.ListDir(ctx, bucket, minioMetaMultipartBucket, er.getMultipartSHADir(bucket, object), -1)
    		if err != nil {
    			if errors.Is(err, errDiskNotFound) {
    				continue
    			}
    			if errors.Is(err, errFileNotFound) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  6. cmd/xl-storage_test.go

    		t.Errorf("Expected to fail with \"%s\", but instead failed with \"%s\"", errDiskNotFound, err)
    	}
    }
    
    // TestXLStorageListDir -  TestXLStorages validate the directory listing functionality provided by xlStorage.ListDir .
    func TestXLStorageListDir(t *testing.T) {
    	// create xlStorage test setup
    	xlStorage, _, err := newXLStorageTestSetup(t)
    	if err != nil {
    		t.Fatalf("Unable to create xlStorage test setup, %s", err)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    	g := errgroup.WithNErrs(len(storageDisks))
    	for index, disk := range storageDisks {
    		if disk == nil {
    			continue
    		}
    		index := index
    		g.Go(func() error {
    			entries, err := storageDisks[index].ListDir(ctx, "", bucket, prefix, 1)
    			if err != nil {
    				return err
    			}
    			if len(entries) > 0 {
    				return errVolumeNotEmpty
    			}
    			return nil
    		}, index)
    	}
    
    	return g.Wait()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  8. cmd/erasure-sets.go

    	for index := range storageDisks {
    		g.Go(func() error {
    			if storageDisks[index] == nil {
    				// we ignore disk not found errors
    				return nil
    			}
    			volsInfo, err := storageDisks[index].ListDir(ctx, "", minioMetaBucket, pathJoin(bucketMetaPrefix, deletedBucketsPrefix), -1)
    			if err != nil {
    				if errors.Is(err, errFileNotFound) {
    					return nil
    				}
    				return err
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  9. cmd/object-api-multipart_test.go

    			t.Fatalf("%s : %s", instanceType, err.Error())
    		}
    	}
    
    	erasureDisks := er.getDisks()
    	uploadIDPath := er.getUploadIDDir(bucketNames[0], objectNames[0], uploadIDs[0])
    	dataDirs, err := erasureDisks[0].ListDir(context.Background(), minioMetaMultipartBucket, minioMetaMultipartBucket, uploadIDPath, -1)
    	if err != nil {
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	var dataDir string
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
Back to top