From f9b575c3bb9c4c3178f7d87679d6ebe0ea9a55b1 Mon Sep 17 00:00:00 2001
From: Extrems <metaradil@gmail.com>
Date: Mon, 6 May 2024 01:25:53 -0400
Subject: [PATCH] Wait for link to be established

---
 lwip/netif/enc28j60if.c | 13 +++++++++----
 lwip/network.c          |  4 +++-
 2 files changed, 12 insertions(+), 5 deletions(-)

diff --git a/lwip/netif/enc28j60if.c b/lwip/netif/enc28j60if.c
index 6bbcc04e..d2d28167 100644
--- a/lwip/netif/enc28j60if.c
+++ b/lwip/netif/enc28j60if.c
@@ -302,6 +302,7 @@ struct enc28j60if {
 	s32 chan;
 	s32 dev;
 	lwpq_t unlockQueue;
+	lwpq_t linkupQueue;
 	sem_t txSemaphore;
 	struct eth_addr *ethaddr;
 };
@@ -530,9 +531,10 @@ static s32 ExiHandler(s32 chan, s32 dev)
 	if (eir & ENC28J60_EIR_LINKIF) {
 		u16 phir;
 
-		if (ENC28J60_GetLinkState(chan))
+		if (ENC28J60_GetLinkState(chan)) {
 			enc28j60_netif->flags |= NETIF_FLAG_LINK_UP;
-		else
+			LWP_ThreadBroadcast(enc28j60if->linkupQueue);
+		} else
 			enc28j60_netif->flags &= ~NETIF_FLAG_LINK_UP;
 
 		ENC28J60_ReadPHYReg(chan, ENC28J60_PHIR, &phir);
@@ -665,12 +667,13 @@ static err_t enc28j60_output(struct netif *netif, struct pbuf *p)
 
 	u32 level = IRQ_Disable();
 
-	if (!(netif->flags & NETIF_FLAG_LINK_UP)) {
+	if (!(netif->flags & NETIF_FLAG_LINK_UP) &&
+		LWP_ThreadTimedSleep(enc28j60if->linkupQueue, &(struct timespec){2, 500000000})) {
 		IRQ_Restore(level);
 		return ERR_CONN;
 	}
 
-	if (LWP_SemTimedWait(enc28j60if->txSemaphore, &(struct timespec){2, 0})) {
+	if (LWP_SemTimedWait(enc28j60if->txSemaphore, &(struct timespec){2, 500000000})) {
 		IRQ_Restore(level);
 		return ERR_IF;
 	}
@@ -717,6 +720,7 @@ err_t enc28j60if_init(struct netif *netif)
 	netif->flags = NETIF_FLAG_BROADCAST;
 
 	LWP_InitQueue(&enc28j60if->unlockQueue);
+	LWP_InitQueue(&enc28j60if->linkupQueue);
 	LWP_SemInit(&enc28j60if->txSemaphore, 1, 1);
 
 	enc28j60if->ethaddr = (struct eth_addr *)netif->hwaddr;
@@ -743,6 +747,7 @@ err_t enc28j60if_init(struct netif *netif)
 	}
 
 	LWP_SemDestroy(enc28j60if->txSemaphore);
+	LWP_CloseQueue(enc28j60if->linkupQueue);
 	LWP_CloseQueue(enc28j60if->unlockQueue);
 
 	mem_free(enc28j60if);
diff --git a/lwip/network.c b/lwip/network.c
index e262acd9..c89390d5 100644
--- a/lwip/network.c
+++ b/lwip/network.c
@@ -1550,8 +1550,10 @@ s32 if_configex(struct in_addr *local_ip,struct in_addr *netmask,struct in_addr
 
 	//last and least start the tcpip layer
 	ret = net_init();
+	if(ret<0) return ret;
 
-	if ( ret == 0 && g_hNetIF.dhcp != NULL ) {
+	if ( (g_hNetIF.flags & NETIF_FLAG_LINK_UP) == 0 ) return -2;
+	if ( g_hNetIF.dhcp != NULL ) {
 		// wait for dhcp to bind
 		while ( g_hNetIF.ip_addr.addr == 0 && g_hNetIF.dhcp->tries <= 4 )
 			LWP_YieldThread();