Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 187 for reader_r (0.09 sec)

  1. src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java

            final Iterator<ImageReader> readers = ImageIO.getImageReaders(input);
            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);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. tensorflow/c/checkpoint_reader.h

      std::pair<std::unique_ptr<TensorSliceReader::VarToShapeMap>,
                std::unique_ptr<TensorSliceReader::VarToDataTypeMap> >
      BuildV2VarMaps();
    
      // Invariant: exactly one of "reader_" and "v2_reader_" is non-null.
      std::unique_ptr<TensorSliceReader> reader_;
      std::unique_ptr<BundleReader> v2_reader_;
    
      std::unique_ptr<TensorSliceReader::VarToShapeMap> var_to_shape_map_;
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Oct 12 08:49:52 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  3. src/bufio/bufio.go

    // NewReaderSize returns a new [Reader] whose buffer has at least the specified
    // size. If the argument io.Reader is already a [Reader] with large enough
    // size, it returns the underlying [Reader].
    func NewReaderSize(rd io.Reader, size int) *Reader {
    	// Is it already a Reader?
    	b, ok := rd.(*Reader)
    	if ok && len(b.buf) >= size {
    		return b
    	}
    	r := new(Reader)
    	r.reset(make([]byte, max(size, minReadBufferSize)), rd)
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  4. internal/s3select/jstream/errors.go

    	msg       string // description of error
    	context   string // additional error context
    	pos       errPos
    	atChar    byte
    	readerErr error // underlying reader error, if any
    }
    
    // ReaderErr returns the underlying error.
    func (e DecoderError) ReaderErr() error { return e.readerErr }
    
    // Error returns a string representation of the error.
    func (e DecoderError) Error() string {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  5. internal/ringbuffer/ring_buffer.go

    	if len(p) == 0 {
    		return 0, r.readErr(false)
    	}
    
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	if err := r.readErr(true); err != nil {
    		return 0, err
    	}
    
    	r.wg.Add(1)
    	defer r.wg.Done()
    	n, err = r.read(p)
    	for err == ErrIsEmpty && r.block {
    		r.writeCond.Wait()
    		if err = r.readErr(true); err != nil {
    			break
    		}
    		n, err = r.read(p)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. internal/ringbuffer/ring_buffer_test.go

    			fmt.Println(args...)
    		}
    	}
    	// Inject random reader/writer sleeps.
    	const maxSleep = int(1 * time.Millisecond)
    	doSleep := !testing.Short()
    	rb := New(4 << 10).SetBlocking(true)
    
    	// Reader
    	var readErr error
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		readRng := rand.New(rand.NewSource(1))
    		defer wg.Done()
    		defer rb.CloseWithError(readErr)
    		buf := make([]byte, 1024)
    		for {
    			// Read
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. internal/hash/reader.go

    )
    
    // A Reader wraps an io.Reader and computes the MD5 checksum
    // of the read content as ETag. Optionally, it also computes
    // the SHA256 checksum of the content.
    //
    // If the reference values for the ETag and content SHA26
    // are not empty then it will check whether the computed
    // match the reference values.
    type Reader struct {
    	src         io.Reader
    	bytesRead   int64
    	expectedMin int64
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. internal/etag/reader.go

    //
    //	// Now, we need an io.Reader that can access
    //	// the ETag computed over the content.
    //	reader := etag.Wrap(encryptedContent, content)
    func Wrap(wrapped, content io.Reader) io.Reader {
    	if t, ok := content.(Tagger); ok {
    		return wrapReader{
    			Reader: wrapped,
    			Tagger: t,
    		}
    	}
    	return wrapReader{
    		Reader: wrapped,
    	}
    }
    
    // A Reader wraps an io.Reader and computes the
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  9. cmd/erasure-decode.go

    )
    
    // Reads in parallel from readers.
    type parallelReader struct {
    	readers       []io.ReaderAt
    	orgReaders    []io.ReaderAt
    	dataBlocks    int
    	offset        int64
    	shardSize     int64
    	shardFileSize int64
    	buf           [][]byte
    	readerToBuf   []int
    	stashBuffer   []byte
    }
    
    // newParallelReader returns parallelReader.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  10. cmd/dummy-data-generator_test.go

    	checkEq(readAll(r), readAll(NewDummyDataGen(100-int64(len(alphabets)), 0)))
    }
    
    // Compares all the bytes returned by the given readers. Any Read
    // errors cause a `false` result. A string describing the error is
    // also returned.
    func cmpReaders(r1, r2 io.Reader) (bool, string) {
    	bufLen := 32 * 1024
    	b1, b2 := make([]byte, bufLen), make([]byte, bufLen)
    	for i := 0; true; i++ {
    		n1, e1 := io.ReadFull(r1, b1)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top