--- nono/vm/ethernet.cpp	2026/04/29 17:04:55	1.1.1.5
+++ nono/vm/ethernet.cpp	2026/04/29 17:05:21	1.1.1.8
@@ -4,142 +4,95 @@
 // Licensed under nono-license.txt
 //
 
+//
+// Ethernet 基本クラス
+//
+
 #include "ethernet.h"
 #include "config.h"
-#include "netdriver_selector.h"
-#include <random>
-
-std::unique_ptr<EthernetDevice> gEthernet;
+#include "hostnet.h"
+#include "scheduler.h"
 
 // コンストラクタ
-EthernetDevice::EthernetDevice(const std::string& objname_)
-	: inherited(objname_)
+EthernetDevice::EthernetDevice(int objid_)
+	: inherited(objid_)
 {
 }
 
 // デストラクタ
 EthernetDevice::~EthernetDevice()
 {
+	if ((bool)hostnet) {
+		hostnet->SetRxCallback(NULL);
+	}
 }
 
 // 動的なコンストラクション
 bool
 EthernetDevice::Create()
 {
-	try {
-		// ホストドライバをこのデバイスと紐付ける。
-		gNetDriverSelector.reset(new NetDriverSelector(this));
-		return true;
-	} catch (...) {
-	}
-	return false;
-}
+	// ホストドライバを作成してこのデバイスと紐付ける
+	int n = GetId() - OBJ_ETHERNET0;
+	hostnet.reset(new HostNetDevice(this, n));
 
-// MAC アドレスをてきとーに生成する。
-// 02:00:01 はローカルだし割り当てもされてなさそうなので使っちゃえ。
-// 下3バイトは乱数。
-/*static*/ void
-EthernetDevice::GenerateMacAddr(macaddr_t *addrp)
-{
-	std::random_device rnd;
-	uint32 x = rnd();
+	hostnet->SetRxCallback(ToDeviceCallback(&EthernetDevice::HostRxCallback));
+
+	return true;
+}
 
-	macaddr_t& addr = *addrp;
-	addr[0] = 0x02;
-	addr[1] = 0x00;
-	addr[2] = 0x01;
-	addr[3] = (x >> 16) & 0xff;
-	addr[4] = (x >>  8) & 0xff;
-	addr[5] = x & 0xff;
+// これは Host スレッドから呼ばれる
+void
+EthernetDevice::HostRxCallback()
+{
+	// スレッドを超えるためにメッセージを投げる
+	int n = GetId() - OBJ_ETHERNET0;
+	scheduler->SendMessage(MessageID::HOSTNET_RX(n));
 }
 
-// MAC アドレス文字列をバイナリに変換して返す。
-// "HH:HH:HH:HH:HH:HH" 形式のみ。
-// 成功すれば true を返す。
+// 設定ファイルから MAC アドレスを読み込む。
+// MAC アドレスを保持するデバイスが呼び出すこと。MAC アドレスを保持する
+// デバイスがイーサネットデバイスとは限らず、例えば LANCE を採用している
+// 機種ではたいてい ROM か誰かが MAC アドレスを持っている。
+//
+// 引数 accept_rom が true なら、設定 ethernet-macaddr=rom を許可する。
+// これは (お手持ちの実機) ROM イメージが MAC アドレスを保持しているため、
+// 指定(や生成)不要なケースで指定できる (prom.cpp 参照)。
+// 引数 accept_rom が false で、設定値に "rom" が指定されるとエラーにする。
+//
+// "rom" が指定されて許可されている場合 mac は触らず true を返す。
+// MAC アドレスが指定されているか自動生成したかで取得できれば mac に格納して
+// true を返す。それ以外の場合は、エラーメッセージを表示して false を返す。
 /*static*/ bool
-EthernetDevice::ParseMacAddr(macaddr_t& dst, const std::string& src)
+EthernetDevice::GetConfigMacAddr(int n, macaddr_t *mac, bool accept_rom)
 {
-	const char *p;
-	char *e;
-
-	p = src.data();
-	for (int i = 0; ; ) {
-		unsigned long val = strtoul(p, &e, 16);
-
-		if (p == e) {
+	std::string keyname = string_format("ethernet%d-macaddr", n);
+	const ConfigItem& item = gConfig->Find(keyname);
+	const std::string& val = item.AsString();
+
+	if (val == "rom") {
+		// ROM に書いてあるのを使う。
+		if (accept_rom) {
+			return true;
+		} else {
+			item.Err("\"rom\" cannot be specified in this vmtype");
 			return false;
 		}
-		if (val > 0xff) {
-			return false;
-		}
-		dst[i++] = val;
-		p = e;
-
-		// 最後だけ ':' をチェックしないので
-		if (i == 6) {
-			break;
+	} else {
+		if (val == "auto") {
+			// 自動生成。
+			// 出来れば生成したのを覚えといて、次からそれを使いたい。
+			if (0) {
+			} else {
+				mac->Generate();
+			}
+		} else {
+			// ユーザ指定
+			if (mac->FromString(val) == false) {
+				item.Err("Invalid MAC address");
+				return false;
+			}
 		}
-
-		if (*p++ != ':') {
-			return false;
-		}
-	}
-	if (*p != '\0') {
-		return false;
 	}
-	return true;
-}
-
-// パケットを送信する (VM から呼ばれる)
-bool
-EthernetDevice::SendPacket(const std::vector<uint8>& buf)
-{
-	tx_pkts++;
-	return gNetDriver->SendPacket(buf);
-}
-
-// パケット受信。
-// NetDriver スレッドから呼ばれる。
-// ロックは中で取るので、ロック解除状態で呼ぶこと。
-// XXX: 戻り値はなんだろう
-bool
-EthernetDevice::RecvPacket(RXPacket packet)
-{
-	std::lock_guard<std::mutex> lock(mtx);
-
-	if (RecvEnabled == false) {
-		// 受信禁止状態
-		putlog(2, "%s: receive disabled", __func__);
-		return true;
-	}
-
-	// イーサネットフレームより長いパケットはゲスト OS が期待していない。
-	// ここでドロップしてみる。
-	// これによりゲストでの dropping chained buffer が出なくなる。
-	// 1518(EthernetII) にするか 1522(802.1Q) にするかは未定。
-	if (packet->size() > 1518) {
-		// TODO: 統計とりたい
-		putlog(1, "%s: drop long packet(%zd)", __func__, packet->size());
-		return true;
-	}
-
-	// XXX とりあえず 16 パケットをキューする。
-	// 入り切らないときは捨てる。
-	if (rxq.size() > 16) {
-		// 前のパケットをまだ処理中なので、このパケットは捨てる
-		putlog(1, "%s: discard %zd bytes, pending %zd packets", __func__,
-			packet->size(), rxq.size());
-		return true;
-	}
-	putlog(1, "%s: enqueue %zd bytes, pending %zd packets", __func__,
-		packet->size(), rxq.size());
-
-	// キューへ投入
-	rxq.push(std::move(packet));
-	rx_pkts++;
-
-	// 継承クラスに通知
-	NotifyRecvPacket();
 
 	return true;
 }