Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NextFrame (0.14 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        writeMedium(frame, 4) // has a 4-byte field
        frame.writeByte(99) // type 99
        frame.writeByte(FLAG_NONE)
        frame.writeInt(expectedStreamId)
        frame.writeInt(111111111) // custom data
        reader.nextFrame(requireSettings = false, BaseTestHandler()) // Should not callback.
      }
    
      @Test fun onlyOneLiteralHeadersFrame() {
        val sentHeaders = headerEntries("name", "value")
        val headerBytes = literalHeaders(sentHeaders)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  2. compat/maven-model-builder/src/main/java/org/apache/maven/model/validation/DefaultModelValidator.java

                super(transformer);
                this.stk = stk;
            }
    
            private ActivationFrame nextFrame(String property) {
                return new ActivationFrame(property, Optional.empty());
            }
    
            private <P> ActivationFrame nextFrame(String property, Function<P, InputLocationTracker> child) {
                @SuppressWarnings("unchecked")
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 77.1K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

          headerTableSizeSetting = 4096,
        )
    
      @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.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

            if (truncated) {
              socket.close()
            }
          } else {
            // read a frame
            val inFrame = InFrame(i, reader)
            reader.nextFrame(false, inFrame)
            inFrames.add(inFrame)
          }
        }
      }
    
      fun openSocket(): Socket = Socket("localhost", port)
    
      @Synchronized override fun close() {
        executor.shutdown()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(synStream.headerBlock).isEqualTo(headerEntries("b", "banana"))
        val requestData = peer.takeFrame()
        assertArrayEquals("c3po".toByteArray(), requestData.data)
        val nextFrame = peer.takeFrame()
        assertThat(nextFrame.headerBlock).isEqualTo(headerEntries("e", "elephant"))
      }
    
      @Test fun clientCreatesStreamAndServerRepliesWithFin() {
        // Write the mocking script.
        peer.sendFrame().settings(Settings())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

          var streamErrorCode = ErrorCode.INTERNAL_ERROR
          var errorException: IOException? = null
          try {
            reader.readConnectionPreface(this)
            while (reader.nextFrame(false, this)) {
            }
            connectionErrorCode = ErrorCode.NO_ERROR
            streamErrorCode = ErrorCode.CANCEL
          } catch (e: IOException) {
            errorException = e
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  7. internal/grid/connection.go

    		SkipHeaderCheck: false,
    		OnIntermediate:  controlHandler,
    	}
    	readDataInto := func(dst []byte, s ws.State, want ws.OpCode) ([]byte, error) {
    		dst = dst[:0]
    		for {
    			hdr, err := wsReader.NextFrame()
    			if err != nil {
    				return nil, err
    			}
    			if hdr.OpCode.IsControl() {
    				if err := controlHandler(hdr, &wsReader); err != nil {
    					return nil, err
    				}
    				continue
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  8. okhttp-android/src/main/baseline-prof.txt

    HSPLokhttp3/internal/http2/Http2Reader;-><init>(Lokio/BufferedSource;Z)V
    HSPLokhttp3/internal/http2/Http2Reader;->close()V
    HSPLokhttp3/internal/http2/Http2Reader;->lengthWithoutPadding(III)I
    HSPLokhttp3/internal/http2/Http2Reader;->nextFrame(ZLokhttp3/internal/http2/Http2Reader$Handler;)Z
    HSPLokhttp3/internal/http2/Http2Reader;->readConnectionPreface(Lokhttp3/internal/http2/Http2Reader$Handler;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (0)
Back to top