using threads to try speed up desktop switching but its not working out
[dana/xcompmgr.git] / xcompmgr.c
index a142cff..b9f11a3 100644 (file)
 #include <sys/time.h>
 #include <time.h>
 #include <unistd.h>
+#include <pthread.h>
+#include <sys/types.h>
+#include <signal.h>
+#include <getopt.h>
 #include <X11/Xlib.h>
 #include <X11/Xutil.h>
 #include <X11/Xatom.h>
@@ -59,6 +63,9 @@ typedef struct _win {
     Window             id;
 #if HAS_NAME_WINDOW_PIXMAP
     Pixmap             pixmap;
+    pthread_t           pixmap_thread;
+    int                 pixmap_nthreads;
+    pthread_mutex_t     pixmap_lock;
 #endif
     XWindowAttributes  a;
 #if CAN_DO_USABLE
@@ -81,6 +88,7 @@ typedef struct _win {
     unsigned int       opacity;
     Atom                windowType;
     unsigned long      damage_sequence;    /* sequence when damage was created */
+    Bool                unmapped_configure;
 
     /* for drawing translucent windows */
     XserverRegion      borderClip;
@@ -98,11 +106,17 @@ typedef struct _fade {
     double             cur;
     double             finish;
     double             step;
-    void               (*callback) (Display *dpy, win *w, Bool gone);
+    void               (*callback) (Display *dpy, win *w);
     Display            *dpy;
-    Bool               gone;
 } fade;
 
+typedef struct _threaddata {
+    Display             *dpy;
+    win                 *w;
+    XserverRegion        extents;
+    pthread_t            prev_thread;
+} threaddata;
+
 win             *list;
 fade           *fades;
 Display                *dpy;
@@ -114,6 +128,7 @@ Picture             blackPicture;
 Picture                transBlackPicture;
 Picture                rootTile;
 XserverRegion  allDamage;
+pthread_mutex_t damage_lock = PTHREAD_MUTEX_INITIALIZER;
 Bool           clipChanged;
 #if HAS_NAME_WINDOW_PIXMAP
 Bool           hasNamePixmap;
@@ -229,7 +244,7 @@ dequeue_fade (Display *dpy, fade *f)
        {
            *prev = f->next;
            if (f->callback)
-               (*f->callback) (dpy, f->w, f->gone);
+               (*f->callback) (dpy, f->w);
            free (f);
            break;
        }
@@ -254,8 +269,8 @@ enqueue_fade (Display *dpy, fade *f)
 
 static void
 set_fade (Display *dpy, win *w, double start, double finish, double step,
-         void (*callback) (Display *dpy, win *w, Bool gone),
-         Bool gone, Bool exec_callback, Bool override)
+         void (*callback) (Display *dpy, win *w),
+         Bool exec_callback, Bool override)
 {
     fade    *f;
 
@@ -274,7 +289,7 @@ set_fade (Display *dpy, win *w, double start, double finish, double step,
     {
        if (exec_callback)
            if (f->callback)
-               (*f->callback)(dpy, f->w, f->gone);
+               (*f->callback)(dpy, f->w);
     }
 
     if (finish < 0)
@@ -287,7 +302,6 @@ set_fade (Display *dpy, win *w, double start, double finish, double step,
     else if (f->cur > finish)
        f->step = -step;
     f->callback = callback;
-    f->gone = gone;
     w->opacity = f->cur * OPAQUE;
 #if 0
     printf ("set_fade start %g step %g\n", f->cur, f->step);
@@ -320,7 +334,7 @@ void
 run_fades (Display *dpy)
 {
     int            now = get_time_in_milliseconds();
-    fade    *f, *next;
+    fade    *next = fades;
     int            steps;
     Bool    need_dequeue;
 
@@ -330,8 +344,10 @@ run_fades (Display *dpy)
     if (fade_time - now > 0)
        return;
     steps = 1 + (now - fade_time) / fade_delta;
-    for (next = fades; f = next; )
+
+    while (next)
     {
+       fade *f = next;
        win *w = f->w;
        next = f->next;
        f->cur += f->step * steps;
@@ -751,7 +767,7 @@ find_win (Display *dpy, Window id)
     return 0;
 }
 
-static char *backgroundProps[] = {
+static const char *backgroundProps[] = {
     "_XROOTPMAP_ID",
     "_XSETROOT_ID",
     0,
@@ -900,10 +916,162 @@ border_size (Display *dpy, win *w)
 }
 
 static void
+add_damage (Display *dpy, XserverRegion damage)
+{
+    pthread_mutex_lock (&damage_lock);
+    if (allDamage)
+    {
+       XFixesUnionRegion (dpy, allDamage, allDamage, damage);
+       XFixesDestroyRegion (dpy, damage);
+    }
+    else
+       allDamage = damage;
+    pthread_mutex_unlock (&damage_lock);
+}
+
+static void
+repair_win (Display *dpy, win *w)
+{
+    XserverRegion   parts;
+
+    if (!w->damaged)
+    {
+       parts = win_extents (dpy, w);
+       set_ignore (dpy, NextRequest (dpy));
+       XDamageSubtract (dpy, w->damage, None, None);
+    }
+    else
+    {
+       XserverRegion   o;
+       parts = XFixesCreateRegion (dpy, 0, 0);
+       set_ignore (dpy, NextRequest (dpy));
+       XDamageSubtract (dpy, w->damage, None, parts);
+       XFixesTranslateRegion (dpy, parts,
+                              w->a.x + w->a.border_width,
+                              w->a.y + w->a.border_width);
+       if (compMode == CompServerShadows)
+       {
+           o = XFixesCreateRegion (dpy, 0, 0);
+           XFixesCopyRegion (dpy, o, parts);
+           XFixesTranslateRegion (dpy, o, w->shadow_dx, w->shadow_dy);
+           XFixesUnionRegion (dpy, parts, parts, o);
+           XFixesDestroyRegion (dpy, o);
+       }
+    }
+    if (!w->picture)
+        printf("adding damage 0x%x 0x%x\n", w->id, w->picture);
+    add_damage (dpy, parts);
+    w->damaged = 1;
+}
+
+#if HAS_NAME_WINDOW_PIXMAP
+static void*
+get_pixmap_thread (void *vdata)
+{
+    threaddata *d = vdata;
+    Pixmap pix;
+    Picture pic;
+
+    /* if another thread is already running for this window, then wait for it
+       to exit before start */
+    if (d->prev_thread != 0) {
+        void *ret;
+
+        pthread_join (d->prev_thread, &ret);
+    }
+
+    pix = None;
+    pic = None;
+
+    printf("getting pixmap for 0x%x\n", d->w->id);
+
+    /* this is the slow stuff */
+    XLockDisplay (d->dpy);
+    pix = XCompositeNameWindowPixmap (d->dpy, d->w->id);
+    if (pix) {
+        XRenderPictureAttributes       pa;
+        XRenderPictFormat              *format;
+
+        format = XRenderFindVisualFormat (d->dpy, d->w->a.visual);
+        pa.subwindow_mode = IncludeInferiors;
+        pic = XRenderCreatePicture (d->dpy, pix,
+                                    format,
+                                    CPSubwindowMode,
+                                    &pa);
+    }
+    XUnlockDisplay (d->dpy);
+
+    /* we're done the slow stuff so lock and set things */
+
+    if (pic) {
+        pthread_mutex_lock (&d->w->pixmap_lock);
+
+        if (d->w->pixmap)
+        {
+            XFreePixmap (dpy, d->w->pixmap);
+            d->w->pixmap = None;
+        }
+
+        if (d->w->picture)
+        {
+            XRenderFreePicture (dpy, d->w->picture);
+            d->w->picture = None;
+        }
+
+        d->w->pixmap = pix;
+        d->w->picture = pic;
+
+        pthread_mutex_unlock (&d->w->pixmap_lock);
+
+        /* make the window redraw */
+        //add_damage(d->dpy, d->extents);
+        /* wake up the main loop */
+        kill(getpid(), SIGURG);
+    }
+
+    free(vdata);
+
+    pthread_mutex_lock (&d->w->pixmap_lock);
+    d->w->pixmap_nthreads--;
+    pthread_mutex_unlock (&d->w->pixmap_lock);
+
+    return NULL;
+}
+#endif
+
+#if HAS_NAME_WINDOW_PIXMAP
+static void
+start_get_pixmap_thread (Display *dpy, win *w, XserverRegion extents)
+{
+    if (hasNamePixmap) {
+        threaddata  *data;
+
+        pthread_mutex_lock (&w->pixmap_lock);
+        w->pixmap_nthreads++;
+        pthread_mutex_unlock (&w->pixmap_lock);
+
+        data = malloc (sizeof (threaddata));
+        data->dpy = dpy;
+        data->w = w;
+        data->extents = extents;
+        data->prev_thread = w->pixmap_thread;
+        if (pthread_create (&w->pixmap_thread, NULL, get_pixmap_thread, data))
+        {
+            /* error */
+            pthread_mutex_lock (&w->pixmap_lock);
+            w->pixmap_nthreads--;
+            pthread_mutex_unlock (&w->pixmap_lock);
+        }
+    }
+}
+#endif
+
+static Bool
 paint_all (Display *dpy, XserverRegion region)
 {
     win        *w;
     win        *t = 0;
+    Bool pending = False;
     
     if (!region)
     {
@@ -949,25 +1117,31 @@ paint_all (Display *dpy, XserverRegion region)
        if (w->a.x + w->a.width < 1 || w->a.y + w->a.height < 1
            || w->a.x >= root_width || w->a.y >= root_height)
            continue;
+
+#if HAS_NAME_WINDOW_PIXMAP
+        pthread_mutex_lock (&w->pixmap_lock);
+#endif
        if (!w->picture)
        {
            XRenderPictureAttributes    pa;
            XRenderPictFormat           *format;
-           Drawable                    draw = w->id;
            
-#if HAS_NAME_WINDOW_PIXMAP
-           if (hasNamePixmap && !w->pixmap)
-               w->pixmap = XCompositeNameWindowPixmap (dpy, w->id);
-           if (w->pixmap)
-               draw = w->pixmap;
-#endif
            format = XRenderFindVisualFormat (dpy, w->a.visual);
            pa.subwindow_mode = IncludeInferiors;
-           w->picture = XRenderCreatePicture (dpy, draw,
+           w->picture = XRenderCreatePicture (dpy, w->id,
                                               format,
                                               CPSubwindowMode,
                                               &pa);
+            printf("got temp picture for 0x%x\n", w->id);
+
+#if HAS_NAME_WINDOW_PIXMAP
+            pending = True;
+#endif
        }
+#if HAS_NAME_WINDOW_PIXMAP
+        pthread_mutex_unlock (&w->pixmap_lock);
+#endif
+
 #if DEBUG_REPAINT
        printf (" 0x%x", w->id);
 #endif
@@ -1116,51 +1290,8 @@ paint_all (Display *dpy, XserverRegion region)
        XRenderComposite (dpy, PictOpSrc, rootBuffer, None, rootPicture,
                          0, 0, 0, 0, 0, 0, root_width, root_height);
     }
-}
 
-static void
-add_damage (Display *dpy, XserverRegion damage)
-{
-    if (allDamage)
-    {
-       XFixesUnionRegion (dpy, allDamage, allDamage, damage);
-       XFixesDestroyRegion (dpy, damage);
-    }
-    else
-       allDamage = damage;
-}
-
-static void
-repair_win (Display *dpy, win *w)
-{
-    XserverRegion   parts;
-
-    if (!w->damaged)
-    {
-       parts = win_extents (dpy, w);
-       set_ignore (dpy, NextRequest (dpy));
-       XDamageSubtract (dpy, w->damage, None, None);
-    }
-    else
-    {
-       XserverRegion   o;
-       parts = XFixesCreateRegion (dpy, 0, 0);
-       set_ignore (dpy, NextRequest (dpy));
-       XDamageSubtract (dpy, w->damage, None, parts);
-       XFixesTranslateRegion (dpy, parts,
-                              w->a.x + w->a.border_width,
-                              w->a.y + w->a.border_width);
-       if (compMode == CompServerShadows)
-       {
-           o = XFixesCreateRegion (dpy, 0, 0);
-           XFixesCopyRegion (dpy, o, parts);
-           XFixesTranslateRegion (dpy, o, w->shadow_dx, w->shadow_dy);
-           XFixesUnionRegion (dpy, parts, parts, o);
-           XFixesDestroyRegion (dpy, o);
-       }
-    }
-    add_damage (dpy, parts);
-    w->damaged = 1;
+    return pending;
 }
 
 static unsigned int
@@ -1190,7 +1321,11 @@ map_win (Display *dpy, Window id, unsigned long sequence, Bool fade)
     w->damaged = 0;
 
     if (fade && fadeWindows)
-       set_fade (dpy, w, 0, get_opacity_percent (dpy, w, 1.0), fade_in_step, 0, False, True, True);
+       set_fade (dpy, w, 0, get_opacity_percent (dpy, w, 1.0), fade_in_step, 0, True, True);
+
+#if HAS_NAME_WINDOW_PIXMAP
+    start_get_pixmap_thread (dpy, w, 0);
+#endif
 }
 
 static void
@@ -1205,22 +1340,24 @@ finish_unmap_win (Display *dpy, win *w)
        add_damage (dpy, w->extents);    /* destroys region */
        w->extents = None;
     }
-    
+
+    if (w->unmapped_configure) {
 #if HAS_NAME_WINDOW_PIXMAP
-    if (w->pixmap)
-    {
-       XFreePixmap (dpy, w->pixmap);
-       w->pixmap = None;
-    }
+        pthread_mutex_lock (&w->pixmap_lock);
+        if (w->pixmap)
+        {
+            XFreePixmap (dpy, w->pixmap);
+            w->pixmap = None;
+            if (w->picture)
+            {
+                XRenderFreePicture (dpy, w->picture);
+                w->picture = None;
+            }
+        }
+        pthread_mutex_unlock (&w->pixmap_lock);
 #endif
-
-    if (w->picture)
-    {
-       set_ignore (dpy, NextRequest (dpy));
-       XRenderFreePicture (dpy, w->picture);
-       w->picture = None;
     }
-
+    
     /* don't care about properties anymore */
     set_ignore (dpy, NextRequest (dpy));
     XSelectInput(dpy, w->id, 0);
@@ -1247,7 +1384,7 @@ finish_unmap_win (Display *dpy, win *w)
 
 #if HAS_NAME_WINDOW_PIXMAP
 static void
-unmap_callback (Display *dpy, win *w, Bool gone)
+unmap_callback (Display *dpy, win *w)
 {
     finish_unmap_win (dpy, w);
 }
@@ -1262,7 +1399,7 @@ unmap_win (Display *dpy, Window id, Bool fade)
     w->a.map_state = IsUnmapped;
 #if HAS_NAME_WINDOW_PIXMAP
     if (w->pixmap && fade && fadeWindows)
-       set_fade (dpy, w, w->opacity*1.0/OPAQUE, 0.0, fade_out_step, unmap_callback, False, False, True);
+       set_fade (dpy, w, w->opacity*1.0/OPAQUE, 0.0, fade_out_step, unmap_callback, False, True);
     else
 #endif
        finish_unmap_win (dpy, w);
@@ -1444,6 +1581,9 @@ add_win (Display *dpy, Window id, Window prev)
 #endif
 #if HAS_NAME_WINDOW_PIXMAP
     new->pixmap = None;
+    new->pixmap_thread = 0;
+    new->pixmap_nthreads = 0;
+    pthread_mutex_init(&new->pixmap_lock, NULL);
 #endif
     new->picture = None;
     if (new->a.class == InputOnly)
@@ -1466,6 +1606,7 @@ add_win (Display *dpy, Window id, Window prev)
     new->shadow_width = 0;
     new->shadow_height = 0;
     new->opacity = OPAQUE;
+    new->unmapped_configure = False;
 
     new->borderClip = None;
     new->prev_trans = 0;
@@ -1538,32 +1679,28 @@ configure_win (Display *dpy, XConfigureEvent *ce)
     }
     w->a.x = ce->x;
     w->a.y = ce->y;
+    /* Only destroy the pixmap if the window is mapped */
     if (w->a.width != ce->width || w->a.height != ce->height)
     {
+        if (w->a.map_state == IsUnmapped)
+            w->unmapped_configure = True;
+        else {
 #if HAS_NAME_WINDOW_PIXMAP
-       if (w->pixmap)
-       {
-           XFreePixmap (dpy, w->pixmap);
-           w->pixmap = None;
-           if (w->picture)
-           {
-               XRenderFreePicture (dpy, w->picture);
-               w->picture = None;
-           }
-       }
+            start_get_pixmap_thread (dpy, w, 0);
 #endif
-       if (w->shadow)
-       {
-           XRenderFreePicture (dpy, w->shadow);
-           w->shadow = None;
-       }
+            if (w->shadow)
+            {
+                XRenderFreePicture (dpy, w->shadow);
+                w->shadow = None;
+            }
+        }
     }
     w->a.width = ce->width;
     w->a.height = ce->height;
     w->a.border_width = ce->border_width;
     w->a.override_redirect = ce->override_redirect;
     restack_win (dpy, w, ce->above);
-    if (damage)
+    if (w->a.map_state != IsUnmapped && damage)
     {
        XserverRegion   extents = win_extents (dpy, w);
        XFixesUnionRegion (dpy, damage, damage, extents);
@@ -1591,22 +1728,33 @@ circulate_win (Display *dpy, XCirculateEvent *ce)
 }
 
 static void
-finish_destroy_win (Display *dpy, Window id, Bool gone)
+finish_destroy_win (Display *dpy, Window id)
 {
     win        **prev, *w;
+    void *ret;
 
     for (prev = &list; (w = *prev); prev = &w->next)
        if (w->id == id)
        {
-           if (gone)
-               finish_unmap_win (dpy, w);
+            /* join before freeing stuff so nothing leaks */
+            if (w->pixmap_nthreads > 0)
+                pthread_join (w->pixmap_thread, &ret);
+
+            finish_unmap_win (dpy, w);
            *prev = w->next;
-           if (w->picture)
-           {
-               set_ignore (dpy, NextRequest (dpy));
-               XRenderFreePicture (dpy, w->picture);
-               w->picture = None;
-           }
+#if HAS_NAME_WINDOW_PIXMAP
+            if (w->pixmap)
+            {
+                XFreePixmap (dpy, w->pixmap);
+                w->pixmap = None;
+            }
+#endif
+            if (w->picture)
+            {
+                set_ignore (dpy, NextRequest (dpy));
+                XRenderFreePicture (dpy, w->picture);
+                w->picture = None;
+            }
            if (w->alphaPict)
            {
                XRenderFreePicture (dpy, w->alphaPict);
@@ -1624,6 +1772,7 @@ finish_destroy_win (Display *dpy, Window id, Bool gone)
                w->damage = None;
            }
            cleanup_fade (dpy, w);
+            pthread_mutex_destroy(&w->pixmap_lock);
            free (w);
            break;
        }
@@ -1631,23 +1780,24 @@ finish_destroy_win (Display *dpy, Window id, Bool gone)
 
 #if HAS_NAME_WINDOW_PIXMAP
 static void
-destroy_callback (Display *dpy, win *w, Bool gone)
+destroy_callback (Display *dpy, win *w)
 {
-    finish_destroy_win (dpy, w->id, gone);
+    finish_destroy_win (dpy, w->id);
 }
 #endif
 
 static void
-destroy_win (Display *dpy, Window id, Bool gone, Bool fade)
+destroy_win (Display *dpy, Window id, Bool fade)
 {
     win *w = find_win (dpy, id);
 #if HAS_NAME_WINDOW_PIXMAP
     if (w && w->pixmap && fade && fadeWindows)
-       set_fade (dpy, w, w->opacity*1.0/OPAQUE, 0.0, fade_out_step, destroy_callback, gone, False, True);
+       set_fade (dpy, w, w->opacity*1.0/OPAQUE, 0.0, fade_out_step,
+                  destroy_callback, False, (w->a.map_state != IsUnmapped));
     else
 #endif
     {
-       finish_destroy_win (dpy, id, gone);
+       finish_destroy_win (dpy, id);
     }
 }
 
@@ -1720,7 +1870,7 @@ damage_win (Display *dpy, XDamageNotifyEvent *de)
        {
            clipChanged = True;
            if (fadeWindows)
-               set_fade (dpy, w, 0, get_opacity_percent (dpy, w, 1.0), fade_in_step, 0, False, True, True);
+               set_fade (dpy, w, 0, get_opacity_percent (dpy, w, 1.0), fade_in_step, 0, True, True);
            w->usable = True;
        }
     }
@@ -1733,7 +1883,7 @@ static int
 error (Display *dpy, XErrorEvent *ev)
 {
     int            o;
-    char    *name = 0;
+    const char    *name = 0;
     
     if (should_ignore (dpy, ev->serial))
        return 0;
@@ -1957,7 +2107,8 @@ main (int argc, char **argv)
            break;
        }
     }
-    
+
+    XInitThreads();
     dpy = XOpenDisplay (display);
     if (!dpy)
     {
@@ -2084,7 +2235,7 @@ main (int argc, char **argv)
                configure_win (dpy, &ev.xconfigure);
                break;
            case DestroyNotify:
-               destroy_win (dpy, ev.xdestroywindow.window, True, True);
+               destroy_win (dpy, ev.xdestroywindow.window, True);
                break;
            case MapNotify:
                map_win (dpy, ev.xmap.window, ev.xmap.serial, True);
@@ -2096,7 +2247,7 @@ main (int argc, char **argv)
                if (ev.xreparent.parent == root)
                    add_win (dpy, ev.xreparent.window, 0);
                else
-                   destroy_win (dpy, ev.xreparent.window, False, True);
+                   destroy_win (dpy, ev.xreparent.window, True);
                break;
            case CirculateNotify:
                circulate_win (dpy, &ev.xcirculate);
@@ -2155,7 +2306,7 @@ main (int argc, char **argv)
                    {
                        if (fadeTrans)
                            set_fade (dpy, w, w->opacity*1.0/OPAQUE, get_opacity_percent (dpy, w, 1.0),
-                                     fade_out_step, 0, False, True, False);
+                                     fade_out_step, 0, True, False);
                        else
                        {
                        w->opacity = get_opacity_prop(dpy, w, OPAQUE);
@@ -2176,14 +2327,16 @@ main (int argc, char **argv)
                break;
            }
        } while (QLength (dpy));
+        pthread_mutex_lock (&damage_lock);
        if (allDamage && !autoRedirect)
        {
            static int  paint;
-           paint_all (dpy, allDamage);
+           if (!paint_all (dpy, allDamage))
+                allDamage = None;
            paint++;
            XSync (dpy, False);
-           allDamage = None;
            clipChanged = False;
        }
+        pthread_mutex_unlock (&damage_lock);
     }
 }