X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=gosa-si%2Fgosa-si-client;h=5a728fcd3cd3d84c1813f9c229edf4eeb5b5cbf0;hb=06fd60ccdfa1f960ece1310f9d74d6992261ffc0;hp=0fb1c1be64c57c57e7536b2689b29752ce84618e;hpb=48bf0812fc0107d2fdf41df1ff3a77a8d89ce48c;p=gosa.git diff --git a/gosa-si/gosa-si-client b/gosa-si/gosa-si-client index 0fb1c1be6..5a728fcd3 100755 --- a/gosa-si/gosa-si-client +++ b/gosa-si/gosa-si-client @@ -1,7 +1,7 @@ #!/usr/bin/perl #=============================================================================== # -# FILE: gosa-server +# FILE: gosa-si-client # # USAGE: gosa-si-client # @@ -18,8 +18,6 @@ # REVISION: --- #=============================================================================== -my $client_version = '$HeadURL$:$Rev$'; - use strict; use warnings; use Getopt::Long; @@ -37,11 +35,14 @@ use MIME::Base64; use XML::Simple; use File::Basename; use File::Spec; +use Net::ARP; use Fcntl; # Workaround: need pure perl to make it work with UTF-8 :-( $XML::Simple::PREFERRED_PARSER= "XML::SAX::PurePerl"; +my $client_version = '$HeadURL$:$Rev$'; + my $client_headURL; my $client_revision; my $client_status; @@ -58,6 +59,7 @@ my $default_server_key; my @servers; my $gotoHardwareChecksum; my $system_com; +my $servers_string; $verbose= 1; # globalise variables which are used in imported events @@ -72,9 +74,11 @@ our $client_dnsname; our $client_force_hostname; our $server_key; our $terminal_server_hash; +our $opts_dnslookup; + # default variables -our $REGISTERED = 0; +my $REGISTERED = 0; # path to fifo for non-gosa-si-client messages to gosa-si-server my $fai_com_fifo = "/var/run/gosa-si-client.socket"; @@ -112,14 +116,15 @@ my $fai_log_dir = "/var/log/fai"; "nss-config" => [\$nss_config, "/etc/libnss-ldap.conf"], "fai-logpath" => [\$fai_logpath, "/var/log/fai/fai.log"], "force-hostname" => [\$client_force_hostname, "false"], - "system-com" => [\$system_com, "disabled"], + "system-com" => [\$system_com, "disabled"], }, "server" => { - "ip" => [\$server_ip, "127.0.0.1"], + "ip" => [\$servers_string, "127.0.0.1"], "port" => [\$server_port, "20081"], "key" => [\$server_key, ""], "timeout" => [\$server_timeout, 10], - "key-lifetime" => [\$server_key_lifetime, 600], + "key-lifetime" => [\$server_key_lifetime, 600], + "dns-lookup" => [\$opts_dnslookup, "true"], }, ); @@ -174,27 +179,27 @@ sub check_cmdline_param () { sub check_pid { $pid = -1; # Check, if we are already running - if( open(LOCK_FILE, "<$pid_file") ) { - $pid = ; + if( open(my $LOCK_FILE, "<","$pid_file") ) { + $pid = <$LOCK_FILE>; if( defined $pid ) { chomp( $pid ); if( -f "/proc/$pid/stat" ) { my($stat) = `cat /proc/$pid/stat` =~ m/$pid \((.+)\).*/; if( $0 eq $stat ) { - close( LOCK_FILE ); + close($LOCK_FILE); exit -1; } } } - close( LOCK_FILE ); + close( $LOCK_FILE ); unlink( $pid_file ); } # create a syslog msg if it is not to possible to open PID file if (not sysopen(LOCK_FILE, $pid_file, O_WRONLY|O_CREAT|O_EXCL, 0644)) { my($msg) = "Couldn't obtain lockfile '$pid_file' "; - if (open(LOCK_FILE, '<', $pid_file) - && ($pid = )) + if (open(my $LOCK_FILE, '<', $pid_file) + && ($pid = <$LOCK_FILE>)) { chomp($pid); $msg .= "(PID $pid)\n"; @@ -260,7 +265,12 @@ sub daemon_log { $monthday = $monthday < 10 ? $monthday = "0".$monthday : $monthday; $year+=1900; - my $log_msg = "$month $monthday $hours:$minutes:$seconds $prg $msg\n"; + # Microseconds since epoch + my $microSeconds = sprintf("%.2f", &Time::HiRes::clock_gettime()); + $microSeconds =~ s/^\d*(.\d\d)$/$1/; + + + my $log_msg = "$month $monthday $hours:$minutes:$seconds$microSeconds $prg $msg\n"; print LOG_HANDLE $log_msg; if( $foreground ) { print STDERR $log_msg; @@ -292,25 +302,12 @@ sub get_mac { $result = "00:00:00:00:00:00"; } } else { - my $SIOCGIFHWADDR= 0x8927; # man 2 ioctl_list - # A configured MAC Address should always override a guessed value if ($client_mac_address and length($client_mac_address) > 0 and not($client_mac_address eq "00:00:00:00:00:00")) { $result= $client_mac_address; } else { - socket SOCKET, PF_INET, SOCK_DGRAM, getprotobyname('ip') - or die "socket: $!"; - - if(ioctl SOCKET, $SIOCGIFHWADDR, $ifreq) { - my ($if, $mac)= unpack 'h36 H12', $ifreq; - - if (length($mac) > 0) { - $mac=~ m/^([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])$/; - $mac= sprintf("%s:%s:%s:%s:%s:%s", $1, $2, $3, $4, $5, $6); - $result = $mac; - } - } + $result = Net::ARP::get_mac($ifreq); } } } @@ -341,12 +338,12 @@ sub get_local_mac_for_remote_ip { if($server_ip =~ /^(\d\d?\d?\.){3}\d\d?\d?$/) { my $PROC_NET_ROUTE= ('/proc/net/route'); - open(PROC_NET_ROUTE, "<$PROC_NET_ROUTE") + open(my $PROC_NET_ROUTE, "<","$PROC_NET_ROUTE") or die "Could not open $PROC_NET_ROUTE"; - my @ifs = ; + my @ifs = <$PROC_NET_ROUTE>; - close(PROC_NET_ROUTE); + close($PROC_NET_ROUTE); # Eat header line shift @ifs; @@ -377,6 +374,12 @@ sub generate_hw_digest { foreach my $line (split /\n/, `cat /proc/bus/pci/devices`) { $hw_data.= sprintf "%s", $line =~ /[^\s]+\s([^\s]+)\s.*/; } + # linux-vserver has no /proc/bus/pci/devices + if ( !$hw_data ) { + foreach my $line (split /\n/, `ifconfig | grep HWaddr`) { + $hw_data.= sprintf "%s", $line =~ /[^\s]+\s([^\s]+)\s.*/; + } + } return(md5_base64($hw_data)); } @@ -439,6 +442,12 @@ sub send_msg_hash_to_target { return $error; } +sub _setREGISTERED { + my $newStatus = shift; + &daemon_log("DEBUG: set REGISTERED flag from '$REGISTERED' to '$newStatus'", 7); + $REGISTERED = $newStatus; + return; +} sub send_msg_to_target { my ($msg, $address, $encrypt_key, $msg_header) = @_ ; @@ -459,7 +468,7 @@ sub send_msg_to_target { if( !$socket ) { daemon_log("WARNING: cannot send ".$msg_header."msg to '$address', host not reachable", 3); if ($REGISTERED == 1) { - $REGISTERED = 0; # if server is not available, cause reregistering + &_setREGISTERED(0); # if server is not available, cause reregistering daemon_log("INFO: cause reregistering at gosa-si-server", 5); $global_kernel->yield('register_at_gosa_si_server'); @@ -500,13 +509,13 @@ sub write_to_file { chomp($string); - if (open(FILE, ">> $file")){ - print FILE $string."\n"; - close(FILE); + if (open(my $FILE, ">>", "$file")){ + print $FILE $string."\n"; + close($FILE); } } - return; + return; } @@ -536,35 +545,35 @@ sub open_socket { # DESCRIPTION: #=============================================================================== sub register_at_gosa_si_server { - my ($kernel) = $_[KERNEL]; - my $try_to_register = 0; - - # if client is already registered, stop registration process - if ($REGISTERED) { - $kernel->delay('register_at_gosa_si_server'); + my ($kernel) = $_[KERNEL]; + my $try_to_register = 0; - # client is not registered, start registration process + if ($REGISTERED) { + # Client is already registered, clear all other registration events + $kernel->delay('register_at_gosa_si_server'); } else { - # clear all other triggered events and wait till registration was successful - $kernel->delay('trigger_new_key'); + # Client is not registered, start registration process + # Clear all other events and wait till registration was successful + $kernel->delay('register_at_gosa_si_server'); + $kernel->delay('trigger_new_key'); - # create new passwd and ciphering object for client-server communication - $server_key = &create_passwd(); + # Create new passwd and ciphering object for client-server communication + $server_key = &create_passwd(); - my $events = join( ",", keys %{$event_hash} ); - while(1) { - $try_to_register++; + my $events = join( ",", keys %{$event_hash} ); + while(1) { + $try_to_register++; - # after one complete round through all server, stop trying to register - if( $try_to_register > @servers ) { last; } + # after one complete round through all server, stop trying to register + if( $try_to_register > @servers ) { last; } - # fetch first gosa-si-server from @servers - # append shifted gosa-si-server at the end of @servers, so looking for servers never stop if - # a registration never occured - my $server = shift(@servers); - push( @servers, $server ); + # fetch first gosa-si-server from @servers + # append shifted gosa-si-server at the end of @servers, so looking for servers never stop if + # a registration never occured + my $server = shift(@servers); + push( @servers, $server ); - # Check if our ip is resolvable - if not: don't try to register + # Check if $server is a valid server address if(!(defined($server) && $server =~ m/^[0-9\.]*?:.*$/)) { &main::daemon_log("ERROR: Server with address '".defined($server)?$server:""."' is invalid!", 1); if (length(@servers) == 1) { @@ -573,30 +582,30 @@ sub register_at_gosa_si_server { } } - # Check if our ip is resolvable - if not: don't try to register - my $ip= &get_local_ip_for_remote_ip(sprintf("%s", $server =~ /^([0-9\.]*?):.*$/)); - my $dnsname= gethostbyaddr(inet_aton($ip), AF_INET); - if(!defined($dnsname)) { - if( defined($client_force_hostname) && $client_force_hostname eq "true") { - $dnsname = `hostname`; - } else { - &write_to_file("goto-error-dns:$ip", $fai_logpath); - &main::daemon_log("ERROR: ip is not resolvable, no registration possible. Write 'goto-error-dns:$ip' to $fai_logpath", 1); - exit(1); - } - } + # Check if our ip is resolvable - if not: don't try to register + my $ip= &get_local_ip_for_remote_ip(sprintf("%s", $server =~ /^([0-9\.]*?):.*$/)); + my $dnsname= gethostbyaddr(inet_aton($ip), AF_INET); + if(!defined($dnsname)) { + if( defined($client_force_hostname) && $client_force_hostname eq "true") { + $dnsname = `hostname`; + } else { + &write_to_file("goto-error-dns:$ip", $fai_logpath); + &main::daemon_log("ERROR: ip is not resolvable, no registration possible. Write 'goto-error-dns:$ip' to $fai_logpath", 1); + exit(1); + } + } - # create registration msg + # create registration msg my $local_ip = &get_local_ip_for_remote_ip(sprintf("%s", $server =~ /^([0-9\.]*?):.*$/)); my $local_mac = &get_local_mac_for_remote_ip(sprintf("%s", $server =~ /^([0-9\.]*?):.*$/)); my $register_hash = &create_xml_hash("here_i_am", $local_ip.":".$client_port, $server); &add_content2xml_hash($register_hash, "new_passwd", $server_key); &add_content2xml_hash($register_hash, "mac_address", $local_mac); &add_content2xml_hash($register_hash, "events", $events); - &add_content2xml_hash($register_hash, "client_status", $client_status); - &add_content2xml_hash($register_hash, "client_revision", $client_revision); + &add_content2xml_hash($register_hash, "client_status", $client_status); + &add_content2xml_hash($register_hash, "client_revision", $client_revision); &add_content2xml_hash($register_hash, "gotoHardwareChecksum", $gotoHardwareChecksum); - &add_content2xml_hash($register_hash, "key_lifetime", $server_key_lifetime); + &add_content2xml_hash($register_hash, "key_lifetime", $server_key_lifetime); # Add $HOSTNAME from ENV if force-hostname is set if( defined($client_force_hostname) && $client_force_hostname eq "true") { @@ -607,45 +616,45 @@ sub register_at_gosa_si_server { } } - # send xml hash to server with general server passwd + # send xml hash to server with general server passwd my $res = &send_msg_hash_to_target($register_hash, $server, $default_server_key); - # if delivery of registration msg succeed + # if delivery of registration msg succeed if($res eq "0") { - # reset try_to_register + # reset try_to_register $try_to_register = 0; - # Set fixed client address and mac address + # Set fixed client address and mac address $client_ip= &get_local_ip_for_remote_ip(sprintf("%s", $server =~ /^([0-9\.]*?):.*$/)); $client_address= "$client_ip:$client_port"; $client_mac_address = $local_mac; $client_dnsname = $dnsname; - last; + last; - # delivery of registration msg failed + # delivery of registration msg failed } else { - # wait 1 sec until trying to register again + # wait 1 sec until trying to register again sleep(1); next; } - } # end of while - # one circle through all servers finished and no registration succeed - if ( $try_to_register >= @servers ) { + } # end of while + + if ( $try_to_register >= @servers ) { + # One circle through all servers finished and no registration succeed &write_to_file("gosa-si-no-server-available", $fai_logpath); - $kernel->delay_set('register_at_gosa_si_server', $delay_set_time); - - # delivery of registraion msg succeed, waiting for server response - } else { + } else { + # Delivery of registraion msg succeed, waiting for server response daemon_log("INFO: waiting for msg 'register_at_gosa_si_server'",5); - $kernel->delay_set('register_at_gosa_si_server', $delay_set_time); - # clear old settings and set it again + # Clear old settings and set it again $kernel->delay('trigger_new_key'); $kernel->delay_set('trigger_new_key', $server_key_lifetime); - } + } - } - return; + # Set waiting time for 'register_at_gosa_si_server'-event + $kernel->delay_set('register_at_gosa_si_server', $delay_set_time); + } + return; } @@ -823,9 +832,9 @@ sub trigger_seen_messages { # Check if file has 'seen' tag foreach my $goto_file (@goto_files) { - open(FILE, "$goto_dir/$goto_file"); - my @lines = ; - close FILE; + open(my $FILE, "$goto_dir/$goto_file"); + my @lines = <$FILE>; + close($FILE); my $source; my $target; @@ -989,9 +998,9 @@ sub save_fai_log { next; } - open(FILE, "<$log_file"); - my @lines = ; - close (FILE); + open(my $FILE, "<","$log_file"); + my @lines = <$FILE> ; + close ($FILE); my $log_string = join("", @lines); $log .= &encode_base64($log_string); push(@log_list, $log); @@ -1061,17 +1070,15 @@ sub server_input { if( (!$msg) || (!$msg_hash) ) { daemon_log("WARNING: Deciphering of incoming msg failed", 3); if($server_address =~ /$remote_ip/) { - # got a msg from gosa-si-server which can not be decrypted, may the secrete not up-to-date + # Got a msg from gosa-si-server which can not be decrypted, the secrete is not up-to-date # cause a reregistering with a new secrete handshake - daemon_log("WARNING: Message from gosa-si-server could not be understood, cause reregistering at server", 3); - - # if client is alread in a registration process, that means not registered, do nothing - # if not, cause re-registration - if (not $REGISTERED) { - &daemon_log("WARNING: gosa-si-client is already in a registration process so ignore this message", 3); - } else { - $REGISTERED = 0; + daemon_log("ERROR: Message from gosa-si-server could not be understood, cause reregistering at server", 1); + if ($REGISTERED) { + daemon_log("INFO: Client has currently status registered so throw new registering event", 5); + &_setREGISTERED(0); $kernel->post('client_session', 'register_at_gosa_si_server'); + } else { + daemon_log("INFO: Client is currently within a registration process so wait for the next registration itteration", 5); } } $error++; @@ -1113,34 +1120,101 @@ sub post_processing_and_sending # Check gosa-si envelope validity my $answer_hash = &check_outgoing_xml_validity($answer); - if( $answer_hash ) - { - # Answer is valid - # Pre-sending - if( $answer =~ "
registered
") - { - # Set registered flag to true to stop sending further registered msgs - $REGISTERED = 1; - } - else - { - $answer =~ /
(\S+)<\/header>/; - &send_msg_to_target($answer, $server_address, $server_key, $1); - } - - # Post-sending - if( $answer =~ "
new_key
") - { - # Set new key to global variable - $answer =~ /(\S*?)<\/new_key>/; - my $new_key = $1; - $server_key = $new_key; - } - } - + # If answer is valid go ahead + if( not defined $answer_hash ) { return; } + + # Sending + $answer =~ /
(\S+)<\/header>/; + &send_msg_to_target($answer, $server_address, $server_key, $1); + return; } +sub find_servers { + # add gosa-si-server address from config file at first position of server list + my $server_check_cfg = Config::IniFiles->new( -file => $cfg_file ); + + # Parse servers string + my @conf_servers = split(',', $servers_string); + + # Now search for fallback servers in the configuration + foreach my $cur_server (@conf_servers) { + # Remove spaces from the IP + $cur_server =~ s/\s//g; + + my $ip = $cur_server; + if(not $cur_server =~ /^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/) { + my $ip_address = inet_ntoa(scalar gethostbyname($ip)); + if(defined($ip_address) && $ip_address =~ /^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/) { + # Write ip address to $server_ip variable + $ip = $ip_address; + } + } + + my $server_addr = sprintf("%s:%s", $ip, $server_port); + if (not grep { $_ eq $server_addr } @servers) { + push(@servers, $server_addr); + } + } + + my $servers_string = join(", ", @servers); + daemon_log("INFO: found servers in configuration file: $servers_string", 1); + + # Last but not least search for fallback servers in the DNS + if (defined($opts_dnslookup) and $opts_dnslookup eq "true") { + my @tmp_servers; + if ( !$server_domain) { + # Try our DNS Searchlist + my @domain_list = &get_dns_domains(); + my $tmp_domains; + my $error_string; + for my $domain (@domain_list) { + chomp($domain); + ($tmp_domains, $error_string) = &get_server_addresses($domain); + if(@$tmp_domains) { + for my $tmp_server(@$tmp_domains) { + push @tmp_servers, $tmp_server; + } + } + } + + if (0 == @tmp_servers) { + daemon_log("INFO: No servers found in DNS.", 1); + } + else { + my $servers_string = join(", ", @tmp_servers); + daemon_log("INFO: found servers in DNS: $servers_string", 1); + } + } else { + @tmp_servers = &get_server_addresses($server_domain); + if( 0 == @tmp_servers ) { + daemon_log("INFO: No servers found in DNS for domain '$server_domain'",1); + } + } + + if ( 0 != @tmp_servers ) { + foreach my $server_addr (@tmp_servers) { + if (not grep { $_ eq $server_addr } @servers) { + push(@servers, $server_addr); + } + } + } + } + + if (0 == scalar(@servers)) { + daemon_log("ERROR: No servers found in the configuration or DNS.", 1); + exit(1); + } + + # Define first server as server_ip + $server_ip = $servers[0]; + + # prepare variables + if( inet_aton($server_ip) ){ $server_ip = inet_ntoa(inet_aton($server_ip)); } + if (defined $server_ip && defined $server_port) { + $server_address = $server_ip.":".$server_port; + } +} #==== MAIN = main ============================================================== # parse commandline options @@ -1176,9 +1250,9 @@ if( ! $foreground ) { # Do something useful - put our PID into the pid_file if( 0 != $pid ) { - open( LOCK_FILE, ">$pid_file" ); - print LOCK_FILE "$pid\n"; - close( LOCK_FILE ); + open( my $LOCK_FILE, ">", "$pid_file" ); + print $LOCK_FILE "$pid\n"; + close( $LOCK_FILE ); if( !$foreground ) { exit( 0 ) }; @@ -1240,7 +1314,6 @@ foreach my $log_line (@$result) { $gotoHardwareChecksum= &generate_hw_digest(); daemon_log("INFO: gotoHardwareChecksum detected: $gotoHardwareChecksum", 1); - # create socket for incoming xml messages POE::Component::Server::TCP->new( Alias => 'gosa-si-client', @@ -1249,73 +1322,21 @@ POE::Component::Server::TCP->new( ); daemon_log("INFO: start socket for incoming xml messages at port '$client_port' ", 1); - -# prepare variables -if( inet_aton($server_ip) ){ $server_ip = inet_ntoa(inet_aton($server_ip)); } -if (defined $server_ip && defined $server_port) { - $server_address = $server_ip.":".$server_port; -} $xml = new XML::Simple(); $default_server_key = $server_key; -# add gosa-si-server address from config file at first position of server list -my $server_check_cfg = Config::IniFiles->new( -file => $cfg_file ); -my $server_check = (defined($server_check_cfg))?$server_check_cfg->val( "server", "ip"):undef; -if( defined $server_check ) { - unshift(@servers, $server_address); - my $servers_string = join(", ", @servers); - daemon_log("INFO: found servers in configuration file: $servers_string", 1); -} else { - my @tmp_servers; - if ( !$server_domain) { - # Try our DNS Searchlist - my @domain_list = &get_dns_domains(); - my $tmp_domains; - my $error_string; - for my $domain (@domain_list) { - chomp($domain); - ($tmp_domains, $error_string) = &get_server_addresses($domain); - if(@$tmp_domains) { - for my $tmp_server(@$tmp_domains) { - push @tmp_servers, $tmp_server; - } - } - } - if (0 == @tmp_servers) { - my $log_string = "no gosa-si-server found!"; - $log_string .= "\n\tdetermined domains out of /etc/resolv.conf: ".join(", ", @domain_list) if (@domain_list); - $log_string .= "\n\tdetermined server addresses in domains: ".join(", ",@$tmp_domains) if (defined($tmp_domains)); - daemon_log("ERROR: $log_string", 1) if (defined($log_string)); - daemon_log("ERROR: $error_string", 1) if (defined($error_string)); - daemon_log("ERROR: please specify a gosa-si-server address or a domain in config file", 1); - kill 2, $$; - } - } else { - @tmp_servers = &get_server_addresses($server_domain); - if( 0 == @tmp_servers ) { - daemon_log("ERROR: no gosa-si-server found in DNS for domain '$server_domain'",1); - daemon_log("ERROR: please specify a gosa-si-server address or a domain in config file", 1); - kill 2, $$; - } - } - - foreach my $server (@tmp_servers) { - unshift(@servers, $server); - } - my $servers_string = join(", ", @servers); - daemon_log("INFO: found servers in DNS: $servers_string", 1); -} - - # Open a new fifo for FAI messages to gosa-si-server if (-p $fai_com_fifo) { unlink $fai_com_fifo } -POSIX::mkfifo("$fai_com_fifo", "0600"); +POSIX::mkfifo("$fai_com_fifo", 0600); + +# Find servers from config and DNS +&find_servers; # Open a new fifo for system communication, if (-p $system_com_fifo) { unlink $system_com_fifo } if ($system_com eq "enabled") { - POSIX::mkfifo("$system_com_fifo", "0600"); + POSIX::mkfifo("$system_com_fifo", 0600); } POE::Session->create(