--- nono/vm/mpscc.cpp 2026/04/29 17:05:17 1.1.1.3 +++ nono/vm/mpscc.cpp 2026/04/29 17:05:46 1.1.1.10 @@ -22,6 +22,7 @@ #include "bitops.h" #include "hostcom.h" #include "interrupt.h" +#include "monitor.h" #include "scheduler.h" #include "syncer.h" #include @@ -65,18 +66,6 @@ MPSCCDevice::MPSCCDevice() for (int ch = 0; ch < mpscc.chan.size(); ch++) { auto& chan = mpscc.chan[ch]; chan.Init(ch); - - // time は SetTxPeriod() でセット。 - // 名前は継承先でセットする。機種ごとに名前を使い分けているため。 - txevent[ch].dev = this; - txevent[ch].func = ToEventCallback(&MPSCCDevice::TxCallback); - txevent[ch].code = ch; - txevent[ch].Regist(); - - rxevent[ch].dev = this; - rxevent[ch].func = ToEventCallback(&MPSCCDevice::RxCallback); - rxevent[ch].code = ch; - rxevent[ch].Regist(); } // モニタは継承先で設定する @@ -86,22 +75,23 @@ MPSCCDevice::MPSCCDevice() MPSCCDevice::~MPSCCDevice() { if ((bool)hostcom) { - hostcom->SetCallbackDevice(NULL); + hostcom->ResetRxCallback(); } } bool MPSCCDevice::Create() { - // 対応するホストドライバを作成 + // 対応するホストドライバを作成。 + // ポート名は継承先ごとに Init() で設定している。 try { - hostcom.reset(new HostCOMDevice("HostCOM")); - } catch (...) { + hostcom.reset(new HostCOMDevice(this, 0, "")); + } catch (...) { } + if ((bool)hostcom == false) { + warnx("Failed to initialize HostCOMDevice at %s", __method__); return false; } - - hostcom->SetRxCallback(ToDeviceCallback(&MPSCCDevice::HostRxCallback)); - hostcom->SetCallbackDevice(this); + hostcom->SetRxCallback(ToDeviceCallback(&MPSCCDevice::HostRxCallback), 0); return true; } @@ -111,22 +101,34 @@ MPSCCDevice::SetLogLevel(int loglevel_) { inherited::SetLogLevel(loglevel_); - assert((bool)hostcom); - hostcom->SetLogLevel(loglevel_); + if ((bool)hostcom) { + hostcom->SetLogLevel(loglevel_); + } } // 初期化 bool MPSCCDevice::Init() { - if (inherited::Init() == false) { - return false; - } - interrupt = GetInterruptDevice(); - scheduler->ConnectMessage(MessageID::HOSTCOM_RX, this, - ToMessageCallback(&MPSCCDevice::RxMessageCallback)); + scheduler->ConnectMessage(MessageID::HOSTCOM0_RX, this, + ToMessageCallback(&MPSCCDevice::RxMessage)); + + for (int ch = 0; ch < mpscc.chan.size(); ch++) { + // time は SetTxPeriod() でセット。 + // 名前は継承先でセットする。機種ごとに名前を使い分けているため。 + txevent[ch].dev = this; + txevent[ch].func = ToEventCallback(&MPSCCDevice::TxCallback); + txevent[ch].code = ch; + scheduler->RegistEvent(txevent[ch]); + + rxevent[ch].dev = this; + rxevent[ch].func = ToEventCallback(&MPSCCDevice::RxCallback); + rxevent[ch].code = ch; + scheduler->RegistEvent(rxevent[ch]); + } + return true; } @@ -152,6 +154,12 @@ MPSCCDevice::ResetChannelCommon(MPSCCCha ChangeInterrupt(); } +bool +MPSCCDevice::PokePort(uint32 offset, uint32 data) +{ + return false; +} + // CR0/WR0 レジスタの内容を取得 // (値の取り出しだけなら共通) /*static*/ uint8 @@ -209,7 +217,7 @@ MPSCCDevice::GetCR3(const MPSCCChan& cha data |= MPSCC::RXBITS_8; break; default: - VMPANIC("corrupted chan.rxbits=%d", chan.rxbits); + VMPANIC("corrupted chan.rxbits=%u", chan.rxbits); } if (chan.auto_enable) { data |= MPSCC::CR3_AUTO_EN; @@ -267,7 +275,7 @@ MPSCCDevice::GetCR4(const MPSCCChan& cha data |= MPSCC::CLKRATE_64; break; default: - VMPANIC("corrupted chan.clkrate=%d", chan.clkrate); + VMPANIC("corrupted chan.clkrate=%u", chan.clkrate); } data |= chan.syncmode; data |= chan.stopbits << 2; @@ -329,7 +337,7 @@ MPSCCDevice::GetCR5(const MPSCCChan& cha data |= MPSCC::TXBITS_8; break; default: - VMPANIC("corrupted chan.txbits=%d", chan.txbits); + VMPANIC("corrupted chan.txbits=%u", chan.txbits); } if (chan.nDTR) { data |= MPSCC::CR5_nDTR; @@ -398,10 +406,10 @@ MPSCCDevice::GetSR2B() const stat = 3; // VIS_321 とはビット順が逆 data &= ~0x70; - data |= bitrev(stat << 1); + data |= bitrev8(stat << 1); break; default: - VMPANIC("corrupted mpscc.vis=%d", (int)mpscc.vis); + VMPANIC("corrupted mpscc.vis=%u", (uint)mpscc.vis); } return data; @@ -520,7 +528,7 @@ MPSCCDevice::WriteCR4(MPSCCChan& chan, u putlog(2, "Channel %c Synchronous mode not supported", chan.name); } else { const char *sm[] = { "?", "1", "1.5", "2" }; - putlog(2, "Channel %c Async Mode (x%d clock, stopbit %s)", + putlog(2, "Channel %c Async Mode (x%u clock, stopbit %s)", chan.name, chan.clkrate, sm[chan.stopbits]); @@ -656,9 +664,9 @@ MPSCCDevice::TrySend(MPSCCChan& chan) // 送信のイベントコールバック void -MPSCCDevice::TxCallback(Event& event) +MPSCCDevice::TxCallback(Event& ev) { - int ch = event.code; + int ch = ev.code; MPSCCChan& chan = mpscc.chan[ch]; // 接続デバイスの呼び出し @@ -671,7 +679,7 @@ MPSCCDevice::TxCallback(Event& event) // ホストスレッドからの受信通知 // (HostCOM スレッドで呼ばれる) void -MPSCCDevice::HostRxCallback() +MPSCCDevice::HostRxCallback(uint32 dummy) { // XXX 暫定 // HostCom からメッセージが大量に送られると、スケジューラの @@ -685,7 +693,7 @@ MPSCCDevice::HostRxCallback() if (ev.IsRunning() == false) { // スレッドを超えるためにメッセージを投げる - scheduler->SendMessage(MessageID::HOSTCOM_RX); + scheduler->SendMessage(MessageID::HOSTCOM0_RX); } } @@ -721,7 +729,7 @@ MPSCCDevice::Rx(int ch, uint32 data) // ホストシリアルからの1バイト受信メッセージ void -MPSCCDevice::RxMessageCallback(MessageID msgid, uint32 arg) +MPSCCDevice::RxMessage(MessageID msgid, uint32 arg) { Event& ev = rxevent[COM_CH]; @@ -825,7 +833,7 @@ MPSCCDevice::GetStopBits(MPSCCChan& chan void MPSCCDevice::SetRxPeriod(MPSCCChan& chan) { - int bit; + uint bit; // 受信データビット数 bit = chan.rxbits; @@ -856,7 +864,7 @@ MPSCCDevice::SetRxPeriod(MPSCCChan& chan if (loglevel >= 2) { nsstr = string_format(" (%" PRIu64 ")", chan.bit12_ns); } - putlogn("Channel %c RX Enable, %.1f bps%s, %d bits/frame", + putlogn("Channel %c RX Enable, %.1f bps%s, %u bits/frame", chan.name, chan.baudrate, nsstr.c_str(), @@ -890,7 +898,7 @@ MPSCCDevice::SetRxPeriod(MPSCCChan& chan void MPSCCDevice::SetTxPeriod(MPSCCChan& chan) { - int bit; + uint bit; // 送信データビット数 bit = chan.txbits; @@ -921,7 +929,7 @@ MPSCCDevice::SetTxPeriod(MPSCCChan& chan if (loglevel >= 2) { nsstr = string_format(" (%" PRIu64 ")", chan.bit12_ns); } - putlogn("Channel %c TX Enable, %.1f bps%s, %d bits/frame", + putlogn("Channel %c TX Enable, %.1f bps%s, %u bits/frame", chan.name, chan.baudrate, nsstr.c_str(), @@ -942,15 +950,20 @@ MPSCCDevice::SetTxPeriod(MPSCCChan& chan // All/First RxChar ----|& |OR |&--+ // |OR---------|& | // o Special Rx Condition -----|OR +---|OR -// |OR --- -// o External/Status ------------------------------|OR-->o-- INT // |OR -// o Tx Buffer Empty ----------|& +---|OR -// |&-----|& | -// Tx INT/DMA Enable --------|& |& | -// (CR1 b1) |&-------+ -// |& -// INT/DMA Mode (CR2A b1,0) --------|& (注2) +// o External/Status ------------------------------|OR----|& ___ +// |OR |&-->o-- INT +// o Tx Buffer Empty ----------|& +---|OR +-|& +// |&-----|& | | +// Tx INT/DMA Enable --------|& |& | | +// (CR1 b1) |&-------+ | +// |& | +// INT/DMA Mode (CR2A b1,0) --------|& (注2) | +// | +// Master Interrupt Enable ---------------------------+ (注3) +// (Z8530 Only, WR9) +// +// 左端の o 印は割り込み要因(チャンネルあたり4種類)。他は制御フラグ。 // // 注1: uPD7201/7201A Figure 3-2 では "Rx Disable (CR1:D1)" だがそこは // Tx INT/DMA Enable ビットなので名称もビット位置も誤り。 @@ -959,6 +972,8 @@ MPSCCDevice::SetTxPeriod(MPSCCChan& chan // // 注2: uPD7201 のみ。Z8530 ではこの選択肢はないので常に true のはず。 // +// 注3: Z8530 のみ。uPD7201 ではこの選択肢はないので常に true にしてある。 +// void MPSCCDevice::ChangeInterrupt() { @@ -1014,6 +1029,11 @@ MPSCCDevice::ChangeInterrupt() total_intpend |= chan.intpend; } + // Z8530 の MIE。uPD7201 では true 固定にしてある。 + if (mpscc.master_int_enable == false) { + total_intpend = 0; + } + // いずれかでもあれば割り込みをアサート interrupt->ChangeINT(this, total_intpend); }