mirror of
https://github.com/MaSzyna-EU07/maszyna.git
synced 2026-10-17 20:19:20 +02:00
b8f040e6fd
AnimModel.cpp reaches cParser through the simulation core, not a direct import, so the previous pass missed it; the propagation now follows the whole import closure. Train.cpp, drivermode.cpp and Globals.cpp call Console:: inside _WIN32 guards without importing eu07.console - invisible on Linux, where those blocks are skipped.
101 lines
2.3 KiB
C++
101 lines
2.3 KiB
C++
module;
|
|
#include <array>
|
|
#include <cstddef>
|
|
#include <limits>
|
|
#include <mutex>
|
|
#include <ostream>
|
|
#include <sstream>
|
|
#include <type_traits>
|
|
#include <utility>
|
|
#include <deque>
|
|
#include <cstdint>
|
|
#include <zmq_addon.hpp>
|
|
#include <chrono>
|
|
#include <map>
|
|
#include <optional>
|
|
#include <string>
|
|
#include <tuple>
|
|
#include <unordered_map>
|
|
#include <vector>
|
|
|
|
export module eu07.input.zmq_input;
|
|
import eu07.input.command;
|
|
|
|
export {
|
|
|
|
|
|
class zmq_input
|
|
{
|
|
enum class output_fields {
|
|
shp,
|
|
alerter,
|
|
radio_stop,
|
|
motor_resistors,
|
|
line_breaker,
|
|
motor_overload,
|
|
motor_connectors,
|
|
wheelslip,
|
|
converter_overload,
|
|
converter_off,
|
|
compressor_overload,
|
|
ventilator_overload,
|
|
motor_overload_threshold,
|
|
train_heating,
|
|
cab,
|
|
recorder_braking,
|
|
recorder_power,
|
|
alerter_sound,
|
|
coupled_hv_voltage_relays,
|
|
velocity,
|
|
reservoir_pressure,
|
|
pipe_pressure,
|
|
brake_pressure,
|
|
hv_voltage,
|
|
hv_current_1,
|
|
hv_current_2,
|
|
hv_current_3,
|
|
lv_voltage,
|
|
distance,
|
|
radio_channel,
|
|
springbrake_active,
|
|
time_month_of_era,
|
|
time_minute_of_month,
|
|
time_millisecond_of_day
|
|
};
|
|
|
|
zmq::context_t ctx;
|
|
std::optional<zmq::socket_t> sock;
|
|
|
|
enum class input_type
|
|
{
|
|
none,
|
|
toggle, // two commands, each mapped to one state; press event on state change
|
|
impulse, // one command; press event when set, release when cleared
|
|
value // one command; press event, value of specified byte passed as param1
|
|
};
|
|
|
|
struct peer_state {
|
|
float update_interval;
|
|
std::vector<output_fields> sopi_list;
|
|
std::vector<std::tuple<input_type, user_command, user_command, bool>> sipo_list;;
|
|
std::chrono::time_point<std::chrono::high_resolution_clock> last_update;
|
|
};
|
|
|
|
std::map<uint32_t, peer_state> peers;
|
|
|
|
float unpack_float(const zmq::message_t &);
|
|
zmq::message_t pack_float(float f);
|
|
zmq::message_t pack_field(output_fields f);
|
|
|
|
std::unordered_map<std::string, user_command> nametocommandmap;
|
|
|
|
static std::unordered_map<std::string, output_fields> output_fields_map;
|
|
command_relay relay;
|
|
|
|
public:
|
|
zmq_input();
|
|
void poll();
|
|
};
|
|
|
|
} // export
|