mirror of https://github.com/ARMmbed/mbed-os.git
Implement Ethernet interface for Nanostack.
* New Phy type: NanostackEthernetPhy * New tasklet: enet_tasklet. * New Interface: NanostackEthernetInterface, inherited from MeshInterfaceNanostackpull/3267/head
parent
7732adb8a0
commit
ae885ca0e9
|
|
@ -0,0 +1,36 @@
|
|||
/*
|
||||
* Copyright (c) 2016 ARM Limited. All rights reserved.
|
||||
* SPDX-License-Identifier: Apache-2.0
|
||||
* 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.
|
||||
*/
|
||||
|
||||
#ifndef NANOSTACKETHERNETINTERFACE_H
|
||||
#define NANOSTACKETHERNETINTERFACE_H
|
||||
|
||||
#include "MeshInterfaceNanostack.h"
|
||||
#include "NanostackEthernetPhy.h"
|
||||
|
||||
class NanostackEthernetInterface : public MeshInterfaceNanostack {
|
||||
public:
|
||||
|
||||
NanostackEthernetInterface() : MeshInterfaceNanostack() { }
|
||||
NanostackEthernetInterface(NanostackEthernetPhy *phy) : MeshInterfaceNanostack(phy) { }
|
||||
|
||||
nsapi_error_t initialize(NanostackEthernetPhy *phy);
|
||||
int connect();
|
||||
int disconnect();
|
||||
bool getOwnIpAddress(char *address, int8_t len);
|
||||
bool getRouterIpAddress(char *address, int8_t len);
|
||||
};
|
||||
|
||||
#endif // NANOSTACKETHERNETINTERFACE_H
|
||||
|
|
@ -0,0 +1,84 @@
|
|||
/*
|
||||
* Copyright (c) 2016 ARM Limited. All rights reserved.
|
||||
* SPDX-License-Identifier: Apache-2.0
|
||||
* 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 "NanostackEthernetInterface.h"
|
||||
#include "mesh_system.h"
|
||||
#include "callback_handler.h"
|
||||
#include "enet_tasklet.h"
|
||||
|
||||
nsapi_error_t NanostackEthernetInterface::initialize(NanostackEthernetPhy *phy)
|
||||
{
|
||||
nsapi_error_t err = MeshInterfaceNanostack::initialize(phy);
|
||||
if (err != NSAPI_ERROR_OK)
|
||||
return err;
|
||||
|
||||
nanostack_lock();
|
||||
|
||||
if (register_phy() < 0) {
|
||||
nanostack_unlock();
|
||||
return NSAPI_ERROR_DEVICE_ERROR;
|
||||
}
|
||||
|
||||
enet_tasklet_init();
|
||||
__mesh_handler_set_callback(this);
|
||||
_network_interface_id = enet_tasklet_network_init(_device_id);
|
||||
|
||||
nanostack_unlock();
|
||||
|
||||
if (_network_interface_id < 0)
|
||||
return MESH_ERROR_UNKNOWN;
|
||||
else
|
||||
return MESH_ERROR_NONE;
|
||||
}
|
||||
|
||||
int NanostackEthernetInterface::connect()
|
||||
{
|
||||
nanostack_lock();
|
||||
int8_t status = enet_tasklet_connect(&__mesh_handler_c_callback, _network_interface_id);
|
||||
nanostack_unlock();
|
||||
|
||||
if (status == -1) {
|
||||
return MESH_ERROR_PARAM;
|
||||
} else if (status == -2) {
|
||||
return MESH_ERROR_MEMORY;
|
||||
} else if (status == -3) {
|
||||
return MESH_ERROR_STATE;
|
||||
} else if (status != 0) {
|
||||
return MESH_ERROR_UNKNOWN;
|
||||
}
|
||||
|
||||
int32_t count = connect_semaphore.wait(30000);
|
||||
|
||||
if (count <= 0) {
|
||||
return NSAPI_ERROR_DHCP_FAILURE; // sort of...
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
int NanostackEthernetInterface::disconnect()
|
||||
{
|
||||
enet_tasklet_disconnect();
|
||||
return 0;
|
||||
}
|
||||
|
||||
bool NanostackEthernetInterface::getOwnIpAddress(char *address, int8_t len)
|
||||
{
|
||||
return enet_tasklet_get_ip_address(address, len)?false:true;
|
||||
}
|
||||
|
||||
bool NanostackEthernetInterface::getRouterIpAddress(char *address, int8_t len)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
|
@ -0,0 +1,281 @@
|
|||
/*
|
||||
* Copyright (c) 2015 ARM Limited. All rights reserved.
|
||||
* SPDX-License-Identifier: Apache-2.0
|
||||
* 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 <string.h> //memset
|
||||
#include "eventOS_event_timer.h"
|
||||
#include "common_functions.h"
|
||||
#include "net_interface.h"
|
||||
#include "ip6string.h" //ip6tos
|
||||
#include "nsdynmemLIB.h"
|
||||
#include "include/static_config.h"
|
||||
#include "include/mesh_system.h"
|
||||
#include "ns_event_loop.h"
|
||||
#include "mesh_interface_types.h"
|
||||
#include "eventOS_event.h"
|
||||
|
||||
// For tracing we need to define flag, have include and define group
|
||||
#include "ns_trace.h"
|
||||
#define TRACE_GROUP "IPV6"
|
||||
|
||||
#include "ethernet_mac_api.h"
|
||||
|
||||
#define INTERFACE_NAME "eth0"
|
||||
|
||||
// Tasklet timer events
|
||||
#define TIMER_EVENT_START_BOOTSTRAP 1
|
||||
|
||||
#define INVALID_INTERFACE_ID (-1)
|
||||
|
||||
#define STR_HELPER(x) #x
|
||||
#define STR(x) STR_HELPER(x)
|
||||
|
||||
/*
|
||||
* Mesh tasklet states.
|
||||
*/
|
||||
typedef enum {
|
||||
TASKLET_STATE_CREATED = 0,
|
||||
TASKLET_STATE_INITIALIZED,
|
||||
TASKLET_STATE_BOOTSTRAP_STARTED,
|
||||
TASKLET_STATE_BOOTSTRAP_FAILED,
|
||||
TASKLET_STATE_BOOTSTRAP_READY
|
||||
} tasklet_state_t;
|
||||
|
||||
/*
|
||||
* Mesh tasklet data structure.
|
||||
*/
|
||||
typedef struct {
|
||||
void (*mesh_api_cb)(mesh_connection_status_t nwk_status);
|
||||
tasklet_state_t tasklet_state;
|
||||
int8_t node_main_tasklet_id;
|
||||
int8_t network_interface_id;
|
||||
int8_t tasklet;
|
||||
} tasklet_data_str_t;
|
||||
|
||||
/* Tasklet data */
|
||||
static tasklet_data_str_t *tasklet_data_ptr = NULL;
|
||||
static eth_mac_api_t *eth_mac_api = NULL;
|
||||
typedef void (*mesh_interface_cb)(mesh_connection_status_t mesh_status);
|
||||
|
||||
|
||||
/* private function prototypes */
|
||||
static void enet_tasklet_main(arm_event_s *event);
|
||||
static void enet_tasklet_network_state_changed(mesh_connection_status_t status);
|
||||
static void enet_tasklet_parse_network_event(arm_event_s *event);
|
||||
static void enet_tasklet_configure_and_connect_to_network(void);
|
||||
|
||||
/*
|
||||
* \brief A function which will be eventually called by NanoStack OS when ever the OS has an event to deliver.
|
||||
* @param event, describes the sender, receiver and event type.
|
||||
*
|
||||
* NOTE: Interrupts requested by HW are possible during this function!
|
||||
*/
|
||||
void enet_tasklet_main(arm_event_s *event)
|
||||
{
|
||||
arm_library_event_type_e event_type;
|
||||
event_type = (arm_library_event_type_e) event->event_type;
|
||||
|
||||
switch (event_type) {
|
||||
case ARM_LIB_NWK_INTERFACE_EVENT:
|
||||
/* This event is delivered every and each time when there is new
|
||||
* information of network connectivity.
|
||||
*/
|
||||
enet_tasklet_parse_network_event(event);
|
||||
break;
|
||||
|
||||
case ARM_LIB_TASKLET_INIT_EVENT:
|
||||
/* Event with type EV_INIT is an initializer event of NanoStack OS.
|
||||
* The event is delivered when the NanoStack OS is running fine.
|
||||
* This event should be delivered ONLY ONCE.
|
||||
*/
|
||||
tasklet_data_ptr->node_main_tasklet_id = event->receiver;
|
||||
mesh_system_send_connect_event(tasklet_data_ptr->tasklet);
|
||||
break;
|
||||
|
||||
case ARM_LIB_SYSTEM_TIMER_EVENT:
|
||||
eventOS_event_timer_cancel(event->event_id,
|
||||
tasklet_data_ptr->node_main_tasklet_id);
|
||||
|
||||
if (event->event_id == TIMER_EVENT_START_BOOTSTRAP) {
|
||||
tr_debug("Restart bootstrap");
|
||||
enet_tasklet_configure_and_connect_to_network();
|
||||
}
|
||||
break;
|
||||
|
||||
case APPLICATION_EVENT:
|
||||
if (event->event_id == APPL_EVENT_CONNECT) {
|
||||
enet_tasklet_configure_and_connect_to_network();
|
||||
}
|
||||
break;
|
||||
|
||||
default:
|
||||
break;
|
||||
} // switch(event_type)
|
||||
}
|
||||
|
||||
/**
|
||||
* \brief Network state event handler.
|
||||
* \param event show network start response or current network state.
|
||||
*
|
||||
* - ARM_NWK_BOOTSTRAP_READY: Save NVK persistent data to NVM and Net role
|
||||
* - ARM_NWK_NWK_SCAN_FAIL: Link Layer Active Scan Fail, Stack is Already at Idle state
|
||||
* - ARM_NWK_IP_ADDRESS_ALLOCATION_FAIL: No ND Router at current Channel Stack is Already at Idle state
|
||||
* - ARM_NWK_NWK_CONNECTION_DOWN: Connection to Access point is lost wait for Scan Result
|
||||
* - ARM_NWK_NWK_PARENT_POLL_FAIL: Host should run net start without any PAN-id filter and all channels
|
||||
* - ARM_NWK_AUHTENTICATION_FAIL: Pana Authentication fail, Stack is Already at Idle state
|
||||
*/
|
||||
void enet_tasklet_parse_network_event(arm_event_s *event)
|
||||
{
|
||||
arm_nwk_interface_status_type_e status = (arm_nwk_interface_status_type_e) event->event_data;
|
||||
tr_debug("app_parse_network_event() %d", status);
|
||||
switch (status) {
|
||||
case ARM_NWK_BOOTSTRAP_READY:
|
||||
/* Network is ready and node is connected to Access Point */
|
||||
if (tasklet_data_ptr->tasklet_state != TASKLET_STATE_BOOTSTRAP_READY) {
|
||||
tr_info("IPv6 bootstrap ready");
|
||||
tasklet_data_ptr->tasklet_state = TASKLET_STATE_BOOTSTRAP_READY;
|
||||
enet_tasklet_network_state_changed(MESH_CONNECTED);
|
||||
}
|
||||
break;
|
||||
case ARM_NWK_IP_ADDRESS_ALLOCATION_FAIL:
|
||||
/* No ND Router at current Channel Stack is Already at Idle state */
|
||||
tr_info("Bootstrap fail");
|
||||
tasklet_data_ptr->tasklet_state = TASKLET_STATE_BOOTSTRAP_FAILED;
|
||||
break;
|
||||
case ARM_NWK_NWK_CONNECTION_DOWN:
|
||||
/* Connection to Access point is lost wait for Scan Result */
|
||||
tr_info("Connection lost");
|
||||
tasklet_data_ptr->tasklet_state = TASKLET_STATE_BOOTSTRAP_FAILED;
|
||||
break;
|
||||
default:
|
||||
tr_warn("Unknown event %d", status);
|
||||
break;
|
||||
}
|
||||
|
||||
if (tasklet_data_ptr->tasklet_state != TASKLET_STATE_BOOTSTRAP_READY) {
|
||||
// Set 5s timer for new network scan
|
||||
eventOS_event_timer_request(TIMER_EVENT_START_BOOTSTRAP,
|
||||
ARM_LIB_SYSTEM_TIMER_EVENT,
|
||||
tasklet_data_ptr->node_main_tasklet_id,
|
||||
5000);
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
* \brief Configure and establish network connection
|
||||
*
|
||||
*/
|
||||
void enet_tasklet_configure_and_connect_to_network(void)
|
||||
{
|
||||
arm_nwk_interface_up(tasklet_data_ptr->network_interface_id);
|
||||
}
|
||||
|
||||
/*
|
||||
* Inform application about network state change
|
||||
*/
|
||||
void enet_tasklet_network_state_changed(mesh_connection_status_t status)
|
||||
{
|
||||
if (tasklet_data_ptr->mesh_api_cb) {
|
||||
(tasklet_data_ptr->mesh_api_cb)(status);
|
||||
}
|
||||
}
|
||||
|
||||
/* Public functions */
|
||||
int8_t enet_tasklet_get_ip_address(char *address, int8_t len)
|
||||
{
|
||||
uint8_t binary_ipv6[16];
|
||||
|
||||
if ((len >= 40) && (0 == arm_net_address_get(
|
||||
tasklet_data_ptr->network_interface_id, ADDR_IPV6_GP, binary_ipv6))) {
|
||||
ip6tos(binary_ipv6, address);
|
||||
//tr_debug("IP address: %s", address);
|
||||
return 0;
|
||||
} else {
|
||||
return -1;
|
||||
}
|
||||
}
|
||||
|
||||
int8_t enet_tasklet_connect(mesh_interface_cb callback, int8_t nwk_interface_id)
|
||||
{
|
||||
int8_t re_connecting = true;
|
||||
int8_t tasklet_id = tasklet_data_ptr->tasklet;
|
||||
|
||||
if (tasklet_data_ptr->tasklet_state == TASKLET_STATE_CREATED) {
|
||||
re_connecting = false;
|
||||
}
|
||||
|
||||
memset(tasklet_data_ptr, 0, sizeof(tasklet_data_str_t));
|
||||
tasklet_data_ptr->mesh_api_cb = callback;
|
||||
tasklet_data_ptr->network_interface_id = nwk_interface_id;
|
||||
tasklet_data_ptr->tasklet_state = TASKLET_STATE_INITIALIZED;
|
||||
|
||||
if (re_connecting == false) {
|
||||
tasklet_data_ptr->tasklet = eventOS_event_handler_create(&enet_tasklet_main,
|
||||
ARM_LIB_TASKLET_INIT_EVENT);
|
||||
if (tasklet_data_ptr->tasklet < 0) {
|
||||
// -1 handler already used by other tasklet
|
||||
// -2 memory allocation failure
|
||||
return tasklet_data_ptr->tasklet;
|
||||
}
|
||||
} else {
|
||||
tasklet_data_ptr->tasklet = tasklet_id;
|
||||
mesh_system_send_connect_event(tasklet_data_ptr->tasklet);
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
int8_t enet_tasklet_disconnect(bool send_cb)
|
||||
{
|
||||
int8_t status = -1;
|
||||
if (tasklet_data_ptr != NULL) {
|
||||
if (tasklet_data_ptr->network_interface_id != INVALID_INTERFACE_ID) {
|
||||
status = arm_nwk_interface_down(tasklet_data_ptr->network_interface_id);
|
||||
tasklet_data_ptr->network_interface_id = INVALID_INTERFACE_ID;
|
||||
if (send_cb == true) {
|
||||
enet_tasklet_network_state_changed(MESH_DISCONNECTED);
|
||||
}
|
||||
}
|
||||
tasklet_data_ptr->mesh_api_cb = NULL;
|
||||
}
|
||||
return status;
|
||||
}
|
||||
|
||||
void enet_tasklet_init(void)
|
||||
{
|
||||
if (tasklet_data_ptr == NULL) {
|
||||
tasklet_data_ptr = ns_dyn_mem_alloc(sizeof(tasklet_data_str_t));
|
||||
tasklet_data_ptr->tasklet_state = TASKLET_STATE_CREATED;
|
||||
tasklet_data_ptr->network_interface_id = INVALID_INTERFACE_ID;
|
||||
}
|
||||
}
|
||||
|
||||
int8_t enet_tasklet_network_init(int8_t device_id)
|
||||
{
|
||||
if (tasklet_data_ptr->network_interface_id != -1) {
|
||||
tr_debug("Interface already at active state\n");
|
||||
return tasklet_data_ptr->network_interface_id;
|
||||
}
|
||||
if (!eth_mac_api) {
|
||||
eth_mac_api = ethernet_mac_create(device_id);
|
||||
}
|
||||
|
||||
tasklet_data_ptr->network_interface_id = arm_nwk_interface_ethernet_init(eth_mac_api, "eth0");
|
||||
|
||||
tr_debug("interface ID: %d", tasklet_data_ptr->network_interface_id);
|
||||
arm_nwk_interface_configure_ipv6_bootstrap_set(
|
||||
tasklet_data_ptr->network_interface_id, NET_IPV6_BOOTSTRAP_AUTONOMOUS, NULL);
|
||||
return tasklet_data_ptr->network_interface_id;
|
||||
}
|
||||
|
|
@ -0,0 +1,35 @@
|
|||
/*
|
||||
* Copyright (c) 2016 ARM Limited. All rights reserved.
|
||||
* SPDX-License-Identifier: Apache-2.0
|
||||
* 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.
|
||||
*/
|
||||
|
||||
#ifndef ENET_TASKLET_H
|
||||
#define ENET_TASKLET_H
|
||||
|
||||
|
||||
#ifdef __cplusplus
|
||||
extern "C" {
|
||||
#endif
|
||||
|
||||
void enet_tasklet_init(void);
|
||||
uint8_t enet_tasklet_network_init(int8_t);
|
||||
int8_t enet_tasklet_connect(void (*)(mesh_connection_status_t mesh_status), int8_t nwk_interface_id);
|
||||
void enet_tasklet_disconnect();
|
||||
int8_t enet_tasklet_get_ip_address(char *address, int8_t len);
|
||||
|
||||
#ifdef __cplusplus
|
||||
}
|
||||
#endif
|
||||
|
||||
#endif // ENET_TASKLET_H
|
||||
|
|
@ -0,0 +1,13 @@
|
|||
/*
|
||||
* Copyright (c) 2016 ARM Limited. All rights reserved.
|
||||
*/
|
||||
|
||||
#ifndef NANOSTACK_ETHERNET_PHY_H_
|
||||
#define NANOSTACK_ETHERNET_PHY_H_
|
||||
|
||||
#include "NanostackPhy.h"
|
||||
|
||||
class NanostackEthernetPhy : public NanostackPhy {
|
||||
};
|
||||
|
||||
#endif /* NANOSTACK_INTERFACE_H_ */
|
||||
|
|
@ -23,6 +23,7 @@
|
|||
// Include here for backward compatibility
|
||||
#include "LoWPANNDInterface.h"
|
||||
#include "ThreadInterface.h"
|
||||
#include "NanostackEthernetInterface.h"
|
||||
#include "MeshInterfaceNanostack.h"
|
||||
|
||||
class NanostackInterface : public NetworkStack {
|
||||
|
|
|
|||
Loading…
Reference in New Issue