- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 149 for errorCode (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
if (streamId == 0) throw IOException("TYPE_RST_STREAM streamId == 0") val errorCodeInt = source.readInt() val errorCode = ErrorCode.fromHttp2(errorCodeInt) ?: throw IOException( "TYPE_RST_STREAM unexpected error code: $errorCodeInt", ) handler.rstStream(streamId, errorCode) } @Throws(IOException::class) private fun readSettings( handler: Handler, length: Int,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
this.data = source.readByteString(length.toLong()).toByteArray() } override fun rstStream( streamId: Int, errorCode: ErrorCode, ) { check(type == -1) this.type = Http2.TYPE_RST_STREAM this.streamId = streamId this.errorCode = errorCode } override fun ping( ack: Boolean, payload1: Int, payload2: Int, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/metrics/error_collector_inst.h
namespace TFL { // Collects errors when running the pass manager. class ErrorCollectorInstrumentation : public PassInstrumentation { using ConverterErrorData = tflite::metrics::ConverterErrorData; using ErrorCode = ConverterErrorData::ErrorCode; public: explicit ErrorCollectorInstrumentation(MLIRContext *context); private: // Instrumentation hooks. These hooks don't need to be thread-safe. The pass
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Mar 25 01:48:36 UTC 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
frame.writeInt(ErrorCode.PROTOCOL_ERROR.httpCode) reader.nextFrame( requireSettings = false, object : BaseTestHandler() { override fun rstStream( streamId: Int, errorCode: ErrorCode, ) { assertThat(streamId).isEqualTo(expectedStreamId) assertThat(errorCode).isEqualTo(ErrorCode.PROTOCOL_ERROR) } }, )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 28.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
mockWebServer: MockWebServer, ) { setUp(protocol, mockWebServer) noRecoveryFromErrorWithRetryDisabled(ErrorCode.CANCEL) } private fun noRecoveryFromErrorWithRetryDisabled(errorCode: ErrorCode?) { server.enqueue( MockResponse(socketPolicy = ResetStreamAtStart(errorCode!!.httpCode)), ) server.enqueue(MockResponse(body = "abc")) client = client.newBuilder()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
fun rstStream( streamId: Int, errorCode: ErrorCode, ) { this.withLock { if (closed) throw IOException("closed") require(errorCode.httpCode != -1) frameHeader( streamId = streamId, length = 4, type = TYPE_RST_STREAM, flags = FLAG_NONE, ) sink.writeInt(errorCode.httpCode) 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) -
src/html/template/error.go
package template import ( "fmt" "text/template/parse" ) // Error describes a problem encountered during template Escaping. type Error struct { // ErrorCode describes the kind of error. ErrorCode ErrorCode // Node is the node that caused the problem, if known. // If not nil, it overrides Name and Line. Node parse.Node // Name is the name of the template in which the error was encountered.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 02 15:18:39 UTC 2023 - 9.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/PushObserver.kt
streamId: Int, source: BufferedSource, byteCount: Int, last: Boolean, ): Boolean /** Indicates the reason why this stream was canceled. */ fun onReset( streamId: Int, errorCode: ErrorCode, ) companion object { @JvmField val CANCEL: PushObserver = PushObserverCancel() private class PushObserverCancel : PushObserver { override fun onRequest( streamId: Int,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
connection.newStream(headerEntries("b", "banana"), false) // Verify the peer received what was expected. assertThat(peer.takeFrame().type).isEqualTo(Http2.TYPE_HEADERS) assertThat(peer.takeFrame().errorCode).isEqualTo(ErrorCode.PROTOCOL_ERROR) } @Test fun pushPromiseStreamsAutomaticallyCancel() { // Write the mocking script. peer.sendFrame().settings(Settings()) peer.acceptFrame() // ACK
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/typesinternal/types.go
func ReadGo116ErrorData(err types.Error) (code ErrorCode, start, end token.Pos, ok bool) { var data [3]int // By coincidence all of these fields are ints, which simplifies things. v := reflect.ValueOf(err) for i, name := range []string{"go116code", "go116start", "go116end"} { f := v.FieldByName(name) if !f.IsValid() { return 0, 0, 0, false } data[i] = int(f.Int()) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 1.4K bytes - Viewed (0)