![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to netdriver_slirp.cpp CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Isaki's NoNo m68k/m88k emulator] / nono / host|
Return to netdriver_slirp.cpp CVS log | Up to [Isaki's NoNo m68k/m88k emulator] / nono / host |
1.1 root 1: //
2: // nono
3: // Copyright (C) 2025 nono project
4: // Licensed under nono-license.txt
5: //
6:
7: //
8: // ホストネットワークの usermode (SLIRP) ドライバ
9: //
10:
11: //
12: // NetDriverSlirp SlirpThread
13: // (HostNet スレッド) : (裏スレッド)
14: //
15: // 送信時のフロー:
16: // NetDriverSlirp() は送信パケットをパイプ txfd (=txfd_w) に書き込む。
17: // SlirpThread 側で txfd_r に着信するので取り出して slirp_input() へ送る。
18: //
19: // NetDriverSlirp::Write() :
20: // |
21: // | txfd(=txfd_w) txfd_r
22: // +--------------->| pipe |------+ … パイプで裏スレッドに送信
23: // | |
24: // <-+ : v
25: // --- kevent @ ThreadRun()
26: // : |
27: // SlirpThread::Write()
28: // : |
29: // +-----> slirp_input()
30: //
31:
32: // 受信時のフロー:
33: // SlirpThread 側のイベントループにて、管理する受信ディスクリプタに
34: // 着信があれば SlirpThread::Read() がそれを読み出してパイプ rxfd_w に
35: // 書き込む。
36: // このパイプの対向は HostNetDevice に AddOuter() で登録したものなので
37: // この書き込みに対する着信で HostDevice::Dispatch() が動き、
38: // その結果 NetDriverSlirp() が呼ばれる。
39: // NetDriverSlirp() はこのパイプからパケットを読み出して親に引き渡す。
40: //
41: // --- kevent @ ThreadRun()
42: // |
43: // SlirpThread::Read()
44: // |
45: // rxfd(=rxfd_r) rxfd_w|
46: // +---------------| pipe |<-----+
47: // | 着信通知 ‖
48: // v ‖
49: // --- kqueue ‖
50: // | ‖
51: // HostNetDevice::Read() ‖
52: // | ‖
53: // NetDriverSlirp::Read() ‖
54: // | ‖
55: // パイプから受信 <==++
56: // |
57: // <--+ VM 側へ
58:
59: #include "netdriver_slirp.h"
60: #include "hostnet.h"
61: #include "scheduler.h"
62: #include <sys/socket.h>
63: #include <sys/uio.h>
64: #include <slirp/libslirp.h>
65:
66: //
67: // NetDriver 側スレッド
68: //
69:
70: // コンストラクタ
71: NetDriverSlirp::NetDriverSlirp(HostDevice *hostdev_)
72: : inherited(hostdev_, "Usermode")
73: {
74: txd = -1;
75: rxd = -1;
76: }
77:
78: // デストラクタ
79: NetDriverSlirp::~NetDriverSlirp()
80: {
81: Close();
82: }
83:
84: // ログレベルを設定。
85: void
86: NetDriverSlirp::SetLogLevel(int loglevel_)
87: {
88: inherited::SetLogLevel(loglevel_);
89:
90: // バックエンドにも伝達。
91: if ((bool)backend) {
92: backend->SetLogLevel(loglevel_);
93: }
94: }
95:
96: // ドライバ初期化
97: bool
98: NetDriverSlirp::InitDriver()
99: {
100: putmsg(1, "trying usermode...");
101:
102: if (slirp_occupied) {
103: putmsg(1, "Already configured on the other interface");
104: return false;
105: }
106:
1.1.1.2 ! root 107: try {
! 108: backend.reset(new SlirpThread(this));
! 109: } catch (...) { }
1.1 root 110: if ((bool)backend == false) {
1.1.1.2 ! root 111: warnx("Failed to initialize SlirpThread at %s", __method__);
1.1 root 112: return false;
113: }
114:
115: // ディスクリプタは裏スレッドが所有しているのでこちらでは解放しないこと。
116: const std::string key = hostdev->GetConfigKey();
117: if (backend->InitBackend(key, &rxd, &txd) == false) {
118: backend.reset();
119: return false;
120: }
121:
122: // 読み込み側を Slirp からの受信端として親に登録。
123: if (hostdev->AddOuter(rxd) < 0) {
124: putmsg(0, "AddOuter(rxd=%d): %s", rxd, strerror(errno));
125: return false;
126: }
127:
128: slirp_occupied = true;
129: putmsg(1, "opened");
130: return true;
131: }
132:
133: // クローズ
134: void
135: NetDriverSlirp::Close()
136: {
137: // rxd がすでに閉じられていたらとかはここでは関係なくて、
138: // この番号を kqueue から外す必要がある。(Linux)
139: hostdev->DelOuter(rxd);
140:
141: // txd, rxd は裏スレッドの所有なのでこちらでは何もしない。
142:
143: if ((bool)backend) {
144: backend->Terminate();
145: backend->Close();
146: }
147: slirp_occupied = false;
148: }
149:
150: // モニタ (ドライバ依存情報のみ)
151: void
152: NetDriverSlirp::MonitorUpdateMD(TextScreen& screen, int y)
153: {
154: // なし
155: }
156:
157: // パケットを送信する。
158: // と言っても裏スレッドに送り直すだけ。
159: void
160: NetDriverSlirp::Write(const void *buf, int buflen)
161: {
162: struct iovec iov[2];
163: ssize_t r;
164:
165: // 先頭4バイトに後続パケット長を入れておく。
166: static_assert(sizeof(buflen) == sizeof(uint32), "");
167: iov[0].iov_base = &buflen;
168: iov[0].iov_len = sizeof(buflen);
169: iov[1].iov_base = const_cast<void *>(buf);
170: iov[1].iov_len = buflen;
171: r = writev(txd, &iov[0], countof(iov));
172: if (r < 0) {
173: putmsg(0, "writev failed: %s", strerror(errno));
174: return;
175: }
176: }
177:
178: // パケットを受信する。
179: // これは rxd に着信があってから HostDevice::Dispatch() から呼ばれるほう。
180: int
181: NetDriverSlirp::Read(NetPacket *p)
182: {
183: ssize_t n;
184: uint32 len;
185:
186: // 先頭4バイトに後続パケット長を入れてある。
187: len = 0;
188: n = read(rxd, &len, sizeof(len));
189: if (n < 0) {
190: putmsg(0, "read(len) failed: %s", strerror(errno));
191: return NODATA;
192: }
193:
194: n = read(rxd, p->data(), len);
195: if (n < 0) {
196: putmsg(0, "read(buf) failed: %s", strerror(errno));
197: return NODATA;
198: }
199:
200: p->length = n;
201: return 0;
202: }
203:
204: // usermode を使えるのは同時に1人だけに限定する。
205: /*static*/ bool NetDriverSlirp::slirp_occupied = false;
206:
207:
208: //
209: // 裏スレッド
210: //
211:
212: // おそらく同じはずなので無駄な変換はしない。
213: #if SLIRP_POLL_IN == POLLIN && \
214: SLIRP_POLL_OUT == POLLOUT && \
215: SLIRP_POLL_PRI == POLLPRI && \
216: SLIRP_POLL_ERR == POLLERR && \
217: SLIRP_POLL_HUP == POLLHUP
218: #define POLL_EVENT_to_SLIRP_EVENT(x) (x)
219: #define SLIRP_EVENT_to_POLL_EVENT(x) (x)
220: #else
221: static int POLL_EVENT_to_SLIRP_EVENT(int pollevents)
222: {
223: int slevents = 0;
224: if ((pollevents & POLLIN)) slevents |= SLIRP_POLL_IN;
225: if ((pollevents & POLLOUT)) slevents |= SLIRP_POLL_OUT;
226: if ((pollevents & POLLPRI)) slevents |= SLIRP_POLL_PRI;
227: if ((pollevents & POLLERR)) slevents |= SLIRP_POLL_ERR;
228: if ((pollevents & POLLHUP)) slevents |= SLIRP_POLL_HUP;
229: return slevents;
230: }
231: static int SLIRP_EVENT_to_POLL_EVENT(int slevents)
232: {
233: int pollevents = 0;
234: if ((slevents & SLIRP_POLL_IN)) pollevents |= POLLIN;
235: if ((slevents & SLIRP_POLL_OUT)) pollevents |= POLLOUT;
236: if ((slevents & SLIRP_POLL_PRI)) pollevents |= POLLPRI;
237: if ((slevents & SLIRP_POLL_ERR)) pollevents |= POLLERR;
238: if ((slevents & SLIRP_POLL_HUP)) pollevents |= POLLHUP;
239: return pollevents;
240: }
241: #endif
242:
243: // タイマーは TimerNewCB() コールバックで確保して返す。
244: // 確保した領域そのものはライブラリが管理し、TimerFreeCB() コールバックで
245: // 解放する。
246: // 一方 timerlist は有効なタイマーのリストなので、期限が来たらこのリスト
247: // からは削除してよい。
248: class SlirpTimer
249: {
250: public:
251: SlirpTimer(SlirpTimerCb func_, void *arg_)
252: {
253: func = func_;
254: arg = arg_;
255: }
256:
257: SlirpTimerCb func {};
258: void *arg {};
259: int64 expire_msec {}; // 期限の(仮想?)絶対時刻 [msec]
260: int num {}; // デバッグ用のタイマー番号。
261: };
262:
263: static ssize_t send_packet_cb(const void *, size_t, void *);
264: static void guest_error_cb(const char *msg, void *);
265: static int64 clock_get_ns_cb(void *);
266: static void *timer_new_cb(SlirpTimerCb cb, void *cb_arg, void *);
267: static void timer_free_cb(void *timer, void *);
268: static void timer_mod_cb(void *timer, int64 expire_msec, void *);
269: static void register_poll_fd_cb(int fd, void *);
270: static void unregister_poll_fd_cb(int fd, void *);
271: static void notify_cb(void *);
272: static int add_poll_cb(int fd, int events, void *);
273: static int get_revents_cb(int idx, void *);
274:
275: static SlirpCb slirp_callbacks = {
276: .send_packet = send_packet_cb,
277: .guest_error = guest_error_cb,
278: .clock_get_ns = clock_get_ns_cb,
279: .timer_new = timer_new_cb,
280: .timer_free = timer_free_cb,
281: .timer_mod = timer_mod_cb,
282: .register_poll_fd = register_poll_fd_cb,
283: .unregister_poll_fd = unregister_poll_fd_cb,
284: .notify = notify_cb,
285: };
286:
287: // コンストラクタ
288: SlirpThread::SlirpThread(NetDriverSlirp *parent_)
289: : inherited(OBJ_NONE)
290: {
291: parent = parent_;
292: hostnet = dynamic_cast<HostNetDevice *>(parent->GetHostDev());
293: SetName(parent->GetName());
294:
295: // コンストラクト後ただちにログ出力できるようここで一度追従しておく。
296: // 以降は親 (NetDriver側) の SetLogLevel() で変更する。
297: loglevel = parent->loglevel;
298:
299: // オレオレパフォーマンス測定用アドレス (see vm/virtio_net.cpp)
300: inet_pton(AF_INET6, "fe80::db8:db8:9090", &perfaddr6);
301: }
302:
303: // デストラクタ
304: SlirpThread::~SlirpThread()
305: {
306: TerminateThread();
307: }
308:
309: // 初期化。
310: // Device::Init() とは違い、NetDriver::InitDriver() から呼ばれる独自版。
311: // (表スレッドから見た裏スレッドへの) 受信側(RX)と送信側(TX)の
312: // ディスクリプタを返す。
313: // これはスレッド起動前に (VM スレッドで) 呼ばれる。
314: bool
315: SlirpThread::InitBackend(const std::string& key, int *rxdp, int *txdp)
316: {
317: SlirpConfig config;
318: struct in_addr vnetwork;
319: struct in_addr vnetmask;
320: struct in6_addr vprefix_addr6;
321: uint vprefix_len;
322: int fds[2];
323:
324: // hostnetN-usermode-net=<network>/<netmask_or_len>
325: {
326: const ConfigItem& netitem = gConfig->Find(key + "-usermode-net");
327: std::string net = netitem.AsString();
328: const char *s = strchr(net.c_str(), '/');
329: if (s == NULL) {
330: netitem.Err();
331: return false;
332: }
333: const char *p = s + 1;
334: auto plen = strlen(p);
335: if (plen < 3) {
336: // strtoul() は先頭のスペースを無視して進むので
337: // 先頭がスペースでないことはチェックする必要がある。
338: if (*p < '0' || *p > '9') {
339: netitem.Err();
340: return false;
341: }
342: char *end;
343: errno = 0;
344: unsigned long netlen = strtoul(p, &end, 10);
345: if (*end != '\0' || errno != 0) {
346: netitem.Err("Invalid netmask len");
347: return false;
348: }
349: // DHCP 配布アドレスまで入れるには最小でも /28 (16-2個) が必要。
350: if (netlen < 1 || netlen > 28) {
351: netitem.Err("netmask len is out of range");
352: return false;
353: }
354: vnetmask.s_addr = htonl(((1U << netlen) - 1) << (32 - netlen));
355: } else {
356: int r = inet_pton(AF_INET, p, &vnetmask);
357: if (r < 1) {
358: netitem.Err("Invalid netmask");
359: return false;
360: }
361: }
362:
363: net.resize(s - net.c_str());
364: int r = inet_pton(AF_INET, net.c_str(), &vnetwork);
365: if (r < 1) {
366: netitem.Err("Invalid network address");
367: return false;
368: }
369: }
370:
371: // hostnetN-usermode-net6=<netmask>/<prefixlen>
372: {
373: const ConfigItem& net6item = gConfig->Find(key + "-usermode-net6");
374: std::string net6 = net6item.AsString();
375: const char *s = strchr(net6.c_str(), '/');
376: if (s == NULL) {
377: net6item.Err();
378: return false;
379: }
380: const char *p = s + 1;
381: // strtoul() は先頭のスペースを無視して進むので
382: // 先頭がスペースでないことはチェックする必要がある。
383: if (*p < '0' || *p > '9') {
384: net6item.Err();
385: return false;
386: }
387: char *end;
388: errno = 0;
389: unsigned long netlen = strtoul(p, &end, 10);
390: if (*end != '\0' || errno != 0) {
391: net6item.Err("Invalid prefix len");
392: return false;
393: }
394: // 適切な範囲がよく分からないのでとりあえず物理限界だけチェック。
395: if (netlen < 1 || netlen > 125) {
396: net6item.Err("prefix len iis out of range");
397: return false;
398: }
399: vprefix_len = netlen;
400:
401: net6.resize(s - net6.c_str());
402: int r = inet_pton(AF_INET6, net6.c_str(), &vprefix_addr6);
403: if (r < 1) {
404: net6item.Err("Invalid network address");
405: return false;
406: }
407: }
408:
409: // hostnetN-usermode-hostfwd の書式は
410: // <entry> := <proto>,[<hostaddr>:]<hostport>,[<guestaddr>:]<guestport>
411: // で、<entry> が複数ならセミコロンで区切る。
412: const ConfigItem& fwditem = gConfig->Find(key + "-usermode-hostfwd");
413: auto entries = string_split(fwditem.AsString(), ';');
414: for (auto entry : entries) {
415: FwdInfo fwd;
416: std::string msg;
417:
418: entry = string_trim(entry);
419: auto val = string_split(entry, ',');
420: if (val.size() != 3) {
421: fwditem.Err("syntax error at \"%s\"", entry.c_str());
422: return false;
423: }
424:
425: // proto
426: auto proto_str = string_trim(val[0]);
427: if (strcasecmp(proto_str.c_str(), "tcp") == 0) {
428: fwd.is_udp = 0;
429: } else if (strcasecmp(proto_str.c_str(), "udp") == 0) {
430: fwd.is_udp = 1;
431: } else {
432: fwditem.Err("protocol must be \"tcp\" or \"udp\" at \"%s\"",
433: entry.c_str());
434: return false;
435: }
436:
437: // [<hostaddr>:]<hostport>
438: if (ParseAddr(val[1], "host", &fwd.host, msg) == false) {
439: fwditem.Err("%s at \"%s\"", msg.c_str(), entry.c_str());
440: return false;
441: }
442:
443: // [<guestaddr>:]<guestport>
444: if (ParseAddr(val[2], "guest", &fwd.guest, msg) == false) {
445: fwditem.Err("%s at \"%s\"", msg.c_str(), entry.c_str());
446: return false;
447: }
448:
449: fwdinfo.push_back(fwd);
450: }
451:
452: // Slirp を初期化。
453: memset(&config, 0, sizeof(config));
454: config.version = 4;
455: config.in_enabled = true;
456: config.vnetwork = vnetwork;
457: config.vnetmask = vnetmask;
458: config.vhost.s_addr = htonl(ntohl(vnetwork.s_addr) + 0x01);
459: config.vnameserver.s_addr = htonl(ntohl(vnetwork.s_addr) + 0x02);
460: config.vdhcp_start.s_addr = htonl(ntohl(vnetwork.s_addr) + 0x0a);
461: config.in6_enabled = true;
462: config.vprefix_addr6 = vprefix_addr6;
463: config.vprefix_len = vprefix_len;
464: config.vhost6 = vprefix_addr6;
465: config.vhost6.s6_addr[15] = 1;
466: config.vnameserver6 = vprefix_addr6;
467: config.vnameserver6.s6_addr[15] = 2;
468: gw6 = config.vhost6;
469: dns6 = config.vnameserver6;
470:
471: sl = slirp_new(&config, &slirp_callbacks, this);
472: if (sl == NULL) {
473: putmsg(0, "slirp_new() failed");
474: return false;
475: }
476:
477: for (const auto& fwd : fwdinfo) {
478: int r = slirp_add_hostfwd(sl, fwd.is_udp,
479: fwd.host.sin_addr, fwd.host.sin_port,
480: fwd.guest.sin_addr, fwd.guest.sin_port);
481: if (r != 0) {
482: char hname[INET_ADDRSTRLEN];
483: char gname[INET_ADDRSTRLEN];
484: hname[0] = '\0';
485: gname[0] = '\0';
486: inet_ntop(AF_INET, &fwd.host.sin_addr,
487: hname, (socklen_t)sizeof(hname));
488: inet_ntop(AF_INET, &fwd.guest.sin_addr,
489: gname, (socklen_t)sizeof(gname));
490: putmsg(0, "slirp_add_hostfwd(%s,%s,%d,%s,%d) failed",
491: (fwd.is_udp ? "udp" : "tcp"),
492: hname, fwd.host.sin_port, gname, fwd.guest.sin_port);
493: return false;
494: }
495: }
496:
497: // libslirp のバージョンをチェック。
498: const char *version_str = slirp_version_string();
499: uint major;
500: uint minor;
501: uint patch;
502: if (sscanf(version_str, "%u.%u.%u", &major, &minor, &patch) == 3) {
503: putmsg(1, "libslirp version %u.%u", major, minor);
504: ver = VER(major, minor, patch);
505: }
506:
507: // 送信用のパイプを用意。
508: if (pipe(fds) < 0) {
509: putmsg(0, "pipe() failed");
510: return false;
511: }
512: txd_r = fds[0];
513: txd_w = fds[1];
514:
515: // 受信用のパイプを用意。
516: if (pipe(fds) < 0) {
517: putmsg(0, "pipe() failed");
518: return false;
519: }
520: rxd_r = fds[0];
521: rxd_w = fds[1];
522:
523: *rxdp = rxd_r;
524: *txdp = txd_w;
525:
526: // 成功したらモニタを登録。
527: monitor = gMonitorManager->Regist(ID_MONITOR_SLIRP, this);
528: monitor->func = ToMonitorCallback(&SlirpThread::MonitorUpdate);
529: monitor->SetSize(80, 40);
530:
531: return true;
532: }
533:
534: // "[アドレス:]ポート" から addr, port を取り出す。
535: // エラーなら errmsg にエラーメッセージを格納して false を返す。
536: bool
537: SlirpThread::ParseAddr(std::string hostport, const char *msg,
538: struct sockaddr_in *sin, std::string& errmsg) const
539: {
540: hostport = string_trim(hostport);
541:
542: // ':' で分離。':' 自体がなければポートのみ。
543: std::string serv;
544: if (strchr(hostport.c_str(), ':')) {
545: auto h = string_split(hostport, ':');
546: const std::string& name = h[0];
547: serv = h[1];
548:
549: // アドレス。
550: int r = inet_pton(AF_INET, name.c_str(), &sin->sin_addr);
551: if (r < 0) {
552: errmsg = string_format("\"%s\": inet_pton failed", name.c_str());
553: return false;
554: }
555: if (r == 0) {
556: errmsg = string_format("\"%s\": %s address not parsable",
557: name.c_str(), msg);
558: return false;
559: }
560: } else {
561: sin->sin_addr.s_addr = 0;
562: serv = hostport;
563: }
564:
565: // ポート。
566: int port = atoi(serv.c_str());
567: if (port < 1 || port > 65535) {
568: errmsg = string_format("%d: invalid %s port", port, msg);
569: return false;
570: }
571: sin->sin_port = port;
572:
573: return true;
574: }
575:
576: void
577: SlirpThread::Close()
578: {
579: txd_r.Close();
580: txd_w.Close();
581: rxd_r.Close();
582: rxd_w.Close();
583:
584: if (sl) {
585: for (const auto& fwd : fwdinfo) {
586: slirp_remove_hostfwd(sl, fwd.is_udp,
587: fwd.host.sin_addr, fwd.host.sin_port);
588: }
589: slirp_cleanup(sl);
590: sl = NULL;
591: }
592: }
593:
594: // スレッドの終了を指示
595: void
596: SlirpThread::Terminate()
597: {
598: txd_r.Close();
599: }
600:
601: // スレッド
602: void
603: SlirpThread::ThreadRun()
604: {
605: SetThreadAffinityHint(AffinityClass::Light);
606:
607: while (exit_requested == false) {
608: // タイマー処理。
609: int64 cur_msec = ClockGetNsCB() / 1000'000;
610: for (auto it = timerlist.begin(); it != timerlist.end(); ) {
611: SlirpTimer *timer = *it;
612: if (timer->expire_msec <= cur_msec) {
613: // 期限が来ていれば登録されているハンドラを実行。
614: // このハンドラ内から TimerModCB() が呼ばれて
615: // timerlist が書き換わる可能性があるので先に削除。
616: timerlist.erase(it);
617: timer->func(timer->arg);
618: // この場合 it の状態が保証されなくなるので、
619: // もう一度先頭からやり直す。
620: it = timerlist.begin();
621: } else {
622: it++;
623: }
624: }
625:
626: // poll に入る前に内部のテーブル(文字列)を取得しておく。
627: UpdateInfo();
628:
629: // 先頭を txd とする。
630: pollfds.clear();
631: AddPollCB(txd_r, SLIRP_POLL_IN);
632:
633: // slirp ハンドルが持っているディスクリプタを pollfds[] にセット。
634: // コールバックで都度 AddPollCB() が呼ばれてそいつが追加している。
635: //
636: // slirp_pollfds_fill() の &timeout_ms 引数は、timeout_ms を
637: // 書き出す(out パラメータ)ではなく、現行の timeout_ms を必要に
638: // 応じて更新というか短くする(ref パラメータ)。つまり呼び出し前に
639: // 適切な値をセットしておく必要がある。値は必ず 1000 以下にしてくる
640: // ため、初期値も 1000 をセットするのがよさそう。
641: // ドキュメントをちゃんと書け。
642: uint32 timeout_ms = 1000;
643: slirp_pollfds_fill(sl, &timeout_ms, add_poll_cb, this);
644:
645: int err = poll(pollfds.data(), pollfds.size(), timeout_ms);
646: if (err < 0) {
647: if (errno == EINTR) {
648: continue;
649: }
650: // XXX どうする?
651: putmsg(0, "poll failed: %s", strerror(errno));
652: break;
653: }
654:
655: // txd に何か起きた。
656: if (pollfds[0].revents != 0) {
657: // txd のクローズはこのスレッドの終了通知。
658: if ((pollfds[0].revents & (POLLERR | POLLHUP | POLLNVAL))) {
659: exit_requested = true;
660: continue;
661: }
662:
663: // txd への着信は VM (-> HostNet スレッド) からのパケット送信。
664: if ((pollfds[0].revents & POLLIN)) {
665: Write();
666: }
667: }
668:
669: // poll() 完了後に slirp ハンドルの持っている各ディスクリプタの
670: // revents (GetReventsCB() コールバックを通じて取得する) に応じた
671: // 処理をするようだ。
672: slirp_pollfds_poll(sl, (err < 0), get_revents_cb, this);
673: }
674: }
675:
676: // slirp_pollfds_fill() から呼ばれるコールバック。
677: // fd, events をこっちの pollfds[] に追加し、追加したインデックスを返す。
678: int
679: SlirpThread::AddPollCB(int fd, int slevents)
680: {
681: struct pollfd pfd;
682:
683: pfd.fd = fd;
684: pfd.events = SLIRP_EVENT_to_POLL_EVENT(slevents);
685: pfd.revents = 0;
686:
687: int idx = pollfds.size();
688: pollfds.emplace_back(pfd);
689: return idx;
690: }
691:
692: // slirp_pollfds_poll() から呼ばれるコールバック。
693: // pollfds[idx] の revents (SLRIP_POLL_*) を返す。
694: int
695: SlirpThread::GetReventsCB(int idx)
696: {
697: if (idx < 0 || idx >= pollfds.size()) {
698: return 0;
699: }
700:
701: int slevents = POLL_EVENT_to_SLIRP_EVENT(pollfds[idx].revents);
702: return slevents;
703: }
704:
705: // HostNet(NetDriver) スレッドから txd に着信したパケットを Slirp に送信する。
706: void
707: SlirpThread::Write()
708: {
709: uint32 len;
710: int r;
711:
712: // 先頭4バイトに後続パケット長を入れてある。
713: r = read(txd_r, &len, sizeof(len));
714: if (r < 0) {
715: putmsg(0, "Write: read(len) failed: %s", strerror(errno));
716: return;
717: }
718:
719: std::vector<uint8> buf(len);
720: r = read(txd_r, buf.data(), buf.size());
721: if (r < 0) {
722: putmsg(0, "Write: read(buf) failed: %s", strerror(errno));
723: return;
724: }
725:
726: // 一部のフレームを libslirp に渡す前にこちらで処理する。
727: if (__predict_false(WriteHook(buf))) {
728: return;
729: }
730:
731: if (__predict_false(loglevel >= 2)) {
732: putmsgn("Send to SLIRP:");
733: DumpFrame(buf.data(), buf.size());
734: }
735: slirp_input(sl, buf.data(), buf.size());
736: }
737:
738: // 一部の frame を libslirp に渡す前にこちらで処理する。
739: // 処理した (libslirp に渡さない) 場合は true を返す。
740: // 処理しない (libslirp に渡す) 場合は false を返す。
741: //
742: // 現状、自分(ルータと DNS サーバ)以外への ICMPv6 Echo Request が該当。
743: bool
744: SlirpThread::WriteHook(const std::vector<uint8>& frame) const
745: {
746: const uint8 *payload;
747: size_t payloadlen;
748:
749: // XXX libslirp-4.7.0 は、自身が管理するルータ・DNS サーバ以外の
750: // アドレスへの ICMPv6 Echo Request の送出に対する処理が未実装。
751: // それ自体はいいのだが、slirp_input() がそのパケットを受け取ると
752: // GLib の機構でコンソールにログを出してしまい、このログはこちらで制御
753: // 出来ない (しにくい) のにユーザに目立つ形で表示されるので大変困る。
754: // そこで、このパケットを事前にここで検出して、自分で処理というか
755: // ドロップして putmsg() で控えめにログを出すことにする。
756: // libslirp-4.8.0 で修正された。
757: if (ver >= VER(4, 8, 0)) {
758: return false;
759: }
760:
761: // イーサネットフレームが IPv6。
762: if (__predict_false(frame.size() < 14)) {
763: return false;
764: }
765: if (frame[12] != 0x86 || frame[13] != 0xdd) {
766: return false;
767: }
768:
769: struct ipv6_hdr {
770: uint8 ver_cls; // 上位4ビットが version
771: uint8 clf_flw;
772: uint16 flowlabel;
773: uint16 payloadlen;
774: uint8 nexthdr;
775: uint8 hoplimit;
776: uint8 srcip[16];
777: uint8 dstip[16];
778: } __packed;
779: payload = frame.data() + 14;
780: payloadlen = frame.size() - 14;
781: const ipv6_hdr& ipv6 = *(const ipv6_hdr *)payload;
782: if (__predict_false(payloadlen < sizeof(ipv6_hdr))) {
783: return false;
784: }
785: // 先に NextHdr をチェック。途中に別ヘッダが挟まるケースは諦める。
786: if (ipv6.nexthdr != 58) {
787: return false;
788: }
789:
790: struct icmp_hdr {
791: uint8 type;
792: uint8 code;
793: uint16 cksum;
794: } __packed;
795: payload += sizeof(ipv6_hdr);
796: payloadlen -= sizeof(ipv6_hdr);
797: const icmp_hdr& icmp = *(const icmp_hdr *)payload;
798: if (__predict_false(payloadlen < sizeof(icmp_hdr))) {
799: return false;
800: }
801: if (icmp.type != 128) { // ICMPV6 Echo Request
802: return false;
803: }
804:
805: // ICMPv6 Echo Reuqest は確定したのでここで宛先をチェック。
806: if (0) {
807: char srcname[100];
808: char dstname[100];
809: inet_ntop(AF_INET6, ipv6.srcip, srcname, (socklen_t)sizeof(srcname));
810: inet_ntop(AF_INET6, ipv6.dstip, dstname, (socklen_t)sizeof(dstname));
811: printf("ICMPv6 src=%s dst=%s\n", srcname, dstname);
812: }
813:
814: // 宛先が自分のルータか DNS サーバなら処理可能なので何もしない。
815: if (memcmp(ipv6.dstip, &gw6, sizeof(gw6)) == 0) {
816: return false;
817: }
818: if (memcmp(ipv6.dstip, &dns6, sizeof(dns6)) == 0) {
819: return false;
820: }
1.1.1.2 ! root 821: // リンクローカルはここで作って比較。
! 822: struct in6_addr linklocal;
! 823: memset(&linklocal, 0, sizeof(linklocal));
! 824: linklocal.s6_addr[0] = 0xfe;
! 825: linklocal.s6_addr[1] = 0x80;
! 826: memcpy(&linklocal.s6_addr[8], &gw6.s6_addr[8], 8);
! 827: if (memcmp(ipv6.dstip, &linklocal, sizeof(linklocal)) == 0) {
! 828: return false;
! 829: }
! 830: memcpy(&linklocal.s6_addr[8], &dns6.s6_addr[8], 8);
! 831: if (memcmp(ipv6.dstip, &linklocal, sizeof(linklocal)) == 0) {
! 832: return false;
! 833: }
1.1 root 834:
835: // ここから未実装ログが出る組み合わせ。
836:
837: // 統計情報。
838: hostnet->CountTXUnsupp(frame.size());
839:
840: // 宛先が fe80::db8:db8:9090 なのはオレオレパフォーマンス測定用だし、
841: // この宛先はドキュメント用に予約されたもので送出すべきでないので、
842: // これに限り黙って握りつぶす。
843: // それ以外は同じメッセージを出しておく。
844: if (memcmp(ipv6.dstip, &perfaddr6, sizeof(perfaddr6)) != 0) {
845: putmsg(1, "libslirp: external icmpv6 not supported yet");
846: }
847:
848: return true;
849: }
850:
851: // Slirp ライブラリがパケットを "送信した" 時に呼ばれるコールバック。
852: // なのでこちらから見れば HUB から NIC への着信。
853: ssize_t
854: SlirpThread::SendPacketCB(const void *src, size_t srclen)
855: {
856: if (__predict_false(loglevel >= 2)) {
857: putmsgn("Recv from SLIRP");
858: DumpFrame(src, srclen);
859: }
860:
861: // 受信ディスクリプタ (の書き込み端) に書き込む。
862: // 先頭4バイトはホストバイトオーダーでの後続のパケット長。
863: uint32 lenbuf = srclen;
864:
865: struct iovec iov[2];
866: iov[0].iov_base = &lenbuf;
867: iov[0].iov_len = sizeof(lenbuf);
868: iov[1].iov_base = const_cast<void *>(src);
869: iov[1].iov_len = srclen;
870:
871: ssize_t r = writev(rxd_w, &iov[0], countof(iov));
872: if (r < 0) {
873: putmsg(0, "writev failed: %s", strerror(errno));
874: return -1;
875: }
876: if (r < sizeof(lenbuf) + srclen) {
877: putmsg(0, "writev failed: too short");
878: return -1;
879: }
880:
881: return srclen;
882: }
883:
884: // 現在の仮想時間を返すコールバック。
885: int64
886: SlirpThread::ClockGetNsCB() const
887: {
888: // XXX scheduler がセットされる前から呼ばれるのでとりあえず。
889: if (__predict_false(scheduler == NULL)) {
890: return 0;
891: }
892: uint64 time = scheduler->GetVirtTime();
893: return (int64)time;
894: }
895:
896: // 新しいタイマー(イベント)を返すコールバック。
897: // 引数は時間が来たら呼ぶハンドラと引数。
898: void *
899: SlirpThread::TimerNewCB(SlirpTimerCb func, void *arg)
900: {
901: SlirpTimer *newtimer = new SlirpTimer(func, arg);
902: newtimer->num = latest_timer_num++;
903: return newtimer;
904: }
905:
906: // タイマーを削除する。
907: void
908: SlirpThread::TimerFreeCB(SlirpTimer *timer)
909: {
910: // まだアクティブならそれも削除する。
911: timerlist.remove(timer);
912: delete timer;
913: }
914:
915: // タイマーの期限を新しく設定する?。
916: void
917: SlirpThread::TimerModCB(SlirpTimer *timer, int64 expire_msec)
918: {
919: timer->expire_msec = expire_msec;
920:
921: // リストから一旦削除してから、適切なところに挿入し直す。
922: timerlist.remove(timer);
923: if (timerlist.empty()) {
924: timerlist.push_back(timer);
925: } else {
926: for (auto it = timerlist.begin(); it != timerlist.end(); ++it) {
927: auto *t = *it;
928: if (t->expire_msec > timer->expire_msec) {
929: timerlist.insert(it, timer);
930: break;
931: }
932: }
933: }
934: }
935:
936: // ゲスト (VM) から送信しようとしたパケットのエラーメッセージ。
937: // とりあえずログに出しておく。
938: void
939: SlirpThread::GuestErrorCB(const char *msg)
940: {
941: putmsg(1, "libslirp: %s", msg);
942: }
943:
944: // Slirp の内部テーブルのこちら側のコピーを更新する。
945: // メインループ内から呼ばれる。
946: void
947: SlirpThread::UpdateInfo()
948: {
949: // 取得。
950: char *newconn = slirp_connection_info(sl);
951: char *newnbr = slirp_neighbor_info(sl);
952:
953: // 更新が必要か。前回と同じなら今取得したほうを解放。
954: if (conninfo && strcmp(conninfo, newconn) == 0) {
955: free(newconn);
956: newconn = NULL;
957: }
958: if (nbrinfo && strcmp(nbrinfo, newnbr) == 0) {
959: free(newnbr);
960: newnbr = NULL;
961: }
962: // どちらも更新なしならここで終了。
963: if (newconn == NULL && newnbr == NULL) {
964: return;
965: }
966:
967: // 更新。
968: char *oldconn = NULL;
969: char *oldnbr = NULL;
970: {
971: std::unique_lock<std::mutex> lock(info_mtx);
972:
973: if (newconn) {
974: oldconn = conninfo;
975: conninfo = newconn;
976: }
977: if (newnbr) {
978: oldnbr = nbrinfo;
979: nbrinfo = newnbr;
980: }
981: }
982:
983: free(oldconn);
984: free(oldnbr);
985: }
986:
987: void
988: SlirpThread::MonitorUpdate(Monitor *, TextScreen& screen)
989: {
990: std::string local_conn;
991: std::string local_nbr;
992: int y;
993:
994: // スレッド越しにコピーを取る。
995: {
996: std::unique_lock<std::mutex> lock(info_mtx);
997: local_conn = std::string(conninfo);
998: local_nbr = std::string(nbrinfo);
999: }
1000:
1001: // Connection State の UDP 欄は [0 sec] の次に一瞬だけ [4294966 sec] に
1002: // なる。これは slirp_connection_info() が文字列を返してきた時点で
1003: // こうなっているのでこっちの話ではないのだが、あまりに幼稚すぎて
1004: // 自分のソフトでこれが表示されるのは恥ずかしいのでパッチしておく。
1005: static const char ovfsec[] = "UDP[4294966 sec]";
1006: static const char patch[] = "UDP[expired] ";
1007: for (char *s = &local_conn[0]; (s = strstr(s, ovfsec)) != NULL; ) {
1008: memcpy(s, patch, strlen(patch));
1009: s += strlen(patch);
1010: }
1011:
1012: screen.Clear();
1013: y = 0;
1014:
1015: auto lines = string_split(local_conn, '\n');
1016: for (auto& buf : lines) {
1017: screen.Puts(0, y++, buf.c_str());
1018: }
1019:
1020: lines = string_split(local_nbr, '\n');
1021: for (auto& buf : lines) {
1022: screen.Puts(0, y++, buf.c_str());
1023: }
1024: // あふれたら諦める…。
1025: }
1026:
1027: // src から srclen バイトの16進ダンプをログに(無条件に)出力する。
1028: void
1029: SlirpThread::DumpHex(const void *src, size_t srclen) const
1030: {
1031: std::vector<std::string> lines = HostNetDevice::DumpHex(src, srclen);
1032: for (auto& line : lines) {
1033: putmsgn("%s", line.c_str());
1034: }
1035: }
1036:
1037: // イーサネットフレームを整形してログに(無条件に)出力する。
1038: void
1039: SlirpThread::DumpFrame(const void *src, size_t srclen) const
1040: {
1041: std::vector<std::string> lines = HostNetDevice::DumpFrame(src, srclen);
1042: for (auto& line : lines) {
1043: putmsgn("%s", line.c_str());
1044: }
1045: }
1046:
1047: // コールバックのトランポリン関数たち
1048:
1049: static ssize_t
1050: send_packet_cb(const void *buf, size_t buflen, void *opaque)
1051: {
1052: auto *backend = reinterpret_cast<SlirpThread *>(opaque);
1053: return backend->SendPacketCB(buf, buflen);
1054: }
1055:
1056: static void
1057: guest_error_cb(const char *msg, void *opaque)
1058: {
1059: auto *backend = reinterpret_cast<SlirpThread *>(opaque);
1060: backend->GuestErrorCB(msg);
1061: }
1062:
1063: static int64
1064: clock_get_ns_cb(void *opaque)
1065: {
1066: auto *backend = reinterpret_cast<SlirpThread *>(opaque);
1067: return backend->ClockGetNsCB();
1068: }
1069:
1070: static void *
1071: timer_new_cb(SlirpTimerCb func, void *arg, void *opaque)
1072: {
1073: auto *backend = reinterpret_cast<SlirpThread *>(opaque);
1074: return backend->TimerNewCB(func, arg);
1075: }
1076:
1077: static void
1078: timer_free_cb(void *timer, void *opaque)
1079: {
1080: auto *backend = reinterpret_cast<SlirpThread *>(opaque);
1081: auto *sltimer = reinterpret_cast<SlirpTimer *>(timer);
1082: return backend->TimerFreeCB(sltimer);
1083: }
1084:
1085: static void
1086: timer_mod_cb(void *timer, int64 expire_msec, void *opaque)
1087: {
1088: auto *backend = reinterpret_cast<SlirpThread *>(opaque);
1089: auto *sltimer = reinterpret_cast<SlirpTimer *>(timer);
1090: backend->TimerModCB(sltimer, expire_msec);
1091: }
1092:
1093: // おそらく不要で何もしなくていいのだが、コールバックを NULL に出来ないため。
1094: static void
1095: register_poll_fd_cb(int fd, void *)
1096: {
1097: }
1098:
1099: // おそらく不要で何もしなくていいのだが、コールバックを NULL に出来ないため。
1100: static void
1101: unregister_poll_fd_cb(int fd, void *)
1102: {
1103: }
1104:
1105: // シングルスレッド動作なので不要なはずだが、コールバックを NULL に出来ない。
1106: static void
1107: notify_cb(void *)
1108: {
1109: }
1110:
1111: static int
1112: add_poll_cb(int fd, int events, void *opaque)
1113: {
1114: auto *backend = reinterpret_cast<SlirpThread *>(opaque);
1115: return backend->AddPollCB(fd, events);
1116: }
1117:
1118: static int
1119: get_revents_cb(int idx, void *opaque)
1120: {
1121: auto *backend = reinterpret_cast<SlirpThread *>(opaque);
1122: return backend->GetReventsCB(idx);
1123: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.