xserver git update 15/5/2010

1 files changed, 681 insertions, 681 deletions

diff --git a/xorg-server/os/WaitFor.c b/xorg-server/os/WaitFor.c
index dfe85e515..ac4b58e48 100644
--- a/xorg-server/os/WaitFor.c
+++ b/xorg-server/os/WaitFor.c
@@ -1,681 +1,681 @@
-/***********************************************************
-
-Copyright 1987, 1998  The Open Group
-
-Permission to use, copy, modify, distribute, and sell this software and its
-documentation for any purpose is hereby granted without fee, provided that
-the above copyright notice appear in all copies and that both that
-copyright notice and this permission notice appear in supporting
-documentation.
-
-The above copyright notice and this permission notice shall be included in
-all copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL THE
-OPEN GROUP BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
-AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
-CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-Except as contained in this notice, the name of The Open Group shall not be
-used in advertising or otherwise to promote the sale, use or other dealings
-in this Software without prior written authorization from The Open Group.
-
-
-Copyright 1987 by Digital Equipment Corporation, Maynard, Massachusetts.
-
-                        All Rights Reserved
-
-Permission to use, copy, modify, and distribute this software and its 
-documentation for any purpose and without fee is hereby granted, 
-provided that the above copyright notice appear in all copies and that
-both that copyright notice and this permission notice appear in 
-supporting documentation, and that the name of Digital not be
-used in advertising or publicity pertaining to distribution of the
-software without specific, written prior permission.  
-
-DIGITAL DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING
-ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL
-DIGITAL BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR
-ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,
-WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION,
-ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS
-SOFTWARE.
-
-******************************************************************/
-
-
-/*****************************************************************
- * OS Dependent input routines:
- *
- *  WaitForSomething
- *  TimerForce, TimerSet, TimerCheck, TimerFree
- *
- *****************************************************************/
-
-#ifdef HAVE_DIX_CONFIG_H
-#include <dix-config.h>
-#endif
-
-#ifdef WIN32
-#include <X11/Xwinsock.h>
-#endif
-#include <X11/Xos.h>			/* for strings, fcntl, time */
-#include <errno.h>
-#include <stdio.h>
-#include <X11/X.h>
-#include "misc.h"
-
-#include "osdep.h"
-#include <X11/Xpoll.h>
-#include "dixstruct.h"
-#include "opaque.h"
-#ifdef DPMSExtension
-#include "dpmsproc.h"
-#endif
-
-#ifdef WIN32
-/* Error codes from windows sockets differ from fileio error codes  */
-#undef EINTR
-#define EINTR WSAEINTR
-#undef EINVAL
-#define EINVAL WSAEINVAL
-#undef EBADF
-#define EBADF WSAENOTSOCK
-/* Windows select does not set errno. Use GetErrno as wrapper for 
-   WSAGetLastError */
-#define GetErrno WSAGetLastError
-#else
-/* This is just a fallback to errno to hide the differences between unix and
-   Windows in the code */
-#define GetErrno() errno
-#endif
-
-/* like ffs, but uses fd_mask instead of int as argument, so it works
-   when fd_mask is longer than an int, such as common 64-bit platforms */
-/* modifications by raphael */
-int
-mffs(fd_mask mask)
-{
-    int i;
-
-    if (!mask) return 0;
-    i = 1;
-    while (!(mask & 1))
-    {
-	i++;
-	mask >>= 1;
-    }
-    return i;
-}
-
-#ifdef DPMSExtension
-#include <X11/extensions/dpmsconst.h>
-#endif
-
-struct _OsTimerRec {
-    OsTimerPtr		next;
-    CARD32		expires;
-    CARD32              delta;
-    OsTimerCallback	callback;
-    pointer		arg;
-};
-
-static void DoTimer(OsTimerPtr timer, CARD32 now, OsTimerPtr *prev);
-static void CheckAllTimers(void);
-static OsTimerPtr timers = NULL;
-
-/*****************
- * WaitForSomething:
- *     Make the server suspend until there is
- *	1. data from clients or
- *	2. input events available or
- *	3. ddx notices something of interest (graphics
- *	   queue ready, etc.) or
- *	4. clients that have buffered replies/events are ready
- *
- *     If the time between INPUT events is
- *     greater than ScreenSaverTime, the display is turned off (or
- *     saved, depending on the hardware).  So, WaitForSomething()
- *     has to handle this also (that's why the select() has a timeout.
- *     For more info on ClientsWithInput, see ReadRequestFromClient().
- *     pClientsReady is an array to store ready client->index values into.
- *****************/
-
-int
-WaitForSomething(int *pClientsReady)
-{
-    int i;
-    struct timeval waittime, *wt;
-    INT32 timeout = 0;
-    fd_set clientsReadable;
-    fd_set clientsWritable;
-    int curclient;
-    int selecterr;
-    int nready;
-    fd_set devicesReadable;
-    CARD32 now = 0;
-    Bool    someReady = FALSE;
-
-    FD_ZERO(&clientsReadable);
-
-    /* We need a while loop here to handle 
-       crashed connections and the screen saver timeout */
-    while (1)
-    {
-	/* deal with any blocked jobs */
-	if (workQueue)
-	    ProcessWorkQueue();
-	if (XFD_ANYSET (&ClientsWithInput))
-	{
-	    if (!SmartScheduleDisable)
-	    {
-		someReady = TRUE;
-		waittime.tv_sec = 0;
-		waittime.tv_usec = 0;
-		wt = &waittime;
-	    }
-	    else
-	    {
-		XFD_COPYSET (&ClientsWithInput, &clientsReadable);
-		break;
-	    }
-	}
-	if (someReady)
-	{
-	    XFD_COPYSET(&AllSockets, &LastSelectMask);
-	    XFD_UNSET(&LastSelectMask, &ClientsWithInput);
-	}
-	else
-	{
-        wt = NULL;
-	if (timers)
-        {
-            now = GetTimeInMillis();
-	    timeout = timers->expires - now;
-            if (timeout > 0 && timeout > timers->delta + 250) {
-                /* time has rewound.  reset the timers. */
-                CheckAllTimers();
-            }
-
-	    if (timers) {
-		timeout = timers->expires - now;
-		if (timeout < 0)
-		    timeout = 0;
-		waittime.tv_sec = timeout / MILLI_PER_SECOND;
-		waittime.tv_usec = (timeout % MILLI_PER_SECOND) *
-				   (1000000 / MILLI_PER_SECOND);
-		wt = &waittime;
-	    }
-	}
-	XFD_COPYSET(&AllSockets, &LastSelectMask);
-	}
-	SmartScheduleStopTimer ();
-
-	BlockHandler((pointer)&wt, (pointer)&LastSelectMask);
-	if (NewOutputPending)
-	    FlushAllOutput();
-	/* keep this check close to select() call to minimize race */
-	if (dispatchException)
-	    i = -1;
-	else if (AnyClientsWriteBlocked)
-	{
-	    XFD_COPYSET(&ClientsWriteBlocked, &clientsWritable);
-	    i = Select (MaxClients, &LastSelectMask, &clientsWritable, NULL, wt);
-	}
-	else 
-	{
-	    i = Select (MaxClients, &LastSelectMask, NULL, NULL, wt);
-	}
-	selecterr = GetErrno();
-	WakeupHandler(i, (pointer)&LastSelectMask);
-	SmartScheduleStartTimer ();
-	if (i <= 0) /* An error or timeout occurred */
-	{
-	    if (dispatchException)
-		return 0;
-	    if (i < 0) 
-	    {
-		if (selecterr == EBADF)    /* Some client disconnected */
-		{
-		    CheckConnections ();
-		    if (! XFD_ANYSET (&AllClients))
-			return 0;
-		}
-		else if (selecterr == EINVAL)
-		{
-		    FatalError("WaitForSomething(): select: %s\n",
-			strerror(selecterr));
-            }
-		else if (selecterr != EINTR && selecterr != EAGAIN)
-		{
-		    ErrorF("WaitForSomething(): select: %s\n",
-			strerror(selecterr));
-		}
-	    }
-	    else if (someReady)
-	    {
-		/*
-		 * If no-one else is home, bail quickly
-		 */
-		XFD_COPYSET(&ClientsWithInput, &LastSelectMask);
-		XFD_COPYSET(&ClientsWithInput, &clientsReadable);
-		break;
-	    }
-	    if (*checkForInput[0] != *checkForInput[1])
-		return 0;
-
-	    if (timers)
-	    {
-                int expired = 0;
-		now = GetTimeInMillis();
-		if ((int) (timers->expires - now) <= 0)
-		    expired = 1;
-
-		while (timers && (int) (timers->expires - now) <= 0)
-		    DoTimer(timers, now, &timers);
-
-                if (expired)
-                    return 0;
-	    }
-	}
-	else
-	{
-	    fd_set tmp_set;
-
-	    if (*checkForInput[0] == *checkForInput[1]) {
-	        if (timers)
-	        {
-                    int expired = 0;
-		    now = GetTimeInMillis();
-		    if ((int) (timers->expires - now) <= 0)
-		        expired = 1;
-
-		    while (timers && (int) (timers->expires - now) <= 0)
-		        DoTimer(timers, now, &timers);
-
-                    if (expired)
-                        return 0;
-	        }
-	    }
-	    if (someReady)
-		XFD_ORSET(&LastSelectMask, &ClientsWithInput, &LastSelectMask);
-	    if (AnyClientsWriteBlocked && XFD_ANYSET (&clientsWritable))
-	    {
-		NewOutputPending = TRUE;
-		XFD_ORSET(&OutputPending, &clientsWritable, &OutputPending);
-		XFD_UNSET(&ClientsWriteBlocked, &clientsWritable);
-		if (! XFD_ANYSET(&ClientsWriteBlocked))
-		    AnyClientsWriteBlocked = FALSE;
-	    }
-
-	    XFD_ANDSET(&devicesReadable, &LastSelectMask, &EnabledDevices);
-	    XFD_ANDSET(&clientsReadable, &LastSelectMask, &AllClients); 
-	    XFD_ANDSET(&tmp_set, &LastSelectMask, &WellKnownConnections);
-	    if (XFD_ANYSET(&tmp_set))
-		QueueWorkProc(EstablishNewConnections, NULL,
-			      (pointer)&LastSelectMask);
-
-	    if (XFD_ANYSET (&devicesReadable) || XFD_ANYSET (&clientsReadable))
-		break;
-	    /* check here for DDXes that queue events during Block/Wakeup */
-	    if (*checkForInput[0] != *checkForInput[1])
-		return 0;
-	}
-    }
-
-    nready = 0;
-    if (XFD_ANYSET (&clientsReadable))
-    {
-#ifndef WIN32
-	for (i=0; i<howmany(XFD_SETSIZE, NFDBITS); i++)
-	{
-	    int highest_priority = 0;
-
-	    while (clientsReadable.fds_bits[i])
-	    {
-	        int client_priority, client_index;
-
-		curclient = mffs (clientsReadable.fds_bits[i]) - 1;
-		client_index = /* raphael: modified */
-			ConnectionTranslation[curclient + (i * (sizeof(fd_mask) * 8))];
-#else
-	int highest_priority = 0;
-	fd_set savedClientsReadable;
-	XFD_COPYSET(&clientsReadable, &savedClientsReadable);
-	for (i = 0; i < XFD_SETCOUNT(&savedClientsReadable); i++)
-	{
-	    int client_priority, client_index;
-
-	    curclient = XFD_FD(&savedClientsReadable, i);
-	    client_index = GetConnectionTranslation(curclient);
-#endif
-		/*  We implement "strict" priorities.
-		 *  Only the highest priority client is returned to
-		 *  dix.  If multiple clients at the same priority are
-		 *  ready, they are all returned.  This means that an
-		 *  aggressive client could take over the server.
-		 *  This was not considered a big problem because
-		 *  aggressive clients can hose the server in so many 
-		 *  other ways :)
-		 */
-		client_priority = clients[client_index]->priority;
-		if (nready == 0 || client_priority > highest_priority)
-		{
-		    /*  Either we found the first client, or we found
-		     *  a client whose priority is greater than all others
-		     *  that have been found so far.  Either way, we want 
-		     *  to initialize the list of clients to contain just
-		     *  this client.
-		     */
-		    pClientsReady[0] = client_index;
-		    highest_priority = client_priority;
-		    nready = 1;
-		}
-		/*  the following if makes sure that multiple same-priority 
-		 *  clients get batched together
-		 */
-		else if (client_priority == highest_priority)
-		{
-		    pClientsReady[nready++] = client_index;
-		}
-#ifndef WIN32
-		clientsReadable.fds_bits[i] &= ~(((fd_mask)1L) << curclient);
-	    }
-#else
-	    FD_CLR(curclient, &clientsReadable);
-#endif
-	}
-    }
-    return nready;
-}
-
-/* If time has rewound, re-run every affected timer.
- * Timers might drop out of the list, so we have to restart every time. */
-static void
-CheckAllTimers(void)
-{
-    OsTimerPtr timer;
-    CARD32 now;
-
-start:
-    now = GetTimeInMillis();
-
-    for (timer = timers; timer; timer = timer->next) {
-        if (timer->expires - now > timer->delta + 250) {
-            TimerForce(timer);
-            goto start;
-        }
-    }
-}
-
-static void
-DoTimer(OsTimerPtr timer, CARD32 now, OsTimerPtr *prev)
-{
-    CARD32 newTime;
-
-    *prev = timer->next;
-    timer->next = NULL;
-    newTime = (*timer->callback)(timer, now, timer->arg);
-    if (newTime)
-	TimerSet(timer, 0, newTime, timer->callback, timer->arg);
-}
-
-OsTimerPtr
-TimerSet(OsTimerPtr timer, int flags, CARD32 millis, 
-    OsTimerCallback func, pointer arg)
-{
-    register OsTimerPtr *prev;
-    CARD32 now = GetTimeInMillis();
-
-    if (!timer)
-    {
-	timer = xalloc(sizeof(struct _OsTimerRec));
-	if (!timer)
-	    return NULL;
-    }
-    else
-    {
-	for (prev = &timers; *prev; prev = &(*prev)->next)
-	{
-	    if (*prev == timer)
-	    {
-		*prev = timer->next;
-		if (flags & TimerForceOld)
-		    (void)(*timer->callback)(timer, now, timer->arg);
-		break;
-	    }
-	}
-    }
-    if (!millis)
-	return timer;
-    if (flags & TimerAbsolute) {
-        timer->delta = millis - now;
-    }
-    else {
-        timer->delta = millis;
-	millis += now;
-    }
-    timer->expires = millis;
-    timer->callback = func;
-    timer->arg = arg;
-    if ((int) (millis - now) <= 0)
-    {
-	timer->next = NULL;
-	millis = (*timer->callback)(timer, now, timer->arg);
-	if (!millis)
-	    return timer;
-    }
-    for (prev = &timers;
-	 *prev && (int) ((*prev)->expires - millis) <= 0;
-	 prev = &(*prev)->next)
-        ;
-    timer->next = *prev;
-    *prev = timer;
-    return timer;
-}
-
-Bool
-TimerForce(OsTimerPtr timer)
-{
-    OsTimerPtr *prev;
-
-    for (prev = &timers; *prev; prev = &(*prev)->next)
-    {
-	if (*prev == timer)
-	{
-	    DoTimer(timer, GetTimeInMillis(), prev);
-	    return TRUE;
-	}
-    }
-    return FALSE;
-}
-
-
-void
-TimerCancel(OsTimerPtr timer)
-{
-    OsTimerPtr *prev;
-
-    if (!timer)
-	return;
-    for (prev = &timers; *prev; prev = &(*prev)->next)
-    {
-	if (*prev == timer)
-	{
-	    *prev = timer->next;
-	    break;
-	}
-    }
-}
-
-void
-TimerFree(OsTimerPtr timer)
-{
-    if (!timer)
-	return;
-    TimerCancel(timer);
-    xfree(timer);
-}
-
-void
-TimerCheck(void)
-{
-    CARD32 now = GetTimeInMillis();
-
-    while (timers && (int) (timers->expires - now) <= 0)
-	DoTimer(timers, now, &timers);
-}
-
-void
-TimerInit(void)
-{
-    OsTimerPtr timer;
-
-    while ((timer = timers))
-    {
-	timers = timer->next;
-	xfree(timer);
-    }
-}
-
-#ifdef DPMSExtension
-
-#define DPMS_CHECK_MODE(mode,time)\
-    if (time > 0 && DPMSPowerLevel < mode && timeout >= time)\
-	DPMSSet(serverClient, mode);
-
-#define DPMS_CHECK_TIMEOUT(time)\
-    if (time > 0 && (time - timeout) > 0)\
-	return time - timeout;
-
-static CARD32
-NextDPMSTimeout(INT32 timeout)
-{
-    /*
-     * Return the amount of time remaining until we should set
-     * the next power level. Fallthroughs are intentional.
-     */
-    switch (DPMSPowerLevel)
-    {
-	case DPMSModeOn:
-	    DPMS_CHECK_TIMEOUT(DPMSStandbyTime)
-
-	case DPMSModeStandby:
-	    DPMS_CHECK_TIMEOUT(DPMSSuspendTime)
-
-	case DPMSModeSuspend:
-	    DPMS_CHECK_TIMEOUT(DPMSOffTime)
-
-	default: /* DPMSModeOff */
-	    return 0;
-    }
-}
-#endif /* DPMSExtension */
-
-static CARD32
-ScreenSaverTimeoutExpire(OsTimerPtr timer,CARD32 now,pointer arg)
-{
-    INT32 timeout      = now - lastDeviceEventTime.milliseconds;
-    CARD32 nextTimeout = 0;
-
-#ifdef DPMSExtension
-    /*
-     * Check each mode lowest to highest, since a lower mode can
-     * have the same timeout as a higher one.
-     */
-    if (DPMSEnabled)
-    {
-	DPMS_CHECK_MODE(DPMSModeOff,     DPMSOffTime)
-	DPMS_CHECK_MODE(DPMSModeSuspend, DPMSSuspendTime)
-	DPMS_CHECK_MODE(DPMSModeStandby, DPMSStandbyTime)
-
-	nextTimeout = NextDPMSTimeout(timeout);
-    }
-
-    /*
-     * Only do the screensaver checks if we're not in a DPMS
-     * power saving mode
-     */
-    if (DPMSPowerLevel != DPMSModeOn)
-	return nextTimeout;
-#endif /* DPMSExtension */
-
-    if (!ScreenSaverTime)
-	return nextTimeout;
-
-    if (timeout < ScreenSaverTime)
-    {
-	return nextTimeout > 0 ? 
-		min(ScreenSaverTime - timeout, nextTimeout) :
-		ScreenSaverTime - timeout;
-    }
-
-    ResetOsBuffers(); /* not ideal, but better than nothing */
-    dixSaveScreens(serverClient, SCREEN_SAVER_ON, ScreenSaverActive);
-
-    if (ScreenSaverInterval > 0)
-    {
-	nextTimeout = nextTimeout > 0 ? 
-		min(ScreenSaverInterval, nextTimeout) :
-		ScreenSaverInterval;
-    }
-
-    return nextTimeout;
-}
-
-static OsTimerPtr ScreenSaverTimer = NULL;
-
-void
-FreeScreenSaverTimer(void)
-{
-    if (ScreenSaverTimer) {
-	TimerFree(ScreenSaverTimer);
-	ScreenSaverTimer = NULL;
-    }
-}
-
-void
-SetScreenSaverTimer(void)
-{
-    CARD32 timeout = 0;
-
-#ifdef DPMSExtension
-    if (DPMSEnabled)
-    {
-	/*
-	 * A higher DPMS level has a timeout that's either less
-	 * than or equal to that of a lower DPMS level.
-	 */
-	if (DPMSStandbyTime > 0)
-	    timeout = DPMSStandbyTime;
-
-	else if (DPMSSuspendTime > 0)
-	    timeout = DPMSSuspendTime;
-
-	else if (DPMSOffTime > 0)
-	    timeout = DPMSOffTime;
-    }
-#endif
-
-    if (ScreenSaverTime > 0)
-    {
-	timeout = timeout > 0 ?
-		min(ScreenSaverTime, timeout) :
-		ScreenSaverTime;
-    }
-
-#ifdef SCREENSAVER
-    if (timeout && !screenSaverSuspended) {
-#else
-    if (timeout) {
-#endif
-	ScreenSaverTimer = TimerSet(ScreenSaverTimer, 0, timeout,
-	                            ScreenSaverTimeoutExpire, NULL);
-    }
-    else if (ScreenSaverTimer) {
-	FreeScreenSaverTimer();
-    }
-}
-
+/***********************************************************

+

+Copyright 1987, 1998  The Open Group

+

+Permission to use, copy, modify, distribute, and sell this software and its

+documentation for any purpose is hereby granted without fee, provided that

+the above copyright notice appear in all copies and that both that

+copyright notice and this permission notice appear in supporting

+documentation.

+

+The above copyright notice and this permission notice shall be included in

+all copies or substantial portions of the Software.

+

+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR

+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,

+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL THE

+OPEN GROUP BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN

+AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN

+CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

+

+Except as contained in this notice, the name of The Open Group shall not be

+used in advertising or otherwise to promote the sale, use or other dealings

+in this Software without prior written authorization from The Open Group.

+

+

+Copyright 1987 by Digital Equipment Corporation, Maynard, Massachusetts.

+

+                        All Rights Reserved

+

+Permission to use, copy, modify, and distribute this software and its 

+documentation for any purpose and without fee is hereby granted, 

+provided that the above copyright notice appear in all copies and that

+both that copyright notice and this permission notice appear in 

+supporting documentation, and that the name of Digital not be

+used in advertising or publicity pertaining to distribution of the

+software without specific, written prior permission.  

+

+DIGITAL DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING

+ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL

+DIGITAL BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR

+ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,

+WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION,

+ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS

+SOFTWARE.

+

+******************************************************************/

+

+

+/*****************************************************************

+ * OS Dependent input routines:

+ *

+ *  WaitForSomething

+ *  TimerForce, TimerSet, TimerCheck, TimerFree

+ *

+ *****************************************************************/

+

+#ifdef HAVE_DIX_CONFIG_H

+#include <dix-config.h>

+#endif

+

+#ifdef WIN32

+#include <X11/Xwinsock.h>

+#endif

+#include <X11/Xos.h>			/* for strings, fcntl, time */

+#include <errno.h>

+#include <stdio.h>

+#include <X11/X.h>

+#include "misc.h"

+

+#include "osdep.h"

+#include <X11/Xpoll.h>

+#include "dixstruct.h"

+#include "opaque.h"

+#ifdef DPMSExtension

+#include "dpmsproc.h"

+#endif

+

+#ifdef WIN32

+/* Error codes from windows sockets differ from fileio error codes  */

+#undef EINTR

+#define EINTR WSAEINTR

+#undef EINVAL

+#define EINVAL WSAEINVAL

+#undef EBADF

+#define EBADF WSAENOTSOCK

+/* Windows select does not set errno. Use GetErrno as wrapper for 

+   WSAGetLastError */

+#define GetErrno WSAGetLastError

+#else

+/* This is just a fallback to errno to hide the differences between unix and

+   Windows in the code */

+#define GetErrno() errno

+#endif

+

+/* like ffs, but uses fd_mask instead of int as argument, so it works

+   when fd_mask is longer than an int, such as common 64-bit platforms */

+/* modifications by raphael */

+int

+mffs(fd_mask mask)

+{

+    int i;

+

+    if (!mask) return 0;

+    i = 1;

+    while (!(mask & 1))

+    {

+	i++;

+	mask >>= 1;

+    }

+    return i;

+}

+

+#ifdef DPMSExtension

+#include <X11/extensions/dpmsconst.h>

+#endif

+

+struct _OsTimerRec {

+    OsTimerPtr		next;

+    CARD32		expires;

+    CARD32              delta;

+    OsTimerCallback	callback;

+    pointer		arg;

+};

+

+static void DoTimer(OsTimerPtr timer, CARD32 now, OsTimerPtr *prev);

+static void CheckAllTimers(void);

+static OsTimerPtr timers = NULL;

+

+/*****************

+ * WaitForSomething:

+ *     Make the server suspend until there is

+ *	1. data from clients or

+ *	2. input events available or

+ *	3. ddx notices something of interest (graphics

+ *	   queue ready, etc.) or

+ *	4. clients that have buffered replies/events are ready

+ *

+ *     If the time between INPUT events is

+ *     greater than ScreenSaverTime, the display is turned off (or

+ *     saved, depending on the hardware).  So, WaitForSomething()

+ *     has to handle this also (that's why the select() has a timeout.

+ *     For more info on ClientsWithInput, see ReadRequestFromClient().

+ *     pClientsReady is an array to store ready client->index values into.

+ *****************/

+

+int

+WaitForSomething(int *pClientsReady)

+{

+    int i;

+    struct timeval waittime, *wt;

+    INT32 timeout = 0;

+    fd_set clientsReadable;

+    fd_set clientsWritable;

+    int curclient;

+    int selecterr;

+    int nready;

+    fd_set devicesReadable;

+    CARD32 now = 0;

+    Bool    someReady = FALSE;

+

+    FD_ZERO(&clientsReadable);

+

+    /* We need a while loop here to handle 

+       crashed connections and the screen saver timeout */

+    while (1)

+    {

+	/* deal with any blocked jobs */

+	if (workQueue)

+	    ProcessWorkQueue();

+	if (XFD_ANYSET (&ClientsWithInput))

+	{

+	    if (!SmartScheduleDisable)

+	    {

+		someReady = TRUE;

+		waittime.tv_sec = 0;

+		waittime.tv_usec = 0;

+		wt = &waittime;

+	    }

+	    else

+	    {

+		XFD_COPYSET (&ClientsWithInput, &clientsReadable);

+		break;

+	    }

+	}

+	if (someReady)

+	{

+	    XFD_COPYSET(&AllSockets, &LastSelectMask);

+	    XFD_UNSET(&LastSelectMask, &ClientsWithInput);

+	}

+	else

+	{

+        wt = NULL;

+	if (timers)

+        {

+            now = GetTimeInMillis();

+	    timeout = timers->expires - now;

+            if (timeout > 0 && timeout > timers->delta + 250) {

+                /* time has rewound.  reset the timers. */

+                CheckAllTimers();

+            }

+

+	    if (timers) {

+		timeout = timers->expires - now;

+		if (timeout < 0)

+		    timeout = 0;

+		waittime.tv_sec = timeout / MILLI_PER_SECOND;

+		waittime.tv_usec = (timeout % MILLI_PER_SECOND) *

+				   (1000000 / MILLI_PER_SECOND);

+		wt = &waittime;

+	    }

+	}

+	XFD_COPYSET(&AllSockets, &LastSelectMask);

+	}

+	SmartScheduleStopTimer ();

+

+	BlockHandler((pointer)&wt, (pointer)&LastSelectMask);

+	if (NewOutputPending)

+	    FlushAllOutput();

+	/* keep this check close to select() call to minimize race */

+	if (dispatchException)

+	    i = -1;

+	else if (AnyClientsWriteBlocked)

+	{

+	    XFD_COPYSET(&ClientsWriteBlocked, &clientsWritable);

+	    i = Select (MaxClients, &LastSelectMask, &clientsWritable, NULL, wt);

+	}

+	else 

+	{

+	    i = Select (MaxClients, &LastSelectMask, NULL, NULL, wt);

+	}

+	selecterr = GetErrno();

+	WakeupHandler(i, (pointer)&LastSelectMask);

+	SmartScheduleStartTimer ();

+	if (i <= 0) /* An error or timeout occurred */

+	{

+	    if (dispatchException)

+		return 0;

+	    if (i < 0) 

+	    {

+		if (selecterr == EBADF)    /* Some client disconnected */

+		{

+		    CheckConnections ();

+		    if (! XFD_ANYSET (&AllClients))

+			return 0;

+		}

+		else if (selecterr == EINVAL)

+		{

+		    FatalError("WaitForSomething(): select: %s\n",

+			strerror(selecterr));

+            }

+		else if (selecterr != EINTR && selecterr != EAGAIN)

+		{

+		    ErrorF("WaitForSomething(): select: %s\n",

+			strerror(selecterr));

+		}

+	    }

+	    else if (someReady)

+	    {

+		/*

+		 * If no-one else is home, bail quickly

+		 */

+		XFD_COPYSET(&ClientsWithInput, &LastSelectMask);

+		XFD_COPYSET(&ClientsWithInput, &clientsReadable);

+		break;

+	    }

+	    if (*checkForInput[0] != *checkForInput[1])

+		return 0;

+

+	    if (timers)

+	    {

+                int expired = 0;

+		now = GetTimeInMillis();

+		if ((int) (timers->expires - now) <= 0)

+		    expired = 1;

+

+		while (timers && (int) (timers->expires - now) <= 0)

+		    DoTimer(timers, now, &timers);

+

+                if (expired)

+                    return 0;

+	    }

+	}

+	else

+	{

+	    fd_set tmp_set;

+

+	    if (*checkForInput[0] == *checkForInput[1]) {

+	        if (timers)

+	        {

+                    int expired = 0;

+		    now = GetTimeInMillis();

+		    if ((int) (timers->expires - now) <= 0)

+		        expired = 1;

+

+		    while (timers && (int) (timers->expires - now) <= 0)

+		        DoTimer(timers, now, &timers);

+

+                    if (expired)

+                        return 0;

+	        }

+	    }

+	    if (someReady)

+		XFD_ORSET(&LastSelectMask, &ClientsWithInput, &LastSelectMask);

+	    if (AnyClientsWriteBlocked && XFD_ANYSET (&clientsWritable))

+	    {

+		NewOutputPending = TRUE;

+		XFD_ORSET(&OutputPending, &clientsWritable, &OutputPending);

+		XFD_UNSET(&ClientsWriteBlocked, &clientsWritable);

+		if (! XFD_ANYSET(&ClientsWriteBlocked))

+		    AnyClientsWriteBlocked = FALSE;

+	    }

+

+	    XFD_ANDSET(&devicesReadable, &LastSelectMask, &EnabledDevices);

+	    XFD_ANDSET(&clientsReadable, &LastSelectMask, &AllClients); 

+	    XFD_ANDSET(&tmp_set, &LastSelectMask, &WellKnownConnections);

+	    if (XFD_ANYSET(&tmp_set))

+		QueueWorkProc(EstablishNewConnections, NULL,

+			      (pointer)&LastSelectMask);

+

+	    if (XFD_ANYSET (&devicesReadable) || XFD_ANYSET (&clientsReadable))

+		break;

+	    /* check here for DDXes that queue events during Block/Wakeup */

+	    if (*checkForInput[0] != *checkForInput[1])

+		return 0;

+	}

+    }

+

+    nready = 0;

+    if (XFD_ANYSET (&clientsReadable))

+    {

+#ifndef WIN32

+	for (i=0; i<howmany(XFD_SETSIZE, NFDBITS); i++)

+	{

+	    int highest_priority = 0;

+

+	    while (clientsReadable.fds_bits[i])

+	    {

+	        int client_priority, client_index;

+

+		curclient = mffs (clientsReadable.fds_bits[i]) - 1;

+		client_index = /* raphael: modified */

+			ConnectionTranslation[curclient + (i * (sizeof(fd_mask) * 8))];

+#else

+	int highest_priority = 0;

+	fd_set savedClientsReadable;

+	XFD_COPYSET(&clientsReadable, &savedClientsReadable);

+	for (i = 0; i < XFD_SETCOUNT(&savedClientsReadable); i++)

+	{

+	    int client_priority, client_index;

+

+	    curclient = XFD_FD(&savedClientsReadable, i);

+	    client_index = GetConnectionTranslation(curclient);

+#endif

+		/*  We implement "strict" priorities.

+		 *  Only the highest priority client is returned to

+		 *  dix.  If multiple clients at the same priority are

+		 *  ready, they are all returned.  This means that an

+		 *  aggressive client could take over the server.

+		 *  This was not considered a big problem because

+		 *  aggressive clients can hose the server in so many 

+		 *  other ways :)

+		 */

+		client_priority = clients[client_index]->priority;

+		if (nready == 0 || client_priority > highest_priority)

+		{

+		    /*  Either we found the first client, or we found

+		     *  a client whose priority is greater than all others

+		     *  that have been found so far.  Either way, we want 

+		     *  to initialize the list of clients to contain just

+		     *  this client.

+		     */

+		    pClientsReady[0] = client_index;

+		    highest_priority = client_priority;

+		    nready = 1;

+		}

+		/*  the following if makes sure that multiple same-priority 

+		 *  clients get batched together

+		 */

+		else if (client_priority == highest_priority)

+		{

+		    pClientsReady[nready++] = client_index;

+		}

+#ifndef WIN32

+		clientsReadable.fds_bits[i] &= ~(((fd_mask)1L) << curclient);

+	    }

+#else

+	    FD_CLR(curclient, &clientsReadable);

+#endif

+	}

+    }

+    return nready;

+}

+

+/* If time has rewound, re-run every affected timer.

+ * Timers might drop out of the list, so we have to restart every time. */

+static void

+CheckAllTimers(void)

+{

+    OsTimerPtr timer;

+    CARD32 now;

+

+start:

+    now = GetTimeInMillis();

+

+    for (timer = timers; timer; timer = timer->next) {

+        if (timer->expires - now > timer->delta + 250) {

+            TimerForce(timer);

+            goto start;

+        }

+    }

+}

+

+static void

+DoTimer(OsTimerPtr timer, CARD32 now, OsTimerPtr *prev)

+{

+    CARD32 newTime;

+

+    *prev = timer->next;

+    timer->next = NULL;

+    newTime = (*timer->callback)(timer, now, timer->arg);

+    if (newTime)

+	TimerSet(timer, 0, newTime, timer->callback, timer->arg);

+}

+

+OsTimerPtr

+TimerSet(OsTimerPtr timer, int flags, CARD32 millis, 

+    OsTimerCallback func, pointer arg)

+{

+    register OsTimerPtr *prev;

+    CARD32 now = GetTimeInMillis();

+

+    if (!timer)

+    {

+	timer = malloc(sizeof(struct _OsTimerRec));

+	if (!timer)

+	    return NULL;

+    }

+    else

+    {

+	for (prev = &timers; *prev; prev = &(*prev)->next)

+	{

+	    if (*prev == timer)

+	    {

+		*prev = timer->next;

+		if (flags & TimerForceOld)

+		    (void)(*timer->callback)(timer, now, timer->arg);

+		break;

+	    }

+	}

+    }

+    if (!millis)

+	return timer;

+    if (flags & TimerAbsolute) {

+        timer->delta = millis - now;

+    }

+    else {

+        timer->delta = millis;

+	millis += now;

+    }

+    timer->expires = millis;

+    timer->callback = func;

+    timer->arg = arg;

+    if ((int) (millis - now) <= 0)

+    {

+	timer->next = NULL;

+	millis = (*timer->callback)(timer, now, timer->arg);

+	if (!millis)

+	    return timer;

+    }

+    for (prev = &timers;

+	 *prev && (int) ((*prev)->expires - millis) <= 0;

+	 prev = &(*prev)->next)

+        ;

+    timer->next = *prev;

+    *prev = timer;

+    return timer;

+}

+

+Bool

+TimerForce(OsTimerPtr timer)

+{

+    OsTimerPtr *prev;

+

+    for (prev = &timers; *prev; prev = &(*prev)->next)

+    {

+	if (*prev == timer)

+	{

+	    DoTimer(timer, GetTimeInMillis(), prev);

+	    return TRUE;

+	}

+    }

+    return FALSE;

+}

+

+

+void

+TimerCancel(OsTimerPtr timer)

+{

+    OsTimerPtr *prev;

+

+    if (!timer)

+	return;

+    for (prev = &timers; *prev; prev = &(*prev)->next)

+    {

+	if (*prev == timer)

+	{

+	    *prev = timer->next;

+	    break;

+	}

+    }

+}

+

+void

+TimerFree(OsTimerPtr timer)

+{

+    if (!timer)

+	return;

+    TimerCancel(timer);

+    free(timer);

+}

+

+void

+TimerCheck(void)

+{

+    CARD32 now = GetTimeInMillis();

+

+    while (timers && (int) (timers->expires - now) <= 0)

+	DoTimer(timers, now, &timers);

+}

+

+void

+TimerInit(void)

+{

+    OsTimerPtr timer;

+

+    while ((timer = timers))

+    {

+	timers = timer->next;

+	free(timer);

+    }

+}

+

+#ifdef DPMSExtension

+

+#define DPMS_CHECK_MODE(mode,time)\

+    if (time > 0 && DPMSPowerLevel < mode && timeout >= time)\

+	DPMSSet(serverClient, mode);

+

+#define DPMS_CHECK_TIMEOUT(time)\

+    if (time > 0 && (time - timeout) > 0)\

+	return time - timeout;

+

+static CARD32

+NextDPMSTimeout(INT32 timeout)

+{

+    /*

+     * Return the amount of time remaining until we should set

+     * the next power level. Fallthroughs are intentional.

+     */

+    switch (DPMSPowerLevel)

+    {

+	case DPMSModeOn:

+	    DPMS_CHECK_TIMEOUT(DPMSStandbyTime)

+

+	case DPMSModeStandby:

+	    DPMS_CHECK_TIMEOUT(DPMSSuspendTime)

+

+	case DPMSModeSuspend:

+	    DPMS_CHECK_TIMEOUT(DPMSOffTime)

+

+	default: /* DPMSModeOff */

+	    return 0;

+    }

+}

+#endif /* DPMSExtension */

+

+static CARD32

+ScreenSaverTimeoutExpire(OsTimerPtr timer,CARD32 now,pointer arg)

+{

+    INT32 timeout      = now - lastDeviceEventTime.milliseconds;

+    CARD32 nextTimeout = 0;

+

+#ifdef DPMSExtension

+    /*

+     * Check each mode lowest to highest, since a lower mode can

+     * have the same timeout as a higher one.

+     */

+    if (DPMSEnabled)

+    {

+	DPMS_CHECK_MODE(DPMSModeOff,     DPMSOffTime)

+	DPMS_CHECK_MODE(DPMSModeSuspend, DPMSSuspendTime)

+	DPMS_CHECK_MODE(DPMSModeStandby, DPMSStandbyTime)

+

+	nextTimeout = NextDPMSTimeout(timeout);

+    }

+

+    /*

+     * Only do the screensaver checks if we're not in a DPMS

+     * power saving mode

+     */

+    if (DPMSPowerLevel != DPMSModeOn)

+	return nextTimeout;

+#endif /* DPMSExtension */

+

+    if (!ScreenSaverTime)

+	return nextTimeout;

+

+    if (timeout < ScreenSaverTime)

+    {

+	return nextTimeout > 0 ? 

+		min(ScreenSaverTime - timeout, nextTimeout) :

+		ScreenSaverTime - timeout;

+    }

+

+    ResetOsBuffers(); /* not ideal, but better than nothing */

+    dixSaveScreens(serverClient, SCREEN_SAVER_ON, ScreenSaverActive);

+

+    if (ScreenSaverInterval > 0)

+    {

+	nextTimeout = nextTimeout > 0 ? 

+		min(ScreenSaverInterval, nextTimeout) :

+		ScreenSaverInterval;

+    }

+

+    return nextTimeout;

+}

+

+static OsTimerPtr ScreenSaverTimer = NULL;

+

+void

+FreeScreenSaverTimer(void)

+{

+    if (ScreenSaverTimer) {

+	TimerFree(ScreenSaverTimer);

+	ScreenSaverTimer = NULL;

+    }

+}

+

+void

+SetScreenSaverTimer(void)

+{

+    CARD32 timeout = 0;

+

+#ifdef DPMSExtension

+    if (DPMSEnabled)

+    {

+	/*

+	 * A higher DPMS level has a timeout that's either less

+	 * than or equal to that of a lower DPMS level.

+	 */

+	if (DPMSStandbyTime > 0)

+	    timeout = DPMSStandbyTime;

+

+	else if (DPMSSuspendTime > 0)

+	    timeout = DPMSSuspendTime;

+

+	else if (DPMSOffTime > 0)

+	    timeout = DPMSOffTime;

+    }

+#endif

+

+    if (ScreenSaverTime > 0)

+    {

+	timeout = timeout > 0 ?

+		min(ScreenSaverTime, timeout) :

+		ScreenSaverTime;

+    }

+

+#ifdef SCREENSAVER

+    if (timeout && !screenSaverSuspended) {

+#else

+    if (timeout) {

+#endif

+	ScreenSaverTimer = TimerSet(ScreenSaverTimer, 0, timeout,

+	                            ScreenSaverTimeoutExpire, NULL);

+    }

+    else if (ScreenSaverTimer) {

+	FreeScreenSaverTimer();

+    }

+}

+