158 lines
5.0 KiB
C
158 lines
5.0 KiB
C
/*
|
|
* The MIT License (MIT)
|
|
*
|
|
* Copyright (c) 2019 Ha Thach (tinyusb.org)
|
|
*
|
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
* of this software and associated documentation files (the "Software"), to deal
|
|
* in the Software without restriction, including without limitation the rights
|
|
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
* copies of the Software, and to permit persons to whom the Software is
|
|
* furnished to do so, subject to the following conditions:
|
|
*
|
|
* The above copyright notice and this permission notice shall be included in
|
|
* all copies or substantial portions of the Software.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
|
* THE SOFTWARE.
|
|
*
|
|
* This file is part of the TinyUSB stack.
|
|
*/
|
|
|
|
#include "cdc_serial_host_app.h"
|
|
#include "app_os_prio.h"
|
|
|
|
#if CFG_TUH_CDC
|
|
|
|
#define QUEUE_SERIAL_DEPTH 100
|
|
|
|
//--------------------------------------------------------------------+
|
|
// MACRO CONSTANT TYPEDEF
|
|
//--------------------------------------------------------------------+
|
|
static osal_semaphore_t sem_hdl;
|
|
|
|
enum { SERIAL_BUFFER_SIZE = 64 };
|
|
CFG_TUSB_MEM_SECTION static uint8_t serial_in_buffer[SERIAL_BUFFER_SIZE];
|
|
CFG_TUSB_MEM_SECTION static uint8_t serial_out_buffer[SERIAL_BUFFER_SIZE];
|
|
|
|
static uint8_t received_bytes; // set by transfer complete callback
|
|
|
|
//--------------------------------------------------------------------+
|
|
// tinyusb callbacks
|
|
//--------------------------------------------------------------------+
|
|
void tuh_cdc_mounted_cb(uint8_t dev_addr)
|
|
{ // application set-up
|
|
printf("\na CDC device (address %d) is mounted\n", dev_addr);
|
|
|
|
tu_memclr(serial_in_buffer, sizeof(serial_in_buffer));
|
|
tu_memclr(serial_out_buffer, sizeof(serial_out_buffer));
|
|
received_bytes = 0;
|
|
|
|
osal_semaphore_reset(sem_hdl);
|
|
tuh_cdc_receive(dev_addr, serial_in_buffer, SERIAL_BUFFER_SIZE, true); // schedule first transfer
|
|
}
|
|
|
|
void tuh_cdc_unmounted_cb(uint8_t dev_addr)
|
|
{ // application tear-down
|
|
printf("\na CDC device (address %d) is unmounted \n", dev_addr);
|
|
}
|
|
|
|
// invoked ISR context
|
|
void tuh_cdc_xfer_isr(uint8_t dev_addr, xfer_result_t event, cdc_pipeid_t pipe_id, uint32_t xferred_bytes)
|
|
{
|
|
(void) dev_addr; // compiler warnings
|
|
|
|
switch ( pipe_id )
|
|
{
|
|
case CDC_PIPE_DATA_IN:
|
|
switch(event)
|
|
{
|
|
case XFER_RESULT_SUCCESS:
|
|
received_bytes = xferred_bytes;
|
|
osal_semaphore_post(sem_hdl); // notify main task
|
|
break;
|
|
|
|
case XFER_RESULT_FAILED:
|
|
received_bytes = 0; // ignore
|
|
tuh_cdc_receive(dev_addr, serial_in_buffer, SERIAL_BUFFER_SIZE, true); // waiting for next data
|
|
break;
|
|
|
|
case XFER_RESULT_STALLED:
|
|
default :
|
|
break;
|
|
}
|
|
break;
|
|
|
|
case CDC_PIPE_DATA_OUT:
|
|
case CDC_PIPE_NOTIFICATION:
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
//--------------------------------------------------------------------+
|
|
// APPLICATION
|
|
//--------------------------------------------------------------------+
|
|
void cdc_serial_host_app_init(void)
|
|
{
|
|
sem_hdl = osal_semaphore_create(1, 0);
|
|
TU_ASSERT( sem_hdl, VOID_RETURN);
|
|
|
|
TU_VERIFY( osal_task_create(cdc_serial_host_app_task, "cdc", 128, NULL, CDC_SERIAL_APP_TASK_PRIO), );
|
|
}
|
|
|
|
//------------- main task -------------//
|
|
void cdc_serial_host_app_task( void* param )
|
|
{
|
|
(void) param;
|
|
|
|
OSAL_TASK_BEGIN
|
|
|
|
//------------- send characters got from uart terminal to the first CDC device -------------//
|
|
for(uint8_t dev_addr=1; dev_addr <= CFG_TUSB_HOST_DEVICE_MAX; dev_addr++)
|
|
{
|
|
if ( tuh_cdc_serial_is_mounted(dev_addr) )
|
|
{
|
|
int ch_tx = getchar();
|
|
if ( ch_tx > 0 )
|
|
{ // USB is much faster than serial, here we assume usb is always complete. There could be some characters missing though
|
|
serial_out_buffer[0] = (uint8_t) ch_tx;
|
|
|
|
if ( !tuh_cdc_is_busy(dev_addr, CDC_PIPE_DATA_OUT) )
|
|
{
|
|
tuh_cdc_send(dev_addr, serial_out_buffer, 1, false); // no need for callback on serial out pipe
|
|
}
|
|
}
|
|
break; // demo app only communicate with the first CDC-capable device
|
|
}
|
|
}
|
|
|
|
//------------- print out received characters -------------//
|
|
tusb_error_t error;
|
|
osal_semaphore_wait(sem_hdl, 100, &error); // waiting for incoming data
|
|
|
|
if ( TUSB_ERROR_NONE == error)
|
|
{
|
|
for(uint8_t i=0; i<received_bytes; i++) putchar(serial_in_buffer[i]);
|
|
|
|
for(uint8_t dev_addr=1; dev_addr <= CFG_TUSB_HOST_DEVICE_MAX; dev_addr++)
|
|
{
|
|
if ( tuh_cdc_serial_is_mounted(dev_addr) )
|
|
{
|
|
tuh_cdc_receive(dev_addr, serial_in_buffer, SERIAL_BUFFER_SIZE, true);
|
|
|
|
break; // demo app only communicate with the first CDC-capable device
|
|
}
|
|
}
|
|
}
|
|
|
|
OSAL_TASK_END
|
|
}
|
|
|
|
#endif
|