TCP_HA.c File Reference

: TCP connectie naar Home Assistant More...

#include <stdio.h>
#include <string.h>
#include "tcp.h"
#include "main.h"
#include "lwip.h"
#include "TCP_HA.h"
#include "display.h"

Go to the source code of this file.

Data Structures
struct	PCB_HA_argument
	Bevat informatie over de entity. More...

Functions
static PCB_HA_argument *	prvHaMakePcbArgument ()
	Alloceert memory voor PCB_HA_argument.
static void	prvHaFreePcbArgument (PCB_HA_argument *pcb_argument)
	Geef memory vrij PCB_HA_argument.
static void	prvHaErrorHandelingRebootSystem (void)
	Reset MCU.
static void	prvHaErrorHandelingRoutingError (void)
	Error handling van de Routing error.
err_t	errHaRecieve (void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err)
	errHaRecieve functie TCP.
err_t	errHaConnected (void *arg, struct tcp_pcb *tpcb, err_t err)
	errHaConnected functie (callback van de LwIP_stack)
err_t	errHaSendPacket (struct tcp_pcb *tpcb)
	errHaSendPacket Verstuurd een TCP pakket naar de server.
void	vHaError (void *arg, err_t err)
	error callback functie van de LwIP_stack
void	vHaErrorHandling (err_t err)
	Error handling van de TCP errors.
void	vHaWaitOnLink (err_t err)
	Wacht op link.
err_t	errHaSend (char entity[], char action[], uint16_t usButton)
	Stuur boodschap naar server.

Variables
uint8_t	globalReceive
	Globale variabele voor communicatie tussen twee aparte functies.
struct netif	gnetif

Detailed Description

: TCP connectie naar Home Assistant

Definition in file TCP_HA.c.

Function Documentation

errHaConnected()

err_t errHaConnected	(	void *	arg,
		struct tcp_pcb *	tpcb,
		err_t	err )

errHaConnected functie (callback van de LwIP_stack)

Callbackfunctie van de LwIp_stack, gaat intern de functie oproepen om een tcp packet te gaan verzenden

Parameters

*arg	Additional argument to pass to the callback function
*tpcb	The connection pcb which received data
*p	The received data (or NULL when the connection has been closed!)
err	error code

Returns

ERR_OK

Definition at line 166 of file TCP_HA.c.

                                                                 {
    printf("/************************ Begin ****************************/\n");
    printf("Verbinden is gelukt\n"); //\n belangrijk !!!!
    errHaSendPacket(tpcb);
    return ERR_OK;
}

References errHaSendPacket().

errHaRecieve()

err_t errHaRecieve	(	void *	arg,
		struct tcp_pcb *	tpcb,
		struct pbuf *	p,
		err_t	err )

errHaRecieve functie TCP.

Ontvangt de data van de server,de data bevat de status van de gevraagde entity. De data wordt verwerkt op basis van de button dat in de PCB_argument staat. Is de ontvangen data bestemd voor button 1 dan wordt de kleur aangepast op basis van de ontvangen data

Parameters

*arg	Additional argument to pass to the callback function
*tpcb	The connection pcb which received data
*p	The received data (or NULL when the connection has been closed!)
err	error code

Returns

err Stuurt ERR_OK als de functie is uitgevoerd

<

<

Definition at line 98 of file TCP_HA.c.

                                                                             {
 
    PCB_HA_argument *PCB_argument = tpcb->callback_arg;  
    static uint8_t cReadNextFrame = 0; 
 
    //er is data beschikbaar
    if(err == ERR_OK && p!=NULL){
 
        //Print de pbuf
        printf("Number of pbufs %d\n", pbuf_clen(p));
        printf("Contents of pbuf %.*s\n",p->len,(char *)p->payload);
        printf("Length of pbuf %d\n", p->len);
        //printf("total lent of pbuf %d\n", p->tot_len);
 
        //vorige frame moet payload hebben \r\n\r\n en houdig frame heeft deze niet
        if(strstr(p->payload,"\r\n\r\n") != NULL){
            cReadNextFrame = 1;
        }
        else{
            if(cReadNextFrame == 1){
                cReadNextFrame = 0;
                char state[10];
                strcpy(state, (char*) p->payload); //lees de state in
                printf("Payload: %s\n", state); //print de paylaad van de pbuf
                vDisplayBgButtonState(PCB_argument->usButton,state); //verwerk de data(PCB_argument->usButton,state); //verwerk de data
            }
        }
 
        //Ack de ontvangen data en geeft de pbuf terug vrij
        tcp_recved(tpcb,p->len);
        pbuf_free(p);
    }
 
    //connectie gesloten door server
    if(err == ERR_OK && p == NULL){
 
        printf("Connectie gesloten\n");
        printf("/************************ End ****************************/\n");
 
        globalReceive = 1;
 
        cReadNextFrame = 0;
        //verwijder de tpcb  en de PCB_HA wegens dat de connectie is gesloten
        prvHaFreePcbArgument(PCB_argument);
        tcp_sent(tpcb, NULL);
        tcp_recv(tpcb,NULL);
        tcp_close(tpcb);
    }
 
    return ERR_OK;
}

References globalReceive, prvHaFreePcbArgument(), PCB_HA_argument::usButton, and vDisplayBgButtonState().

errHaSend()

err_t errHaSend	(	char	entity[],
		char	action[],
		uint16_t	usButton )

Stuur boodschap naar server.

Initaliseerd de tcp connectie en stelt de callback functies in

Parameters

entity[]	de entity naam
action[]	gevraagde actie voor de entity
usButton	button nummer

Returns

err Err code

Definition at line 389 of file TCP_HA.c.

                                                                {
    struct tcp_pcb *pConnectie;
 
    PCB_HA_argument *PCB_argument;
 
    //PCB_argument maken
    PCB_argument = prvHaMakePcbArgument();
 
    //PCB_argument is niet aangemaakt
    if(PCB_argument == NULL){
        vHaErrorHandling(ERR_MEM);
        return ERR_MEM;
    }
    else{
        //Niet direct nodig, ga door met rest van programma
    }
 
    //Schrijf de data in de PCB_argument struct
    strcpy(PCB_argument->entity,entity);
    strcpy(PCB_argument->action,action );
    PCB_argument->usButton = usButton;
 
    //Maak een nieuwe tcp_pcb
    pConnectie = tcp_new();
 
    //Geef de PCB_argument mee aan de pcb
    tcp_arg(pConnectie, PCB_argument);
 
    //stel het IP van de server in
    ip_addr_t serverIP;
    IP_ADDR4(&serverIP,192,168,0,10);
 
    // Error callback
    err_t error;
    tcp_err(pConnectie,vHaError);
 
    //Maak een nieuwe TCP connectie
    error = tcp_connect(pConnectie,&serverIP, 5000, errHaConnected);
    if(error){
        printf("ERROR: Code %d (errHaSend :: tcp_connect)\n",error);
        vHaErrorHandling(error);
        return error;
    }
 
    //Callback functie instellen voor recieve
    tcp_recv(pConnectie,errHaRecieve);
 
    return ERR_OK;
}

References PCB_HA_argument::action, PCB_HA_argument::entity, errHaConnected(), errHaRecieve(), prvHaMakePcbArgument(), PCB_HA_argument::usButton, vHaError(), and vHaErrorHandling().

errHaSendPacket()

err_t errHaSendPacket

(

struct tcp_pcb *

tpcb

)

errHaSendPacket Verstuurd een TCP pakket naar de server.

Verstuurd een TCP pakket naar de server met hierin het GET request. Het GET-request bevat de actie dat moet worden ondernomen samen met de gevraagde entity.

Parameters

*tpcb

PCB

Returns

ERR_OK bij goede verzending and ERR_xx in functie van de error

Note

vb code voor de GET request gehaald van https://stackoverflow.com/questions/26192758/how-can-i-send-a-simple-http-request-with-a-lwip-stack

Definition at line 189 of file TCP_HA.c.

{
    PCB_HA_argument *pArguments = tpcb->callback_arg;
    printf("args: %s\n",pArguments->action);
 
    char url[200] = "GET /ha?entity=";
    strcat(url,pArguments->entity);
    if(strcmp(pArguments->action,"") != 0){
        strcat(url,"&action=");
        strcat(url,pArguments->action);
    }
    strcat(url," HTTP/1.0\r\nHost: 192.168.0.10:5000\r\n\r\n ");
 
    printf("url: %s", url);
 
    err_t error;
    /* push to buffer */
    error = tcp_write(tpcb, url, strlen(url), TCP_WRITE_FLAG_COPY);
 
    // Error bij het schrijven naar de buffer
    if (error) {
        printf("ERROR: Code: %d (errHaSendPacket :: tcp_write)\n", error);
        vHaErrorHandling(error); //Behandel de fout
        return error;
    }
 
    /* now send */
    error = tcp_output(tpcb);
 
    //Error bij het verzenden?
    if (error) {
        printf("ERROR: Code: %d (errHaSendPacket :: tcp_output)\n", error);
        vHaErrorHandling(error); //Behandel de fout
        return error;
    }
 
    return ERR_OK;
}

References PCB_HA_argument::action, PCB_HA_argument::entity, and vHaErrorHandling().

prvHaErrorHandelingRebootSystem()

static void prvHaErrorHandelingRebootSystem ( void )

static

Reset MCU.

Schrijft boodschap "restart pending" op het scherm idem op UART Reset de MCU

Definition at line 314 of file TCP_HA.c.

                                                 {
    HAL_Delay(5000);
    vDisplayError("Restart Pending");
    printf("Restart Pending");
    HAL_Delay(2000);
    NVIC_SystemReset();
}

References vDisplayError().

prvHaErrorHandelingRoutingError()

static void prvHaErrorHandelingRoutingError ( void )

static

Error handling van de Routing error.

Gaat wachten op de link Bij terug aanwezigheid van de link wordt de button states opnieuw opgevraagd

Definition at line 330 of file TCP_HA.c.

                                                 {
    vHaWaitOnLink(ERR_RTE);
    vDisplaySetUpButtonStates();
    vDisplayMainScreen();
}

References vDisplayMainScreen(), vDisplaySetUpButtonStates(), and vHaWaitOnLink().

prvHaFreePcbArgument()

static void prvHaFreePcbArgument ( PCB_HA_argument * pcb_argument )

static

Geef memory vrij PCB_HA_argument.

Geef memory vrij PCB_HA_argument

@argument PCB_HA_argument *

Definition at line 467 of file TCP_HA.c.

                                                                {
    free(pcb_argument);
}

prvHaMakePcbArgument()

static PCB_HA_argument * prvHaMakePcbArgument ( void )

static

Alloceert memory voor PCB_HA_argument.

Alloceert memory voor het PCB_HA_argument

Returns

PCB_HA_argument *

Note

!!!!! Controleer op eventuel NULL pointer !!!!!

Kan een NULL pointer bevatten! Behandel dit op een correcte manier

Definition at line 453 of file TCP_HA.c.

                                               {
    return (PCB_HA_argument *) malloc(sizeof(PCB_HA_argument));
}

vHaError()

void vHaError	(	void *	arg,
		err_t	err )

error callback functie van de LwIP_stack

De error callback functie wordt opgroepen als het aanmaken van een tpcb niet lukt wegens te weinig geheugen

Parameters

*arg	Additional argument to pass to the callback function
err	error code

Note

callback van error functie, wordt niet altijd gecalled??

Definition at line 241 of file TCP_HA.c.

                                   {
    printf("TCP_ha :: vHaError callback function\n");
    printf("%d",err);
    vHaErrorHandling(err);
}

References vHaErrorHandling().

vHaErrorHandling()

void vHaErrorHandling

(

err_t

err

)

Error handling van de TCP errors.

Voor al de errors wordt de MCU gereset behalve bij de ERR_RTE, Bij de ERR_RTE wordt er gewacht op de link

Bij iedere error wordt er een UART message geprint samen met een gepaste boodschap op het scherm

Parameters

err	Error code

Definition at line 260 of file TCP_HA.c.

                                {
    printf("ERROR: Code: %d in function %pS\n",err,__builtin_return_address(0));
    switch (err){
        case ERR_MEM:
            vDisplayError("Out of memory error.");
            printf("Out of memory error");
            prvHaErrorHandelingRebootSystem();
            break;
        case ERR_BUF:
            vDisplayError("Buffer error.");
            printf("Buffer");
            prvHaErrorHandelingRebootSystem();
            break;
        case ERR_TIMEOUT:
            vDisplayError("Timeout.");
            printf("Timeout");
            prvHaErrorHandelingRebootSystem();
            break;
        case ERR_RTE:
            vDisplayError("Routing problem.");
            printf("Routing problem.");
            HAL_Delay(2000); //message anders niet zichtbaar
            prvHaErrorHandelingRoutingError();
            break;
        case ERR_INPROGRESS:
            vDisplayError("Operation in progress.");
            printf("Operation in progress.");
            prvHaErrorHandelingRebootSystem();
            break;
        case ERR_VAL:
            vDisplayError("Illegal value.");
            printf("Illegal value.");
            prvHaErrorHandelingRebootSystem();
            break;
        case ERR_CONN:
            vDisplayError("Not connected.");
            printf("Not connected.");
            prvHaErrorHandelingRebootSystem();
            break;
        default:
            prvHaErrorHandelingRebootSystem();
            break;
    }
 
}

References prvHaErrorHandelingRebootSystem(), prvHaErrorHandelingRoutingError(), and vDisplayError().

vHaWaitOnLink()

void vHaWaitOnLink

(

err_t

err

)

Wacht op link.

Gaat wachten op de ethernet link

Parameters

err	Error code

Returns

Definition at line 347 of file TCP_HA.c.

                             {
 
          //wait on interface
    printf("Waiting on interface\n");
          while(!netif_is_up(&gnetif)){
              MX_LWIP_Process();
              if(err == ERR_OK){
                  vDisplayMessage("Waiting on interface");
              }
              else{
                  vDisplayError("Waiting on interface");
              }
          }
 
          //wait on link (deze werkt :) ), gaat wachten op connectie
          printf("Waiting on link\n");
          while(!netif_is_link_up(&gnetif)){
              MX_LWIP_Process();
              if(err == ERR_OK){
                  vDisplayMessage("Waiting on link");
              }
              else{
                  vDisplayError("Waiting on link");
              }
 
          }
}

References gnetif, vDisplayError(), and vDisplayMessage().

Variable Documentation

globalReceive

uint8_t globalReceive

extern

Globale variabele voor communicatie tussen twee aparte functies.

Definition at line 67 of file main.c.

gnetif

struct netif gnetif

extern