Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for DebugData (0.33 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

          frameHeader(
            streamId = 0,
            length = 8 + debugData.size,
            type = TYPE_GOAWAY,
            flags = FLAG_NONE,
          )
          sink.writeInt(lastGoodStreamId)
          sink.writeInt(errorCode.httpCode)
          if (debugData.isNotEmpty()) {
            sink.write(debugData)
          }
          sink.flush()
        }
      }
    
      /**
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

            override fun goAway(
              lastGoodStreamId: Int,
              errorCode: ErrorCode,
              debugData: ByteString,
            ) {
              assertThat(lastGoodStreamId).isEqualTo(expectedStreamId)
              assertThat(errorCode).isEqualTo(expectedError)
              assertThat(debugData.size).isEqualTo(0)
            }
          },
        )
      }
    
      @Test fun goAwayWithDebugDataRoundTrip() {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

            "TYPE_GOAWAY unexpected error code: $errorCodeInt",
          )
        var debugData = ByteString.EMPTY
        if (opaqueDataLength > 0) { // Must read debug data in order to not corrupt the connection.
          debugData = source.readByteString(opaqueDataLength.toLong())
        }
        handler.goAway(lastStreamId, errorCode, debugData)
      }
    
      /** Unlike other `readXxx()` functions, this one must log the frame before returning. */
    Registered: Sun Jun 16 04:42:17 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/BaseTestHandler.kt

      }
    
      override fun ping(
        ack: Boolean,
        payload1: Int,
        payload2: Int,
      ) {
        fail("")
      }
    
      override fun goAway(
        lastGoodStreamId: Int,
        errorCode: ErrorCode,
        debugData: ByteString,
      ) {
        fail("")
      }
    
      override fun windowUpdate(
        streamId: Int,
        windowSizeIncrement: Long,
      ) {
        fail("")
      }
    
      override fun priority(
        streamId: Int,
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

        }
    
        override fun goAway(
          lastGoodStreamId: Int,
          errorCode: ErrorCode,
          debugData: ByteString,
        ) {
          check(type == -1)
          this.type = Http2.TYPE_GOAWAY
          this.streamId = lastGoodStreamId
          this.errorCode = errorCode
          this.data = debugData.toByteArray()
        }
    
        override fun windowUpdate(
          streamId: Int,
          windowSizeIncrement: Long,
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

            }
          }
        }
    
        override fun goAway(
          lastGoodStreamId: Int,
          errorCode: ErrorCode,
          debugData: ByteString,
        ) {
          if (debugData.size > 0) {
            // TODO: log the debugData
          }
    
          // Copy the streams first. We don't want to hold a lock when we call receiveRstStream().
          val streamsCopy: Array<Http2Stream>
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  7. src/net/http/h2_bundle.go

    	LastStreamID uint32
    	ErrCode      http2ErrCode
    	debugData    []byte
    }
    
    // DebugData returns any debug data in the GOAWAY frame. Its contents
    // are not defined.
    // The caller must not retain the returned memory past the next
    // call to ReadFrame.
    func (f *http2GoAwayFrame) DebugData() []byte {
    	f.checkValid()
    	return f.debugData
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
Back to top