43#include "model/comm_drv_n0183_android_int.h"
48#include "androidUTIL.h"
51typedef enum DS_ENUM_BUFFER_STATE {
54} _DS_ENUM_BUFFER_STATE;
56using namespace std::literals::chrono_literals;
60#define MAX_OUT_QUEUE_MESSAGE_LENGTH 100
66 std::lock_guard<std::mutex> lock(m_mutex);
67 return m_queque.size();
71 std::lock_guard<std::mutex> lock(m_mutex);
72 return m_queque.empty();
76 std::lock_guard<std::mutex> lock(m_mutex);
77 return m_queque.front();
80 void push(
const T& value) {
81 std::lock_guard<std::mutex> lock(m_mutex);
86 std::lock_guard<std::mutex> lock(m_mutex);
91 std::queue<T> m_queque;
92 mutable std::mutex m_mutex;
95#define OUT_QUEUE_LENGTH 20
96#define MAX_OUT_QUEUE_MESSAGE_LENGTH 100
98wxDEFINE_EVENT(wxEVT_COMMDRIVER_N0183_ANDROID_INT,
101CommDriverN0183AndroidIntEvent::CommDriverN0183AndroidIntEvent(
102 wxEventType commandType,
int id = 0)
103 : wxEvent(id, commandType) {};
105CommDriverN0183AndroidIntEvent::~CommDriverN0183AndroidIntEvent() {};
107void CommDriverN0183AndroidIntEvent::SetPayload(
108 std::shared_ptr<std::vector<unsigned char>> data) {
111std::shared_ptr<std::vector<unsigned char>>
112CommDriverN0183AndroidIntEvent::GetPayload() {
117wxEvent* CommDriverN0183AndroidIntEvent::Clone()
const {
120 newevent->m_payload = this->m_payload;
128 : buf_(std::unique_ptr<T[]>(new T[size])), max_size_(size) {}
131 size_t capacity()
const;
136 return (!full_ && (head_ == tail_));
145 std::lock_guard<std::mutex> lock(mutex_);
147 if (full_) tail_ = (tail_ + 1) % max_size_;
149 head_ = (head_ + 1) % max_size_;
151 full_ = head_ == tail_;
155 std::lock_guard<std::mutex> lock(mutex_);
157 if (empty())
return T();
160 auto val = buf_[tail_];
162 tail_ = (tail_ + 1) % max_size_;
169 std::unique_ptr<T[]> buf_;
172 const size_t max_size_;
176CommDriverN0183AndroidInt::CommDriverN0183AndroidInt(
180 m_portstring(params->GetDSPort()),
181 m_stats_timer(*this, 2s),
183 m_listener(listener) {
184 this->attributes[
"commPort"] = params->Port.ToStdString();
185 this->attributes[
"userComment"] = params->UserComment.ToStdString();
186 this->attributes[
"ioDirection"] = DsPortTypeToString(params->IOSelect);
187 m_driver_stats.driver_bus = NavAddr::Bus::N0183;
188 m_driver_stats.driver_iface = params->GetStrippedDSPort();
191 Bind(wxEVT_COMMDRIVER_N0183_ANDROID_INT,
192 &CommDriverN0183AndroidInt::handle_N0183_MSG,
this);
197CommDriverN0183AndroidInt::~CommDriverN0183AndroidInt() { Close(); }
199bool CommDriverN0183AndroidInt::Open() {
200 androidStartGPS(
this);
201 m_driver_stats.available =
true;
205void CommDriverN0183AndroidInt::Close() {
207 wxString::Format(_T(
"Closing NMEA Driver %s"), m_portstring.c_str()));
210 m_driver_stats.available =
false;
212 Unbind(wxEVT_COMMDRIVER_N0183_ANDROID_INT,
213 &CommDriverN0183AndroidInt::handle_N0183_MSG,
this);
216bool CommDriverN0183AndroidInt::SendMessage(
217 std::shared_ptr<const NavMsg> msg, std::shared_ptr<const NavAddr> addr) {
221void CommDriverN0183AndroidInt::handle_N0183_MSG(
223 auto p =
event.GetPayload();
224 std::vector<unsigned char>* payload = p.get();
226 m_driver_stats.
rx_count += payload->size();
229 std::string full_sentence = std::string(payload->begin(), payload->end());
231 if ((full_sentence[0] ==
'$') || (full_sentence[0] ==
'!')) {
232 std::string identifier;
234 identifier = full_sentence.substr(1, 5);
238 auto msg = std::make_shared<const Nmea0183Msg>(identifier, full_sentence,
240 auto msg_all = std::make_shared<const Nmea0183Msg>(*msg,
"ALL");
242 if (m_params.SentencePassesFilter(full_sentence, FILTER_INPUT))
243 m_listener.
Notify(std::move(msg));
245 m_listener.
Notify(std::move(msg_all));
NMEA0183 drivers common part.
Interface implemented by transport layer and possible other parties like test code which should handl...
virtual void Notify(std::shared_ptr< const NavMsg > message)=0
Handle a received message.
Where messages are sent to or received from.
Driver registration container, a singleton.
Raw messages layer, supports sending and recieving navmsg messages.
unsigned rx_count
Number of bytes received since program start.