--- nono/vm/ethernet.cpp	2026/04/29 17:04:35	1.1.1.3
+++ nono/vm/ethernet.cpp	2026/04/29 17:04:55	1.1.1.5
@@ -6,15 +6,14 @@
 
 #include "ethernet.h"
 #include "config.h"
-#include "netdriver_bpf.h"
-#include "netdriver_tap.h"
-#include "netdriver_none.h"
+#include "netdriver_selector.h"
 #include <random>
 
 std::unique_ptr<EthernetDevice> gEthernet;
 
 // コンストラクタ
-EthernetDevice::EthernetDevice()
+EthernetDevice::EthernetDevice(const std::string& objname_)
+	: inherited(objname_)
 {
 }
 
@@ -27,53 +26,13 @@ EthernetDevice::~EthernetDevice()
 bool
 EthernetDevice::Create()
 {
-	const ConfigItem& item = gConfig->Find("ethernet-hostdriver");
-	const std::string& type = item.AsString();
-	if (type == "none") {
-		gNetDriver.reset(new NetDriverNone());
-	} else if (type == "tap") {
-#if defined(NETDRIVER_TAP)
-		try {
-			gNetDriver.reset(new NetDriverTap(this, &mtx, &cv));
-		} catch (...) {
-			warnx("Creating NetDriverTap failed");
-			return false;
-		}
-#else
-		item.Err("tap not supported");
-		return false;
-#endif
-	} else if (type == "bpf") {
-#if defined(NETDRIVER_BPF)
-		try {
-			gNetDriver.reset(new NetDriverBPF(this, &mtx, &cv));
-		} catch (...) {
-			warnx("Creating NetDriverBPF failed");
-			return false;
-		}
-#else
-		item.Err("bpf not supported");
-		return false;
-#endif
-	} else {
-		item.Err();
-		return false;
+	try {
+		// ホストドライバをこのデバイスと紐付ける。
+		gNetDriverSelector.reset(new NetDriverSelector(this));
+		return true;
+	} catch (...) {
 	}
-	assert((bool)gNetDriver);
-
-	return true;
-}
-
-// 初期化
-bool
-EthernetDevice::Init()
-{
-	if (gNetDriver->Init() == false) {
-		gNetDriver.reset();
-		return false;
-	}
-
-	return true;
+	return false;
 }
 
 // MAC アドレスをてきとーに生成する。
@@ -135,5 +94,52 @@ EthernetDevice::ParseMacAddr(macaddr_t&
 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;
+}