@ASEHST Thank you for the response.
I am using project as exactly same with the link Github > STM32H7-LwIP-Examples /STM32H723_Nucleo_ETH
Here is the RX and TX Callbacks in the ethernetif.c file
/**
* @brief Ethernet Rx Transfer completed callback
* @param handlerEth: ETH handler
* @retval None
*/
void HAL_ETH_RxCpltCallback(ETH_HandleTypeDef *handlerEth)
{
osSemaphoreRelease(RxPktSemaphore);
// osSemaphoreRelease(myBinarySem01Handle); // Scenario - 2 after complated the reception let the semaphore release
}
/**
* @brief Ethernet Tx Transfer completed callback
* @param handlerEth: ETH handler
* @retval None
*/
void HAL_ETH_TxCpltCallback(ETH_HandleTypeDef *handlerEth)
{
osSemaphoreRelease(TxPktSemaphore);
// osSemaphoreRelease(myBinarySem02Handle); // Scenario - 2 after complated the transfer let the semaphore release
}
ethernetif_input function;
void ethernetif_input(void* argument)
{
struct pbuf *p = NULL;
struct netif *netif = (struct netif *) argument;
for( ;; )
{
if (osSemaphoreAcquire(RxPktSemaphore, TIME_WAITING_FOR_INPUT) == osOK)
{
do
{
p = low_level_input( netif );
if (p != NULL)
{
if (netif->input( p, netif) != ERR_OK )
{
pbuf_free(p);
}
}
} while(p!=NULL);
}
}
}
And ethernet output function;
static err_t low_level_output(struct netif *netif, struct pbuf *p)
{
uint32_t i = 0U;
struct pbuf *q = NULL;
err_t errval = ERR_OK;
ETH_BufferTypeDef Txbuffer[ETH_TX_DESC_CNT] = {0};
memset(Txbuffer, 0 , ETH_TX_DESC_CNT*sizeof(ETH_BufferTypeDef));
for(q = p; q != NULL; q = q->next)
{
if(i >= ETH_TX_DESC_CNT)
return ERR_IF;
Txbuffer[i].buffer = q->payload;
Txbuffer[i].len = q->len;
if(i>0)
{
Txbuffer[i-1].next = &Txbuffer[i];
}
if(q->next == NULL)
{
Txbuffer[i].next = NULL;
}
i++;
}
TxConfig.Length = p->tot_len;
TxConfig.TxBuffer = Txbuffer;
TxConfig.pData = p;
pbuf_ref(p);
do
{
if(HAL_ETH_Transmit_IT(&heth, &TxConfig) == HAL_OK)
{
errval = ERR_OK;
}
else
{
if(HAL_ETH_GetError(&heth) & HAL_ETH_ERROR_BUSY)
{
/* Wait for descriptors to become available */
osSemaphoreAcquire(TxPktSemaphore, ETHIF_TX_TIMEOUT);
HAL_ETH_ReleaseTxPacket(&heth);
errval = ERR_BUF;
}
else
{
/* Other error */
pbuf_free(p);
errval = ERR_IF;
}
}
}while(errval == ERR_BUF);
return errval;
}
Also I would like to share my tasks and semaphores in the the main.c file
//****************************************************************************
//****************************************************************************
void StartDefaultTask(void *argument)
{
/* init code for LWIP */
MX_LWIP_Init();
/* USER CODE BEGIN 5 */
LOCK_TCPIP_CORE();
const char* message = "Hello UDP message!\n\r";
osDelay(10);
ip_addr_t PC_IPADDR;
IP_ADDR4(&PC_IPADDR, 192, 168, 1, 1);
struct udp_pcb* my_udp = udp_new();
udp_connect(my_udp, &PC_IPADDR, 55151);
struct pbuf* udp_buffer = NULL;
UNLOCK_TCPIP_CORE();
/* Infinite loop */
for (;;) {
osDelay(1000);
/* !! PBUF_RAM is critical for correct operation !! */
udp_buffer = pbuf_alloc(PBUF_TRANSPORT, strlen(message), PBUF_RAM);
if (udp_buffer != NULL) {
memcpy(udp_buffer->payload, message, strlen(message));
// osSemaphoreRelease(myBinarySem01Handle); // Scenario - 1 Release semaphore just Before send message.
udp_send(my_udp, udp_buffer);
// osSemaphoreRelease(myBinarySem02Handle); // Scenario - 1 Release semaphore just After send message
pbuf_free(udp_buffer);
}
}
/* USER CODE END 5 */
}
//****************************************************************************
//****************************************************************************
/* USER CODE END Header_StartTask01 */
void StartTask01(void *argument)
{
/* USER CODE BEGIN StartTask01 */
/* Infinite loop */
for(;;)
{
osSemaphoreAcquire(myBinarySem01Handle, osWaitForever);
/* Check */
if( (PHY_REG_Globalvalue & LAN8742_CH_SELECT) == LAN8742_CH_SELECT){
PHY_REG_Globalvalue &= ~ LAN8742_CH_SELECT;
HAL_ETH_WritePHYRegister(&heth,PHY_ADDR,27); // write phy reg
}
osDelay(1);
}
/* USER CODE END StartTask01 */
}
//****************************************************************************
//****************************************************************************
/* USER CODE END Header_StartTask02 */
void StartTask02(void *argument)
{
/* USER CODE BEGIN StartTask02 */
/* Infinite loop */
for(;;)
{
osSemaphoreAcquire(myBinarySem02Handle, osWaitForever);
/* Check */
if((PHY_REG_Globalvalue & LAN8742_CH_SELECT) == 0){
PHY_REG_Globalvalue |= LAN8742_CH_SELECT;
HAL_ETH_WritePHYRegister(&heth,PHY_ADDR,27); // write phy
}
osDelay(1);
}
/* USER CODE END StartTask02 */
}
//****************************************************************************
//****************************************************************************
Edit:
In this example code above, i want to release these Semaphores as soon as valid data packet is received and as soon as it sends a response back to the server. Therefore, direct them to the relevant tasks.
Valid data packed means only data packets which match with ip address only.
Thanks
