source: trunk/tools/neercs/old/client.c @ 1656

Last change on this file since 1656 was 1656, checked in by sam, 8 years ago

neercs: start porting the old code to Windows; this breaks the Visual Studio
build until further fixes are made.

  • Property svn:keywords set to Id
File size: 9.2 KB
Line 
1/*
2 *  neercs        console-based window manager
3 *  Copyright (c) 2006-2010 Sam Hocevar <sam@hocevar.net>
4 *                2008-2010 Jean-Yves Lamoureux <jylam@lnxscene.org>
5 *                2008-2011 Pascal Terjan <pterjan@linuxfr.org>
6 *                All Rights Reserved
7 *
8 *  This program is free software. It comes without any warranty, to
9 *  the extent permitted by applicable law. You can redistribute it
10 *  and/or modify it under the terms of the Do What The Fuck You Want
11 *  To Public License, Version 2, as published by Sam Hocevar. See
12 *  http://sam.zoy.org/wtfpl/COPYING for more details.
13 */
14
15#if defined HAVE_CONFIG_H
16#   include "config.h"
17#endif
18
19#if !defined _WIN32
20
21#include <stdio.h>
22#include <string.h>
23#include <stdlib.h>
24#include <unistd.h>
25#include <fcntl.h>
26#include <signal.h>
27#include <sys/ioctl.h>
28#include <sys/types.h>
29#include <sys/wait.h>
30#include <sys/time.h>
31#include <time.h>
32#include <pwd.h>
33
34#include <errno.h>
35#include <caca.h>
36
37#include "neercs.h"
38
39#define NEERCS_RECV_BUFSIZE 128*1024
40
41
42int start_client(struct screen_list *screen_list)
43{
44    char *sess = NULL;
45    create_socket(screen_list, SOCK_CLIENT);
46    while ((sess = connect_socket(screen_list, SOCK_SERVER)) == NULL)
47        usleep(100);
48    free(sess);
49
50    /* Create main canvas and associated caca window */
51    screen_list->cv = caca_create_canvas(0, 0);
52    screen_list->dp = caca_create_display(screen_list->cv);
53    screen_list->mouse_button = 0;
54
55    if (!screen_list->dp)
56        return -3;
57
58    caca_set_display_time(screen_list->dp, screen_list->delay * 1000);
59    caca_set_cursor(screen_list->dp, 1);
60
61    request_attach(screen_list);
62
63    return 0;
64}
65
66int send_event(caca_event_t ev, struct screen_list *screen_list)
67{
68    enum caca_event_type t;
69    char buf[64];
70    int bytes = 0;
71
72    t = caca_get_event_type(&ev);
73
74    if (t & CACA_EVENT_KEY_PRESS)
75    {
76        bytes =  snprintf(buf, sizeof(buf) - 1, "KEY %d",
77                          caca_get_event_key_ch(&ev));
78        debug("Sending key press to server: %s", buf);
79    }
80    else if (t & CACA_EVENT_RESIZE)
81    {
82        bytes = snprintf(buf, sizeof(buf) - 1, "RESIZE %10d %10d",
83                         caca_get_event_resize_width(&ev),
84                         caca_get_event_resize_height(&ev));
85    }
86    else if (t & CACA_EVENT_MOUSE_PRESS)
87    {
88        screen_list->mouse_button = caca_get_event_mouse_button(&ev);
89        bytes = snprintf(buf, sizeof(buf) - 1, "MOUSEP %10d %10d %10d",
90                         caca_get_mouse_x(screen_list->dp),
91                         caca_get_mouse_y(screen_list->dp),
92                         screen_list->mouse_button);
93    }
94    else if (t & CACA_EVENT_MOUSE_RELEASE)
95    {
96        bytes = snprintf(buf, sizeof(buf) - 1, "MOUSER %10d %10d %10d",
97                         caca_get_mouse_x(screen_list->dp),
98                         caca_get_mouse_y(screen_list->dp),
99                         screen_list->mouse_button);
100        screen_list->mouse_button = 0;
101    }
102    else if (t & CACA_EVENT_MOUSE_MOTION)
103    {
104        int x = caca_get_mouse_x(screen_list->dp);
105        int y = caca_get_mouse_y(screen_list->dp);
106        int b = screen_list->mouse_button;
107        debug("Mouse motion, button %d", b);
108        if (x != screen_list->old_x || y != screen_list->old_y)
109        {
110            screen_list->old_x = caca_get_mouse_x(screen_list->dp);
111            screen_list->old_y = caca_get_mouse_y(screen_list->dp);
112
113            bytes = snprintf(buf, sizeof(buf) - 1, "MOUSEM %10d %10d %10d",
114                             caca_get_mouse_x(screen_list->dp),
115                             caca_get_mouse_y(screen_list->dp),
116                             b>=0?b:0);
117        }
118    }
119    else if (t & CACA_EVENT_QUIT)
120    {
121        bytes = snprintf(buf, sizeof(buf) - 1, "QUIT");
122    }
123    if (bytes)
124    {
125        ssize_t r;
126        buf[bytes] = '\0';
127        debug("Sending '%s', %d bytes", buf, bytes);
128        r = write(screen_list->comm.socket[SOCK_SERVER], buf, bytes+1);
129        while (r < 0 && errno == EAGAIN)
130        {
131            usleep(20);
132            r = write(screen_list->comm.socket[SOCK_SERVER], buf, bytes+1);
133        }
134        return r < 0;
135    }
136    return 0;
137}
138
139int send_delay(struct screen_list *screen_list)
140{
141    debug("Sending DELAY\n");
142    char buf[18];
143    int bytes;
144    bytes = snprintf(buf, sizeof(buf) - 1, "DELAY %10d", screen_list->delay);
145    buf[bytes] = '\0';
146    return write(screen_list->comm.socket[SOCK_SERVER], buf, strlen(buf)) <= 0;
147}
148
149/** \brief Main client loop.
150 *
151 * This is the main client loop.
152 *
153 * Repeat forever:
154 *  - if data is available on the client socket, read it and interpret it:
155 *    - "DETACH": exit the loop
156 *    - "UPDATE": update screen with the given canvas data
157 *    - "REFRESH": refresh the whole display
158 *    - "CURSOR": set cursor position
159 *    - "TITLE": set window or display title
160 *  - wait for an input event with a 10ms timeout
161 */
162void mainloop(struct screen_list *screen_list)
163{
164    char *buf = NULL;
165    screen_list->last_key_time = get_us();
166
167    while (mainloop_tick(&buf, screen_list))
168        ;
169
170    free(buf);
171}
172
173int mainloop_tick(char **pbuf, struct screen_list *screen_list)
174{
175    caca_event_t ev;
176    int ret = 0;
177    ssize_t n;
178    if (!screen_list)
179        return 0;
180    if (!*pbuf)
181        *pbuf = malloc(NEERCS_RECV_BUFSIZE);
182    if (!*pbuf)
183    {
184        debug("Failed to allocate memory");
185        return 0;
186    }
187    if (screen_list->comm.socket[SOCK_CLIENT]
188        && (n =
189            read(screen_list->comm.socket[SOCK_CLIENT], *pbuf,
190                 NEERCS_RECV_BUFSIZE - 1)) > 0)
191    {
192        *pbuf[n] = 0;
193        debug("Received from server: '%s' (%d bytes)", *pbuf, n);
194        if (!strncmp("DETACH", *pbuf, 6))
195        {
196            /* ret = 1; Not used */
197            return 1;
198        }
199        else if (!strncmp("UPDATE ", *pbuf, 7))
200        {
201            int x, y;
202            ssize_t l2 = 0, lb = 0;
203            char *buf2;
204            size_t l = 0;
205            /* FIXME check the length before calling atoi */
206            x = atoi(*pbuf + 8);
207            y = atoi(*pbuf + 19);
208
209            /* 0 means we have valid data but incomplete, so read the rest
210             */
211            while (l == 0)
212            {
213                buf2 = realloc(*pbuf, l2 + NEERCS_RECV_BUFSIZE);
214                if (!buf2)
215                {
216                    debug("Failed to allocate memory");
217                    return 0;
218                }
219                *pbuf = buf2;
220                fcntl(screen_list->comm.socket[SOCK_CLIENT], F_SETFL, 0);
221                lb = read(screen_list->comm.socket[SOCK_CLIENT], *pbuf + l2,
222                          NEERCS_RECV_BUFSIZE - 1);
223                if (lb < 0)
224                {
225                    debug
226                        ("Failed to read the end of the refresh message (%s)",
227                         strerror(errno));
228                    l = -1;
229                }
230                else
231                {
232                    l2 += lb;
233                    l = caca_import_area_from_memory(screen_list->cv, x, y,
234                                                     *pbuf, l2, "caca");
235                }
236            }
237            fcntl(screen_list->comm.socket[SOCK_CLIENT], F_SETFL,
238                  O_NONBLOCK);
239        }
240        else if (!strncmp("REFRESH ", *pbuf, 8))
241        {
242            int dt, x, y;
243            /* FIXME check the length before calling atoi */
244            x = atoi(*pbuf + 8);
245            y = atoi(*pbuf + 19);
246            caca_gotoxy(screen_list->cv, x, y);
247            caca_refresh_display(screen_list->dp);
248            dt = caca_get_display_time(screen_list->dp);
249
250            /* Adjust refresh delay so that the server do not compute
251               useless things */
252            if (dt > 2 * 1000 * screen_list->delay
253                && screen_list->delay <= 100)
254            {
255                screen_list->delay *= 2;
256                send_delay(screen_list);
257            }
258            else if (dt < screen_list->delay * 1000 * 1.2 &&
259                     screen_list->delay >=
260                     3 * screen_list->requested_delay / 2)
261            {
262                screen_list->delay = 2 * screen_list->delay / 3;
263                send_delay(screen_list);
264            }
265            screen_list->comm.attached = 1;
266        }
267        else if (!strncmp("CURSOR ", *pbuf, 7))
268        {
269            caca_set_cursor(screen_list->dp, atoi(*pbuf + 7));
270        }
271        else if (!strncmp("TITLE ", *pbuf, 6))
272        {
273            caca_set_display_title(screen_list->dp, *pbuf + 6);
274            caca_refresh_display(screen_list->dp);
275        }
276        else
277        {
278            debug("Unknown message received from server: %s", *pbuf);
279        }
280    }
281
282    /* Wait to have finished attaching before handling events */
283    if (screen_list->comm.attached)
284    {
285        ret = caca_get_event(screen_list->dp,
286                             CACA_EVENT_KEY_PRESS
287                             | CACA_EVENT_MOUSE_PRESS
288                             | CACA_EVENT_MOUSE_RELEASE
289                             | CACA_EVENT_MOUSE_MOTION
290                             | CACA_EVENT_RESIZE
291                             | CACA_EVENT_QUIT, &ev, 10000);
292        if (ret)
293            ret = send_event(ev, screen_list);
294        if (ret)
295        {
296            debug("Failed send event, quitting: %s\n", strerror(errno));
297            return 1;
298        }
299    }
300
301    return 1;
302}
303
304#endif
305
Note: See TracBrowser for help on using the repository browser.