1*4882a593Smuzhiyun /*
2*4882a593Smuzhiyun * Copyright 2002-2004 Red Hat Inc., Durham, North Carolina.
3*4882a593Smuzhiyun *
4*4882a593Smuzhiyun * All Rights Reserved.
5*4882a593Smuzhiyun *
6*4882a593Smuzhiyun * Permission is hereby granted, free of charge, to any person obtaining
7*4882a593Smuzhiyun * a copy of this software and associated documentation files (the
8*4882a593Smuzhiyun * "Software"), to deal in the Software without restriction, including
9*4882a593Smuzhiyun * without limitation on the rights to use, copy, modify, merge,
10*4882a593Smuzhiyun * publish, distribute, sublicense, and/or sell copies of the Software,
11*4882a593Smuzhiyun * and to permit persons to whom the Software is furnished to do so,
12*4882a593Smuzhiyun * subject to the following conditions:
13*4882a593Smuzhiyun *
14*4882a593Smuzhiyun * The above copyright notice and this permission notice (including the
15*4882a593Smuzhiyun * next paragraph) shall be included in all copies or substantial
16*4882a593Smuzhiyun * portions of the Software.
17*4882a593Smuzhiyun *
18*4882a593Smuzhiyun * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
19*4882a593Smuzhiyun * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
20*4882a593Smuzhiyun * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
21*4882a593Smuzhiyun * NON-INFRINGEMENT. IN NO EVENT SHALL RED HAT AND/OR THEIR SUPPLIERS
22*4882a593Smuzhiyun * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
23*4882a593Smuzhiyun * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
24*4882a593Smuzhiyun * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
25*4882a593Smuzhiyun * SOFTWARE.
26*4882a593Smuzhiyun */
27*4882a593Smuzhiyun
28*4882a593Smuzhiyun /*
29*4882a593Smuzhiyun * Authors:
30*4882a593Smuzhiyun * Rickard E. (Rik) Faith <faith@redhat.com>
31*4882a593Smuzhiyun *
32*4882a593Smuzhiyun */
33*4882a593Smuzhiyun
34*4882a593Smuzhiyun /** \file
35*4882a593Smuzhiyun *
36*4882a593Smuzhiyun * The DMX server code is written to call #dmxSync() whenever an XSync()
37*4882a593Smuzhiyun * might be necessary. However, since XSync() requires a two way
38*4882a593Smuzhiyun * communication with the other X server, eliminating unnecessary
39*4882a593Smuzhiyun * XSync() calls is a key performance optimization. Support for this
40*4882a593Smuzhiyun * optimization is provided here. Statistics about XSync() calls and
41*4882a593Smuzhiyun * latency are gathered in \a dmxstat.c.
42*4882a593Smuzhiyun *
43*4882a593Smuzhiyun * During the initial conversion from calling XSync() immediately to the
44*4882a593Smuzhiyun * XSync() batching method implemented in this file, it was noted that,
45*4882a593Smuzhiyun * out of more than 300 \a x11perf tests, 8 tests became more than 100
46*4882a593Smuzhiyun * times faster, with 68 more than 50X faster, 114 more than 10X faster,
47*4882a593Smuzhiyun * and 181 more than 2X faster. */
48*4882a593Smuzhiyun
49*4882a593Smuzhiyun #ifdef HAVE_DMX_CONFIG_H
50*4882a593Smuzhiyun #include <dmx-config.h>
51*4882a593Smuzhiyun #endif
52*4882a593Smuzhiyun
53*4882a593Smuzhiyun #include "dmx.h"
54*4882a593Smuzhiyun #include "dmxsync.h"
55*4882a593Smuzhiyun #include "dmxstat.h"
56*4882a593Smuzhiyun #include "dmxlog.h"
57*4882a593Smuzhiyun #include <sys/time.h>
58*4882a593Smuzhiyun
59*4882a593Smuzhiyun static int dmxSyncInterval = 100; /* Default interval in milliseconds */
60*4882a593Smuzhiyun static OsTimerPtr dmxSyncTimer;
61*4882a593Smuzhiyun static int dmxSyncPending;
62*4882a593Smuzhiyun
63*4882a593Smuzhiyun static void
dmxDoSync(DMXScreenInfo * dmxScreen)64*4882a593Smuzhiyun dmxDoSync(DMXScreenInfo * dmxScreen)
65*4882a593Smuzhiyun {
66*4882a593Smuzhiyun dmxScreen->needsSync = FALSE;
67*4882a593Smuzhiyun
68*4882a593Smuzhiyun if (!dmxScreen->beDisplay)
69*4882a593Smuzhiyun return; /* FIXME: Is this correct behavior for sync stats? */
70*4882a593Smuzhiyun
71*4882a593Smuzhiyun if (!dmxStatInterval) {
72*4882a593Smuzhiyun XSync(dmxScreen->beDisplay, False);
73*4882a593Smuzhiyun }
74*4882a593Smuzhiyun else {
75*4882a593Smuzhiyun struct timeval start, stop;
76*4882a593Smuzhiyun
77*4882a593Smuzhiyun gettimeofday(&start, 0);
78*4882a593Smuzhiyun XSync(dmxScreen->beDisplay, False);
79*4882a593Smuzhiyun gettimeofday(&stop, 0);
80*4882a593Smuzhiyun dmxStatSync(dmxScreen, &stop, &start, dmxSyncPending);
81*4882a593Smuzhiyun }
82*4882a593Smuzhiyun }
83*4882a593Smuzhiyun
84*4882a593Smuzhiyun static CARD32
dmxSyncCallback(OsTimerPtr timer,CARD32 time,void * arg)85*4882a593Smuzhiyun dmxSyncCallback(OsTimerPtr timer, CARD32 time, void *arg)
86*4882a593Smuzhiyun {
87*4882a593Smuzhiyun int i;
88*4882a593Smuzhiyun
89*4882a593Smuzhiyun if (dmxSyncPending) {
90*4882a593Smuzhiyun for (i = 0; i < dmxNumScreens; i++) {
91*4882a593Smuzhiyun DMXScreenInfo *dmxScreen = &dmxScreens[i];
92*4882a593Smuzhiyun
93*4882a593Smuzhiyun if (dmxScreen->needsSync)
94*4882a593Smuzhiyun dmxDoSync(dmxScreen);
95*4882a593Smuzhiyun }
96*4882a593Smuzhiyun }
97*4882a593Smuzhiyun dmxSyncPending = 0;
98*4882a593Smuzhiyun return 0; /* Do not place on queue again */
99*4882a593Smuzhiyun }
100*4882a593Smuzhiyun
101*4882a593Smuzhiyun static void
dmxSyncBlockHandler(void * blockData,void * timeout)102*4882a593Smuzhiyun dmxSyncBlockHandler(void *blockData, void *timeout)
103*4882a593Smuzhiyun {
104*4882a593Smuzhiyun TimerForce(dmxSyncTimer);
105*4882a593Smuzhiyun }
106*4882a593Smuzhiyun
107*4882a593Smuzhiyun static void
dmxSyncWakeupHandler(void * blockData,int result)108*4882a593Smuzhiyun dmxSyncWakeupHandler(void *blockData, int result)
109*4882a593Smuzhiyun {
110*4882a593Smuzhiyun }
111*4882a593Smuzhiyun
112*4882a593Smuzhiyun /** Request the XSync() batching optimization with the specified \a
113*4882a593Smuzhiyun * interval (in mS). If the \a interval is 0, 100mS is used. If the \a
114*4882a593Smuzhiyun * interval is less than 0, then the XSync() batching optimization is
115*4882a593Smuzhiyun * not requested (e.g., so the -syncbatch -1 command line option can
116*4882a593Smuzhiyun * turn off the default 100mS XSync() batching).
117*4882a593Smuzhiyun *
118*4882a593Smuzhiyun * Note that the parameter to this routine is a string, since it will
119*4882a593Smuzhiyun * usually be called from #ddxProcessArgument in \a dmxinit.c */
120*4882a593Smuzhiyun void
dmxSyncActivate(const char * interval)121*4882a593Smuzhiyun dmxSyncActivate(const char *interval)
122*4882a593Smuzhiyun {
123*4882a593Smuzhiyun dmxSyncInterval = (interval ? atoi(interval) : 100);
124*4882a593Smuzhiyun
125*4882a593Smuzhiyun if (dmxSyncInterval < 0)
126*4882a593Smuzhiyun dmxSyncInterval = 0;
127*4882a593Smuzhiyun }
128*4882a593Smuzhiyun
129*4882a593Smuzhiyun /** Initialize the XSync() batching optimization, but only if
130*4882a593Smuzhiyun * #dmxSyncActivate was last called with a non-negative value. */
131*4882a593Smuzhiyun void
dmxSyncInit(void)132*4882a593Smuzhiyun dmxSyncInit(void)
133*4882a593Smuzhiyun {
134*4882a593Smuzhiyun if (dmxSyncInterval) {
135*4882a593Smuzhiyun RegisterBlockAndWakeupHandlers(dmxSyncBlockHandler,
136*4882a593Smuzhiyun dmxSyncWakeupHandler, NULL);
137*4882a593Smuzhiyun dmxLog(dmxInfo, "XSync batching with %d ms interval\n",
138*4882a593Smuzhiyun dmxSyncInterval);
139*4882a593Smuzhiyun }
140*4882a593Smuzhiyun else {
141*4882a593Smuzhiyun dmxLog(dmxInfo, "XSync batching disabled\n");
142*4882a593Smuzhiyun }
143*4882a593Smuzhiyun }
144*4882a593Smuzhiyun
145*4882a593Smuzhiyun /** Request an XSync() to the display used by \a dmxScreen. If \a now
146*4882a593Smuzhiyun * is TRUE, call XSync() immediately instead of waiting for the next
147*4882a593Smuzhiyun * XSync() batching point. Note that if XSync() batching was deselected
148*4882a593Smuzhiyun * with #dmxSyncActivate() before #dmxSyncInit() was called, then no
149*4882a593Smuzhiyun * XSync() batching is performed and this function always calles XSync()
150*4882a593Smuzhiyun * immediately.
151*4882a593Smuzhiyun *
152*4882a593Smuzhiyun * (Note that this function uses TimerSet but works correctly in the
153*4882a593Smuzhiyun * face of a server generation. See the source for details.)
154*4882a593Smuzhiyun *
155*4882a593Smuzhiyun * If \a dmxScreen is \a NULL, then all pending syncs will be flushed
156*4882a593Smuzhiyun * immediately.
157*4882a593Smuzhiyun */
158*4882a593Smuzhiyun void
dmxSync(DMXScreenInfo * dmxScreen,Bool now)159*4882a593Smuzhiyun dmxSync(DMXScreenInfo * dmxScreen, Bool now)
160*4882a593Smuzhiyun {
161*4882a593Smuzhiyun static unsigned long dmxGeneration = 0;
162*4882a593Smuzhiyun
163*4882a593Smuzhiyun if (dmxSyncInterval) {
164*4882a593Smuzhiyun if (dmxGeneration != serverGeneration) {
165*4882a593Smuzhiyun /* Server generation does a TimerInit, which frees all
166*4882a593Smuzhiyun * timers. So, at this point dmxSyncTimer is either:
167*4882a593Smuzhiyun * 1) NULL, iff dmxGeneration == 0,
168*4882a593Smuzhiyun * 2) freed, if it was on a queue (dmxSyncPending != 0), or
169*4882a593Smuzhiyun * 3) allocated, if it wasn't on a queue (dmxSyncPending == 0)
170*4882a593Smuzhiyun */
171*4882a593Smuzhiyun if (dmxSyncTimer && !dmxSyncPending)
172*4882a593Smuzhiyun free(dmxSyncTimer);
173*4882a593Smuzhiyun dmxSyncTimer = NULL;
174*4882a593Smuzhiyun now = TRUE;
175*4882a593Smuzhiyun dmxGeneration = serverGeneration;
176*4882a593Smuzhiyun }
177*4882a593Smuzhiyun /* Queue sync */
178*4882a593Smuzhiyun if (dmxScreen) {
179*4882a593Smuzhiyun dmxScreen->needsSync = TRUE;
180*4882a593Smuzhiyun ++dmxSyncPending;
181*4882a593Smuzhiyun }
182*4882a593Smuzhiyun
183*4882a593Smuzhiyun /* Do sync or set time for later */
184*4882a593Smuzhiyun if (now || !dmxScreen) {
185*4882a593Smuzhiyun if (dmxSyncTimer == NULL || !TimerForce(dmxSyncTimer))
186*4882a593Smuzhiyun dmxSyncCallback(NULL, 0, NULL);
187*4882a593Smuzhiyun /* At this point, dmxSyncPending == 0 because
188*4882a593Smuzhiyun * dmxSyncCallback must have been called. */
189*4882a593Smuzhiyun if (dmxSyncPending)
190*4882a593Smuzhiyun dmxLog(dmxFatal, "dmxSync(%s,%d): dmxSyncPending = %d\n",
191*4882a593Smuzhiyun dmxScreen ? dmxScreen->name : "", now, dmxSyncPending);
192*4882a593Smuzhiyun }
193*4882a593Smuzhiyun else {
194*4882a593Smuzhiyun dmxScreen->needsSync = TRUE;
195*4882a593Smuzhiyun if (dmxSyncPending == 1)
196*4882a593Smuzhiyun dmxSyncTimer = TimerSet(dmxSyncTimer, 0, dmxSyncInterval,
197*4882a593Smuzhiyun dmxSyncCallback, NULL);
198*4882a593Smuzhiyun }
199*4882a593Smuzhiyun }
200*4882a593Smuzhiyun else {
201*4882a593Smuzhiyun /* If dmxSyncInterval is not being used,
202*4882a593Smuzhiyun * then all the backends are already
203*4882a593Smuzhiyun * up-to-date. */
204*4882a593Smuzhiyun if (dmxScreen)
205*4882a593Smuzhiyun dmxDoSync(dmxScreen);
206*4882a593Smuzhiyun }
207*4882a593Smuzhiyun }
208