Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for readRaw (0.03 sec)

  1. cmd/xl-storage.go

    			// are attempting a rename from file to directory.
    			return errIsNotRegular
    		default:
    			return err
    		}
    	}
    	return nil
    }
    
    func (s *xlStorage) readRaw(ctx context.Context, volume, volumeDir, filePath string, readData bool) (buf []byte, dmTime time.Time, err error) {
    	if filePath == "" {
    		return nil, dmTime, errFileNotFound
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  2. cmd/bitrot_test.go

    	b := make([]byte, 10)
    	if _, err = reader.ReadAt(b, 0); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b, 10); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b, 20); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b[:5], 30); err != nil {
    		t.Fatal(err)
    	}
    	if br, ok := reader.(io.Closer); ok {
    		br.Close()
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/pac/kerberos/KerberosToken.java

                    throw new PACDecodingException("Not a kerberos token");
                }
    
                int readLow = stream.read() & 0xff;
                int readHigh = stream.read() & 0xff;
                int read = (readHigh << 8) + readLow;
                if (read != 0x01) {
                    throw new PACDecodingException("Malformed kerberos token");
                }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  4. cmd/erasure-decode.go

    	missingPartsHeal := int32(0) // Atomic bool flag.
    	readerIndex := 0
    	var wg sync.WaitGroup
    	// if readTrigger is true, it implies next disk.ReadAt() should be tried
    	// if readTrigger is false, it implies previous disk.ReadAt() was successful and there is no need
    	// to try reading the next disk.
    	for readTrigger := range readTriggerCh {
    		newBufLK.RLock()
    		canDecode := p.canDecode(newBuf)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/pac/kerberos/KerberosEncData.java

                    break;
                case 5: // Kerberos Time
                    // DERGeneralizedTime derTime = KerberosUtil.readAs(tagged,
                    // DERGeneralizedTime.class);
                    break;
                case 6: // Kerberos Time
                    // DERGeneralizedTime derTime = KerberosUtil.readAs(tagged,
                    // DERGeneralizedTime.class);
                    break;
                case 7: // Kerberos Time
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  6. cmd/bitrot-streaming.go

    	}
    	return nil
    }
    
    func (b *streamingBitrotReader) ReadAt(buf []byte, offset int64) (int, error) {
    	var err error
    	if offset%b.shardSize != 0 {
    		// Offset should always be aligned to b.shardSize
    		// Can never happen unless there are programmer bugs
    		return 0, errUnexpected
    	}
    	if b.rc == nil {
    		// For the first ReadAt() call we need to open the stream for reading.
    		b.currOffset = offset
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jan 17 19:19:30 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  7. cmd/bitrot-whole.go

    	tillOffset int64           // Affects the length of data requested in disk.ReadFile depending on Read()'s offset
    	buf        []byte          // Holds bit-rot verified data
    }
    
    func (b *wholeBitrotReader) ReadAt(buf []byte, offset int64) (n int, err error) {
    	if b.buf == nil {
    		b.buf = make([]byte, b.tillOffset-offset)
    		if _, err := b.disk.ReadFile(context.TODO(), b.volume, b.filePath, offset, b.buf, b.verifier); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. cmd/sftp-server-driver.go

    			minio.PutObjectOptions{DisableContentSha256: true},
    		)
    		return err
    	}
    
    	return NotImplemented{}
    }
    
    type listerAt []os.FileInfo
    
    // Modeled after strings.Reader's ReadAt() implementation
    func (f listerAt) ListAt(ls []os.FileInfo, offset int64) (int, error) {
    	var n int
    	if offset >= int64(len(f)) {
    		return 0, io.EOF
    	}
    	n = copy(ls, f[offset:])
    	if n < len(ls) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 10 16:35:49 UTC 2025
    - 11.6K bytes
    - Viewed (0)
Back to top