Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,667 for byteEq (0.05 sec)

  1. cmd/xl-storage-format-v2_gen_test.go

    import (
    	"bytes"
    	"testing"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    func TestMarshalUnmarshalxlMetaDataDirDecoder(t *testing.T) {
    	v := xlMetaDataDirDecoder{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	left, err := v.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 18 20:15:22 UTC 2021
    - 11.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/io/ReaderInputStream.java

       * stream. When encoding it is "unflipped" (encoded bytes between 0 and position) and when
       * draining it is flipped (undrained bytes between position and limit).
       */
      private ByteBuffer byteBuffer;
    
      /** Whether we've finished reading the reader. */
      private boolean endOfInput;
      /** Whether we're copying encoded bytes to the caller's buffer. */
      private boolean draining;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/ReaderInputStream.java

       * stream. When encoding it is "unflipped" (encoded bytes between 0 and position) and when
       * draining it is flipped (undrained bytes between position and limit).
       */
      private ByteBuffer byteBuffer;
    
      /** Whether we've finished reading the reader. */
      private boolean endOfInput;
      /** Whether we're copying encoded bytes to the caller's buffer. */
      private boolean draining;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  4. cmd/untar.go

    			asyncWriters <- struct{}{}
    			b := poolBuf128k.Get().([]byte)
    			if cap(b) < int(header.Size) {
    				b = make([]byte, smallFileThreshold)
    			}
    			b = b[:header.Size]
    			if _, err := io.ReadFull(tarReader, b); err != nil {
    				return err
    			}
    			wg.Add(1)
    			go func(name string, fi fs.FileInfo, b []byte) {
    				rc := disconnectReader{r: bytes.NewReader(b)}
    				defer func() {
    					rc.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (2)
  5. src/bufio/example_test.go

    // Use a Scanner with a custom split function to parse a comma-separated
    // list with an empty final value but stops at the token "STOP".
    func ExampleScanner_earlyStop() {
    	onComma := func(data []byte, atEOF bool) (advance int, token []byte, err error) {
    		i := bytes.IndexByte(data, ',')
    		if i == -1 {
    			if !atEOF {
    				return 0, nil, nil
    			}
    			// If we have reached the end, return the last token.
    			return 0, data, bufio.ErrFinalToken
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. internal/s3select/csv/recordtransform.go

    package csv
    
    import (
    	"bytes"
    	"io"
    )
    
    // recordTransform will convert records to always have newline records.
    type recordTransform struct {
    	reader io.Reader
    	// recordDelimiter can be up to 2 characters.
    	recordDelimiter []byte
    	oneByte         []byte
    	useOneByte      bool
    }
    
    func (rr *recordTransform) Read(p []byte) (n int, err error) {
    	if rr.useOneByte {
    		p[0] = rr.oneByte[0]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  7. internal/grid/types_test.go

    			b.Fatal(err)
    		}
    	}
    }
    
    func TestMarshalUnmarshalBytes(t *testing.T) {
    	v := Bytes([]byte("abc123123123"))
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	var v2 Bytes
    	left, err := v2.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) != 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    	}
    
    	left, err = msgp.Skip(bts)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/SmbRandomAccess.java

         * 
         * @param b
         *            buffer
         * @param off
         *            offset into buffer
         * @param len
         *            read up to <tt>len</tt> bytes
         * @return number of bytes read
         * @throws SmbException
         */
        int read ( byte[] b, int off, int len ) throws SmbException;
    
    
        /**
         * Current position in file
         * 
         * @return current position
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.5K bytes
    - Viewed (0)
  9. src/bytes/reader_test.go

    	// any state.
    	r := NewReader([]byte("0123456789"))
    	var wg sync.WaitGroup
    	for i := 0; i < 5; i++ {
    		wg.Add(1)
    		go func(i int) {
    			defer wg.Done()
    			var buf [1]byte
    			r.ReadAt(buf[:], int64(i))
    		}(i)
    	}
    	wg.Wait()
    }
    
    func TestEmptyReaderConcurrent(t *testing.T) {
    	// Test for the race detector, to verify a Read that doesn't yield any bytes
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 8K bytes
    - Viewed (0)
  10. cmd/bucket-stats_gen_test.go

    import (
    	"bytes"
    	"testing"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    func TestMarshalUnmarshalBucketReplicationStat(t *testing.T) {
    	v := BucketReplicationStat{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	left, err := v.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 30 08:00:59 UTC 2023
    - 20.5K bytes
    - Viewed (0)
Back to top