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

Last change on this file since 4098 was 4098, checked in by Jean-Yves Lamoureux, 11 years ago
  • Improved mouse support (now reports mouse motion events, and handles (badly) X10 compatibility mode)
File size: 9.2 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
52    if (!screen_list->dp)
53        return -3;
54
55    caca_set_display_time(screen_list->dp, screen_list->delay * 1000);
56    caca_set_cursor(screen_list->dp, 1);
57
58    request_attach(screen_list);
59
60    return 0;
61}
62
63int send_event(caca_event_t ev, struct screen_list *screen_list)
64{
65
66    enum caca_event_type t;
67
68    t = caca_get_event_type(&ev);
69
70    if (t & CACA_EVENT_KEY_PRESS)
71    {
72        char buf[16];
73        int bytes;
74        bytes =
75            snprintf(buf, sizeof(buf) - 1, "KEY %d",
76                     caca_get_event_key_ch(&ev));
77        buf[bytes] = '\0';
78        debug("Sending key press to server: %s", buf);
79        debug("Sending '%s', %d bytes\n", buf, strlen(buf));
80        return write(screen_list->comm.socket[SOCK_SERVER], buf,
81                     strlen(buf) + 1) <= 0;
82    }
83    else if (t & CACA_EVENT_RESIZE)
84    {
85
86        char buf[32];
87        int bytes;
88        bytes = snprintf(buf, sizeof(buf) - 1, "RESIZE %10d %10d",
89                         caca_get_event_resize_width(&ev),
90                         caca_get_event_resize_height(&ev));
91        buf[bytes] = '\0';
92        debug("Sending '%s', %d bytes\n", buf, strlen(buf));
93        return write(screen_list->comm.socket[SOCK_SERVER], buf,
94                     strlen(buf) + 1) <= 0;
95    }
96    else if (t & CACA_EVENT_MOUSE_PRESS)
97    {
98        char buf[52];
99        int bytes;
100        bytes = snprintf(buf, sizeof(buf) - 1, "MOUSEP %10d %10d %10d",
101                         caca_get_mouse_x(screen_list->dp),
102                         caca_get_mouse_y(screen_list->dp),
103                         caca_get_event_mouse_button(&ev));
104        buf[bytes] = '\0';
105        debug("Sending '%s', %d bytes\n", buf, strlen(buf));
106        return write(screen_list->comm.socket[SOCK_SERVER], buf,
107                     strlen(buf) + 1) <= 0;
108    }
109    else if (t & CACA_EVENT_MOUSE_MOTION)
110    {
111        int x = caca_get_mouse_x(screen_list->dp);
112        int y = caca_get_mouse_y(screen_list->dp);
113        if (x != screen_list->old_x || y != screen_list->old_y)
114        {
115            screen_list->old_x = caca_get_mouse_x(screen_list->dp);
116            screen_list->old_y = caca_get_mouse_y(screen_list->dp);
117
118            char buf[52];
119            int bytes;
120            bytes = snprintf(buf, sizeof(buf) - 1, "MOUSEM %10d %10d",
121                             caca_get_mouse_x(screen_list->dp),
122                             caca_get_mouse_y(screen_list->dp));
123            buf[bytes] = '\0';
124            debug("Sending '%s', %d bytes\n", buf, strlen(buf));
125            return write(screen_list->comm.socket[SOCK_SERVER], buf,
126                         strlen(buf) + 1) <= 0;
127        }
128        return 0;
129    }
130    else if (t & CACA_EVENT_QUIT)
131        return write(screen_list->comm.socket[SOCK_SERVER], "QUIT",
132                     strlen("QUIT")) <= 0;
133
134    return 0;
135}
136
137int send_delay(struct screen_list *screen_list)
138{
139    debug("Sending DELAY\n");
140    char buf[18];
141    int bytes;
142    bytes = snprintf(buf, sizeof(buf) - 1, "DELAY %10d", screen_list->delay);
143    buf[bytes] = '\0';
144    return write(screen_list->comm.socket[SOCK_SERVER], buf, strlen(buf)) <= 0;
145}
146
147
148void mainloop(struct screen_list *screen_list)
149{
150    char *buf = NULL;
151
152    screen_list->last_key_time = get_us();
153
154    for (;;)
155    {
156        caca_event_t ev;
157        int ret = 0;
158        ssize_t n;
159        if (!screen_list)
160            goto end;
161        if (!buf)
162            buf = malloc(NEERCS_RECV_BUFSIZE);
163        if (!buf)
164        {
165            debug("Failed to allocate memory");
166            goto end;
167        }
168        if (screen_list->comm.socket[SOCK_CLIENT]
169            && (n =
170                read(screen_list->comm.socket[SOCK_CLIENT], buf,
171                     NEERCS_RECV_BUFSIZE - 1)) > 0)
172        {
173            buf[n] = 0;
174            debug("Received from server: '%s' (%d bytes)", buf, n);
175            if (!strncmp("DETACH", buf, 6))
176            {
177                /* ret = 1; Not used */
178                break;
179            }
180            else if (!strncmp("UPDATE ", buf, 7))
181            {
182                int x, y;
183                ssize_t l2 = 0, lb = 0;
184                char *buf2;
185                size_t l = 0;
186                /* FIXME check the length before calling atoi */
187                x = atoi(buf + 8);
188                y = atoi(buf + 19);
189
190                /* 0 means we have valid data but incomplete, so read the rest
191                 */
192                while (l == 0)
193                {
194                    buf2 = realloc(buf, l2 + NEERCS_RECV_BUFSIZE);
195                    if (!buf2)
196                    {
197                        debug("Failed to allocate memory");
198                        goto end;
199                    }
200                    buf = buf2;
201                    fcntl(screen_list->comm.socket[SOCK_CLIENT], F_SETFL, 0);
202                    lb = read(screen_list->comm.socket[SOCK_CLIENT], buf + l2,
203                              NEERCS_RECV_BUFSIZE - 1);
204                    if (lb < 0)
205                    {
206                        debug
207                            ("Failed to read the end of the refresh message (%s)",
208                             strerror(errno));
209                        l = -1;
210                    }
211                    else
212                    {
213                        l2 += lb;
214#if defined HAVE_CACA_DIRTY_RECTANGLES
215                        l = caca_import_area_from_memory(screen_list->cv, x, y,
216                                                         buf, l2, "caca");
217#else
218                        l = caca_import_from_memory(screen_list->cv, buf, l2,
219                                                    "caca");
220#endif
221                    }
222                }
223                fcntl(screen_list->comm.socket[SOCK_CLIENT], F_SETFL,
224                      O_NONBLOCK);
225            }
226            else if (!strncmp("REFRESH ", buf, 8))
227            {
228                int dt, x, y;
229                /* FIXME check the length before calling atoi */
230                x = atoi(buf + 8);
231                y = atoi(buf + 19);
232                caca_gotoxy(screen_list->cv, x, y);
233                caca_refresh_display(screen_list->dp);
234                dt = caca_get_display_time(screen_list->dp);
235
236                /* Adjust refresh delay so that the server do not compute
237                   useless things */
238                if (dt > 2 * 1000 * screen_list->delay
239                    && screen_list->delay <= 100)
240                {
241                    screen_list->delay *= 2;
242                    send_delay(screen_list);
243                }
244                else if (dt < screen_list->delay * 1000 * 1.2 &&
245                         screen_list->delay >=
246                         3 * screen_list->requested_delay / 2)
247                {
248                    screen_list->delay = 2 * screen_list->delay / 3;
249                    send_delay(screen_list);
250                }
251            }
252            else if (!strncmp("CURSOR ", buf, 7))
253            {
254                caca_set_cursor(screen_list->dp, atoi(buf + 7));
255            }
256            else if (!strncmp("TITLE ", buf, 6))
257            {
258                caca_set_display_title(screen_list->dp, buf + 6);
259                caca_refresh_display(screen_list->dp);
260            }
261            else
262            {
263                debug("Unknown message received from server: %s", buf);
264            }
265        }
266
267        if (ret)
268        {
269            debug("ret1\n");
270            break;
271        }
272        ret = caca_get_event(screen_list->dp,
273                             CACA_EVENT_KEY_PRESS
274                             | CACA_EVENT_MOUSE_PRESS
275                             | CACA_EVENT_MOUSE_RELEASE
276                             | CACA_EVENT_MOUSE_MOTION
277                             | CACA_EVENT_RESIZE
278                             | CACA_EVENT_QUIT, &ev, 10000);
279        if (ret)
280            ret = send_event(ev, screen_list);
281
282        if (ret)
283        {
284            debug("ret2\n");
285            break;
286        }
287    }
288
289  end:
290    if (buf)
291        free(buf);
292
293}
Note: See TracBrowser for help on using the repository browser.