96 lines
2.9 KiB
C++
96 lines
2.9 KiB
C++
#ifndef __DEVICE_H__
|
|
#define __DEVICE_H__
|
|
|
|
#include <vector>
|
|
#include <memory>
|
|
#include <cstring>
|
|
#include "icsneo/device/neodevice.h"
|
|
#include "icsneo/device/idevicesettings.h"
|
|
#include "icsneo/device/devicetype.h"
|
|
#include "icsneo/communication/communication.h"
|
|
#include "icsneo/communication/packetizer.h"
|
|
#include "icsneo/communication/encoder.h"
|
|
#include "icsneo/communication/decoder.h"
|
|
#include "icsneo/communication/message/resetstatusmessage.h"
|
|
#include "icsneo/third-party/concurrentqueue/concurrentqueue.h"
|
|
|
|
namespace icsneo {
|
|
|
|
class Device {
|
|
public:
|
|
Device(neodevice_t neodevice = { 0 }) {
|
|
data = neodevice;
|
|
data.device = this;
|
|
}
|
|
virtual ~Device() {
|
|
disableMessagePolling();
|
|
close();
|
|
}
|
|
|
|
static std::string SerialNumToString(uint32_t serial);
|
|
static uint32_t SerialStringToNum(const std::string& serial);
|
|
static bool SerialStringIsNumeric(const std::string& serial);
|
|
|
|
DeviceType getType() const { return DeviceType(data.type); }
|
|
uint16_t getProductId() const { return productId; }
|
|
std::string getSerial() const { return data.serial; }
|
|
uint32_t getSerialNumber() const { return Device::SerialStringToNum(getSerial()); }
|
|
const neodevice_t& getNeoDevice() const { return data; }
|
|
|
|
virtual bool open();
|
|
virtual bool close();
|
|
virtual bool isOnline() const { return online; }
|
|
virtual bool goOnline();
|
|
virtual bool goOffline();
|
|
|
|
// Message polling related functions
|
|
void enableMessagePolling();
|
|
bool disableMessagePolling();
|
|
std::vector<std::shared_ptr<Message>> getMessages();
|
|
bool getMessages(std::vector<std::shared_ptr<Message>>& container, size_t limit = 0);
|
|
size_t getCurrentMessageCount() { return pollingContainer.size_approx(); }
|
|
size_t getPollingMessageLimit() { return pollingMessageLimit; }
|
|
void setPollingMessageLimit(size_t newSize) {
|
|
pollingMessageLimit = newSize;
|
|
enforcePollingMessageLimit();
|
|
}
|
|
|
|
int addMessageCallback(const MessageCallback& cb) { return com->addMessageCallback(cb); }
|
|
bool removeMessageCallback(int id) { return com->removeMessageCallback(id); }
|
|
|
|
bool transmit(std::shared_ptr<Message> message);
|
|
bool transmit(std::vector<std::shared_ptr<Message>> messages);
|
|
|
|
void handleInternalMessage(std::shared_ptr<Message> message);
|
|
|
|
std::unique_ptr<IDeviceSettings> settings;
|
|
|
|
protected:
|
|
uint16_t productId = 0;
|
|
bool online = false;
|
|
int messagePollingCallbackID = 0;
|
|
int internalHandlerCallbackID = 0;
|
|
std::shared_ptr<Communication> com;
|
|
|
|
neodevice_t& getWritableNeoDevice() { return data; }
|
|
|
|
private:
|
|
neodevice_t data;
|
|
std::shared_ptr<ResetStatusMessage> latestResetStatus;
|
|
|
|
enum class LEDState : uint8_t {
|
|
Offline = 0x04,
|
|
CoreMiniRunning = 0x08, // This should override "offline" if the CoreMini is running
|
|
Online = 0x10
|
|
};
|
|
LEDState ledState;
|
|
void updateLEDState();
|
|
|
|
size_t pollingMessageLimit = 20000;
|
|
moodycamel::ConcurrentQueue<std::shared_ptr<Message>> pollingContainer;
|
|
void enforcePollingMessageLimit();
|
|
};
|
|
|
|
}
|
|
|
|
#endif |