Annotation of nono/vm/lance.cpp, revision 1.1.1.5

1.1       root        1: //
                      2: // nono
1.1.1.4   root        3: // Copyright (C) 2020 nono project
                      4: // Licensed under nono-license.txt
1.1       root        5: //
                      6: 
                      7: #include "lance.h"
                      8: #include "bus.h"
1.1.1.4   root        9: #include "config.h"
1.1       root       10: #include "mpu.h"
                     11: #include "mystring.h"
1.1.1.4   root       12: #include "mythread.h"
                     13: #include "zram.h"
1.1       root       14: 
                     15: static void *lance_run(void *);
                     16: 
                     17: LanceDevice::LanceDevice()
                     18: {
                     19:        logname = "lance";
                     20:        devname = "Lance";
                     21:        devaddr = 0xf1000000;
                     22: 
1.1.1.5 ! root       23:        monitor_size = nnSize(80, 34);
1.1       root       24: 
                     25:        rx_event.dev = this;
                     26:        rx_event.func = (DeviceCallback_t)&LanceDevice::Callback;
                     27:        rx_event.code = 0;
                     28:        rx_event.time = 0;      // 都度設定する
1.1.1.2   root       29:        rx_event.SetName("Lance RX");
1.1       root       30: 
                     31:        tx_event.dev = this;
                     32:        tx_event.func = (DeviceCallback_t)&LanceDevice::Callback;
                     33:        tx_event.code = 0;
                     34:        tx_event.time = 0;      // 都度設定する
1.1.1.2   root       35:        tx_event.SetName("Lance TX");
1.1       root       36: }
                     37: 
                     38: LanceDevice::~LanceDevice()
                     39: {
1.1.1.3   root       40:        if (thread_created) {
                     41:                Terminate();
                     42:                pthread_join(thread, NULL);
                     43:        }
1.1       root       44: }
                     45: 
                     46: bool
                     47: LanceDevice::Init()
                     48: {
                     49:        // 親も Init() を持っている
                     50:        if (inherited::Init() == false) {
                     51:                return false;
                     52:        }
                     53: 
1.1.1.4   root       54:        const ConfigItem& item = gConfig->Find("ethernet-macaddr");
1.1.1.3   root       55:        const std::string& config_macaddr = item.AsString();
1.1       root       56:        if (config_macaddr == "rom") {
                     57:                // ROM に書いてあるのを使うので、ここでは何もしなくていい
                     58:        } else {
                     59:                if (config_macaddr == "auto") {
                     60:                        // 自動生成
                     61:                        // すでに記録されていれば使う。なければ生成して記録したい
                     62:                        if (0) {
                     63:                        } else {
                     64:                                GenerateMacAddr(&macaddr);
                     65:                        }
                     66:                } else {
                     67:                        // ユーザ指定
                     68:                        if (ParseMacAddr(macaddr, config_macaddr) == false) {
1.1.1.3   root       69:                                item.Err("invalid MAC address");
1.1       root       70:                                return false;
                     71:                        }
                     72:                }
                     73: 
1.1.1.4   root       74:                putmsg(1, "macaddr=%s", macaddr.to_string(':').c_str());
1.1       root       75:        }
                     76: 
                     77:        // ワーカスレッド起動
1.1.1.3   root       78:        pthread_create(&thread, NULL, lance_run, NULL);
                     79:        thread_created = true;
1.1       root       80: 
                     81:        return true;
                     82: }
                     83: 
                     84: void
                     85: LanceDevice::ResetHard()
                     86: {
                     87:        std::unique_lock<std::mutex> lock(mtx);
                     88: 
                     89:        reg.rap = 0;
                     90:        ChipStop();
                     91: }
                     92: 
                     93: uint64
1.1.1.3   root       94: LanceDevice::Read(uint32 addr)
1.1       root       95: {
                     96:        uint32 data;
                     97: 
1.1.1.3   root       98:        switch (addr) {
1.1       root       99:         case 0:        // RDP
                    100:                data = ReadData();
                    101:                return data;
1.1.1.3   root      102:         case 1:        // RAP
1.1       root      103:         {
                    104:                std::unique_lock<std::mutex> lock(mtx);
                    105:                data = reg.rap;
                    106:                putlog(2, "RAP -> %d", reg.rap);
                    107:                return data;
                    108:         }
                    109:        }
1.1.1.3   root      110:        __unreachable();
1.1       root      111: }
                    112: 
                    113: uint64
1.1.1.3   root      114: LanceDevice::Write(uint32 addr, uint32 data)
1.1       root      115: {
1.1.1.3   root      116:        switch (addr) {
1.1       root      117:         case 0:        // RDP
                    118:                WriteData(data);
                    119:                return 0;
1.1.1.3   root      120:         case 1:        // RAP
1.1       root      121:         {
                    122:                std::unique_lock<std::mutex> lock(mtx);
                    123:                reg.rap = data & 3;
                    124:                return 0;
                    125:         }
                    126:        }
1.1.1.3   root      127:        __unreachable();
1.1       root      128: }
                    129: 
                    130: uint64
1.1.1.3   root      131: LanceDevice::Peek(uint32 addr)
1.1       root      132: {
1.1.1.3   root      133:        switch (addr) {
                    134:         case 0:        // RDP
                    135:         {
                    136:                // 今読めるはずのデータ。
                    137:                // CSR[123] は STOP 中でなければ不定だがとりあえずそれは無視。
                    138:                std::unique_lock<std::mutex> lock(mtx);
                    139:                switch (reg.rap) {
                    140:                 case 0:
                    141:                        return reg.GetCSR0();
                    142:                 case 1:
                    143:                        return reg.iadr & 0xffff;
                    144:                 case 2:
                    145:                        return reg.iadr >> 16;
                    146:                 case 3:
                    147:                        return reg.csr3;
                    148:                }
                    149:                break;
                    150:         }
                    151:         case 1:        // RAP
                    152:         {
                    153:                std::unique_lock<std::mutex> lock(mtx);
                    154:                return reg.rap;
                    155:         }
                    156:        }
                    157:        __unreachable();
1.1       root      158: }
                    159: 
1.1.1.5 ! root      160: void
        !           161: LanceDevice::MonitorUpdate(TextScreen& monitor)
1.1       root      162: {
                    163: /*
                    164: CSR0: $1111 ERR  BABL CERR MISS MERR RINT TINT IDON   IADR:$123456
                    165:                                                       CSR3:$0004 BSWP ACON BCON
                    166: 
                    167: MODE: $0000 PROM INTL DRTY COLL DTCR LOOP DTX  DRX
                    168: PADR: 00:11:22:33:44:55    RDRP: $12345678 (RDRA=$123456 entries=32)
                    169: LADRF:$12345678_12345678   TDRP:
                    170: 
                    171: <RMD> Current 00 OWN ERR OFLO CRC BUFF STP ENP BCNT=$123 MCNT=$123 buf=$123456
                    172: 01234567890123456789012345678901234567890             00
                    173: 00 OVCBSE $12345 $123/$123 00 OVCBSE $12345 $123/$123
                    174: <TMD> Current 00 OWN ERR STP ENP  BUFF UFLO BCNT=$123 buf=$123456
                    175: 00 OSEBU  $12345 $123
                    176: */
                    177: 
                    178: // name を表示。(var & bit) ならオン(反転)表示。
                    179: // bitpos は 0..15 で [0] が MSB にあたる。
                    180: #define MonitorBit(var, bit, name) do { \
1.1.1.4   root      181:        monitor.Puts(x, y, TA::OnOff((var) & (bit)), name); \
1.1       root      182:        x += strlen(name) + 1; \
                    183: } while (0)
                    184: 
                    185:        int x;
                    186:        int y;
                    187:        int i;
                    188: 
                    189:        monitor.Clear();
                    190: 
                    191:        // XXX lock
                    192: 
                    193:        y = 0;
                    194:        // CSR
                    195:        uint16 csr0 = reg.GetCSR0();
                    196:        monitor.Print(0, y, "CSR0:$%04x", csr0);
1.1.1.5 ! root      197:        MonitorReg(monitor, 11, y,     csr0 >> 8, csr0names);
        !           198:        MonitorReg(monitor, 11, y + 1, csr0, csr0names + 8);
1.1       root      199: 
                    200:        monitor.Print(54, y++, "IADR:$%06x", reg.iadr);
                    201:        monitor.Print(54, y, "CSR3:$%04x", reg.csr3);
                    202:        // CSR3 は下位3ビットだけなので手動で配置
                    203:        x = 65;
                    204:        MonitorBit(reg.csr3, AM7990::CSR3_BSWP, csr3names[13]);
                    205:        MonitorBit(reg.csr3, AM7990::CSR3_ACON, csr3names[14]);
                    206:        MonitorBit(reg.csr3, AM7990::CSR3_BCON, csr3names[15]);
                    207:        y++;
                    208: 
1.1.1.4   root      209:        monitor.Puts(0, y, "<Initial Block>");
1.1       root      210:        y++;
                    211:        // MODE は bit15 と bit6-0 の8ビットだけ使われてるので
                    212:        // 途中を省略して 8ビットとして表示する
                    213:        monitor.Print(0, y, "MODE:$%04x", initblock[0]);
                    214:        x = 11;
                    215:        MonitorBit(initblock[0], AM7990::IBMODE_PROM, ib_mode_names[0]);
                    216:        MonitorBit(initblock[0], AM7990::IBMODE_INTL, ib_mode_names[1]);
                    217:        MonitorBit(initblock[0], AM7990::IBMODE_DRTY, ib_mode_names[2]);
                    218:        MonitorBit(initblock[0], AM7990::IBMODE_COLL, ib_mode_names[3]);
                    219:        MonitorBit(initblock[0], AM7990::IBMODE_DTCR, ib_mode_names[4]);
                    220:        MonitorBit(initblock[0], AM7990::IBMODE_LOOP, ib_mode_names[5]);
                    221:        MonitorBit(initblock[0], AM7990::IBMODE_DTX,  ib_mode_names[6]);
                    222:        MonitorBit(initblock[0], AM7990::IBMODE_DRX,  ib_mode_names[7]);
                    223:        y++;
                    224: 
                    225:        monitor.Print(0, y, "PADR: %02x:%02x:%02x:%02x:%02x:%02x",
                    226:                initblock[1] & 0xff, initblock[1] >> 8,
                    227:                initblock[2] & 0xff, initblock[2] >> 8,
                    228:                initblock[3] & 0xff, initblock[3] >> 8);
                    229:        // XXX LADRF のバイト順未検証
                    230:        monitor.Print(0, y + 1, "LADRF:$%04x%04x_%04x%04x",
                    231:                initblock[7],
                    232:                initblock[6],
                    233:                initblock[5],
                    234:                initblock[4]);
                    235: 
                    236:        // RDRP
                    237:        uint32 rdrp = initblock[8] | (initblock[9] << 16);
                    238:        monitor.Print(31, y, "RDRP:$%08x (RDRA=$%06x entries=%d)",
                    239:                rdrp, rmd_base, rmd_num);
                    240:        y++;
                    241: 
                    242:        // TDRP
                    243:        uint32 tdrp = initblock[10] | (initblock[11] << 16);
                    244:        monitor.Print(31, y, "TDRP:$%08x (TDRA=$%06x entries=%d)",
                    245:                tdrp, tmd_base, tmd_num);
                    246:        y++;
                    247:        y++;
                    248: 
                    249:        // RMD
1.1.1.4   root      250:        monitor.Puts(0, y, "<RMD>");
1.1       root      251: 
                    252:        uint16 rmd[4];
                    253:        uint32 rmd_addr;
                    254:        // 現行ディスクリプタは詳細表示
                    255:        if (rmd_num > 0) {
                    256:                rmd_addr = rmd_base + rmd_cur * 8;
                    257:                for (int j = 0; j < countof(rmd); j++) {
                    258:                        rmd[j] = PeekMem(rmd_addr + j * 2);
                    259:                }
                    260:                x = 6;
                    261:                monitor.Print(x, y, "Current %02x", rmd_cur); x += 11;
                    262:                MonitorBit(rmd[1], AM7990::RMD1_OWN,  rmd1_names[0]);
                    263:                MonitorBit(rmd[1], AM7990::RMD1_ERR,  rmd1_names[1]);
                    264:                // 発生し得ないので省略    RMD1_FRAM  rmd1_names[2]
                    265:                MonitorBit(rmd[1], AM7990::RMD1_OFLO, rmd1_names[3]);
                    266:                MonitorBit(rmd[1], AM7990::RMD1_CRC,  rmd1_names[4]);
                    267:                MonitorBit(rmd[1], AM7990::RMD1_BUFF, rmd1_names[5]);
                    268:                MonitorBit(rmd[1], AM7990::RMD1_STP,  rmd1_names[6]);
                    269:                MonitorBit(rmd[1], AM7990::RMD1_ENP,  rmd1_names[7]);
                    270:                // BCNT は負数(2の補数)でエンコードされているので正数にデコード
                    271:                monitor.Print(x, y, "MCNT=$%03x BCNT=$%03x",
                    272:                        rmd[3] & 0xfff,
                    273:                        (-(int16)rmd[2]) & 0xfff);
                    274:                x += 20;
                    275:                monitor.Print(x, y, "buf=$%06x", ((rmd[1] & 0xff) << 16) | rmd[0]);
                    276:        }
                    277:        y++;
                    278: 
                    279:        // 他は一覧表示
                    280:        int rs;
                    281:        if (rmd_num > 48) {
                    282:                // 画面内に収まらないので仕方ないのでカーソルのある16個ブロックが
                    283:                // 常に中央にくるようにローテートするのはどうか。
                    284:                rs = (((rmd_cur - 16 + rmd_num) % rmd_num) / 16) * 16;
                    285:        } else {
                    286:                // 画面内に収まるので最初から書いていくだけ
                    287:                rs = 0;
                    288:        }
                    289:        for (x = 0; x < 3; x++) {
                    290:                for (i = 0; i < 16 && rs < rmd_num; i++) {
                    291:                        rmd_addr = rmd_base + rs * 8;
                    292:                        for (int j = 0; j < countof(rmd); j++) {
                    293:                                rmd[j] = PeekMem(rmd_addr + j * 2);
                    294:                        }
                    295:                        monitor.Print(x * 27, y + i,
                    296:                                (rs == rmd_cur) ? TA::Em : TA::Normal,
                    297:                                "%02x %c%c%c%c%c%c $%05x $%03x/$%03x",
                    298:                                rs,
                    299:                                (rmd[1] & AM7990::RMD1_OWN)  ? 'O' : '-',
                    300:                                (rmd[1] & AM7990::RMD1_OFLO) ? 'F' : '-',
                    301:                                (rmd[1] & AM7990::RMD1_CRC)  ? 'C' : '-',
                    302:                                (rmd[1] & AM7990::RMD1_BUFF) ? 'B' : '-',
                    303:                                (rmd[1] & AM7990::RMD1_STP)  ? 'S' : '-',
                    304:                                (rmd[1] & AM7990::RMD1_ENP)  ? 'E' : '-',
                    305:                                ((rmd[1] & 0xff) << 16 | rmd[0]),
                    306:                                rmd[3] & 0xfff,
                    307:                                (-(int16)rmd[2]) & 0xfff);
                    308: 
                    309:                        // 画面内に収まらない場合は折り返し。
                    310:                        // 収まる場合はこのまま rmd_num を超えればループを抜ける。
                    311:                        rs++;
                    312:                        if (rmd_num > 48 && rs >= rmd_num) {
                    313:                                rs = 0;
                    314:                        }
                    315:                }
                    316:        }
                    317:        y += 17;
                    318: 
                    319:        // TMD
1.1.1.4   root      320:        monitor.Puts(0, y, "<TMD>");
1.1       root      321: 
                    322:        uint16 tmd[4];
                    323:        uint32 tmd_addr;
                    324:        // 現行ディスクリプタは詳細表示
                    325:        if (tmd_num > 0) {
                    326:                tmd_addr = tmd_base + tmd_cur * 8;
                    327:                for (int j = 0; j < countof(tmd); j++) {
                    328:                        tmd[j] = PeekMem(tmd_addr + j * 2);
                    329:                }
                    330:                // MORE, ONE, DEF と LCOL, LCAR, RTRY, TDR は発生し得ないので省略
                    331:                x = 6;
                    332:                monitor.Print(x, y, "Current %02x ", tmd_cur); x += 11;
                    333:                MonitorBit(tmd[1], AM7990::TMD1_OWN,  tmd1_names[0]);
                    334:                MonitorBit(tmd[1], AM7990::TMD1_ERR,  tmd1_names[1]);
                    335:                MonitorBit(tmd[1], AM7990::TMD1_STP,  tmd1_names[6]);
                    336:                MonitorBit(tmd[1], AM7990::TMD1_ENP,  tmd1_names[7]);
                    337:                x += 1;
                    338:                MonitorBit(tmd[3], AM7990::TMD3_BUFF, tmd3_names[0]);
                    339:                MonitorBit(tmd[3], AM7990::TMD3_UFLO, tmd3_names[1]);
                    340:                // BCNT は負数(2の補数)でエンコードされているので正数にデコード
                    341:                monitor.Print(x, y, "BCNT=$%03x", (-(int16)tmd[2]) & 0xfff);
                    342:                x += 10;
                    343:                monitor.Print(x, y, "buf=$%06x", ((tmd[1] & 0xff) << 16) | tmd[0]);
                    344:        }
                    345:        y++;
                    346: 
                    347:        // 他は一覧表示
                    348:        int ts;
                    349:        if (tmd_num > 24) {
                    350:                // 画面内に収まらないので仕方ないのでカーソルのある16個ブロックが
                    351:                // 常に中央にくるようにローテートするのはどうか。
                    352:                ts = (((tmd_cur - 16 + tmd_num) % tmd_num) / 16) * 16;
                    353:        } else {
                    354:                // 画面内に収まるので最初から書いていくだけ
                    355:                ts = 0;
                    356:        }
                    357:        for (x = 0; x < 3; x++) {
                    358:                for (i = 0; i < 8 && ts < tmd_num; i++) {
                    359:                        tmd_addr = tmd_base + ts * 8;
                    360:                        for (int j = 0; j < countof(tmd); j++) {
                    361:                                tmd[j] = PeekMem(tmd_addr + j * 2);
                    362:                        }
                    363:                        monitor.Print(x * 27, y + i,
                    364:                                (ts == tmd_cur) ? TA::Em : TA::Normal,
                    365:                                "%02x %c%c%c%c%c  $%05x $%03x",
                    366:                                ts,
                    367:                                (tmd[1] & AM7990::TMD1_OWN)  ? 'O' : '-',
                    368:                                (tmd[1] & AM7990::TMD1_STP)  ? 'S' : '-',
                    369:                                (tmd[1] & AM7990::TMD1_ENP)  ? 'E' : '-',
                    370:                                (tmd[3] & AM7990::TMD3_BUFF) ? 'B' : '-',
                    371:                                (tmd[3] & AM7990::TMD3_UFLO) ? 'U' : '-',
                    372:                                ((tmd[1] & 0xff) << 16 | tmd[0]),
                    373:                                (-(int16)tmd[2]) & 0xfff);
                    374: 
                    375:                        // 画面内に収まらない場合は折り返し。
                    376:                        // 収まる場合はこのまま rmd_num を超えればループを抜ける。
                    377:                        ts++;
                    378:                        if (tmd_num > 24 && ts >= tmd_num) {
                    379:                                ts = 0;
                    380:                        }
                    381:                }
                    382:        }
                    383: }
                    384: 
                    385: // レジスタをビットごとに表示する。
                    386: // data は下位8ビットのみ使用し、上位は無視する。
                    387: void
1.1.1.5 ! root      388: LanceDevice::MonitorReg(TextScreen& monitor,
        !           389:        int x, int y, uint32 data, const char * const *names)
1.1       root      390: {
                    391:        for (int i = 0; i < 8; i++) {
                    392:                bool b = data & (1 << (7 - i));
1.1.1.4   root      393:                monitor.Puts(x + i * 5, y, TA::OnOff(b), names[i]);
1.1       root      394:        }
                    395: }
                    396: 
                    397: 
                    398: // 現在選択されているレジスタを読み出す
                    399: uint32
                    400: LanceDevice::ReadData()
                    401: {
                    402:        uint32 data;
                    403: 
                    404:        std::unique_lock<std::mutex> lock(mtx);
                    405: 
                    406:        // XXX CSR[123] は STOP 中だけ読める。そうでない時は未定義値になる。
                    407:        switch (reg.rap) {
                    408:         case 0:
                    409:         {
                    410:                data = reg.GetCSR0();
                    411:                const std::string name = CSR0ToString(data);
                    412:                putlog(2, "CSR0 -> $%04x<%s>", data, name.c_str());
                    413:                break;
                    414:         }
                    415:         case 1:
                    416:                if (reg.IsSTOP()) {
                    417:                        data = reg.iadr & 0xffff;
                    418:                        putlog(2, "CSR%d -> $%04x", reg.rap, data);
                    419:                } else {
                    420:                        data = 0xcccc & AM7990::CSR1_MASK;
                    421:                        putlog(2, "CSR%d -> $%04x (不定読み出し)", reg.rap, data);
                    422:                }
                    423:                break;
                    424:         case 2:
                    425:                if (reg.IsSTOP()) {
                    426:                        data = reg.iadr >> 16;
                    427:                        putlog(2, "CSR%d -> $%04x", reg.rap, data);
                    428:                } else {
                    429:                        data = 0xcccc & AM7990::CSR2_MASK;
                    430:                        putlog(2, "CSR%d -> $%04x (不定読み出し)", reg.rap, data);
                    431:                }
                    432:                break;
                    433:         case 3:
                    434:                if (reg.IsSTOP()) {
                    435:                        data = reg.csr3;
                    436:                        const std::string name = CSR3ToString(data);
                    437:                        putlog(2, "CSR%d -> $%04x<%s>", reg.rap, data, name.c_str());
                    438:                } else {
                    439:                        data = 0xcccc & AM7990::CSR3_MASK;
                    440:                        putlog(2, "CSR%d -> $%04x (不定読み出し)", reg.rap, data);
                    441:                }
                    442:                break;
                    443:         default:
                    444:                __unreachable();
                    445:        }
                    446:        return data;
                    447: }
                    448: 
                    449: // 現在選択されてるレジスタに data を書き込む
                    450: void
                    451: LanceDevice::WriteData(uint32 data)
                    452: {
                    453:        std::unique_lock<std::mutex> lock(mtx);
                    454: 
                    455:        switch (reg.rap) {
                    456:         case 0:
                    457:         {
                    458:                // CSR0 は STOP ビットによらず書き込み可能
                    459:                const std::string name = CSR0ToString(data);
                    460:                putlog(2, "CSR0 <- $%04x<%s>", data, name.c_str());
                    461: 
                    462:                // STOP,STRT,INIT 全部立てると STOP のみ有効 (AM7990.pdf, p17)。
                    463:                // STOP は実質リセットなので、これ立ってたらもうそれで終わりだろう。
                    464:                if ((data & AM7990::CSR0_STOP)) {
                    465:                        ChipStop();
                    466:                        break;
                    467:                }
                    468: 
                    469:                if ((data & AM7990::CSR0_INIT)) {
                    470:                        ChipInit();
                    471:                }
                    472:                if ((data & AM7990::CSR0_STRT)) {
                    473:                        ChipStart();
                    474:                }
                    475: 
                    476:                // TDMD はセットオンリー (チップがクリアする)
                    477:                if ((data & AM7990::CSR0_TDMD)) {
                    478:                        reg.csr0 |= AM7990::CSR0_TDMD;
                    479:                }
                    480: 
                    481:                // 書き込みがビットクリアになる人たち
                    482:                if ((data & AM7990::CSR0_IDON)) {
                    483:                        reg.csr0 &= ~AM7990::CSR0_IDON;
                    484:                }
                    485:                if ((data & AM7990::CSR0_TINT)) {
                    486:                        reg.csr0 &= ~AM7990::CSR0_TINT;
                    487:                }
                    488:                if ((data & AM7990::CSR0_RINT)) {
                    489:                        reg.csr0 &= ~AM7990::CSR0_RINT;
                    490:                }
                    491:                if ((data & AM7990::CSR0_MERR)) {
                    492:                        reg.csr0 &= ~AM7990::CSR0_MERR;
                    493:                }
                    494:                if ((data & AM7990::CSR0_MISS)) {
                    495:                        reg.csr0 &= ~AM7990::CSR0_MISS;
                    496:                }
                    497:                if ((data & AM7990::CSR0_CERR)) {
                    498:                        reg.csr0 &= ~AM7990::CSR0_CERR;
                    499:                }
                    500:                if ((data & AM7990::CSR0_BABL)) {
                    501:                        reg.csr0 &= ~AM7990::CSR0_BABL;
                    502:                }
                    503: 
                    504:                // INEA は %0 も %1 も書き込める
                    505:                // INEA は STOP 中は設定できない
                    506:                if (!reg.IsSTOP()) {
                    507:                        uint16 old_inea = reg.csr0 & AM7990::CSR0_INEA;
                    508:                        uint16 new_inea = data & AM7990::CSR0_INEA;
                    509:                        reg.csr0 &= ~AM7990::CSR0_INEA;
                    510:                        reg.csr0 |= new_inea;
                    511: 
                    512:                        // INEA が 0->1 に変化して、INTR 立ってたら割り込み上げる?
                    513:                        if (old_inea == 0 && new_inea != 0 && reg.IsINTR()) {
                    514:                                Interrupt();
                    515:                        }
                    516:                }
                    517:                break;
                    518:         }
                    519: 
                    520:         case 1:
                    521:                // STOP 中のみ書き込み可能。そうでない時は無視する。
                    522:                if (reg.IsSTOP()) {
                    523:                        reg.iadr = (reg.iadr & 0xff0000) | (data & AM7990::IADR_L_MASK);
                    524:                        putlog(2, "IDAR(L)=$%06x", reg.iadr);
                    525:                }
                    526:                break;
                    527: 
                    528:         case 2:
                    529:                // STOP 中のみ書き込み可能。そうでない時は無視する。
                    530:                if (reg.IsSTOP()) {
                    531:                        reg.iadr = ((data & AM7990::IADR_H_MASK) << 16)
                    532:                                 | (reg.iadr & 0xffff);
                    533:                        putlog(2, "IDAR(H)=$%06x", reg.iadr);
                    534:                }
                    535:                break;
                    536: 
                    537:         case 3:
                    538:                // STOP 中のみ書き込み可能。そうでない時は無視する。
                    539:                if (reg.IsSTOP()) {
                    540:                        reg.csr3 = data & AM7990::CSR3_MASK;
                    541:                        const std::string name = CSR3ToString(reg.csr3);
                    542:                        putlog(2, "CSR3 <- $%04x<%s>", reg.csr3, name.c_str());
                    543:                }
                    544:                break;
                    545: 
                    546:         default:
                    547:                __unreachable();
                    548:        }
                    549: }
                    550: 
                    551: // メモリアクセスについて。
                    552: // AM7990 から見たメモリは LUNA の 3ポートSRAM (ここでは ZRAM デバイス)。
                    553: //
                    554: // AM7990 は CSR3.BSWP が %0 ならリトルエンディアンアクセス、
                    555: // %1 ならビッグエンディアンアクセス。
                    556: // 一方、RAMDevice.Read16() はビッグエンディアン動作になるので、
                    557: // BSWP==%0 ならバイトスワップする。ホストのエンディアンには無関係。
                    558: 
                    559: // メモリから1ワード読み込む。paddr はワードアラインしていること。
                    560: // バスエラーは起きない。
                    561: uint64
                    562: LanceDevice::ReadMem(uint32 paddr)
                    563: {
                    564:        uint64 data;
                    565: 
1.1.1.3   root      566:        assertmsg((paddr & 1) == 0, "paddr=$%x", paddr);
1.1       root      567: 
                    568:        // XXX 3ポートRAM のエンディアンとかを調べること
                    569:        data = gZRAM->Read16(paddr);
                    570:        if (!reg.IsBSWP()) {
                    571:                data = __builtin_bswap16(data);
                    572:        }
                    573: 
                    574:        // XXX 所要クロックを考察すること
                    575: 
                    576:        return data;
                    577: }
                    578: 
                    579: // メモリに1ワード書き込む。paddr はワードアラインしていること。
                    580: uint64
                    581: LanceDevice::WriteMem(uint32 paddr, uint32 data)
                    582: {
1.1.1.3   root      583:        assertmsg((paddr & 1) == 0, "paddr=$%x", paddr);
1.1       root      584: 
                    585:        if (!reg.IsBSWP()) {
                    586:                data = __builtin_bswap16(data);
                    587:        }
                    588: 
                    589:        // XXX 所要クロックを考察すること
                    590: 
                    591:        gZRAM->Write16(paddr, data);
                    592:        return 0;
                    593: }
                    594: 
                    595: // メモリ (3ポートSRAM) から1ワードピークする。バスエラーは起きない。
                    596: uint64
                    597: LanceDevice::PeekMem(uint32 paddr)
                    598: {
                    599:        uint64 data;
                    600: 
                    601:        paddr &= 0x1ffff;
                    602:        paddr += 0x71000000;    // XXX 定数にしたほうがいい
                    603: 
                    604:        if (reg.IsBSWP()) {
                    605:                // ビッグエンディアンアクセス
1.1.1.3   root      606:                data = vm_phys_peek_8(paddr) << 8;
                    607:                data |= vm_phys_peek_8(paddr + 1);
1.1       root      608:        } else {
                    609:                // リトルエンディアンアクセス
1.1.1.3   root      610:                data = vm_phys_peek_8(paddr);
                    611:                data |= vm_phys_peek_8(paddr + 1) << 8;
1.1       root      612:        }
                    613:        return data;
                    614: }
                    615: 
                    616: // INIT ビットによるチップ初期化。
                    617: // ロック状態で呼ばれる。
                    618: void
                    619: LanceDevice::ChipInit()
                    620: {
                    621:        // INIT をセットすると STOP ビットはクリア
                    622:        reg.csr0 |=  AM7990::CSR0_INIT;
                    623:        reg.csr0 &= ~AM7990::CSR0_STOP;
                    624: 
                    625:        // Initialization Block を読み込む
                    626:        for (int i = 0; i < countof(initblock); i++) {
                    627:                initblock[i] = ReadMem(reg.iadr + i * 2);
                    628:        }
                    629:        if (0) {
                    630:                for (int i = 0; i < countof(initblock); i++) {
                    631:                        putlog(3, "initblock[%d] = $%04x", i, initblock[i]);
                    632:                }
                    633:        }
                    634: 
                    635:        // 送受信ディスクリプタ用の内部変数を設定
                    636:        uint32 rdrp = initblock[8] | (initblock[9] << 16);
                    637:        rmd_base = rdrp & 0xfffffc;
                    638:        int rlen = rdrp >> 29;
                    639:        rmd_num  = (1 << rlen);
                    640: 
                    641:        uint32 tdrp = initblock[10] | (initblock[11] << 16);
                    642:        tmd_base = tdrp & 0xfffffc;
                    643:        int tlen = tdrp >> 29;
                    644:        tmd_num  = (1 << tlen);
                    645: 
                    646:        // XXX 本当はいろいろ時間がかかりそうなはずだが
                    647:        // 初期化完了
                    648:        SetInterrupt(AM7990::CSR0_IDON);
                    649: }
                    650: 
                    651: // STRT ビットによるスタート。
                    652: // ロック状態で呼ばれる。
                    653: void
                    654: LanceDevice::ChipStart()
                    655: {
                    656:        putlog(1, "スタート");
                    657: 
                    658:        // STRT を書き込むと STOP はクリア
                    659:        reg.csr0 |=  AM7990::CSR0_STRT;
                    660:        reg.csr0 &= ~AM7990::CSR0_STOP;
                    661: 
                    662:        // MODE の DTX がクリアなら TXON をセット?
                    663:        // XXX 実際はタイミング違う気がする
                    664:        // INIT で DTX==%0 ならトランスミッタがオンになり、
                    665:        // トランスミッタがオンで STRT すると TXON がオンになる、ように読めるが
                    666:        // トランスミッタは省略してみる。
                    667:        // RX 側も同様。
                    668:        if ((initblock[0] & AM7990::IBMODE_DTX) == 0) {
                    669:                reg.csr0 |= AM7990::CSR0_TXON;
                    670:        }
                    671:        if ((initblock[0] & AM7990::IBMODE_DRX) == 0) {
                    672:                reg.csr0 |= AM7990::CSR0_RXON;
                    673:                // ホストからのパケット受信を許可。
                    674:                RecvEnabled = true;
                    675:        }
                    676: 
                    677:        // 初回読み込みに備えて RMD1/TMD1 の先読みバッファを無効化する
                    678:        rmd1_ahead = (uint32)-1;
                    679:        tmd1_ahead = (uint32)-1;
                    680: 
                    681:        // ワーカスレッドに通知
                    682:        request |= REQ_TXIDLE | REQ_RXIDLE;
                    683:        cv.notify_one();
                    684: }
                    685: 
                    686: // STOP ビットによるチップリセット。
                    687: // ハードリセットもここに来る。
                    688: // ロック状態で呼ばれる。
                    689: void
                    690: LanceDevice::ChipStop()
                    691: {
                    692:        putlog(1, "リセット");
                    693: 
                    694:        // STOPセットで CSR0 は STOP セット、他は全クリア
                    695:        reg.csr0 = AM7990::CSR0_STOP;
                    696:        // CSR1, 2 は不定
                    697:        // CSR3 はクリア
                    698:        reg.csr3 = 0;
                    699: 
                    700:        // 内部ポインタも戻す
                    701:        tmd_cur = 0;
                    702:        rmd_cur = 0;
                    703: 
                    704:        // イベントを(あれば)停止。
1.1.1.3   root      705:        rx_event.Stop();
                    706:        tx_event.Stop();
1.1       root      707: 
                    708:        // 受信を停止
                    709:        RecvEnabled = false;
                    710: }
                    711: 
                    712: // 割り込み要因を CSR0 にセットし、許可されていれば割り込みを上げる。
                    713: void
                    714: LanceDevice::SetInterrupt(uint32 bit)
                    715: {
                    716:        reg.csr0 |= bit;
                    717: 
                    718:        Interrupt();
                    719: }
                    720: 
                    721: // 許可されていれば割り込みを上げる。
                    722: void
                    723: LanceDevice::Interrupt()
                    724: {
                    725:        if ((reg.csr0 & AM7990::CSR0_INEA)) {
                    726:                putlog(2, "割り込み");
1.1.1.4   root      727:                gMPU->Interrupt(this, 3);
1.1       root      728:        } else {
                    729:                putlog(2, "割り込みはマスクされている");
                    730:        }
                    731: }
                    732: 
                    733: // ワーカスレッドのエントリポイント
                    734: void *
                    735: lance_run(void *dummy)
                    736: {
1.1.1.4   root      737:        PTHREAD_SETNAME("Lance worker");
1.1       root      738: 
1.1.1.3   root      739:        dynamic_cast<LanceDevice*>(gEthernet.get())->ThreadRun();
1.1       root      740:        return NULL;
                    741: }
                    742: 
                    743: // ワーカスレッド
                    744: void
                    745: LanceDevice::ThreadRun()
                    746: {
                    747:        for (;;) {
                    748:                uint32 req;
                    749: 
                    750:                // 何か起きるまで待つ
                    751:                std::unique_lock<std::mutex> lock(mtx);
                    752:                cv.wait(lock, [&] { return (request != 0); });
                    753:                // request のほうはもうここでリセットして、コピーのほうを使う
                    754:                req = request;
                    755:                request = 0;
                    756: 
                    757:                if ((req & REQ_TERMINATE)) {
                    758:                        // 終了するので、他のフラグは無視
                    759:                        break;
                    760:                }
                    761: 
                    762:                // デバッグ用に TMD の OWN,STP,ENP に変更があれば表示する
                    763:                if (1) {
                    764:                        std::string tmdstr;
                    765:                        for (int i = 0; i < tmd_num; i++) {
                    766:                                uint16 tmd1_ = PeekMem(tmd_base + i * 8 + 2);
                    767:                                tmdstr += string_format(" %c%c%c",
                    768:                                        (tmd1_ & AM7990::TMD1_OWN) ? 'W' : '-',
                    769:                                        (tmd1_ & AM7990::TMD1_STP) ? 'S' : '-',
                    770:                                        (tmd1_ & AM7990::TMD1_ENP) ? 'E' : '-');
                    771:                        }
                    772:                        if (tmdstr != last_tmdstr) {
                    773:                                putlog(3, "TMD %s", tmdstr.c_str());
                    774:                                last_tmdstr = tmdstr;
                    775:                        }
                    776:                }
                    777: 
1.1.1.4   root      778: #define dispatch(flag, func) do { \
1.1       root      779:                if ((req & (flag))) { \
                    780:                        req &= ~(flag); \
                    781:                        (func)(); \
1.1.1.4   root      782:                } \
                    783: } while (0)
1.1       root      784: 
                    785:                dispatch(REQ_TXIDLE,    TXIdle);
                    786:                dispatch(REQ_TXCOPY,    TXCopy);
                    787:                dispatch(REQ_TXSEND,    TXSend);
                    788:                dispatch(REQ_TXNEXT,    TXNext);
                    789: 
                    790:                dispatch(REQ_RXIDLE,    RXIdle);
                    791:                dispatch(REQ_RXCOPY,    RXCopy);
                    792:                dispatch(REQ_RXNEXT,    RXNext);
                    793:                dispatch(REQ_RXMISS,    RXMiss);
                    794:                dispatch(REQ_RXRECV,    RXRecv);
                    795: 
1.1.1.3   root      796:                assertmsg(req == 0, "req=$%x", req);
1.1       root      797:        }
                    798: }
                    799: 
1.1.1.3   root      800: // スレッドの終了を指示
                    801: void
                    802: LanceDevice::Terminate()
                    803: {
                    804:        assert(thread_created);
                    805: 
                    806:        std::unique_lock<std::mutex> lock(mtx);
                    807:        request |= REQ_TERMINATE;
                    808:        cv.notify_one();
                    809: }
                    810: 
1.1       root      811: // TXIDLE 送信アイドルフェーズ。
                    812: // ディスクリプタを所有できるかポーリングする。
                    813: // - 所有できれば PUSH フェーズへ。
                    814: // - 所有できない場合、TDMD オンなら即、オフなら 1.6ms 待ってから再び POLL へ。
                    815: void
                    816: LanceDevice::TXIdle()
                    817: {
                    818:        // TMD1 を読み込む
                    819:        if ((int32)tmd1_ahead >= 0) {
                    820:                // すでに先読みしてあればそれを使う
                    821:                tmd1 = tmd1_ahead;
                    822:        } else {
                    823:                // 読み込む
                    824:                uint32 tmd_addr = tmd_base + tmd_cur * 8;
                    825:                tmd1 = ReadMem(tmd_addr + 2);
                    826:        }
                    827:        // どちらにしても先読みバッファは無効に戻す
                    828:        tmd1_ahead = (uint32)-1;
                    829: 
                    830:        // その TMD1 に OWN と STP が立っているか
                    831:        if ((tmd1 & AM7990::TMD1_OWN) && (tmd1 & AM7990::TMD1_STP)) {
                    832:                // 取り込みへ
                    833:                request |= REQ_TXCOPY;
                    834:                return;
                    835:        }
                    836: 
                    837:        // 立っていなければ
                    838:        if ((reg.csr0 & AM7990::CSR0_TDMD)) {
                    839:                // TDMD がオンなら即再実行。
                    840:                request |= REQ_TXIDLE;
                    841:        } else {
                    842:                // TDMD がオフなら 1.6ms 待って再度 POLL へ。
                    843:                tx_event.time = 1.6_msec;
                    844:                tx_event.code = REQ_TXIDLE;
1.1.1.3   root      845:                tx_event.Start();
1.1       root      846:        }
                    847: }
                    848: 
                    849: // TXCOPY バッファ処理フェーズ。
                    850: // 現ディスクリプタのバッファの内容をメモリから読み込み、
                    851: // それにかかる時間相当分をウェイトする。
                    852: // - ENP ならウェイトした後 SEND フェーズへ。
                    853: // - 次 TMD が OWN できればウェイトした後 NEXT フェーズへ。
                    854: // - 次 TMD が OWN 出来なければウェイトした後 SEND フェーズ。
                    855: void
                    856: LanceDevice::TXCopy()
                    857: {
                    858:        // TMD0, TMD2 は送信することが確定してから読み出す
                    859:        uint32 tmd_addr = tmd_base + tmd_cur * 8;
                    860:        uint16 tmd0 = ReadMem(tmd_addr);
                    861:        uint16 tmd2 = ReadMem(tmd_addr + 4);
                    862: 
                    863:        // アドレスと送信バイト数。送信バイト数は2の補数。
                    864:        uint32 bufsrc = ((tmd1 & 0x00ff) << 16) | tmd0;
                    865:        uint32 src = bufsrc;
                    866:        int32 bcnt = (int32)(int16)tmd2;
                    867: 
                    868:        // ローカルの送信バッファにコピー
                    869:        for (; bcnt < 0; ) {
                    870:                // XXX バーストコピー未対応
                    871:                // XXX BSWP==0の時のバッファ内のエンディアンとかは?
                    872: 
                    873:                if (bcnt <= -2 && (src & 1) == 0) {
                    874:                        // 2バイト以上残っててワード境界ならワードアクセス
                    875:                        uint16 data = ReadMem(src);
                    876:                        txq.push_back(data >> 8);
                    877:                        txq.push_back(data & 0xff);
                    878:                        src += 2;
                    879:                        bcnt += 2;
                    880:                } else if ((src & 1) == 0) {
                    881:                        // 偶数アドレスから1バイト
                    882:                        uint16 data = ReadMem(src);
                    883:                        txq.push_back(data >> 8);
                    884:                        src += 1;
                    885:                        bcnt += 1;
                    886:                } else {
                    887:                        // 奇数アドレスから1バイト
                    888:                        uint16 data = ReadMem(src & ~1);
                    889:                        txq.push_back(data & 0xff);
                    890:                        src += 1;
                    891:                        bcnt += 1;
                    892:                }
                    893:        }
                    894: 
                    895:        // ここが ENP なら、送信のため TXSEND フェーズへ
                    896:        if ((tmd1 & AM7990::TMD1_ENP)) {
                    897:                tx_event.code = REQ_TXSEND;
                    898:        } else {
                    899:                // 次のディスクリプタを先読み
                    900:                tmd_addr = tmd_base + ((tmd_cur + 1) % tmd_num) * 8;
                    901:                tmd1_ahead = ReadMem(tmd_addr + 2);
                    902: 
                    903:                if ((tmd1_ahead & AM7990::TMD1_OWN)) {
                    904:                        // 次ディスクリプタが所有できれば TXNEXT フェーズへ
                    905:                        tx_event.code = REQ_TXNEXT;
                    906:                } else {
                    907:                        // この時点で所有できなければアンダーフロー。
                    908:                        // ここまでのバッファでパケットを送信するため TXSEND へ。
                    909:                        // エラーフラグの処理は TXSEND 側で行う。
                    910:                        tx_event.code = REQ_TXSEND;
                    911:                }
                    912:        }
                    913: 
                    914:        // メモリからの転送にかかった時間をざっくり計算 XXX まだ適当
                    915:        // そのウェイト後に指定のフェーズへ。
                    916:        tx_event.time = 700 * (src - bufsrc) / 16;
1.1.1.3   root      917:        tx_event.Start();
1.1       root      918: }
                    919: 
                    920: // TXSEND フェーズ。パケットを送信。
                    921: // ただし ENP でなければアンダーフローによるパケット送信なのでフラグ処理。
                    922: // その後 TXNEXT フェーズへ。
                    923: void
                    924: LanceDevice::TXSend()
                    925: {
                    926:        // 送信
                    927:        SendPacket(txq);
                    928:        txq.clear();
                    929: 
                    930:        // TDMD は1回送ると下ろすのかな
                    931:        reg.csr0 &= ~AM7990::CSR0_TDMD;
                    932: 
                    933:        // ENP でなければアンダーフローによるものだった
                    934:        if ((tmd1 & AM7990::TMD1_ENP) == 0) {
                    935:                // TMD3 はここで書き出す
                    936:                // XXX 読まずに書くだけもいいはず?
                    937:                uint32 tmd_addr = tmd_base + tmd_cur * 8;
                    938:                uint16 tmd3 = ReadMem(tmd_addr + 6);
                    939:                tmd3 |= AM7990::TMD3_BUFF | AM7990::TMD3_UFLO;
                    940:                WriteMem(tmd_addr + 6, tmd3);
                    941: 
                    942:                // TMD1 は NEXT フェーズで書き戻す
                    943:                tmd1 |= AM7990::TMD1_ERR;
                    944:        }
                    945: 
                    946:        // どちらにしても送信割り込み
                    947:        SetInterrupt(AM7990::CSR0_TINT);
                    948: 
                    949:        request |= REQ_TXNEXT;
                    950: }
                    951: 
                    952: // TXNEXT フェーズ。次のディスクリプタを指して TXIDLE へ。
                    953: void
                    954: LanceDevice::TXNext()
                    955: {
                    956:        // このディスクリプタの所有権を放棄
                    957:        tmd1 &= ~AM7990::TMD1_OWN;
                    958:        uint32 tmd_addr = tmd_base + tmd_cur * 8;
                    959:        WriteMem(tmd_addr + 2, tmd1);
                    960: 
                    961:        // 次のディスクリプタへ
                    962:        tmd_cur = (tmd_cur + 1) % tmd_num;
                    963: 
                    964:        request |= REQ_TXIDLE;
                    965: }
                    966: 
                    967: // パケット受信。
                    968: // これは mtx 取得状態で Nerdriver スレッドから呼ばれるので、
                    969: // パケットを手元にコピーして VM スレッドに通知を出すだけ。
                    970: bool
                    971: LanceDevice::RecvPacket(qvector<uint8>& buf)
                    972: {
                    973:        if (rxq.empty() == false) {
                    974:                // 前のパケットをまだ処理中なので、このパケットは捨てる
                    975:                putlog(2, "%s: discard %zd bytes", __func__, buf.size());
                    976:                return true;
                    977:        }
                    978:        putlog(3, "%s: %zd bytes", __func__, buf.size());
                    979: 
                    980:        // コピー
                    981:        rxq = buf;
                    982: 
                    983:        // 通知
                    984:        request |= REQ_RXRECV;
                    985:        cv.notify_one();
                    986:        return true;
                    987: }
                    988: 
                    989: // RXIDLE 受信アイドルフェーズ。
                    990: // (最初の)ディスクリプタを所有できるかポーリングする。
                    991: void
                    992: LanceDevice::RXIdle()
                    993: {
                    994:        putlog(3, "%s[%d]", __func__, rmd_cur);
                    995:        // RMD1 を読み込む
                    996:        if ((int32)rmd1_ahead >= 0) {
                    997:                // すでにあればそれを使う
                    998:                rmd1 = rmd1_ahead;
                    999:        } else {
                   1000:                // 読み込む
                   1001:                uint32 rmd_addr = rmd_base + rmd_cur * 8;
                   1002:                rmd1 = ReadMem(rmd_addr + 2);
                   1003:        }
                   1004:        // どちらにしても先読みバッファは無効に戻す
                   1005:        rmd1_ahead = (uint32)-1;
                   1006: 
                   1007:        // その RMD1 に OWN が立っているか
                   1008:        if ((rmd1 & AM7990::RMD1_OWN)) {
                   1009:                // ここが STP になる
                   1010:                rmd1 |= AM7990::RMD1_STP;
                   1011: 
                   1012:                // パケットを受信するまで何もすることはないのでフラグ立てずに戻る
                   1013:                return;
                   1014:        }
                   1015: 
                   1016:        // 立っていなければ
                   1017:        // 1.6ms 待って再度 RXIDLE へ。
                   1018:        rx_event.time = 1.6_msec;
                   1019:        rx_event.code = REQ_RXIDLE;
1.1.1.3   root     1020:        rx_event.Start();
1.1       root     1021: }
                   1022: 
                   1023: // RXRECV 先頭ディスクリプタ開始フェーズ。
                   1024: // - OWN していれば RXCOPY へ。
                   1025: // - していなければ、パケット長相当分ウェイトしてから RXMISS へ。
                   1026: void
                   1027: LanceDevice::RXRecv()
                   1028: {
                   1029:        putlog(3, "%s[%d]", __func__, rmd_cur);
                   1030:        if ((rmd1 & AM7990::RMD1_OWN)) {
                   1031:                // 所有しているのでコピー処理へ
                   1032:                request |= REQ_RXCOPY;
                   1033:        } else {
                   1034:                // パケットを受信してる時間に相当するウェイト XXX 適当
                   1035:                rx_event.time = 700 * rxq.size() / 16;
                   1036:                rx_event.code = REQ_RXMISS;
1.1.1.3   root     1037:                rx_event.Start();
1.1       root     1038:        }
                   1039: }
                   1040: 
                   1041: // RXCOPY バッファ処理フェーズ。
                   1042: // 受信バッファからディスクリプタのバッファに書き込み、
                   1043: // 書き込みにかかる時間相当分をウェイトする。
                   1044: void
                   1045: LanceDevice::RXCopy()
                   1046: {
                   1047:        putlog(3, "%s[%d]", __func__, rmd_cur);
                   1048:        // RMD0, RMD2 は受信することが確定してから読み出す
                   1049:        uint32 rmd_addr = rmd_base + rmd_cur * 8;
                   1050:        uint16 rmd0 = ReadMem(rmd_addr);
                   1051:        uint16 rmd2 = ReadMem(rmd_addr + 4);
                   1052: 
                   1053:        // アドレスと受信バッファのバイト数。バッファサイズは2の補数。
                   1054:        uint32 bufdst = ((rmd1 & 0x00ff) << 16) | rmd0;
                   1055:        uint32 dst = bufdst;
                   1056:        int32 bcnt = (int32)(int16)rmd2;
                   1057: 
                   1058:        // ローカルの受信バッファからディスクリプタバッファにコピー
                   1059:        for (; bcnt < 0; ) {
                   1060:                int remsize = rxq.size();
                   1061:                if (remsize == 0) {
                   1062:                        break;
                   1063:                }
                   1064: 
                   1065:                // XXX バーストコピー未対応
                   1066:                // XXX BSWP==0の時のバッファ内のエンディアンとかは?
                   1067:                uint16 data;
                   1068:                if (bcnt <= -2 && remsize >= 2 && (dst & 1) == 0) {
                   1069:                        // 2バイト以上残っててワード境界ならワードアクセス
                   1070:                        data  = rxq.pop() << 8;
                   1071:                        data |= rxq.pop();
                   1072:                        WriteMem(dst, data);
                   1073:                        dst += 2;
                   1074:                        bcnt += 2;
                   1075:                } else if ((dst & 1) == 0) {
                   1076:                        // 偶数アドレスへ1バイト
                   1077:                        // 奇数バイトには不定データが出るらしいがここでは 0 にする
                   1078:                        data = rxq.pop() << 8;
                   1079:                        WriteMem(dst, data);
                   1080:                        dst += 1;
                   1081:                        bcnt += 1;
                   1082:                } else {
                   1083:                        // 奇数アドレスへ1バイト
                   1084:                        // 偶数バイトには不定データが出るらしいがここでは 0 にする
                   1085:                        data = rxq.pop();
                   1086:                        WriteMem(dst & ~1, data);
                   1087:                        dst += 1;
                   1088:                        bcnt += 1;
                   1089:                }
                   1090:        }
                   1091: 
                   1092:        // 全部書き出せたらここが ENP
                   1093:        if (rxq.size() == 0) {
                   1094:                rmd1 |= AM7990::RMD1_ENP;
                   1095: 
                   1096:                // ENP なら MCNT を更新
                   1097:                WriteMem(rmd_addr + 6, (dst - bufdst) & 0xfff);
                   1098:        }
                   1099: 
                   1100:        // メモリへの転送にかかった時間をざっくり計算 XXX まだ適当
                   1101:        // そのウェイト後に RXNEXT フェーズへ。
                   1102:        rx_event.time = 700 * (dst - bufdst) / 16;
                   1103:        rx_event.code = REQ_RXNEXT;
1.1.1.3   root     1104:        rx_event.Start();
1.1       root     1105: }
                   1106: 
                   1107: // RXNEXT フェーズ。
                   1108: // ここが ENP なら、次のディスクリプタを指して RXIDLE へ。
                   1109: // ENP でなければ、
                   1110: // - 次のディスクリプタが所有できれば引き続き書き出すため RXCOPY へ。
                   1111: // - 次のディスクリプタが所有できなければエラーにして RXIDLE へ。
                   1112: void
                   1113: LanceDevice::RXNext()
                   1114: {
                   1115:        putlog(3, "%s[%d]", __func__, rmd_cur);
                   1116: 
                   1117:        // RXCOPY フェーズで rxq が empty() になっても、(Lance スレッドの)
                   1118:        // メッセージループでここ(RXNEXT)に来るまでの間に、rxq に再び着信する
                   1119:        // 可能性はあるので、ここでは rxq を調べたり触ったりしてはいけない、
                   1120:        // はず。
                   1121: 
                   1122:        if ((rmd1 & AM7990::RMD1_ENP)) {
                   1123:                // ENP なら、RXIDLE へ。
                   1124:                request |= REQ_RXIDLE;
                   1125:        } else {
                   1126:                // 次のディスクリプタを先読み
                   1127:                uint32 rmd_addr = rmd_base + ((rmd_cur + 1) % rmd_num) * 8;
                   1128:                rmd1_ahead = ReadMem(rmd_addr + 2);
                   1129: 
                   1130:                if ((rmd1_ahead & AM7990::RMD1_OWN)) {
                   1131:                        // 次ディスクリプタが所有できれば RXCOPY へ。
                   1132:                        request |= REQ_RXCOPY;
                   1133:                } else {
                   1134:                        // この時点で所有できなければオーバーフロー。
                   1135:                        // XXX BUFF と OFLO の違いがよくわからん
                   1136:                        rmd1 |= AM7990::RMD1_BUFF | AM7990::RMD1_OFLO;
                   1137: 
                   1138:                        // 次のディスクリプタをポールするため RXIDLE へ。
                   1139:                        request |= REQ_RXIDLE;
                   1140:                }
                   1141:        }
                   1142: 
                   1143:        // このディスクリプタの所有権を放棄
                   1144:        rmd1 &= ~AM7990::RMD1_OWN;
                   1145:        uint32 rmd_addr = rmd_base + rmd_cur * 8;
                   1146: putlog(3, "%s[%d] addr=%x RMD1=%02x", __func__, rmd_cur, rmd_addr + 2, rmd1);
                   1147:        WriteMem(rmd_addr + 2, rmd1);
                   1148: 
                   1149:        // 次のディスクリプタへ
                   1150:        rmd_cur = (rmd_cur + 1) % rmd_num;
                   1151: 
                   1152:        // どちらにしても受信割り込み
                   1153:        SetInterrupt(AM7990::CSR0_RINT);
                   1154: }
                   1155: 
                   1156: // RXMISS 受信失敗処理。
                   1157: void
                   1158: LanceDevice::RXMiss()
                   1159: {
                   1160:        putlog(3, "%s", __func__);
                   1161: 
                   1162:        // 受信データがあるのにディスクリプタを所有してなければエラー
                   1163:        SetInterrupt(AM7990::CSR0_MISS | AM7990::CSR0_RINT);
                   1164: 
                   1165:        // 受信データを破棄。
                   1166:        rxq.clear();
                   1167: 
                   1168:        // そのまますぐにアイドルフェーズに戻るんだろうか
                   1169:        request |= REQ_RXIDLE;
                   1170: }
                   1171: 
                   1172: // イベントハンドラ
                   1173: void
                   1174: LanceDevice::Callback(int arg)
                   1175: {
                   1176:        std::unique_lock<std::mutex> lock(mtx);
                   1177: 
                   1178:        // ワーカスレッドにフェーズ遷移を伝えるだけ
                   1179:        request |= arg;
                   1180:        cv.notify_one();
                   1181: }
                   1182: 
                   1183: // ビット名文字列配列は [0] が MSB 側の順で並べる
                   1184: 
                   1185: /*static*/ const char * const LanceDevice::csr0names[] = {
                   1186:        "ERR",  "BABL", "CERR", "MISS", "MERR", "RINT", "TINT", "IDON",
                   1187:        "INTR", "INEA", "RXON", "TXON", "TDMD", "STOP", "STRT", "INIT",
                   1188: };
                   1189: 
                   1190: /*static*/ const char * const LanceDevice::csr3names[] = {
                   1191:        "", "", "", "", "", "", "", "", 
                   1192:        "", "", "", "", "", "BSWP", "ACON", "BCON",
                   1193: };
                   1194: 
                   1195: /*static*/ const char * const LanceDevice::ib_mode_names[] = {
                   1196:        "PROM", "INTL", "DRTY", "COLL", "DTCR", "LOOP", "DTX",  "DRX",
                   1197: };
                   1198: 
                   1199: /*static*/ const char * const LanceDevice::rmd1_names[] = {
                   1200:        "OWN",  "ERR",  "FRAM", "OFLO", "CRC",  "BUFF", "STP",  "ENP",
                   1201: };
                   1202: 
                   1203: /*static*/ const char * const LanceDevice::tmd1_names[] = {
                   1204:        "OWN",  "ERR",  "----", "MORE", "ONE",  "DEF",  "STP",  "ENP",
                   1205: };
                   1206: 
                   1207: /*static*/ const char * const LanceDevice::tmd3_names[] = {
                   1208:        "BUFF", "UFLO", "----", "LCOL", "LCAR", "BTRY", "",     "",
                   1209: };
                   1210: 
                   1211: // bits の立っているビット名を左から MSB->LSB の順で並べて返す
                   1212: const std::string
                   1213: LanceDevice::BitToString(const char * const name[], uint16 bits)
                   1214: {
                   1215:        std::string str;
                   1216: 
                   1217:        while (bits) {
                   1218:                int clz = __builtin_clz(bits) - 16;
                   1219:                if (!str.empty()) {
                   1220:                        str += ",";
                   1221:                }
                   1222:                str += name[clz];
                   1223:                bits ^= 1 << (15 - clz);
                   1224:        }
                   1225:        return str;
                   1226: }
                   1227: 
                   1228: // CSR0 のビット名を返す
                   1229: const std::string
                   1230: LanceDevice::CSR0ToString(uint16 bits)
                   1231: {
                   1232:        return BitToString(csr0names, bits);
                   1233: }
                   1234: 
                   1235: // CSR3 のビット名を返す
                   1236: const std::string
                   1237: LanceDevice::CSR3ToString(uint16 bits)
                   1238: {
                   1239:        return BitToString(csr3names, bits);
                   1240: }

unix.superglobalmegacorp.com

This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.