en61107_request.c File Reference

#include <esp8266.h>
#include "driver/uart.h"
#include "unix_time.h"
#include "mqtt.h"
#include "tinyprintf.h"
#include "en61107_request.h"
#include "en61107.h"
#include "config.h"
#include "crypto/crypto.h"
#include "crypto/aes.h"
#include "utils.h"
#include "led.h"

Include dependency graph for en61107_request.c:

Go to the source code of this file.

Macros
#define	QUEUE_SIZE   256

Functions
ICACHE_FLASH_ATTR void	en61107_receive_timeout_timer_func (void *arg)
ICACHE_FLASH_ATTR void	en61107_delayed_uart_change_setting_timer_func (UartDevice *uart_settings)
ICACHE_FLASH_ATTR void	en61107_meter_wake_up_timer_func (void *arg)
static ICACHE_FLASH_ATTR void	en61107_received_task (os_event_t *events)
ICACHE_FLASH_ATTR void	en61107_request_init ()
ICACHE_FLASH_ATTR void	en61107_set_mqtt_client (MQTT_Client *client)
ICACHE_FLASH_ATTR void	en61107_register_meter_is_ready_cb (meter_is_ready_cb cb)
ICACHE_FLASH_ATTR uint32_t	en61107_get_received_serial ()
ICACHE_FLASH_ATTR unsigned int	en61107_get_received_energy_kwh ()
bool	en61107_is_eod_char (uint8_t c)
ICACHE_FLASH_ATTR void	en61107_request_send ()
ICACHE_FLASH_ATTR void	en61107_uart_send_en61107_ident ()
ICACHE_FLASH_ATTR void	en61107_uart_send_en61107 ()
ICACHE_FLASH_ATTR void	en61107_uart_send_standard_data_1 ()
ICACHE_FLASH_ATTR void	en61107_uart_send_standard_data_2 ()
ICACHE_FLASH_ATTR void	en61107_uart_send_inst_values ()
ICACHE_FLASH_ATTR unsigned int	en61107_fifo_in_use ()
unsigned char	en61107_fifo_put (unsigned char c)
ICACHE_FLASH_ATTR unsigned char	en61107_fifo_get (unsigned char *c)
ICACHE_FLASH_ATTR unsigned char	en61107_fifo_snoop (unsigned char *c, unsigned int pos)

Variables
uint32_t	en61107_serial = 0
bool	en61107_serial_set = false
int8_t	en61107_request_num
meter_is_ready_cb	en61107_meter_is_ready_cb = NULL
bool	meter_is_ready_cb_called = false
volatile unsigned int	fifo_head
volatile unsigned int	fifo_tail
volatile unsigned char	fifo_buffer [QUEUE_SIZE]
char	frame [EN61107_FRAME_L]
unsigned int	frame_length
en61107_response_t	response
static MQTT_Client *	mqtt_client = NULL
static os_timer_t	en61107_receive_timeout_timer
static os_timer_t	en61107_delayed_uart_change_setting_timer
static os_timer_t	en61107_meter_wake_up_timer
volatile en61107_uart_state_t	en61107_uart_state
UartDevice	uart_settings
volatile uint8_t	en61107_eod
bool	en61107_etx_received

Macro Definition Documentation

QUEUE_SIZE

#define QUEUE_SIZE   256

Definition at line 15 of file en61107_request.c.

Referenced by en61107_fifo_get(), en61107_fifo_put(), and en61107_fifo_snoop().

Function Documentation

en61107_delayed_uart_change_setting_timer_func()

ICACHE_FLASH_ATTR void en61107_delayed_uart_change_setting_timer_func

(

UartDevice *

uart_settings

)

Definition at line 83 of file en61107_request.c.

References UartDevice::baut_rate, ICACHE_FLASH_ATTR, UartDevice::stop_bits, UART0, uart_set_baudrate(), and uart_set_stop_bits().

Referenced by en61107_uart_send_en61107(), en61107_uart_send_en61107_ident(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), and en61107_uart_send_standard_data_2().

                                                                               {
    uart_set_baudrate(UART0, uart_settings->baut_rate);
//  uart_set_word_length(UART0, SEVEN_BITS);
//  uart_set_parity(UART0, EVEN_BITS);
    uart_set_stop_bits(UART0, uart_settings->stop_bits);
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_fifo_get()

ICACHE_FLASH_ATTR unsigned char en61107_fifo_get

(

unsigned char *

c

)

Definition at line 583 of file en61107_request.c.

References en61107_fifo_in_use(), fifo_buffer, fifo_tail, ICACHE_FLASH_ATTR, and QUEUE_SIZE.

Referenced by en61107_received_task(), and en61107_request_send().

                                                 {
    if (en61107_fifo_in_use() != 0) {
        *c = fifo_buffer[fifo_tail++ % QUEUE_SIZE];
        // wrap
        if (fifo_tail == QUEUE_SIZE) {
            fifo_tail = 0;
        }
        return 1;
    }
    else {
        return 0;
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_fifo_in_use()

ICACHE_FLASH_ATTR unsigned int en61107_fifo_in_use

(

)

Definition at line 563 of file en61107_request.c.

References fifo_head, and fifo_tail.

Referenced by en61107_fifo_get(), en61107_fifo_put(), and en61107_fifo_snoop().

                                   {
    return fifo_head - fifo_tail;
}

Here is the caller graph for this function:

en61107_fifo_put()

unsigned char en61107_fifo_put ( unsigned char  c )

inline

Definition at line 568 of file en61107_request.c.

References en61107_fifo_in_use(), fifo_buffer, fifo_head, ICACHE_FLASH_ATTR, and QUEUE_SIZE.

Referenced by uart0_rx_intr_handler().

                                                       {
    if (en61107_fifo_in_use() != QUEUE_SIZE) {
        fifo_buffer[fifo_head++ % QUEUE_SIZE] = c;
        // wrap
        if (fifo_head == QUEUE_SIZE) {
            fifo_head = 0;
        }
        return 1;
    }
    else {
        return 0;
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_fifo_snoop()

ICACHE_FLASH_ATTR unsigned char en61107_fifo_snoop	(	unsigned char *	c,
		unsigned int	pos
	)

Definition at line 598 of file en61107_request.c.

References en61107_fifo_in_use(), fifo_buffer, fifo_tail, and QUEUE_SIZE.

                                                                     {
    if (en61107_fifo_in_use() > (pos)) {
        *c = fifo_buffer[(fifo_tail + pos) % QUEUE_SIZE];
        return 1;
    }
    else {
        return 0;
    }
}

Here is the call graph for this function:

en61107_get_received_energy_kwh()

ICACHE_FLASH_ATTR unsigned int en61107_get_received_energy_kwh

(

)

Definition at line 320 of file en61107_request.c.

References en61107_response_t::e1, EN61107_UNIT_L, EN61107_VALUE_L, mw_to_w_str(), strncmp, en61107_response_register_t::unit, and en61107_response_register_t::value.

                                               {
    char e1_kwh[EN61107_VALUE_L];

    if (strncmp(response.e1.unit, "MWh", EN61107_UNIT_L) == 0) {
        mw_to_w_str(response.e1.value, e1_kwh);
    }
    return atoi(e1_kwh);
}

Here is the call graph for this function:

en61107_get_received_serial()

ICACHE_FLASH_ATTR uint32_t en61107_get_received_serial

(

)

Definition at line 314 of file en61107_request.c.

References en61107_serial, and ICACHE_FLASH_ATTR.

                                       {
    return en61107_serial;
}

en61107_is_eod_char()

bool en61107_is_eod_char ( uint8_t  c )

inline

Definition at line 330 of file en61107_request.c.

References en61107_eod, en61107_etx_received, and ICACHE_FLASH_ATTR.

Referenced by uart0_rx_intr_handler().

                                           {
    if (en61107_eod == 0x03) {
        // we need to get the next char as well for this protocol
        if (c == en61107_eod) {
            en61107_etx_received = true;
            return false;
        }
        else if (en61107_etx_received) {
//          en61107_etx_received = false;   // DEBUG: should really be here
            return true;
        }
    }
    else {
        if (c == en61107_eod) {
            return true;
        }
        else {
            return false;
        }
    }
    return false;
}

Here is the caller graph for this function:

en61107_meter_wake_up_timer_func()

ICACHE_FLASH_ATTR void en61107_meter_wake_up_timer_func

(

void *

arg

)

Definition at line 91 of file en61107_request.c.

References en61107_uart_send_en61107_ident(), and ICACHE_FLASH_ATTR.

Referenced by en61107_receive_timeout_timer_func(), and en61107_request_send().

                                                 {
//  en61107_uart_state = UART_STATE_EN61107_IDENT;
    en61107_uart_send_en61107_ident();
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_receive_timeout_timer_func()

ICACHE_FLASH_ATTR void en61107_receive_timeout_timer_func

(

void *

arg

)

Definition at line 49 of file en61107_request.c.

References en61107_meter_wake_up_timer, en61107_meter_wake_up_timer_func(), en61107_request_num, en61107_uart_send_en61107_ident(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), en61107_uart_send_standard_data_2(), en61107_uart_state, ICACHE_FLASH_ATTR, led_blink(), NULL, os_timer_arm, os_timer_disarm, os_timer_func_t, os_timer_setfn, UART_STATE_EN61107, UART_STATE_EN61107_IDENT, UART_STATE_INST_VALUES, UART_STATE_STANDARD_DATA_1, and UART_STATE_STANDARD_DATA_2.

Referenced by en61107_uart_send_en61107(), en61107_uart_send_en61107_ident(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), and en61107_uart_send_standard_data_2().

                                                   {
    led_blink();    // DEBUG
    // if no reply received, retransmit

    if (en61107_request_num <= 2) {
        switch (en61107_uart_state) {
            case UART_STATE_EN61107_IDENT:
                en61107_uart_send_en61107_ident();
                break;
            case UART_STATE_EN61107:
                en61107_uart_send_en61107_ident();  // restart en61107 request from state UART_STATE_EN61107_IDENT
                break;
#ifndef MC_66B
            case UART_STATE_INST_VALUES:
                en61107_uart_send_inst_values();
                break;
#endif
            case UART_STATE_STANDARD_DATA_1:
                en61107_uart_send_standard_data_1();
                break;
            case UART_STATE_STANDARD_DATA_2:
                en61107_uart_send_standard_data_2();
                break;
        }
    }
    else {
        // too many errors, wait for meter to be clear and start over
        os_timer_disarm(&en61107_meter_wake_up_timer);
        os_timer_setfn(&en61107_meter_wake_up_timer, (os_timer_func_t *)en61107_meter_wake_up_timer_func, NULL);
        os_timer_arm(&en61107_meter_wake_up_timer, 60000, 0);         // wait 60 seconds
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_received_task()

static ICACHE_FLASH_ATTR void en61107_received_task ( os_event_t *  events )

static

Definition at line 98 of file en61107_request.c.

References en61107_meter_program_t::a, en61107_meter_program_t::b, en61107_meter_program_t::ccc, current_unix_time, en61107_response_t::customer_no, en61107_meter_program_t::dd, en61107_meter_program_t::e, en61107_response_t::e1, en61107_response_t::effect1, en61107_fifo_get(), EN61107_FRAME_L, en61107_meter_is_ready_cb, en61107_receive_timeout_timer, en61107_request_num, en61107_serial, en61107_serial_set, en61107_uart_send_en61107(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), en61107_uart_send_standard_data_2(), en61107_uart_state, encrypt_aes_hmac_combined(), en61107_meter_program_t::ff, en61107_response_t::flow1, get_unix_time(), en61107_meter_program_t::gg, en61107_response_t::hr, ICACHE_FLASH_ATTR, memset, meter_is_ready_cb_called, en61107_response_t::meter_program, MQTT_Publish(), MQTT_TOPIC_L, os_memset, os_printf, os_strncpy, os_timer_disarm, parse_en61107_frame(), parse_mc66cde_inst_values_frame(), parse_mc66cde_standard_data_1_frame(), parse_mc66cde_standard_data_2_frame(), strcat, strlen, system_get_free_heap_size(), en61107_response_t::t1, en61107_response_t::t2, en61107_response_t::t3, en61107_response_t::tdif, tfp_snprintf(), UART_STATE_EN61107, UART_STATE_EN61107_IDENT, UART_STATE_INST_VALUES, UART_STATE_NONE, UART_STATE_STANDARD_DATA_1, UART_STATE_STANDARD_DATA_2, en61107_response_register_t::unit, en61107_response_t::v1, and en61107_response_register_t::value.

Referenced by en61107_request_init().

                                                      {
    unsigned char c;
    unsigned int i;
    uint64_t current_unix_time;
    char current_unix_time_string[64];  // BUGFIX var
    char key_value[128];
    unsigned char topic[MQTT_TOPIC_L];
    unsigned char message[EN61107_FRAME_L];
    int message_l;

    // vars for aes encryption
    uint8_t cleartext[EN61107_FRAME_L];

    switch (en61107_uart_state) {
        case UART_STATE_EN61107_IDENT:
            // dont en61107_fifo_get() anything here, we get it in next state
            en61107_uart_send_en61107();
            break;
        case UART_STATE_EN61107:
            // get message buffer
            memset(message, 0, sizeof(message));
            i = 0;
            while (en61107_fifo_get(&c) && (i <= EN61107_FRAME_L)) {
                message[i++] = c;
            }
            message_l = i;

            if (parse_en61107_frame(&response, message, message_l) == false) {
                // timeout if we cant parse response
                break;
            }

            en61107_serial = atoi(response.customer_no);
            en61107_serial_set = true;

#ifndef MC_66B
            en61107_uart_send_inst_values();
#else
            en61107_uart_send_standard_data_1();
#endif
            break;
#ifndef MC_66B
        case UART_STATE_INST_VALUES:
            // get message buffer
            memset(message, 0, sizeof(message));
            i = 0;
            while (en61107_fifo_get(&c) && (i <= EN61107_FRAME_L)) {
                message[i++] = c;
            }
            message_l = i;

            if (parse_mc66cde_inst_values_frame(&response, message, message_l) == false) {
                // timeout if we cant parse response
                break;
            }

            en61107_uart_send_standard_data_1();
            break;
#endif
        case UART_STATE_STANDARD_DATA_1:
            // get message buffer
            memset(message, 0, sizeof(message));
            i = 0;
            while (en61107_fifo_get(&c) && (i <= EN61107_FRAME_L)) {
                message[i++] = c;
            }
            message_l = i;
            message[message_l - 2] = 0;     // remove last two chars and null terminate

            if (parse_mc66cde_standard_data_1_frame(&response, message, message_l)) {
                // if we can parse, send next request to meter
                en61107_uart_send_standard_data_2();
                break;
            }

            break;
        case UART_STATE_STANDARD_DATA_2:
            // get message buffer
            memset(message, 0, sizeof(message));
            i = 0;
            while (en61107_fifo_get(&c) && (i <= EN61107_FRAME_L)) {
                message[i++] = c;
            }
            message_l = i;
            message[message_l - 2] = 0;     // remove last two chars and null terminate

            if (parse_mc66cde_standard_data_2_frame(&response, message, message_l)) {
                // tell user_main we got a serial
                if (en61107_meter_is_ready_cb && !meter_is_ready_cb_called) {
                    meter_is_ready_cb_called = true;
                    en61107_meter_is_ready_cb();
                }
#ifdef DEBUG
                else {
                    os_printf("tried to call en61107_meter_is_ready_cb() before it was set - should not happen\n");
                }
#endif
                current_unix_time = (uint32)(get_unix_time());      // TODO before 2038 ,-)
                if (current_unix_time) {    // only send mqtt if we got current time via ntp
                    // format /sample/v2/serial/unix_time => val1=23&val2=val3&baz=blah
                    memset(topic, 0, sizeof(topic));            // clear it
                    tfp_snprintf(current_unix_time_string, 64, "%u", (uint32_t)current_unix_time);
                    tfp_snprintf(topic, MQTT_TOPIC_L, "/sample/v2/%07u/%s", en61107_serial, current_unix_time_string);

                    memset(message, 0, sizeof(message));            // clear it

                    // heap size
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "heap=%u&", system_get_free_heap_size());
                    strcat(message, key_value);

                    // meter program
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "program=%01u%01u%03u%02u%01u%02u%02u&", 
                        response.meter_program.a, 
                        response.meter_program.b, 
                        response.meter_program.ccc, 
                        response.meter_program.dd, 
                        response.meter_program.e, 
                        response.meter_program.ff, 
                        response.meter_program.gg
                    );
                    strcat(message, key_value);

                    // heating meter specific
                    // flow temperature
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "t1=%s %s&", response.t1.value, response.t1.unit);
                    strcat(message, key_value);
            
                    // return flow temperature
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "t2=%s %s&", response.t2.value, response.t2.unit);
                    strcat(message, key_value);

#ifndef MC_66B
                    // t3 temperature
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "t3=%s %s&", response.t3.value, response.t3.unit);
                    strcat(message, key_value);
#endif

                    // calculated temperature difference
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "tdif=%s %s&", response.tdif.value, response.tdif.unit);
                    strcat(message, key_value);

                    // flow
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "flow1=%s %s&", response.flow1.value, response.flow1.unit);
                    strcat(message, key_value);

                    // current power
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "effect1=%s %s&", response.effect1.value, response.effect1.unit);
                    strcat(message, key_value);

                    // hours
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "hr=%s %s&", response.hr.value, response.hr.unit);
                    strcat(message, key_value);

                    // volume
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "v1=%s %s&", response.v1.value, response.v1.unit);
                    strcat(message, key_value);

                    // power
                    tfp_snprintf(key_value, MQTT_TOPIC_L, "e1=%s %s&", response.e1.value, response.e1.unit);
                    strcat(message, key_value);

                    memset(cleartext, 0, sizeof(cleartext));
                    os_strncpy(cleartext, message, sizeof(message));    // make a copy of message for later use
                    os_memset(message, 0, sizeof(message));             // ...and clear it

                    // encrypt and send
                    message_l = encrypt_aes_hmac_combined(message, topic, strlen(topic), cleartext, strlen(cleartext) + 1);

                    // and stop retransmission timeout timer, last data from meter
                    os_timer_disarm(&en61107_receive_timeout_timer);

                    if (mqtt_client) {
                        // if mqtt_client is initialized
                        if (message_l > 1) {
                            MQTT_Publish(mqtt_client, topic, message, message_l, 2, 0); // QoS level 2
                        }
                    }

                    // change to last state - idle state
                    en61107_uart_state = UART_STATE_NONE;
                    en61107_request_num = 0;
                }
            }
            break;
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_register_meter_is_ready_cb()

ICACHE_FLASH_ATTR void en61107_register_meter_is_ready_cb

(

meter_is_ready_cb

cb

)

Definition at line 308 of file en61107_request.c.

References en61107_meter_is_ready_cb, and ICACHE_FLASH_ATTR.

                                                              {
    en61107_meter_is_ready_cb = cb;
}

en61107_request_init()

ICACHE_FLASH_ATTR void en61107_request_init

(

)

Definition at line 286 of file en61107_request.c.

References en61107_etx_received, en61107_received_task(), en61107_received_task_prio, en61107_received_task_queue, en61107_received_task_queue_length, en61107_request_num, en61107_uart_state, fifo_head, fifo_tail, ICACHE_FLASH_ATTR, memset, system_os_task(), and UART_STATE_NONE.

                            {
    fifo_head = 0;
    fifo_tail = 0;

    memset(&response, 0, sizeof(response)); // zero response before use

    en61107_uart_state = UART_STATE_NONE;

    en61107_request_num = 0;

    en61107_etx_received = false;
    
    system_os_task(en61107_received_task, en61107_received_task_prio, en61107_received_task_queue, en61107_received_task_queue_length);
}

Here is the call graph for this function:

en61107_request_send()

ICACHE_FLASH_ATTR void en61107_request_send

(

)

Definition at line 354 of file en61107_request.c.

References en61107_fifo_get(), EN61107_FRAME_L, en61107_meter_wake_up_timer, en61107_meter_wake_up_timer_func(), en61107_request_num, en61107_serial, en61107_uart_state, encrypt_aes_hmac_combined(), get_unix_time(), ICACHE_FLASH_ATTR, memset, MQTT_Publish(), NULL, os_memset, os_sprintf, os_strncpy, os_timer_arm, os_timer_disarm, os_timer_func_t, os_timer_setfn, strlen, and UART_STATE_NONE.

                            {
#ifndef DEBUG_NO_METER
    unsigned char c;
    unsigned int i;

    // clear message buffer
    i = 0;
    while (en61107_fifo_get(&c) && (i <= EN61107_FRAME_L)) {
        i++;
    }

    en61107_request_num++;
    if (en61107_uart_state == UART_STATE_NONE) {
        // give the meter some time between retransmissions
        os_timer_disarm(&en61107_meter_wake_up_timer);
        os_timer_setfn(&en61107_meter_wake_up_timer, (os_timer_func_t *)en61107_meter_wake_up_timer_func, NULL);
        os_timer_arm(&en61107_meter_wake_up_timer, 6000, 0);         // 6 seconds for meter to wake up
    }

#else
    unsigned char topic[128];
    unsigned char cleartext[EN61107_FRAME_L];
    unsigned char message[EN61107_FRAME_L];
    int topic_l;
    int message_l;
    
    // fake serial for testing without meter
    en61107_serial = 4615611;
    
    topic_l = os_sprintf(topic, "/sample/v2/%u/%u", en61107_serial, get_unix_time());
    message_l = os_sprintf(message, "heap=20000&t1=25.00 C&t2=15.00 C&tdif=10.00 K&flow1=0 l/h&effect1=0.0 kW&hr=0 h&v1=0.00 m3&e1=0 kWh&");
    memset(cleartext, 0, sizeof(cleartext));
    os_strncpy(cleartext, message, sizeof(message));    // make a copy of message for later use
    os_memset(message, 0, sizeof(message));             // ...and clear it

    message_l = encrypt_aes_hmac_combined(message, topic, strlen(topic), cleartext, strlen(cleartext) + 1);

    if (mqtt_client) {
        // if mqtt_client is initialized
        if (message_l > 1) {
            MQTT_Publish(mqtt_client, topic, message, message_l, 2, 0); // QoS level 2
        }
    }

#endif
}

Here is the call graph for this function:

en61107_set_mqtt_client()

ICACHE_FLASH_ATTR void en61107_set_mqtt_client

(

MQTT_Client *

client

)

Definition at line 303 of file en61107_request.c.

References ICACHE_FLASH_ATTR.

                                                  {
    mqtt_client = client;
}

en61107_uart_send_en61107()

ICACHE_FLASH_ATTR void en61107_uart_send_en61107

(

)

Definition at line 434 of file en61107_request.c.

References UartDevice::baut_rate, BIT_RATE_300, en61107_delayed_uart_change_setting_timer, en61107_delayed_uart_change_setting_timer_func(), en61107_eod, en61107_etx_received, en61107_receive_timeout_timer, en61107_receive_timeout_timer_func(), en61107_uart_state, EVEN_BITS, frame, frame_length, ICACHE_FLASH_ATTR, NULL, ONE_STOP_BIT, os_timer_arm, os_timer_disarm, os_timer_func_t, os_timer_setfn, SEVEN_BITS, UartDevice::stop_bits, strcpy, strlen, TWO_STOP_BIT, UART0, uart0_tx_buffer(), uart_set_baudrate(), uart_set_parity(), uart_set_stop_bits(), uart_set_word_length(), and UART_STATE_EN61107.

Referenced by en61107_received_task().

                                 {
    en61107_eod = 0x03;
    en61107_etx_received = false;   // DEBUG: should be in en61107_is_eod_char() but does not work

    // 300 bps
    uart_set_baudrate(UART0, BIT_RATE_300);
    uart_set_word_length(UART0, SEVEN_BITS);
    uart_set_parity(UART0, EVEN_BITS);
    uart_set_stop_bits(UART0, TWO_STOP_BIT);

    // change to next state
    en61107_uart_state = UART_STATE_EN61107;

    // and start retransmission timeout timer
    os_timer_disarm(&en61107_receive_timeout_timer);
    os_timer_setfn(&en61107_receive_timeout_timer, (os_timer_func_t *)en61107_receive_timeout_timer_func, NULL);
    os_timer_arm(&en61107_receive_timeout_timer, 8000, 0);         // 8 seconds for UART_STATE_EN61107

    strcpy(frame, "\006000\r\n");
    frame_length = strlen(frame);
    uart0_tx_buffer(frame, frame_length);     // send request

    // reply is 300 bps, 7e1, not 7e2 as stated in standard
    uart_settings.baut_rate = BIT_RATE_300;
    uart_settings.stop_bits = ONE_STOP_BIT;
    // change uart settings after the data has been sent
    os_timer_disarm(&en61107_delayed_uart_change_setting_timer);
    os_timer_setfn(&en61107_delayed_uart_change_setting_timer, (os_timer_func_t *)en61107_delayed_uart_change_setting_timer_func, &uart_settings);
    os_timer_arm(&en61107_delayed_uart_change_setting_timer, 400, 0);   // 400 mS
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_uart_send_en61107_ident()

ICACHE_FLASH_ATTR void en61107_uart_send_en61107_ident

(

)

Definition at line 402 of file en61107_request.c.

References UartDevice::baut_rate, BIT_RATE_300, en61107_delayed_uart_change_setting_timer, en61107_delayed_uart_change_setting_timer_func(), en61107_eod, en61107_etx_received, en61107_receive_timeout_timer, en61107_receive_timeout_timer_func(), en61107_uart_state, EVEN_BITS, frame, frame_length, ICACHE_FLASH_ATTR, NULL, ONE_STOP_BIT, os_timer_arm, os_timer_disarm, os_timer_func_t, os_timer_setfn, SEVEN_BITS, UartDevice::stop_bits, strcpy, strlen, TWO_STOP_BIT, UART0, uart0_tx_buffer(), uart_set_baudrate(), uart_set_parity(), uart_set_stop_bits(), uart_set_word_length(), and UART_STATE_EN61107_IDENT.

Referenced by en61107_meter_wake_up_timer_func(), and en61107_receive_timeout_timer_func().

                                       {
    en61107_eod = '\n';
    en61107_etx_received = false;   // DEBUG: should be in en61107_is_eod_char() but does not work

    // 300 bps
    uart_set_baudrate(UART0, BIT_RATE_300);
    uart_set_word_length(UART0, SEVEN_BITS);
    uart_set_parity(UART0, EVEN_BITS);
    uart_set_stop_bits(UART0, TWO_STOP_BIT);

    // change to next state
    en61107_uart_state = UART_STATE_EN61107_IDENT;

    // and start retransmission timeout timer
    os_timer_disarm(&en61107_receive_timeout_timer);
    os_timer_setfn(&en61107_receive_timeout_timer, (os_timer_func_t *)en61107_receive_timeout_timer_func, NULL);
    os_timer_arm(&en61107_receive_timeout_timer, 3000, 0);         // 3 seconds for UART_STATE_EN61107_IDENT

    strcpy(frame, "/?!\r\n");
    frame_length = strlen(frame);
    uart0_tx_buffer(frame, frame_length);     // send request

    // reply is 300 bps, 7e1, not 7e2 as stated in standard
    uart_settings.baut_rate = BIT_RATE_300;
    uart_settings.stop_bits = ONE_STOP_BIT;
    // change uart settings after the data has been sent
    os_timer_disarm(&en61107_delayed_uart_change_setting_timer);
    os_timer_setfn(&en61107_delayed_uart_change_setting_timer, (os_timer_func_t *)en61107_delayed_uart_change_setting_timer_func, &uart_settings);
    os_timer_arm(&en61107_delayed_uart_change_setting_timer, 400, 0);   // 400 mS
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_uart_send_inst_values()

ICACHE_FLASH_ATTR void en61107_uart_send_inst_values

(

)

Definition at line 529 of file en61107_request.c.

References UartDevice::baut_rate, BIT_RATE_1200, BIT_RATE_300, en61107_delayed_uart_change_setting_timer, en61107_delayed_uart_change_setting_timer_func(), en61107_eod, en61107_receive_timeout_timer, en61107_receive_timeout_timer_func(), en61107_uart_state, EVEN_BITS, frame, frame_length, ICACHE_FLASH_ATTR, NULL, ONE_STOP_BIT, os_timer_arm, os_timer_disarm, os_timer_func_t, os_timer_setfn, SEVEN_BITS, UartDevice::stop_bits, strcpy, strlen, TWO_STOP_BIT, UART0, uart0_tx_buffer(), uart_set_baudrate(), uart_set_parity(), uart_set_stop_bits(), uart_set_word_length(), and UART_STATE_INST_VALUES.

Referenced by en61107_receive_timeout_timer_func(), and en61107_received_task().

                                     {
    en61107_eod = '\r';

    // 300 bps
    uart_set_baudrate(UART0, BIT_RATE_300);
    uart_set_word_length(UART0, SEVEN_BITS);
    uart_set_parity(UART0, EVEN_BITS);
    uart_set_stop_bits(UART0, TWO_STOP_BIT);

    // change to next state
    en61107_uart_state = UART_STATE_INST_VALUES;

    // and start retransmission timeout timer
    os_timer_disarm(&en61107_receive_timeout_timer);
    os_timer_setfn(&en61107_receive_timeout_timer, (os_timer_func_t *)en61107_receive_timeout_timer_func, NULL);
    os_timer_arm(&en61107_receive_timeout_timer, 3200, 0);         // 3.2 seconds for UART_STATE_INST_VALUES

    strcpy(frame, "/#C");
    frame_length = strlen(frame);
    uart0_tx_buffer(frame, frame_length);     // send request

    // reply is 1200 bps, 7e1, not 7e2 as stated in standard
    uart_settings.baut_rate = BIT_RATE_1200;
    uart_settings.stop_bits = ONE_STOP_BIT;
    // change uart settings after the data has been sent
    os_timer_disarm(&en61107_delayed_uart_change_setting_timer);
    os_timer_setfn(&en61107_delayed_uart_change_setting_timer, (os_timer_func_t *)en61107_delayed_uart_change_setting_timer_func, &uart_settings);
    os_timer_arm(&en61107_delayed_uart_change_setting_timer, 300, 0);   // 300 mS
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_uart_send_standard_data_1()

ICACHE_FLASH_ATTR void en61107_uart_send_standard_data_1

(

)

Definition at line 466 of file en61107_request.c.

References UartDevice::baut_rate, BIT_RATE_1200, BIT_RATE_300, en61107_delayed_uart_change_setting_timer, en61107_delayed_uart_change_setting_timer_func(), en61107_eod, en61107_receive_timeout_timer, en61107_receive_timeout_timer_func(), en61107_uart_state, EVEN_BITS, frame, frame_length, ICACHE_FLASH_ATTR, NULL, ONE_STOP_BIT, os_timer_arm, os_timer_disarm, os_timer_func_t, os_timer_setfn, SEVEN_BITS, UartDevice::stop_bits, strcpy, strlen, TWO_STOP_BIT, UART0, uart0_tx_buffer(), uart_set_baudrate(), uart_set_parity(), uart_set_stop_bits(), uart_set_word_length(), and UART_STATE_STANDARD_DATA_1.

Referenced by en61107_receive_timeout_timer_func(), and en61107_received_task().

                                         {
    en61107_eod = '\r';

    // 300 bps
    uart_set_baudrate(UART0, BIT_RATE_300);
    uart_set_word_length(UART0, SEVEN_BITS);
    uart_set_parity(UART0, EVEN_BITS);
    uart_set_stop_bits(UART0, TWO_STOP_BIT);
    
    // change to next state
    en61107_uart_state = UART_STATE_STANDARD_DATA_1;

    // and start retransmission timeout timer
    os_timer_disarm(&en61107_receive_timeout_timer);
    os_timer_setfn(&en61107_receive_timeout_timer, (os_timer_func_t *)en61107_receive_timeout_timer_func, NULL);
    os_timer_arm(&en61107_receive_timeout_timer, 3000, 0);         // 3 seconds for UART_STATE_STANDARD_DATA_1

    strcpy(frame, "/#1\r");
    frame_length = strlen(frame);
    uart0_tx_buffer(frame, frame_length);     // send request

    // reply is 1200 bps, 7e1, not 7e2 as stated in standard
    uart_settings.baut_rate = BIT_RATE_1200;
    uart_settings.stop_bits = ONE_STOP_BIT;
    // change uart settings after the data has been sent
    os_timer_disarm(&en61107_delayed_uart_change_setting_timer);
    os_timer_setfn(&en61107_delayed_uart_change_setting_timer, (os_timer_func_t *)en61107_delayed_uart_change_setting_timer_func, &uart_settings);
    os_timer_arm(&en61107_delayed_uart_change_setting_timer, 220, 0);   // 220 mS
}

Here is the call graph for this function:

Here is the caller graph for this function:

en61107_uart_send_standard_data_2()

ICACHE_FLASH_ATTR void en61107_uart_send_standard_data_2

(

)

Definition at line 497 of file en61107_request.c.

References UartDevice::baut_rate, BIT_RATE_1200, BIT_RATE_300, en61107_delayed_uart_change_setting_timer, en61107_delayed_uart_change_setting_timer_func(), en61107_eod, en61107_receive_timeout_timer, en61107_receive_timeout_timer_func(), en61107_uart_state, EVEN_BITS, frame, frame_length, ICACHE_FLASH_ATTR, NULL, ONE_STOP_BIT, os_timer_arm, os_timer_disarm, os_timer_func_t, os_timer_setfn, SEVEN_BITS, UartDevice::stop_bits, strcpy, strlen, TWO_STOP_BIT, UART0, uart0_tx_buffer(), uart_set_baudrate(), uart_set_parity(), uart_set_stop_bits(), uart_set_word_length(), and UART_STATE_STANDARD_DATA_2.

Referenced by en61107_receive_timeout_timer_func(), and en61107_received_task().

                                         {
    en61107_eod = '\r';

    // 300 bps
    uart_set_baudrate(UART0, BIT_RATE_300);
    uart_set_word_length(UART0, SEVEN_BITS);
    uart_set_parity(UART0, EVEN_BITS);
    uart_set_stop_bits(UART0, TWO_STOP_BIT);
    
    // change to next state
    en61107_uart_state = UART_STATE_STANDARD_DATA_2;

    // and start retransmission timeout timer
    os_timer_disarm(&en61107_receive_timeout_timer);
    os_timer_setfn(&en61107_receive_timeout_timer, (os_timer_func_t *)en61107_receive_timeout_timer_func, NULL);
    os_timer_arm(&en61107_receive_timeout_timer, 3000, 0);         // 3 seconds for UART_STATE_STANDARD_DATA_2

    strcpy(frame, "/#2\r");
    frame_length = strlen(frame);
    uart0_tx_buffer(frame, frame_length);     // send request

    // reply is 1200 bps, 7e1, not 7e2 as stated in standard
    uart_settings.baut_rate = BIT_RATE_1200;
    uart_settings.stop_bits = ONE_STOP_BIT;
    // change uart settings after the data has been sent
    os_timer_disarm(&en61107_delayed_uart_change_setting_timer);
    os_timer_setfn(&en61107_delayed_uart_change_setting_timer, (os_timer_func_t *)en61107_delayed_uart_change_setting_timer_func, &uart_settings);
    os_timer_arm(&en61107_delayed_uart_change_setting_timer, 220, 0);   // 220 mS
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

en61107_delayed_uart_change_setting_timer

os_timer_t en61107_delayed_uart_change_setting_timer

static

Definition at line 38 of file en61107_request.c.

Referenced by en61107_uart_send_en61107(), en61107_uart_send_en61107_ident(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), and en61107_uart_send_standard_data_2().

en61107_eod

volatile uint8_t en61107_eod

Definition at line 45 of file en61107_request.c.

Referenced by en61107_is_eod_char(), en61107_uart_send_en61107(), en61107_uart_send_en61107_ident(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), and en61107_uart_send_standard_data_2().

en61107_etx_received

bool en61107_etx_received

Definition at line 46 of file en61107_request.c.

Referenced by en61107_is_eod_char(), en61107_request_init(), en61107_uart_send_en61107(), and en61107_uart_send_en61107_ident().

en61107_meter_is_ready_cb

meter_is_ready_cb en61107_meter_is_ready_cb = NULL

Definition at line 20 of file en61107_request.c.

Referenced by en61107_received_task(), and en61107_register_meter_is_ready_cb().

en61107_meter_wake_up_timer

os_timer_t en61107_meter_wake_up_timer

static

Definition at line 39 of file en61107_request.c.

Referenced by en61107_receive_timeout_timer_func(), and en61107_request_send().

en61107_receive_timeout_timer

os_timer_t en61107_receive_timeout_timer

static

Definition at line 37 of file en61107_request.c.

Referenced by en61107_received_task(), en61107_uart_send_en61107(), en61107_uart_send_en61107_ident(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), and en61107_uart_send_standard_data_2().

en61107_request_num

int8_t en61107_request_num

Definition at line 19 of file en61107_request.c.

Referenced by en61107_receive_timeout_timer_func(), en61107_received_task(), en61107_request_init(), and en61107_request_send().

en61107_serial

uint32_t en61107_serial = 0

Definition at line 17 of file en61107_request.c.

Referenced by en61107_get_received_serial(), en61107_received_task(), and en61107_request_send().

en61107_serial_set

bool en61107_serial_set = false

Definition at line 18 of file en61107_request.c.

Referenced by en61107_received_task().

en61107_uart_state

volatile en61107_uart_state_t en61107_uart_state

Definition at line 41 of file en61107_request.c.

Referenced by en61107_receive_timeout_timer_func(), en61107_received_task(), en61107_request_init(), en61107_request_send(), en61107_uart_send_en61107(), en61107_uart_send_en61107_ident(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), and en61107_uart_send_standard_data_2().

fifo_buffer

volatile unsigned char fifo_buffer[QUEUE_SIZE]

Definition at line 26 of file en61107_request.c.

Referenced by en61107_fifo_get(), en61107_fifo_put(), and en61107_fifo_snoop().

fifo_head

volatile unsigned int fifo_head

Definition at line 25 of file en61107_request.c.

Referenced by en61107_fifo_in_use(), en61107_fifo_put(), and en61107_request_init().

fifo_tail

volatile unsigned int fifo_tail

Definition at line 25 of file en61107_request.c.

Referenced by en61107_fifo_get(), en61107_fifo_in_use(), en61107_fifo_snoop(), and en61107_request_init().

frame

char frame[EN61107_FRAME_L]

Definition at line 29 of file en61107_request.c.

Referenced by en61107_uart_send_en61107(), en61107_uart_send_en61107_ident(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), en61107_uart_send_standard_data_2(), kmp_decode_frame(), kmp_get_register(), kmp_get_serial(), kmp_get_type(), and parse_en61107_frame().

frame_length

unsigned int frame_length

Definition at line 30 of file en61107_request.c.

Referenced by en61107_uart_send_en61107(), en61107_uart_send_en61107_ident(), en61107_uart_send_inst_values(), en61107_uart_send_standard_data_1(), en61107_uart_send_standard_data_2(), kmp_decode_frame(), and parse_en61107_frame().

meter_is_ready_cb_called

bool meter_is_ready_cb_called = false

Definition at line 21 of file en61107_request.c.

Referenced by en61107_received_task().

mqtt_client

MQTT_Client* mqtt_client = NULL

static

Definition at line 35 of file en61107_request.c.

response

en61107_response_t response

Definition at line 33 of file en61107_request.c.

Referenced by kmp_decode_frame().

uart_settings

UartDevice uart_settings

Definition at line 43 of file en61107_request.c.