--- googlecode.com/svn/trunk/meteord	2008/02/03 23:10:24	42
+++ googlecode.com/svn/trunk/meteord	2008/02/04 22:30:35	49
@@ -35,7 +35,8 @@
 # meterod version
 ################################################################################
 	
-	$::VERSION='1.05.01';
+	$::VERSION='1.05.06';
+	$::RELEASE_DATE='not yet released';
 
 ###############################################################################
 # Configuration
@@ -43,6 +44,8 @@
 	
 	use strict;
 	
+	use Socket;
+	
 	use Meteor::Syslog;
 	
 	use Meteor::Socket;
@@ -62,6 +65,8 @@
 	our $AGE_CHECK_INTERVALL=60;
 	
 	our $MAX_EXIT_DELAY=120;
+	
+	our $UDP_MAX_MESSAGE_SIZE=8192;
 
 ###############################################################################
 # Main
@@ -101,7 +106,9 @@
 	{
 		$0="$::PGM daemon";
 		
-		unless($::CONF{'Debug'})
+		my $facility=$::CONF{'SyslogFacility'} || $Meteor::Syslog::DEFAULT_FACILITY;
+		
+		unless($::CONF{'Debug'} || $facility eq 'none')
 		{
 			# close standard file descriptors
 			close(STDIN);
@@ -124,7 +131,7 @@
 		}
 		else
 		{
-			print "$::PGM PID: $$\n";
+			&::syslog('info',"PID\t%s",$$);
 		}
 	}
 	
@@ -157,9 +164,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,11 +198,11 @@
 				my $rVec=$serverVector;
 				my $wVec='';
 				my $eVec='';
-		
+			
 				my $rout;
 				my $wout;
 				my $eout;
-		
+			
 				Meteor::Connection->addAllHandleBits(\$rVec,\$wVec,\$eVec);
 				
 				my $timeout=$MAIN_LOOP_TIMEOUT;
@@ -207,6 +227,10 @@
 					{
 						Meteor::Subscriber->newFromServer($subscriberServer);
 					}
+					if(defined($udpServerFN) && vec($rout,$udpServerFN,1))
+					{
+						&handleUPD($udpServer);
+					}
 					
 					Meteor::Connection->checkAllHandleBits($rout,$wout,$eout);
 				}
@@ -327,5 +351,32 @@
 	
 	&::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