lv_app_ethernet: simple but working version added

lv_appx/lv_app_ethernet.c

+/**
+ * @file lv_app_ethernet.c
+ *
+ */
+
+/*********************
+ *      INCLUDES
+ *********************/
+#include "lv_app_ethernet.h"
+#if LV_APP_ENABLE != 0 && USE_LV_APP_ETHERNET != 0
+
+#include "../lv_app/lv_app_util/lv_app_kb.h"
+#include "hal/eth/eth.h"
+#include "misc/os/ptask.h"
+#include "hal/systick/systick.h"
+#include <stdio.h>
+
+/*********************
+ *      DEFINES
+ *********************/
+#define ETH_MONITOR_PERIOD     1000    /*ms*/
+
+/**********************
+ *      TYPEDEFS
+ **********************/
+
+/*Application specific data for an instance of this application*/
+typedef struct
+{
+    uint8_t * last_msg_dp;
+    uint16_t last_msg_size;
+}my_app_data_t;
+
+/*Application specific data a window of this application*/
+typedef struct
+{
+
+}my_win_data_t;
+
+/*Application specific data for a shortcut of this application*/
+typedef struct
+{
+    lv_obj_t * label;
+}my_sc_data_t;
+
+/**********************
+ *  STATIC PROTOTYPES
+ **********************/
+static void my_app_run(lv_app_inst_t * app, void * conf);
+static void my_app_close(lv_app_inst_t * app);
+static void my_com_rec(lv_app_inst_t * app_send, lv_app_inst_t * app_rec, lv_app_com_type_t type , const void * data, uint32_t size);
+static void my_sc_open(lv_app_inst_t * app, lv_obj_t * sc);
+static void my_sc_close(lv_app_inst_t * app);
+static void my_win_open(lv_app_inst_t * app, lv_obj_t * win);
+static void my_win_close(lv_app_inst_t * app);
+
+static void eth_state_monitor_task(void * param);
+static void tcp_transf_cb(eth_state_t state, const char * txt);
+
+/**********************
+ *  STATIC VARIABLES
+ **********************/
+static lv_app_dsc_t my_app_dsc =
+{
+	.name = "Ethernet",
+	.mode = LV_APP_MODE_NONE,
+	.app_run = my_app_run,
+	.app_close = my_app_close,
+	.com_rec = my_com_rec,
+	.win_open = my_win_open,
+	.win_close = my_win_close,
+	.sc_open = my_sc_open,
+	.sc_close = my_sc_close,
+	.app_data_size = sizeof(my_app_data_t),
+	.sc_data_size = sizeof(my_sc_data_t),
+	.win_data_size = sizeof(my_win_data_t),
+};
+
+static lv_app_inst_t * app_act_com = NULL;
+
+/**********************
+ *      MACROS
+ **********************/
+
+/**********************
+ *   GLOBAL FUNCTIONS
+ **********************/
+
+/**
+ * Initialize the application
+ * @return pointer to the application descriptor of this application
+ */
+const lv_app_dsc_t * lv_app_ethernet_init(void)
+{
+    ptask_create(eth_state_monitor_task, ETH_MONITOR_PERIOD, PTASK_PRIO_LOW, NULL);
+	return &my_app_dsc;
+}
+
+/**********************
+ *   STATIC FUNCTIONS
+ **********************/
+
+/**
+ * Run an application according to 'app_dsc'
+ * @param app_dsc pointer to an application descriptor
+ * @param conf pointer to a lv_app_ethernet_conf_t structure with configuration data or NULL if unused
+ * @return pointer to the opened application or NULL if any error occurred
+ */
+static void my_app_run(lv_app_inst_t * app, void * conf)
+{
+    /*Initialize the application*/
+}
+
+/**
+ * Close a running application.
+ * Close the Window and the Shortcut too if opened.
+ * Free all the allocated memory by this application.
+ * @param app pointer to an application
+ */
+static void my_app_close(lv_app_inst_t * app)
+{
+    /*No dynamically allocated data in 'my_app_data'*/
+}
+
+/**
+ * Read the data have been sent to this application
+ * @param app_send pointer to an application which sent the message
+ * @param app_rec pointer to an application which is receiving the message
+ * @param type type of data from 'lv_app_com_type_t' enum
+ * @param data pointer to the sent data
+ * @param size length of 'data' in bytes
+ */
+static void my_com_rec(lv_app_inst_t * app_send, lv_app_inst_t * app_rec,
+                       lv_app_com_type_t type , const void * data, uint32_t size)
+{
+	if(type == LV_APP_COM_TYPE_CHAR) {      /*data: string*/
+        eth_tcp_transf(data, size, tcp_transf_cb);
+        app_act_com = app_rec;
+        my_app_data_t * adata = app_act_com->app_data;
+        if(adata->last_msg_dp != NULL) dm_free(adata->last_msg_dp); 
+        
+        adata->last_msg_dp = dm_alloc(size);
+        memcpy(adata->last_msg_dp, data, size);
+        adata->last_msg_size = size;
+	}
+}
+
+/**
+ * Open a shortcut for an application
+ * @param app pointer to an application
+ * @param sc pointer to an object where the application
+ *           can create content of the shortcut
+ */
+static void my_sc_open(lv_app_inst_t * app, lv_obj_t * sc)
+{
+    my_sc_data_t * sc_data = app->sc_data;
+
+    sc_data->label = lv_label_create(sc, NULL);
+	lv_label_set_text(sc_data->label, "Empty");
+	lv_obj_align(sc_data->label, NULL, LV_ALIGN_CENTER, 0, 0);
+}
+
+/**
+ * Close the shortcut of an application
+ * @param app pointer to an application
+ */
+static void my_sc_close(lv_app_inst_t * app)
+{
+    /*No dynamically allocated data in 'my_sc_data'*/
+}
+
+
+/**
+ * Open the application in a window
+ * @param app pointer to an application
+ * @param win pointer to a window object where
+ *            the application can create content
+ */
+static void my_win_open(lv_app_inst_t * app, lv_obj_t * win)
+{
+    
+}
+
+/**
+ * Close the window of an application
+ * @param app pointer to an application
+ */
+static void my_win_close(lv_app_inst_t * app)
+{
+
+}
+
+/*--------------------
+ * OTHER FUNCTIONS
+ ---------------------*/
+
+static void eth_state_monitor_task(void * param)
+{   
+    /* The eth. should be busy if there is sg. to send. 
+     * It means fail during last send. Try again*/
+    if(app_act_com != NULL && eth_busy() ==  false) {
+        /*Try to send the message again*/
+        lv_app_notice_add("Resend Ethernet message");
+        my_app_data_t * adata = app_act_com->app_data;
+        eth_tcp_transf(adata->last_msg_dp, adata->last_msg_size, tcp_transf_cb);
+    }
+}
+
+static void tcp_transf_cb(eth_state_t state, const char * txt)
+{
+    if(state == ETH_STATE_OK) {
+        uint16_t size =  txt[0] + ((txt[1] << 8) & 0xFF00);
+        char buf[256];
+        memcpy(buf, &txt[2], size);
+        buf[size] = '\0';
+        lv_app_com_send(app_act_com, LV_APP_COM_TYPE_CHAR, &txt[2], size);
+        my_app_data_t * adata = app_act_com->app_data;
+        dm_free(adata->last_msg_dp);
+        adata->last_msg_dp = NULL;
+        adata->last_msg_size = 0;
+        app_act_com = NULL;
+    }else if(state == ETH_STATE_ERROR) {
+        lv_app_notice_add("Ethernet TCP transfer error\n%s", txt);
+    }
+    
+}
+#endif /*LV_APP_ENABLE != 0 && USE_LV_APP_ETHERNET != 0*/

lv_appx/lv_app_ethernet.h

+/**
+ * @file lv_app_ethernet.h
+ *
+ */
+
+#ifndef LV_APP_ETHERNET_H
+#define LV_APP_ETHERNET_H
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+/*********************
+ *      INCLUDES
+ *********************/
+#include "lvgl/lv_app/lv_app.h"
+
+#if LV_APP_ENABLE != 0 && USE_LV_APP_ETHERNET != 0
+
+/*********************
+ *      DEFINES
+ *********************/
+
+/**********************
+ *      TYPEDEFS
+ **********************/
+typedef struct
+{
+
+}lv_app_ethernet_conf_t;
+
+/**********************
+ * GLOBAL PROTOTYPES
+ **********************/
+const lv_app_dsc_t * lv_app_ethernet_init(void);
+
+/**********************
+ *      MACROS
+ **********************/
+
+#endif /*LV_APP_ENABLE != 0 && USE_LV_APP_ETHERNET != 0*/
+
+
+#ifdef __cplusplus
+} /* extern "C" */
+#endif
+
+#endif /* LV_APP_ETHERNET_H */