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 <masa...@apache.org>
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;

Reply via email to