Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 1,066 for readOp (0.2 sec)

  1. internal/ioutil/ioutil.go

    		for s.skipCount > 0 {
    			if l > s.skipCount {
    				l = s.skipCount
    			}
    			n, err := s.Reader.Read(tmp[:l])
    			if err != nil {
    				return 0, err
    			}
    			s.skipCount -= int64(n)
    		}
    	}
    	return s.Reader.Read(p)
    }
    
    // NewSkipReader - creates a SkipReader
    func NewSkipReader(r io.Reader, n int64) io.Reader {
    	return &SkipReader{r, n}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. common-protos/k8s.io/apimachinery/pkg/apis/testapigroup/v1/generated.proto

      // This data may not be up to date.
      // Populated by the system.
      // Read-only.
      // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status
      // +optional
      optional CarpStatus status = 3;
    }
    
    message CarpCondition {
      // Type is the type of the condition.
      // Currently only Ready.
      // More info: http://kubernetes.io/docs/user-guide/carp-states#carp-conditions
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  3. cmd/naughty-disk_test.go

    }
    
    func (d *naughtyDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.CreateFile(ctx, origvolume, volume, path, size, reader)
    }
    
    func (d *naughtyDisk) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. internal/s3select/jstream/scanner.go

    		fillReady: make(chan int64),
    	}
    
    	go func() {
    		var rpos int64 // total bytes read into buffer
    
    		defer func() {
    			atomic.StoreInt64(&sr.end, rpos)
    			close(sr.fillReady)
    		}()
    
    		for range sr.fillReq {
    		scan:
    			n, err := r.Read(sr.nbuf[:])
    
    			if n == 0 {
    				switch err {
    				case io.EOF: // reader is exhausted
    					return
    				case nil: // no data and no error, retry fill
    					goto scan
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  5. cmd/encryption-v1.go

    	reader, err := sio.DecryptReader(client, sio.Config{
    		Key:            objectEncryptionKey,
    		SequenceNumber: seqNumber,
    		CipherSuites:   fips.DARECiphers(),
    	})
    	if err != nil {
    		return nil, crypto.ErrInvalidCustomerKey
    	}
    	return reader, nil
    }
    
    // DecryptBlocksRequestR - same as DecryptBlocksRequest but with a
    // reader
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  6. cmd/streaming-signature-v4.go

    	return nil
    }
    
    // readCRLF - check if reader only has '\r\n' CRLF character.
    // returns malformed encoding if it doesn't.
    func readCRLF(reader io.Reader) error {
    	buf := make([]byte, 2)
    	_, err := io.ReadFull(reader, buf[:2])
    	if err != nil {
    		return err
    	}
    	if buf[0] != '\r' || buf[1] != '\n' {
    		return errMalformedEncoding
    	}
    	return nil
    }
    
    // Read a line of bytes (up to \n) from b.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  7. internal/ringbuffer/ring_buffer_test.go

    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.TryRead([]byte{0}); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	rb.CloseWithError(testError2{})
    	if _, err := rb.Read(nil); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.Read([]byte{0}); err != (testError1{}) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  8. internal/crypto/sse.go

    	return
    }
    
    // EncryptSinglePart encrypts an io.Reader which must be the
    // body of a single-part PUT request.
    func EncryptSinglePart(r io.Reader, key ObjectKey) io.Reader {
    	r, err := sio.EncryptReader(r, sio.Config{MinVersion: sio.Version20, Key: key[:], CipherSuites: fips.DARECiphers()})
    	if err != nil {
    		logger.CriticalIf(context.Background(), errors.New("Unable to encrypt io.Reader using object key"))
    	}
    	return r
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  9. cmd/erasure-encode.go

    	return fmt.Errorf("%w (offline-disks=%d/%d)", writeErr, countErrs(p.errs, errDiskNotFound), len(p.writers))
    }
    
    // Encode reads from the reader, erasure-encodes the data and writes to the writers.
    func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) {
    	writer := &multiWriter{
    		writers:     writers,
    		writeQuorum: quorum,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java

            if (readers.hasNext()) {
                final ImageReader reader = readers.next();
                try {
                    reader.setInput(input);
                    final ImageReadParam param = reader.getDefaultReadParam();
                    final int width = reader.getWidth(0);
                    final int height = reader.getHeight(0);
                    if (width <= 0 || height <= 0) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top