146 lines
2.7 KiB
C++
146 lines
2.7 KiB
C++
// (C) 2018-2023 by Folkert van Heusden
|
|
// // Released under Apache License v2.0
|
|
#include <errno.h>
|
|
#include <string.h>
|
|
#include <unistd.h>
|
|
|
|
#include "tty.h"
|
|
#include "cpu.h"
|
|
#include "gen.h"
|
|
#include "log.h"
|
|
#include "memory.h"
|
|
#include "utils.h"
|
|
|
|
|
|
const char * const regnames[] = {
|
|
"reader status ",
|
|
"reader buffer ",
|
|
"puncher status",
|
|
"puncher buffer"
|
|
};
|
|
|
|
tty::tty(console *const c, bus *const b) :
|
|
c(c),
|
|
b(b)
|
|
{
|
|
th = new std::thread(std::ref(*this));
|
|
}
|
|
|
|
tty::~tty()
|
|
{
|
|
stop_flag = true;
|
|
|
|
th->join();
|
|
delete th;
|
|
}
|
|
|
|
uint8_t tty::readByte(const uint16_t addr)
|
|
{
|
|
uint16_t v = readWord(addr & ~1);
|
|
|
|
if (addr & 1)
|
|
return v >> 8;
|
|
|
|
return v;
|
|
}
|
|
|
|
uint16_t tty::readWord(const uint16_t addr)
|
|
{
|
|
const int reg = (addr - PDP11TTY_BASE) / 2;
|
|
uint16_t vtemp = registers[reg];
|
|
|
|
if (addr == PDP11TTY_TKS) {
|
|
std::unique_lock<std::mutex> lck(chars_lock);
|
|
|
|
bool have_char = chars.empty() == false;
|
|
|
|
vtemp &= ~128;
|
|
vtemp |= have_char ? 128 : 0;
|
|
}
|
|
else if (addr == PDP11TTY_TKB) {
|
|
std::unique_lock<std::mutex> lck(chars_lock);
|
|
|
|
if (chars.empty())
|
|
vtemp = 0;
|
|
else {
|
|
uint8_t ch = chars.front();
|
|
chars.erase(chars.begin());
|
|
|
|
vtemp = ch | (parity(ch) << 7);
|
|
|
|
if (chars.empty() == false) {
|
|
registers[(PDP11TTY_TKS - PDP11TTY_BASE) / 2] |= 128;
|
|
|
|
if (registers[(PDP11TTY_TKS - PDP11TTY_BASE) / 2] & 64)
|
|
b->getCpu()->queue_interrupt(4, 060);
|
|
}
|
|
}
|
|
}
|
|
else if (addr == PDP11TTY_TPS) {
|
|
vtemp |= 128;
|
|
}
|
|
|
|
DOLOG(debug, true, "PDP11TTY read addr %o (%s): %d, 7bit: %d", addr, regnames[reg], vtemp, vtemp & 127);
|
|
|
|
registers[reg] = vtemp;
|
|
|
|
return vtemp;
|
|
}
|
|
|
|
void tty::operator()()
|
|
{
|
|
while(!stop_flag) {
|
|
if (c->poll_char()) {
|
|
std::unique_lock<std::mutex> lck(chars_lock);
|
|
|
|
chars.push_back(c->get_char());
|
|
|
|
registers[(PDP11TTY_TKS - PDP11TTY_BASE) / 2] |= 128;
|
|
|
|
if (registers[(PDP11TTY_TKS - PDP11TTY_BASE) / 2] & 64)
|
|
b->getCpu()->queue_interrupt(4, 060);
|
|
}
|
|
else {
|
|
myusleep(100000);
|
|
}
|
|
}
|
|
}
|
|
|
|
void tty::writeByte(const uint16_t addr, const uint8_t v)
|
|
{
|
|
uint16_t vtemp = registers[(addr - PDP11TTY_BASE) / 2];
|
|
|
|
if (addr & 1) {
|
|
vtemp &= ~0xff00;
|
|
vtemp |= v << 8;
|
|
}
|
|
else {
|
|
vtemp &= ~0x00ff;
|
|
vtemp |= v;
|
|
}
|
|
|
|
writeWord(addr, vtemp);
|
|
}
|
|
|
|
void tty::writeWord(const uint16_t addr, uint16_t v)
|
|
{
|
|
const int reg = (addr - PDP11TTY_BASE) / 2;
|
|
|
|
DOLOG(debug, true, "PDP11TTY write %o (%s): %o", addr, regnames[reg], v);
|
|
|
|
if (addr == PDP11TTY_TPB) {
|
|
char ch = v & 127;
|
|
|
|
DOLOG(debug, true, "PDP11TTY print '%c'", ch);
|
|
|
|
c->put_char(ch);
|
|
|
|
registers[(PDP11TTY_TPS - PDP11TTY_BASE) / 2] |= 128;
|
|
|
|
if (registers[(PDP11TTY_TPS - PDP11TTY_BASE) / 2] & 64)
|
|
b->getCpu()->queue_interrupt(4, 064);
|
|
}
|
|
|
|
DOLOG(debug, true, "set register %o to %o", addr, v);
|
|
registers[(addr - PDP11TTY_BASE) / 2] = v;
|
|
}
|