Changeset 408 for trunk/lib/Perlbal/Plugin/AtomStream.pm

Timestamp:

08/16/05 19:11:32 (4 years ago)

Author:

bradfitz

Message:

add in the whole "sorryTooSlow" XML element

Files:

• trunk/lib/Perlbal/Plugin/AtomStream.pm (modified) (2 diffs)

trunk/lib/Perlbal/Plugin/AtomStream.pm

@@ -11 +11 @@
 our @subs;  # subscribers
 
+use constant MAX_LAG => 262144;
+
 sub InjectFeed {
     my $class = shift;
@@ -21 +23 @@
             next;
         }
-        $s->write($atomref);
+
+        my $lag = $s->{write_buf_size};
+
+        if ($lag > MAX_LAG) {
+            $s->{scratch}{skipped_atom}++;
+        } else {
+            if (my $skip_count = $s->{scratch}{skipped_atom}) {
+                $s->{scratch}{skipped_atom} = 0;
+                $s->write(\ "<sorryTooSlow youMissed=\"$skip_count\" />\n");
+            }
+            $s->write($atomref);
+        }
     }