Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 56 for Frame (0.04 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

        assertThat(client.canceled).isFalse()
    
        taskFaker.advanceUntil(ns(RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS))
        assertThat(client.canceled).isTrue()
    
        client.processNextFrame() // This won't get a frame, but it will get a closed pipe.
        client.listener.assertFailure(IOException::class.java, "canceled")
        taskFaker.runTasks()
      }
    
      @Test
      fun clientCloseCancelsConnectionAfterCustomTimeout() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      /** True if we've enqueued a close frame. No further message frames will be enqueued. */
      private var enqueuedClose = false
    
      /** The close code from the peer, or -1 if this web socket has not yet read a close frame. */
      private var receivedCloseCode = -1
    
      /** The close reason from the peer, or null if this web socket has not yet read a close frame. */
      private var receivedCloseReason: String? = null
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  3. doc/asm.html

    The frame size <code>$24-8</code> states that the function has a 24-byte frame
    and is called with 8 bytes of argument, which live on the caller's frame.
    If <code>NOSPLIT</code> is not specified for the <code>TEXT</code>,
    the argument size must be provided.
    For assembly functions with Go prototypes, <code>go</code> <code>vet</code> will check that the
    argument size is correct.
    </p>
    
    <p>
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Nov 28 19:15:27 UTC 2023
    - 36.3K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

    import okhttp3.internal.ws.WebSocketProtocol.validateCloseCode
    import okio.Buffer
    import okio.BufferedSink
    import okio.ByteString
    
    /**
     * An [RFC 6455][rfc_6455]-compatible WebSocket frame writer.
     *
     * This class is not thread safe.
     *
     * [rfc_6455]: http://tools.ietf.org/html/rfc6455
     */
    class WebSocketWriter(
      private val isClient: Boolean,
      val sink: BufferedSink,
      val random: Random,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 6K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Settings.kt

        /** HTTP/2: The peer must not send a PUSH_PROMISE frame when this is 0. */
        const val ENABLE_PUSH = 2
    
        /** Sender's maximum number of concurrent streams. */
        const val MAX_CONCURRENT_STREAMS = 3
    
        /** Window size in bytes. */
        const val INITIAL_WINDOW_SIZE = 4
    
        /** HTTP/2: Size in bytes of the largest frame payload the sender will accept. */
        const val MAX_FRAME_SIZE = 5
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/transformer/impl/XpathTransformerTest.java

                Map<String, String> childUrlRuleMap = newHashMap();
                childUrlRuleMap.put("//A", "href");
                childUrlRuleMap.put("//AREA", "href");
                childUrlRuleMap.put("//FRAME", "src");
                childUrlRuleMap.put("//IFRAME", "src");
                childUrlRuleMap.put("//IMG", "src");
                childUrlRuleMap.put("//LINK", "href");
                childUrlRuleMap.put("//SCRIPT", "src");
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/ConnectionShutdownException.kt

     * limitations under the License.
     */
    package okhttp3.internal.http2
    
    import java.io.IOException
    
    /**
     * Thrown when an HTTP/2 connection is shutdown (either explicitly or if the peer has sent a GOAWAY
     * frame) and an attempt is made to use the connection.
     */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 875 bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketWriterTest.kt

          payload.writeByte('0'.code)
        }
        serverWriter.writeMessageFrame(OPCODE_BINARY, payload.snapshot())
    
        // Write directly to the unbuffered sink. This ensures it will become single frame.
        assertData("827e") // 'e' == 4-byte follow-up length.
        assertData(format("%04X", payload.completeSegmentByteCount()))
        assertData(payload.readByteString())
      }
    
      @Test fun serverMessageLengthLong() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

        )
        assertThat(webSocket.close(1000, null)).isFalse()
      }
    
      /**
       * There's no read timeout when reading the first byte of a new frame. But as soon as we start
       * reading a frame we enable the read timeout. In this test we have the server returning the first
       * byte of a frame but no more frames.
       */
      @Test
      fun readTimeoutAppliesWithinFrames() {
        webServer.dispatcher =
          object : Dispatcher() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  10. docs/contribute/concurrency.md

    #### Do-stuff-later pool
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
Back to top