![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to hostcom.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 hostcom.cpp CVS log | Up to [Isaki's NoNo m68k/m88k emulator] / nono / host |
1.1 root 1: //
2: // nono
3: // Copyright (C) 2021 nono project
4: // Licensed under nono-license.txt
5: //
6:
7: //
8: // シリアルポートのホストデバイス
9: //
10:
11: // 送信のフロー
12: //
13: // VM thread : Host thread
14: //
15: // 各シリアルデバイス::Tx() :
16: // |
17: // SerialDevice::Tx() :
18: // |
19: // HostCOMDevice::Tx() : HostDevice::ThreadRun
20: // |
21: // +-------------->| queue |----+
22: // +-------------->| pipe |----+
23: // | |
24: // <-+ : v
25: // --- kevent
26: // : |
27: // HostCOMDevice::Write()
28: // : |
29: // COMDriver*::Write()
30: // : |
31: // +-----> Send to the real world
32:
33: // 受信のフロー
34: //
35: // VM thread : Host thread
36: //
37: // : HostDevice::ThreadRun
38: //
39: // : +-----< Recv from the real world
40: // |
41: // : v
42: // --- kevent
43: // : |
44: // HostCOMDevice::Read()
45: // |
46: // +---------------| queue |<---+
47: // +---------------| event |<---+
48: // v
49: // SerialDevice::Callback()
50: // |
51: // 各シリアルデバイス::Rx()
52:
53: // ログ名
54: // MPSCC HostDevice COMDriver
55: // | | |
56: // v v v
57: // SIODevice -> HostCOMDevice -> COMDriver***
58: // 表示名 (sio) (HostCOMx) (HostCOMx.***)
59: // 識別名 "sio" "hostcomx" "hostcomx"
60: //
61: // HostCOM は 1VM あたり 1個とは限らないので、親デバイスがそれぞれ対応する
62: // HostCOM に名前を付ける。
63:
64:
65: #include "hostcom.h"
66: #include "comdriver_none.h"
67: #include "comdriver_stdio.h"
68: #include "comdriver_tcp.h"
69: #include "config.h"
70: #include "mainapp.h"
71:
72: // コンストラクタ
73: //
74: // objname_ は "HostCOM" とか (スレッド名も同じになる)。
75: // 設定ファイルキーワードプレフィックスはこれを小文字にしたもの("hostcom")。
76: HostCOMDevice::HostCOMDevice(const std::string& objname_)
77: : inherited(objname_)
78: {
79: // 親が hostcom* か debugger かによっていろいろ動作が違う。
80: if (GetName() == "Debugger") {
81: // デバッガコンソールならログレベルは親に準じるため、こっちは不要。
82: ClearAlias();
83:
84: // 送受信バイト数がメインのモニタはこっちにはなくていいだろう。
85: } else {
86: // hostcom* なら親(mpscc などのシリアルデバイス)とこっち(HostCOM*)
87: // のログレベルは独立。
88:
89: // モニタは hostcom* のみ必要。
90: monitor.func = ToMonitorCallback(&HostCOMDevice::MonitorUpdate);
91: monitor.SetSize(30, 16);
92: monitor.Regist(ID_MONITOR_HOSTCOM);
93: }
94: }
95:
96: // デストラクタ
97: HostCOMDevice::~HostCOMDevice()
98: {
99: }
100:
101: // ログレベル設定
102: void
103: HostCOMDevice::SetLogLevel(int loglevel_)
104: {
105: inherited::SetLogLevel(loglevel_);
106:
107: if ((bool)driver) {
108: driver->SetLogLevel(loglevel_);
109: }
110: }
111:
112: // 初期化
113: bool
114: HostCOMDevice::Init()
115: {
116: if (inherited::Init() == false) {
117: return false;
118: }
119:
120: if (SelectDriver() == false) {
121: return false;
122: }
123:
124: return true;
125: }
126:
127: // ドライバ(再)選択
128: bool
129: HostCOMDevice::SelectDriver()
130: {
131: // 設定のキー名は親デバイスによって異なる
132: std::string key = GetConfigKey();
133: const ConfigItem& item = gConfig->Find(key + "-driver");
134: const std::string& type = item.AsString();
135:
136: driver.reset();
137:
138: if (type != "none") {
139: if (type == "stdio") {
140: // debugger-driver=stdio (または -D オプション) と
141: // hostcom*-driver=stdio とは共存できない。
142: // 歴史的経緯でとりあえず debugger-driver=stdio 側を優先とする。
143: // XXX これも後指定優先にするかどうか
144: // XXX hostcom が増えたらたぶんこうじゃなくなる
145: if (key != "debugger") {
146: const ConfigItem& dditem = gConfig->Find("debugger-driver");
147: const std::string& ddtype = dditem.AsString();
148: if (ddtype == "stdio") {
149: const char *opt;
150: if (gMainApp.opt_D) {
151: opt = "-D";
152: } else {
153: opt = "'-V debugger-driver=stdio'";
154: }
155: item.Err("cannot be used with %s option", opt);
156: return false;
157: }
158: }
159:
160: driver.reset(new COMDriverStdio(this));
161: if ((bool)driver && driver->InitDriver() == false) {
162: driver.reset();
163: }
164:
165: } else if (type == "tcp") {
166: driver.reset(new COMDriverTCP(this));
167: if ((bool)driver && driver->InitDriver() == false) {
168: driver.reset();
169: }
170:
171: } else {
172: // 知らないドライバ種別
173: item.Err();
174: return false;
175: }
176:
177: if ((bool)driver == false) {
178: bool fallback = false;
179:
180: // 指定のドライバが使えなかった場合、
181: // hostcom*-driver なら fallback するかどうかは設定による。
182: // debugger-driver なら常に fallback せず終了する。
183: //
184: // 元々 hostnet が tap, bpf のように順に試してという流れだったので
185: // fallback の選択肢が用意されていたが、hostcom は今の所どれか1つ
186: // (stdio か tcp) か、そうでなければ none しかないので、fallback
187: // するかどうかを選ばせる意味があまりような気もするけど、
188: // とりあえず形式だけ真似してみる…。
189: // 一方、debugger-driver なら常に fallback せず、設定自体も用意
190: // しない。デバッガを使いたいと言ってる時点でデバッガがなくても
191: // とりあえず起動してほしいとはならないだろうと思うので。
192: if (key != "debugger") {
193: fallback = gConfig->Find(key + "-fallback").AsInt();
194: putmsg(1, "%s-fallback=%d", key.c_str(), fallback ? 1 : 0);
195: }
196:
197: if (fallback == false) {
198: // フォールバックしないならエラー終了
199: std::string errmsg;
200: errmsg = string_format("No %s driver found", key.c_str());
201: putmsg(1, "%s", errmsg.c_str());
202: warnx("%s (See details with option -C -L%s=1)",
203: errmsg.c_str(), key.c_str());
204: return false;
205: }
206: }
207: }
208:
209: if ((bool)driver == false) {
210: driver.reset(new COMDriverNone(this));
211: if ((bool)driver && driver->InitDriver() == false) {
212: // 失敗したら出来ることはあまりなさげ
213: assert(false);
214: }
215: }
216: assert((bool)driver);
217:
218: // ドライバ名は Capitalize だがログはほぼ小文字なので雰囲気を揃える…
219: putmsg(1, "selected host driver: %s",
220: string_tolower(driver->GetDriverName()).c_str());
221:
222: return true;
223: }
224:
225: void
226: HostCOMDevice::Dispatch(int udata)
227: {
228: // driver の Dispatch は処理し終わったら DONE を返す
229: udata = driver->Dispatch(udata);
230:
231: // ...のだが、Dispatch(LISTEN_SOCKET) は着信を受け付けた時には
232: // LISTEN_SOCKET を返し、それを受けてここで通知処理を行う。
233: if (udata == LISTEN_SOCKET) {
234: if (dev && accept_func) {
235: (dev->*accept_func)();
236: }
237: udata = DONE;
238: }
239:
240: inherited::Dispatch(udata);
241: }
242:
243: // VM からの送信 (VM スレッドで呼ばれる)
244: bool
245: HostCOMDevice::Tx(uint32 data)
246: {
247: if (loglevel >= 2) {
248: char buf[8];
249:
250: buf[0] = '\0';
251: if (0x20 <= data && data < 0x7f) {
252: snprintf(buf, sizeof(buf), " '%c'", data);
253: }
254: putlog(2, "Send $%02x%s", data, buf);
255: }
256:
257: // 送信キューに入れて..
258: if (txq.Enqueue(data) == false) {
259: putlog(2, "txq exhausted");
260: stat.txqfull_bytes++;
261: return false;
262: }
263: stat.tx_bytes++;
264:
265: // ざっくりピーク値
266: stat.txq_peak = std::max((int)txq.Length(), stat.txq_peak);
267:
268: // パイプに通知 (値はダミー)
269: return WritePipe(0);
270: }
271:
272: // キューから取り出す (VM スレッドで呼ばれる)
273: uint32
274: HostCOMDevice::Rx()
275: {
276: uint8 data;
277:
278: if (rxq.Dequeue(&data) == false) {
279: // キューが空
280: return -1;
281: }
282: stat.rx_bytes++;
283:
284: if (loglevel >= 2) {
285: char buf[8];
286:
287: buf[0] = '\0';
288: if (0x20 <= data && data < 0x7f) {
289: snprintf(buf, sizeof(buf), " '%c'", data);
290: }
291: putlog(2, "Recv $%02x%s", data, buf);
292: }
293:
294: return data;
295: }
296:
297: // ドライバから読み込む。
298: // 戻り値はキューに投入したデータ数。
299: int
300: HostCOMDevice::Read()
301: {
302: assert((bool)driver);
303:
304: int data = driver->Read();
305: if (data < 0) {
306: return 0;
307: }
308: stat.read_bytes++;
309:
310: if (rxq.Enqueue(data) == false) {
311: stat.rxqfull_bytes++;
312: return 0;
313: }
314:
315: // ざっくりピーク値
316: stat.rxq_peak = std::max((int)rxq.Length(), stat.rxq_peak);
317:
318: return 1;
319: }
320:
321: // 外部への書き出し (ホストスレッドで呼ばれる)
322: void
323: HostCOMDevice::Write(uint32 dummy)
324: {
325: uint8 data;
326:
327: assert(driver);
328:
329: // 送信キューを全部吐き出す
330: while (txq.Dequeue(&data)) {
331: driver->Write(data);
332: stat.write_bytes++;
333: }
334: }
335:
336: // モニタ
337: void
338: HostCOMDevice::MonitorUpdate(Monitor *, TextScreen& screen)
339: {
340: screen.Clear();
341:
342: screen.Print(0, 0, "HostCOM Driver: %s", driver->GetDriverName());
343: // 次の1行はドライバ依存情報
344: driver->MonitorUpdateMD(screen);
345:
346: int y = 3;
347: screen.Print(0, y++, "%-17s%13s", "<Tx>", "Bytes");
348: screen.Print(0, y++, "%-17s%13s", "VM sends",
349: format_number(stat.tx_bytes).c_str());
350: screen.Print(0, y++, "%-17s%13s", "Write to host",
351: format_number(stat.write_bytes).c_str());
352: screen.Print(0, y++, "%-17s%13s", "Drop:TxQ Full",
353: format_number(stat.txqfull_bytes).c_str());
354: y++;
355:
356: screen.Print(0, y++, "%-17s%13s", "<Rx>", "Bytes");
357: screen.Print(0, y++, "%-17s%13s", "Read from host",
358: format_number(stat.read_bytes).c_str());
359: screen.Print(0, y++, "%-17s%13s", "VM receives",
360: format_number(stat.rx_bytes).c_str());
361: screen.Print(0, y++, "%-17s%13s", "Drop:RxQ Full",
362: format_number(stat.rxqfull_bytes).c_str());
363: y++;
364:
365: screen.Print(5, y++, "Capacity Peak");
366: screen.Print(0, y++, "TxQ %4d/%4d %4d",
367: (int)txq.Length(), (int)txq.Capacity(), stat.txq_peak);
368: screen.Print(0, y++, "RxQ %4d/%4d %4d",
369: (int)rxq.Length(), (int)rxq.Capacity(), stat.rxq_peak);
370: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.