CanBuffer.h

#ifndef __ECU_CANBUFFER_H__
#define __ECU_CANBUFFER_H__
 
#include <stdint.h>
#include <stdlib.h>
 
#include "TeensyThreads.h"
 
namespace CAN {
 
typedef void (*canCallback)(uint32_t, volatile uint8_t *);
 
struct Buffer { // IMPROVE: more rigorous testing on the get funcs
    const uint32_t address;
 
    volatile uint8_t *buffer;
 
    volatile canCallback callback;
 
    const bool outgoing;
 
    bool modified = false;
 
    Buffer(volatile uint8_t *buffer, bool outgoing = false) : address(0), buffer(buffer), outgoing(outgoing){};
    Buffer(const uint32_t address, volatile uint8_t *buffer, bool outgoing = false) : address(address), buffer(buffer), outgoing(outgoing){};
    void init();
    void dump(uint8_t *dest);
    void set(const uint8_t *src);
    void clear(void);
 
    void Buffer::setDouble(double val);
    void Buffer::setULong(uint64_t val);
    void Buffer::setLong(int64_t val);
    void Buffer::setFloat(float val, size_t pos);
    void Buffer::setUInt(uint32_t val, size_t pos);
    void Buffer::setInt(int32_t val, size_t pos);
    void Buffer::setUShort(uint16_t val, size_t pos);
    void Buffer::setShort(int16_t val, size_t pos);
    void Buffer::setUByte(uint8_t val, size_t pos);
    void Buffer::setByte(int8_t val, size_t pos);
    void Buffer::setBit(bool val, size_t pos);
 
    double Buffer::getDouble();
 
    float Buffer::getFloat(size_t pos);
 
    uint64_t getULong();
    int64_t getLong();
    uint32_t getUInt(size_t pos);
    int32_t getInt(size_t pos);
    uint16_t getUShort(size_t pos);
    int16_t getShort(size_t pos);
    uint8_t getUByte(size_t pos);
    int8_t getByte(size_t pos);
    bool getBit(size_t pos);
 
    bool lock();
 
    void lock_wait();
 
    void unlock();
 
private:
    Thread::Mutex mux; // TODO: make shared_mutex to allow multiple readers
};
} // namespace CAN
#endif // __ECU_CANBUFFER_H__