Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 1,758 for read0 (0.08 seconds)

  1. internal/http/headers.go

    	// Header indicates if the etag should be preserved by client
    	MinIOSourceETag = "x-minio-source-etag"
    
    	// Writes expected write quorum
    	MinIOWriteQuorum = "x-minio-write-quorum"
    
    	// Reads expected read quorum
    	MinIOReadQuorum = "x-minio-read-quorum"
    
    	// Indicates if we are using default storage class and there was problem loading config
    	// if this header is set to "true"
    	MinIOStorageClassDefaults = "x-minio-storage-class-defaults"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  2. internal/ioutil/read_file.go

    	_, err = io.ReadFull(f, dst)
    	return dst, st, err
    }
    
    // ReadFile reads the named file and returns the contents.
    // A successful call returns err == nil, not err == EOF.
    // Because ReadFile reads the whole file, it does not treat an EOF from Read
    // as an error to be reported.
    //
    // passes NOATIME flag for reads on Unix systems to avoid atime updates.
    func ReadFile(name string) ([]byte, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Dec 09 18:17:51 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  3. internal/bucket/bandwidth/reader.go

    type MonitorReaderOptions struct {
    	BucketOptions
    	HeaderSize int
    }
    
    // Read implements a throttled read
    func (r *MonitoredReader) Read(buf []byte) (n int, err error) {
    	if r.throttle == nil {
    		return r.r.Read(buf)
    	}
    	if r.lastErr != nil {
    		err = r.lastErr
    		return n, err
    	}
    	b := r.throttle.Burst()  // maximum available tokens
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  4. api/maven-api-xml/src/main/java/org/apache/maven/api/xml/XmlService.java

            return read(reader, null);
        }
    
        /**
         * Reads an XML node from a reader.
         */
        @Nonnull
        public static XmlNode read(Reader reader, @Nullable InputLocationBuilder locationBuilder)
                throws XMLStreamException {
            return getService().doRead(reader, locationBuilder);
        }
    
        /**
         * Reads an XML node from an XMLStreamReader.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Apr 03 13:33:59 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/core/io/FileUtil.java

                ChannelUtil.read(channel, buffer);
                return buffer.array();
            } finally {
                CloseableUtil.close(is);
            }
        }
    
        /**
         * Reads text from a file using the default encoding.
         *
         * @param path
         *            The file path. Must not be {@literal null} or empty.
         * @return The text read from the file.
         */
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Feb 12 12:10:45 GMT 2026
    - 13.2K bytes
    - Click Count (0)
  6. internal/ioutil/hardlimitreader.go

    // A HardLimitedReader reads from R but limits the amount of
    // data returned to just N bytes. Each call to Read
    // updates N to reflect the new amount remaining.
    // Read returns EOF when N <= 0 or when the underlying R returns EOF.
    type HardLimitedReader struct {
    	R io.Reader // underlying reader
    	N int64     // max bytes remaining
    }
    
    func (l *HardLimitedReader) Read(p []byte) (n int, err error) {
    	if l.N < 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java

        }
    
        /**
         * Reads bytes from the file into the specified byte array.
         *
         * @param b the byte array to read data into
         * @return the number of bytes read, or -1 if end of file is reached
         * @throws SmbException if an I/O error occurs
         */
        public int read(final byte b[]) throws SmbException {
            return read(b, 0, b.length);
        }
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 14.1K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/io/Resources.java

        }
      }
    
      /**
       * Returns a {@link CharSource} that reads from the given URL using the given character set.
       *
       * @since 14.0
       */
      public static CharSource asCharSource(URL url, Charset charset) {
        return asByteSource(url).asCharSource(charset);
      }
    
      /**
       * Reads all bytes from a URL into a byte array.
       *
       * @param url the URL to read from
       * @return a byte array containing all the bytes from the URL
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  9. internal/ringbuffer/README.md

    Regular Reads will block until data is available, but not wait for a full buffer. 
    Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space.
    
    `TryRead` and `TryWrite` are still available for non-blocking reads and writes.
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 15 00:11:04 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  10. internal/deadlineconn/deadlineconn.go

    		c.Conn.SetWriteDeadline(now.Add(c.writeDeadline + updateInterval))
    		c.writeSetAt = now
    	}
    }
    
    // Read - reads data from the connection using wrapped buffered reader.
    func (c *DeadlineConn) Read(b []byte) (n int, err error) {
    	if c.abortReads.Load() {
    		return 0, context.DeadlineExceeded
    	}
    	c.setReadDeadline()
    	n, err = c.Conn.Read(b)
    	return n, err
    }
    
    // Write - writes data to the connection.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Dec 02 13:21:17 GMT 2024
    - 5.1K bytes
    - Click Count (0)
Back to Top