Home
last modified time | relevance | path

Searched refs:GetOrCreateStream (Results 1 – 25 of 51) sorted by relevance

123

/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/test_tools/
H A Dquic_server_session_base_peer.h17 static QuicStream* GetOrCreateStream(QuicServerSessionBase* s, in GetOrCreateStream() function
19 return s->GetOrCreateStream(id); in GetOrCreateStream()
H A Dquic_session_peer.cc117 QuicStream* QuicSessionPeer::GetOrCreateStream(QuicSession* session, in GetOrCreateStream() function in quic::test::QuicSessionPeer
119 return session->GetOrCreateStream(stream_id); in GetOrCreateStream()
H A Dquic_session_peer.h55 static QuicStream* GetOrCreateStream(QuicSession* session,
H A Dquic_test_client.cc395 QuicStream* stream = session->GetOrCreateStream(stream_id); in SendRequestAndRstTogether()
434 QuicSpdyClientStream* stream = GetOrCreateStream(); in GetOrCreateStreamAndSendRequest()
552 QuicSpdyClientStream* QuicTestClient::GetOrCreateStream() { in GetOrCreateStream() function in quic::test::QuicTestClient
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/test_tools/
H A Dquic_server_session_base_peer.h17 static QuicStream* GetOrCreateStream(QuicServerSessionBase* s, in GetOrCreateStream() function
19 return s->GetOrCreateStream(id); in GetOrCreateStream()
H A Dquic_session_peer.cc117 QuicStream* QuicSessionPeer::GetOrCreateStream(QuicSession* session, in GetOrCreateStream() function in quic::test::QuicSessionPeer
119 return session->GetOrCreateStream(stream_id); in GetOrCreateStream()
H A Dquic_session_peer.h55 static QuicStream* GetOrCreateStream(QuicSession* session,
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/core/
H A Dquic_session_test.cc609 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
616 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
618 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
623 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
630 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
632 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
691 session_.GetOrCreateStream(stream_id1); in TEST_P()
692 session_.GetOrCreateStream(stream_id2); in TEST_P()
711 session_.GetOrCreateStream(stream_id1); in TEST_P()
730 session_.GetOrCreateStream(stream_id); in TEST_P()
[all …]
H A Dquic_session.cc216 QuicStream* stream = GetOrCreateStream(stream_id); in OnStreamFrame()
272 QuicStream* stream = GetOrCreateStream(stream_id); in OnStopSendingFrame()
355 QuicStream* stream = GetOrCreateStream(stream_id); in OnRstStream()
495 QuicStream* stream = GetOrCreateStream(stream_id); in OnWindowUpdateFrame()
632 QuicStream* stream = GetOrCreateStream(currently_writing_stream_id_); in OnCanWrite()
1553 QuicStream* QuicSession::GetOrCreateStream(const QuicStreamId stream_id) { in GetOrCreateStream() function in quic::QuicSession
1761 if (GetOrCreateStream(id) == nullptr) { in MarkConnectionLevelWriteBlocked()
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/core/
H A Dquic_session_test.cc672 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
679 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
681 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
686 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
693 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
695 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
757 session_.GetOrCreateStream(stream_id1); in TEST_P()
758 session_.GetOrCreateStream(stream_id2); in TEST_P()
778 session_.GetOrCreateStream(stream_id1); in TEST_P()
797 session_.GetOrCreateStream(stream_id); in TEST_P()
[all …]
H A Dquic_session.cc204 QuicStream* stream = GetOrCreateStream(stream_id); in OnStreamFrame()
260 QuicStream* stream = GetOrCreateStream(stream_id); in OnStopSendingFrame()
345 QuicStream* stream = GetOrCreateStream(stream_id); in OnRstStream()
485 QuicStream* stream = GetOrCreateStream(stream_id); in OnWindowUpdateFrame()
619 QuicStream* stream = GetOrCreateStream(currently_writing_stream_id_); in OnCanWrite()
1855 QuicStream* QuicSession::GetOrCreateStream(const QuicStreamId stream_id) { in GetOrCreateStream() function in quic::QuicSession
2035 if (GetOrCreateStream(id) == nullptr) { in MarkConnectionLevelWriteBlocked()
/dports/www/grafana8/grafana-8.3.6/pkg/services/live/managedstream/
H A Drunner_test.go51 s1, err := runner.GetOrCreateStream(1, "stream", "test1")
53 s2, err := runner.GetOrCreateStream(1, "stream", "test2")
77 s3, err := runner.GetOrCreateStream(2, "stream", "test1")
H A Drunner.go113 func (r *Runner) GetOrCreateStream(orgID int64, scope string, namespace string) (*NamespaceStream, … func
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/core/http/
H A Dquic_client_promised_info_test.cc221 session_.GetOrCreateStream(promise_id_)); in TEST_F()
252 session_.GetOrCreateStream(promise_id_)); in TEST_F()
269 session_.GetOrCreateStream(promise_id_)); in TEST_F()
303 session_.GetOrCreateStream(promise_id_); in TEST_F()
322 session_.GetOrCreateStream(promise_id_)); in TEST_F()
H A Dquic_server_session_base_test.cc368 EXPECT_TRUE(QuicServerSessionBasePeer::GetOrCreateStream(session_.get(), in TEST_P()
377 EXPECT_TRUE(QuicServerSessionBasePeer::GetOrCreateStream(session_.get(), in TEST_P()
398 QuicServerSessionBasePeer::GetOrCreateStream(session_.get(), stream_id)); in TEST_P()
411 EXPECT_TRUE(QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
423 EXPECT_TRUE(QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
435 EXPECT_FALSE(QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
446 EXPECT_EQ(nullptr, QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
459 EXPECT_QUIC_BUG(QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
H A Dquic_spdy_session_test.cc517 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
524 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
526 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
546 session_.GetOrCreateStream(stream_id1); in TEST_P()
547 session_.GetOrCreateStream(stream_id2); in TEST_P()
596 session_.GetOrCreateStream(stream_id); in TEST_P()
600 session_.GetOrCreateStream( in TEST_P()
633 session_.GetOrCreateStream(stream_id); in TEST_P()
1825 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
1832 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
[all …]
H A Dquic_spdy_client_session_test.cc708 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
790 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
812 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
832 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
849 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
908 session_->GetOrCreateStream(GetNthServerInitiatedBidirectionalStreamId( in TEST_P()
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/core/http/
H A Dquic_client_promised_info_test.cc228 session_.GetOrCreateStream(promise_id_)); in TEST_F()
258 session_.GetOrCreateStream(promise_id_)); in TEST_F()
275 session_.GetOrCreateStream(promise_id_)); in TEST_F()
309 session_.GetOrCreateStream(promise_id_); in TEST_F()
327 session_.GetOrCreateStream(promise_id_)); in TEST_F()
H A Dquic_server_session_base_test.cc374 EXPECT_TRUE(QuicServerSessionBasePeer::GetOrCreateStream(session_.get(), in TEST_P()
383 EXPECT_TRUE(QuicServerSessionBasePeer::GetOrCreateStream(session_.get(), in TEST_P()
404 QuicServerSessionBasePeer::GetOrCreateStream(session_.get(), stream_id)); in TEST_P()
417 EXPECT_TRUE(QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
429 EXPECT_TRUE(QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
441 EXPECT_FALSE(QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
452 EXPECT_EQ(nullptr, QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
465 EXPECT_QUIC_BUG(QuicServerSessionBasePeer::GetOrCreateStream( in TEST_P()
H A Dquic_spdy_session_test.cc570 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
577 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
579 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
601 session_.GetOrCreateStream(stream_id1); in TEST_P()
602 session_.GetOrCreateStream(stream_id2); in TEST_P()
653 session_.GetOrCreateStream(stream_id); in TEST_P()
657 session_.GetOrCreateStream( in TEST_P()
690 session_.GetOrCreateStream(stream_id); in TEST_P()
1912 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
1919 ASSERT_TRUE(session_.GetOrCreateStream( in TEST_P()
[all …]
H A Dquic_spdy_client_session_test.cc730 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
813 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
835 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
855 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
872 session_->GetOrCreateStream(promised_stream_id_); in TEST_P()
931 session_->GetOrCreateStream(GetNthServerInitiatedBidirectionalStreamId( in TEST_P()
/dports/www/grafana8/grafana-8.3.6/pkg/services/live/pipeline/
H A Dframe_output_managed_stream.go26 stream, err := out.managedStream.GetOrCreateStream(vars.OrgID, vars.Scope, vars.Namespace)
H A Dsubscribe_managed_stream.go28 stream, err := s.managedStream.GetOrCreateStream(vars.OrgID, vars.Scope, vars.Namespace)
/dports/www/grafana8/grafana-8.3.6/pkg/services/live/pushws/
H A Dpush_stream.go70 stream, err := s.managedStreamRunner.GetOrCreateStream(user.OrgId, liveDto.ScopeStream, streamID)
/dports/www/grafana8/grafana-8.3.6/pkg/services/live/pushhttp/
H A Dpush.go51 …stream, err := g.GrafanaLive.ManagedStreamRunner.GetOrCreateStream(ctx.SignedInUser.OrgId, liveDto…

123