KEK/dc11.h
folkert van heusden ac6c10f349
DC11: r/w
2024-04-30 09:52:23 +02:00

64 lines
1.5 KiB
C++

// (C) 2024 by Folkert van Heusden
// Released under MIT license
#pragma once
#include <atomic>
#include <condition_variable>
#include <cstdint>
#include <mutex>
#include <thread>
#include <vector>
#if defined(ESP32)
#include <lwip/sockets.h>
#else
#include <poll.h>
#endif
#include "gen.h"
#include "bus.h"
#include "log.h"
#define DC11_RCSR 0174000 // receiver status register
#define DC11_BASE DC11_RCSR
#define DC11_END (DC11_BASE + (4 * 4 + 1) * 2) // 4 interfaces, + 2 to point after it
class bus;
// 4 interfaces
constexpr const int dc11_n_lines = 4;
class dc11
{
private:
int base_port { 1100 };
bus *const b { nullptr };
uint16_t registers[4 * dc11_n_lines] { };
std::atomic_bool stop_flag { false };
std::thread *th { nullptr };
pollfd pfds[dc11_n_lines * 2] { };
std::vector<char> recv_buffers[dc11_n_lines];
std::condition_variable have_data[dc11_n_lines];
std::mutex input_lock[dc11_n_lines];
void trigger_interrupt(const int line_nr);
public:
dc11(const int base_port, bus *const b);
virtual ~dc11();
#if IS_POSIX
// json_t *serialize();
// static tty *deserialize(const json_t *const j, bus *const b, console *const cnsl);
#endif
void reset();
uint8_t read_byte(const uint16_t addr);
uint16_t read_word(const uint16_t addr);
void write_byte(const uint16_t addr, const uint8_t v);
void write_word(const uint16_t addr, uint16_t v);
void operator()();
};