This is an automated email from the ASF dual-hosted git repository.
masaori pushed a commit to branch quic-latest
in repository https://gitbox.apache.org/repos/asf/trafficserver.git
The following commit(s) were added to refs/heads/quic-latest by this push:
new ecc8f02 Fix QUICStreamManager to use QUICStreamVConnection
ecc8f02 is described below
commit ecc8f02e3ad988de7051c73d19a70892d55c81a1
Author: Masaori Koshiba <[email protected]>
AuthorDate: Thu Mar 7 12:26:14 2019 +0900
Fix QUICStreamManager to use QUICStreamVConnection
---
iocore/net/quic/QUICStreamManager.cc | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/iocore/net/quic/QUICStreamManager.cc
b/iocore/net/quic/QUICStreamManager.cc
index 33d36b4..a4d3188 100644
--- a/iocore/net/quic/QUICStreamManager.cc
+++ b/iocore/net/quic/QUICStreamManager.cc
@@ -339,7 +339,7 @@ QUICStreamManager::total_reordered_bytes() const
uint64_t total_bytes = 0;
// FIXME Iterating all (open + closed) streams is expensive
- for (QUICStream *s = this->stream_list.head; s; s = s->link.next) {
+ for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next)
{
total_bytes += s->reordered_bytes();
}
return total_bytes;
@@ -351,7 +351,7 @@ QUICStreamManager::total_offset_received() const
uint64_t total_offset_received = 0;
// FIXME Iterating all (open + closed) streams is expensive
- for (QUICStream *s = this->stream_list.head; s; s = s->link.next) {
+ for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next)
{
total_offset_received += s->largest_offset_received();
}
return total_offset_received;
@@ -374,7 +374,7 @@ uint32_t
QUICStreamManager::stream_count() const
{
uint32_t count = 0;
- for (QUICStream *s = this->stream_list.head; s; s = s->link.next) {
+ for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next)
{
++count;
}
return count;
@@ -398,7 +398,7 @@ QUICStreamManager::will_generate_frame(QUICEncryptionLevel
level, ink_hrtime tim
return false;
}
- for (QUICStream *s = this->stream_list.head; s; s = s->link.next) {
+ for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next)
{
if (s->will_generate_frame(level, timestamp)) {
return true;
}
@@ -423,7 +423,7 @@ QUICStreamManager::generate_frame(uint8_t *buf,
QUICEncryptionLevel level, uint6
}
// FIXME We should pick a stream based on priority
- for (QUICStream *s = this->stream_list.head; s; s = s->link.next) {
+ for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next)
{
frame = s->generate_frame(buf, level, connection_credit,
maximum_frame_size, timestamp);
if (frame) {
break;