Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 115 for readPing (0.03 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt

        val promisedStreamId = source.readInt() and 0x7fffffff
        val headerBlockLength = lengthWithoutPadding(length - 4, flags, padding) // - 4 for readInt().
        val headerBlock = readHeaderBlock(headerBlockLength, padding, flags, streamId)
        handler.pushPromise(streamId, promisedStreamId, headerBlock)
      }
    
      @Throws(IOException::class)
      private fun readPing(
        handler: Handler,
        length: Int,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/io/ByteStreams.java

          }
        }
    
        @Override
        public int readInt() {
          try {
            return input.readInt();
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
        }
    
        @Override
        public long readLong() {
          try {
            return input.readLong();
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/io/CharSource.java

      }
    
      /**
       * Opens a new {@link Stream} for reading text one line at a time from this source. This method
       * returns a new, independent stream each time it is called.
       *
       * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an
       * I/O error occurs while the stream is reading from the source or when the stream is closed, an
       * {@link UncheckedIOException} is thrown.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.7K bytes
    - Viewed (0)
  4. guava/src/com/google/common/io/CharSource.java

      }
    
      /**
       * Opens a new {@link Stream} for reading text one line at a time from this source. This method
       * returns a new, independent stream each time it is called.
       *
       * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an
       * I/O error occurs while the stream is reading from the source or when the stream is closed, an
       * {@link UncheckedIOException} is thrown.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/io/CharStreams.java

        return sb;
      }
    
      /**
       * Reads all of the lines from a {@link Readable} object. The lines do not include
       * line-termination characters, but do include other leading and trailing whitespace.
       *
       * <p>Does not close the {@code Readable}. If reading files or resources you should use the {@link
       * Files#readLines} and {@link Resources#readLines} methods.
       *
       * @param r the object to read from
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 30 17:25:01 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/SuggestHelper.java

                final boolean apply) {
            final String[] readings;
            if (StringUtil.isBlank(reading)) {
                readings = word.replace(" ", TEXT_SEP).replaceAll(TEXT_SEP + "+", TEXT_SEP).split(TEXT_SEP);
            } else {
                readings = reading.replace(" ", TEXT_SEP).replaceAll(TEXT_SEP + "+", TEXT_SEP).split(TEXT_SEP);
            }
    
            final List<String> labelList = new ArrayList<>();
            if (tags != null) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/Relay.kt

          val prefix = header.readByteString(PREFIX_CLEAN.size.toLong())
          if (prefix != PREFIX_CLEAN) throw IOException("unreadable cache file")
          val upstreamSize = header.readLong()
          val metadataSize = header.readLong()
    
          // Read the metadata.
          val metadataBuffer = Buffer()
          fileOperator.read(FILE_HEADER_SIZE + upstreamSize, metadataBuffer, metadataSize)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 17:15:47 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiFile.java

                    String token = null;
                    String segmentation = null;
                    String reading = null;
                    String pos = null;
                    switch (values.length) {
                    case 4:
                        pos = values[3];
                    case 3:
                        reading = values[2];
                    case 2:
                        segmentation = values[1];
                    case 1:
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

     *
     * Exchanges that do not have a request body may skip creating and closing the request body.
     * Exchanges that do not have a response body can call
     * [newFixedLengthSource(0)][newFixedLengthSource] and may skip reading and closing that source.
     */
    class Http1ExchangeCodec(
      /** The client that configures this stream. May be null for HTTPS proxy tunnels. */
      private val client: OkHttpClient?,
      override val carrier: ExchangeCodec.Carrier,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

          )
        }
    
        // Get frame length, optionally reading from follow-up bytes if indicated by special values.
        frameLength = (b1 and B1_MASK_LENGTH).toLong()
        if (frameLength == PAYLOAD_SHORT.toLong()) {
          frameLength = (source.readShort() and 0xffff).toLong() // Value is unsigned.
        } else if (frameLength == PAYLOAD_LONG.toLong()) {
          frameLength = source.readLong()
          if (frameLength < 0L) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 9.9K bytes
    - Viewed (0)
Back to top