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

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