mirror of
https://github.com/espressif/esp-idf
synced 2025-03-10 01:29:21 -04:00
131 lines
4.6 KiB
C
131 lines
4.6 KiB
C
/*
|
|
* SPDX-FileCopyrightText: 2024 Espressif Systems (Shanghai) CO LTD
|
|
*
|
|
* SPDX-License-Identifier: Unlicense OR CC0-1.0
|
|
*/
|
|
|
|
#include "esp_err.h"
|
|
#include "esp_event.h"
|
|
#include "esp_event_base.h"
|
|
#include "esp_vfs_eventfd.h"
|
|
#include "example_common_private.h"
|
|
#include "protocol_examples_common.h"
|
|
#include "protocol_examples_thread_config.h"
|
|
#include "esp_log.h"
|
|
#include <string.h>
|
|
|
|
#include <esp_openthread_cli.h>
|
|
#include <esp_openthread_lock.h>
|
|
#include <esp_openthread_netif_glue.h>
|
|
#include <esp_openthread_types.h>
|
|
#include <esp_openthread.h>
|
|
#include <openthread/dataset.h>
|
|
#include <openthread/logging.h>
|
|
|
|
static TaskHandle_t s_ot_task_handle = NULL;
|
|
static esp_netif_t *s_openthread_netif = NULL;
|
|
static SemaphoreHandle_t s_semph_thread_attached = NULL;
|
|
static SemaphoreHandle_t s_semph_thread_set_dns_server = NULL;
|
|
static const char *TAG = "example_connect";
|
|
|
|
static void thread_event_handler(void* arg, esp_event_base_t event_base, int32_t event_id,
|
|
void* event_data)
|
|
{
|
|
if (event_base == OPENTHREAD_EVENT) {
|
|
if (event_id == OPENTHREAD_EVENT_ATTACHED) {
|
|
xSemaphoreGive(s_semph_thread_attached);
|
|
} else if (event_id == OPENTHREAD_EVENT_SET_DNS_SERVER) {
|
|
xSemaphoreGive(s_semph_thread_set_dns_server);
|
|
}
|
|
}
|
|
}
|
|
|
|
static void ot_task_worker(void *aContext)
|
|
{
|
|
esp_openthread_platform_config_t config = {
|
|
.radio_config = ESP_OPENTHREAD_DEFAULT_RADIO_CONFIG(),
|
|
.host_config = ESP_OPENTHREAD_DEFAULT_HOST_CONFIG(),
|
|
.port_config = ESP_OPENTHREAD_DEFAULT_PORT_CONFIG(),
|
|
};
|
|
|
|
esp_netif_inherent_config_t esp_netif_config = ESP_NETIF_INHERENT_DEFAULT_OPENTHREAD();
|
|
esp_netif_config.if_desc = EXAMPLE_NETIF_DESC_THREAD;
|
|
esp_netif_config_t cfg = {
|
|
.base = &esp_netif_config,
|
|
.stack = &g_esp_netif_netstack_default_openthread,
|
|
};
|
|
s_openthread_netif = esp_netif_new(&cfg);
|
|
assert(s_openthread_netif != NULL);
|
|
|
|
// Initialize the OpenThread stack
|
|
ESP_ERROR_CHECK(esp_openthread_init(&config));
|
|
ESP_ERROR_CHECK(esp_netif_attach(s_openthread_netif, esp_openthread_netif_glue_init(&config)));
|
|
esp_openthread_lock_acquire(portMAX_DELAY);
|
|
(void)otLoggingSetLevel(CONFIG_LOG_DEFAULT_LEVEL);
|
|
esp_openthread_cli_init();
|
|
esp_openthread_cli_create_task();
|
|
otOperationalDatasetTlvs dataset;
|
|
otError error = otDatasetGetActiveTlvs(esp_openthread_get_instance(), &dataset);
|
|
if (error != OT_ERROR_NONE) {
|
|
ESP_ERROR_CHECK(esp_openthread_auto_start(NULL));
|
|
} else {
|
|
ESP_ERROR_CHECK(esp_openthread_auto_start(&dataset));
|
|
}
|
|
esp_openthread_lock_release();
|
|
|
|
// Run the main loop
|
|
esp_openthread_launch_mainloop();
|
|
|
|
// Clean up
|
|
esp_openthread_netif_glue_deinit();
|
|
esp_netif_destroy(s_openthread_netif);
|
|
esp_vfs_eventfd_unregister();
|
|
vTaskDelete(NULL);
|
|
}
|
|
|
|
/* tear down connection, release resources */
|
|
void example_thread_shutdown(void)
|
|
{
|
|
vTaskDelete(s_ot_task_handle);
|
|
esp_openthread_netif_glue_deinit();
|
|
esp_netif_destroy(s_openthread_netif);
|
|
esp_vfs_eventfd_unregister();
|
|
vSemaphoreDelete(s_semph_thread_set_dns_server);
|
|
vSemaphoreDelete(s_semph_thread_attached);
|
|
}
|
|
|
|
esp_err_t example_thread_connect(void)
|
|
{
|
|
s_semph_thread_attached = xSemaphoreCreateBinary();
|
|
if (s_semph_thread_attached == NULL) {
|
|
return ESP_ERR_NO_MEM;
|
|
}
|
|
s_semph_thread_set_dns_server = xSemaphoreCreateBinary();
|
|
if (s_semph_thread_set_dns_server == NULL) {
|
|
vSemaphoreDelete(s_semph_thread_attached);
|
|
return ESP_ERR_NO_MEM;
|
|
}
|
|
// 4 eventfds might be used for Thread
|
|
// * netif
|
|
// * ot task queue
|
|
// * radio driver
|
|
// * border router
|
|
esp_vfs_eventfd_config_t eventfd_config = {
|
|
.max_fds = 4,
|
|
};
|
|
esp_vfs_eventfd_register(&eventfd_config);
|
|
ESP_ERROR_CHECK(esp_event_handler_register(OPENTHREAD_EVENT, ESP_EVENT_ANY_ID, thread_event_handler, NULL));
|
|
if (xTaskCreate(ot_task_worker, "ot_br_main", CONFIG_EXAMPLE_THREAD_TASK_STACK_SIZE, NULL, 5, &s_ot_task_handle) != pdPASS) {
|
|
vSemaphoreDelete(s_semph_thread_attached);
|
|
vSemaphoreDelete(s_semph_thread_set_dns_server);
|
|
ESP_LOGE(TAG, "Failed to create openthread task");
|
|
return ESP_FAIL;
|
|
}
|
|
xSemaphoreTake(s_semph_thread_attached, portMAX_DELAY);
|
|
// Wait 1s for the Thread device to set its DNS server with the NAT64 prefix.
|
|
if (xSemaphoreTake(s_semph_thread_set_dns_server, 1000 / portTICK_PERIOD_MS) != pdPASS) {
|
|
ESP_LOGW(TAG, "DNS server is not set for the Thread device, might be unable to access the Internet");
|
|
}
|
|
return ESP_OK;
|
|
}
|