linuxfirewiredevice.h

Go to the documentation of this file.

 
#ifndef LINUX_FIREWIRE_DEVICE_H
#define LINUX_FIREWIRE_DEVICE_H
 
#include <QRunnable>
 
#include "firewiredevice.h"
#include "libmythbase/mthread.h"
 
class LFDPriv;
class LinuxAVCInfo;
class LinuxFirewireDevice;
 
class LinuxFirewireDevice : public FirewireDevice, public QRunnable
{
    friend int linux_firewire_device_tspacket_handler(
        unsigned char *tspacket, int len, uint dropped, void *callback_data);
 
  public:
    LinuxFirewireDevice(uint64_t guid, uint subunitid,
                        uint speed, bool use_p2p,
                        uint av_buffer_size_in_bytes = 0);
    ~LinuxFirewireDevice() override;
 
    // Commands
    bool OpenPort(void) override; // FirewireDevice
    bool ClosePort(void) override; // FirewireDevice
    bool ResetBus(void) override; // FirewireDevice
 
    void AddListener(TSDataListener *listener) override; // FirewireDevice
    void RemoveListener(TSDataListener *listener) override; // FirewireDevice
 
    // Gets
    bool IsPortOpen(void) const override; // FirewireDevice
 
    // Signal from driver
    void SignalReset(uint generation);
 
    // Statics
    static std::vector<AVCInfo> GetSTBList(void);
 
    // Constants
    static const uint kBroadcastChannel;
    static const uint kConnectionP2P;
    static const uint kConnectionBroadcast;
    static const uint kMaxBufferedPackets;
 
  private:
    bool OpenNode(void);
    bool CloseNode(void);
 
    bool OpenAVStream(void);
    bool CloseAVStream(void);
 
    bool OpenP2PNode(void);
    bool CloseP2PNode(void);
 
    bool OpenBroadcastNode(void);
    bool CloseBroadcastNode(void);
 
    bool StartStreaming(void);
    bool StopStreaming(void);
 
    void run(void) override; // QRunnable
    void PrintDropped(uint dropped_packets);
 
    bool SetAVStreamBufferSize(uint size_in_bytes);
    bool SetAVStreamSpeed(uint speed);
 
    bool IsNodeOpen(void) const;
    bool IsAVStreamOpen(void) const;
 
    bool UpdateDeviceList(void);
    void UpdateDeviceListItem(uint64_t guid, void *pitem);
    std::vector<AVCInfo> GetSTBListPrivate(void);
 
    bool SendAVCCommand(const std::vector<uint8_t> &cmd,
                        std::vector<uint8_t>       &result,
                        int                    retry_cnt) override; // FirewireDevice
 
    LinuxAVCInfo *GetInfoPtr(void);
    const LinuxAVCInfo *GetInfoPtr(void) const;
 
    void HandleBusReset(void);
 
  private:
    uint     m_bufsz;
    bool     m_dbResetDisabled   {false};
    bool     m_useP2P;
    LFDPriv *m_priv              {nullptr};
};
 
#endif // LINUX_FIREWIRE_DEVICE_H