source: neercs/trunk/src/client.c @ 4218

Last change on this file since 4218 was 4218, checked in by Sam Hocevar, 11 years ago

Add Doxygen build rules.

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