awesomewm-mirrors
/
awesome
mirror of https://github.com/awesomeWM/awesome.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

[awesome] Make layout and statusbar refresh threaded 

Signed-off-by: Julien Danjou <julien@danjou.info>
This commit is contained in:
Julien Danjou 2008-05-21 15:33:08 +02:00
parent 3c6f9a8fa0
commit a953b57a87
1 changed files with 20 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
awesome.c
View File

@ -34,6 +34,8 @@
#include <fcntl.h> #include <fcntl.h>
#include <signal.h> #include <signal.h>
#include <pthread.h>
#include <xcb/xcb.h> #include <xcb/xcb.h>
#include <xcb/shape.h> #include <xcb/shape.h>
#include <xcb/randr.h> #include <xcb/randr.h>
@ -61,6 +63,12 @@ bool running = true;
AwesomeConf globalconf; AwesomeConf globalconf;
#define a_thread_refresh(id, fct) \
do { \
if(pthread_create(id, NULL, fct, NULL)) \
perror("error creating thread\n"); \
} while(0)
typedef struct typedef struct
{ {
xcb_window_t id; xcb_window_t id;
@ -284,6 +292,7 @@ main(int argc, char **argv)
xcb_generic_event_t *ev; xcb_generic_event_t *ev;
struct sockaddr_un *addr; struct sockaddr_un *addr;
client_t *c; client_t *c;
pthread_t tid_layout, tid_statusbar;
static struct option long_options[] = static struct option long_options[] =
{ {
{"help", 0, NULL, 'h'}, {"help", 0, NULL, 'h'},
@ -504,38 +513,40 @@ main(int argc, char **argv)
break; break;
buf[r] = '\0'; buf[r] = '\0';
luaA_docmd(buf); luaA_docmd(buf);
statusbar_refresh(NULL);
layout_refresh(NULL);
} }
if(dbusfd >= 0 && FD_ISSET(dbusfd, &rd)) if(dbusfd >= 0 && FD_ISSET(dbusfd, &rd))
a_dbus_process_requests(&dbusfd); a_dbus_process_requests(&dbusfd);
/* two level XPending: /* Two level polling:
* we need to first check we have XEvent to handle * We need to first check we have an event to handle
* and if so, we handle them all in a round. * and if so, we handle them all in a round.
* Then when we have refresh()'ed stuff so maybe new XEvent * Then when we have refresh()'ed stuff so maybe new XEvent
* are available and select() won't tell us, so let's check * are available and select() won't tell us, so let's check
* with XPending() again. * with xcb_poll_for_event() again.
*/ */
while((ev = xcb_poll_for_event(globalconf.connection))) while((ev = xcb_poll_for_event(globalconf.connection)))
{ {
do do
{ {
xcb_handle_event(globalconf.evenths, ev); xcb_handle_event(globalconf.evenths, ev);
/* need to resync */ /* need to resync */
xcb_aux_sync(globalconf.connection); xcb_aux_sync(globalconf.connection);
p_delete(&ev); p_delete(&ev);
} while((ev = xcb_poll_for_event(globalconf.connection))); } while((ev = xcb_poll_for_event(globalconf.connection)));
statusbar_refresh(NULL); a_thread_refresh(&tid_statusbar, &statusbar_refresh);
layout_refresh(NULL); a_thread_refresh(&tid_layout, &layout_refresh);
pthread_join(tid_statusbar, NULL);
pthread_join(tid_layout, NULL);
/* need to resync */ /* need to resync */
xcb_aux_sync(globalconf.connection); xcb_aux_sync(globalconf.connection);
} }
a_thread_refresh(&tid_statusbar, &statusbar_refresh);
a_thread_refresh(&tid_layout, &layout_refresh);
pthread_join(tid_statusbar, NULL);
pthread_join(tid_layout, NULL);
xcb_aux_sync(globalconf.connection); xcb_aux_sync(globalconf.connection);
} }