Skip to content

Commit

Permalink
Add ntp server address to settings menu and ntp via dhcp support. Pre…
Browse files Browse the repository at this point in the history
…pare manual ntp server ip entry. Add support for setting ntp ip addr manually via prusa_printer_settings.ini. Add ntp pool support.
  • Loading branch information
bkerler committed Feb 11, 2024
1 parent 1b1844e commit 5f8e662
Show file tree
Hide file tree
Showing 15 changed files with 118 additions and 37 deletions.
2 changes: 2 additions & 0 deletions doc/prusa_printer_settings.ini
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,8 @@ hostname=prusa
# Printer support two dns servers. If variables are not empty, they will be used
# even is DHCP pr AUTO type is set.
dns4=192.168.0.1;192.168.0.2
# ip or dns name for NTP server
ntp=pool.ntp.org

[eth::ipv4]
# Type could be DHCP, STATIC or OFF.
Expand Down
43 changes: 23 additions & 20 deletions include/buddy/lwipopts.h
Original file line number Diff line number Diff line change
Expand Up @@ -9,26 +9,29 @@ extern "C" {

#include <stdint.h>

#define WITH_RTOS 1
#define MEM_LIBC_MALLOC 0
#define CHECKSUM_BY_HARDWARE 0
#define LWIP_DHCP 1
#define MEM_ALIGNMENT 4
#define MEMP_NUM_SYS_TIMEOUT 8
#define LWIP_ETHERNET 1
#define LWIP_DNS_SECURE 7
#define DNS_MAX_NAME_LENGTH 128

#define TCP_MSS 1024
#define TCP_WND (8 * TCP_MSS)
#define TCP_SND_BUF (2 * TCP_MSS)
#define LWIP_WND_SCALE 0
#define TCP_RCV_SCALE 0
#define PBUF_POOL_SIZE 10
#define PBUF_POOL_SMALL_SIZE 12
#define IP_REASS_MAX_PBUFS 15
#define TCPIP_THREAD_STACKSIZE 1248
#define TCPIP_MBOX_SIZE PBUF_POOL_SIZE + PBUF_POOL_SMALL_SIZE
#define WITH_RTOS 1
#define MEM_LIBC_MALLOC 0
#define CHECKSUM_BY_HARDWARE 0
#define LWIP_DHCP 1
#define MEM_ALIGNMENT 4
#define MEMP_NUM_SYS_TIMEOUT 8
#define LWIP_ETHERNET 1
#define LWIP_DNS_SECURE 7
#define DNS_MAX_NAME_LENGTH 128
#define SNTP_GET_SERVERS_FROM_DHCP 1
#define SNTP_GET_SERVERS_FROM_DHCPV6 1
#define LWIP_DHCP_GET_NTP_SRV 1
#define SNTP_MAX_SERVERS 2
#define TCP_MSS 1024
#define TCP_WND (8 * TCP_MSS)
#define TCP_SND_BUF (2 * TCP_MSS)
#define LWIP_WND_SCALE 0
#define TCP_RCV_SCALE 0
#define PBUF_POOL_SIZE 10
#define PBUF_POOL_SMALL_SIZE 12
#define IP_REASS_MAX_PBUFS 15
#define TCPIP_THREAD_STACKSIZE 1248
#define TCPIP_MBOX_SIZE PBUF_POOL_SIZE + PBUF_POOL_SMALL_SIZE

#define DEFAULT_UDP_RECVMBOX_SIZE TCPIP_MBOX_SIZE
#define DEFAULT_TCP_RECVMBOX_SIZE TCPIP_MBOX_SIZE
Expand Down
1 change: 1 addition & 0 deletions lib/WUI/netif_settings.h
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ typedef struct {
ip_addr_t dns2_ip4; // user defined DNS #2
lan_t lan; // user defined LAN configurations
uint32_t var_mask; // mask for setting ethvars
char ntp[DNS_MAX_NAME_LENGTH + 1]; // user defined NTP
} ETH_config_t;

// those bits were previously assigned to distinguish WPA/WEP/none
Expand Down
40 changes: 30 additions & 10 deletions lib/WUI/sntp/sntp_client.c
Original file line number Diff line number Diff line change
@@ -1,30 +1,50 @@
#include "sntp.h"
#include "sntp_client.h"
#include "netdev.h"
#include "netif.h"
#include "netdb.h"

static ip_addr_t ntp_server; // testing ntp server located in Prague
static uint32_t sntp_running = 0; // describes if sntp is currently running or not
void sntp_client_init(void) {
void sntp_client_static_init(const char *ntp_address) {
sntp_setoperatingmode(SNTP_OPMODE_POLL);
sntp_servermode_dhcp(0);
sntp_setservername(0, ntp_address);
sntp_init();
}

/* TODO: enable DNS for ntp.pool.org as default sntp server*/

// TMP: ip of Czech CESNET NTP server tak.cesnet.cz
if (ipaddr_aton("195.113.144.238", &ntp_server)) {
sntp_setserver(0, &ntp_server);
}
void sntp_client_dhcp_init(const char *ntp_address) {
sntp_setoperatingmode(SNTP_OPMODE_POLL);
sntp_servermode_dhcp(1);
#if LWIP_IPV4
#ifdef SNTP_SERVER_DNS
sntp_setservername(1, "pool.ntp.org");
#else
sntp_setservername(1, ntp_address);
#endif
#endif /* LWIP_IPV4 */
sntp_init();
}

void sntp_client_step(void) {
void sntp_client_step(bool ntp_via_dhcp, const char *ntp_address) {
netdev_status_t eth = netdev_get_status(NETDEV_ETH_ID);
netdev_status_t wifi = netdev_get_status(NETDEV_ESP_ID);

if (!sntp_running && (eth == NETDEV_NETIF_UP || wifi == NETDEV_NETIF_UP)) {
sntp_client_init();
if (ntp_via_dhcp) {
sntp_client_dhcp_init(ntp_address);
} else {
sntp_client_static_init(ntp_address);
}
sntp_running = 1;
} else if (sntp_running && eth != NETDEV_NETIF_UP && wifi != NETDEV_NETIF_UP) {
sntp_stop();
sntp_running = 0;
}
}

void sntp_client_stop() {
if (sntp_running) {
sntp_stop();
sntp_running = 0;
}
}
6 changes: 4 additions & 2 deletions lib/WUI/sntp/sntp_client.h
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,10 @@
extern "C" {
#endif

void sntp_client_init(void);
void sntp_client_step(void);
void sntp_client_static_init(const char *ntp_address);
void sntp_client_dhcp_init(const char *ntp_address);
void sntp_client_step(bool ntp_via_dhcp, const char *ntp_ipv4_address);
void sntp_client_stop(void);

#ifdef __cplusplus
}
Expand Down
2 changes: 1 addition & 1 deletion lib/WUI/sntp/sntp_opts.h
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@
* \#define SNTP_SERVER_ADDRESS "pool.ntp.org"
*/
#if !defined SNTP_SERVER_DNS || defined __DOXYGEN__
#define SNTP_SERVER_DNS 0
#define SNTP_SERVER_DNS 1
#endif

/**
Expand Down
6 changes: 4 additions & 2 deletions lib/WUI/wui.cpp
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
#include "wui.h"
#include "netdb.h"
#include "netif_settings.h"

#include "marlin_client.hpp"
Expand Down Expand Up @@ -29,7 +30,7 @@
#include "main.h"
#include <ccm_thread.hpp>
#include "tasks.hpp"

#include "sntp_client.h"
#include "netdev.h"

#include "otp.hpp"
Expand Down Expand Up @@ -244,6 +245,7 @@ class NetworkState {
// selected interface?
dns_setserver(0, &cfg.dns1_ip4);
dns_setserver(1, &cfg.dns2_ip4);
sntp_client_static_init((const char *)&cfg.ntp);
netifapi_netif_set_addr(&iface.dev, &cfg.lan.addr_ip4, &cfg.lan.msk_ip4, &cfg.lan.gw_ip4);
netifapi_dhcp_inform(&iface.dev);
break;
Expand Down Expand Up @@ -408,7 +410,7 @@ class NetworkState {
// TODO: This does some code gymnastics inside to track changes
// of network configuration. Consider cleaning that up and
// integrating into some kind of up/down mechanism.
sntp_client_step();
sntp_client_step(config_store().lan_ntp_via_dhcp.get(), config_store().lan_ntp_addr.get_c_str());
}

if (events & HealthCheck) {
Expand Down
9 changes: 8 additions & 1 deletion lib/WUI/wui_api.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,9 @@ static int ini_handler_func(void *user, const char *section, const char *name, c
if (ip4addr_aton(value, &tmp_config->lan.gw_ip4)) {
tmp_config->var_mask |= ETHVAR_MSK(ETHVAR_LAN_GW_IP4);
}
} else if (ini_string_match(section, "network", name, "ntp")) {
strlcpy(tmp_config->ntp, value, DNS_MAX_NAME_LENGTH + 1);
tmp_config->var_mask |= ETHVAR_MSK(ETHVAR_NTP_ADDRESS);
} else if (ini_string_match(section, "network", name, "dns4")) {

if (NULL != strchr(value, ';')) {
Expand Down Expand Up @@ -169,7 +172,9 @@ void save_net_params(ETH_config_t *ethconfig, ap_entry_t *ap, uint32_t netdev_id
netdev_id == NETDEV_ETH_ID ? config_store().lan_hostname.set(ethconfig->hostname)
: config_store().wifi_hostname.set(ethconfig->hostname);
}

if (ethconfig->var_mask & ETHVAR_MSK(ETHVAR_NTP_ADDRESS)) {
config_store().lan_ntp_addr.set(ethconfig->ntp);
}
if (ap != NULL) {
assert(netdev_id == NETDEV_ESP_ID);
static_assert(SSID_MAX_LEN == config_store_ns::wifi_max_ssid_len);
Expand All @@ -194,6 +199,7 @@ void load_net_params(ETH_config_t *ethconfig, ap_entry_t *ap, uint32_t netdev_id
ethconfig->dns2_ip4.addr = config_store().lan_ip4_dns2.get();
ethconfig->lan.msk_ip4.addr = config_store().lan_ip4_mask.get();
ethconfig->lan.gw_ip4.addr = config_store().lan_ip4_gateway.get();
strlcpy(ethconfig->ntp, config_store().lan_ntp_addr.get_c_str(), DNS_MAX_NAME_LENGTH + 1);
strlcpy(ethconfig->hostname, config_store().lan_hostname.get_c_str(), ETH_HOSTNAME_LEN + 1);
} else {
ethconfig->lan.flag = config_store().wifi_flag.get() & ~RESERVED_MASK;
Expand All @@ -202,6 +208,7 @@ void load_net_params(ETH_config_t *ethconfig, ap_entry_t *ap, uint32_t netdev_id
ethconfig->dns2_ip4.addr = config_store().wifi_ip4_dns2.get();
ethconfig->lan.msk_ip4.addr = config_store().wifi_ip4_mask.get();
ethconfig->lan.gw_ip4.addr = config_store().wifi_ip4_gateway.get();
strlcpy(ethconfig->ntp, config_store().lan_ntp_addr.get_c_str(), DNS_MAX_NAME_LENGTH + 1);
strlcpy(ethconfig->hostname, config_store().wifi_hostname.get_c_str(), ETH_HOSTNAME_LEN + 1);
}

Expand Down
1 change: 1 addition & 0 deletions lib/WUI/wui_api.h
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,7 @@ typedef enum {
ETHVAR_DNS1_IP4, // ip_addr_t, dns1_ip4
ETHVAR_DNS2_IP4, // ip_addr_t, dns2_ip4
ETHVAR_MAC_ADDRESS, // is not included in ethconfig (used in stringifying for screen)
ETHVAR_NTP_ADDRESS, // char[256+1], hostname or ip

APVAR_SSID, // char[32 + 1], ap_entry_t::ssid
APVAR_PASS, // char[64 + 1], ap_entry_t::pass
Expand Down
18 changes: 18 additions & 0 deletions src/gui/MItem_lan.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,12 @@

#include "MItem_lan.hpp"
#include "wui_api.h"
#include "wui.h"
#include "netdev.h"
#include "ScreenHandler.hpp"
#include "marlin_client.hpp"
#include "sntp.h"
#include "sntp_client.h"

MI_WIFI_STATUS_t::MI_WIFI_STATUS_t()
: WI_INFO_t(_(label), nullptr, is_enabled_t::yes, is_hidden_t::dev) {
Expand Down Expand Up @@ -83,3 +86,18 @@ MI_IP4_GWAY::MI_IP4_GWAY()
MI_MAC_ADDR::MI_MAC_ADDR()
: WiInfo<MAC_LEN>(_(label), nullptr, is_enabled_t::yes, is_hidden_t::no) {
}

MI_NTP_ADDR::MI_NTP_ADDR()
: WiInfo<DNS_MAX_NAME_LENGTH>(_(label), nullptr, is_enabled_t::yes, is_hidden_t::no) {
}

/*****************************************************************************/
// MI_NTP_VIA_DHCP
MI_NTP_VIA_DHCP::MI_NTP_VIA_DHCP()
: WI_ICON_SWITCH_OFF_ON_t(bool(config_store().lan_ntp_via_dhcp.get()), _(label), nullptr, is_enabled_t::yes, is_hidden_t::no) {}

void MI_NTP_VIA_DHCP::OnChange(size_t /*old_index*/) {
bool enabled = config_store().lan_ntp_via_dhcp.get();
config_store().lan_ntp_via_dhcp.set(!enabled);
notify_reconfigure();
}
15 changes: 15 additions & 0 deletions src/gui/MItem_lan.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -117,3 +117,18 @@ class MI_MAC_ADDR : public WiInfo<MAC_LEN> {
public:
MI_MAC_ADDR();
};

class MI_NTP_ADDR : public WiInfo<DNS_MAX_NAME_LENGTH> {
static constexpr const char *const label = GuiDefaults::ScreenWidth > 240 ? N_("NTP Address") : N_("NTP");

public:
MI_NTP_ADDR();
};

class MI_NTP_VIA_DHCP : public WI_ICON_SWITCH_OFF_ON_t {
constexpr static const char *const label = N_("NTP via DHCP");

public:
MI_NTP_VIA_DHCP();
virtual void OnChange(size_t old_index) override;
};
4 changes: 4 additions & 0 deletions src/gui/screen_menu_network.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
#include "netdev.h"
#include "network_gui_tools.hpp"
#include <http_lifetime.h>
#include <sntp.h>

ScreenMenuNetwork::ScreenMenuNetwork()
: ScreenMenuNetwork__(_(label)) {
Expand All @@ -27,8 +28,11 @@ void ScreenMenuNetwork::refresh_address() {
netdev_get_ipv4_addresses(active_netdev, &ethconfig);
stringify_address_for_screen(str, sizeof(str), ethconfig, ETHVAR_MSK(ETHVAR_LAN_ADDR_IP4));
Item<MI_IP4_ADDR>().ChangeInformation(str);
const ip_addr_t *ntp_server = sntp_getserver(0);
Item<MI_NTP_ADDR>().ChangeInformation(ipaddr_ntoa(ntp_server));
} else {
Item<MI_IP4_ADDR>().ChangeInformation(UNKNOWN_ADDR);
Item<MI_NTP_ADDR>().ChangeInformation(UNKNOWN_ADDR);
}
}

Expand Down
2 changes: 1 addition & 1 deletion src/gui/screen_menu_network.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ using ScreenMenuNetwork__ = ScreenMenu<EFooter::Off, MI_RETURN, MI_PRUSALINK,
#if BUDDY_ENABLE_CONNECT()
MI_PRUSA_CONNECT,
#endif
MI_NET_INTERFACE_t, MI_IP4_ADDR, MI_MAC_ADDR, MI_METRICS_SETTINGS, MI_ETH_SETTINGS, MI_WIFI_SETTINGS>;
MI_NET_INTERFACE_t, MI_IP4_ADDR, MI_MAC_ADDR, MI_NTP_VIA_DHCP, MI_NTP_ADDR, MI_METRICS_SETTINGS, MI_ETH_SETTINGS, MI_WIFI_SETTINGS>;

class ScreenMenuNetwork : public ScreenMenuNetwork__ {
public:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
#include <module/prusa/dock_position.hpp>
#include <module/prusa/tool_offset.hpp>
#include <filament_sensors_remap_data.hpp>
#include "lwipopts.h"

namespace config_store_ns {

Expand Down Expand Up @@ -80,6 +81,8 @@ namespace defaults {
inline constexpr std::array<char, wifi_max_ssid_len + 1> wifi_ap_ssid { "" };
inline constexpr std::array<char, wifi_max_passwd_len + 1> wifi_ap_password { "" };

inline constexpr std::array<char, DNS_MAX_NAME_LENGTH + 1> ntp_server { "pool.ntp.org" };

inline constexpr eSOUND_MODE sound_mode { eSOUND_MODE::_undef };
inline constexpr uint8_t sound_volume { 5 };
inline constexpr uint16_t language { 0xffff };
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,12 +58,15 @@ struct CurrentStore : public journal::CurrentStoreConfig<journal::Backend, backe
StoreItem<uint32_t, defaults::uint32_t_zero, journal::hash("LAN IP4 Gateway")> lan_ip4_gateway; // X.X.X.X address encoded
StoreItem<uint32_t, defaults::uint32_t_zero, journal::hash("LAN IP4 DNS1")> lan_ip4_dns1; // X.X.X.X address encoded
StoreItem<uint32_t, defaults::uint32_t_zero, journal::hash("LAN IP4 DNS2")> lan_ip4_dns2; // X.X.X.X address encoded
StoreItem<std::array<char, DNS_MAX_NAME_LENGTH + 1>, defaults::ntp_server, journal::hash("NTP Address")> lan_ntp_addr; // X.X.X.X address encoded or string
StoreItem<std::array<char, lan_hostname_max_len + 1>, defaults::net_hostname, journal::hash("LAN Hostname")> lan_hostname;

StoreItem<int8_t, defaults::lan_timezone, journal::hash("LAN Timezone")> timezone; // hour difference from UTC
StoreItem<time_tools::TimeOffsetMinutes, defaults::timezone_minutes, journal::hash("Timezone Minutes")> timezone_minutes; // minutes offset for hour difference from UTC
StoreItem<time_tools::TimeOffsetSummerTime, defaults::timezone_summer, journal::hash("Timezone Summertime")> timezone_summer; // Summertime hour offset

StoreItem<bool, defaults::bool_false, journal::hash("NTP via DHCP")> lan_ntp_via_dhcp; // use dhcp server for ntp

// WIFI settings
// wifi_flag & 1 -> On = 0/off = 1, lan_flag & 2 -> dhcp = 0/static = 1, wifi_flag & 0b1100 -> reserved, previously ap_sec_t security
StoreItem<uint8_t, defaults::uint8_t_zero, journal::hash("WIFI Flag")> wifi_flag;
Expand Down

0 comments on commit 5f8e662

Please sign in to comment.