SPIBackend.h

/*
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Library General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
 *
 * SPIBackend.h
 * The backend for SPI output. These are the classes which write the data to
 * the SPI bus.
 * Copyright (C) 2013 Simon Newton
 */

#ifndef PLUGINS_SPI_SPIBACKEND_H_
#define PLUGINS_SPI_SPIBACKEND_H_

#include <stdint.h>
#include <ola/thread/Mutex.h>
#include <ola/thread/Thread.h>
#include <string>
#include <vector>

#include "plugins/spi/SPIWriter.h"

namespace ola {
namespace plugin {
namespace spi {

using std::string;
using std::vector;

class SPIBackendInterface {
  public:
    virtual ~SPIBackendInterface() {}

    virtual uint8_t *Checkout(uint8_t output, unsigned int length) = 0;
    virtual uint8_t *Checkout(uint8_t output,
                              unsigned int length,
                              unsigned int latch_bytes) = 0;
    virtual void Commit(uint8_t output) = 0;

    virtual string DevicePath() const = 0;

    virtual bool Init() = 0;

  protected:
    static const char SPI_DROP_VAR[];
    static const char SPI_DROP_VAR_KEY[];
};


class HardwareBackend : public ola::thread::Thread,
                        public SPIBackendInterface {
  public:
    struct Options {
      // Which GPIO bits to use to select the output. The number of outputs
      // will be 2 ** gpio_pins.size();
      vector<uint8_t> gpio_pins;
    };

    HardwareBackend(const Options &options,
                    SPIWriterInterface *writer,
                    ExportMap *export_map);
    ~HardwareBackend();

    bool Init();

    uint8_t *Checkout(uint8_t output, unsigned int length) {
      return Checkout(output, length, 0);
    }

    uint8_t *Checkout(uint8_t output,
                      unsigned int length,
                      unsigned int latch_bytes);
    void Commit(uint8_t output);

    string DevicePath() const { return m_spi_writer->DevicePath(); }

  protected:
    void* Run();

  private:
    class OutputData {
      public:
        OutputData()
            : m_data(NULL),
              m_write_pending(false),
              m_size(0),
              m_actual_size(0),
              m_latch_bytes(0) {
        }

        ~OutputData() { delete[] m_data; }

        uint8_t *Resize(unsigned int length);
        void SetLatchBytes(unsigned int latch_bytes);
        void SetPending();
        bool IsPending() const { return m_write_pending; }
        void ResetPending() { m_write_pending = false; }
        const uint8_t *GetData() const { return m_data; }
        unsigned int Size() const { return m_size; }

        OutputData& operator=(const OutputData &other);

      private:
        uint8_t *m_data;
        bool m_write_pending;
        unsigned int m_size;
        unsigned int m_actual_size;
        unsigned int m_latch_bytes;

        OutputData(const OutputData&);
    };

    typedef vector<int> GPIOFds;
    typedef vector<OutputData*> Outputs;

    SPIWriterInterface *m_spi_writer;
    UIntMap *m_drop_map;
    const uint8_t m_output_count;
    ola::thread::Mutex m_mutex;
    ola::thread::ConditionVariable m_cond_var;
    bool m_exit;

    Outputs m_output_data;

    // GPIO members
    GPIOFds m_gpio_fds;
    const vector<uint8_t> m_gpio_pins;
    vector<bool> m_gpio_pin_state;

    void SetupOutputs(Outputs *outputs);
    void WriteOutput(uint8_t output_id, OutputData *output);
    bool SetupGPIO();
    void CloseGPIOFDs();
};


class SoftwareBackend : public SPIBackendInterface,
                        public ola::thread::Thread {
  public:
    struct Options {
      /*
       * The number of outputs.
       */
      uint8_t outputs;
       /*
       * Controls if we designate one of the outputs as the 'sync' output.
       * If set >= 0, it denotes the output which triggers the SPI write.
       * If set to -1, we perform an SPI write on each update.
       */
      int16_t sync_output;

      explicit Options() : outputs(1), sync_output(0) {}
    };

    SoftwareBackend(const Options &options,
                    SPIWriterInterface *writer,
                    ExportMap *export_map);
    ~SoftwareBackend();

    bool Init();

    uint8_t *Checkout(uint8_t output, unsigned int length) {
      return Checkout(output, length, 0);
    }

    uint8_t *Checkout(uint8_t output,
                      unsigned int length,
                      unsigned int latch_bytes);
    void Commit(uint8_t output);

    string DevicePath() const { return m_spi_writer->DevicePath(); }

  protected:
    void* Run();

  private:
    SPIWriterInterface *m_spi_writer;
    UIntMap *m_drop_map;
    ola::thread::Mutex m_mutex;
    ola::thread::ConditionVariable m_cond_var;
    bool m_write_pending;
    bool m_exit;

    const int16_t m_sync_output;
    vector<unsigned int> m_output_sizes;
    vector<unsigned int> m_latch_bytes;
    uint8_t *m_output;
    unsigned int m_length;
    unsigned int m_buffer_size;
};


class FakeSPIBackend : public SPIBackendInterface {
  public:
    explicit FakeSPIBackend(unsigned int outputs);
    ~FakeSPIBackend();

    uint8_t *Checkout(uint8_t output, unsigned int length) {
      return Checkout(output, length, 0);
    }

    uint8_t *Checkout(uint8_t output,
                      unsigned int length,
                      unsigned int latch_bytes);

    void Commit(uint8_t output);
    const uint8_t *GetData(uint8_t output, unsigned int *length);

    string DevicePath() const { return "/dev/test"; }

    bool Init() { return true; }

    unsigned int Writes(uint8_t output) const;

  private:
    class Output {
      public:
        Output() : data(NULL), length(0), writes(0) {}
        ~Output() { delete[] data; }

        uint8_t *data;
        unsigned int length;
        unsigned int writes;
    };

    typedef vector<Output*> Outputs;
    Outputs m_outputs;
};
}  // namespace spi
}  // namespace plugin
}  // namespace ola
#endif  // PLUGINS_SPI_SPIBACKEND_H_