Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for readRaw (0.04 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. src/main/java/jcifs/pac/kerberos/KerberosToken.java

    
                // yes, there really is non ASN.1/DER data inside the tagged object
                int read = 0;
                int readLow = stream.read() & 0xff;
                int readHigh = stream.read() & 0xff;
                read = ( readHigh << 8 ) + readLow;
                if ( read != 0x01 )
                    throw new PACDecodingException("Malformed kerberos token");
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Oct 02 12:02:06 UTC 2023
    - 3K bytes
    - Viewed (0)
  4. src/bytes/reader.go

    		return 0, io.EOF
    	}
    	r.prevRune = -1
    	n = copy(b, r.s[r.i:])
    	r.i += int64(n)
    	return
    }
    
    // ReadAt implements the [io.ReaderAt] interface.
    func (r *Reader) ReadAt(b []byte, off int64) (n int, err error) {
    	// cannot modify state - see io.ReaderAt
    	if off < 0 {
    		return 0, errors.New("bytes.Reader.ReadAt: negative offset")
    	}
    	if off >= int64(len(r.s)) {
    		return 0, io.EOF
    	}
    	n = copy(b, r.s[off:])
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. src/archive/zip/zip_test.go

    	for i := 0; i < len(all); i++ {
    		for j := 0; j < len(all)-i; j++ {
    			buf := make([]byte, j)
    			n, err := b.ReadAt(buf, int64(i))
    			if err != nil || n != len(buf) {
    				t.Errorf("ReadAt(%d, %d) = %d, %v; want %d, nil", i, j, n, err, len(buf))
    			}
    			if !bytes.Equal(buf, all[i:i+j]) {
    				t.Errorf("ReadAt(%d, %d) = %q; want %q", i, j, buf, all[i:i+j])
    			}
    		}
    	}
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  7. 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: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Oct 02 12:02:06 UTC 2023
    - 11.4K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  10. src/archive/zip/reader.go

    // findBodyOffset does the minimum work to verify the file has a header
    // and returns the file body offset.
    func (f *File) findBodyOffset() (int64, error) {
    	var buf [fileHeaderLen]byte
    	if _, err := f.zipr.ReadAt(buf[:], f.headerOffset); err != nil {
    		return 0, err
    	}
    	b := readBuf(buf[:])
    	if sig := b.uint32(); sig != fileHeaderSignature {
    		return 0, ErrFormat
    	}
    	b = b[22:] // skip over most of the header
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
Back to top