--- nono/vm/mpscc.cpp	2026/04/29 17:05:33	1.1.1.7
+++ nono/vm/mpscc.cpp	2026/04/29 17:05:50	1.1.1.11
@@ -20,6 +20,7 @@
 #define MPSCC_SIO_LOG_HACK
 #include "mpscc.h"
 #include "bitops.h"
+#include "event.h"
 #include "hostcom.h"
 #include "interrupt.h"
 #include "monitor.h"
@@ -75,19 +76,23 @@ MPSCCDevice::MPSCCDevice()
 MPSCCDevice::~MPSCCDevice()
 {
 	if ((bool)hostcom) {
-		hostcom->SetRxCallback(NULL);
+		hostcom->ResetRxCallback();
 	}
 }
 
 bool
 MPSCCDevice::Create()
 {
-	// 対応するホストドライバを作成
-	hostcom.reset(new HostCOMDevice(this, "HostCOM"));
+	// 対応するホストドライバを作成。
+	// ポート名は継承先ごとに Init() で設定している。
+	try {
+		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->SetRxCallback(ToDeviceCallback(&MPSCCDevice::HostRxCallback), 0);
 
 	return true;
 }
@@ -97,35 +102,28 @@ 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,
+	scheduler->ConnectMessage(MessageID::HOSTCOM0_RX, this,
 		ToMessageCallback(&MPSCCDevice::RxMessage));
 
+	auto evman = GetEventManager();
 	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]);
+		txevent[ch] = evman->Regist(this, ch,
+			ToEventCallback(&MPSCCDevice::TxCallback));
+
+		rxevent[ch] = evman->Regist(this, ch,
+			ToEventCallback(&MPSCCDevice::RxCallback));
 	}
 
 	return true;
@@ -405,7 +403,7 @@ MPSCCDevice::GetSR2B() const
 			stat = 3;
 		// VIS_321 とはビット順が逆
 		data &= ~0x70;
-		data |= bitrev(stat << 1);
+		data |= bitrev8(stat << 1);
 		break;
 	 default:
 		VMPANIC("corrupted mpscc.vis=%u", (uint)mpscc.vis);
@@ -647,7 +645,7 @@ void
 MPSCCDevice::TrySend(MPSCCChan& chan)
 {
 	// 送信可で送信バッファにデータがあって送信中でなければ
-	if (chan.tx_enable && chan.txlen && !txevent[chan.id].IsRunning()) {
+	if (chan.tx_enable && chan.txlen && !txevent[chan.id]->IsRunning()) {
 		// 送信する
 		chan.tx_shiftreg = chan.txbuf;
 		chan.txlen = 0;
@@ -663,9 +661,9 @@ MPSCCDevice::TrySend(MPSCCChan& chan)
 
 // 送信のイベントコールバック
 void
-MPSCCDevice::TxCallback(Event& ev)
+MPSCCDevice::TxCallback(Event *ev)
 {
-	int ch = ev.code;
+	int ch = ev->code;
 	MPSCCChan& chan = mpscc.chan[ch];
 
 	// 接続デバイスの呼び出し
@@ -678,7 +676,7 @@ MPSCCDevice::TxCallback(Event& ev)
 // ホストスレッドからの受信通知
 // (HostCOM スレッドで呼ばれる)
 void
-MPSCCDevice::HostRxCallback()
+MPSCCDevice::HostRxCallback(uint32 dummy)
 {
 	// XXX 暫定
 	// HostCom からメッセージが大量に送られると、スケジューラの
@@ -688,11 +686,39 @@ MPSCCDevice::HostRxCallback()
 	// またはスケジューラにメッセージではないなにか別の方法で
 	// 通知を出すようにする必要がある。
 
-	Event& ev = rxevent[COM_CH];
+	const Event *ev = rxevent[COM_CH];
 
-	if (ev.IsRunning() == false) {
+	if (ev->IsRunning() == false) {
 		// スレッドを超えるためにメッセージを投げる
-		scheduler->SendMessage(MessageID::HOSTCOM_RX);
+		scheduler->SendMessage(MessageID::HOSTCOM0_RX);
+	}
+}
+
+// ホストシリアルからの1バイト受信メッセージ
+void
+MPSCCDevice::RxMessage(MessageID msgid, uint32 arg)
+{
+	Event *ev = rxevent[COM_CH];
+
+	// 受信ループが止まっていれば開始
+	if (ev->IsRunning() == false) {
+		scheduler->StartEvent(ev);
+	}
+}
+
+// 受信イベントコールバック
+void
+MPSCCDevice::RxCallback(Event *ev)
+{
+	int ch = ev->code;
+	int data;
+
+	// ホストキューにあるだけ取り出す
+	data = hostcom->Rx();
+	if (data >= 0) {
+		Rx(ch, data);
+
+		scheduler->StartEvent(ev);
 	}
 }
 
@@ -726,34 +752,6 @@ MPSCCDevice::Rx(int ch, uint32 data)
 	return true;
 }
 
-// ホストシリアルからの1バイト受信メッセージ
-void
-MPSCCDevice::RxMessage(MessageID msgid, uint32 arg)
-{
-	Event& ev = rxevent[COM_CH];
-
-	// 受信ループが止まっていれば開始
-	if (ev.IsRunning() == false) {
-		scheduler->StartEvent(ev);
-	}
-}
-
-// 受信イベントコールバック
-void
-MPSCCDevice::RxCallback(Event& ev)
-{
-	int ch = ev.code;
-	int data;
-
-	// ホストキューにあるだけ取り出す
-	data = hostcom->Rx();
-	if (data >= 0) {
-		Rx(ch, data);
-
-		scheduler->StartEvent(ev);
-	}
-}
-
 static double
 to_freq(uint64 nsec)
 {
@@ -840,7 +838,7 @@ MPSCCDevice::SetRxPeriod(MPSCCChan& chan
 	bit += AdditionalBits(chan, chan.rx_enable);
 	chan.rxframebits = bit;
 
-	rxevent[chan.id].time = bit * chan.bit12_ns / 12;
+	rxevent[chan.id]->time = bit * chan.bit12_ns / 12;
 
 	if (loglevel >= 1) {
 		bool old_enable = chan.old_cr3 & MPSCC::CR3_RX_EN;
@@ -905,7 +903,7 @@ MPSCCDevice::SetTxPeriod(MPSCCChan& chan
 	bit += AdditionalBits(chan, chan.tx_enable);
 	chan.txframebits = bit;
 
-	txevent[chan.id].time = bit * chan.bit12_ns / 12;
+	txevent[chan.id]->time = bit * chan.bit12_ns / 12;
 
 	if (loglevel >= 1) {
 		bool old_enable = chan.old_cr5 & MPSCC::CR5_TX_EN;
@@ -1086,7 +1084,7 @@ MPSCCDevice::GetParamStr(const MPSCCChan
 	// 75 * 2 ^ (e-1) を求める
 	double a = (chan.baudrate / 75) * 1.5;
 	std::frexp(a, &e);
-	int b = 75 * (1 << (e - 1));
+	int b = 75 * (1U << (e - 1));
 
 	if (b * 19 / 20 <= chan.baudrate && chan.baudrate <= b * 21 / 20) {
 		baud = b;
@@ -1178,7 +1176,7 @@ MPSCCDevice::MonitorReg(TextScreen& scre
 		if (names[i][0] == '-') {
 			screen.Puts(x + i * 5, y, TA::Disable, "----");
 		} else {
-			bool b = reg & (1 << (7 - i));
+			bool b = reg & (1U << (7 - i));
 			screen.Puts(x + i * 5, y, TA::OnOff(b), names[i]);
 		}
 	}