emo/busybox
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

udhcp: rename client_config to client_data, server_config to server_data

Browse Source 
Signed-off-by: Denys Vlasenko <vda.linux@googlemail.com>
This commit is contained in:
Denys Vlasenko 2019-05-26 15:01:13 +02:00
parent 818d9e02f2
commit bcb1fc3e6c
4 changed files with 188 additions and 188 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

152
networking/udhcp/d6_dhcpc.c
View File

@ -63,7 +63,7 @@
#include <netpacket/packet.h> #include <netpacket/packet.h>
#include <linux/filter.h> #include <linux/filter.h>
/* "struct client_config_t client_config" is in bb_common_bufsiz1 */ /* "struct client_data_t client_data" is in bb_common_bufsiz1 */
static const struct dhcp_optflag d6_optflags[] = { static const struct dhcp_optflag d6_optflags[] = {
#if ENABLE_FEATURE_UDHCPC6_RFC3646 #if ENABLE_FEATURE_UDHCPC6_RFC3646
@ -427,7 +427,7 @@ static char **fill_envp(const uint8_t *option, const uint8_t *option_end)
client6_data.env_ptr = NULL; client6_data.env_ptr = NULL;
client6_data.env_idx = 0; client6_data.env_idx = 0;
*new_env() = xasprintf("interface=%s", client_config.interface); *new_env() = xasprintf("interface=%s", client_data.interface);
if (option) if (option)
option_to_env(option, option_end); option_to_env(option, option_end);
@ -449,8 +449,8 @@ static void d6_run_script(const uint8_t *option, const uint8_t *option_end,
envp = fill_envp(option, option_end); envp = fill_envp(option, option_end);
/* call script */ /* call script */
log1("executing %s %s", client_config.script, name); log1("executing %s %s", client_data.script, name);
argv[0] = (char*) client_config.script; argv[0] = (char*) client_data.script;
argv[1] = (char*) name; argv[1] = (char*) name;
argv[2] = NULL; argv[2] = NULL;
spawn_and_wait(argv); spawn_and_wait(argv);
@ -486,7 +486,7 @@ static uint8_t *init_d6_packet(struct d6_packet *packet, char type, uint32_t xid
packet->d6_xid32 = xid; packet->d6_xid32 = xid;
packet->d6_msg_type = type; packet->d6_msg_type = type;
clientid = (void*)client_config.clientid; clientid = (void*)client_data.clientid;
return mempcpy(packet->d6_options, clientid, clientid->len + 2+2); return mempcpy(packet->d6_options, clientid, clientid->len + 2+2);
} }
@ -499,7 +499,7 @@ static uint8_t *add_d6_client_options(uint8_t *ptr)
ptr += 4; ptr += 4;
for (option = 1; option < 256; option++) { for (option = 1; option < 256; option++) {
if (client_config.opt_mask[option >> 3] & (1 << (option & 7))) { if (client_data.opt_mask[option >> 3] & (1 << (option & 7))) {
ptr[0] = (option >> 8); ptr[0] = (option >> 8);
ptr[1] = option; ptr[1] = option;
ptr += 2; ptr += 2;
@ -518,7 +518,7 @@ static uint8_t *add_d6_client_options(uint8_t *ptr)
ptr = mempcpy(ptr, &opt_fqdn_req, sizeof(opt_fqdn_req)); ptr = mempcpy(ptr, &opt_fqdn_req, sizeof(opt_fqdn_req));
#endif #endif
/* Add -x options if any */ /* Add -x options if any */
curr = client_config.options; curr = client_data.options;
while (curr) { while (curr) {
len = (curr->data[D6_OPT_LEN] << 8) | curr->data[D6_OPT_LEN + 1]; len = (curr->data[D6_OPT_LEN] << 8) | curr->data[D6_OPT_LEN + 1];
ptr = mempcpy(ptr, curr->data, D6_OPT_DATA + len); ptr = mempcpy(ptr, curr->data, D6_OPT_DATA + len);
@ -528,7 +528,7 @@ static uint8_t *add_d6_client_options(uint8_t *ptr)
return ptr; return ptr;
} }
static int d6_mcast_from_client_config_ifindex(struct d6_packet *packet, uint8_t *end) static int d6_mcast_from_client_data_ifindex(struct d6_packet *packet, uint8_t *end)
{ {
/* FF02::1:2 is "All_DHCP_Relay_Agents_and_Servers" address */ /* FF02::1:2 is "All_DHCP_Relay_Agents_and_Servers" address */
static const uint8_t FF02__1_2[16] = { static const uint8_t FF02__1_2[16] = {
@ -540,7 +540,7 @@ static int d6_mcast_from_client_config_ifindex(struct d6_packet *packet, uint8_t
packet, (end - (uint8_t*) packet), packet, (end - (uint8_t*) packet),
/*src*/ &client6_data.ll_ip6, CLIENT_PORT6, /*src*/ &client6_data.ll_ip6, CLIENT_PORT6,
/*dst*/ (struct in6_addr*)FF02__1_2, SERVER_PORT6, MAC_BCAST_ADDR, /*dst*/ (struct in6_addr*)FF02__1_2, SERVER_PORT6, MAC_BCAST_ADDR,
client_config.ifindex client_data.ifindex
); );
} }
@ -671,7 +671,7 @@ static NOINLINE int send_d6_discover(uint32_t xid, struct in6_addr *requested_ip
opt_ptr = add_d6_client_options(opt_ptr); opt_ptr = add_d6_client_options(opt_ptr);
bb_info_msg("sending %s", "discover"); bb_info_msg("sending %s", "discover");
return d6_mcast_from_client_config_ifindex(&packet, opt_ptr); return d6_mcast_from_client_data_ifindex(&packet, opt_ptr);
} }
/* Multicast a DHCPv6 request message /* Multicast a DHCPv6 request message
@ -728,7 +728,7 @@ static NOINLINE int send_d6_select(uint32_t xid)
opt_ptr = add_d6_client_options(opt_ptr); opt_ptr = add_d6_client_options(opt_ptr);
bb_info_msg("sending %s", "select"); bb_info_msg("sending %s", "select");
return d6_mcast_from_client_config_ifindex(&packet, opt_ptr); return d6_mcast_from_client_data_ifindex(&packet, opt_ptr);
} }
/* Unicast or broadcast a DHCP renew message /* Unicast or broadcast a DHCP renew message
@ -806,9 +806,9 @@ static NOINLINE int send_d6_renew(uint32_t xid, struct in6_addr *server_ipv6, st
&packet, (opt_ptr - (uint8_t*) &packet), &packet, (opt_ptr - (uint8_t*) &packet),
our_cur_ipv6, CLIENT_PORT6, our_cur_ipv6, CLIENT_PORT6,
server_ipv6, SERVER_PORT6, server_ipv6, SERVER_PORT6,
client_config.ifindex client_data.ifindex
); );
return d6_mcast_from_client_config_ifindex(&packet, opt_ptr); return d6_mcast_from_client_data_ifindex(&packet, opt_ptr);
} }
/* Unicast a DHCP release message */ /* Unicast a DHCP release message */
@ -835,7 +835,7 @@ int send_d6_release(struct in6_addr *server_ipv6, struct in6_addr *our_cur_ipv6)
&packet, (opt_ptr - (uint8_t*) &packet), &packet, (opt_ptr - (uint8_t*) &packet),
our_cur_ipv6, CLIENT_PORT6, our_cur_ipv6, CLIENT_PORT6,
server_ipv6, SERVER_PORT6, server_ipv6, SERVER_PORT6,
client_config.ifindex client_data.ifindex
); );
} }
@ -903,12 +903,12 @@ static NOINLINE int d6_recv_raw_packet(struct in6_addr *peer_ipv6, struct d6_pac
/*** Main ***/ /*** Main ***/
/* Values for client_config.listen_mode */ /* Values for client_data.listen_mode */
#define LISTEN_NONE 0 #define LISTEN_NONE 0
#define LISTEN_KERNEL 1 #define LISTEN_KERNEL 1
#define LISTEN_RAW 2 #define LISTEN_RAW 2
/* Values for client_config.state */ /* Values for client_data.state */
/* initial state: (re)start DHCP negotiation */ /* initial state: (re)start DHCP negotiation */
#define INIT_SELECTING 0 #define INIT_SELECTING 0
/* discover was sent, DHCPOFFER reply received */ /* discover was sent, DHCPOFFER reply received */
@ -1016,35 +1016,35 @@ static void change_listen_mode(int new_mode)
: "none" : "none"
); );
client_config.listen_mode = new_mode; client_data.listen_mode = new_mode;
if (client_config.sockfd >= 0) { if (client_data.sockfd >= 0) {
close(client_config.sockfd); close(client_data.sockfd);
client_config.sockfd = -1; client_data.sockfd = -1;
} }
if (new_mode == LISTEN_KERNEL) if (new_mode == LISTEN_KERNEL)
client_config.sockfd = udhcp_listen_socket(/*INADDR_ANY,*/ CLIENT_PORT6, client_config.interface); client_data.sockfd = udhcp_listen_socket(/*INADDR_ANY,*/ CLIENT_PORT6, client_data.interface);
else if (new_mode != LISTEN_NONE) else if (new_mode != LISTEN_NONE)
client_config.sockfd = d6_raw_socket(client_config.ifindex); client_data.sockfd = d6_raw_socket(client_data.ifindex);
/* else LISTEN_NONE: client_config.sockfd stays closed */ /* else LISTEN_NONE: client_data.sockfd stays closed */
} }
/* Called only on SIGUSR1 */ /* Called only on SIGUSR1 */
static void perform_renew(void) static void perform_renew(void)
{ {
bb_info_msg("performing DHCP renew"); bb_info_msg("performing DHCP renew");
switch (client_config.state) { switch (client_data.state) {
case BOUND: case BOUND:
change_listen_mode(LISTEN_KERNEL); change_listen_mode(LISTEN_KERNEL);
case RENEWING: case RENEWING:
case REBINDING: case REBINDING:
client_config.state = RENEW_REQUESTED; client_data.state = RENEW_REQUESTED;
break; break;
case RENEW_REQUESTED: /* impatient are we? fine, square 1 */ case RENEW_REQUESTED: /* impatient are we? fine, square 1 */
d6_run_script_no_option("deconfig"); d6_run_script_no_option("deconfig");
case REQUESTING: case REQUESTING:
case RELEASED: case RELEASED:
change_listen_mode(LISTEN_RAW); change_listen_mode(LISTEN_RAW);
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
break; break;
case INIT_SELECTING: case INIT_SELECTING:
break; break;
@ -1054,10 +1054,10 @@ static void perform_renew(void)
static void perform_d6_release(struct in6_addr *server_ipv6, struct in6_addr *our_cur_ipv6) static void perform_d6_release(struct in6_addr *server_ipv6, struct in6_addr *our_cur_ipv6)
{ {
/* send release packet */ /* send release packet */
if (client_config.state == BOUND if (client_data.state == BOUND
|| client_config.state == RENEWING || client_data.state == RENEWING
|| client_config.state == REBINDING || client_data.state == REBINDING
|| client_config.state == RENEW_REQUESTED || client_data.state == RENEW_REQUESTED
) { ) {
bb_info_msg("unicasting a release"); bb_info_msg("unicasting a release");
send_d6_release(server_ipv6, our_cur_ipv6); /* unicast */ send_d6_release(server_ipv6, our_cur_ipv6); /* unicast */
@ -1071,7 +1071,7 @@ static void perform_d6_release(struct in6_addr *server_ipv6, struct in6_addr *ou
*/ */
d6_run_script_no_option("deconfig"); d6_run_script_no_option("deconfig");
change_listen_mode(LISTEN_NONE); change_listen_mode(LISTEN_NONE);
client_config.state = RELEASED; client_data.state = RELEASED;
} }
///static uint8_t* alloc_dhcp_option(int code, const char *str, int extra) ///static uint8_t* alloc_dhcp_option(int code, const char *str, int extra)
@ -1091,7 +1091,7 @@ static void client_background(void)
bb_daemonize(0); bb_daemonize(0);
logmode &= ~LOGMODE_STDIO; logmode &= ~LOGMODE_STDIO;
/* rewrite pidfile, as our pid is different now */ /* rewrite pidfile, as our pid is different now */
write_pidfile(client_config.pidfile); write_pidfile(client_data.pidfile);
} }
#endif #endif
@ -1170,9 +1170,9 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
/* Default options */ /* Default options */
IF_FEATURE_UDHCP_PORT(SERVER_PORT6 = 547;) IF_FEATURE_UDHCP_PORT(SERVER_PORT6 = 547;)
IF_FEATURE_UDHCP_PORT(CLIENT_PORT6 = 546;) IF_FEATURE_UDHCP_PORT(CLIENT_PORT6 = 546;)
client_config.interface = "eth0"; client_data.interface = "eth0";
client_config.script = CONFIG_UDHCPC_DEFAULT_SCRIPT; client_data.script = CONFIG_UDHCPC_DEFAULT_SCRIPT;
client_config.sockfd = -1; client_data.sockfd = -1;
/* Parse command line */ /* Parse command line */
opt = getopt32long(argv, "^" opt = getopt32long(argv, "^"
@ -1184,8 +1184,8 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
"v" "v"
"\0" IF_UDHCP_VERBOSE("vv") /* -v is a counter */ "\0" IF_UDHCP_VERBOSE("vv") /* -v is a counter */
, udhcpc6_longopts , udhcpc6_longopts
, &client_config.interface, &client_config.pidfile, &str_r /* i,p */ , &client_data.interface, &client_data.pidfile, &str_r /* i,p */
, &client_config.script /* s */ , &client_data.script /* s */
, &discover_timeout, &discover_retries, &tryagain_timeout /* T,t,A */ , &discover_timeout, &discover_retries, &tryagain_timeout /* T,t,A */
, &list_O , &list_O
, &list_x , &list_x
@ -1216,29 +1216,29 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
n = udhcp_option_idx(optstr, d6_option_strings); n = udhcp_option_idx(optstr, d6_option_strings);
n = d6_optflags[n].code; n = d6_optflags[n].code;
} }
client_config.opt_mask[n >> 3] |= 1 << (n & 7); client_data.opt_mask[n >> 3] |= 1 << (n & 7);
} }
if (!(opt & OPT_o)) { if (!(opt & OPT_o)) {
unsigned i, n; unsigned i, n;
for (i = 0; (n = d6_optflags[i].code) != 0; i++) { for (i = 0; (n = d6_optflags[i].code) != 0; i++) {
if (d6_optflags[i].flags & OPTION_REQ) { if (d6_optflags[i].flags & OPTION_REQ) {
client_config.opt_mask[n >> 3] |= 1 << (n & 7); client_data.opt_mask[n >> 3] |= 1 << (n & 7);
} }
} }
} }
while (list_x) { while (list_x) {
char *optstr = xstrdup(llist_pop(&list_x)); char *optstr = xstrdup(llist_pop(&list_x));
udhcp_str2optset(optstr, &client_config.options, udhcp_str2optset(optstr, &client_data.options,
d6_optflags, d6_option_strings, d6_optflags, d6_option_strings,
/*dhcpv6:*/ 1 /*dhcpv6:*/ 1
); );
free(optstr); free(optstr);
} }
if (d6_read_interface(client_config.interface, if (d6_read_interface(client_data.interface,
&client_config.ifindex, &client_data.ifindex,
&client6_data.ll_ip6, &client6_data.ll_ip6,
client_config.client_mac) client_data.client_mac)
) { ) {
return 1; return 1;
} }
@ -1252,8 +1252,8 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
clientid->data[1] = 3; /* DUID-LL */ clientid->data[1] = 3; /* DUID-LL */
clientid->data[3] = 1; /* ethernet */ clientid->data[3] = 1; /* ethernet */
clientid_mac_ptr = clientid->data + 2+2; clientid_mac_ptr = clientid->data + 2+2;
memcpy(clientid_mac_ptr, client_config.client_mac, 6); memcpy(clientid_mac_ptr, client_data.client_mac, 6);
client_config.clientid = (void*)clientid; client_data.clientid = (void*)clientid;
} }
#if !BB_MMU #if !BB_MMU
@ -1271,13 +1271,13 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
/* Make sure fd 0,1,2 are open */ /* Make sure fd 0,1,2 are open */
bb_sanitize_stdio(); bb_sanitize_stdio();
/* Create pidfile */ /* Create pidfile */
write_pidfile(client_config.pidfile); write_pidfile(client_data.pidfile);
/* Goes to stdout (unless NOMMU) and possibly syslog */ /* Goes to stdout (unless NOMMU) and possibly syslog */
bb_info_msg("started, v"BB_VER); bb_info_msg("started, v"BB_VER);
/* Set up the signal pipe */ /* Set up the signal pipe */
udhcp_sp_setup(); udhcp_sp_setup();
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
d6_run_script_no_option("deconfig"); d6_run_script_no_option("deconfig");
change_listen_mode(LISTEN_RAW); change_listen_mode(LISTEN_RAW);
packet_num = 0; packet_num = 0;
@ -1296,16 +1296,16 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
/* silence "uninitialized!" warning */ /* silence "uninitialized!" warning */
unsigned timestamp_before_wait = timestamp_before_wait; unsigned timestamp_before_wait = timestamp_before_wait;
//bb_error_msg("sockfd:%d, listen_mode:%d", client_config.sockfd, client_config.listen_mode); //bb_error_msg("sockfd:%d, listen_mode:%d", client_data.sockfd, client_data.listen_mode);
/* Was opening raw or udp socket here /* Was opening raw or udp socket here
* if (client_config.listen_mode != LISTEN_NONE && client_config.sockfd < 0), * if (client_data.listen_mode != LISTEN_NONE && client_data.sockfd < 0),
* but on fast network renew responses return faster * but on fast network renew responses return faster
* than we open sockets. Thus this code is moved * than we open sockets. Thus this code is moved
* to change_listen_mode(). Thus we open listen socket * to change_listen_mode(). Thus we open listen socket
* BEFORE we send renew request (see "case BOUND:"). */ * BEFORE we send renew request (see "case BOUND:"). */
udhcp_sp_fd_set(pfds, client_config.sockfd); udhcp_sp_fd_set(pfds, client_data.sockfd);
tv = timeout - already_waited_sec; tv = timeout - already_waited_sec;
retval = 0; retval = 0;
@ -1334,20 +1334,20 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
* or if the status of the bridge changed). * or if the status of the bridge changed).
* Refresh ifindex and client_mac: * Refresh ifindex and client_mac:
*/ */
if (d6_read_interface(client_config.interface, if (d6_read_interface(client_data.interface,
&client_config.ifindex, &client_data.ifindex,
&client6_data.ll_ip6, &client6_data.ll_ip6,
client_config.client_mac) client_data.client_mac)
) { ) {
goto ret0; /* iface is gone? */ goto ret0; /* iface is gone? */
} }
memcpy(clientid_mac_ptr, client_config.client_mac, 6); memcpy(clientid_mac_ptr, client_data.client_mac, 6);
/* We will restart the wait in any case */ /* We will restart the wait in any case */
already_waited_sec = 0; already_waited_sec = 0;
switch (client_config.state) { switch (client_data.state) {
case INIT_SELECTING: case INIT_SELECTING:
if (!discover_retries || packet_num < discover_retries) { if (!discover_retries || packet_num < discover_retries) {
if (packet_num == 0) if (packet_num == 0)
@ -1396,12 +1396,12 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
* were seen in the wild. Treat them similarly * were seen in the wild. Treat them similarly
* to "no response to discover" case */ * to "no response to discover" case */
change_listen_mode(LISTEN_RAW); change_listen_mode(LISTEN_RAW);
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
goto leasefail; goto leasefail;
case BOUND: case BOUND:
/* 1/2 lease passed, enter renewing state */ /* 1/2 lease passed, enter renewing state */
client_config.state = RENEWING; client_data.state = RENEWING;
client_config.first_secs = 0; /* make secs field count from 0 */ client_data.first_secs = 0; /* make secs field count from 0 */
change_listen_mode(LISTEN_KERNEL); change_listen_mode(LISTEN_KERNEL);
log1("entering renew state"); log1("entering renew state");
/* fall right through */ /* fall right through */
@ -1424,7 +1424,7 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
} }
/* Timed out, enter rebinding state */ /* Timed out, enter rebinding state */
log1("entering rebinding state"); log1("entering rebinding state");
client_config.state = REBINDING; client_data.state = REBINDING;
/* fall right through */ /* fall right through */
case REBINDING: case REBINDING:
/* Switch to bcast receive */ /* Switch to bcast receive */
@ -1440,8 +1440,8 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
/* Timed out, enter init state */ /* Timed out, enter init state */
bb_info_msg("lease lost, entering init state"); bb_info_msg("lease lost, entering init state");
d6_run_script_no_option("deconfig"); d6_run_script_no_option("deconfig");
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
client_config.first_secs = 0; /* make secs field count from 0 */ client_data.first_secs = 0; /* make secs field count from 0 */
/*timeout = 0; - already is */ /*timeout = 0; - already is */
packet_num = 0; packet_num = 0;
continue; continue;
@ -1457,10 +1457,10 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
/* Is it a signal? */ /* Is it a signal? */
switch (udhcp_sp_read()) { switch (udhcp_sp_read()) {
case SIGUSR1: case SIGUSR1:
client_config.first_secs = 0; /* make secs field count from 0 */ client_data.first_secs = 0; /* make secs field count from 0 */
already_waited_sec = 0; already_waited_sec = 0;
perform_renew(); perform_renew();
if (client_config.state == RENEW_REQUESTED) { if (client_data.state == RENEW_REQUESTED) {
/* We might be either on the same network /* We might be either on the same network
* (in which case renew might work), * (in which case renew might work),
* or we might be on a completely different one * or we might be on a completely different one
@ -1495,15 +1495,15 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
int len; int len;
/* A packet is ready, read it */ /* A packet is ready, read it */
if (client_config.listen_mode == LISTEN_KERNEL) if (client_data.listen_mode == LISTEN_KERNEL)
len = d6_recv_kernel_packet(&srv6_buf, &packet, client_config.sockfd); len = d6_recv_kernel_packet(&srv6_buf, &packet, client_data.sockfd);
else else
len = d6_recv_raw_packet(&srv6_buf, &packet, client_config.sockfd); len = d6_recv_raw_packet(&srv6_buf, &packet, client_data.sockfd);
if (len == -1) { if (len == -1) {
/* Error is severe, reopen socket */ /* Error is severe, reopen socket */
bb_error_msg("read error: "STRERROR_FMT", reopening socket" STRERROR_ERRNO); bb_error_msg("read error: "STRERROR_FMT", reopening socket" STRERROR_ERRNO);
sleep(discover_timeout); /* 3 seconds by default */ sleep(discover_timeout); /* 3 seconds by default */
change_listen_mode(client_config.listen_mode); /* just close and reopen */ change_listen_mode(client_data.listen_mode); /* just close and reopen */
} }
/* If this packet will turn out to be unrelated/bogus, /* If this packet will turn out to be unrelated/bogus,
* we will go back and wait for next one. * we will go back and wait for next one.
@ -1520,7 +1520,7 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
continue; continue;
} }
switch (client_config.state) { switch (client_data.state) {
case INIT_SELECTING: case INIT_SELECTING:
if (packet.d6_msg_type == D6_MSG_ADVERTISE) if (packet.d6_msg_type == D6_MSG_ADVERTISE)
goto type_is_ok; goto type_is_ok;
@ -1546,12 +1546,12 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
bb_info_msg("received DHCP NAK (%u)", option->data[4]); bb_info_msg("received DHCP NAK (%u)", option->data[4]);
d6_run_script(packet.d6_options, d6_run_script(packet.d6_options,
packet_end, "nak"); packet_end, "nak");
if (client_config.state != REQUESTING) if (client_data.state != REQUESTING)
d6_run_script_no_option("deconfig"); d6_run_script_no_option("deconfig");
change_listen_mode(LISTEN_RAW); change_listen_mode(LISTEN_RAW);
sleep(3); /* avoid excessive network traffic */ sleep(3); /* avoid excessive network traffic */
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
client_config.first_secs = 0; /* make secs field count from 0 */ client_data.first_secs = 0; /* make secs field count from 0 */
requested_ipv6 = NULL; requested_ipv6 = NULL;
timeout = 0; timeout = 0;
packet_num = 0; packet_num = 0;
@ -1571,7 +1571,7 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
client6_data.server_id = option; client6_data.server_id = option;
if (packet.d6_msg_type == D6_MSG_ADVERTISE) { if (packet.d6_msg_type == D6_MSG_ADVERTISE) {
/* enter requesting state */ /* enter requesting state */
client_config.state = REQUESTING; client_data.state = REQUESTING;
timeout = 0; timeout = 0;
packet_num = 0; packet_num = 0;
already_waited_sec = 0; already_waited_sec = 0;
@ -1746,9 +1746,9 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
timeout = 61; timeout = 61;
/* enter bound state */ /* enter bound state */
d6_run_script(packet.d6_options, packet_end, d6_run_script(packet.d6_options, packet_end,
(client_config.state == REQUESTING ? "bound" : "renew")); (client_data.state == REQUESTING ? "bound" : "renew"));
client_config.state = BOUND; client_data.state = BOUND;
change_listen_mode(LISTEN_NONE); change_listen_mode(LISTEN_NONE);
if (opt & OPT_q) { /* quit after lease */ if (opt & OPT_q) { /* quit after lease */
goto ret0; goto ret0;
@ -1777,7 +1777,7 @@ int udhcpc6_main(int argc UNUSED_PARAM, char **argv)
perform_d6_release(&srv6_buf, requested_ipv6); perform_d6_release(&srv6_buf, requested_ipv6);
retval = 0; retval = 0;
ret: ret:
/*if (client_config.pidfile) - remove_pidfile has its own check */ /*if (client_data.pidfile) - remove_pidfile has its own check */
remove_pidfile(client_config.pidfile); remove_pidfile(client_data.pidfile);
return retval; return retval;
} }

214
networking/udhcp/dhcpc.c
View File

@ -49,7 +49,7 @@ struct tpacket_auxdata {
#endif #endif
/* "struct client_config_t client_config" is in bb_common_bufsiz1 */ /* "struct client_data_t client_data" is in bb_common_bufsiz1 */
#if ENABLE_LONG_OPTS #if ENABLE_LONG_OPTS
@ -477,7 +477,7 @@ static char **fill_envp(struct dhcp_packet *packet)
} }
curr = envp = xzalloc(sizeof(envp[0]) * envc); curr = envp = xzalloc(sizeof(envp[0]) * envc);
*curr = xasprintf("interface=%s", client_config.interface); *curr = xasprintf("interface=%s", client_data.interface);
putenv(*curr++); putenv(*curr++);
if (!packet) if (!packet)
@ -577,8 +577,8 @@ static void udhcp_run_script(struct dhcp_packet *packet, const char *name)
envp = fill_envp(packet); envp = fill_envp(packet);
/* call script */ /* call script */
log1("executing %s %s", client_config.script, name); log1("executing %s %s", client_data.script, name);
argv[0] = (char*) client_config.script; argv[0] = (char*) client_data.script;
argv[1] = (char*) name; argv[1] = (char*) name;
argv[2] = NULL; argv[2] = NULL;
spawn_and_wait(argv); spawn_and_wait(argv);
@ -608,15 +608,15 @@ static void init_packet(struct dhcp_packet *packet, char type)
packet->xid = random_xid(); packet->xid = random_xid();
client_config.last_secs = monotonic_sec(); client_data.last_secs = monotonic_sec();
if (client_config.first_secs == 0) if (client_data.first_secs == 0)
client_config.first_secs = client_config.last_secs; client_data.first_secs = client_data.last_secs;
secs = client_config.last_secs - client_config.first_secs; secs = client_data.last_secs - client_data.first_secs;
packet->secs = htons(secs); packet->secs = htons(secs);
memcpy(packet->chaddr, client_config.client_mac, 6); memcpy(packet->chaddr, client_data.client_mac, 6);
if (client_config.clientid) if (client_data.clientid)
udhcp_add_binary_option(packet, client_config.clientid); udhcp_add_binary_option(packet, client_data.clientid);
} }
static void add_client_options(struct dhcp_packet *packet) static void add_client_options(struct dhcp_packet *packet)
@ -631,7 +631,7 @@ static void add_client_options(struct dhcp_packet *packet)
end = udhcp_end_option(packet->options); end = udhcp_end_option(packet->options);
len = 0; len = 0;
for (i = 1; i < DHCP_END; i++) { for (i = 1; i < DHCP_END; i++) {
if (client_config.opt_mask[i >> 3] & (1 << (i & 7))) { if (client_data.opt_mask[i >> 3] & (1 << (i & 7))) {
packet->options[end + OPT_DATA + len] = i; packet->options[end + OPT_DATA + len] = i;
len++; len++;
} }
@ -642,12 +642,12 @@ static void add_client_options(struct dhcp_packet *packet)
packet->options[end + OPT_DATA + len] = DHCP_END; packet->options[end + OPT_DATA + len] = DHCP_END;
} }
if (client_config.vendorclass) if (client_data.vendorclass)
udhcp_add_binary_option(packet, client_config.vendorclass); udhcp_add_binary_option(packet, client_data.vendorclass);
if (client_config.hostname) if (client_data.hostname)
udhcp_add_binary_option(packet, client_config.hostname); udhcp_add_binary_option(packet, client_data.hostname);
if (client_config.fqdn) if (client_data.fqdn)
udhcp_add_binary_option(packet, client_config.fqdn); udhcp_add_binary_option(packet, client_data.fqdn);
/* Request broadcast replies if we have no IP addr */ /* Request broadcast replies if we have no IP addr */
if ((option_mask32 & OPT_B) && packet->ciaddr == 0) if ((option_mask32 & OPT_B) && packet->ciaddr == 0)
@ -655,15 +655,15 @@ static void add_client_options(struct dhcp_packet *packet)
/* Add -x options if any */ /* Add -x options if any */
{ {
struct option_set *curr = client_config.options; struct option_set *curr = client_data.options;
while (curr) { while (curr) {
udhcp_add_binary_option(packet, curr->data); udhcp_add_binary_option(packet, curr->data);
curr = curr->next; curr = curr->next;
} }
// if (client_config.sname) // if (client_data.sname)
// strncpy((char*)packet->sname, client_config.sname, sizeof(packet->sname) - 1); // strncpy((char*)packet->sname, client_data.sname, sizeof(packet->sname) - 1);
// if (client_config.boot_file) // if (client_data.boot_file)
// strncpy((char*)packet->file, client_config.boot_file, sizeof(packet->file) - 1); // strncpy((char*)packet->file, client_data.boot_file, sizeof(packet->file) - 1);
} }
// This will be needed if we remove -V VENDOR_STR in favor of // This will be needed if we remove -V VENDOR_STR in favor of
@ -691,12 +691,12 @@ static void add_client_options(struct dhcp_packet *packet)
* client reverts to using the IP broadcast address. * client reverts to using the IP broadcast address.
*/ */
static int raw_bcast_from_client_config_ifindex(struct dhcp_packet *packet, uint32_t src_nip) static int raw_bcast_from_client_data_ifindex(struct dhcp_packet *packet, uint32_t src_nip)
{ {
return udhcp_send_raw_packet(packet, return udhcp_send_raw_packet(packet,
/*src*/ src_nip, CLIENT_PORT, /*src*/ src_nip, CLIENT_PORT,
/*dst*/ INADDR_BROADCAST, SERVER_PORT, MAC_BCAST_ADDR, /*dst*/ INADDR_BROADCAST, SERVER_PORT, MAC_BCAST_ADDR,
client_config.ifindex); client_data.ifindex);
} }
static int bcast_or_ucast(struct dhcp_packet *packet, uint32_t ciaddr, uint32_t server) static int bcast_or_ucast(struct dhcp_packet *packet, uint32_t ciaddr, uint32_t server)
@ -705,7 +705,7 @@ static int bcast_or_ucast(struct dhcp_packet *packet, uint32_t ciaddr, uint32_t
return udhcp_send_kernel_packet(packet, return udhcp_send_kernel_packet(packet,
ciaddr, CLIENT_PORT, ciaddr, CLIENT_PORT,
server, SERVER_PORT); server, SERVER_PORT);
return raw_bcast_from_client_config_ifindex(packet, ciaddr); return raw_bcast_from_client_data_ifindex(packet, ciaddr);
} }
/* Broadcast a DHCP discover packet to the network, with an optionally requested IP */ /* Broadcast a DHCP discover packet to the network, with an optionally requested IP */
@ -731,7 +731,7 @@ static NOINLINE int send_discover(uint32_t xid, uint32_t requested)
add_client_options(&packet); add_client_options(&packet);
bb_info_msg("sending %s", "discover"); bb_info_msg("sending %s", "discover");
return raw_bcast_from_client_config_ifindex(&packet, INADDR_ANY); return raw_bcast_from_client_data_ifindex(&packet, INADDR_ANY);
} }
/* Broadcast a DHCP request message */ /* Broadcast a DHCP request message */
@ -775,7 +775,7 @@ static NOINLINE int send_select(uint32_t xid, uint32_t server, uint32_t requeste
temp_addr.s_addr = requested; temp_addr.s_addr = requested;
bb_info_msg("sending select for %s", inet_ntoa(temp_addr)); bb_info_msg("sending select for %s", inet_ntoa(temp_addr));
return raw_bcast_from_client_config_ifindex(&packet, INADDR_ANY); return raw_bcast_from_client_data_ifindex(&packet, INADDR_ANY);
} }
/* Unicast or broadcast a DHCP renew message */ /* Unicast or broadcast a DHCP renew message */
@ -845,7 +845,7 @@ static NOINLINE int send_decline(/*uint32_t xid,*/ uint32_t server, uint32_t req
udhcp_add_simple_option(&packet, DHCP_SERVER_ID, server); udhcp_add_simple_option(&packet, DHCP_SERVER_ID, server);
bb_info_msg("sending %s", "decline"); bb_info_msg("sending %s", "decline");
return raw_bcast_from_client_config_ifindex(&packet, INADDR_ANY); return raw_bcast_from_client_data_ifindex(&packet, INADDR_ANY);
} }
#endif #endif
@ -984,12 +984,12 @@ static NOINLINE int udhcp_recv_raw_packet(struct dhcp_packet *dhcp_pkt, int fd)
/*** Main ***/ /*** Main ***/
/* Values for client_config.listen_mode */ /* Values for client_data.listen_mode */
#define LISTEN_NONE 0 #define LISTEN_NONE 0
#define LISTEN_KERNEL 1 #define LISTEN_KERNEL 1
#define LISTEN_RAW 2 #define LISTEN_RAW 2
/* Values for client_config.state */ /* Values for client_data.state */
/* initial state: (re)start DHCP negotiation */ /* initial state: (re)start DHCP negotiation */
#define INIT_SELECTING 0 #define INIT_SELECTING 0
/* discover was sent, DHCPOFFER reply received */ /* discover was sent, DHCPOFFER reply received */
@ -1100,35 +1100,35 @@ static void change_listen_mode(int new_mode)
: "none" : "none"
); );
client_config.listen_mode = new_mode; client_data.listen_mode = new_mode;
if (client_config.sockfd >= 0) { if (client_data.sockfd >= 0) {
close(client_config.sockfd); close(client_data.sockfd);
client_config.sockfd = -1; client_data.sockfd = -1;
} }
if (new_mode == LISTEN_KERNEL) if (new_mode == LISTEN_KERNEL)
client_config.sockfd = udhcp_listen_socket(/*INADDR_ANY,*/ CLIENT_PORT, client_config.interface); client_data.sockfd = udhcp_listen_socket(/*INADDR_ANY,*/ CLIENT_PORT, client_data.interface);
else if (new_mode != LISTEN_NONE) else if (new_mode != LISTEN_NONE)
client_config.sockfd = udhcp_raw_socket(client_config.ifindex); client_data.sockfd = udhcp_raw_socket(client_data.ifindex);
/* else LISTEN_NONE: client_config.sockfd stays closed */ /* else LISTEN_NONE: client_data.sockfd stays closed */
} }
/* Called only on SIGUSR1 */ /* Called only on SIGUSR1 */
static void perform_renew(void) static void perform_renew(void)
{ {
bb_info_msg("performing DHCP renew"); bb_info_msg("performing DHCP renew");
switch (client_config.state) { switch (client_data.state) {
case BOUND: case BOUND:
change_listen_mode(LISTEN_KERNEL); change_listen_mode(LISTEN_KERNEL);
case RENEWING: case RENEWING:
case REBINDING: case REBINDING:
client_config.state = RENEW_REQUESTED; client_data.state = RENEW_REQUESTED;
break; break;
case RENEW_REQUESTED: /* impatient are we? fine, square 1 */ case RENEW_REQUESTED: /* impatient are we? fine, square 1 */
udhcp_run_script(NULL, "deconfig"); udhcp_run_script(NULL, "deconfig");
case REQUESTING: case REQUESTING:
case RELEASED: case RELEASED:
change_listen_mode(LISTEN_RAW); change_listen_mode(LISTEN_RAW);
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
break; break;
case INIT_SELECTING: case INIT_SELECTING:
break; break;
@ -1141,10 +1141,10 @@ static void perform_release(uint32_t server_addr, uint32_t requested_ip)
struct in_addr temp_addr; struct in_addr temp_addr;
/* send release packet */ /* send release packet */
if (client_config.state == BOUND if (client_data.state == BOUND
|| client_config.state == RENEWING || client_data.state == RENEWING
|| client_config.state == REBINDING || client_data.state == REBINDING
|| client_config.state == RENEW_REQUESTED || client_data.state == RENEW_REQUESTED
) { ) {
temp_addr.s_addr = server_addr; temp_addr.s_addr = server_addr;
strcpy(buffer, inet_ntoa(temp_addr)); strcpy(buffer, inet_ntoa(temp_addr));
@ -1163,7 +1163,7 @@ static void perform_release(uint32_t server_addr, uint32_t requested_ip)
udhcp_run_script(NULL, "deconfig"); udhcp_run_script(NULL, "deconfig");
change_listen_mode(LISTEN_NONE); change_listen_mode(LISTEN_NONE);
client_config.state = RELEASED; client_data.state = RELEASED;
} }
static uint8_t* alloc_dhcp_option(int code, const char *str, int extra) static uint8_t* alloc_dhcp_option(int code, const char *str, int extra)
@ -1183,7 +1183,7 @@ static void client_background(void)
bb_daemonize(0); bb_daemonize(0);
logmode &= ~LOGMODE_STDIO; logmode &= ~LOGMODE_STDIO;
/* rewrite pidfile, as our pid is different now */ /* rewrite pidfile, as our pid is different now */
write_pidfile(client_config.pidfile); write_pidfile(client_data.pidfile);
} }
#endif #endif
@ -1266,9 +1266,9 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
/* Default options */ /* Default options */
IF_FEATURE_UDHCP_PORT(SERVER_PORT = 67;) IF_FEATURE_UDHCP_PORT(SERVER_PORT = 67;)
IF_FEATURE_UDHCP_PORT(CLIENT_PORT = 68;) IF_FEATURE_UDHCP_PORT(CLIENT_PORT = 68;)
client_config.interface = "eth0"; client_data.interface = "eth0";
client_config.script = CONFIG_UDHCPC_DEFAULT_SCRIPT; client_data.script = CONFIG_UDHCPC_DEFAULT_SCRIPT;
client_config.sockfd = -1; client_data.sockfd = -1;
str_V = "udhcp "BB_VER; str_V = "udhcp "BB_VER;
/* Parse command line */ /* Parse command line */
@ -1282,9 +1282,9 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
"\0" IF_UDHCP_VERBOSE("vv") /* -v is a counter */ "\0" IF_UDHCP_VERBOSE("vv") /* -v is a counter */
, udhcpc_longopts , udhcpc_longopts
, &str_V, &str_h, &str_h, &str_F , &str_V, &str_h, &str_h, &str_F
, &client_config.interface, &client_config.pidfile /* i,p */ , &client_data.interface, &client_data.pidfile /* i,p */
, &str_r /* r */ , &str_r /* r */
, &client_config.script /* s */ , &client_data.script /* s */
, &discover_timeout, &discover_retries, &tryagain_timeout /* T,t,A */ , &discover_timeout, &discover_retries, &tryagain_timeout /* T,t,A */
, &list_O , &list_O
, &list_x , &list_x
@ -1295,11 +1295,11 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
if (opt & (OPT_h|OPT_H)) { if (opt & (OPT_h|OPT_H)) {
//msg added 2011-11 //msg added 2011-11
bb_error_msg("option -h NAME is deprecated, use -x hostname:NAME"); bb_error_msg("option -h NAME is deprecated, use -x hostname:NAME");
client_config.hostname = alloc_dhcp_option(DHCP_HOST_NAME, str_h, 0); client_data.hostname = alloc_dhcp_option(DHCP_HOST_NAME, str_h, 0);
} }
if (opt & OPT_F) { if (opt & OPT_F) {
/* FQDN option format: [0x51][len][flags][0][0]<fqdn> */ /* FQDN option format: [0x51][len][flags][0][0]<fqdn> */
client_config.fqdn = alloc_dhcp_option(DHCP_FQDN, str_F, 3); client_data.fqdn = alloc_dhcp_option(DHCP_FQDN, str_F, 3);
/* Flag bits: 0000NEOS /* Flag bits: 0000NEOS
* S: 1 = Client requests server to update A RR in DNS as well as PTR * S: 1 = Client requests server to update A RR in DNS as well as PTR
* O: 1 = Server indicates to client that DNS has been updated regardless * O: 1 = Server indicates to client that DNS has been updated regardless
@ -1308,9 +1308,9 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
* N: 1 = Client requests server to not update DNS (S must be 0 then) * N: 1 = Client requests server to not update DNS (S must be 0 then)
* Two [0] bytes which follow are deprecated and must be 0. * Two [0] bytes which follow are deprecated and must be 0.
*/ */
client_config.fqdn[OPT_DATA + 0] = 0x1; client_data.fqdn[OPT_DATA + 0] = 0x1;
/*client_config.fqdn[OPT_DATA + 1] = 0; - xzalloc did it */ /*client_data.fqdn[OPT_DATA + 1] = 0; - xzalloc did it */
/*client_config.fqdn[OPT_DATA + 2] = 0; */ /*client_data.fqdn[OPT_DATA + 2] = 0; */
} }
if (opt & OPT_r) if (opt & OPT_r)
requested_ip = inet_addr(str_r); requested_ip = inet_addr(str_r);
@ -1328,49 +1328,49 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
n = udhcp_option_idx(optstr, dhcp_option_strings); n = udhcp_option_idx(optstr, dhcp_option_strings);
n = dhcp_optflags[n].code; n = dhcp_optflags[n].code;
} }
client_config.opt_mask[n >> 3] |= 1 << (n & 7); client_data.opt_mask[n >> 3] |= 1 << (n & 7);
} }
if (!(opt & OPT_o)) { if (!(opt & OPT_o)) {
unsigned i, n; unsigned i, n;
for (i = 0; (n = dhcp_optflags[i].code) != 0; i++) { for (i = 0; (n = dhcp_optflags[i].code) != 0; i++) {
if (dhcp_optflags[i].flags & OPTION_REQ) { if (dhcp_optflags[i].flags & OPTION_REQ) {
client_config.opt_mask[n >> 3] |= 1 << (n & 7); client_data.opt_mask[n >> 3] |= 1 << (n & 7);
} }
} }
} }
while (list_x) { while (list_x) {
char *optstr = xstrdup(llist_pop(&list_x)); char *optstr = xstrdup(llist_pop(&list_x));
udhcp_str2optset(optstr, &client_config.options, udhcp_str2optset(optstr, &client_data.options,
dhcp_optflags, dhcp_option_strings, dhcp_optflags, dhcp_option_strings,
/*dhcpv6:*/ 0 /*dhcpv6:*/ 0
); );
free(optstr); free(optstr);
} }
if (udhcp_read_interface(client_config.interface, if (udhcp_read_interface(client_data.interface,
&client_config.ifindex, &client_data.ifindex,
NULL, NULL,
client_config.client_mac) client_data.client_mac)
) { ) {
return 1; return 1;
} }
clientid_mac_ptr = NULL; clientid_mac_ptr = NULL;
if (!(opt & OPT_C) && !udhcp_find_option(client_config.options, DHCP_CLIENT_ID)) { if (!(opt & OPT_C) && !udhcp_find_option(client_data.options, DHCP_CLIENT_ID)) {
/* not suppressed and not set, set the default client ID */ /* not suppressed and not set, set the default client ID */
client_config.clientid = alloc_dhcp_option(DHCP_CLIENT_ID, "", 7); client_data.clientid = alloc_dhcp_option(DHCP_CLIENT_ID, "", 7);
client_config.clientid[OPT_DATA] = 1; /* type: ethernet */ client_data.clientid[OPT_DATA] = 1; /* type: ethernet */
clientid_mac_ptr = client_config.clientid + OPT_DATA+1; clientid_mac_ptr = client_data.clientid + OPT_DATA+1;
memcpy(clientid_mac_ptr, client_config.client_mac, 6); memcpy(clientid_mac_ptr, client_data.client_mac, 6);
} }
if (str_V[0] != '\0') { if (str_V[0] != '\0') {
// can drop -V, str_V, client_config.vendorclass, // can drop -V, str_V, client_data.vendorclass,
// but need to add "vendor" to the list of recognized // but need to add "vendor" to the list of recognized
// string opts for this to work; // string opts for this to work;
// and need to tweak add_client_options() too... // and need to tweak add_client_options() too...
// ...so the question is, should we? // ...so the question is, should we?
//bb_error_msg("option -V VENDOR is deprecated, use -x vendor:VENDOR"); //bb_error_msg("option -V VENDOR is deprecated, use -x vendor:VENDOR");
client_config.vendorclass = alloc_dhcp_option(DHCP_VENDOR, str_V, 0); client_data.vendorclass = alloc_dhcp_option(DHCP_VENDOR, str_V, 0);
} }
#if !BB_MMU #if !BB_MMU
@ -1388,7 +1388,7 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
/* Make sure fd 0,1,2 are open */ /* Make sure fd 0,1,2 are open */
bb_sanitize_stdio(); bb_sanitize_stdio();
/* Create pidfile */ /* Create pidfile */
write_pidfile(client_config.pidfile); write_pidfile(client_data.pidfile);
/* Goes to stdout (unless NOMMU) and possibly syslog */ /* Goes to stdout (unless NOMMU) and possibly syslog */
bb_info_msg("started, v"BB_VER); bb_info_msg("started, v"BB_VER);
/* Set up the signal pipe */ /* Set up the signal pipe */
@ -1396,7 +1396,7 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
/* We want random_xid to be random... */ /* We want random_xid to be random... */
srand(monotonic_us()); srand(monotonic_us());
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
udhcp_run_script(NULL, "deconfig"); udhcp_run_script(NULL, "deconfig");
change_listen_mode(LISTEN_RAW); change_listen_mode(LISTEN_RAW);
packet_num = 0; packet_num = 0;
@ -1414,16 +1414,16 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
/* silence "uninitialized!" warning */ /* silence "uninitialized!" warning */
unsigned timestamp_before_wait = timestamp_before_wait; unsigned timestamp_before_wait = timestamp_before_wait;
//bb_error_msg("sockfd:%d, listen_mode:%d", client_config.sockfd, client_config.listen_mode); //bb_error_msg("sockfd:%d, listen_mode:%d", client_data.sockfd, client_data.listen_mode);
/* Was opening raw or udp socket here /* Was opening raw or udp socket here
* if (client_config.listen_mode != LISTEN_NONE && client_config.sockfd < 0), * if (client_data.listen_mode != LISTEN_NONE && client_data.sockfd < 0),
* but on fast network renew responses return faster * but on fast network renew responses return faster
* than we open sockets. Thus this code is moved * than we open sockets. Thus this code is moved
* to change_listen_mode(). Thus we open listen socket * to change_listen_mode(). Thus we open listen socket
* BEFORE we send renew request (see "case BOUND:"). */ * BEFORE we send renew request (see "case BOUND:"). */
udhcp_sp_fd_set(pfds, client_config.sockfd); udhcp_sp_fd_set(pfds, client_data.sockfd);
tv = timeout - already_waited_sec; tv = timeout - already_waited_sec;
retval = 0; retval = 0;
@ -1452,20 +1452,20 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
* or if the status of the bridge changed). * or if the status of the bridge changed).
* Refresh ifindex and client_mac: * Refresh ifindex and client_mac:
*/ */
if (udhcp_read_interface(client_config.interface, if (udhcp_read_interface(client_data.interface,
&client_config.ifindex, &client_data.ifindex,
NULL, NULL,
client_config.client_mac) client_data.client_mac)
) { ) {
goto ret0; /* iface is gone? */ goto ret0; /* iface is gone? */
} }
if (clientid_mac_ptr) if (clientid_mac_ptr)
memcpy(clientid_mac_ptr, client_config.client_mac, 6); memcpy(clientid_mac_ptr, client_data.client_mac, 6);
/* We will restart the wait in any case */ /* We will restart the wait in any case */
already_waited_sec = 0; already_waited_sec = 0;
switch (client_config.state) { switch (client_data.state) {
case INIT_SELECTING: case INIT_SELECTING:
if (!discover_retries || packet_num < discover_retries) { if (!discover_retries || packet_num < discover_retries) {
if (packet_num == 0) if (packet_num == 0)
@ -1514,12 +1514,12 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
* were seen in the wild. Treat them similarly * were seen in the wild. Treat them similarly
* to "no response to discover" case */ * to "no response to discover" case */
change_listen_mode(LISTEN_RAW); change_listen_mode(LISTEN_RAW);
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
goto leasefail; goto leasefail;
case BOUND: case BOUND:
/* 1/2 lease passed, enter renewing state */ /* 1/2 lease passed, enter renewing state */
client_config.state = RENEWING; client_data.state = RENEWING;
client_config.first_secs = 0; /* make secs field count from 0 */ client_data.first_secs = 0; /* make secs field count from 0 */
change_listen_mode(LISTEN_KERNEL); change_listen_mode(LISTEN_KERNEL);
log1("entering renew state"); log1("entering renew state");
/* fall right through */ /* fall right through */
@ -1555,7 +1555,7 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
} }
/* Timed out or error, enter rebinding state */ /* Timed out or error, enter rebinding state */
log1("entering rebinding state"); log1("entering rebinding state");
client_config.state = REBINDING; client_data.state = REBINDING;
/* fall right through */ /* fall right through */
case REBINDING: case REBINDING:
/* Switch to bcast receive */ /* Switch to bcast receive */
@ -1571,8 +1571,8 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
/* Timed out, enter init state */ /* Timed out, enter init state */
bb_info_msg("lease lost, entering init state"); bb_info_msg("lease lost, entering init state");
udhcp_run_script(NULL, "deconfig"); udhcp_run_script(NULL, "deconfig");
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
client_config.first_secs = 0; /* make secs field count from 0 */ client_data.first_secs = 0; /* make secs field count from 0 */
/*timeout = 0; - already is */ /*timeout = 0; - already is */
packet_num = 0; packet_num = 0;
continue; continue;
@ -1588,10 +1588,10 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
/* Is it a signal? */ /* Is it a signal? */
switch (udhcp_sp_read()) { switch (udhcp_sp_read()) {
case SIGUSR1: case SIGUSR1:
client_config.first_secs = 0; /* make secs field count from 0 */ client_data.first_secs = 0; /* make secs field count from 0 */
already_waited_sec = 0; already_waited_sec = 0;
perform_renew(); perform_renew();
if (client_config.state == RENEW_REQUESTED) { if (client_data.state == RENEW_REQUESTED) {
/* We might be either on the same network /* We might be either on the same network
* (in which case renew might work), * (in which case renew might work),
* or we might be on a completely different one * or we might be on a completely different one
@ -1626,15 +1626,15 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
int len; int len;
/* A packet is ready, read it */ /* A packet is ready, read it */
if (client_config.listen_mode == LISTEN_KERNEL) if (client_data.listen_mode == LISTEN_KERNEL)
len = udhcp_recv_kernel_packet(&packet, client_config.sockfd); len = udhcp_recv_kernel_packet(&packet, client_data.sockfd);
else else
len = udhcp_recv_raw_packet(&packet, client_config.sockfd); len = udhcp_recv_raw_packet(&packet, client_data.sockfd);
if (len == -1) { if (len == -1) {
/* Error is severe, reopen socket */ /* Error is severe, reopen socket */
bb_error_msg("read error: "STRERROR_FMT", reopening socket" STRERROR_ERRNO); bb_error_msg("read error: "STRERROR_FMT", reopening socket" STRERROR_ERRNO);
sleep(discover_timeout); /* 3 seconds by default */ sleep(discover_timeout); /* 3 seconds by default */
change_listen_mode(client_config.listen_mode); /* just close and reopen */ change_listen_mode(client_data.listen_mode); /* just close and reopen */
} }
/* If this packet will turn out to be unrelated/bogus, /* If this packet will turn out to be unrelated/bogus,
* we will go back and wait for next one. * we will go back and wait for next one.
@ -1652,7 +1652,7 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
/* Ignore packets that aren't for us */ /* Ignore packets that aren't for us */
if (packet.hlen != 6 if (packet.hlen != 6
|| memcmp(packet.chaddr, client_config.client_mac, 6) != 0 || memcmp(packet.chaddr, client_data.client_mac, 6) != 0
) { ) {
//FIXME: need to also check that last 10 bytes are zero //FIXME: need to also check that last 10 bytes are zero
log1("chaddr does not match, ignoring packet"); // log2? log1("chaddr does not match, ignoring packet"); // log2?
@ -1665,7 +1665,7 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
continue; continue;
} }
switch (client_config.state) { switch (client_data.state) {
case INIT_SELECTING: case INIT_SELECTING:
/* Must be a DHCPOFFER */ /* Must be a DHCPOFFER */
if (*message == DHCPOFFER) { if (*message == DHCPOFFER) {
@ -1707,7 +1707,7 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
requested_ip = packet.yiaddr; requested_ip = packet.yiaddr;
/* enter requesting state */ /* enter requesting state */
client_config.state = REQUESTING; client_data.state = REQUESTING;
timeout = 0; timeout = 0;
packet_num = 0; packet_num = 0;
already_waited_sec = 0; already_waited_sec = 0;
@ -1754,19 +1754,19 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
if (!arpping(packet.yiaddr, if (!arpping(packet.yiaddr,
NULL, NULL,
(uint32_t) 0, (uint32_t) 0,
client_config.client_mac, client_data.client_mac,
client_config.interface, client_data.interface,
arpping_ms) arpping_ms)
) { ) {
bb_info_msg("offered address is in use " bb_info_msg("offered address is in use "
"(got ARP reply), declining"); "(got ARP reply), declining");
send_decline(/*xid,*/ server_addr, packet.yiaddr); send_decline(/*xid,*/ server_addr, packet.yiaddr);
if (client_config.state != REQUESTING) if (client_data.state != REQUESTING)
udhcp_run_script(NULL, "deconfig"); udhcp_run_script(NULL, "deconfig");
change_listen_mode(LISTEN_RAW); change_listen_mode(LISTEN_RAW);
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
client_config.first_secs = 0; /* make secs field count from 0 */ client_data.first_secs = 0; /* make secs field count from 0 */
requested_ip = 0; requested_ip = 0;
timeout = tryagain_timeout; timeout = tryagain_timeout;
packet_num = 0; packet_num = 0;
@ -1782,7 +1782,7 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
requested_ip = packet.yiaddr; requested_ip = packet.yiaddr;
start = monotonic_sec(); start = monotonic_sec();
udhcp_run_script(&packet, client_config.state == REQUESTING ? "bound" : "renew"); udhcp_run_script(&packet, client_data.state == REQUESTING ? "bound" : "renew");
already_waited_sec = (unsigned)monotonic_sec() - start; already_waited_sec = (unsigned)monotonic_sec() - start;
timeout = lease_seconds / 2; timeout = lease_seconds / 2;
if ((unsigned)timeout < already_waited_sec) { if ((unsigned)timeout < already_waited_sec) {
@ -1790,7 +1790,7 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
timeout = already_waited_sec = 0; timeout = already_waited_sec = 0;
} }
client_config.state = BOUND; client_data.state = BOUND;
change_listen_mode(LISTEN_NONE); change_listen_mode(LISTEN_NONE);
if (opt & OPT_q) { /* quit after lease */ if (opt & OPT_q) { /* quit after lease */
goto ret0; goto ret0;
@ -1832,12 +1832,12 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
/* return to init state */ /* return to init state */
bb_info_msg("received %s", "DHCP NAK"); bb_info_msg("received %s", "DHCP NAK");
udhcp_run_script(&packet, "nak"); udhcp_run_script(&packet, "nak");
if (client_config.state != REQUESTING) if (client_data.state != REQUESTING)
udhcp_run_script(NULL, "deconfig"); udhcp_run_script(NULL, "deconfig");
change_listen_mode(LISTEN_RAW); change_listen_mode(LISTEN_RAW);
sleep(3); /* avoid excessive network traffic */ sleep(3); /* avoid excessive network traffic */
client_config.state = INIT_SELECTING; client_data.state = INIT_SELECTING;
client_config.first_secs = 0; /* make secs field count from 0 */ client_data.first_secs = 0; /* make secs field count from 0 */
requested_ip = 0; requested_ip = 0;
timeout = 0; timeout = 0;
packet_num = 0; packet_num = 0;
@ -1855,7 +1855,7 @@ int udhcpc_main(int argc UNUSED_PARAM, char **argv)
perform_release(server_addr, requested_ip); perform_release(server_addr, requested_ip);
retval = 0; retval = 0;
ret: ret:
/*if (client_config.pidfile) - remove_pidfile has its own check */ /*if (client_data.pidfile) - remove_pidfile has its own check */
remove_pidfile(client_config.pidfile); remove_pidfile(client_data.pidfile);
return retval; return retval;
} }

8
networking/udhcp/dhcpc.h
View File

@ -7,7 +7,7 @@
PUSH_AND_SET_FUNCTION_VISIBILITY_TO_HIDDEN PUSH_AND_SET_FUNCTION_VISIBILITY_TO_HIDDEN
struct client_config_t { struct client_data_t {
uint8_t client_mac[6]; /* Our mac address */ uint8_t client_mac[6]; /* Our mac address */
IF_FEATURE_UDHCP_PORT(uint16_t port;) IF_FEATURE_UDHCP_PORT(uint16_t port;)
int ifindex; /* Index number of the interface to use */ int ifindex; /* Index number of the interface to use */
@ -31,11 +31,11 @@ struct client_config_t {
} FIX_ALIASING; } FIX_ALIASING;
/* server_config sits in 1st half of bb_common_bufsiz1 */ /* server_config sits in 1st half of bb_common_bufsiz1 */
#define client_config (*(struct client_config_t*)(&bb_common_bufsiz1[COMMON_BUFSIZE / 2])) #define client_data (*(struct client_data_t*)(&bb_common_bufsiz1[COMMON_BUFSIZE / 2]))
#if ENABLE_FEATURE_UDHCP_PORT #if ENABLE_FEATURE_UDHCP_PORT
#define CLIENT_PORT (client_config.port) #define CLIENT_PORT (client_data.port)
#define CLIENT_PORT6 (client_config.port) #define CLIENT_PORT6 (client_data.port)
#else #else
#define CLIENT_PORT 68 #define CLIENT_PORT 68
#define CLIENT_PORT6 546 #define CLIENT_PORT6 546

2
networking/udhcp/dhcpd.h
View File

@ -54,7 +54,7 @@ struct server_config_t {
} FIX_ALIASING; } FIX_ALIASING;
#define server_config (*(struct server_config_t*)bb_common_bufsiz1) #define server_config (*(struct server_config_t*)bb_common_bufsiz1)
/* client_config sits in 2nd half of bb_common_bufsiz1 */ /* client_data sits in 2nd half of bb_common_bufsiz1 */
#if ENABLE_FEATURE_UDHCP_PORT #if ENABLE_FEATURE_UDHCP_PORT
#define SERVER_PORT (server_config.port) #define SERVER_PORT (server_config.port)