Return to console_tcp.cpp CVS log

Up to [Isaki's NoNo m68k/m88k emulator] / nono / debugger

Annotation of nono/debugger/console_tcp.cpp, revision 1.1.1.1

1.1       root        1: //
                      2: // nono
                      3: // Copyright (C) 2019 [email protected]
                      4: //
                      5: 
                      6: #include "header.h"
                      7: #include "config.h"
                      8: #include "console.h"
                      9: #include <netdb.h>
                     10: #include <sys/socket.h>
                     11: 
                     12: //
                     13: // TCP コンソール
                     14: //
                     15: 
                     16: // コンストラクタ
                     17: ConsoleTCP::ConsoleTCP()
                     18: {
                     19:        ls = -1;
                     20:        sock = -1;
                     21: 
                     22:        // editline は使えないようだ...
                     23:        //use_editline = true;
                     24: }
                     25: 
                     26: // デストラクタ
                     27: ConsoleTCP::~ConsoleTCP()
                     28: {
                     29:        if (res) {
                     30:                freeaddrinfo(res);
                     31:                res = NULL;
                     32:        }
                     33:        if (sock != -1) {
                     34:                close(sock);
                     35:                sock = -1;
                     36:        }
                     37:        if (ls != -1) {
                     38:                close(ls);
                     39:                ls = -1;
                     40:        }
                     41: }
                     42: 
                     43: // 初期化
                     44: bool
                     45: ConsoleTCP::Init()
                     46: {
                     47:        struct addrinfo hints;
                     48:        int r;
                     49:        int on = 1;
                     50: 
                     51:        memset(&hints, 0, sizeof(hints));
                     52:        hints.ai_family = AF_UNSPEC;
                     53:        hints.ai_socktype = SOCK_STREAM;
                     54:        hints.ai_flags = AI_PASSIVE;
                     55: 
                     56:        const char *host = "::1";
                     57:        const ConfigItem& item = gConfig->Get("debugger-port");
                     58:        const std::string& port = item.AsString();
                     59:        int portnum = atoi(port.c_str());
                     60:        if (portnum < 0 || portnum > 65535) {
                     61:                item.Err();
                     62:                return false;
                     63:        }
                     64:        // 0 なら待ち受けしない
                     65:        if (portnum == 0) {
                     66:                return false;
                     67:        }
                     68: 
                     69:        r = getaddrinfo(host, port.c_str(), &hints, &res);
                     70:        if (r != 0) {
                     71:                const char *errmsg;
                     72:                if (r == EAI_SYSTEM) {
                     73:                        errmsg = strerror(errno);
                     74:                } else {
                     75:                        errmsg = gai_strerror(r);
                     76:                }
                     77:                warnx("getaddrinfo: %s: %s", host, errmsg);
                     78:                return false;
                     79:        }
                     80:        if (res == NULL) {
                     81:                warnx("getaddrinfo: %s: no address found", host);
                     82:                return false;
                     83:        }
                     84: 
                     85:        // res を順番に試して成功したらそれで待ち受ける
                     86:        ls = -1;
                     87:        for (ai = res; ai && ls == -1; ai = ai->ai_next) {
                     88:                ls = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol);
                     89:                if (ls == -1) {
                     90:                        warn("socket");
                     91:                        continue;
                     92:                }
                     93: 
                     94:                if (setsockopt(ls, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on))) {
                     95:                        warn("setsockopt(SO_REUSEADDR)");
                     96:                        close(ls);
                     97:                        continue;
                     98:                }
                     99: 
                    100:                if (setsockopt(ls, SOL_SOCKET, SO_REUSEPORT, &on, sizeof(on))) {
                    101:                        warn("setsockopt(SO_REUSEPORT)");
                    102:                        close(ls);
                    103:                        continue;
                    104:                }
                    105: 
                    106:                if (bind(ls, ai->ai_addr, ai->ai_addrlen) == -1) {
                    107:                        warn("bind");
                    108:                        close(ls);
                    109:                        continue;
                    110:                }
                    111: 
                    112:                if (listen(ls, 0) == -1) {
                    113:                        warn("listen");
                    114:                        close(ls);
                    115:                        continue;
                    116:                }
                    117: 
                    118:                // ここまで来たら成功
                    119:                break;
                    120:        }
                    121: 
                    122:        if (ls == -1) {
                    123:                return false;
                    124:        }
                    125: 
                    126:        return true;
                    127: }
                    128: 
                    129: bool
                    130: ConsoleTCP::Open()
                    131: {
                    132:        // 待ち受け
                    133:        for (;;) {
                    134:                sock = accept(ls, ai->ai_addr, &ai->ai_addrlen);
                    135:                if (sock == -1) {
                    136:                        if (errno == EINTR) {
                    137:                                continue;
                    138:                        }
                    139:                        warn("accept");
                    140:                        return false;
                    141:                }
                    142:                break;
                    143:        }
                    144: 
                    145:        inp.fd = dup(sock);
                    146:        out.fd = dup(sock);
                    147:        FDOpen();
                    148: 
                    149:        // editline(3) を使う場合、出力側がフルバッファリングだと内部バッファが
                    150:        // 一杯になったか何かのタイミングでしか出力されなくなるので、少なくとも
                    151:        // 行バッファリングにはしないといけない。
                    152:        setlinebuf(out.file);
                    153:        // バッファリングなしにしてもプロンプトは表示されない...
                    154:        //setvbuf(out.file, NULL, _IONBF, 0);
                    155: 
                    156:        return true;
                    157: }
                    158: 
                    159: void
                    160: ConsoleTCP::Close()
                    161: {
                    162:        inherited::Close();
                    163: 
                    164:        if (sock != -1) {
                    165:                close(sock);
                    166:                sock = -1;
                    167:        }
                    168: }

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