- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 94 for payloadB (0.24 sec)
-
internal/grid/handlers.go
NewStream(ctx context.Context, h HandlerID, payload []byte) (st *Stream, err error) } // Call the remove with the request and func (h *StreamTypeHandler[Payload, Req, Resp]) Call(ctx context.Context, c Streamer, payload Payload) (st *TypedStream[Req, Resp], err error) { if c == nil { return nil, ErrDisconnected } var payloadB []byte if h.WithPayload { var err error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/volume/util/atomic_writer_test.go
for _, payload := range tc.payloads { writer.Write(payload, nil) checkVolumeContents(targetDir, tc.name, payload, t) } } } func checkVolumeContents(targetDir, tcName string, payload map[string]FileProjection, t *testing.T) { dataDirPath := filepath.Join(targetDir, dataDirName) // use filepath.Walk to reconstruct the payload, then deep equal
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 30.5K bytes - Viewed (0) -
tests/integration/security/jwt_test.go
"istio.io/istio/tests/common/jwt" ) // TestRequestAuthentication tests beta authn policy for jwt. func TestRequestAuthentication(t *testing.T) { payload1 := strings.Split(jwt.TokenIssuer1, ".")[1] payload2 := strings.Split(jwt.TokenIssuer2, ".")[1] payload3 := strings.Split(jwt.TokenIssuer1WithNestedClaims2, ".")[1] framework.NewTest(t). Label(label.IPv4). // https://github.com/istio/istio/issues/35835
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 25.3K bytes - Viewed (0) -
internal/s3select/message.go
progressTicker.Stop() } // Whatever drain the payloadCh to prevent from memory leaking. for len(writer.payloadCh) > 0 { payload := <-writer.payloadCh bufPool.Put(payload) } } // Sends a single whole record. func (writer *messageWriter) SendRecord(payload *bytes.Buffer) error { select { case writer.payloadCh <- payload: return nil case <-writer.doneCh:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 15.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
requireSettings = false, object : BaseTestHandler() { override fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { assertThat(ack).isTrue() assertThat(payload1).isEqualTo(expectedPayload1) assertThat(payload2).isEqualTo(expectedPayload2) } }, ) } @Test fun maxLengthDataFrame() {
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/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
) { if (length != 8) throw IOException("TYPE_PING length != 8: $length") if (streamId != 0) throw IOException("TYPE_PING streamId != 0") val payload1 = source.readInt() val payload2 = source.readInt() val ack = flags and FLAG_ACK != 0 handler.ping(ack, payload1, payload2) } @Throws(IOException::class) private fun readGoAway( handler: Handler, length: Int, flags: 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) -
internal/grid/grid_test.go
errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) { t.Log("1: server payload: ", len(payload), "bytes.") return append([]byte{}, payload...), nil })) // 2: Return as error errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) { t.Log("2: server payload: ", len(payload), "bytes.") err := RemoteErr(payload) return nil, &err }))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
} } /** * Send a connection-level ping to the peer. `ack` indicates this is a reply. The data in * `payload1` and `payload2` opaque binary, and there are no rules on the content. */ @Throws(IOException::class) fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { this.withLock { if (closed) throw IOException("closed") frameHeader( streamId = 0,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
val b1 = source.readByte() and 0xff val isMasked = b1 and B1_FLAG_MASK != 0 if (isMasked == isClient) { // Masked payloads must be read on the server. Unmasked payloads must be read on the client. throw ProtocolException( if (isClient) { "Server-sent frames must not be masked." } else {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.8K bytes - Viewed (0) -
src/internal/coverage/defs.go
// <length of pkg 0> // <length of pkg 1> // ... // --string table------ // <uleb128 len> 8 // <data> "somestring" // ... // --package payloads------ // <meta-symbol for pkg 0> // <meta-symbol for pkg 1> // ... // // Each package payload is a stand-alone blob emitted by the compiler, // and does not depend on anything else in the meta-data file. In // particular, each blob has it's own string table. Note that the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 14 12:51:16 UTC 2023 - 11.9K bytes - Viewed (0)