Annotation of hatari/src/control.c, revision 1.1.1.1

1.1       root        1: /*
                      2:   Hatari - control.c
                      3: 
                      4:   This file is distributed under the GNU Public License, version 2 or at
                      5:   your option any later version. Read the file gpl.txt for details.
                      6: 
                      7:   This code processes commands from the Hatari control socket
                      8: */
                      9: const char control_rcsid[] = "Hatari $Id: control.c,v 1.10 2008/11/23 10:27:14 thothy Exp $";
                     10: 
                     11: #include "config.h"
                     12: #if HAVE_UNIX_DOMAIN_SOCKETS
                     13: 
                     14: # include <sys/socket.h>
                     15: #include <sys/un.h>
                     16: 
                     17: #include <sys/types.h>
                     18: #include <sys/time.h>
                     19: #include <unistd.h>
                     20: #include <ctype.h>
                     21: 
                     22: #include "main.h"
                     23: #include "change.h"
                     24: #include "configuration.h"
                     25: #include "control.h"
                     26: #include "debugui.h"
                     27: #include "file.h"
                     28: #include "ikbd.h"
                     29: #include "keymap.h"
                     30: #include "log.h"
                     31: #include "midi.h"
                     32: #include "printer.h"
                     33: #include "rs232.h"
                     34: #include "shortcut.h"
                     35: #include "str.h"
                     36: 
                     37: typedef enum {
                     38:        DO_DISABLE,
                     39:        DO_ENABLE,
                     40:        DO_TOGGLE
                     41: } action_t;
                     42: 
                     43: /* socket from which control command line options are read */
                     44: static int ControlSocket;
                     45: /* Whether to send embedded window info */
                     46: static bool bSendEmbedInfo;
                     47: /* Pausing triggered remotely (battery save pause) */
                     48: static bool bRemotePaused;
                     49: 
                     50: /* pre-declared local functions */
                     51: static int Control_GetUISocket(void);
                     52: 
                     53: 
                     54: /*-----------------------------------------------------------------------*/
                     55: /**
                     56:  * Parse key command and synthetize key press/release
                     57:  * corresponding to given keycode or character.
                     58:  * Return FALSE if parsing failed, TRUE otherwise
                     59:  * 
                     60:  * This can be used by external Hatari UI(s) for
                     61:  * string macros, or on devices which lack keyboard
                     62:  */
                     63: static bool Control_InsertKey(const char *event)
                     64: {
                     65:        const char *key = NULL;
                     66:        bool press;
                     67: 
                     68:        if (strncmp(event, "keypress ", 9) == 0) {
                     69:                key = &event[9];
                     70:                press = TRUE;
                     71:        } else if (strncmp(event, "keyrelease ", 11) == 0) {
                     72:                key = &event[11];
                     73:                press = FALSE;
                     74:        }
                     75:        if (!(key && key[0])) {
                     76:                fprintf(stderr, "ERROR: event '%s' contains no key press/release\n", event);
                     77:                return FALSE;
                     78:        }
                     79:        if (key[1]) {
                     80:                char *endptr;
                     81:                /* multiple characters, assume it's a keycode */
                     82:                int keycode = strtol(key, &endptr, 0);
                     83:                /* not a valid number or keycode is out of range? */
                     84:                if (*endptr || keycode < 0 || keycode > 255) {
                     85:                        fprintf(stderr, "ERROR: '%s' is not valid key code, got %d\n",
                     86:                                key, keycode);
                     87:                        return FALSE;
                     88:                }
                     89:                IKBD_PressSTKey(keycode, press);
                     90:        } else {
                     91:                Keymap_SimulateCharacter(key[0], press);
                     92:        }
                     93:        fprintf(stderr, "Simulated %s key %s\n",
                     94:                key, (press?"press":"release"));
                     95:        return TRUE;
                     96: }
                     97: 
                     98: /*-----------------------------------------------------------------------*/
                     99: /**
                    100:  * Parse event name and synthetize corresponding event to emulation
                    101:  * Return FALSE if name parsing failed, TRUE otherwise
                    102:  * 
                    103:  * This can be used by external Hatari UI(s) on devices which input
                    104:  * methods differ from normal keyboard and mouse, such as high DPI
                    105:  * touchscreen (no right/middle button, inaccurate clicks)
                    106:  */
                    107: static bool Control_InsertEvent(const char *event)
                    108: {
                    109:        if (strcmp(event, "doubleclick") == 0) {
                    110:                Keyboard.LButtonDblClk = 1;
                    111:                return TRUE;
                    112:        }
                    113:        if (strcmp(event, "rightpress") == 0) {
                    114:                Keyboard.bRButtonDown |= BUTTON_MOUSE;
                    115:                return TRUE;
                    116:        }
                    117:        if (strcmp(event, "rightrelease") == 0) {
                    118:                Keyboard.bRButtonDown &= ~BUTTON_MOUSE;
                    119:                return TRUE;
                    120:        }
                    121:        if (Control_InsertKey(event)) {
                    122:                return TRUE;
                    123:        }
                    124:        fprintf(stderr, "ERROR: unrecognized event: '%s'\n", event);
                    125:        fprintf(stderr, "Supported events are:\n");
                    126:        fprintf(stderr, "- doubleclick\n");
                    127:        fprintf(stderr, "- rightpress\n");
                    128:        fprintf(stderr, "- rightrelease\n");
                    129:        fprintf(stderr, "- keypress <character>\n");
                    130:        fprintf(stderr, "- keyrelease <character>\n");
                    131:        fprintf(stderr, "<character> can be either a single ASCII char or keycode.\n");
                    132:        return FALSE;   
                    133: }
                    134: 
                    135: /*-----------------------------------------------------------------------*/
                    136: /**
                    137:  * Parse device name and enable/disable/toggle & init/uninit it according
                    138:  * to action.  Return FALSE if name parsing failed, TRUE otherwise
                    139:  */
                    140: static bool Control_DeviceAction(const char *name, action_t action)
                    141: {
                    142:        /* Note: e.g. RTC would require restarting emulation
                    143:         * and HD-boot setting emulation reboot.  Devices
                    144:         * listed here work just with init/uninit.
                    145:         */
                    146:        struct {
                    147:                const char *name;
                    148:                bool *pvalue;
                    149:                void(*init)(void);
                    150:                void(*uninit)(void);
                    151:        } item[] = {
                    152:                { "printer", &ConfigureParams.Printer.bEnablePrinting, Printer_Init, Printer_UnInit },
                    153:                { "rs232",   &ConfigureParams.RS232.bEnableRS232, RS232_Init, RS232_UnInit },
                    154:                { "midi",    &ConfigureParams.Midi.bEnableMidi, Midi_Init, Midi_UnInit },
                    155:                { NULL, NULL, NULL, NULL }
                    156:        };
                    157:        int i;
                    158:        bool value;
                    159:        for (i = 0; item[i].name; i++)
                    160:        {
                    161:                if (strcmp(name, item[i].name) == 0)
                    162:                {
                    163:                        switch (action) {
                    164:                        case DO_TOGGLE:
                    165:                                value = !*(item[i].pvalue);
                    166:                                break;
                    167:                        case DO_ENABLE:
                    168:                                value = TRUE;
                    169:                                break;
                    170:                        case DO_DISABLE:
                    171:                        default:
                    172:                                value = FALSE;
                    173:                                break;
                    174:                        }
                    175:                        *(item[i].pvalue) = value;
                    176:                        if (value) {
                    177:                                item[i].init();
                    178:                        } else {
                    179:                                item[i].uninit();
                    180:                        }
                    181:                        fprintf(stderr, "%s: %s\n", name, value?"ON":"OFF");
                    182:                        return TRUE;
                    183:                }
                    184:        }
                    185:        fprintf(stderr, "WARNING: unknown device '%s'\n\n", name);
                    186:        fprintf(stderr, "Accepted devices are:\n");
                    187:        for (i = 0; item[i].name; i++)
                    188:        {
                    189:                fprintf(stderr, "- %s\n", item[i].name);
                    190:        }
                    191:        return FALSE;
                    192: }
                    193: 
                    194: /*-----------------------------------------------------------------------*/
                    195: /**
                    196:  * Parse path type name and set the path to given value.
                    197:  * Return FALSE if name parsing failed, TRUE otherwise
                    198:  */
                    199: static bool Control_SetPath(char *name)
                    200: {
                    201:        struct {
                    202:                const char *name;
                    203:                char *path;
                    204:        } item[] = {
                    205:                { "memauto",  ConfigureParams.Memory.szAutoSaveFileName },
                    206:                { "memsave",  ConfigureParams.Memory.szMemoryCaptureFileName },
                    207:                { "midiout",  ConfigureParams.Midi.szMidiOutFileName },
                    208:                { "printout", ConfigureParams.Printer.szPrintToFileName },
                    209:                { "soundout", ConfigureParams.Sound.szYMCaptureFileName },
                    210:                { "rs232in",  ConfigureParams.RS232.szInFileName },
                    211:                { "rs232out", ConfigureParams.RS232.szOutFileName },
                    212:                { NULL, NULL }
                    213:        };
                    214:        int i;
                    215:        char *arg;
                    216:        const char *value;
                    217:        
                    218:        /* argument? */
                    219:        arg = strchr(name, ' ');
                    220:        if (arg) {
                    221:                *arg = '\0';
                    222:                value = Str_Trim(arg+1);
                    223:        } else {
                    224:                return FALSE;
                    225:        }
                    226:        
                    227:        for (i = 0; item[i].name; i++)
                    228:        {
                    229:                if (strcmp(name, item[i].name) == 0)
                    230:                {
                    231:                        fprintf(stderr, "%s: %s -> %s\n", name, item[i].path, value);
                    232:                        strncpy(item[i].path, value, FILENAME_MAX-1);
                    233:                        return TRUE;
                    234:                }
                    235:        }
                    236:        fprintf(stderr, "WARNING: unknown path type '%s'\n\n", name);
                    237:        fprintf(stderr, "Accepted paths types are:\n");
                    238:        for (i = 0; item[i].name; i++)
                    239:        {
                    240:                fprintf(stderr, "- %s\n", item[i].name);
                    241:        }
                    242:        return FALSE;
                    243: }
                    244: 
                    245: /*-----------------------------------------------------------------------*/
                    246: /**
                    247:  * Show Hatari remote usage info and return FALSE
                    248:  */
                    249: static bool Control_Usage(const char *cmd)
                    250: {
                    251:        fprintf(stderr, "ERROR: unrecognized hatari command: '%s'", cmd);
                    252:        fprintf(stderr,
                    253:                "Supported commands are:\n"
                    254:                "- hatari-debug <Debug UI command>\n"
                    255:                "- hatari-event <event to simulate>\n"
                    256:                "- hatari-option <command line options>\n"
                    257:                "- hatari-enable/disable/toggle <device name>\n"
                    258:                "- hatari-path <config name> <new path>\n"
                    259:                "- hatari-shortcut <shortcut name>\n"
                    260:                "- hatari-embed-info\n"
                    261:                "- hatari-stop\n"
                    262:                "- hatari-cont\n"
                    263:                "The last two can be used to stop and continue the Hatari emulation.\n"
                    264:                "All commands need to be separated by newlines.\n"
                    265:                );
                    266:        return FALSE;
                    267: }
                    268: 
                    269: /*-----------------------------------------------------------------------*/
                    270: /**
                    271:  * Parse Hatari debug/event/option/toggle/path/shortcut command buffer.
                    272:  * Given buffer is modified in-place.
                    273:  */
                    274: static void Control_ProcessBuffer(char *buffer)
                    275: {
                    276:        char *cmd, *cmdend, *arg;
                    277:        int ok = TRUE;
                    278:        
                    279:        cmd = buffer;
                    280:        do {
                    281:                /* command terminator? */
                    282:                cmdend  = strchr(cmd, '\n');
                    283:                if (cmdend) {
                    284:                        *cmdend = '\0';
                    285:                }
                    286:                /* arguments? */
                    287:                arg = strchr(cmd, ' ');
                    288:                if (arg) {
                    289:                        *arg = '\0';
                    290:                        arg = Str_Trim(arg+1);
                    291:                }
                    292:                if (arg) {
                    293:                        if (strcmp(cmd, "hatari-option") == 0) {
                    294:                                ok = Change_ApplyCommandline(arg);
                    295:                        } else if (strcmp(cmd, "hatari-debug") == 0) {
                    296:                                ok = DebugUI_ParseCommand(arg);
                    297:                        } else if (strcmp(cmd, "hatari-shortcut") == 0) {
                    298:                                ok = Shortcut_Invoke(arg);
                    299:                        } else if (strcmp(cmd, "hatari-event") == 0) {
                    300:                                ok = Control_InsertEvent(arg);
                    301:                        } else if (strcmp(cmd, "hatari-path") == 0) {
                    302:                                ok = Control_SetPath(arg);
                    303:                        } else if (strcmp(cmd, "hatari-enable") == 0) {
                    304:                                ok = Control_DeviceAction(arg, DO_ENABLE);
                    305:                        } else if (strcmp(cmd, "hatari-disable") == 0) {
                    306:                                ok = Control_DeviceAction(arg, DO_DISABLE);
                    307:                        } else if (strcmp(cmd, "hatari-toggle") == 0) {
                    308:                                ok = Control_DeviceAction(arg, DO_TOGGLE);
                    309:                        } else {
                    310:                                ok = Control_Usage(cmd);
                    311:                        }
                    312:                } else {
                    313:                        if (strcmp(cmd, "hatari-embed-info") == 0) {
                    314:                                fprintf(stderr, "Embedded window ID change messages = ON\n");
                    315:                                bSendEmbedInfo = TRUE;
                    316:                        } else if (strcmp(cmd, "hatari-stop") == 0) {
                    317:                                Main_PauseEmulation(TRUE);
                    318:                                bRemotePaused = TRUE;
                    319:                        } else if (strcmp(cmd, "hatari-cont") == 0) {
                    320:                                Main_UnPauseEmulation();
                    321:                                bRemotePaused = FALSE;
                    322:                        } else {
                    323:                                ok = Control_Usage(cmd);
                    324:                        }
                    325:                }
                    326:                if (cmdend) {
                    327:                        cmd = cmdend + 1;
                    328:                }
                    329:        } while (ok && cmdend && *cmd);
                    330: }
                    331: 
                    332: 
                    333: /*-----------------------------------------------------------------------*/
                    334: /**
                    335:  * Check ControlSocket for new commands and execute them.
                    336:  * Commands should be separated by newlines.
                    337:  * 
                    338:  * Return TRUE if remote pause ON (and connected), FALSE otherwise
                    339:  */
                    340: bool Control_CheckUpdates(void)
                    341: {
                    342:        /* just using all trace options with +/- are about 300 chars */
                    343:        char buffer[400];
                    344:        struct timeval tv;
                    345:        fd_set readfds;
                    346:        ssize_t bytes;
                    347:        int status, sock;
                    348: 
                    349:        /* socket of file? */
                    350:        if (ControlSocket) {
                    351:                sock = ControlSocket;
                    352:        } else {
                    353:                return FALSE;
                    354:        }
                    355:        
                    356:        /* ready for reading? */
                    357:        tv.tv_usec = tv.tv_sec = 0;
                    358:        do {
                    359:                FD_ZERO(&readfds);
                    360:                FD_SET(sock, &readfds);
                    361:                if (bRemotePaused) {
                    362:                        /* return only when there're UI events
                    363:                         * (redraws etc) to save battery:
                    364:                         *   http://bugzilla.libsdl.org/show_bug.cgi?id=323
                    365:                         */
                    366:                        int uisock = Control_GetUISocket();
                    367:                        if (uisock) {
                    368:                                FD_SET(uisock, &readfds);
                    369:                                if (uisock < sock) {
                    370:                                        uisock = sock;
                    371:                                }
                    372:                        }
                    373:                        status = select(uisock+1, &readfds, NULL, NULL, NULL);
                    374:                } else {
                    375:                        status = select(sock+1, &readfds, NULL, NULL, &tv);
                    376:                }
                    377:                if (status < 0) {
                    378:                        perror("Control socket select() error");
                    379:                        return FALSE;
                    380:                }
                    381:                /* nothing to process here */
                    382:                if (status == 0) {
                    383:                        return bRemotePaused;
                    384:                }
                    385:                if (!FD_ISSET(sock, &readfds)) {
                    386:                        return bRemotePaused;
                    387:                }
                    388:                
                    389:                /* assume whole command can be read in one go */
                    390:                bytes = read(sock, buffer, sizeof(buffer)-1);
                    391:                if (bytes < 0)
                    392:                {
                    393:                        perror("Control socket read");
                    394:                        return FALSE;
                    395:                }
                    396:                if (bytes == 0) {
                    397:                        /* closed */
                    398:                        close(ControlSocket);
                    399:                        ControlSocket = 0;
                    400:                        return FALSE;
                    401:                }
                    402:                buffer[bytes] = '\0';
                    403:                Control_ProcessBuffer(buffer);
                    404: 
                    405:        } while (bRemotePaused);
                    406:        
                    407:        return FALSE;
                    408: }
                    409: 
                    410: 
                    411: /*-----------------------------------------------------------------------*/
                    412: /**
                    413:  * Open given control socket.
                    414:  * Return NULL for success, otherwise an error string
                    415:  */
                    416: const char *Control_SetSocket(const char *socketpath)
                    417: {
                    418:        struct sockaddr_un address;
                    419:        int newsock;
                    420:        
                    421:        newsock = socket(AF_UNIX, SOCK_STREAM, 0);
                    422:        if (newsock < 0)
                    423:        {
                    424:                perror("socket creation");
                    425:                return "Can't create AF_UNIX socket";
                    426:        }
                    427: 
                    428:        address.sun_family = AF_UNIX;
                    429:        strncpy(address.sun_path, socketpath, sizeof(address.sun_path));
                    430:        address.sun_path[sizeof(address.sun_path)-1] = '\0';
                    431:        Log_Printf(LOG_INFO, "Connecting to control socket '%s'...\n", address.sun_path);
                    432:        if (connect(newsock, &address, sizeof(address)) < 0)
                    433:        {
                    434:                perror("socket connect");
                    435:                close(newsock);
                    436:                return "connection to control socket failed";
                    437:        }
                    438:                                
                    439:        if (ControlSocket) {
                    440:                close(ControlSocket);
                    441:        }
                    442:        ControlSocket = newsock;
                    443:        Log_Printf(LOG_INFO, "new control socket is '%s'\n", socketpath);
                    444:        return NULL;
                    445: }
                    446: 
                    447: 
                    448: /*-----------------------------------------------------------------------
                    449:  * Currently works only on X11.
                    450:  * 
                    451:  * SDL_syswm.h automatically includes everything else needed.
                    452:  */
                    453: #if HAVE_X11
                    454: 
                    455: #include <SDL_syswm.h>
                    456: 
                    457: /**
                    458:  * Reparent Hatari window if so requested.  Needs to be done inside
                    459:  * Hatari because if SDL itself is requested to reparent itself,
                    460:  * SDL window stops accepting any input (specifically done like
                    461:  * this in SDL backends for some reason).
                    462:  * 
                    463:  * 'noembed' argument tells whether the SDL window should be embedded
                    464:  * or not.
                    465:  *
                    466:  * If the window is embedded (which means that SDL WM window needs
                    467:  * to be hidden) when SDL is asked to fullscreen, Hatari window just
                    468:  * disappears when returning back from fullscreen.  I.e. call this
                    469:  * with noembed=TRUE _before_ fullscreening and any other time with
                    470:  * noembed=FALSE after changing window size.  You can do this by
                    471:  * giving bInFullscreen as the noembed value.
                    472:  */
                    473: void Control_ReparentWindow(int width, int height, bool noembed)
                    474: {
                    475:        Display *display;
                    476:        Window parent_win, sdl_win, wm_win;
                    477:        const char *parent_win_id;
                    478:        SDL_SysWMinfo info;
                    479: 
                    480:        parent_win_id = getenv("PARENT_WIN_ID");
                    481:        if (!parent_win_id) {
                    482:                return;
                    483:        }
                    484:        parent_win = strtol(parent_win_id, NULL, 0);
                    485:        if (!parent_win) {
                    486:                Log_Printf(LOG_WARN, "Invalid PARENT_WIN_ID value '%s'\n", parent_win_id);
                    487:                return;
                    488:        }
                    489: 
                    490:        SDL_VERSION(&info.version);
                    491:        if (!SDL_GetWMInfo(&info)) {
                    492:                Log_Printf(LOG_WARN, "Failed to get SDL_GetWMInfo()\n");
                    493:                return;
                    494:        }
                    495:        display = info.info.x11.display;
                    496:        sdl_win = info.info.x11.window;
                    497:        wm_win = info.info.x11.wmwindow;
                    498:        info.info.x11.lock_func();
                    499:        if (noembed) {
                    500:                /* show WM window again */
                    501:                XMapWindow(display, wm_win);
                    502:        } else {
                    503:                char buffer[12];  /* 32-bits in hex (+ '\r') + '\n' + '\0' */
                    504: 
                    505:                /* hide WM window for Hatari */
                    506:                XUnmapWindow(display, wm_win);
                    507:                /* reparent main Hatari window to given parent */
                    508:                XReparentWindow(display, sdl_win, parent_win, 0, 0);
                    509: 
                    510:                /* whether to send new window size */
                    511:                if (bSendEmbedInfo && ControlSocket) {
                    512:                        fprintf(stderr, "New %dx%d SDL window with ID: %lx\n",
                    513:                                width, height, sdl_win);
                    514:                        sprintf(buffer, "%dx%d", width, height);
                    515:                        write(ControlSocket, buffer, strlen(buffer));
                    516:                }
                    517:        }
                    518:        info.info.x11.unlock_func();
                    519: }
                    520: 
                    521: /**
                    522:  * Return the X connection socket or zero
                    523:  */
                    524: static int Control_GetUISocket(void)
                    525: {
                    526:        SDL_SysWMinfo info;
                    527:        SDL_VERSION(&info.version);
                    528:        if (!SDL_GetWMInfo(&info)) {
                    529:                Log_Printf(LOG_WARN, "Failed to get SDL_GetWMInfo()\n");
                    530:                return 0;
                    531:        }
                    532:        return ConnectionNumber(info.info.x11.display);
                    533: }
                    534: 
                    535: #else
                    536: static int Control_GetUISocket(void)
                    537: {
                    538:        return 0;
                    539: }
                    540: void Control_ReparentWindow(int width, int height, bool noembed)
                    541: {
                    542:        /* TODO: implement the Windows part.  SDL sources offer example */
                    543:        Log_Printf(LOG_TODO, "Support for Hatari window reparenting not built in\n");
                    544: }
                    545: #endif /* HAVE_X11 */
                    546: 
                    547: 
                    548: #endif /* HAVE_UNIX_DOMAIN_SOCKETS */

unix.superglobalmegacorp.com

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