/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/test_tools/ |
H A D | quic_server_session_base_peer.h | 17 static QuicStream* GetOrCreateStream(QuicServerSessionBase* s, in GetOrCreateStream() function 19 return s->GetOrCreateStream(id); in GetOrCreateStream()
|
H A D | quic_session_peer.cc | 117 QuicStream* QuicSessionPeer::GetOrCreateStream(QuicSession* session, in GetOrCreateStream() function in quic::test::QuicSessionPeer 119 return session->GetOrCreateStream(stream_id); in GetOrCreateStream()
|
H A D | quic_session_peer.h | 55 static QuicStream* GetOrCreateStream(QuicSession* session,
|
H A D | quic_test_client.cc | 395 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 D | quic_server_session_base_peer.h | 17 static QuicStream* GetOrCreateStream(QuicServerSessionBase* s, in GetOrCreateStream() function 19 return s->GetOrCreateStream(id); in GetOrCreateStream()
|
H A D | quic_session_peer.cc | 117 QuicStream* QuicSessionPeer::GetOrCreateStream(QuicSession* session, in GetOrCreateStream() function in quic::test::QuicSessionPeer 119 return session->GetOrCreateStream(stream_id); in GetOrCreateStream()
|
H A D | quic_session_peer.h | 55 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 D | quic_session_test.cc | 609 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 D | quic_session.cc | 216 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 D | quic_session_test.cc | 672 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 D | quic_session.cc | 204 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 D | runner_test.go | 51 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 D | runner.go | 113 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 D | quic_client_promised_info_test.cc | 221 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 D | quic_server_session_base_test.cc | 368 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 D | quic_spdy_session_test.cc | 517 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 D | quic_spdy_client_session_test.cc | 708 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 D | quic_client_promised_info_test.cc | 228 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 D | quic_server_session_base_test.cc | 374 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 D | quic_spdy_session_test.cc | 570 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 D | quic_spdy_client_session_test.cc | 730 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 D | frame_output_managed_stream.go | 26 stream, err := out.managedStream.GetOrCreateStream(vars.OrgID, vars.Scope, vars.Namespace)
|
H A D | subscribe_managed_stream.go | 28 stream, err := s.managedStream.GetOrCreateStream(vars.OrgID, vars.Scope, vars.Namespace)
|
/dports/www/grafana8/grafana-8.3.6/pkg/services/live/pushws/ |
H A D | push_stream.go | 70 stream, err := s.managedStreamRunner.GetOrCreateStream(user.OrgId, liveDto.ScopeStream, streamID)
|
/dports/www/grafana8/grafana-8.3.6/pkg/services/live/pushhttp/ |
H A D | push.go | 51 …stream, err := g.GrafanaLive.ManagedStreamRunner.GetOrCreateStream(ctx.SignedInUser.OrgId, liveDto…
|