summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorsakumisu <[email protected]>2023-11-17 23:37:15 +0800
committersakumisu <[email protected]>2023-11-17 23:37:15 +0800
commit07fa211f40bcf77e28bf34af1c09391ada5a7d37 (patch)
tree69294193cd01c5cf558ea7fe9fb26289fe5fbb40
parent73eb69bfa26819b9a175669b2aba8d46c07eb0e1 (diff)
remove rndis code in third party because it is implemented internally
-rw-r--r--SConscript3
-rw-r--r--third_party/FreeRTOS-10.4/rndis_host/rndis_host.c286
-rw-r--r--third_party/rt-thread-4.1.1/rndis_host/rndis_host.c618
-rw-r--r--third_party/rt-thread-4.1.1/rndis_host/rndis_host_lwip2.1.2.c653
4 files changed, 2 insertions, 1558 deletions
diff --git a/SConscript b/SConscript
index fe7ac025..b96c8c94 100644
--- a/SConscript
+++ b/SConscript
@@ -107,7 +107,8 @@ if GetDepend(['PKG_CHERRYUSB_HOST']):
src += Glob('class/msc/usbh_msc.c')
if GetDepend(['PKG_CHERRYUSB_HOST_RNDIS']):
src += Glob('class/wireless/usbh_rndis.c')
- src += Glob('third_party/rt-thread-4.1.1/rndis_host/rndis_host.c')
+ if GetDepend(['PKG_CHERRYUSB_HOST_CDC_ECM']):
+ src += Glob('class/cdc/usbh_cdc_ecm.c')
if GetDepend(['PKG_CHERRYUSB_HOST_DWC2']):
src += Glob('port/dwc2/usb_hc_dwc2.c')
diff --git a/third_party/FreeRTOS-10.4/rndis_host/rndis_host.c b/third_party/FreeRTOS-10.4/rndis_host/rndis_host.c
deleted file mode 100644
index a006d144..00000000
--- a/third_party/FreeRTOS-10.4/rndis_host/rndis_host.c
+++ /dev/null
@@ -1,286 +0,0 @@
-/* FreeRTOS kernel includes. */
-#include "FreeRTOS.h"
-#include "task.h"
-#include "semphr.h"
-#include "timers.h"
-
-#include <stdio.h>
-#include "board.h"
-#include "netif/etharp.h"
-#include "lwip/init.h"
-#include "lwip/tcp.h"
-#include "lwip/tcpip.h"
-#include "lwip/netif.h"
-#include "lwip/pbuf.h"
-#include "lwip/icmp.h"
-#include "lwip/udp.h"
-#include "lwip/opt.h"
-#include "lwip/arch.h"
-#include "lwip/api.h"
-#include "lwip/inet.h"
-#include "lwip/dhcp.h"
-#include "lwip/prot/dhcp.h"
-#include <lwip/ip.h>
-#include <lwip/netdb.h>
-#include <lwip/sockets.h>
-#include "usbh_core.h"
-#include "usbh_rndis.h"
-#include "rndis_protocol.h"
-
-/* Macro Definition */
-/*--------------- Tasks Priority -------------*/
-#define RNDIS_RECV_DATA_TASK_PRIO (tskIDLE_PRIORITY + 6)
-
-#define RNDIS_ETH_BUFFER_LEN (sizeof(rndis_data_packet_t) + 1514 + 42)
-#define RNDIS_RXETH_BUFFER_LEN (RNDIS_ETH_BUFFER_LEN * 3)
-
-/* Static Variable Definition*/
-static struct usbh_rndis *s_rndis_class_ptr;
-static struct netif netif_data;
-static ip4_addr_t ipaddr;
-static ip4_addr_t netmask;
-static ip4_addr_t gateway;
-USB_NOCACHE_RAM_SECTION uint8_t tx_buffer[RNDIS_ETH_BUFFER_LEN];
-USB_NOCACHE_RAM_SECTION uint8_t rx_buffer[RNDIS_RXETH_BUFFER_LEN];
-static uint8_t *rx_buf_ptr;
-SemaphoreHandle_t mutex_sem_handle;
-SemaphoreHandle_t sig_sem_handle;
-TimerHandle_t timer_handle;
-TaskHandle_t data_recv_task_handle;
-
-/* Static Function Declaration */
-static void rndis_dev_keepalive_timeout(void *pdata);
-static err_t netif_init_cb(struct netif *netif);
-static err_t linkoutput_fn(struct netif *netif, struct pbuf *p);
-static int usbh_rndis_eth_tx(struct pbuf *p);
-static int rndis_msg_data_send(struct usbh_rndis *rndis_class, uint8_t *buffer, int nbytes);
-static void lwip_rx_handle(void *pdata);
-
-extern int usbh_rndis_query_msg_transfer(struct usbh_rndis *rndis_class,
- uint32_t oid, uint32_t query_len,
- uint8_t *info, uint32_t *info_len);
-
-void usbh_rndis_run(struct usbh_rndis *rndis_class)
-{
- struct netif *netif = &netif_data;
-
- s_rndis_class_ptr = rndis_class;
- rx_buf_ptr = rx_buffer;
-
- /* Create tcp_ip stack thread */
- tcpip_init(NULL, NULL);
-
- netif->hwaddr_len = 6;
- memcpy(netif->hwaddr, rndis_class->mac, 6);
-
- IP4_ADDR(&ipaddr, 0, 0, 0, 0);
- IP4_ADDR(&netmask, 0, 0, 0, 0);
- IP4_ADDR(&gateway, 0, 0, 0, 0);
-
- netif = netif_add(netif, &ipaddr, &netmask, &gateway, NULL, netif_init_cb, tcpip_input);
- netif_set_default(netif);
- netif_set_up(netif);
-
- mutex_sem_handle = xSemaphoreCreateMutex();
- if (NULL == mutex_sem_handle) {
- printf("mutex semaphore creat faile!\r\n");
- for (;;) {
- ;
- }
- }
-
- sig_sem_handle = xSemaphoreCreateCounting(1, 0);
- if (NULL == sig_sem_handle) {
- printf("Rndis sig semaphore creat faile!\r\n");
- for (;;) {
- ;
- }
- }
-
- timer_handle =
- xTimerCreate((const char *)NULL, (TickType_t)5000, (UBaseType_t)pdTRUE, (void *const)1, (TimerCallbackFunction_t)rndis_dev_keepalive_timeout);
- if (NULL != timer_handle) {
- xTimerStart(timer_handle, 0);
- } else {
- printf("timer creation failed!.\n");
- for (;;) {
- ;
- }
- }
-
- if (xTaskCreate(lwip_rx_handle, "rndis_lwip_rx", configMINIMAL_STACK_SIZE + 2048U, rndis_class, RNDIS_RECV_DATA_TASK_PRIO, &data_recv_task_handle) !=
- pdPASS) {
- printf("rndis_lwip_rx Task creation failed!.\n");
- for (;;) {
- ;
- }
- }
-}
-
-void usbh_rndis_stop(struct usbh_rndis *rndis_class)
-{
- vTaskDelete(data_recv_task_handle);
-
- xTimerStop(timer_handle, 0);
- xTimerDelete(timer_handle, 0);
-
- vSemaphoreDelete(mutex_sem_handle);
- vSemaphoreDelete(sig_sem_handle);
-
- netif_remove(&netif_data);
-
- printf("rndis dev stop!\n");
-}
-
-static void rndis_dev_keepalive_timeout(void *pdata)
-{
- int ret;
-
- xSemaphoreTake(mutex_sem_handle, portMAX_DELAY);
- ret = usbh_rndis_keepalive(s_rndis_class_ptr);
- xSemaphoreGive(mutex_sem_handle);
- if (ret < 0) {
- printf("rndis dev keepalive timeout!\n");
- }
-}
-
-static void lwip_rx_handle(void *pdata)
-{
- err_t err;
- int ret = 0;
- struct pbuf *p;
- rndis_data_packet_t *pmsg;
- int pmg_offset;
- int payload_offset;
-
- struct usbh_rndis *rndis_class = (struct usbh_rndis *)pdata;
- rx_buf_ptr = rx_buffer;
-
- while (1) {
- pmg_offset = 0;
- payload_offset = 0;
- ret = usbh_rndis_bulk_in_transfer(rndis_class, rx_buf_ptr, RNDIS_RXETH_BUFFER_LEN, USB_OSAL_WAITING_FOREVER);
- if (ret <= 0) {
- vTaskDelay(1);
- continue;
- }
- while (ret > 0) {
- pmsg = (rndis_data_packet_t *)(rx_buf_ptr + pmg_offset);
- if (pmsg->MessageType == REMOTE_NDIS_PACKET_MSG) {
- /* allocate buffer */
- p = pbuf_alloc(PBUF_RAW, pmsg->DataLength, PBUF_POOL);
- if (p != NULL) {
- struct pbuf *q;
- for (q = p; q != NULL; q = q->next) {
- /* Copy the received frame into buffer from memory pointed by the current ETHERNET DMA Rx descriptor */
- memcpy(q->payload, ((uint8_t *)(&pmsg->DataOffset) + pmsg->DataOffset + payload_offset), q->len);
- payload_offset += q->len;
- }
- /* entry point to the LwIP stack */
- err = netif_data.input(p, &netif_data);
- if (err != ERR_OK) {
- LWIP_DEBUGF(NETIF_DEBUG, ("ethernetif_input: IP input error\n"));
- pbuf_free(p);
- }
- pmg_offset += pmsg->MessageLength;
- ret -= pmsg->MessageLength;
- }
- }
- }
- }
-}
-
-static err_t netif_init_cb(struct netif *netif)
-{
- LWIP_ASSERT("netif != NULL", (netif != NULL));
- netif->mtu = 1500;
- netif->flags = NETIF_FLAG_BROADCAST | NETIF_FLAG_ETHARP | NETIF_FLAG_LINK_UP;
- netif->state = NULL;
- netif->name[0] = 'E';
- netif->name[1] = 'X';
- netif->linkoutput = linkoutput_fn;
- netif->output = etharp_output;
- return ERR_OK;
-}
-
-static err_t linkoutput_fn(struct netif *netif, struct pbuf *p)
-{
- int ret;
-
- ret = usbh_rndis_eth_tx(p);
-
- if (-EBUSY == ret) {
- ret = ERR_BUF;
- }
-
- return ret;
-}
-
-static int usbh_rndis_eth_tx(struct pbuf *p)
-{
- struct pbuf *q;
- uint8_t *buffer;
- rndis_data_packet_t *hdr;
- int ret;
- int recount = 5;
- uint8_t data[4];
- uint32_t info_len = 0;
-
- if (!s_rndis_class_ptr->link_status) {
- printf("linkdown, drop pkg\r\n");
- while (recount--) {
- ret = usbh_rndis_query_msg_transfer(s_rndis_class_ptr, OID_GEN_MEDIA_CONNECT_STATUS, sizeof(data), data, &info_len);
- if (ret < 0) {
- return -EBUSY;
- }
- if (NDIS_MEDIA_STATE_CONNECTED == data[0]) {
- s_rndis_class_ptr->link_status = true;
- break;
- } else {
- s_rndis_class_ptr->link_status = false;
- }
- vTaskDelay(1000);
- }
- return 0;
- }
-
- assert((p->tot_len + sizeof(rndis_data_packet_t)) < sizeof(tx_buffer));
- if (p->tot_len > sizeof(tx_buffer)) {
- printf("RNDIS MTU is:%d, but the send packet size is %d\r\n", sizeof(tx_buffer), p->tot_len);
- p->tot_len = sizeof(tx_buffer);
- }
-
- hdr = (rndis_data_packet_t *)tx_buffer;
- memset(hdr, 0, sizeof(rndis_data_packet_t));
- hdr->MessageType = REMOTE_NDIS_PACKET_MSG;
- hdr->MessageLength = sizeof(rndis_data_packet_t) + p->tot_len;
- hdr->DataOffset = sizeof(rndis_data_packet_t) - sizeof(rndis_generic_msg_t);
- hdr->DataLength = p->tot_len;
-
- buffer = (uint8_t *)(tx_buffer + sizeof(rndis_data_packet_t));
- for (q = p; q != NULL; q = q->next) {
- memcpy(buffer, q->payload, q->len);
- buffer += q->len;
- }
- /* send */
- if ((hdr->MessageLength & 0x1FF) == 0) {
- /* pad a dummy. */
- hdr->MessageLength += 1;
- }
- return rndis_msg_data_send(s_rndis_class_ptr, (uint8_t *)tx_buffer, hdr->MessageLength);
-}
-
-static int rndis_msg_data_send(struct usbh_rndis *rndis_class, uint8_t *buffer,
- int nbytes)
-{
- int ret = ERR_OK;
- int len = 0;
- xSemaphoreTake(mutex_sem_handle, portMAX_DELAY);
- len = usbh_rndis_bulk_out_transfer(rndis_class, buffer, nbytes, 5000);
- xSemaphoreGive(mutex_sem_handle);
- if (len != nbytes) {
- printf("rndis msg send fail\r\n");
- ret = -EBUSY;
- }
- return ret;
-}
diff --git a/third_party/rt-thread-4.1.1/rndis_host/rndis_host.c b/third_party/rt-thread-4.1.1/rndis_host/rndis_host.c
deleted file mode 100644
index b6d2ad98..00000000
--- a/third_party/rt-thread-4.1.1/rndis_host/rndis_host.c
+++ /dev/null
@@ -1,618 +0,0 @@
-#include <rtthread.h>
-#include "usbh_core.h"
-#include "usbh_rndis.h"
-#include "rndis_protocol.h"
-
-/* RT-Thread LWIP ethernet interface */
-#include <netif/ethernetif.h>
-#include <netdev.h>
-
-/* define the rdnis device state*/
-#define RNDIS_BUS_UNINITIALIZED 0
-#define RNDIS_BUS_INITIALIZED 1
-#define RNDIS_INITIALIZED 2
-#define RNDIS_DATA_INITIALIZED 3
-
-#define USB_ETH_MTU (1500 + 14)
-#define RNDIS_THREAD_STACK_SIZE (4096)
-
-#define RNDIS_NET_DEV_NAME "u0"
-#define MAX_ADDR_LEN 6
-/* rndis device keepalive time 5000ms*/
-#define RNDIS_DEV_KEEPALIVE_TIMEOUT 5000
-/*should be the usb Integer multiple of maximum packet length N*64*/
-#define RNDIS_ETH_BUFFER_LEN ((sizeof(struct rndis_packet_msg) + USB_ETH_MTU + 42) * 5)
-
-struct usbh_user_rndis {
- struct usbh_rndis *rndis_class;
- void *user_data;
-};
-
-struct rndis_packet_msg {
- rt_uint32_t MessageType;
- rt_uint32_t MessageLength;
- rt_uint32_t DataOffset;
- rt_uint32_t DataLength;
- rt_uint32_t OOBDataOffset;
- rt_uint32_t OOBDataLength;
- rt_uint32_t NumOOBDataElements;
- rt_uint32_t PerPacketInfoOffset;
- rt_uint32_t PerPacketInfoLength;
- rt_uint32_t VcHandle;
- rt_uint32_t Reserved;
- rt_uint8_t data[0];
-};
-typedef struct rndis_packet_msg* rndis_packet_msg_t;
-
-struct rt_rndis_eth {
- /* inherit from ethernet device */
- struct eth_device parent;
-
- struct usbh_user_rndis *rndis_class;
- rt_mutex_t rndis_mutex;
- /* interface address info */
- rt_uint8_t dev_addr[MAX_ADDR_LEN];
- rt_uint16_t res;
- rt_uint32_t rndis_speed;
- rt_uint32_t res32;
-
- rt_uint8_t tx_buffer[RNDIS_ETH_BUFFER_LEN];
- rt_uint8_t rx_buffer[RNDIS_ETH_BUFFER_LEN];
- rt_uint8_t *rx_buf_ptr;
- rt_uint32_t frame_debug;
- rt_uint32_t send_packet_counter;
- rt_uint32_t recv_packet_counter;
-
- rt_uint32_t rndis_state;
- rt_thread_t rndis_recv;
- rt_thread_t keepalive_timer;
-};
-typedef struct rt_rndis_eth *rt_rndis_eth_t;
-
-struct usbh_user_rndis *g_user_rndis = RT_NULL;
-USB_NOCACHE_RAM_SECTION struct rt_rndis_eth usbh_rndis_eth_device = { 0 };
-
-void hex_data_print(const char *name, const rt_uint8_t *buf, rt_size_t size)
-{
-#define __is_print(ch) ((unsigned int)((ch) - ' ') < 127u - ' ')
-#define WIDTH_SIZE 32
-
- rt_size_t i, j;
- rt_tick_t tick = 0;
- rt_uint32_t time = 0;
-
- tick = rt_tick_get();
- time = (tick * 1000) / RT_TICK_PER_SECOND;
-
- rt_kprintf("%s time=%d.%ds,len = %d\n", name, time / 1000, time % 1000, size);
-
- for (i = 0; i < size; i += WIDTH_SIZE) {
- rt_kprintf("[HEX] %s: %04X-%04X: ", name, i, i + WIDTH_SIZE);
- for (j = 0; j < WIDTH_SIZE; j++) {
- if (i + j < size) {
- rt_kprintf("%02X ", buf[i + j]);
- } else {
- rt_kprintf(" ");
- }
- if ((j + 1) % 8 == 0) {
- rt_kprintf(" ");
- }
- }
- rt_kprintf(" ");
- for (j = 0; j < WIDTH_SIZE; j++) {
- if (i + j < size) {
- rt_kprintf("%c", __is_print(buf[i + j]) ? buf[i + j] : '.');
- }
- }
- rt_kprintf("\n");
- }
-}
-
-#define RNDIS_DEV_DEBUG
-#ifdef RNDIS_DEV_DEBUG
-#define RNDIS_DEV_PRINTF \
- rt_kprintf("[RNDIS_DEV] "); \
- rt_kprintf
-#else
-#define RNDIS_DEV_PRINTF(...)
-#endif /* RNDIS_DEBUG */
-
-/**
- * This function send the rndis data.
- *
- * @param rndis_class the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-static rt_err_t rt_rndis_msg_data_send(struct usbh_user_rndis *rndis_class, rt_uint8_t *buffer, int nbytes)
-{
- int ret = 0;
-
- if (rndis_class == RT_NULL) {
- return -RT_ERROR;
- }
-
- rt_rndis_eth_t info = RT_NULL;
-
- info = (rt_rndis_eth_t)rndis_class->user_data;
- rt_mutex_take(usbh_rndis_eth_device.rndis_mutex, RT_WAITING_FOREVER);
- ret = usbh_rndis_bulk_out_transfer(rndis_class->rndis_class, buffer, nbytes, 5000);
- rt_mutex_release(usbh_rndis_eth_device.rndis_mutex);
- if (ret != nbytes) {
- rt_kprintf("rndis msg send fail(%d %d)\r\n", ret, nbytes);
- }
- return ret;
-}
-
-/**
- * This function recv the rndis data.
- *
- * @param rndis_class the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-static rt_err_t rndis_msg_data_recv(struct usbh_user_rndis *rndis_class, rt_uint8_t *buffer, int nbytes)
-{
- int ret = 0;
-
- if (rndis_class == RT_NULL) {
- return -RT_ERROR;
- }
- ret = usbh_rndis_bulk_in_transfer(rndis_class->rndis_class, buffer, nbytes, USB_OSAL_WAITING_FOREVER);
-
- return ret;
-}
-
-/**
- * This function send the rndis set msg.
- *
- * @param rndis_class the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-static rt_err_t rt_rndis_keepalive_msg(struct usbh_user_rndis *rndis_class)
-{
- return usbh_rndis_keepalive(rndis_class->rndis_class);
-}
-
-/**
- * This function will send the bulk data to the usb device instance,
- *
- * @param device the usb device instance.
- * @param type the type of descriptor bRequest.
- * @param buffer the data buffer to save requested data
- * @param nbytes the size of buffer
- *
- * @return the error code, RT_EOK on successfully.
- */
-void rt_usbh_rndis_data_recv_entry(void *pdata)
-{
- struct usbh_user_rndis *rndis_class = (struct usbh_user_rndis *)pdata;
- rt_rndis_eth_t device = (rt_rndis_eth_t)rndis_class->user_data;
- rndis_data_packet_t sRndisDataPkt;
-
- //device->rx_buf_ptr = device->rx_buffer;
-
- while (1) {
- int ret = 0;
- int pmg_offset = 0;
- int payload_offset = 0;
- ret = usbh_rndis_bulk_in_transfer(rndis_class->rndis_class, device->rx_buf_ptr, RNDIS_ETH_BUFFER_LEN, USB_OSAL_WAITING_FOREVER);
- if (ret <= 0) {
- rt_thread_mdelay(1);
- continue;
- }
-
- while (ret > 0) {
- rndis_data_packet_t *pmsg = (rndis_data_packet_t *)(device->rx_buf_ptr + pmg_offset);
- if (pmg_offset & 0x3) {
- /* Not word-aligned case */
- //rt_kprintf("pmsg@%08x Not word-aligned case\n", pmsg);
-
- rt_memcpy(&sRndisDataPkt, pmsg, sizeof(rndis_data_packet_t));
- pmsg = &sRndisDataPkt;
- }
-
- if (pmsg->MessageType == REMOTE_NDIS_PACKET_MSG) {
- /* allocate buffer */
- struct pbuf *p = pbuf_alloc(PBUF_RAW, pmsg->DataLength, PBUF_POOL);
- if (p != NULL) {
- struct pbuf *q;
- for (q = p; q != NULL; q = q->next) {
- void *src = (void *)(device->rx_buf_ptr + pmg_offset + (2 * sizeof(uint32_t)) + pmsg->DataOffset + payload_offset);
-
- rt_memcpy(q->payload,
- src,
- q->len);
-
- payload_offset += q->len;
- }
- /* entry point to the LwIP stack */
- /* notify to upper layer */
-
- if (device->parent.netif->input(p, device->parent.netif) != ERR_OK) {
- LWIP_DEBUGF(NETIF_DEBUG, ("ethernetif_input: Input error\n"));
- pbuf_free(p);
- p = NULL;
- }
- }
- } else {
- rt_kprintf("pmsg->MessageType=%d\n", pmsg->MessageType);
- break;
- }
-
- pmg_offset += pmsg->MessageLength;
- ret -= pmsg->MessageLength;
- }
- }
-}
-
-void rt_rndis_dev_keepalive_timeout(void *pdata)
-{
- struct usbh_user_rndis *rndis_class = (struct usbh_user_rndis *)pdata;
-
- while (1) {
- rt_thread_mdelay(RT_TICK_PER_SECOND * RNDIS_DEV_KEEPALIVE_TIMEOUT / 1000);
-
- rt_mutex_take(usbh_rndis_eth_device.rndis_mutex, RT_WAITING_FOREVER);
- rt_rndis_keepalive_msg(rndis_class);
- rt_mutex_release(usbh_rndis_eth_device.rndis_mutex);
- }
-}
-
-/**
- * This function will run rndis driver when usb disk is detected.
- *
- * @param rndis_class the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-rt_err_t rt_rndis_run(struct usbh_user_rndis *rndis_class)
-{
- rt_err_t ret = 0;
- rt_uint32_t i = 0, j = 0;
-
- /* check parameter */
- RT_ASSERT(rndis_class != RT_NULL);
-
- /*The host is configured to send and receive any of the RNDIS control messages for suitably
- configuring or querying the device, to receive status indications from the device,
- to reset the device, or to tear down the data and control channels*/
- usbh_rndis_eth_device.rndis_state = RNDIS_INITIALIZED;
-
- usbh_rndis_eth_device.keepalive_timer = rt_thread_create("keeplive",
- (void (*)(void *parameter))rt_rndis_dev_keepalive_timeout,
- rndis_class,
- RNDIS_THREAD_STACK_SIZE,
- 5,
- 20);
-
- if (usbh_rndis_eth_device.keepalive_timer == RT_NULL) {
- ret = -RT_ENOMEM;
- goto __exit;
- }
-
- rndis_class->user_data = (struct rt_device *)&usbh_rndis_eth_device;
-
- usbh_rndis_eth_device.rndis_recv = rt_thread_create("rndis_recv",
- (void (*)(void *parameter))rt_usbh_rndis_data_recv_entry,
- rndis_class,
- RNDIS_THREAD_STACK_SIZE,
- 5,
- 20);
-
- if (usbh_rndis_eth_device.rndis_recv == RT_NULL) {
- ret = -RT_ENOMEM;
- goto __exit;
- }
-
- /*the LINK SPEED is 100Mbps*/
- usbh_rndis_eth_device.rndis_speed = rndis_class->rndis_class->link_speed;
-
- for (j = 0; j < MAX_ADDR_LEN; j++) {
- usbh_rndis_eth_device.dev_addr[j] = rndis_class->rndis_class->mac[j];
- }
-
-__exit:
- if (ret == RT_EOK) {
- /*This state is entered after the host has received REMOTE_NDIS_SET_CMPLT
- messages from the device in response to the REMOTE_NDIS_SET_MSG
- that it had sent earlier to the device with all the OIDs required to configure the device for data transfer.
- When the host is in this state, apart from the control messages,
- it can exchange REMOTE_NDIS_PACKET_MSG messages for network data transfer with the device on the data channel*/
- usbh_rndis_eth_device.rndis_state = RNDIS_DATA_INITIALIZED;
- rt_thread_startup(usbh_rndis_eth_device.rndis_recv);
- rt_thread_startup(usbh_rndis_eth_device.keepalive_timer);
-
- RNDIS_DEV_PRINTF("rndis dev start!\n");
- usbh_rndis_eth_device.rndis_class = rndis_class;
-
- } else {
- RNDIS_DEV_PRINTF("rndis dev faile!\n");
- }
-
- return ret;
-}
-
-void usbh_rndis_run(struct usbh_rndis *rndis_class)
-{
- g_user_rndis = usb_malloc(sizeof(struct usbh_user_rndis));
- RT_ASSERT(g_user_rndis != RT_NULL);
- g_user_rndis->rndis_class = rndis_class;
- if (rt_rndis_run(g_user_rndis) == RT_EOK) {
- /* Allocate ethernet resource. */
- eth_device_init(&usbh_rndis_eth_device.parent, RNDIS_NET_DEV_NAME);
- //eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_FALSE);
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_TRUE);
- }
-}
-
-rt_err_t rt_rndis_stop(struct usbh_user_rndis *rndis_class)
-{
- rt_rndis_eth_t info = RT_NULL;
-
- info = (rt_rndis_eth_t)rndis_class->user_data;
-
- if (info->rndis_recv) {
- rt_thread_delete(info->rndis_recv);
- info->rndis_recv = RT_NULL;
- }
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_FALSE);
-
- /* Destroy ethernet resource. */
- eth_device_deinit(&usbh_rndis_eth_device.parent);
-
- usbh_rndis_eth_device.rndis_class = RT_NULL;
-
- /*disable the other thread etx call the rt_timer_start(rndis->keepalive_timer) cause the RT_ASSERT(rt_object_get_type(&timer->parent) == RT_Object_Class_Timer)*/
- if (info->keepalive_timer) {
- rt_thread_delete(info->keepalive_timer);
- info->keepalive_timer = RT_NULL;
- }
-
- info->rndis_state = RNDIS_BUS_UNINITIALIZED;
-
- RNDIS_DEV_PRINTF("rndis dev stop!\n");
- return RT_EOK;
-}
-
-void usbh_rndis_stop(struct usbh_rndis *rndis_class)
-{
- RT_ASSERT(g_user_rndis != RT_NULL);
- rt_rndis_stop(g_user_rndis);
- usb_free(g_user_rndis);
- g_user_rndis = RT_NULL;
-}
-/**
- * This function rndis eth device.
- *
- * @param intf the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-#ifdef RT_USING_LWIP
-/* initialize the interface */
-static rt_err_t rt_rndis_eth_init(rt_device_t dev)
-{
- return RT_EOK;
-}
-
-static rt_err_t rt_rndis_eth_open(rt_device_t dev, rt_uint16_t oflag)
-{
- return RT_EOK;
-}
-
-static rt_err_t rt_rndis_eth_close(rt_device_t dev)
-{
- return RT_EOK;
-}
-
-static rt_size_t rt_rndis_eth_read(rt_device_t dev, rt_off_t pos, void *buffer, rt_size_t size)
-{
- rt_set_errno(-RT_ENOSYS);
- return 0;
-}
-
-static rt_size_t rt_rndis_eth_write(rt_device_t dev, rt_off_t pos, const void *buffer, rt_size_t size)
-{
- rt_set_errno(-RT_ENOSYS);
- return 0;
-}
-static rt_err_t rt_rndis_eth_control(rt_device_t dev, int cmd, void *args)
-{
- rt_rndis_eth_t rndis_eth_dev = (rt_rndis_eth_t)dev;
- switch (cmd) {
- case NIOCTL_GADDR:
- /* get mac address */
- if (args) {
- rt_memcpy(args, rndis_eth_dev->dev_addr, MAX_ADDR_LEN);
- } else {
- return -RT_ERROR;
- }
- break;
-
- default:
- break;
- }
-
- return RT_EOK;
-}
-
-/* ethernet device interface */
-
-/* transmit packet. */
-extern int usbh_rndis_query_msg_transfer(struct usbh_rndis *rndis_class,
- uint32_t oid, uint32_t query_len,
- uint8_t *info, uint32_t *info_len);
-
-rt_err_t rt_rndis_eth_tx(rt_device_t dev, struct pbuf *p)
-{
- struct pbuf *q;
- rt_uint8_t *buffer = RT_NULL;
- rt_err_t result = RT_EOK;
- rt_rndis_eth_t device = (rt_rndis_eth_t)dev;
- rndis_packet_msg_t msg = RT_NULL;
- int recount = 5;
- int ret;
- uint8_t data[4];
- uint32_t info_len = 0;
-
- if (!device->parent.link_status) {
- while (RT_TRUE) {
- if (device->rndis_class == RT_NULL) {
- rt_thread_delay(1000);
- continue;
- }
- break;
- }
- RNDIS_DEV_PRINTF("linkdown, drop pkg\r\n");
- while (recount--) {
- ret = usbh_rndis_query_msg_transfer(device->rndis_class->rndis_class, OID_GEN_MEDIA_CONNECT_STATUS, sizeof(data), data, &info_len);
- if (ret < 0) {
- return -EBUSY;
- }
- if (NDIS_MEDIA_STATE_CONNECTED == data[0]) {
- device->rndis_class->rndis_class->link_status = true;
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_TRUE);
- RNDIS_DEV_PRINTF("linkup, drop pkg\r\n");
- break;
- } else {
- device->rndis_class->rndis_class->link_status = false;
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_FALSE);
- }
- rt_thread_delay(100);
- }
- return RT_EOK;
- }
-
- RT_ASSERT((p->tot_len + sizeof(struct rndis_packet_msg)) < sizeof(device->tx_buffer));
- if (p->tot_len > sizeof(device->tx_buffer)) {
- RNDIS_DEV_PRINTF("RNDIS MTU is:%d, but the send packet size is %d\r\n",
- sizeof(device->tx_buffer), p->tot_len);
- p->tot_len = sizeof(device->tx_buffer);
- }
-
- msg = (rndis_packet_msg_t)&device->tx_buffer;
- msg->MessageType = REMOTE_NDIS_PACKET_MSG;
- msg->DataOffset = sizeof(struct rndis_packet_msg) - 8;
- msg->DataLength = p->tot_len;
- msg->OOBDataLength = 0;
- msg->OOBDataOffset = 0;
- msg->NumOOBDataElements = 0;
- msg->PerPacketInfoOffset = 0;
- msg->PerPacketInfoLength = 0;
- msg->VcHandle = 0;
- msg->Reserved = 0;
- msg->MessageLength = sizeof(struct rndis_packet_msg) + p->tot_len;
-
- buffer = msg->data;
- for (q = p; q != NULL; q = q->next) {
- rt_memcpy(buffer, q->payload, q->len);
- buffer += q->len;
- }
-
- /* send */
- if ((msg->MessageLength & 0x3F) == 0) {
- /* pad a dummy. */
- msg->MessageLength += 1;
- }
-
- if (device->frame_debug == RT_TRUE) {
- rt_kprintf("msg @ %08x\n", msg);
- hex_data_print("rndis eth tx", (rt_uint8_t *)msg, msg->MessageLength);
- }
- result = rt_rndis_msg_data_send(device->rndis_class, (rt_uint8_t *)msg, msg->MessageLength);
- device->send_packet_counter++;
-
- return result;
-}
-
-#ifdef RT_USING_DEVICE_OPS
-const static struct rt_device_ops rndis_device_ops = {
- rt_rndis_eth_init,
- rt_rndis_eth_open,
- rt_rndis_eth_close,
- rt_rndis_eth_read,
- rt_rndis_eth_write,
- rt_rndis_eth_control
-}
-#endif
-#endif
-
-__WEAK void
-lowlevel_usb_init(void)
-{
-}
-
-int usbh_rndis_eth_device_init(void)
-{
- /* Initialize all data member in usbh_rndis_eth_device */
- rt_memset(&usbh_rndis_eth_device, 0, sizeof(struct rt_rndis_eth));
-
- /* OUI 00-00-00, only for test. */
- usbh_rndis_eth_device.dev_addr[0] = 0xFF;
- usbh_rndis_eth_device.dev_addr[1] = 0xFF;
- usbh_rndis_eth_device.dev_addr[2] = 0xFF;
- /* generate random MAC. */
- usbh_rndis_eth_device.dev_addr[3] = 0xFF;
- usbh_rndis_eth_device.dev_addr[4] = 0xFF;
- usbh_rndis_eth_device.dev_addr[5] = 0xFF;
-
- usbh_rndis_eth_device.rndis_mutex = rt_mutex_create("rndis", RT_IPC_FLAG_PRIO);
-
- if (usbh_rndis_eth_device.rndis_mutex == RT_NULL) {
- RNDIS_DEV_PRINTF("Rndis mutex creat faile!\r\n");
- }
-
-#ifdef RT_USING_DEVICE_OPS
- usbh_rndis_eth_device.parent.parent.ops = &rndis_device_ops;
-#else
- usbh_rndis_eth_device.parent.parent.init = rt_rndis_eth_init;
- usbh_rndis_eth_device.parent.parent.open = rt_rndis_eth_open;
- usbh_rndis_eth_device.parent.parent.close = rt_rndis_eth_close;
- usbh_rndis_eth_device.parent.parent.read = rt_rndis_eth_read;
- usbh_rndis_eth_device.parent.parent.write = rt_rndis_eth_write;
- usbh_rndis_eth_device.parent.parent.control = rt_rndis_eth_control;
-#endif
- usbh_rndis_eth_device.parent.parent.user_data = RT_NULL;
-
- usbh_rndis_eth_device.parent.eth_rx = RT_NULL;
- usbh_rndis_eth_device.parent.eth_tx = rt_rndis_eth_tx;
-
- /* register eth device */
- usbh_rndis_eth_device.rx_buf_ptr = usbh_rndis_eth_device.rx_buffer;
- usbh_rndis_eth_device.frame_debug = RT_FALSE;
-
- usbh_rndis_eth_device.send_packet_counter = 0;
- usbh_rndis_eth_device.recv_packet_counter = 0;
-
- lowlevel_usb_init();
-
- return 0;
-}
-INIT_DEVICE_EXPORT(usbh_rndis_eth_device_init);
-
-/*********************************************************************************************************
-** Function name eth_rndis_frame_debug()
-** Descriptions: rndis frame print
-** input parameters
-** output parameters None
-** Returned value: RT_EOK or RT_ERROR
-*********************************************************************************************************/
-static void eth_rndis_frame_debug(int argc, char **argv)
-{
- if (argc != 2) {
- rt_kprintf("Please check the command you enter, it like this: rndis_debug on/off!\n");
- } else {
- if (rt_strcmp(argv[1], "on") == 0) {
- usbh_rndis_eth_device.frame_debug = RT_TRUE;
- } else {
- usbh_rndis_eth_device.frame_debug = RT_FALSE;
- }
- }
-}
-
-#ifdef FINSH_USING_MSH
-#include <finsh.h>
-MSH_CMD_EXPORT_ALIAS(eth_rndis_frame_debug, rndis_debug, set eth rndis frame print);
-#endif /* FINSH_USING_MSH */
diff --git a/third_party/rt-thread-4.1.1/rndis_host/rndis_host_lwip2.1.2.c b/third_party/rt-thread-4.1.1/rndis_host/rndis_host_lwip2.1.2.c
deleted file mode 100644
index 624dc735..00000000
--- a/third_party/rt-thread-4.1.1/rndis_host/rndis_host_lwip2.1.2.c
+++ /dev/null
@@ -1,653 +0,0 @@
-#include <rtthread.h>
-#include "usbh_core.h"
-#include "usbh_rndis.h"
-#include "rndis_protocol.h"
-
-/* RT-Thread LWIP ethernet interface */
-#include <netif/ethernetif.h>
-#include <netdev.h>
-
-/* define the rdnis device state*/
-#define RNDIS_BUS_UNINITIALIZED 0
-#define RNDIS_BUS_INITIALIZED 1
-#define RNDIS_INITIALIZED 2
-#define RNDIS_DATA_INITIALIZED 3
-
-#define USB_ETH_MTU 1500 + 14
-
-#define RNDIS_NET_DEV_NAME "u0"
-#define MAX_ADDR_LEN 6
-/* rndis device keepalive time 5000ms*/
-#define RNDIS_DEV_KEEPALIVE_TIMEOUT 5000
-/*should be the usb Integer multiple of maximum packet length N*64*/
-#define RNDIS_ETH_BUFFER_LEN ((sizeof(struct rndis_packet_msg) + USB_ETH_MTU + 42) * 5)
-
-static rt_err_t rt_rndis_eth_tx(rt_device_t dev, struct pbuf *p);
-
-extern int usbh_rndis_query_msg_transfer(struct usbh_rndis *rndis_class,
- uint32_t oid, uint32_t query_len,
- uint8_t *info, uint32_t *info_len);
-
-struct usbh_user_rndis {
- struct usbh_rndis *rndis_class;
- void *user_data;
-};
-
-struct rndis_packet_msg
-{
- rt_uint32_t MessageType;
- rt_uint32_t MessageLength;
- rt_uint32_t DataOffset;
- rt_uint32_t DataLength;
- rt_uint32_t OOBDataOffset;
- rt_uint32_t OOBDataLength;
- rt_uint32_t NumOOBDataElements;
- rt_uint32_t PerPacketInfoOffset;
- rt_uint32_t PerPacketInfoLength;
- rt_uint32_t VcHandle;
- rt_uint32_t Reserved;
- rt_uint8_t data[0];
-};
-typedef struct rndis_packet_msg* rndis_packet_msg_t;
-
-struct rt_rndis_eth {
- /* inherit from ethernet device */
- struct eth_device parent;
-
- struct usbh_user_rndis *rndis_class;
- rt_mutex_t rndis_mutex;
- /* interface address info */
- rt_uint8_t dev_addr[MAX_ADDR_LEN];
- rt_uint16_t res;
- rt_uint32_t rndis_speed;
- rt_uint32_t res32;
-
- rt_uint8_t tx_buffer[RNDIS_ETH_BUFFER_LEN];
- rt_uint8_t rx_buffer[RNDIS_ETH_BUFFER_LEN];
- rt_uint8_t *rx_buf_ptr;
- rt_uint32_t frame_debug;
- rt_uint32_t send_packet_counter;
- rt_uint32_t recv_packet_counter;
-
- rt_uint32_t rndis_state;
- rt_thread_t rndis_recv;
- rt_timer_t keepalive_timer;
-};
-typedef struct rt_rndis_eth *rt_rndis_eth_t;
-
-struct usbh_user_rndis *g_user_rndis;
-USB_NOCACHE_RAM_SECTION struct rt_rndis_eth usbh_rndis_eth_device;
-
-void hex_data_print(const char *name, const rt_uint8_t *buf, rt_size_t size)
-{
-#define __is_print(ch) ((unsigned int)((ch) - ' ') < 127u - ' ')
-#define WIDTH_SIZE 32
-
- rt_size_t i, j;
- rt_tick_t tick = 0;
- rt_uint32_t time = 0;
-
- tick = rt_tick_get();
- time = (tick * 1000) / RT_TICK_PER_SECOND;
-
- rt_kprintf("%s time=%d.%ds,len = %d\n", name, time / 1000, time % 1000, size);
-
- for (i = 0; i < size; i += WIDTH_SIZE) {
- rt_kprintf("[HEX] %s: %04X-%04X: ", name, i, i + WIDTH_SIZE);
- for (j = 0; j < WIDTH_SIZE; j++) {
- if (i + j < size) {
- rt_kprintf("%02X ", buf[i + j]);
- } else {
- rt_kprintf(" ");
- }
- if ((j + 1) % 8 == 0) {
- rt_kprintf(" ");
- }
- }
- rt_kprintf(" ");
- for (j = 0; j < WIDTH_SIZE; j++) {
- if (i + j < size) {
- rt_kprintf("%c", __is_print(buf[i + j]) ? buf[i + j] : '.');
- }
- }
- rt_kprintf("\n");
- }
-}
-
-#define RNDIS_DEV_DEBUG
-#ifdef RNDIS_DEV_DEBUG
-#define RNDIS_DEV_PRINTF \
- rt_kprintf("[RNDIS_DEV] "); \
- rt_kprintf
-#else
-#define RNDIS_DEV_PRINTF(...)
-#endif /* RNDIS_DEBUG */
-
-/**
- * This function send the rndis data.
- *
- * @param rndis_class the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-static rt_err_t rt_rndis_msg_data_send(struct usbh_user_rndis *rndis_class, rt_uint8_t *buffer, int nbytes)
-{
- int ret = 0;
-
- if (rndis_class == RT_NULL) {
- return -RT_ERROR;
- }
-
- rt_rndis_eth_t info = RT_NULL;
-
- info = (rt_rndis_eth_t)rndis_class->user_data;
- rt_mutex_take(usbh_rndis_eth_device.rndis_mutex, RT_WAITING_FOREVER);
- ret = usbh_rndis_bulk_out_transfer(rndis_class->rndis_class, buffer, nbytes, 5000);
- rt_mutex_release(usbh_rndis_eth_device.rndis_mutex);
- if (ret != nbytes) {
- rt_kprintf("rndis msg send fial\r\n");
- }
- return ret;
-}
-
-/**
- * This function recv the rndis data.
- *
- * @param rndis_class the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-static rt_err_t rndis_msg_data_recv(struct usbh_user_rndis *rndis_class, rt_uint8_t *buffer, int nbytes)
-{
- int ret = 0;
-
- if (rndis_class == RT_NULL) {
- return -RT_ERROR;
- }
- ret = usbh_rndis_bulk_in_transfer(rndis_class->rndis_class, buffer, nbytes, USB_OSAL_WAITING_FOREVER);
-
- return ret;
-}
-
-/**
- * This function send the rndis set msg.
- *
- * @param rndis_class the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-static rt_err_t rt_rndis_keepalive_msg(struct usbh_user_rndis *rndis_class)
-{
- return usbh_rndis_keepalive(rndis_class->rndis_class);
-}
-
-/**
- * This function will send the bulk data to the usb device instance,
- *
- * @param device the usb device instance.
- * @param type the type of descriptor bRequest.
- * @param buffer the data buffer to save requested data
- * @param nbytes the size of buffer
- *
- * @return the error code, RT_EOK on successfully.
- */
-void rt_usbh_rndis_data_recv_entry(void *pdata)
-{
- int ret = 0;
- uint8_t data[4];
- uint32_t info_len = 0;
- rt_uint32_t recount = 1000;
- struct usbh_user_rndis *rndis_class = (struct usbh_user_rndis *)pdata;
- rt_rndis_eth_t device = RT_NULL;
- device = (rt_rndis_eth_t)rndis_class->user_data;
- err_t err;
- struct pbuf *p;
- rndis_data_packet_t *pmsg;
- int pmg_offset;
- int payload_offset;
-
- if ((pdata == RT_NULL) || (rndis_class == RT_NULL) ||
- (device == RT_NULL)) {
- return;
- }
-
- device->rx_buf_ptr = device->rx_buffer;
-
- if (!device->parent.link_status) {
- while (RT_TRUE) {
- if (device->rndis_class == RT_NULL) {
- rt_thread_delay(1000);
- continue;
- }
- break;
- }
- RNDIS_DEV_PRINTF("linkdown, drop pkg\r\n");
- while(recount--) {
- ret = usbh_rndis_query_msg_transfer(rndis_class->rndis_class, OID_GEN_MEDIA_CONNECT_STATUS, sizeof(data), data, &info_len);
- if (ret < 0) {
- continue;;
- }
- if (NDIS_MEDIA_STATE_CONNECTED == data[0]) {
- device->rndis_class->rndis_class->link_status = true;
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_TRUE);
- RNDIS_DEV_PRINTF("linkup, drop pkg\r\n");
- break;
- } else {
- device->rndis_class->rndis_class->link_status = false;
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_FALSE);
- }
- rt_thread_delay(100);
- }
- }
- while (1) {
- pmg_offset = 0;
- payload_offset = 0;
- ret = usbh_rndis_bulk_in_transfer(rndis_class->rndis_class, device->rx_buf_ptr, RNDIS_ETH_BUFFER_LEN, USB_OSAL_WAITING_FOREVER);
- if (ret <= 0) {
- rt_thread_mdelay(1);
- continue;
- }
- while (ret > 0) {
- pmsg = (rndis_data_packet_t *)(device->rx_buf_ptr + pmg_offset);
- if (pmsg->MessageType == REMOTE_NDIS_PACKET_MSG) {
- /* allocate buffer */
- p = pbuf_alloc(PBUF_RAW, pmsg->DataLength, PBUF_POOL);
- if (p != NULL) {
- struct pbuf *q;
- for (q = p; q != NULL; q = q->next) {
- /* Copy the received frame into buffer from memory pointed by the current ETHERNET DMA Rx descriptor */
- memcpy(q->payload, ((uint8_t *)(&pmsg->DataOffset) + pmsg->DataOffset + payload_offset), q->len);
- payload_offset += q->len;
- }
- /* entry point to the LwIP stack */
- /* notify to upper layer */
- if(device->parent.netif->input(p, device->parent.netif)!= ERR_OK )
- {
- LWIP_DEBUGF(NETIF_DEBUG, ("ethernetif_input: Input error\n"));
- pbuf_free(p);
- p = NULL;
- }
- pmg_offset += pmsg->MessageLength;
- ret -= pmsg->MessageLength;
- }
- }
- }
- }
-}
-
-void rt_rndis_dev_keepalive_timeout(void *pdata)
-{
- struct usbh_user_rndis *rndis_class = (struct usbh_user_rndis *)pdata;
- static rt_uint32_t keepalive_error = 0;
-
- if (rndis_class == RT_NULL) {
- return;
- }
-
- rt_mutex_take(usbh_rndis_eth_device.rndis_mutex, RT_WAITING_FOREVER);
- rt_rndis_keepalive_msg(rndis_class);
- rt_mutex_release(usbh_rndis_eth_device.rndis_mutex);
-}
-
-/**
- * This function will run rndis driver when usb disk is detected.
- *
- * @param rndis_class the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-rt_err_t rt_rndis_run(struct usbh_user_rndis *rndis_class)
-{
- rt_err_t ret = 0;
- rt_uint32_t i = 0, j = 0;
-
- /* check parameter */
- RT_ASSERT(rndis_class != RT_NULL);
-
- /*The host is configured to send and receive any of the RNDIS control messages for suitably
- configuring or querying the device, to receive status indications from the device,
- to reset the device, or to tear down the data and control channels*/
- usbh_rndis_eth_device.rndis_state = RNDIS_INITIALIZED;
-
- usbh_rndis_eth_device.keepalive_timer = rt_timer_create("keeplive", rt_rndis_dev_keepalive_timeout,
- rndis_class,
- RT_TICK_PER_SECOND * RNDIS_DEV_KEEPALIVE_TIMEOUT / 1000,
- RT_TIMER_FLAG_PERIODIC | RT_TIMER_FLAG_SOFT_TIMER);
-
- if (usbh_rndis_eth_device.keepalive_timer == RT_NULL) {
- ret = -RT_ENOMEM;
- goto __exit;
- }
- rt_timer_start(usbh_rndis_eth_device.keepalive_timer);
- rndis_class->user_data = (struct rt_device *)&usbh_rndis_eth_device;
-
- usbh_rndis_eth_device.rndis_recv = rt_thread_create("rndis",
- (void (*)(void *parameter))rt_usbh_rndis_data_recv_entry,
- rndis_class,
- 1024 + 512,
- 5,
- 20);
-
- if (usbh_rndis_eth_device.rndis_recv == RT_NULL) {
- ret = -RT_ENOMEM;
- goto __exit;
- }
-
- /*the LINK SPEED is 100Mbps*/
- usbh_rndis_eth_device.rndis_speed = rndis_class->rndis_class->link_speed;
-
- eth_device_linkchange(&usbh_rndis_eth_device.parent, rndis_class->rndis_class->link_status);
-
- for (j = 0; j < MAX_ADDR_LEN; j++) {
- usbh_rndis_eth_device.dev_addr[j] = rndis_class->rndis_class->mac[j];
- }
-
-__exit:
- if (ret == RT_EOK) {
- /*This state is entered after the host has received REMOTE_NDIS_SET_CMPLT
- messages from the device in response to the REMOTE_NDIS_SET_MSG
- that it had sent earlier to the device with all the OIDs required to configure the device for data transfer.
- When the host is in this state, apart from the control messages,
- it can exchange REMOTE_NDIS_PACKET_MSG messages for network data transfer with the device on the data channel*/
- usbh_rndis_eth_device.rndis_state = RNDIS_DATA_INITIALIZED;
- RNDIS_DEV_PRINTF("rndis dev start!\n");
- usbh_rndis_eth_device.rndis_class = rndis_class;
- rt_thread_startup(usbh_rndis_eth_device.rndis_recv);
-
- } else {
- RNDIS_DEV_PRINTF("rndis dev faile!\n");
- }
-
- return ret;
-}
-
-static err_t linkoutput_fn(struct netif *netif, struct pbuf *p)
-{
- int ret;
- rt_device_t dev = (rt_device_t)&usbh_rndis_eth_device;
- ret = rt_rndis_eth_tx(dev, p);
-
- if (-EBUSY == ret) {
- ret = ERR_BUF;
- }
-
- return ret;
-}
-
-void usbh_rndis_run(struct usbh_rndis *rndis_class)
-{
- g_user_rndis = usb_malloc(sizeof(struct usbh_user_rndis));
- RT_ASSERT(g_user_rndis != RT_NULL);
- g_user_rndis->rndis_class = rndis_class;
- if (rt_rndis_run(g_user_rndis) == RT_EOK) {
- eth_device_init(&usbh_rndis_eth_device.parent, RNDIS_NET_DEV_NAME);
- usbh_rndis_eth_device.parent.netif->linkoutput = linkoutput_fn;
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_FALSE);
- }
-}
-
-rt_err_t rt_rndis_stop(struct usbh_user_rndis *rndis_class)
-{
- rt_rndis_eth_t info = RT_NULL;
-
- info = (rt_rndis_eth_t)rndis_class->user_data;
-
- if (info->rndis_recv) {
- rt_thread_delete(info->rndis_recv);
- info->rndis_recv = RT_NULL;
- }
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_FALSE);
- usbh_rndis_eth_device.rndis_class = RT_NULL;
-
- /*disable the other thread etx call the rt_timer_start(rndis->keepalive_timer) cause the RT_ASSERT(rt_object_get_type(&timer->parent) == RT_Object_Class_Timer)*/
- rt_mutex_take(usbh_rndis_eth_device.rndis_mutex, RT_WAITING_FOREVER);
- if (info->keepalive_timer) {
- rt_timer_stop(info->keepalive_timer);
- rt_timer_delete(info->keepalive_timer);
- info->keepalive_timer = RT_NULL;
- }
- rt_mutex_release(usbh_rndis_eth_device.rndis_mutex);
-
- info->rndis_state = RNDIS_BUS_UNINITIALIZED;
-
- RNDIS_DEV_PRINTF("rndis dev stop!\n");
- return RT_EOK;
-}
-
-void usbh_rndis_stop(struct usbh_rndis *rndis_class)
-{
- RT_ASSERT(g_user_rndis != RT_NULL);
- rt_rndis_stop(g_user_rndis);
- usb_free(g_user_rndis);
-}
-/**
- * This function rndis eth device.
- *
- * @param intf the usb interface instance.
- *
- * @return the error code, RT_EOK on successfully.
- */
-#ifdef RT_USING_LWIP
-/* initialize the interface */
-static rt_err_t rt_rndis_eth_init(rt_device_t dev)
-{
- return RT_EOK;
-}
-
-static rt_err_t rt_rndis_eth_open(rt_device_t dev, rt_uint16_t oflag)
-{
- return RT_EOK;
-}
-
-static rt_err_t rt_rndis_eth_close(rt_device_t dev)
-{
- return RT_EOK;
-}
-
-static rt_ssize_t rt_rndis_eth_read(rt_device_t dev, rt_off_t pos, void *buffer, rt_size_t size)
-{
- rt_set_errno(-RT_ENOSYS);
- return 0;
-}
-
-static rt_ssize_t rt_rndis_eth_write(rt_device_t dev, rt_off_t pos, const void *buffer, rt_size_t size)
-{
- rt_set_errno(-RT_ENOSYS);
- return 0;
-}
-static rt_err_t rt_rndis_eth_control(rt_device_t dev, int cmd, void *args)
-{
- rt_rndis_eth_t rndis_eth_dev = (rt_rndis_eth_t)dev;
- switch (cmd) {
- case NIOCTL_GADDR:
- /* get mac address */
- if (args) {
- rt_memcpy(args, rndis_eth_dev->dev_addr, MAX_ADDR_LEN);
- } else {
- return -RT_ERROR;
- }
- break;
-
- default:
- break;
- }
-
- return RT_EOK;
-}
-
-/* ethernet device interface */
-
-
-/* transmit packet. */
-
-
-static rt_err_t rt_rndis_eth_tx(rt_device_t dev, struct pbuf *p)
-{
- struct pbuf *q;
- rt_uint8_t *buffer = RT_NULL;
- rt_err_t result = RT_EOK;
- rt_rndis_eth_t device = (rt_rndis_eth_t)dev;
- rndis_packet_msg_t msg = RT_NULL;
- int recount = 5;
- int ret;
- uint8_t data[4];
- uint32_t info_len = 0;
-
- if (!device->parent.link_status) {
- while (RT_TRUE) {
- if (device->rndis_class == RT_NULL) {
- rt_thread_delay(1000);
- continue;
- }
- break;
- }
- RNDIS_DEV_PRINTF("linkdown, drop pkg\r\n");
- while(recount--) {
- ret = usbh_rndis_query_msg_transfer(device->rndis_class->rndis_class, OID_GEN_MEDIA_CONNECT_STATUS, sizeof(data), data, &info_len);
- if (ret < 0) {
- return -EBUSY;
- }
- if (NDIS_MEDIA_STATE_CONNECTED == data[0]) {
- device->rndis_class->rndis_class->link_status = true;
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_TRUE);
- RNDIS_DEV_PRINTF("linkup, drop pkg\r\n");
- break;
- } else {
- device->rndis_class->rndis_class->link_status = false;
- eth_device_linkchange(&usbh_rndis_eth_device.parent, RT_FALSE);
- }
- rt_thread_delay(100);
- }
- return RT_EOK;
- }
-
- RT_ASSERT((p->tot_len + sizeof(struct rndis_packet_msg)) < sizeof(device->tx_buffer));
- if (p->tot_len > sizeof(device->tx_buffer)) {
- RNDIS_DEV_PRINTF("RNDIS MTU is:%d, but the send packet size is %d\r\n",
- sizeof(device->tx_buffer), p->tot_len);
- p->tot_len = sizeof(device->tx_buffer);
- }
-
- msg = (rndis_packet_msg_t)&device->tx_buffer;
- msg->MessageType = REMOTE_NDIS_PACKET_MSG;
- msg->DataOffset = sizeof(struct rndis_packet_msg) - 8;
- msg->DataLength = p->tot_len;
- msg->OOBDataLength = 0;
- msg->OOBDataOffset = 0;
- msg->NumOOBDataElements = 0;
- msg->PerPacketInfoOffset = 0;
- msg->PerPacketInfoLength = 0;
- msg->VcHandle = 0;
- msg->Reserved = 0;
- msg->MessageLength = sizeof(struct rndis_packet_msg) + p->tot_len;
-
- buffer = msg->data;
- for (q = p; q != NULL; q = q->next) {
- rt_memcpy(buffer, q->payload, q->len);
- buffer += q->len;
- }
-
- /* send */
- if ((msg->MessageLength & 0x3F) == 0) {
- /* pad a dummy. */
- msg->MessageLength += 1;
- }
-
- if (device->frame_debug == RT_TRUE) {
- hex_data_print("rndis eth tx", (rt_uint8_t *)msg, msg->MessageLength);
- }
- result = rt_rndis_msg_data_send(device->rndis_class, (rt_uint8_t *)msg, msg->MessageLength);
- if (result == msg->MessageLength) {
- result = ERR_OK;
- }
- device->send_packet_counter++;
-
- return result;
-}
-
-#ifdef RT_USING_DEVICE_OPS
-const static struct rt_device_ops rndis_device_ops = {
- rt_rndis_eth_init,
- rt_rndis_eth_open,
- rt_rndis_eth_close,
- rt_rndis_eth_read,
- rt_rndis_eth_write,
- rt_rndis_eth_control
-}
-#endif
-#endif
-
-__WEAK void lowlevel_usb_init(void)
-{
-
-}
-
-int usbh_rndis_eth_device_init(void)
-{
- /* OUI 00-00-00, only for test. */
- usbh_rndis_eth_device.dev_addr[0] = 0xFF;
- usbh_rndis_eth_device.dev_addr[1] = 0xFF;
- usbh_rndis_eth_device.dev_addr[2] = 0xFF;
- /* generate random MAC. */
- usbh_rndis_eth_device.dev_addr[3] = 0xFF;
- usbh_rndis_eth_device.dev_addr[4] = 0xFF;
- usbh_rndis_eth_device.dev_addr[5] = 0xFF;
-
- usbh_rndis_eth_device.rndis_mutex = rt_mutex_create("rndis", RT_IPC_FLAG_PRIO);
-
- if (usbh_rndis_eth_device.rndis_mutex == RT_NULL) {
- RNDIS_DEV_PRINTF("Rndis mutex creat faile!\r\n");
- }
-
-#ifdef RT_USING_DEVICE_OPS
- usbh_rndis_eth_device.parent.parent.ops = &rndis_device_ops;
-#else
- usbh_rndis_eth_device.parent.parent.init = rt_rndis_eth_init;
- usbh_rndis_eth_device.parent.parent.open = rt_rndis_eth_open;
- usbh_rndis_eth_device.parent.parent.close = rt_rndis_eth_close;
- usbh_rndis_eth_device.parent.parent.read = rt_rndis_eth_read;
- usbh_rndis_eth_device.parent.parent.write = rt_rndis_eth_write;
- usbh_rndis_eth_device.parent.parent.control = rt_rndis_eth_control;
-#endif
- usbh_rndis_eth_device.parent.parent.user_data = RT_NULL;
-
- usbh_rndis_eth_device.parent.eth_rx = RT_NULL;
- usbh_rndis_eth_device.parent.eth_tx = RT_NULL;
-
- /* register eth device */
- usbh_rndis_eth_device.rx_buf_ptr = usbh_rndis_eth_device.rx_buffer;
- usbh_rndis_eth_device.frame_debug = RT_FALSE;
-
- usbh_rndis_eth_device.send_packet_counter = 0;
- usbh_rndis_eth_device.recv_packet_counter = 0;
-
- lowlevel_usb_init();
-
- return RT_EOK;
-}
-INIT_APP_EXPORT(usbh_rndis_eth_device_init);
-
-/*********************************************************************************************************
-** Function name eth_rndis_frame_debug()
-** Descriptions: rndis frame print
-** input parameters
-** output parameters None
-** Returned value: RT_EOK or RT_ERROR
-*********************************************************************************************************/
-static void eth_rndis_frame_debug(int argc, char **argv)
-{
- if (argc != 2) {
- rt_kprintf("Please check the command you enter, it like this: rndis_debug on/off!\n");
- } else {
- if (rt_strcmp(argv[1], "on") == 0) {
- usbh_rndis_eth_device.frame_debug = RT_TRUE;
- } else {
- usbh_rndis_eth_device.frame_debug = RT_FALSE;
- }
- }
-}
-
-#ifdef FINSH_USING_MSH
-#include <finsh.h>
-MSH_CMD_EXPORT_ALIAS(eth_rndis_frame_debug, rndis_debug, set eth rndis frame print);
-#endif /* FINSH_USING_MSH */