/* * Copyright (C) 2014 Jared Boone, ShareBrained Technology, Inc. * * This file is part of PortaPack. * * 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, 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 General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; see the file COPYING. If not, write to * the Free Software Foundation, Inc., 51 Franklin Street, * Boston, MA 02110-1301, USA. */ #ifndef __EVENT_M4_H__ #define __EVENT_M4_H__ #include "event.hpp" #include "baseband_thread.hpp" #include "rssi_thread.hpp" #include "message.hpp" #include "ch.h" constexpr auto EVT_MASK_BASEBAND = EVENT_MASK(0); constexpr auto EVT_MASK_SPECTRUM = EVENT_MASK(1); class EventDispatcher { public: EventDispatcher(std::unique_ptr<BasebandProcessor> baseband_processor); void run(); void request_stop(); static inline void events_flag(const eventmask_t events) { chEvtSignal(thread_event_loop, events); } static inline void events_flag_isr(const eventmask_t events) { chEvtSignalI(thread_event_loop, events); } private: static Thread* thread_event_loop; std::unique_ptr<BasebandProcessor> baseband_processor; bool is_running = true; eventmask_t wait(); void dispatch(const eventmask_t events); void handle_baseband_queue(); void on_message(const Message* const message); void on_message_shutdown(const ShutdownMessage&); void on_message_default(const Message* const message); void handle_spectrum(); }; #endif/*__EVENT_M4_H__*/