Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 233 for Reads (0.04 sec)

  1. api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/SettingsXmlFactory.java

     * under the License.
     */
    package org.apache.maven.api.services.xml;
    
    import org.apache.maven.api.annotations.Experimental;
    import org.apache.maven.api.settings.Settings;
    
    /**
     * Reads and writes a {@link Settings} object to/from XML.
     *
     * @since 4.0.0
     */
    @Experimental
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Mar 23 05:29:39 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  2. cmd/xl-storage_noatime_notsupported.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"os"
    )
    
    var (
    	// No special option for reads on windows
    	readMode = os.O_RDONLY
    
    	// Write with sync no buffering only used only for `xl.meta` writes
    	writeMode = os.O_SYNC
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jul 23 16:36:24 UTC 2024
    - 1001 bytes
    - Viewed (0)
  3. src/bufio/bufio.go

    	*b = Reader{
    		buf:          buf,
    		rd:           r,
    		lastByte:     -1,
    		lastRuneSize: -1,
    	}
    }
    
    var errNegativeRead = errors.New("bufio: reader returned negative count from Read")
    
    // fill reads a new chunk into the buffer.
    func (b *Reader) fill() {
    	// Slide existing data to beginning.
    	if b.r > 0 {
    		copy(b.buf, b.buf[b.r:b.w])
    		b.w -= b.r
    		b.r = 0
    	}
    
    	if b.w >= len(b.buf) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Sep 03 14:04:47 UTC 2025
    - 22K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    	return *resp, nil
    }
    
    // where we keep old *Readers
    var readMsgpReaderPool = bpool.Pool[*msgp.Reader]{New: func() *msgp.Reader { return &msgp.Reader{} }}
    
    // mspNewReader returns a *Reader that reads from the provided reader.
    // The reader will be buffered.
    // Return with readMsgpReaderPoolPut when done.
    func msgpNewReader(r io.Reader) *msgp.Reader {
    	p := readMsgpReaderPool.Get()
    	if p.R == nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt

        )
    
      @Throws(IOException::class)
      fun readConnectionPreface(handler: Handler) {
        if (client) {
          // The client reads the initial SETTINGS frame.
          if (!nextFrame(true, handler)) {
            throw IOException("Required SETTINGS preface not received")
          }
        } else {
          // The server reads the CONNECTION_PREFACE byte string.
          val connectionPreface = source.readByteString(CONNECTION_PREFACE.size.toLong())
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb1/util/HexdumpTest.java

            assertEquals("00", Hexdump.toHexString(data4, 1, 2)); // Bug: ignores srcIndex, reads from 0
            assertEquals("0011", Hexdump.toHexString(data4, 1, 4)); // Bug: ignores srcIndex, reads from 0
            assertEquals("0011", Hexdump.toHexString(data4, 2, 4)); // Bug: ignores srcIndex, reads from 0
        }
    
        @Test
        @DisplayName("Should perform hexdump with correct formatting")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/suggest/index/contents/querylog/QueryLogReader.java

     * It extends the {@code Closeable} interface, ensuring that resources can be released when no longer needed.
     */
    public interface QueryLogReader extends Closeable {
        /**
         * Reads a query log.
         * @return The query log.
         */
        QueryLog read();
    
        @Override
        void close();
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 1.1K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/ByteStreams.java

     * @author Colin Decker
     * @since 1.0
     */
    @GwtIncompatible
    public final class ByteStreams {
    
      private static final int BUFFER_SIZE = 8192;
    
      /** Creates a new byte array for buffering reads or writes. */
      static byte[] createBuffer() {
        return new byte[BUFFER_SIZE];
      }
    
      /**
       * There are three methods to implement {@link FileChannel#transferTo(long, long,
       * WritableByteChannel)}:
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/suggest/index/contents/document/DocumentReader.java

     * should also handle resource cleanup when the {@link #close()} method is called.</p>
     */
    public interface DocumentReader extends Closeable {
        /**
         * Reads a document and returns its contents as a map.
         *
         * @return a map containing the document's data, or null if there are no more documents to read.
         */
        Map<String, Object> read();
    
        @Override
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  10. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

            readStory(story00)
            result.add(path.name)
          } catch (ignored: IOException) {
            // Skip this path.
          }
        }
        return result.toTypedArray<String>()
      }
    
      /**
       * Reads stories named "story_xx.json" from the folder provided.
       */
      fun readStories(testFolderName: String): List<Story> {
        val result = mutableListOf<Story>()
        var i = 0
        while (true) { // break after last test.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.3K bytes
    - Viewed (0)
Back to top