Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 15 for ReadData (0.25 seconds)

  1. cmd/erasure-healing_test.go

    	}
    
    	disk := er.getDisks()[0]
    	fileInfoPreHeal1, err := disk.ReadVersion(t.Context(), "", bucket, object, oi1.VersionID, ReadOptions{ReadData: false, Healing: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    	fileInfoPreHeal2, err := disk.ReadVersion(t.Context(), "", bucket, object, oi2.VersionID, ReadOptions{ReadData: false, Healing: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 48.5K bytes
    - Click Count (0)
  2. cmd/erasure-object.go

    	rawFileInfos, errs := readAllRawFileInfo(ctx, disks, bucket, object, readData)
    	return pickLatestQuorumFilesInfo(ctx, rawFileInfos, errs, bucket, object, readData, inclFreeVers)
    }
    
    func (er erasureObjects) getObjectFileInfo(ctx context.Context, bucket, object string, opts ObjectOptions, readData bool) (FileInfo, []FileInfo, []StorageAPI, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  3. cmd/naughty-disk_test.go

    	}
    	return d.disk.ReadAll(ctx, volume, path)
    }
    
    func (d *naughtyDisk) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return rf, err
    	}
    	return d.disk.ReadXL(ctx, volume, path, readData)
    }
    
    func (d *naughtyDisk) VerifyFile(ctx context.Context, volume, path string, fi FileInfo) (*CheckPartsResp, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  4. cmd/storage-interface.go

    	ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (FileInfo, error)
    	ReadXL(ctx context.Context, volume, path string, readData bool) (RawFileInfo, error)
    	RenameData(ctx context.Context, srcVolume, srcPath string, fi FileInfo, dstVolume, dstPath string, opts RenameOptions) (RenameDataResp, error)
    
    	// File operations.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  5. cmd/erasure-metadata-utils.go

    func readAllFileInfo(ctx context.Context, disks []StorageAPI, origbucket string, bucket, object, versionID string, readData, healing bool) ([]FileInfo, []error) {
    	metadataArray := make([]FileInfo, len(disks))
    
    	opts := ReadOptions{
    		ReadData: readData,
    		Healing:  healing,
    	}
    
    	g := errgroup.WithNErrs(len(disks))
    	// Read `xl.meta` in parallel across disks.
    	for index := range disks {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  6. docs/smb3-features/05-rdma-smb-direct-design.md

        
        // Read back
        start = System.currentTimeMillis();
        byte[] readData = new byte[data.length];
        
        try (InputStream is = file.getInputStream()) {
            is.read(readData);
        }
        
        long readTime = System.currentTimeMillis() - start;
        
        assertArrayEquals(data, readData);
        
        // RDMA should be faster than TCP for large transfers
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 35.9K bytes
    - Click Count (0)
  7. cmd/xl-storage.go

    	// Validate file path length, before reading.
    	filePath := pathJoin(volumeDir, path)
    	if err = checkPathLength(filePath); err != nil {
    		return fi, err
    	}
    
    	readData := opts.ReadData
    
    	buf, _, err := s.readRaw(ctx, volume, volumeDir, filePath, readData)
    	if err != nil {
    		if err == errFileNotFound {
    			if versionID != "" {
    				return fi, errFileVersionNotFound
    			}
    		}
    		return fi, err
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb1/SMB1SigningDigestTest.java

        void testVerifyWithReadAndXResponse() {
            SMB1SigningDigest digest = new SMB1SigningDigest(testMacSigningKey);
            byte[] data = new byte[100];
            byte[] readData = new byte[50];
    
            SmbComReadAndXResponse readResponse = mock(SmbComReadAndXResponse.class);
            when(readResponse.getFlags2()).thenReturn(SmbConstants.FLAGS2_SECURITY_SIGNATURES);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 18.1K bytes
    - Click Count (0)
  9. cmd/storage-rest-client.go

    func (client *storageRESTClient) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    	// Use websocket when not reading data.
    	if !readData {
    		resp, err := storageReadXLRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt

        }
    
        if (requireSettings && type != TYPE_SETTINGS) {
          throw IOException("Expected a SETTINGS frame but was ${formattedType(type)}")
        }
    
        when (type) {
          TYPE_DATA -> readData(handler, length, flags, streamId)
          TYPE_HEADERS -> readHeaders(handler, length, flags, streamId)
          TYPE_PRIORITY -> readPriority(handler, length, flags, streamId)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 19.7K bytes
    - Click Count (0)
Back to Top