TCP сервер LWIP stm32f746

/**
  ******************************************************************************
  * File Name          : Target/lwipopts.h
  * Description        : This file overrides LwIP stack default configuration
  *                      done in opt.h file.
  ******************************************************************************
  * @attention
  *
  * <h2><center>&copy; Copyright (c) 2020 STMicroelectronics.
  * All rights reserved.</center></h2>
  *
  * This software component is licensed by ST under Ultimate Liberty license
  * SLA0044, the "License"; You may not use this file except in compliance with
  * the License. You may obtain a copy of the License at:
  *                             www.st.com/SLA0044
  *
  ******************************************************************************
  */
 
/* Define to prevent recursive inclusion --------------------------------------*/
#ifndef __LWIPOPTS__H__
#define __LWIPOPTS__H__
 
#include "main.h"
 
/*-----------------------------------------------------------------------------*/
/* Current version of LwIP supported by CubeMx: 2.1.2 -*/
/*-----------------------------------------------------------------------------*/
 
/* Within 'USER CODE' section, code will be kept by default at each generation */
/* USER CODE BEGIN 0 */
 
/* USER CODE END 0 */
 
#ifdef __cplusplus
 extern "C" {
#endif
 
/* STM32CubeMX Specific Parameters (not defined in opt.h) ---------------------*/
/* Parameters set in STM32CubeMX LwIP Configuration GUI -*/
/*----- WITH_RTOS enabled (Since FREERTOS is set) -----*/
#define WITH_RTOS 1
/*----- CHECKSUM_BY_HARDWARE enabled -----*/
#define CHECKSUM_BY_HARDWARE 1
/*-----------------------------------------------------------------------------*/
 
/* LwIP Stack Parameters (modified compared to initialization value in opt.h) -*/
/* Parameters set in STM32CubeMX LwIP Configuration GUI -*/
/*----- Default Value for MEMP_NUM_UDP_PCB: 4 ---*/
#define MEMP_NUM_UDP_PCB 5
/*----- Default Value for MEMP_NUM_TCP_PCB: 5 ---*/
#define MEMP_NUM_TCP_PCB 10
/*----- Value in opt.h for MEM_ALIGNMENT: 1 -----*/
#define MEM_ALIGNMENT 4
/*----- Default Value for MEM_SIZE: 1600 ---*/
#define MEM_SIZE 2048
/*----- Default Value for MEMP_NUM_PBUF: 16 ---*/
#define MEMP_NUM_PBUF 24
/*----- Default Value for MEMP_NUM_TCP_SEG: 16 ---*/
#define MEMP_NUM_TCP_SEG 24
/*----- Default Value for PBUF_POOL_BUFSIZE: 592 ---*/
#define PBUF_POOL_BUFSIZE 1536
/*----- Value in opt.h for LWIP_ETHERNET: LWIP_ARP || PPPOE_SUPPORT -*/
#define LWIP_ETHERNET 1
/*----- Value in opt.h for LWIP_DNS_SECURE: (LWIP_DNS_SECURE_RAND_XID | LWIP_DNS_SECURE_NO_MULTIPLE_OUTSTANDING | LWIP_DNS_SECURE_RAND_SRC_PORT) -*/
#define LWIP_DNS_SECURE 7
/*----- Default Value for TCP_MSS: 536 ---*/
#define TCP_MSS 1024
/*----- Value in opt.h for TCP_SND_QUEUELEN: (4*TCP_SND_BUF + (TCP_MSS - 1))/TCP_MSS -----*/
#define TCP_SND_QUEUELEN 9
/*----- Value in opt.h for TCP_SNDQUEUELOWAT: LWIP_MAX(TCP_SND_QUEUELEN)/2, 5) -*/
#define TCP_SNDQUEUELOWAT 5
/*----- Value in opt.h for LWIP_NETIF_LINK_CALLBACK: 0 -----*/
#define LWIP_NETIF_LINK_CALLBACK 1
/*----- Value in opt.h for TCPIP_THREAD_STACKSIZE: 0 -----*/
#define TCPIP_THREAD_STACKSIZE 2048
/*----- Value in opt.h for TCPIP_THREAD_PRIO: 1 -----*/
#define TCPIP_THREAD_PRIO osPriorityNormal
/*----- Value in opt.h for TCPIP_MBOX_SIZE: 0 -----*/
#define TCPIP_MBOX_SIZE 8
/*----- Value in opt.h for SLIPIF_THREAD_STACKSIZE: 0 -----*/
#define SLIPIF_THREAD_STACKSIZE 1024
/*----- Value in opt.h for SLIPIF_THREAD_PRIO: 1 -----*/
#define SLIPIF_THREAD_PRIO 3
/*----- Value in opt.h for DEFAULT_THREAD_STACKSIZE: 0 -----*/
#define DEFAULT_THREAD_STACKSIZE 2048
/*----- Value in opt.h for DEFAULT_THREAD_PRIO: 1 -----*/
#define DEFAULT_THREAD_PRIO 3
/*----- Value in opt.h for DEFAULT_UDP_RECVMBOX_SIZE: 0 -----*/
#define DEFAULT_UDP_RECVMBOX_SIZE 6
/*----- Value in opt.h for DEFAULT_TCP_RECVMBOX_SIZE: 0 -----*/
#define DEFAULT_TCP_RECVMBOX_SIZE 8
/*----- Value in opt.h for DEFAULT_ACCEPTMBOX_SIZE: 0 -----*/
#define DEFAULT_ACCEPTMBOX_SIZE 8
/*----- Value in opt.h for RECV_BUFSIZE_DEFAULT: INT_MAX -----*/
#define RECV_BUFSIZE_DEFAULT 2000000000
/*----- Value in opt.h for LWIP_STATS: 1 -----*/
#define LWIP_STATS 0
/*----- Value in opt.h for CHECKSUM_GEN_IP: 1 -----*/
#define CHECKSUM_GEN_IP 0
/*----- Value in opt.h for CHECKSUM_GEN_UDP: 1 -----*/
#define CHECKSUM_GEN_UDP 0
/*----- Value in opt.h for CHECKSUM_GEN_TCP: 1 -----*/
#define CHECKSUM_GEN_TCP 0
/*----- Value in opt.h for CHECKSUM_GEN_ICMP: 1 -----*/
#define CHECKSUM_GEN_ICMP 0
/*----- Value in opt.h for CHECKSUM_GEN_ICMP6: 1 -----*/
#define CHECKSUM_GEN_ICMP6 0
/*----- Value in opt.h for CHECKSUM_CHECK_IP: 1 -----*/
#define CHECKSUM_CHECK_IP 0
/*----- Value in opt.h for CHECKSUM_CHECK_UDP: 1 -----*/
#define CHECKSUM_CHECK_UDP 0
/*----- Value in opt.h for CHECKSUM_CHECK_TCP: 1 -----*/
#define CHECKSUM_CHECK_TCP 0
/*----- Value in opt.h for CHECKSUM_CHECK_ICMP: 1 -----*/
#define CHECKSUM_CHECK_ICMP 0
/*----- Value in opt.h for CHECKSUM_CHECK_ICMP6: 1 -----*/
#define CHECKSUM_CHECK_ICMP6 0
/*-----------------------------------------------------------------------------*/
/* USER CODE BEGIN 1 */
 
/* USER CODE END 1 */
 
#ifdef __cplusplus
}
#endif
#endif /*__LWIPOPTS__H__ */
 
/************************* (C) COPYRIGHT STMicroelectronics *****END OF FILE****/

void StartDefaultTask(void const * argument)
{
  /* init code for LWIP */
  MX_LWIP_Init();
  /* USER CODE BEGIN 5 */
  //-----------------------------------------------------------
    int i = 0;
    struct netconn *conn;
    struct netconn *newconn;
    err_t err;
    conn = netconn_new(NETCONN_TCP);
    if(conn!=NULL)
    {
      err = netconn_bind(conn, NULL, 80);   // Binding the socket struck for sending data and TCP struck
      if (err == ERR_OK)
      {
        netconn_listen(conn);
        if (err != ERR_OK)
        {
            HAL_GPIO_TogglePin(GPIOG, GPIO_PIN_6);
        }
        /* Infinite loop */
        for(;;)
        {
          if (netconn_accept(conn, &newconn) == ERR_OK)
          {
                // client connected
                HAL_GPIO_WritePin(GPIOG, GPIO_PIN_6, GPIO_PIN_SET);
                sock.conn = newconn;
                sys_thread_new("tcp_thread", tcp_thread, (void*)&sock, DEFAULT_THREAD_STACKSIZE, osPriorityNormal );
                sys_thread_new("tcp_thread_send", tcp_thread_send, (void*)&sock, DEFAULT_THREAD_STACKSIZE, osPriorityNormal );
                TcpCreate++;
          }
          else if (err != ERR_OK)
          {
              HAL_GPIO_TogglePin(GPIOG, GPIO_PIN_6);
          }
        }
      }
      else
      {
          HAL_GPIO_TogglePin(GPIOG, GPIO_PIN_6);
          netconn_delete(conn);
      }
    }
    else if (conn == NULL)
    {
        HAL_GPIO_TogglePin(GPIOG, GPIO_PIN_6);
    }
  //-----------------------------------------------------------
  /* USER CODE END 5 */
}

static void tcp_thread(void *arg)
{
    err_t err, recv_err;                 // Variables for arguments (errors)
    struct netconn *conn;                // Structure for connection
    struct netbuf *inbuf;                // Pointer to connection buffer
    struct_sock *arg_sock;               // Pointer to arguments of task
    struct_handler *qstructhandler;      // Handler Queue
    arg_sock = (struct_sock*) arg;
    conn = arg_sock->conn;
    u16_t buflen;
    char* buf;
    for(;;)
    {
       netconn_write(conn, "READY", 5, NETCONN_COPY);                // Sending "READY"
       for(;;)
       {
          recv_err = netconn_recv(conn, &inbuf);                     // Receiving the socket data in inbuf
          if (recv_err == ERR_OK)
          {
            netbuf_data(inbuf, (void**)&buf, &buflen);               // Data transfer of the inbuf data to buf
            if((buf[0]==0x0D)||(buf[0]==0x0A))                       // Checking of the data ending
            {
              netbuf_delete(inbuf);
              continue;
            }
            qstructhandler = osMailAlloc(handler_Queue, osWaitForever);      // Handler Queue
            strncpy(str_buf,buf,buflen);
            str_buf[buflen]=0;
            sprintf(qstructhandler->handler_str,"%-20s", str_buf);           // Handler Queue
            osMailPut(handler_Queue, qstructhandler);                        // Handler Queue
            netbuf_delete(inbuf);
          }
          else
          {
              if (TcpCreate > TcpDelete)
              {
                  netbuf_delete(inbuf);
                  netconn_close(conn);
                  netconn_delete(conn);
                  TcpDelete++;
                  HAL_GPIO_WritePin(GPIOG, GPIO_PIN_6, GPIO_PIN_RESET);
                  break;
              }
              else
              {
                  osDelay(1000);
              }
          }
       }
    }
}

static void tcp_thread_send(void *arg)
{
    struct netconn *conn;                // Structure for connection
    struct_sock *arg_sock;               // Pointer to arguments of task
    arg_sock = (struct_sock*) arg;
    conn = arg_sock->conn;
    uint8_t TcpSendBuffer[1024];
    uint16_t i = 0;
    uint16_t j = 0;
    uint16_t n = 0;
    for (j = 0; j < 1024; j++)
    {
        TcpSendBuffer[j] = 5;
    }
    for(;;)
    {
        if (xSemaphoreTake(binary_semaphore_SEND, portMAX_DELAY) == pdTRUE)
        {
            //for (n = 0; n < 16; n++)
            //{
                HAL_GPIO_WritePin(GPIOC, GPIO_PIN_6, GPIO_PIN_SET);
                //HAL_TIM_OC_Start_IT(&htim4, TIM_CHANNEL_4);
                for (i = 0; i < 12800; i++)
                {
                    //netconn_write(conn, TcpSendBuffer, 1024, NETCONN_COPY);
                    netconn_write(conn, TcpSendBuffer, 1024, NETCONN_NOCOPY);
                }
                //HAL_TIM_OC_Stop_IT(&htim4, TIM_CHANNEL_4);
                HAL_GPIO_WritePin(GPIOC, GPIO_PIN_6, GPIO_PIN_RESET);
                osDelay(100);
            //}
            xSemaphoreGive(binary_semaphore_DONE);
        }
        else
        {
            osDelay(1000);
        }
    }
}

void StartHandlerTask(void const * argument)
{
  /* USER CODE BEGIN StartHandlerTask */
  //-----------------------------------------------------------
  osEvent handlerevent;                                                    // Handler Queue
  struct_handler *qstructhandler;                                          // Handler Queue
  /* Infinite loop */
  for(;;)
  {
      handlerevent = osMailGet(handler_Queue, osWaitForever);              // Handler Queue
      if (handlerevent.status == osEventMail)
      {
          qstructhandler = handlerevent.value.p;
          DataSignal = str_buf[0] - '0';
          if (DataSignal == 1)
          {
              xSemaphoreGive(binary_semaphore_SEND);
          }
          else
          {
              osDelay(1000);
          }
          osMailFree(handler_Queue, handlerevent.value.p);                   // Handler Queue
      }
      else
      {
          osDelay(1000);
      }
  }
  //-----------------------------------------------------------
  /* USER CODE END StartHandlerTask */
}