From: minima <minima>
Date: Wed, 31 Dec 2003 20:04:16 +0000 (+0000)
Subject: add Thingy
X-Git-Tag: R1_51~1
X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=commitdiff_plain;h=1284d2e7cc4c25bb02c7f4fa7c59246de9c0027c;p=spider.git

add Thingy
---

diff --git a/perl/Thingy.pm b/perl/Thingy.pm
new file mode 100644
index 00000000..cf057957
--- /dev/null
+++ b/perl/Thingy.pm
@@ -0,0 +1,50 @@
+#
+# Thingy handling
+#
+# This is the new fundamental protocol engine handler
+#
+# $Id$
+#
+# Copyright (c) 2004 Dirk Koopman G1TLH
+#
+
+package Thingy;
+
+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;
+
+
+use DXChannel;
+use DXDebug;
+
+our @queue;
+
+# we expect all thingies to be subclassed
+sub new
+{
+	my $class = shift;
+	my $self = {@_};
+	
+	bless $self, $class;
+	return $self;
+}
+
+# add the Thingy to the queue
+sub add
+{
+	push @queue, shift;
+}
+
+# dispatch Thingies to action it.
+sub process
+{
+	my $t = pop @queue if @queue;
+
+	$t->process if $t;
+}
+
+1;
+
diff --git a/perl/cluster.pl b/perl/cluster.pl
index 6d4dc90f..62227d21 100755
--- a/perl/cluster.pl
+++ b/perl/cluster.pl
@@ -99,6 +99,7 @@ use Mrtg;
 use USDB;
 use UDPMsg;
 use QSL;
+use Thingy;
 
 use Data::Dumper;
 use IO::File;
@@ -126,7 +127,7 @@ $reqreg = 0;					# 1 = registration required, 2 = deregister people
 use vars qw($VERSION $BRANCH $build $branch);
 $VERSION = sprintf( "%d.%03d", q$Revision$ =~ /(\d+)\.(\d+)/ );
 $BRANCH = sprintf( "%d.%03d", q$Revision$ =~ /\d+\.\d+\.(\d+)\.(\d+)/  || (0,0));
-$main::build += 5;				# add an offset to make it bigger than last system
+$main::build += 4;				# add an offset to make it bigger than last system
 $main::build += $VERSION;
 $main::branch += $BRANCH;
 
@@ -558,7 +559,10 @@ for (;;) {
 		DXUser::process();
 		DXDupe::process();
 		AGWMsg::process();
-				
+
+		# this where things really start to happen (in DXSpider 2)
+		Thingy::process();
+		
 		eval { 
 			Local::process();       # do any localised processing
 		};