netboot/pixiecore/dhcpv6.go

package pixiecore

import (
	"fmt"
	"go.universe.tf/netboot/dhcp6"
)

func (s *ServerV6) serveDHCP(conn *dhcp6.Conn) error {
	s.debug("dhcpv6", "Waiting for packets...\n")
	for {
		pkt, src, err := conn.RecvDHCP()
		if err != nil {
			return fmt.Errorf("Error receiving DHCP packet: %s", err)
		}
		if err := pkt.ShouldDiscard(s.Duid); err != nil {
			s.debug("dhcpv6", fmt.Sprintf("Discarding (%d) packet (%d): %s\n", pkt.Type, pkt.TransactionID, err))
			continue
		}

		s.debug("dhcpv6", fmt.Sprintf("Received (%d) packet (%d): %s\n", pkt.Type, pkt.TransactionID, pkt.Options.HumanReadable()))

		response, err := s.PacketBuilder.BuildResponse(pkt, s.Duid, s.BootConfig, s.AddressPool)
		if err != nil {
			s.log("dhcpv6", fmt.Sprintf("Error creating response for transaction: %d: %s", pkt.TransactionID, err))
			if response == nil {
				s.log("dhcpv6", fmt.Sprintf("Dropping the packet"))
				continue
			} else {
				s.log("dhcpv6", fmt.Sprintf("Will notify the client"))
			}
		}
		if response == nil {
			s.log("dhcpv6", fmt.Sprintf("Don't know how to respond to packet type: %d (transaction id %d)", pkt.Type, pkt.TransactionID))
			continue
		}

		marshalledResponse, err := response.Marshal()
		if err != nil {
			s.log("dhcpv6", fmt.Sprintf("Error marshalling response (%d) (%d): %s", response.Type, response.TransactionID, err))
			continue
		}

		if err := conn.SendDHCP(src, marshalledResponse); err != nil {
			s.log("dhcpv6", fmt.Sprintf("Error sending reply (%d) (%d): %s", response.Type, response.TransactionID, err))
			continue
		}

		s.debug("dhcpv6", fmt.Sprintf("Sent (%d) packet (%d): %s\n", response.Type, response.TransactionID, response.Options.HumanReadable()))
	}
}