--- googlecode.com/svn/trunk/meteord	2008/02/04 21:06:42	47
+++ trunk/meteord	2009/03/28 01:42:07	67
@@ -35,7 +35,7 @@
 # meterod version
 ################################################################################
 	
-	$::VERSION='1.05.04';
+	$::VERSION='1.06.04';
 	$::RELEASE_DATE='not yet released';
 
 ###############################################################################
@@ -44,6 +44,8 @@
 	
 	use strict;
 	
+	use Socket;
+	
 	use Meteor::Syslog;
 	
 	use Meteor::Socket;
@@ -63,6 +65,8 @@
 	our $AGE_CHECK_INTERVALL=60;
 	
 	our $MAX_EXIT_DELAY=120;
+	
+	our $UDP_MAX_MESSAGE_SIZE=8192;
 
 ###############################################################################
 # Main
@@ -112,7 +116,9 @@
 			close(STDERR);
 			chdir("/");
 			umask(0);
+
 			# fork and exit parent
+			print STDERR "Exit: Fork\n";
 			exit if fork;
 			setpgrp(0, $$) if defined $SIG{TTOU};
 			$SIG{TTOU}='ignore' if defined $SIG{TTOU};
@@ -120,10 +126,10 @@
 			# Avoid 'stdin reopened for output' warning with newer perls
 			open(NULL,'/dev/null');
 			<NULL> if(0);
-			
 			open(OUT,">/var/run/$::PGM.pid");
 			print OUT "$$\n";
 			close(OUT);
+
 		}
 		else
 		{
@@ -139,7 +145,8 @@
 	$SIG{'TERM'}=sub{$::TERM=1};
 	$SIG{'USR1'}=sub{$::USR1=1};
 	$SIG{'USR2'}=sub{$::USR2=1};
-	
+	$SIG{'PIPE'}=sub{&::syslog('info',"Signal PIPE received and ignored\n");};
+
 	#
 	# Run server
 	#
@@ -160,9 +167,22 @@
 	);
 	my $subscriberServerFN=$subscriberServer->fileno();
 	
+	my $udpServer=undef;
+	my $udpPort=$::CONF{'UDPPort'};
+	my $udpServerFN=undef;
+	if($udpPort && $udpPort>0)
+	{
+		$udpServer=Meteor::Socket->newUDPServer(
+			$udpPort,
+			$::CONF{'UDPIP'}
+		);
+		$udpServerFN=$udpServer->fileno();
+	}
+	
 	my $serverVector='';
 	vec($serverVector,$controlServerFN,1)=1;
 	vec($serverVector,$subscriberServerFN,1)=1;
+	vec($serverVector,$udpServerFN,1)=1 if(defined($udpServerFN));
 	
 	my $lastAgeCheck=time;
 	
@@ -178,6 +198,8 @@
 		{
 			while(!$::TERM)
 			{
+
+
 				my $rVec=$serverVector;
 				my $wVec='';
 				my $eVec='';
@@ -210,6 +232,10 @@
 					{
 						Meteor::Subscriber->newFromServer($subscriberServer);
 					}
+					if(defined($udpServerFN) && vec($rout,$udpServerFN,1))
+					{
+						&handleUPD($udpServer);
+					}
 					
 					Meteor::Connection->checkAllHandleBits($rout,$wout,$eout);
 				}
@@ -239,7 +265,7 @@
 					
 					Meteor::Channel->clearAllBuffers();
 				}
-				
+
 				if($::USR2)
 				{
 					$::USR2=0;
@@ -248,7 +274,7 @@
 					
 					Meteor::Document->clearDocuments()
 				}
-				
+
 				my $t=time;
 				if($t>$lastAgeCheck+$AGE_CHECK_INTERVALL)
 				{
@@ -258,6 +284,7 @@
 					$t=$lastAgeCheck;
 					
 					Meteor::Subscriber->checkPersistentConnectionsForMaxTime();
+					Meteor::Connection->destroyBadRequests();
 				}
 				
 				if(defined($nextPing) && $nextPing<=$t)
@@ -320,15 +347,44 @@
 		{
 			&::syslog('info',"$cnt client(s) unresponsive, will shutdown anyway");
 			
+			print STDERR "Exit: TERM Shutdown (unresponsive clients)\n";
 			exit(1);
 		}
 		
 		&::syslog('info',"shutdown succeeded");
 		
+		print STDERR "Exit: TERM Shutdown (clean)\n";
 		exit(0);
 	}
 	
 	&::syslog('emerg',"$::PGM loop exited");
 
+###############################################################################
+# Subroutines
+###############################################################################
+sub handleUPD {
+	$udpServer=shift;
+	
+	my $line;
+	my $hispaddr=recv($udpServer->{'handle'},$line,$::UDP_MAX_MESSAGE_SIZE,0);
+	
+	&::syslog('debug',"udp message received: %s",$line);
+	
+	return unless($line=~s/^(\S+)\s//);
+	
+	my $cmd=$1;
+	
+	if($cmd eq 'ADDMESSAGE')
+	{
+		return unless($line=~s/^(\S+)\s//);
+		
+		my $channelName=$1;
+		my $channel=Meteor::Channel->channelWithName($channelName);
+		my $msg=$channel->addMessage($line);
+		my $msgID=$msg->id();
+		&::syslog('debug',"udp: new message added, ID %s",$msgID);
+	}
+}
+
 1;
-############################################################################EOF
\ No newline at end of file
+############################################################################EOF