diff --git a/eth_interface.c b/eth_interface.c index 5fede89..675e5b1 100644 --- a/eth_interface.c +++ b/eth_interface.c @@ -36,7 +36,7 @@ EthInterface *ethintf_new(EthIODef * io) { ethIntf->txQ = mq_create(ETHLIB_DEF_MQ_SIZE); ethIntf->rxQ = mq_create(ETHLIB_DEF_MQ_SIZE); ETHLIB_OS_SEM_CREATE(ðIntf->rxSem); - ETHLIB_OS_THREAD_DEFINE(ethinf_proc_thread, ipp, 10, 4096, ethIntf); + ETHLIB_OS_THREAD_DEFINE(ethinf_proc_thread, ipp, osPriorityHigh, 4096, ethIntf); ETHLIB_OS_THREAD_CREATE(ipp, ethIntf); ethIntf->ipra = ipra_new(); diff --git a/prefab/packet_parsers/dhcp.c b/prefab/packet_parsers/dhcp.c index 1e61d0b..843b559 100644 --- a/prefab/packet_parsers/dhcp.c +++ b/prefab/packet_parsers/dhcp.c @@ -249,6 +249,8 @@ void dhcp_request(ip4_addr reqAddr, ip4_addr dhcpServerAddr) { } static void dhcp_process(DhcpProps *props, DhcpOption *opts) { + MSG("ENTER\n"); + ETHLIB_OS_MTX_LOCK(&s.procMtx); // LOCK! switch (s.state) { @@ -314,6 +316,8 @@ static void dhcp_process(DhcpProps *props, DhcpOption *opts) { } ETHLIB_OS_MTX_UNLOCK(&s.procMtx); // RELEASE! + + MSG("EXIT\n"); } static int dhcp_resp_cb(const Pckt *pckt, PcktSieveLayerTag tag) {