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

Last change on this file since 3954 was 3954, checked in by Jean-Yves Lamoureux, 10 years ago
  • Fixed numerous warnings (warn_unused_result and deprecated libcaca functions, mostly)
File size: 5.6 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#include <caca.h>
35
36#include "neercs.h"
37
38#define NEERCS_RECV_BUFSIZE 128*1024
39
40void mainloop(struct screen_list *screen_list)
41{
42    char *buf = NULL;
43
44    screen_list->last_key_time = get_us();
45
46    for (;;)
47    {
48        caca_event_t ev;
49        int ret = 0;
50        ssize_t n;
51        if (!screen_list)
52            goto end;
53        if (!buf)
54            buf = malloc(NEERCS_RECV_BUFSIZE);
55        if (!buf)
56        {
57            debug("Failed to allocate memory");
58            goto end;
59        }
60        if (screen_list->socket[SOCK_CLIENT]
61            && (n =
62                read(screen_list->socket[SOCK_CLIENT], buf,
63                     NEERCS_RECV_BUFSIZE - 1)) > 0)
64        {
65            buf[n] = 0;
66            debug("Received from server: %s", buf);
67            if (!strncmp("DETACH", buf, 6))
68            {
69                ret = 1;
70                break;
71            }
72            else if (!strncmp("UPDATE ", buf, 7))
73            {
74                int x, y;
75                ssize_t l2 = 0, lb = 0;
76                char *buf2;
77                size_t l = 0;
78                /* FIXME check the length before calling atoi */
79                x = atoi(buf + 8);
80                y = atoi(buf + 19);
81                /* 0 means we have valid data but incomplete, so read the rest
82                 */
83                while (l == 0)
84                {
85                    buf2 = realloc(buf, l2 + NEERCS_RECV_BUFSIZE);
86                    if (!buf2)
87                    {
88                        debug("Failed to allocate memory");
89                        goto end;
90                    }
91                    buf = buf2;
92                    fcntl(screen_list->socket[SOCK_CLIENT], F_SETFL, 0);
93                    lb = read(screen_list->socket[SOCK_CLIENT], buf + l2,
94                              NEERCS_RECV_BUFSIZE - 1);
95                    if (lb < 0)
96                    {
97                        debug
98                            ("Failed to read the end of the refresh message (%s)",
99                             strerror(errno));
100                        l = -1;
101                    }
102                    else
103                    {
104                        l2 += lb;
105#if defined HAVE_CACA_DIRTY_RECTANGLES
106                        l = caca_import_area_from_memory(screen_list->cv, x, y,
107                                                         buf, l2, "caca");
108#else
109                        l = caca_import_memory(screen_list->cv, buf, l2,
110                                               "caca");
111#endif
112                    }
113                }
114                fcntl(screen_list->socket[SOCK_CLIENT], F_SETFL, O_NONBLOCK);
115            }
116            else if (!strncmp("REFRESH ", buf, 8))
117            {
118                int dt, x, y;
119                /* FIXME check the length before calling atoi */
120                x = atoi(buf + 8);
121                y = atoi(buf + 19);
122                caca_gotoxy(screen_list->cv, x, y);
123                caca_refresh_display(screen_list->dp);
124                dt = caca_get_display_time(screen_list->dp);
125                debug("refreshtime=%dms (limit %d, requested %d)", dt / 1000,
126                      screen_list->delay, screen_list->requested_delay);
127                /* Adjust refresh delay so that the server do not compute
128                   useless things */
129                if (dt > 2 * 1000 * screen_list->delay
130                    && screen_list->delay <= 100)
131                {
132                    screen_list->delay *= 2;
133                    send_delay(screen_list);
134                }
135                else if (dt < screen_list->delay * 1000 * 1.2 &&
136                         screen_list->delay >=
137                         3 * screen_list->requested_delay / 2)
138                {
139                    screen_list->delay = 2 * screen_list->delay / 3;
140                    send_delay(screen_list);
141                }
142            }
143            else if (!strncmp("CURSOR ", buf, 7))
144            {
145                caca_set_cursor(screen_list->dp, atoi(buf + 7));
146            }
147            else if (!strncmp("TITLE ", buf, 6))
148            {
149                caca_set_display_title(screen_list->dp, buf + 6);
150                caca_refresh_display(screen_list->dp);
151            }
152            else
153            {
154                debug("Unknown message received from server: %s", buf);
155            }
156        }
157
158        if (ret)
159            break;
160
161        ret = caca_get_event(screen_list->dp,
162                             CACA_EVENT_KEY_PRESS
163                             | CACA_EVENT_RESIZE
164                             | CACA_EVENT_QUIT, &ev, 10000);
165        if (ret)
166            ret = send_event(ev, screen_list);
167
168        if (ret)
169            break;
170    }
171
172  end:
173    if (buf)
174        free(buf);
175
176}
Note: See TracBrowser for help on using the repository browser.