30#if defined (USE_UPF_SEND) || defined (USE_UPF_RECEIVE)
35#include <netinet/in_systm.h>
61int if_register_upf (info)
72 sprintf(filename,
"/dev/pf/pfilt%d", b);
74 sock = open (filename, O_RDWR | O_CLOEXEC, 0);
87 if (ioctl (sock, EIOCSETIF, info -> ifp) < 0)
88 log_fatal (
"Can't attach interface %s to upf device %s: %m",
89 info -> name, filename);
92 if (ioctl (sock, EIOCDEVP, ¶m) < 0)
93 log_fatal (
"Can't get interface %s hardware address: %m",
97 if (param.end_dev_type != ENDT_10MB)
98 log_fatal (
"Invalid device type on network interface %s: %d",
99 info -> name, param.end_dev_type);
101 if (param.end_addr_len != 6)
102 log_fatal (
"Invalid hardware address length on %s: %d",
103 info -> name, param.end_addr_len);
105 info -> hw_address.hlen = 7;
106 info -> hw_address.hbuf [0] = ARPHRD_ETHER;
107 memcpy (&info -> hw_address.hbuf [1], param.end_addr, 6);
119#ifndef USE_UPF_RECEIVE
120 info ->
wfdesc = if_register_upf (info, interface);
125 log_info (
"Sending on UPF/%s/%s%s%s",
138#ifndef USE_UPF_RECEIVE
143 log_info (
"Disabling output on UPF/%s/%s%s%s",
154#ifdef USE_UPF_RECEIVE
159#if defined(RELAY_PORT)
160#error "Relay port is not yet supported for UPF"
172 info -> rfdesc = if_register_upf (info);
175 if (ioctl(info -> rfdesc, EIOCALLOWCOPYALL, &flag) < 0)
176 log_fatal (
"Can't set ALLOWCOPYALL: %m");
179 flag = (ENHOLDSIG | ENBATCH | ENTSTAMP | ENPROMISC |
180 ENNONEXCL | ENCOPYALL);
181 if (ioctl (info -> rfdesc, EIOCMBIC, &flag) < 0)
182 log_fatal (
"Can't clear pfilt bits: %m");
185 bits = ENBATCH | ENCOPYALL;
186 if (ioctl (info -> rfdesc, EIOCMBIS, &bits) < 0)
187 log_fatal (
"Can't set ENBATCH|ENCOPYALL: %m");
194 pf.enf_FilterLen = 0;
196 pf.enf_Filter [pf.enf_FilterLen++] = ENF_PUSHWORD + 6;
197 pf.enf_Filter [pf.enf_FilterLen++] = ENF_PUSHLIT + ENF_CAND;
198 pf.enf_Filter [pf.enf_FilterLen++] = htons (
ETHERTYPE_IP);
199 pf.enf_Filter [pf.enf_FilterLen++] = ENF_PUSHLIT;
200 pf.enf_Filter [pf.enf_FilterLen++] = htons (IPPROTO_UDP);
201 pf.enf_Filter [pf.enf_FilterLen++] = ENF_PUSHWORD + 11;
202 pf.enf_Filter [pf.enf_FilterLen++] = ENF_PUSHLIT + ENF_AND;
203 pf.enf_Filter [pf.enf_FilterLen++] = htons (0xFF);
204 pf.enf_Filter [pf.enf_FilterLen++] = ENF_CAND;
205 pf.enf_Filter [pf.enf_FilterLen++] = ENF_PUSHWORD + 18;
206 pf.enf_Filter [pf.enf_FilterLen++] = ENF_PUSHLIT + ENF_CAND;
207 pf.enf_Filter [pf.enf_FilterLen++] =
local_port;
209 if (ioctl (info -> rfdesc, EIOCSETF, &pf) < 0)
210 log_fatal (
"Can't install packet filter program: %m");
212 log_info (
"Listening on UPF/%s/%s%s%s",
215 info -> hw_address.hlen - 1,
216 &info -> hw_address.hbuf [1]),
228 log_info (
"Disabling input on UPF/%s/%s%s%s",
246 struct sockaddr_in *to;
249 unsigned hbufp = 0, ibufp = 0;
252 struct iovec iov [3];
256 if (!strcmp (interface -> name,
"fallback"))
266 (
unsigned char *)
ip, &ibufp, from.s_addr,
267 to -> sin_addr.s_addr, to -> sin_port,
268 (
unsigned char *)raw, len);
271 iov [0].iov_base = ((
char *)hw);
272 iov [0].iov_len = hbufp;
273 iov [1].iov_base = ((
char *)
ip);
274 iov [1].iov_len = ibufp;
275 iov [2].iov_base = (
char *)raw;
276 iov [2].iov_len = len;
278 result = writev(interface -> wfdesc, iov, 3);
285#ifdef USE_UPF_RECEIVE
290 struct sockaddr_in *from;
296 unsigned char ibuf [1500 +
sizeof (
struct enstamp)];
300 length = read (interface -> rfdesc, ibuf,
sizeof ibuf);
304 bufix =
sizeof (
struct enstamp);
320 from, length, &paylen, 1);
333 memcpy (buf, &ibuf[bufix], paylen);
365 log_fatal (
"Can't register I/O handle for %s: %s",
366 fbi ->
name, isc_result_totext (status));
367 interface_dereference (&fbi,
MDL);
char * print_hw_addr(int htype, const int hlen, const unsigned char *data) const
void if_reinitialize_receive(struct interface_info *)
void maybe_setup_fallback(void)
int supports_multiple_interfaces(struct interface_info *)
void if_deregister_send(struct interface_info *)
void assemble_hw_header(struct interface_info *, unsigned char *, unsigned *, struct hardware *)
ssize_t decode_udp_ip_header(struct interface_info *, unsigned char *, unsigned, struct sockaddr_in *, unsigned, unsigned *, int)
void if_reinitialize_send(struct interface_info *)
isc_result_t fallback_discard(omapi_object_t *)
ssize_t send_packet(struct interface_info *, struct packet *, struct dhcp_packet *, size_t, struct in_addr, struct sockaddr_in *, struct hardware *)
void assemble_udp_ip_header(struct interface_info *, unsigned char *, unsigned *, u_int32_t, u_int32_t, u_int32_t, unsigned char *, unsigned)
int can_receive_unicast_unconfigured(struct interface_info *)
ssize_t receive_packet(struct interface_info *, unsigned char *, size_t, struct sockaddr_in *, struct hardware *)
void if_register_receive(struct interface_info *)
ssize_t send_fallback(struct interface_info *, struct packet *, struct dhcp_packet *, size_t, struct in_addr, struct sockaddr_in *, struct hardware *)
int can_unicast_without_arp(struct interface_info *)
void if_deregister_receive(struct interface_info *)
void if_register_fallback(struct interface_info *)
ssize_t decode_hw_header(struct interface_info *, unsigned char *, unsigned, struct hardware *)
void if_register_send(struct interface_info *)
int setup_fallback(struct interface_info **fp, const char *file, int line)
int quiet_interface_discovery
int if_readsocket(omapi_object_t *h)
isc_result_t omapi_register_io_object(omapi_object_t *, int(*)(omapi_object_t *), int(*)(omapi_object_t *), isc_result_t(*)(omapi_object_t *), isc_result_t(*)(omapi_object_t *), isc_result_t(*)(omapi_object_t *))
struct __omapi_object omapi_object_t
int log_error(const char *,...) __attribute__((__format__(__printf__
void log_fatal(const char *,...) __attribute__((__format__(__printf__
int int log_info(const char *,...) __attribute__((__format__(__printf__
u_int8_t hbuf[HARDWARE_ADDR_LEN+1]
struct hardware anycast_mac_addr
struct hardware hw_address