Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 464 for reeds (0.02 sec)

  1. compat/maven-compat/src/main/java/org/apache/maven/repository/MetadataResolutionResult.java

        // ------------------------------------------------------------------------
    
        public boolean hasVersionRangeViolations() {
            return versionRangeViolations != null;
        }
    
        /**
         * TODO this needs to accept a {@link OverConstrainedVersionException} as returned by
         *       {@link #getVersionRangeViolation(int)} but it's not used like that in
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  2. cmd/config-migrate.go

    		// Preserve older credential if we do not have
    		// root credentials set via environment variable.
    		globalActiveCred = cfg.Credential
    	}
    
    	// Init compression config. For future migration, Compression config needs to be copied over from previous version.
    	switch cfg.Version {
    	case "29":
    		// V29 -> V30
    		cfg.Compression.Enabled = false
    		cfg.Compression.Extensions = strings.Split(compress.DefaultExtensions, config.ValueSeparator)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache2/RelayTest.kt

          .isEqualTo("abcdefghijklmnopqrst".encodeUtf8())
        assertThat(relay.isClosed).isTrue()
        assertFile(Relay.PREFIX_CLEAN, 20L, metadata.size, "abcdefghijklmnopqrst", metadata)
      }
    
      /** Returns a callable that reads all of source, closes it, and returns the bytes.  */
      private fun sourceReader(source: Source?): Callable<ByteString> =
        Callable {
          val buffer = Buffer()
          while (source!!.read(buffer, 16384) != -1L) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  4. guava/src/com/google/common/hash/AbstractStreamingHasher.java

     * entire "chunk" (of implementation-dependent length) is ready to be hashed.
     *
     * @author Kevin Bourrillion
     * @author Dimitris Andreou
     */
    // TODO(kevinb): this class still needs some design-and-document-for-inheritance love
    abstract class AbstractStreamingHasher extends AbstractHasher {
      /** Buffer via which we pass data to the hash algorithm (the implementor) */
      private final ByteBuffer buffer;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  5. cmd/streaming-v4-unsigned.go

    	// provided buffer.
    	if cr.offset > 0 {
    		n = copy(buf, cr.buffer[cr.offset:])
    		if n == len(buf) {
    			cr.offset += n
    			return n, nil
    		}
    		cr.offset = 0
    		buf = buf[n:]
    	}
    	// mustRead reads from input and compares against provided slice.
    	mustRead := func(b ...byte) error {
    		for _, want := range b {
    			got, err := cr.reader.ReadByte()
    			if err == io.EOF {
    				return io.ErrUnexpectedEOF
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Apr 03 14:55:52 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  6. ci/official/utilities/setup.sh

        export TFCI_INSTALLER_WHL_PROJECT_NAME="$TFCI_INSTALLER_WHL_NIGHTLY_PROJECT_NAME"
      fi
      export project_name="$TFCI_INSTALLER_WHL_PROJECT_NAME"
    fi
    
    # Mac builds have some specific setup needs. See setup_macos.sh for details
    if [[ "${OSTYPE}" =~ darwin* ]]; then
      source ./ci/official/utilities/setup_macos.sh
    fi
    
    # Create and expand to the full path of TFCI_OUTPUT_DIR
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Thu Jan 09 18:37:25 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_4x.md

    _2019-10-06_
    
     *  Fix: When closing a canceled HTTP/2 stream, don't send the `END_STREAM` flag. This could cause
        the server to incorrectly interpret the stream as having completed normally. This is most useful
        when a request body needs to cancel its own call.
    
    
    ## Version 4.2.1
    
    _2019-10-02_
    
     *  Fix: In 4.1.0 we introduced a performance regression that prevented connections from being
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/util/InputStreamThread.java

    import java.util.LinkedList;
    import java.util.List;
    import java.util.function.Consumer;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    
    /**
     * A thread that reads from an input stream line by line and maintains a buffer of recent lines.
     * This class provides functionality to read input stream data asynchronously,
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  9. api/maven-api-annotations/src/main/java/org/apache/maven/api/annotations/Config.java

             * System properties are initialized before the build starts and are available throughout the entire Maven
             * execution. They are used for core Maven functionality that needs to be established at startup.
             */
            SYSTEM_PROPERTIES,
            /**
             * Maven user properties. These are properties that users configure through various means such as
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Jul 03 14:18:26 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  10. docs/smb3-features/03-multi-channel-design.md

            // Use single channel for small reads
            normalRead(buffer, offset, length);
            return;
        }
        
        // Split large read across multiple channels
        ChannelManager channelManager = session.getChannelManager();
        List<ChannelInfo> channels = channelManager.getHealthyChannels();
        int channelCount = Math.min(channels.size(), 4);  // Max 4 parallel reads
        
        int chunkSize = length / channelCount;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
Back to top