en61107_request.h File Reference

#include "mqtt.h"
#include "en61107.h"

Include dependency graph for en61107_request.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros
#define	en61107_received_task_prio   USER_TASK_PRIO_2
#define	en61107_received_task_queue_length   64

Typedefs
typedef void(*	meter_is_ready_cb) (void)

Functions
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 unsigned int	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)
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)

Variables
os_event_t	en61107_received_task_queue [en61107_received_task_queue_length]

Macro Definition Documentation

en61107_received_task_prio

#define en61107_received_task_prio   USER_TASK_PRIO_2

Definition at line 7 of file en61107_request.h.

Referenced by en61107_request_init(), and uart0_rx_intr_handler().

en61107_received_task_queue_length

#define en61107_received_task_queue_length   64

Definition at line 8 of file en61107_request.h.

Referenced by en61107_request_init().

Typedef Documentation

meter_is_ready_cb

typedef void(* meter_is_ready_cb) (void)

Definition at line 10 of file en61107_request.h.

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 unsigned int 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_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_received_task_queue

os_event_t en61107_received_task_queue[en61107_received_task_queue_length]

Definition at line 12 of file en61107_request.h.

Referenced by en61107_request_init().