- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for stream_id (0.16 sec)
-
tensorflow/c/experimental/stream_executor/stream_executor_test_util.h
#define TENSORFLOW_C_EXPERIMENTAL_STREAM_EXECUTOR_STREAM_EXECUTOR_TEST_UTIL_H_ #include "tensorflow/c/experimental/stream_executor/stream_executor.h" struct SP_Stream_st { explicit SP_Stream_st(int id) : stream_id(id) {} int stream_id; }; struct SP_Event_st { explicit SP_Event_st(int id) : event_id(id) {} int event_id; }; struct SP_Timer_st { explicit SP_Timer_st(int id) : timer_id(id) {} int timer_id; };
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Mar 17 01:32:30 UTC 2021 - 1.9K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor_test.cc
EXPECT_EQ(stream->stream_id, 1); EXPECT_EQ(event->event_id, 2); TF_SetStatus(status, TF_OK, ""); record_called = true; }; se_.wait_for_event = [](const SP_Device* const device, SP_Stream stream, SP_Event event, TF_Status* const status) { EXPECT_EQ(stream->stream_id, 1); EXPECT_EQ(event->event_id, 2);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 19:54:04 UTC 2024 - 26.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
TYPE_DATA -> readData(handler, length, flags, streamId) TYPE_HEADERS -> readHeaders(handler, length, flags, streamId) TYPE_PRIORITY -> readPriority(handler, length, flags, streamId) TYPE_RST_STREAM -> readRstStream(handler, length, flags, streamId) TYPE_SETTINGS -> readSettings(handler, length, flags, streamId) TYPE_PUSH_PROMISE -> readPushPromise(handler, length, flags, streamId)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
src/net/http/h2_bundle.go
q: *ws.queuePool.get(), id: streamID, weight: http2priorityDefaultWeight, state: http2priorityNodeOpen, } n.setParent(parent) ws.nodes[streamID] = n if streamID > ws.maxID { ws.maxID = streamID } } func (ws *http2priorityWriteScheduler) CloseStream(streamID uint32) { if streamID == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt
override fun data( inFinished: Boolean, streamId: Int, source: BufferedSource, length: Int, ) { fail("") } override fun headers( inFinished: Boolean, streamId: Int, associatedStreamId: Int, headerBlock: List<Header>, ) { fail("") } override fun rstStream( streamId: Int, errorCode: ErrorCode, ) { fail("") }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
src/net/http/h2_error_test.go
ok := errors.As(streamErr, &target) if !ok { t.Fatalf("errors.As failed") } if target.StreamID != streamErr.StreamID { t.Errorf("got StreamID %v, expected %v", target.StreamID, streamErr.StreamID) } if target.Cause != streamErr.Cause { t.Errorf("got Cause %v, expected %v", target.Cause, streamErr.Cause) } if uint32(target.Code) != uint32(streamErr.Code) { t.Errorf("got Code %v, expected %v", target.Code, streamErr.Code) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:27 UTC 2023 - 1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
logger.fine( frameLogWindowUpdate( inbound = false, streamId = streamId, length = 4, windowSizeIncrement = windowSizeIncrement, ), ) } frameHeader( streamId = streamId, length = 4, type = TYPE_WINDOW_UPDATE, flags = FLAG_NONE, )
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/http2/PushObserver.kt
interface PushObserver { /** * Describes the request that the server intends to push a response for. * * @param streamId server-initiated stream ID: an even number. * @param requestHeaders minimally includes `:method`, `:scheme`, `:authority`, * and `:path`. */ fun onRequest( streamId: Int, requestHeaders: List<Header>, ): Boolean /**
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/Http2Test.kt
} @Test fun streamIdHasReservedBit() { val writer = Http2Writer(Buffer(), true) assertFailsWith<IllegalArgumentException> { var streamId = 3 streamId = streamId or (1L shl 31).toInt() // set reserved bit writer.frameHeader(streamId, Http2.INITIAL_MAX_FRAME_SIZE, Http2.TYPE_DATA, FLAG_NONE) }.also { expected -> assertThat(expected.message).isEqualTo("reserved bit set: -2147483645") }
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/Http2Connection.kt
streamId: Int, requestHeaders: List<Header>, ) { this.withLock { if (streamId in currentPushRequests) { writeSynResetLater(streamId, ErrorCode.PROTOCOL_ERROR) return } currentPushRequests.add(streamId) } pushQueue.execute("$connectionName[$streamId] onRequest") { val cancel = pushObserver.onRequest(streamId, requestHeaders) ignoreIoExceptions {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0)