X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=gosa-si%2Fmodules%2FArpHandler.pm;h=210e95654f4e0231a4f6888c3a3f46d351925232;hb=850ef70d7d016480405e610bd698a4b0ffc8d6c7;hp=d4e70eaff59c7ef21ac837a88c822d42d8880e70;hpb=d00ed68a8d2735452cbd94344723d4e7e972e9be;p=gosa.git diff --git a/gosa-si/modules/ArpHandler.pm b/gosa-si/modules/ArpHandler.pm index d4e70eaff..210e95654 100644 --- a/gosa-si/modules/ArpHandler.pm +++ b/gosa-si/modules/ArpHandler.pm @@ -14,9 +14,11 @@ use Net::LDAP::Entry; use Net::DNS; use Switch; use Data::Dumper; +use Socket; # Don't start if some of the modules are missing my $start_service=1; +my $lookup_vendor=1; BEGIN{ unless(eval('use Socket qw(PF_INET SOCK_DGRAM inet_ntoa sockaddr_in)')) { $start_service=0; @@ -24,38 +26,76 @@ BEGIN{ unless(eval('use POE qw(Component::Pcap Component::ArpWatch)')) { $start_service=0; } + unless(eval('use Net::MAC::Vendor')) { + $lookup_vendor=0; + } } END{} my ($timeout, $mailto, $mailfrom, $user, $group); -my %daemon_children; -my ($ldap, $bind_phrase, $password, $ldap_base, $interface) ; +my ($arp_enabled, $arp_interface, $arp_update, $ldap_uri, $ldap_base, $ldap_admin_dn, $ldap_admin_password); my $hosts_database={}; -my $resolver=Net::DNS::Resolver->new; +my $ldap; + +my %cfg_defaults = +( + "ArpHandler" => { + "enabled" => [\$arp_enabled, "true"], + "interface" => [\$arp_interface, "all"], + "update-entries" => [\$arp_update, "false"], + }, + "server" => { + "ldap-uri" => [\$ldap_uri, ""], + "ldap-base" => [\$ldap_base, ""], + "ldap-admin-dn" => [\$ldap_admin_dn, ""], + "ldap-admin-password" => [\$ldap_admin_password, ""], + }, +); -$ldap_base = "dc=gonicus,dc=de" ; -$interface = "eth1"; +#=== FUNCTION ================================================================ +# NAME: read_configfile +# PARAMETERS: cfg_file - string - +# RETURNS: nothing +# DESCRIPTION: read cfg_file and set variables +#=============================================================================== +sub local_read_configfile { + my $cfg; + if( defined( $main::cfg_file) && ( (-s $main::cfg_file) > 0 )) { + if( -r $main::cfg_file ) { + $cfg = Config::IniFiles->new( -file => $main::cfg_file ); + } else { + print STDERR "Couldn't read config file!"; + } + } else { + $cfg = Config::IniFiles->new() ; + } + foreach my $section (keys %cfg_defaults) { + foreach my $param (keys %{$cfg_defaults{ $section }}) { + my $pinfo = $cfg_defaults{ $section }{ $param }; + ${@$pinfo[0]} = $cfg->val( $section, $param, @$pinfo[1] ); + } + } +} sub get_module_info { - my @info = (undef, - undef, - undef, - undef, - "socket", - ); + my @info = (undef, undef); + &local_read_configfile(); # Don't start if some of the modules are missing - if($start_service) { - eval { - $ldap = Net::LDAP->new("ldap.intranet.gonicus.de"); - }; - if (!$ldap) { - &main::daemon_log("Could not connect to LDAP Server!\n$@", 1); + if(($arp_enabled eq 'true') && $start_service) { + if($lookup_vendor) { + eval("Net::MAC::Vendor::load_cache('file:///usr/lib/gosa-si/modules/oui.txt')"); + if($@) { + &main::daemon_log("Loading OUI cache file failed! MAC Vendor lookup disabled", 1); + $lookup_vendor=0; + } else { + &main::daemon_log("Loading OUI cache file suceeded!", 6); + } } # When interface is not configured (or 'all'), start arpwatch on all possible interfaces - if ((!defined($interface)) || $interface eq 'all') { + if ((!defined($arp_interface)) || $arp_interface eq 'all') { foreach my $device(&get_interfaces) { # TODO: Need a better workaround for IPv4-to-IPv6 bridges if($device =~ m/^sit\d+$/) { @@ -80,7 +120,7 @@ sub get_module_info { } } } else { - foreach my $device(split(/[\s,]+/, $interface)) { + foreach my $device(split(/[\s,]+/, $arp_interface)) { &main::daemon_log("Starting ArpWatch on $device", 1); POE::Session->create( inline_states => { @@ -95,6 +135,8 @@ sub get_module_info { ); } } + } else { + &main::daemon_log("ArpHandler disabled. Not starting any capture processes"); } return \@info; } @@ -126,46 +168,65 @@ sub got_packet { my $capture_device = sprintf "%s", $kernel->alias_list($sender) =~ /^arp_watch_(.*)$/; - if(!exists($hosts_database->{$packet->{source_haddr}})) { - my $dnsresult= $resolver->search($packet->{source_ipaddr}); - my $dnsname= (defined($dnsresult))?$dnsresult->{answer}[0]->{ptrdname}:$packet->{source_ipaddr}; + my $ldap_handle = &main::get_ldap_handle(); + if(!exists($hosts_database->{$packet->{source_haddr}})) { + my $dnsname= gethostbyaddr(inet_aton($packet->{source_ipaddr}), AF_INET) || $packet->{source_ipaddr}; my $ldap_result=&get_host_from_ldap($packet->{source_haddr}); - if(exists($ldap_result->{dn})) { + if(exists($ldap_result->{dn}) and $arp_update eq "true") { $hosts_database->{$packet->{source_haddr}}=$ldap_result; + $hosts_database->{$packet->{source_haddr}}->{dnsname}= $dnsname; if(!exists($ldap_result->{ipHostNumber})) { $hosts_database->{$packet->{source_haddr}}->{ipHostNumber}=$packet->{source_ipaddr}; } else { if(!($ldap_result->{ipHostNumber} eq $packet->{source_ipaddr})) { &main::daemon_log( "Current IP Address ".$packet->{source_ipaddr}. - " of host ".$ldap_result->{dnsname}. + " of host ".$hosts_database->{$packet->{source_haddr}}->{dnsname}. " differs from LDAP (".$ldap_result->{ipHostNumber}.")", 4); } } $hosts_database->{$packet->{source_haddr}}->{dnsname}=$dnsname; - &main::daemon_log("Host was found in LDAP as ".$ldap_result->{dn}, 6); + &main::daemon_log("Host was found in LDAP as ".$ldap_result->{dn}, 8); } else { $hosts_database->{$packet->{source_haddr}}={ macAddress => $packet->{source_haddr}, ipHostNumber => $packet->{source_ipaddr}, dnsname => $dnsname, + cn => (($dnsname =~ /^(\d){1,3}\.(\d){1,3}\.(\d){1,3}\.(\d){1,3}/) ? $dnsname : sprintf "%s", $dnsname =~ /([^\.]+)\./), + macVendor => (($lookup_vendor) ? &get_vendor_for_mac($packet->{source_haddr}) : "Unknown Vendor"), }; - &main::daemon_log("Host was not found in LDAP (".($hosts_database->{$packet->{source_haddr}}->{dnsname}).")",6); + &main::daemon_log("A DEBUG: Host was not found in LDAP (".($hosts_database->{$packet->{source_haddr}}->{dnsname}).")",522); &main::daemon_log( - "New Host ".($hosts_database->{$packet->{source_haddr}}->{dnsname}). + "A INFO: New Host ".($hosts_database->{$packet->{source_haddr}}->{dnsname}). ": ".$hosts_database->{$packet->{source_haddr}}->{ipHostNumber}. - "/".$hosts_database->{$packet->{source_haddr}}->{macAddress},4); + "/".$hosts_database->{$packet->{source_haddr}}->{macAddress},5); + &add_ldap_entry( + $ldap_handle, + $ldap_base, + $hosts_database->{$packet->{source_haddr}}->{macAddress}, + 'new-system', + $hosts_database->{$packet->{source_haddr}}->{ipHostNumber}, + 'interface', + $hosts_database->{$packet->{source_haddr}}->{macVendor}); } $hosts_database->{$packet->{source_haddr}}->{device}= $capture_device; } else { - if(!($hosts_database->{$packet->{source_haddr}}->{ipHostNumber} eq $packet->{source_ipaddr})) { + if(($arp_update eq "true") and !($hosts_database->{$packet->{source_haddr}}->{ipHostNumber} eq $packet->{source_ipaddr})) { &main::daemon_log( - "IP Address change of MAC ".$packet->{source_haddr}. + "A INFO: IP Address change of MAC ".$packet->{source_haddr}. ": ".$hosts_database->{$packet->{source_haddr}}->{ipHostNumber}. - "->".$packet->{source_ipaddr}, 4); + "->".$packet->{source_ipaddr}, 5); $hosts_database->{$packet->{source_haddr}}->{ipHostNumber}= $packet->{source_ipaddr}; + &change_ldap_entry( + $ldap_handle, + $ldap_base, + $hosts_database->{$packet->{source_haddr}}->{macAddress}, + 'ip-changed', + $hosts_database->{$packet->{source_haddr}}->{ipHostNumber}, + ); + } - &main::daemon_log("Host already in cache (".($hosts_database->{$packet->{source_haddr}}->{device})."->".($hosts_database->{$packet->{source_haddr}}->{dnsname}).")",6); + &main::daemon_log("Host already in cache (".($hosts_database->{$packet->{source_haddr}}->{device})."->".($hosts_database->{$packet->{source_haddr}}->{dnsname}).")",8); } } @@ -173,68 +234,41 @@ sub get_host_from_ldap { my $mac=shift; my $result={}; - my $ldap_result= search_ldap_entry( - $ldap, - $ldap_base, - "(|(macAddress=$mac)(dhcpHWAddress=ethernet $mac))" - ); - - if(defined($ldap_result) && $ldap_result->count==1) { - if(exists($ldap_result->{entries}[0]) && - exists($ldap_result->{entries}[0]->{asn}->{objectName}) && - exists($ldap_result->{entries}[0]->{asn}->{attributes})) { - - for my $attribute(@{$ldap_result->{entries}[0]->{asn}->{attributes}}) { - if($attribute->{type} eq 'cn') { - $result->{cn} = $attribute->{vals}[0]; - } - if($attribute->{type} eq 'macAddress') { - $result->{macAddress} = $attribute->{vals}[0]; - } - if($attribute->{type} eq 'dhcpHWAddress') { - $result->{dhcpHWAddress} = $attribute->{vals}[0]; - } - if($attribute->{type} eq 'ipHostNumber') { - $result->{ipHostNumber} = $attribute->{vals}[0]; + my $ldap_handle = &main::get_ldap_handle(); + if(defined($ldap_handle)) { + my $ldap_result= &search_ldap_entry( + $ldap_handle, + $ldap_base, + "(|(macAddress=$mac)(dhcpHWAddress=ethernet $mac))" + ); + + if(defined($ldap_result) && $ldap_result->count==1) { + if(exists($ldap_result->{entries}[0]) && + exists($ldap_result->{entries}[0]->{asn}->{objectName}) && + exists($ldap_result->{entries}[0]->{asn}->{attributes})) { + + for my $attribute(@{$ldap_result->{entries}[0]->{asn}->{attributes}}) { + if($attribute->{type} eq 'cn') { + $result->{cn} = $attribute->{vals}[0]; + } + if($attribute->{type} eq 'macAddress') { + $result->{macAddress} = $attribute->{vals}[0]; + } + if($attribute->{type} eq 'dhcpHWAddress') { + $result->{dhcpHWAddress} = $attribute->{vals}[0]; + } + if($attribute->{type} eq 'ipHostNumber') { + $result->{ipHostNumber} = $attribute->{vals}[0]; + } } } + $result->{dn} = $ldap_result->{entries}[0]->{asn}->{objectName}; } - $result->{dn} = $ldap_result->{entries}[0]->{asn}->{objectName}; } return $result; } -#=== FUNCTION ================================================================ -# NAME: get_interfaces -# PARAMETERS: none -# RETURNS: (list of interfaces) -# DESCRIPTION: Uses proc fs (/proc/net/dev) to get list of interfaces. -#=============================================================================== -sub get_interfaces { - my @result; - my $PROC_NET_DEV= ('/proc/net/dev'); - - open(PROC_NET_DEV, "<$PROC_NET_DEV") - or die "Could not open $PROC_NET_DEV"; - - my @ifs = ; - - close(PROC_NET_DEV); - - # Eat first two line - shift @ifs; - shift @ifs; - - chomp @ifs; - foreach my $line(@ifs) { - my $if= (split /:/, $line)[0]; - $if =~ s/^\s+//; - push @result, $if; - } - - return @result; -} #=== FUNCTION ================================================================ # NAME: get_mac @@ -268,6 +302,21 @@ sub get_mac { return $result; } +sub get_vendor_for_mac { + my $mac=shift; + my $result="Unknown Vendor"; + + if(defined($mac)) { + my $vendor= Net::MAC::Vendor::fetch_oui_from_cache(Net::MAC::Vendor::normalize_mac($mac)); + if(length($vendor) > 0) { + $result= @{$vendor}[0]; + } + &main::daemon_log("A INFO: Looking up Vendor for MAC ".$mac.": $result", 5); + } + + return $result; +} + #=== FUNCTION ================================================================ # NAME: add_ldap_entry # PURPOSE: adds an element to ldap-tree @@ -276,46 +325,49 @@ sub get_mac { # DESCRIPTION: ???? # THROWS: no exceptions # COMMENTS: none -# SEE ALSO: n/a +# SEE ALSO: n/a/bin #=============================================================================== -#sub add_ldap_entry { -# my ($ldap_tree, $ldap_base, $mac, $gotoSysStatus, $ip, $interface, $desc) = @_; -# my $dn = "cn=$mac,ou=incoming,$ldap_base"; -# my $s_res = &search_ldap_entry($ldap_tree, $ldap_base, "(|(macAddress=$mac)(dhcpHWAddress=ethernet $mac))"); -# my $c_res = $s_res->count; -# if($c_res == 1) { -# daemon_log("WARNING: macAddress $mac already in LDAP", 1); -# return; -# } elsif($c_res > 0) { -# daemon_log("ERROR: macAddress $mac exists $c_res times in LDAP", 1); -# return; -# } -# -# # create LDAP entry -# my $entry = Net::LDAP::Entry->new( $dn ); -# $entry->dn($dn); -# $entry->add("objectClass" => "goHard"); -# $entry->add("cn" => $mac); -# $entry->add("macAddress" => $mac); -# if(defined $gotoSysStatus) {$entry->add("gotoSysStatus" => $gotoSysStatus)} -# if(defined $ip) {$entry->add("ipHostNumber" => $ip) } -# #if(defined $interface) { } -# if(defined $desc) {$entry->add("description" => $desc) } -# -# # submit entry to LDAP -# my $result = $entry->update ($ldap_tree); -# -# # for $result->code constants please look at Net::LDAP::Constant -# my $log_time = localtime( time ); -# if($result->code == 68) { # entry already exists -# daemon_log("WARNING: $log_time: $dn ".$result->error, 3); -# } elsif($result->code == 0) { # everything went fine -# daemon_log("$log_time: add entry $dn to ldap", 1); -# } else { # if any other error occur -# daemon_log("ERROR: $log_time: $dn, ".$result->code.", ".$result->error, 1); -# } -# return; -#} +sub add_ldap_entry { + my ($ldap_tree, $ldap_base, $mac, $gotoSysStatus, $ip, $interface, $desc) = @_; + if(defined($ldap_tree)) { + my $dn = "cn=".$hosts_database->{$mac}->{cn}.",ou=incoming,$ldap_base"; + my $s_res = &search_ldap_entry($ldap_tree, $ldap_base, "(|(macAddress=$mac)(dhcpHWAddress=ethernet $mac))"); + my $c_res = (defined($s_res))?$s_res->count:0; + if($c_res == 1) { + &main::daemon_log("A WARNING: macAddress $mac already in LDAP", 3); + return; + } elsif($c_res > 0) { + &main::daemon_log("A ERROR: macAddress $mac exists $c_res times in LDAP", 1); + return; + } + + # create LDAP entry + my $entry = Net::LDAP::Entry->new( $dn ); + $entry->dn($dn); + $entry->add("objectClass" => "GOhard"); + $entry->add("cn" => $hosts_database->{$mac}->{cn}); + $entry->add("macAddress" => $mac); + if(defined $gotoSysStatus) {$entry->add("gotoSysStatus" => $gotoSysStatus)} + if(defined $ip) {$entry->add("ipHostNumber" => $ip) } + #if(defined $interface) { } + if(defined $desc) {$entry->add("description" => $desc) } + + # submit entry to LDAP + my $result = $entry->update ($ldap_tree); + + # for $result->code constants please look at Net::LDAP::Constant + if($result->code == 68) { # entry already exists + &main::daemon_log("A WARNING: $dn ".$result->error, 3); + } elsif($result->code == 0) { # everything went fine + &main::daemon_log("A INFO: Add entry $dn to ldap", 5); + } else { # if any other error occur + &main::daemon_log("A ERROR: $dn, ".$result->code.", ".$result->error, 1); + } + } else { + &main::daemon_log("A INFO: Not adding new Entry: LDAP disabled", 5); + } + return; +} #=== FUNCTION ================================================================ @@ -328,36 +380,45 @@ sub get_mac { # COMMENTS: none # SEE ALSO: n/a #=============================================================================== -#sub change_ldap_entry { -# my ($ldap_tree, $ldap_base, $mac, $gotoSysStatus ) = @_; -# -# # check if ldap_entry exists or not -# my $s_res = &search_ldap_entry($ldap_tree, $ldap_base, "(|(macAddress=$mac)(dhcpHWAddress=ethernet $mac))"); -# my $c_res = $s_res->count; -# if($c_res == 0) { -# daemon_log("WARNING: macAddress $mac not in LDAP", 1); -# return; -# } elsif($c_res > 1) { -# daemon_log("ERROR: macAddress $mac exists $c_res times in LDAP", 1); -# return; -# } -# -# my $s_res_entry = $s_res->pop_entry(); -# my $dn = $s_res_entry->dn(); -# my $result = $ldap->modify( $dn, replace => {'gotoSysStatus' => $gotoSysStatus } ); -# -# # for $result->code constants please look at Net::LDAP::Constant -# my $log_time = localtime( time ); -# if($result->code == 32) { # entry doesnt exists -# &add_ldap_entry($mac, $gotoSysStatus); -# } elsif($result->code == 0) { # everything went fine -# daemon_log("$log_time: entry $dn changed successful", 1); -# } else { # if any other error occur -# daemon_log("ERROR: $log_time: $dn, ".$result->code.", ".$result->error, 1); -# } -# -# return; -#} +sub change_ldap_entry { + my ($ldap_tree, $ldap_base, $mac, $gotoSysStatus, $ip) = @_; + + if(defined($ldap_tree)) { + # check if ldap_entry exists or not + my $s_res = &search_ldap_entry($ldap_tree, $ldap_base, "(|(macAddress=$mac)(dhcpHWAddress=ethernet $mac))"); + my $c_res = (defined $s_res)?$s_res->count:0; + if($c_res == 0) { + &main::daemon_log("WARNING: macAddress $mac not in LDAP", 1); + return; + } elsif($c_res > 1) { + &main::daemon_log("ERROR: macAddress $mac exists $c_res times in LDAP", 1); + return; + } + + my $s_res_entry = $s_res->pop_entry(); + my $dn = $s_res_entry->dn(); + my $replace = { + 'gotoSysStatus' => $gotoSysStatus, + }; + if (defined($ip)) { + $replace->{'ipHostNumber'} = $ip; + } + my $result = $ldap_tree->modify( $dn, replace => $replace ); + + # for $result->code constants please look at Net::LDAP::Constant + if($result->code == 32) { # entry doesnt exists + &add_ldap_entry($mac, $gotoSysStatus); + } elsif($result->code == 0) { # everything went fine + &main::daemon_log("entry $dn changed successful", 1); + } else { # if any other error occur + &main::daemon_log("ERROR: $dn, ".$result->code.", ".$result->error, 1); + } + } else { + &main::daemon_log("Not changing Entry: LDAP disabled", 6); + } + + return; +} #=== FUNCTION ================================================================ # NAME: search_ldap_entry @@ -375,319 +436,13 @@ sub search_ldap_entry { my ($ldap_tree, $sub_tree, $search_string) = @_; my $msg; if(defined($ldap_tree)) { - my $msg = $ldap_tree->search( # perform a search + $msg = $ldap_tree->search( # perform a search base => $sub_tree, filter => $search_string, - ) or daemon_log("cannot perform search at ldap: $@", 1); -# if(defined $msg) { -# print $sub_tree."\t".$search_string."\t"; -# print $msg->count."\n"; -# foreach my $entry ($msg->entries) { $entry->dump; }; -# } + ) or &main::daemon_log("cannot perform search at ldap: $@", 1); } return $msg; } - - -#========= MAIN = main ======================================================== -#daemon_log( "####### START DAEMON ######\n", 1 ); -#&check_cmdline_param ; -#&check_pid; -#&open_fifo($fifo_path); -# -## Just fork, if we"re not in foreground mode -#if( ! $foreground ) { $pid = fork(); } -#else { $pid = $$; } -# -## 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 ); -# if( !$foreground ) { exit( 0 ) }; -#} -# -# -#if( not -p $fifo_path ) { die "fifo file disappeared\n" } -#if($c_res == 1) { -# daemon_log("WARNING: macAddress $mac already in LDAP", 1); -# return; -# } elsif($c_res > 0) { -# daemon_log("ERROR: macAddress $mac exists $c_res times in LDAP", 1); -# return; -# } -# -# # create LDAP entry -# my $entry = Net::LDAP::Entry->new( $dn ); -# $entry->dn($dn); -# $entry->add("objectClass" => "goHard"); -# $entry->add("cn" => $mac); -# $entry->add("macAddress" => $mac); -# if(defined $gotoSysStatus) {$entry->add("gotoSysStatus" => $gotoSysStatus)} -# if(defined $ip) {$entry->add("ipHostNumber" => $ip) } -# #if(defined $interface) { } -# if(defined $desc) {$entry->add("description" => $desc) } -# -# # submit entry to LDAP -# my $result = $entry->update ($ldap_tree); -# -# # for $result->code constants please look at Net::LDAP::Constant -# my $log_time = localtime( time ); -# if($result->code == 68) { # entry already exists -# daemon_log("WARNING: $log_time: $dn ".$result->error, 3); -# } elsif($result->code == 0) { # everything went fine -# daemon_log("$log_time: add entry $dn to ldap", 1); -# } else { # if any other error occur -# daemon_log("ERROR: $log_time: $dn, ".$result->code.", ".$result->error, 1); -# } -# return; -#} - - -#=== FUNCTION ================================================================ -# NAME: change_ldap_entry -# PURPOSE: ???? -# PARAMETERS: ???? -# RETURNS: ???? -# DESCRIPTION: ???? -# THROWS: no exceptions -# COMMENTS: none -# SEE ALSO: n/a -#=============================================================================== -#sub change_ldap_entry { -# my ($ldap_tree, $ldap_base, $mac, $gotoSysStatus ) = @_; -# -# # check if ldap_entry exists or not -# my $s_res = &search_ldap_entry($ldap_tree, $ldap_base, "(|(macAddress=$mac)(dhcpHWAddress=ethernet $mac))"); -# my $c_res = $s_res->count; -# if($c_res == 0) { -# daemon_log("WARNING: macAddress $mac not in LDAP", 1); -# return; -# } elsif($c_res > 1) { -# daemon_log("ERROR: macAddress $mac exists $c_res times in LDAP", 1); -# return; -# } -# -# my $s_res_entry = $s_res->pop_entry(); -# my $dn = $s_res_entry->dn(); -# my $result = $ldap->modify( $dn, replace => {'gotoSysStatus' => $gotoSysStatus } ); -# -# # for $result->code constants please look at Net::LDAP::Constant -# my $log_time = localtime( time ); -# if($result->code == 32) { # entry doesnt exists -# &add_ldap_entry($mac, $gotoSysStatus); -# } elsif($result->code == 0) { # everything went fine -# daemon_log("$log_time: entry $dn changed successful", 1); -# } else { # if any other error occur -# daemon_log("ERROR: $log_time: $dn, ".$result->code.", ".$result->error, 1); -# } -# -# return; -#} - -#=== FUNCTION ================================================================ -# NAME: search_ldap_entry -# PURPOSE: ???? -# PARAMETERS: [Net::LDAP] $ldap_tree - object of an ldap-tree -# string $sub_tree - dn of the subtree the search is performed -# string $search_string - either a string or a Net::LDAP::Filter object -# RETURNS: [Net::LDAP::Search] $msg - result object of the performed search -# DESCRIPTION: ???? -# THROWS: no exceptions -# COMMENTS: none -# SEE ALSO: n/a -#=============================================================================== -#sub search_ldap_entry { -# my ($ldap_tree, $sub_tree, $search_string) = @_; -# my $msg = $ldap_tree->search( # perform a search -# base => $sub_tree, -# filter => $search_string, -# ) or daemon_log("cannot perform search at ldap: $@", 1); -## if(defined $msg) { -## print $sub_tree."\t".$search_string."\t"; -## print $msg->count."\n"; -## foreach my $entry ($msg->entries) { $entry->dump; }; -## } -# -# return $msg; -#} - - - -#========= MAIN = main ======================================================== -#daemon_log( "####### START DAEMON ######\n", 1 ); -#&check_cmdline_param ; -#&check_pid; -#&open_fifo($fifo_path); -# -## Just fork, if we"re not in foreground mode -#if( ! $foreground ) { $pid = fork(); } -#else { $pid = $$; } -# -## 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 ); -# if( !$foreground ) { exit( 0 ) }; -#} -# -# -#if( not -p $fifo_path ) { die "fifo file disappeared\n" } -#sysopen(FIFO, $fifo_path, O_RDONLY) or die "can't read from $fifo_path: $!" ; -# -#while( 1 ) { -# # checke alle prozesse im hash daemon_children ob sie noch aktiv sind, wenn -# # nicht, dann entferne prozess aus hash -# while( (my $key, my $val) = each( %daemon_children) ) { -# my $status = waitpid( $key, &WNOHANG) ; -# if( $status == -1 ) { -# delete $daemon_children{$key} ; -# daemon_log("childprocess finished: $key", 3) ; -# } -# } -# -# # ist die max_process anzahl von prozesskindern erreicht, dann warte und -# # prüfe erneut, ob in der zwischenzeit prozesse fertig geworden sind -# if( keys( %daemon_children ) >= $max_process ) { -# sleep($max_process_timeout) ; -# next ; -# } -# -# my $msg = ; -# if( not defined( $msg )) { next ; } -# -# chomp( $msg ); -# if( length( $msg ) == 0 ) { next ; } -# -# my $forked_pid = fork(); -##=== PARENT = parent ========================================================== -# if ( $forked_pid != 0 ) { -# daemon_log("childprocess forked: $forked_pid", 3) ; -# $daemon_children{$forked_pid} = 0 ; -# } -##=== CHILD = child ============================================================ -# else { -# # parse the incoming message from arp, split the message and return -# # the values in an array. not defined values are set to "none" -# #my ($mac, $ip, $interface, $arp_sig, $desc) = &parse_input( $msg ) ; -# daemon_log( "childprocess read from arp: $fifo_path\nline: $msg", 3); -# my ($mac, $ip, $interface, $arp_sig, $desc) = split('\s', $msg, 5); -# -# # create connection to LDAP -# $#sysopen(FIFO, $fifo_path, O_RDONLY) or die "can't read from $fifo_path: $!" ; -# -#while( 1 ) { -# # checke alle prozesse im hash daemon_children ob sie noch aktiv sind, wenn -# # nicht, dann entferne prozess aus hash -# while( (my $key, my $val) = each( %daemon_children) ) { -# my $status = waitpid( $key, &WNOHANG) ; -# if( $status == -1 ) { -# delete $daemon_children{$key} ; -# daemon_log("childprocess finished: $key", 3) ; -# } -# } -# -# # ist die max_process anzahl von prozesskindern erreicht, dann warte und -# # prüfe erneut, ob in der zwischenzeit prozesse fertig geworden sind -# if( keys( %daemon_children ) >= $max_process ) { -# sleep($max_process_timeout) ; -# next ; -# } -# -# my $msg = ; -# if( not defined( $msg )) { next ; } -# -# chomp( $msg ); -# if( length( $msg ) == 0 ) { next ; } -# -# my $forked_pid = fork(); -##=== PARENT = parent ========================================================== -# if ( $forked_pid != 0 ) { -# daemon_log("childprocess forked: $forked_pid", 3) ; -# $daemon_children{$forked_pid} = 0 ; -# } -##=== CHILD = child ============================================================ -# else { -# # parse the incoming message from arp, split the message and return -# # the values in an array. not defined values are set to "none" -# #my ($mac, $ip, $interface, $arp_sig, $desc) = &parse_input( $msg ) ; -# daemon_log( "childprocess read from arp: $fifo_path\nline: $msg", 3); -# my ($mac, $ip, $interface, $arp_sig, $desc) = split('\s', $msg, 5); -# -# # create connection to LDAP -# $ldap = Net::LDAP->new( "localhost" ) or die "$@"; -# $ldap->bind($bind_phrase, -# password => $password, -# ) ; -# -# switch($arp_sig) { -# case 0 {&change_ldap_entry($ldap, $ldap_base, -# $mac, "ip-changed", -# )} -# case 1 {&change_ldap_entry($ldap, $ldap_base, -# $mac, "mac-not-whitelisted", -# )} -# case 2 {&change_ldap_entry($ldap, $ldap_base, -# $mac, "mac-in-blacklist", -# )} -# case 3 {&add_ldap_entry($ldap, $ldap_base, -# $mac, "new-mac-address", $ip, -# $interface, $desc, -# )} -# case 4 {&change_ldap_entry($ldap, $ldap_base, -# $mac, "unauthorized-arp-request", -# )} -# case 5 {&change_ldap_entry($ldap, $ldap_base, -# $mac, "abusive-number-of-arp-requests", -# )} -# case 6 {&change_ldap_entry($ldap, $ldap_base, -# $mac, "ether-and-arp-mac-differs", -# )} -# case 7 {&change_ldap_entry($ldap, $ldap_base, -# $mac, "flood-detected", -# )} -# case 8 {&add_ldap_entry($ldap, $ldap_base, -# $mac, $ip, "new-system", -# )} -# case 9 {&change_ldap_entry($ldap, $ldap_base, -# $mac, "mac-changed", -# )} -# } -# -# - # ldap search -# my $base_phrase = "dc=gonicus,dc=de"; -# my $filter_phrase = "cn=keinesorge"; -# my $attrs_phrase = "cn macAdress"; -# my $msg_search = $ldap->search( base => $base_phrase, -# filter => $filter_phrase, -# attrs => $attrs_phrase, -# ); -# $msg_search->code && die $msg_search->error; -# -# my @entries = $msg_search->entries; -# my $max = $msg_search->count; -# print "anzahl der entries: $max\n"; -# my $i; -# for ( $i = 0 ; $i < $max ; $i++ ) { -# my $entry = $msg_search->entry ( $i ); -# foreach my $attr ( $entry->attributes ) { -# if( not $attr eq "cn") { -# next; -# } -# print join( "\n ", $attr, $entry->get_value( $attr ) ), "\n\n"; -# } -# } - # - # # ldap add - # - # - # $ldap->unbind; - # exit; - # } - # - #} - +# vim:ts=4:shiftwidth:expandtab 1;