File content as of revision 3:dc7e9c6bc26c:

#include "CommLink.h"


// Set the class's constants for streamlined use in other areas of the code
const int CommLink::TX_QUEUE_SIZE = COMM_LINK_TX_QUEUE_SIZE;
const int CommLink::RX_QUEUE_SIZE = COMM_LINK_RX_QUEUE_SIZE;


// =================== CONSTRUCTORS ===================
// Default constructor
CommLink::CommLink()
{
    setup_pins();
    setup();
}

CommLink::CommLink(PinName mosi, PinName miso, PinName sck, PinName cs, PinName int_pin) :
    _txQueueHelper(),
    _rxQueueHelper()
{
    static unsigned int _nbr_links = 0;

    setup_pins(mosi, miso, sck, cs, int_pin);
    setup();
    _nbr_links++;
}


// =================== CLASS SETUP ===================
void CommLink::setup()
{
    // [X] - 1 - Initialize the hardware for communication.
    // =================
    setup_spi();
    setup_cs();
    setup_interrupt();


    // [X] - 2.1 - Define the TX & RX queues.
    // =================
    // The size allocations for each queue are dependent upon what interface that communication is occuring on (radio/serial/usb/etc.)

    // [X] - 2.2 - Create small TX & RX queues.
    // =================


    // [X] - 3.1 - define the thread tasks for controlling the data queues
    // =================
    // Outline the thread definitions
    define_thread(_txDef, &CommLink::txThread);
    define_thread(_rxDef, &CommLink::rxThread);

    // [X] - 3.2 - Create the threads and pass them a pointer to the created object
    _txID = osThreadCreate(&_txDef, (void*)this);
    _rxID = osThreadCreate(&_rxDef, (void*)this);
}


// =================== PIN SETUP ===================
void CommLink::setup_pins(PinName mosi, PinName miso, PinName sck, PinName cs, PinName int_pin)
{
    _mosi_pin = mosi;
    _miso_pin = miso;
    _sck_pin = sck;
    _cs_pin = cs;
    _int_pin = int_pin;
}

void CommLink::setup_spi(void)
{
    if (_mosi_pin != NC & _miso_pin != NC & _sck_pin != NC) {
        // Setup the spi for 8 bit data, high steady state clock, second edge capture
        _spi = new SPI(_mosi_pin, _miso_pin, _sck_pin);
        _spi->format(8,0);
        _spi->frequency(5000000);
    }
}

void CommLink::setup_cs(void)
{
    if (_cs_pin != NC) {
        _cs = new DigitalOut(_cs_pin);
    }
}

void CommLink::setup_interrupt(void)
{
    if (_int_pin != NC) {
        _int_in = new InterruptIn(_int_pin);
        //_int_in->mode(PullDown);
    }
}


// =================== TX/RX THREADS ===================
// Task operations for sending data over the hardware link when a new item is placed in the queue
void CommLink::txThread(void const *arg)
{
    CommLink *inst = (CommLink*)arg;

    // Only continue past this point once the hardware link is initialized
    osSignalWait(COMM_LINK_SIGNAL_START_THREAD, osWaitForever);

    while(1) {
        // [] - 1 - Wait until the CommModule class sends a signal to begin operation on new data being placed in its txQueue
        // =================

        // [] - 2 - Copy the packet from the CommModule txQueue into the CommLink txQueue
        // =================
        void *  osMailAlloc (osMailQId queue_id, uint32_t millisec);

        // [] - 3 - Call the method for sending the packet over a hardware communication link
        // =================
        uint8_t temp[20] = { 0 };
        inst->sendData(temp, 20);

        // [] - 4 - Blink the TX LED for the hardware link
        // =================

    }
}


// Task operations for placing received data into the received data queue
void CommLink::rxThread(void const *arg)
{
    CommLink *inst = (CommLink*)arg;

    // Only continue past this point once the hardware link is initialized
    osSignalWait(COMM_LINK_SIGNAL_START_THREAD & COMM_LINK_SIGNAL_MODULE_LINKED, osWaitForever);

    // Set the function to call on an interrupt trigger
    inst->_int_in->rise(inst, &CommLink::ISR);

    while(1) {
        // [X] - 1 - Wait until new data has arrived
        // =================
        osSignalWait(COMM_LINK_SIGNAL_INTERRUPT_TRIGGER, osWaitForever);

        // [X] - 2 - Get the received data from the external chip
        // =================
        uint8_t rec_bytes = COMM_LINK_BUFFER_SIZE;
        RTP_t p;
        
        //uint8_t *buf_ptr = p.data;
        inst->getData(p.data, &rec_bytes);
        
        p.port = p.data[0] & 0xF0;
        p.subclass = p.data[0] & 0x0F;

        // [] - 3 - Write the data to the CommModule object's rxQueue
        // =================            
        //_comm_module->receive(p);


        // [] - 4 - Blink the RX LED for the hardware link
        // =================
    }
}


// Called by the derived class to begin thread operations
void CommLink::ready(void)
{
    osSignalSet(_txID, COMM_LINK_SIGNAL_START_THREAD);
    osSignalSet(_rxID, COMM_LINK_SIGNAL_START_THREAD);
}


void CommLink::write_tx_queue(RTP_t *p)
{
    // [] - 1 - Write the data to the RX queue
    // =================

    // [] - 2 - Signal the TX thread of new data
    // =================

}


void CommLink::sendPacket(RTP_t *p)
{



}

void CommLink::receivePacket(RTP_t *p)
{

}

// Interrupt Service Routine - KEEP OPERATIONS TO ABOSOLUTE MINIMUM HERE AND IN OVERRIDEN BASE CLASS IMPLEMENTATIONS OF THIS CLASS METHOD
void CommLink::ISR(void)
{
    osSignalSet(_rxID , COMM_LINK_SIGNAL_INTERRUPT_TRIGGER);
}

void CommLink::toggle_cs(void)
{
    *_cs = !*_cs;
}

/*
void CommLink::module(CommModule& module)
{
    _comm_module = &module;
    osSignalSet(_rxID, COMM_LINK_SIGNAL_MODULE_LINKED);
}
*/