- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 187 for reader_r (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)