my @threads;
my $thread;
my $rc;
while (@threads = threads->list()) {
	foreach $thread (@threads) {
		if ($thread->is_joinable()) {
			$rc = $thread->join();
			
			# Send the opcmon
			# $rc->[0] is the return code.
			# $rc->[1] is the nodeName the thread worked on.
			&sendOpcmon($tag, $rc->[0], $rc->[1]);
		}
	}
	
	# To prevent the hard CPU lookups
	sleep(1);
}

#
sub sendRequest {
        require IO::Socket::INET;
        #IO::Socket::INET->import(...);

        my ($msg, $peerAddr, $peerPort) = @_;
	my $eTime = time() + TIMEOUT;
	my $host = (split/\./, $msg)[0];
	
	# configure the socket.
	$MySocket = new IO::Socket::INET->new(	PeerPort => $peerPort,
	        				Proto => 'udp',
	        				PeerAddr => $peerAddr,
	        				);
	ioctl($MySocket, 0x8004667e, pack("I", 1));
	
	# Send the request.
	$MySocket->send($msg);

	# Now we will wait till the server will respond to our request.
	while(time() < $eTime)
	{
		$MySocket->recv($text,128);
		if($text =~ /OK/) {
			return [1, $host];
		}
		
		# Sleep for 2 secs just to free up a %CPU usage
		sleep 2;
	}
	
	# We reached the timeout, probably no response will arrive.
	return [0, $host];
}