--- lib/PXElator/dhcpd.pm 2009/07/30 00:07:57 48 +++ lib/PXElator/dhcpd.pm 2009/08/06 20:14:43 167 @@ -19,16 +19,13 @@ use File::Slurp; use Data::Dump qw/dump/; use Net::Ping; -use Module::Refresh; use lib '..'; use Net::DHCP::Packet; use Net::DHCP::Constants 0.67; use server; -use pxe; - -my $debug = 1; +my $debug = server::debug; if ( ! $server::ip ) { my $server_ip = `/sbin/ifconfig`; @@ -36,63 +33,74 @@ $server::ip = $server_ip; } -warn "server ip $server::ip file: $pxe::file range: $server::ip_from - $server::ip_to\n"; +warn "server ip $server::ip range: $server::ip_from - $server::ip_to\n"; my $addr = $server::ip_from; sub client_ip { my ( $mac ) = @_; - my $conf = "conf/$server::ip"; + my $conf = $server::conf; mkdir $conf unless -e $conf; if ( -e "$conf/mac/$mac" ) { my $ip = read_file "$conf/mac/$mac"; - print "$mac old $ip\n"; + print "RENEW $mac $ip\n"; return $ip; } - mkdir $_ foreach grep { ! -e $_ } map { "$conf/$_" } ( 'ip', 'mac' ); - my $p = Net::Ping->new; my $prefix = $server::ip; $prefix =~ s{\.\d+$}{.}; my $ip = $prefix . $addr; - while ( -e "conf/ip/$ip" || $p->ping( $ip ) ) { + + while ( -e "$conf/ip/$ip" || $p->ping( $ip ) ) { $ip = $prefix . $addr++; die "all addresses allocated!" if $addr == $server::ip_to; } write_file "$conf/mac/$mac", $ip; - if ( -l "$conf/ip/$ip" && readlink "$conf/ip/$ip" ne "$conf/mac/$mac") { - unlink "$conf/ip/$ip"; - symlink "$conf/mac/$mac", "$conf/ip/$ip"; - warn "$mac IP changed to $ip"; - } + + my $ip_path = "$conf/ip/$ip"; + mkdir $ip_path unless -e $ip_path; + + if ( -l "$ip_path/mac" && readlink "$ip_path/mac" ne "$conf/mac/$mac" ) { + warn "$mac IP changed from ", readlink "$ip_path/mac", " to $ip"; + unlink "$ip_path/mac"; + }; + symlink "$conf/mac/$mac", "$ip_path/mac"; print "$mac NEW $ip\n"; return $ip; } +use log; +use config; +use pxelinux; +use client; + +our $file; our $transaction = 0; # FIXME predictible transaction numbers sub process_packet { my $sock = shift; + server->refresh; + my $buf; $sock->recv($buf, 1024); my $size = 'empty'; $size = length($buf) . ' bytes' if defined $buf; - print "packet from ",$sock->peerhost,":",$sock->peerport," $size\n"; + print "packet from ",$sock->peerhost,":",$sock->peerport," $size\n" if $debug; return unless $buf; my $dhcp = Net::DHCP::Packet->new($buf); $dhcp->comment( $transaction++ ); - warn "recv: ", $dhcp->toString; + warn "recv: ", $dhcp->toString if $debug; my $mac = substr($dhcp->chaddr(),0,$dhcp->hlen()*2); my $ip = client_ip($mac); @@ -109,6 +117,8 @@ =cut + config::for_ip( $ip ); + my $packet = { Op => BOOTREPLY(), Hops => $dhcp->hops(), @@ -119,41 +129,72 @@ Siaddr => $server::ip, Giaddr => $dhcp->giaddr(), Chaddr => $dhcp->chaddr(), - File => $pxe::file, + File => $file, + DHO_DHCP_SERVER_IDENTIFIER() => $server::ip, # busybox/udhcpc needs it but doesn't request }; + my $options = { + DHO_SUBNET_MASK() => $server::netmask, + DHO_ROUTERS() => $server::ip, + DHO_DOMAIN_NAME() => $server::domain_name, + DHO_NAME_SERVERS() => $server::ip, + DHO_DOMAIN_NAME_SERVERS() => $server::ip, + DHO_HOST_NAME() => client::conf( $ip, 'hostname' ), + DHO_BROADCAST_ADDRESS() => $server::bcast, +# DHO_NTP_SERVERS() => '', + }; + + my @requested = split(/\s/, $dhcp->getOptionValue(DHO_DHCP_PARAMETER_REQUEST_LIST)); + warn "options ",dump( $options ), ' requested: ',dump( @requested ) if $debug; + + my @missing; + foreach ( @requested ) { + if ( defined $options->{$_} ) { + $packet->{$_} = $options->{$_}; + } else { + push @missing, $_; + } + } + + warn "W: options requested but missing: ",dump( @missing ); + + foreach my $opt ( 'magic', 'config_file', 'path_prefix', 'reboot_time' ) { + my $DH0 = eval 'DHO_PXELINUX_' . uc $opt; + warn "DH0: $@" if $@; + my $v = eval "\$pxelinux::$opt"; + warn "v: $@" if $@; + next unless defined $v; + warn "pxelinux dhcp option $opt = $DH0 = $v\n" if $debug; + $packet->{ $DH0 } = $v; + } + my $messagetype = $dhcp->getOptionValue(DHO_DHCP_MESSAGE_TYPE()); if ($messagetype eq DHCPDISCOVER()) { - warn "DHCP DISCOVER"; + log::mac $mac, "DHCP DISCOVER"; $packet->{Comment} = $dhcp->comment(); $packet->{DHO_DHCP_MESSAGE_TYPE()} = DHCPOFFER(); } elsif ($messagetype eq DHCPREQUEST()) { my $requested_ip = $dhcp->getOptionValue(DHO_DHCP_REQUESTED_ADDRESS()); - warn "DHCP REQUEST $requested_ip"; + log::mac $mac, "DHCP REQUEST $requested_ip $ip $file"; if ( $ip eq $requested_ip ) { $packet->{DHO_DHCP_MESSAGE_TYPE()} = DHCPACK(); $packet->{DHO_DHCP_LEASE_TIME()} = 5 * 60; # 5 min -# $packet->{DHO_DHCP_SERVER_IDENTIFIER()} = $server::ip; # FIXME - $packet->{DHO_SUBNET_MASK()} = '255.255.255.0'; - $packet->{DHO_ROUTERS()} = $server::ip; -# $packet->{DHO_DOMAIN_NAME()} = 'pxelator.lan'; -# $packet->{DHO_NAME_SERVERS()} = $server::ip; # $packet->{DHO_ROOT_PATH()} = '/exports/foobar'; } else { $packet->{DHO_DHCP_MESSAGE_TYPE()} = DHCPNAK(); $packet->{DHO_DHCP_MESSAGE()} = "Bad request, expected $ip"; } } elsif ($messagetype eq DHCPINFORM()) { - warn "DHCP INFORM ignored"; + log::mac $mac, "DHCP INFORM ignored"; } else { - warn "$messagetype igored (bootp?)"; + log::mac $mac, "$messagetype igored (bootp?)"; } - warn ">> $mac == $ip server: $server::ip", $pxe::file ? " pxe file: $pxe::file\n" : "\n"; + warn ">> $mac == $ip server: $server::ip", $file ? " file: $file\n" : "\n" if $debug; $packet = new Net::DHCP::Packet( %$packet ); - warn "## ",$packet->toString(),"\n" if $debug; + warn "send ",$packet->toString() if $debug; my $reply = IO::Socket::INET->new( LocalAddr => $server::ip, @@ -189,7 +230,6 @@ print "DHCP listen on ",$sock->sockhost,":",$sock->sockport,"\n"; while (1) { - Module::Refresh->refresh; process_packet $sock; } }