410 lines
14 KiB
C
410 lines
14 KiB
C
// Copyright 2015-2016 Espressif Systems (Shanghai) PTE LTD
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
#include <stddef.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
|
|
#include "esp_err.h"
|
|
#include "esp_wifi.h"
|
|
#include "esp_wifi_internal.h"
|
|
#include "esp_event.h"
|
|
#include "esp_event_loop.h"
|
|
#include "esp_task.h"
|
|
#include "esp_eth.h"
|
|
|
|
#include "rom/ets_sys.h"
|
|
|
|
#include "freertos/FreeRTOS.h"
|
|
#include "freertos/task.h"
|
|
#include "freertos/queue.h"
|
|
#include "freertos/semphr.h"
|
|
|
|
#include "tcpip_adapter.h"
|
|
#include "esp_log.h"
|
|
|
|
const char* TAG = "event";
|
|
|
|
#define WIFI_API_CALL_CHECK(info, api_call, ret) \
|
|
do{\
|
|
esp_err_t __err = (api_call);\
|
|
if ((ret) != __err) {\
|
|
ESP_LOGE(TAG, "%s %d %s ret=%d", __FUNCTION__, __LINE__, (info), __err);\
|
|
return __err;\
|
|
}\
|
|
} while(0)
|
|
|
|
typedef esp_err_t (*system_event_handler_t)(system_event_t *e);
|
|
|
|
#ifdef CONFIG_WIFI_ENABLED
|
|
static esp_err_t system_event_ap_start_handle_default(system_event_t *event);
|
|
static esp_err_t system_event_ap_stop_handle_default(system_event_t *event);
|
|
static esp_err_t system_event_sta_start_handle_default(system_event_t *event);
|
|
static esp_err_t system_event_sta_stop_handle_default(system_event_t *event);
|
|
static esp_err_t system_event_sta_connected_handle_default(system_event_t *event);
|
|
static esp_err_t system_event_sta_disconnected_handle_default(system_event_t *event);
|
|
static esp_err_t system_event_sta_got_ip_default(system_event_t *event);
|
|
#endif
|
|
|
|
#ifdef CONFIG_ETHERNET
|
|
static esp_err_t system_event_eth_start_handle_default(system_event_t *event);
|
|
static esp_err_t system_event_eth_stop_handle_default(system_event_t *event);
|
|
static esp_err_t system_event_eth_connected_handle_default(system_event_t *event);
|
|
static esp_err_t system_event_eth_disconnected_handle_default(system_event_t *event);
|
|
#endif
|
|
|
|
/* Default event handler functions
|
|
|
|
Any entry in this table which is disabled by config will have a NULL handler.
|
|
*/
|
|
static const system_event_handler_t default_event_handlers[SYSTEM_EVENT_MAX] = {
|
|
#ifdef CONFIG_WIFI_ENABLED
|
|
[SYSTEM_EVENT_WIFI_READY] = NULL,
|
|
[SYSTEM_EVENT_SCAN_DONE] = NULL,
|
|
[SYSTEM_EVENT_STA_START] = system_event_sta_start_handle_default,
|
|
[SYSTEM_EVENT_STA_STOP] = system_event_sta_stop_handle_default,
|
|
[SYSTEM_EVENT_STA_CONNECTED] = system_event_sta_connected_handle_default,
|
|
[SYSTEM_EVENT_STA_DISCONNECTED] = system_event_sta_disconnected_handle_default,
|
|
[SYSTEM_EVENT_STA_AUTHMODE_CHANGE] = NULL,
|
|
[SYSTEM_EVENT_STA_GOT_IP] = system_event_sta_got_ip_default,
|
|
[SYSTEM_EVENT_STA_WPS_ER_SUCCESS] = NULL,
|
|
[SYSTEM_EVENT_STA_WPS_ER_FAILED] = NULL,
|
|
[SYSTEM_EVENT_STA_WPS_ER_TIMEOUT] = NULL,
|
|
[SYSTEM_EVENT_STA_WPS_ER_PIN] = NULL,
|
|
[SYSTEM_EVENT_AP_START] = system_event_ap_start_handle_default,
|
|
[SYSTEM_EVENT_AP_STOP] = system_event_ap_stop_handle_default,
|
|
[SYSTEM_EVENT_AP_STACONNECTED] = NULL,
|
|
[SYSTEM_EVENT_AP_STADISCONNECTED] = NULL,
|
|
[SYSTEM_EVENT_AP_PROBEREQRECVED] = NULL,
|
|
[SYSTEM_EVENT_AP_STA_GOT_IP6] = NULL,
|
|
#endif
|
|
#ifdef CONFIG_ETHERNET
|
|
[SYSTEM_EVENT_ETH_START] = system_event_eth_start_handle_default,
|
|
[SYSTEM_EVENT_ETH_STOP] = system_event_eth_stop_handle_default,
|
|
[SYSTEM_EVENT_ETH_CONNECTED] = system_event_eth_connected_handle_default,
|
|
[SYSTEM_EVENT_ETH_DISCONNECTED] = system_event_eth_disconnected_handle_default,
|
|
[SYSTEM_EVENT_ETH_GOT_IP] = NULL,
|
|
#endif
|
|
};
|
|
|
|
#ifdef CONFIG_ETHERNET
|
|
esp_err_t system_event_eth_start_handle_default(system_event_t *event)
|
|
{
|
|
tcpip_adapter_ip_info_t eth_ip;
|
|
uint8_t eth_mac[6];
|
|
|
|
esp_eth_get_mac(eth_mac);
|
|
tcpip_adapter_get_ip_info(TCPIP_ADAPTER_IF_ETH, ð_ip);
|
|
tcpip_adapter_start(TCPIP_ADAPTER_IF_ETH, eth_mac, ð_ip);
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t system_event_eth_stop_handle_default(system_event_t *event)
|
|
{
|
|
tcpip_adapter_stop(TCPIP_ADAPTER_IF_ETH);
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t system_event_eth_connected_handle_default(system_event_t *event)
|
|
{
|
|
tcpip_adapter_dhcp_status_t status;
|
|
|
|
tcpip_adapter_up(TCPIP_ADAPTER_IF_ETH);
|
|
|
|
tcpip_adapter_dhcpc_get_status(TCPIP_ADAPTER_IF_ETH, &status);
|
|
|
|
if (status == TCPIP_ADAPTER_DHCP_INIT) {
|
|
tcpip_adapter_dhcpc_start(TCPIP_ADAPTER_IF_ETH);
|
|
} else if (status == TCPIP_ADAPTER_DHCP_STOPPED) {
|
|
tcpip_adapter_ip_info_t eth_ip;
|
|
|
|
tcpip_adapter_get_ip_info(TCPIP_ADAPTER_IF_ETH, ð_ip);
|
|
|
|
if (!(ip4_addr_isany_val(eth_ip.ip) || ip4_addr_isany_val(eth_ip.netmask) || ip4_addr_isany_val(eth_ip.gw))) {
|
|
system_event_t evt;
|
|
|
|
//notify event
|
|
evt.event_id = SYSTEM_EVENT_ETH_GOT_IP;
|
|
memcpy(&evt.event_info.got_ip.ip_info, ð_ip, sizeof(tcpip_adapter_ip_info_t));
|
|
|
|
esp_event_send(&evt);
|
|
} else {
|
|
ESP_LOGE(TAG, "invalid static ip");
|
|
}
|
|
}
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t system_event_eth_disconnected_handle_default(system_event_t *event)
|
|
{
|
|
tcpip_adapter_down(TCPIP_ADAPTER_IF_ETH);
|
|
return ESP_OK;
|
|
}
|
|
#endif
|
|
|
|
#ifdef CONFIG_WIFI_ENABLED
|
|
static esp_err_t system_event_sta_got_ip_default(system_event_t *event)
|
|
{
|
|
WIFI_API_CALL_CHECK("esp_wifi_internal_set_sta_ip", esp_wifi_internal_set_sta_ip(), ESP_OK);
|
|
|
|
ESP_LOGI(TAG, "ip: " IPSTR ", mask: " IPSTR ", gw: " IPSTR,
|
|
IP2STR(&event->event_info.got_ip.ip_info.ip),
|
|
IP2STR(&event->event_info.got_ip.ip_info.netmask),
|
|
IP2STR(&event->event_info.got_ip.ip_info.gw));
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t system_event_ap_start_handle_default(system_event_t *event)
|
|
{
|
|
tcpip_adapter_ip_info_t ap_ip;
|
|
uint8_t ap_mac[6];
|
|
|
|
WIFI_API_CALL_CHECK("esp_wifi_internal_reg_rxcb", esp_wifi_internal_reg_rxcb(ESP_IF_WIFI_AP, (wifi_rxcb_t)tcpip_adapter_ap_input), ESP_OK);
|
|
WIFI_API_CALL_CHECK("esp_wifi_mac_get", esp_wifi_get_mac(ESP_IF_WIFI_AP, ap_mac), ESP_OK);
|
|
|
|
tcpip_adapter_get_ip_info(TCPIP_ADAPTER_IF_AP, &ap_ip);
|
|
tcpip_adapter_start(TCPIP_ADAPTER_IF_AP, ap_mac, &ap_ip);
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t system_event_ap_stop_handle_default(system_event_t *event)
|
|
{
|
|
WIFI_API_CALL_CHECK("esp_wifi_internal_reg_rxcb", esp_wifi_internal_reg_rxcb(ESP_IF_WIFI_AP, NULL), ESP_OK);
|
|
|
|
tcpip_adapter_stop(TCPIP_ADAPTER_IF_AP);
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t system_event_sta_start_handle_default(system_event_t *event)
|
|
{
|
|
tcpip_adapter_ip_info_t sta_ip;
|
|
uint8_t sta_mac[6];
|
|
|
|
WIFI_API_CALL_CHECK("esp_wifi_mac_get", esp_wifi_get_mac(ESP_IF_WIFI_STA, sta_mac), ESP_OK);
|
|
tcpip_adapter_get_ip_info(TCPIP_ADAPTER_IF_STA, &sta_ip);
|
|
tcpip_adapter_start(TCPIP_ADAPTER_IF_STA, sta_mac, &sta_ip);
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t system_event_sta_stop_handle_default(system_event_t *event)
|
|
{
|
|
tcpip_adapter_stop(TCPIP_ADAPTER_IF_STA);
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t system_event_sta_connected_handle_default(system_event_t *event)
|
|
{
|
|
tcpip_adapter_dhcp_status_t status;
|
|
|
|
WIFI_API_CALL_CHECK("esp_wifi_internal_reg_rxcb", esp_wifi_internal_reg_rxcb(ESP_IF_WIFI_STA, (wifi_rxcb_t)tcpip_adapter_sta_input), ESP_OK);
|
|
|
|
tcpip_adapter_up(TCPIP_ADAPTER_IF_STA);
|
|
|
|
tcpip_adapter_dhcpc_get_status(TCPIP_ADAPTER_IF_STA, &status);
|
|
|
|
if (status == TCPIP_ADAPTER_DHCP_INIT) {
|
|
tcpip_adapter_dhcpc_start(TCPIP_ADAPTER_IF_STA);
|
|
} else if (status == TCPIP_ADAPTER_DHCP_STOPPED) {
|
|
tcpip_adapter_ip_info_t sta_ip;
|
|
|
|
tcpip_adapter_get_ip_info(TCPIP_ADAPTER_IF_STA, &sta_ip);
|
|
|
|
if (!(ip4_addr_isany_val(sta_ip.ip) || ip4_addr_isany_val(sta_ip.netmask) || ip4_addr_isany_val(sta_ip.gw))) {
|
|
system_event_t evt;
|
|
|
|
//notify event
|
|
evt.event_id = SYSTEM_EVENT_STA_GOT_IP;
|
|
memcpy(&evt.event_info.got_ip.ip_info, &sta_ip, sizeof(tcpip_adapter_ip_info_t));
|
|
|
|
esp_event_send(&evt);
|
|
} else {
|
|
ESP_LOGE(TAG, "invalid static ip");
|
|
}
|
|
}
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t system_event_sta_disconnected_handle_default(system_event_t *event)
|
|
{
|
|
tcpip_adapter_down(TCPIP_ADAPTER_IF_STA);
|
|
WIFI_API_CALL_CHECK("esp_wifi_internal_reg_rxcb", esp_wifi_internal_reg_rxcb(ESP_IF_WIFI_STA, NULL), ESP_OK);
|
|
return ESP_OK;
|
|
}
|
|
#endif
|
|
|
|
static esp_err_t esp_system_event_debug(system_event_t *event)
|
|
{
|
|
if (event == NULL) {
|
|
ESP_LOGE(TAG, "event is null!");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
switch (event->event_id) {
|
|
case SYSTEM_EVENT_WIFI_READY: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_WIFI_READY");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_SCAN_DONE: {
|
|
system_event_sta_scan_done_t *scan_done = &event->event_info.scan_done;
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_SCAN_DONE, status:%d, number:%d", scan_done->status, scan_done->number);
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_START: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_START");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_STOP: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_STOP");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_CONNECTED: {
|
|
system_event_sta_connected_t *connected = &event->event_info.connected;
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_CONNECTED, ssid:%s, ssid_len:%d, bssid:" MACSTR ", channel:%d, authmode:%d", \
|
|
connected->ssid, connected->ssid_len, MAC2STR(connected->bssid), connected->channel, connected->authmode);
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_DISCONNECTED: {
|
|
system_event_sta_disconnected_t *disconnected = &event->event_info.disconnected;
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_DISCONNECTED, ssid:%s, ssid_len:%d, bssid:" MACSTR ", reason:%d", \
|
|
disconnected->ssid, disconnected->ssid_len, MAC2STR(disconnected->bssid), disconnected->reason);
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_AUTHMODE_CHANGE: {
|
|
system_event_sta_authmode_change_t *auth_change = &event->event_info.auth_change;
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_AUTHMODE_CHNAGE, old_mode:%d, new_mode:%d", auth_change->old_mode, auth_change->new_mode);
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_GOT_IP: {
|
|
system_event_sta_got_ip_t *got_ip = &event->event_info.got_ip;
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_GOTIP, ip:" IPSTR ", mask:" IPSTR ", gw:" IPSTR,
|
|
IP2STR(&got_ip->ip_info.ip),
|
|
IP2STR(&got_ip->ip_info.netmask),
|
|
IP2STR(&got_ip->ip_info.gw));
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_WPS_ER_SUCCESS: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_WPS_ER_SUCCESS");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_WPS_ER_FAILED: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_WPS_ER_FAILED");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_WPS_ER_TIMEOUT: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_WPS_ER_TIMEOUT");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_STA_WPS_ER_PIN: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_STA_WPS_ER_PIN");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_AP_START: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_AP_START");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_AP_STOP: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_AP_STOP");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_AP_STACONNECTED: {
|
|
system_event_ap_staconnected_t *staconnected = &event->event_info.sta_connected;
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_AP_STACONNECTED, mac:" MACSTR ", aid:%d", \
|
|
MAC2STR(staconnected->mac), staconnected->aid);
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_AP_STADISCONNECTED: {
|
|
system_event_ap_stadisconnected_t *stadisconnected = &event->event_info.sta_disconnected;
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_AP_STADISCONNECTED, mac:" MACSTR ", aid:%d", \
|
|
MAC2STR(stadisconnected->mac), stadisconnected->aid);
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_AP_PROBEREQRECVED: {
|
|
system_event_ap_probe_req_rx_t *ap_probereqrecved = &event->event_info.ap_probereqrecved;
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_AP_PROBEREQRECVED, rssi:%d, mac:" MACSTR, \
|
|
ap_probereqrecved->rssi, \
|
|
MAC2STR(ap_probereqrecved->mac));
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_AP_STA_GOT_IP6: {
|
|
ip6_addr_t *addr = &event->event_info.got_ip6.ip6_info.ip;
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_AP_STA_GOT_IP6 address %04x:%04x:%04x:%04x:%04x:%04x:%04x:%04x",
|
|
IP6_ADDR_BLOCK1(addr),
|
|
IP6_ADDR_BLOCK2(addr),
|
|
IP6_ADDR_BLOCK3(addr),
|
|
IP6_ADDR_BLOCK4(addr),
|
|
IP6_ADDR_BLOCK5(addr),
|
|
IP6_ADDR_BLOCK6(addr),
|
|
IP6_ADDR_BLOCK7(addr),
|
|
IP6_ADDR_BLOCK8(addr));
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_ETH_START: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_ETH_START");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_ETH_STOP: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_ETH_STOP");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_ETH_CONNECTED: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_ETH_CONNECETED");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_ETH_DISCONNECTED: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_ETH_DISCONNECETED");
|
|
break;
|
|
}
|
|
case SYSTEM_EVENT_ETH_GOT_IP: {
|
|
ESP_LOGD(TAG, "SYSTEM_EVENT_ETH_GOT_IP");
|
|
break;
|
|
}
|
|
|
|
default: {
|
|
ESP_LOGW(TAG, "unexpected system event %d!", event->event_id);
|
|
break;
|
|
}
|
|
}
|
|
|
|
return ESP_OK;
|
|
}
|
|
|
|
esp_err_t esp_event_process_default(system_event_t *event)
|
|
{
|
|
if (event == NULL) {
|
|
ESP_LOGE(TAG, "Error: event is null!");
|
|
return ESP_FAIL;
|
|
}
|
|
|
|
esp_system_event_debug(event);
|
|
if ((event->event_id < SYSTEM_EVENT_MAX)) {
|
|
if (default_event_handlers[event->event_id] != NULL) {
|
|
ESP_LOGV(TAG, "enter default callback");
|
|
default_event_handlers[event->event_id](event);
|
|
ESP_LOGV(TAG, "exit default callback");
|
|
}
|
|
} else {
|
|
ESP_LOGE(TAG, "mismatch or invalid event, id=%d", event->event_id);
|
|
return ESP_FAIL;
|
|
}
|
|
return ESP_OK;
|
|
}
|