X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FRingBuf.pm;fp=perl%2FRingBuf.pm;h=82b534e41d2081887c4cee814cade8dee0a4286a;hb=9cc26cc7a73efb7679d3e8e819ba0019307f8607;hp=0000000000000000000000000000000000000000;hpb=20efba5d5f656113144785e0ef84296e6d2c2e69;p=spider.git

diff --git a/perl/RingBuf.pm b/perl/RingBuf.pm
new file mode 100644
index 00000000..82b534e4
--- /dev/null
+++ b/perl/RingBuf.pm
@@ -0,0 +1,79 @@
+#
+# Finite size ring buffer creation and access routines
+#
+# Copyright (c) - 1998 Dirk Koopman G1TLH
+#
+# $Id$
+#
+
+use strict;
+
+package RingBuf;
+
+use vars qw($VERSION $BRANCH);
+$VERSION = sprintf( "%d.%03d", q$Revision$ =~ /(\d+)\.(\d+)/ );
+$BRANCH = sprintf( "%d.%03d", q$Revision$ =~ /\d+\.\d+\.(\d+)\.(\d+)/  || (0,0));
+$main::build += $VERSION;
+$main::branch += $BRANCH;
+
+
+sub new
+{
+	my $pkg = shift;
+	my $size = shift;
+	return bless [$size, 0, 0, 0, 0, []], (ref $pkg || $pkg);
+}
+
+sub write
+{
+	my $self = shift;
+
+	$self->[5]->[$self->[2]++] = shift;
+	$self->[2] = 0 if $self->[2] >= $self->[0];
+	if ($self->[1] < $self->[0]) {
+		$self->[1] = ++$self->[1];
+	}
+	$self->[2] = $self->[2];
+	if ($self->[1] == $self->[0] && $self->[2] == $self->[3]) {
+		$self->[3] = $self->[2]+1;
+		$self->[3] = 0 if $self->[3] >= $self->[0]; 
+	}
+}
+
+sub read
+{
+	my $self = shift;
+	return unless $self->[1];
+	my $r;
+	
+	if ($self->[4] != $self->[2]) {
+		$r = $self->[5]->[$self->[4]++];
+		$self->[4] = 0 if $self->[4] >= $self->[0];
+	}
+	return $r;
+}
+
+sub rewind
+{
+	my $self = shift;
+	$self->[4] = $self->[3];
+}
+
+sub lth
+{
+	my $self = shift;
+	return $self->[1];
+}
+
+sub readall
+{
+	my $self = shift;
+	my @out;
+	
+	$self->rewind;
+	while (my $r = $self->read) {
+		push @out, $r;
+	}
+	return @out;
+}
+1;