Bug Summary

File:NextEvent.c
Location:line 862, column 15
Description:Access to field 'workQueue' results in a dereference of a null pointer (loaded from variable 'app')

Annotated Source Code

1/***********************************************************
2Copyright (c) 1993, Oracle and/or its affiliates. All rights reserved.
3
4Permission is hereby granted, free of charge, to any person obtaining a
5copy of this software and associated documentation files (the "Software"),
6to deal in the Software without restriction, including without limitation
7the rights to use, copy, modify, merge, publish, distribute, sublicense,
8and/or sell copies of the Software, and to permit persons to whom the
9Software is furnished to do so, subject to the following conditions:
10
11The above copyright notice and this permission notice (including the next
12paragraph) shall be included in all copies or substantial portions of the
13Software.
14
15THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
18THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
20FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
21DEALINGS IN THE SOFTWARE.
22
23Copyright 1987, 1988 by Digital Equipment Corporation, Maynard, Massachusetts.
24
25 All Rights Reserved
26
27Permission to use, copy, modify, and distribute this software and its
28documentation for any purpose and without fee is hereby granted,
29provided that the above copyright notice appear in all copies and that
30both that copyright notice and this permission notice appear in
31supporting documentation, and that the name of Digital not be
32used in advertising or publicity pertaining to distribution of the
33software without specific, written prior permission.
34
35DIGITAL DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING
36ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL
37DIGITAL BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR
38ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,
39WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION,
40ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS
41SOFTWARE.
42
43******************************************************************/
44
45/*
46
47Copyright 1987, 1988, 1994, 1998, 2001 The Open Group
48
49Permission to use, copy, modify, distribute, and sell this software and its
50documentation for any purpose is hereby granted without fee, provided that
51the above copyright notice appear in all copies and that both that
52copyright notice and this permission notice appear in supporting
53documentation.
54
55The above copyright notice and this permission notice shall be included in
56all copies or substantial portions of the Software.
57
58THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
59IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
60FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
61OPEN GROUP BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
62AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
63CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
64
65Except as contained in this notice, the name of The Open Group shall not be
66used in advertising or otherwise to promote the sale, use or other dealings
67in this Software without prior written authorization from The Open Group.
68
69*/
70
71#ifdef HAVE_CONFIG_H1
72#include <config.h>
73#endif
74#include "IntrinsicI.h"
75#include <stdio.h>
76#include <errno(*__errno_location ()).h>
77
78#ifdef __UNIXOS2__
79#include <sys/time.h>
80#endif
81
82static TimerEventRec* freeTimerRecs;
83static WorkProcRec* freeWorkRecs;
84static SignalEventRec* freeSignalRecs;
85
86/* Some systems running NTP daemons are known to return strange usec
87 * values from gettimeofday.
88 */
89
90#ifndef NEEDS_NTPD_FIXUP0
91# if defined(sun) || defined(MOTOROLA) || (defined(__osf__) && defined(__alpha))
92# define NEEDS_NTPD_FIXUP0 1
93# else
94# define NEEDS_NTPD_FIXUP0 0
95# endif
96#endif
97
98#if NEEDS_NTPD_FIXUP0
99#define FIXUP_TIMEVAL(t) { \
100 while ((t).tv_usec >= 1000000) { \
101 (t).tv_usec -= 1000000; \
102 (t).tv_sec++; \
103 } \
104 while ((t).tv_usec < 0) { \
105 if ((t).tv_sec > 0) { \
106 (t).tv_usec += 1000000; \
107 (t).tv_sec--; \
108 } else { \
109 (t).tv_usec = 0; \
110 break; \
111 } \
112 }}
113#else
114#define FIXUP_TIMEVAL(t)
115#endif /*NEEDS_NTPD_FIXUP*/
116
117/*
118 * Private routines
119 */
120#define ADD_TIME(dest, src1, src2){ if(((dest).tv_usec = (src1).tv_usec + (src2).tv_usec) >=
1000000) { (dest).tv_usec -= 1000000; (dest).tv_sec = (src1)
.tv_sec + (src2).tv_sec + 1 ; } else { (dest).tv_sec = (src1)
.tv_sec + (src2).tv_sec ; if(((dest).tv_sec >= 1) &&
(((dest).tv_usec <0))) { (dest).tv_sec --;(dest).tv_usec +=
1000000; } } } { \
121 if(((dest).tv_usec = (src1).tv_usec + (src2).tv_usec) >= 1000000) {\
122 (dest).tv_usec -= 1000000;\
123 (dest).tv_sec = (src1).tv_sec + (src2).tv_sec + 1 ; \
124 } else { (dest).tv_sec = (src1).tv_sec + (src2).tv_sec ; \
125 if(((dest).tv_sec >= 1) && (((dest).tv_usec <0))) { \
126 (dest).tv_sec --;(dest).tv_usec += 1000000; } } }
127
128
129#define TIMEDELTA(dest, src1, src2){ if(((dest).tv_usec = (src1).tv_usec - (src2).tv_usec) < 0
) { (dest).tv_usec += 1000000; (dest).tv_sec = (src1).tv_sec -
(src2).tv_sec - 1; } else (dest).tv_sec = (src1).tv_sec - (src2
).tv_sec; } { \
130 if(((dest).tv_usec = (src1).tv_usec - (src2).tv_usec) < 0) {\
131 (dest).tv_usec += 1000000;\
132 (dest).tv_sec = (src1).tv_sec - (src2).tv_sec - 1;\
133 } else (dest).tv_sec = (src1).tv_sec - (src2).tv_sec; }
134
135#define IS_AFTER(t1, t2)(((t2).tv_sec > (t1).tv_sec) || (((t2).tv_sec == (t1).tv_sec
)&& ((t2).tv_usec > (t1).tv_usec))) (((t2).tv_sec > (t1).tv_sec) \
136 || (((t2).tv_sec == (t1).tv_sec)&& ((t2).tv_usec > (t1).tv_usec)))
137
138#define IS_AT_OR_AFTER(t1, t2)(((t2).tv_sec > (t1).tv_sec) || (((t2).tv_sec == (t1).tv_sec
)&& ((t2).tv_usec >= (t1).tv_usec))) (((t2).tv_sec > (t1).tv_sec) \
139 || (((t2).tv_sec == (t1).tv_sec)&& ((t2).tv_usec >= (t1).tv_usec)))
140
141#ifdef USE_POLL1
142#ifndef XT_DEFAULT_FDLIST_SIZE32
143#define XT_DEFAULT_FDLIST_SIZE32 32
144#endif
145#endif
146
147static void AdjustHowLong (
148 unsigned long *howlong,
149 struct timeval *start_time)
150{
151 struct timeval new_time, time_spent, lstart_time;
152
153 lstart_time = *start_time;
154 X_GETTIMEOFDAY (&new_time)gettimeofday(&new_time, (struct timezone*)0);
155 FIXUP_TIMEVAL(new_time);
156 TIMEDELTA(time_spent, new_time, lstart_time){ if(((time_spent).tv_usec = (new_time).tv_usec - (lstart_time
).tv_usec) < 0) { (time_spent).tv_usec += 1000000; (time_spent
).tv_sec = (new_time).tv_sec - (lstart_time).tv_sec - 1; } else
(time_spent).tv_sec = (new_time).tv_sec - (lstart_time).tv_sec
; };
157 if(*howlong <= (unsigned long)(time_spent.tv_sec*1000+time_spent.tv_usec/1000))
158 *howlong = (unsigned long)0; /* Timed out */
159 else
160 *howlong -= (time_spent.tv_sec*1000+time_spent.tv_usec/1000);
161}
162
163typedef struct {
164 struct timeval cur_time;
165 struct timeval start_time;
166 struct timeval wait_time;
167 struct timeval new_time;
168 struct timeval time_spent;
169 struct timeval max_wait_time;
170#ifndef USE_POLL1
171 struct timeval *wait_time_ptr;
172#else
173 int poll_wait;
174#endif
175} wait_times_t, *wait_times_ptr_t;
176
177static struct timeval zero_time = { 0 , 0};
178#ifndef USE_POLL1
179static fd_set zero_fd;
180#else
181#define X_BLOCK-1 -1
182#define X_DONT_BLOCK0 0
183#endif
184
185static void InitTimes (
186 Boolean block,
187 unsigned long* howlong,
188 wait_times_ptr_t wt)
189{
190 if (block) {
191 X_GETTIMEOFDAY (&wt->cur_time)gettimeofday(&wt->cur_time, (struct timezone*)0);
192 FIXUP_TIMEVAL(wt->cur_time);
193 wt->start_time = wt->cur_time;
194 if(howlong == NULL((void*)0)) { /* special case for ever */
195#ifndef USE_POLL1
196 wt->wait_time_ptr = NULL((void*)0);
197#else
198 wt->poll_wait = X_BLOCK-1;
199#endif
200 } else { /* block until at most */
201 wt->max_wait_time.tv_sec = *howlong/1000;
202 wt->max_wait_time.tv_usec = (*howlong %1000)*1000;
203#ifndef USE_POLL1
204 wt->wait_time_ptr = &wt->max_wait_time;
205#else
206 wt->poll_wait = *howlong;
207#endif
208 }
209 } else { /* don't block */
210 wt->max_wait_time = zero_time;
211#ifndef USE_POLL1
212 wt->wait_time_ptr = &wt->max_wait_time;
213#else
214 wt->poll_wait = X_DONT_BLOCK0;
215#endif
216 }
217}
218
219typedef struct {
220#ifndef USE_POLL1
221 fd_set rmask, wmask, emask;
222 int nfds;
223#else
224 struct pollfd* fdlist;
225 struct pollfd* stack;
226 int fdlistlen, num_dpys;
227#endif
228} wait_fds_t, *wait_fds_ptr_t;
229
230static void InitFds (
231 XtAppContext app,
232 Boolean ignoreEvents,
233 Boolean ignoreInputs,
234 wait_fds_ptr_t wf)
235{
236 int ii;
237 app->rebuild_fdlist = FALSE0;
238#ifndef USE_POLL1
239 wf->nfds = app->fds.nfds;
240 if( !ignoreInputs ) {
241 wf->rmask = app->fds.rmask;
242 wf->wmask = app->fds.wmask;
243 wf->emask = app->fds.emask;
244 } else
245 wf->rmask = wf->wmask = wf->emask = zero_fd;
246
247 if (!ignoreEvents)
248 for (ii = 0; ii < app->count; ii++) {
249 FD_SET (ConnectionNumber(app->list[ii]), &wf->rmask)((void) (((&wf->rmask)->__fds_bits)[(((((_XPrivDisplay
)app->list[ii])->fd)) / (8 * (int) sizeof (__fd_mask)))
] |= ((__fd_mask) 1 << (((((_XPrivDisplay)app->list[
ii])->fd)) % (8 * (int) sizeof (__fd_mask))))));
250 }
251#else
252#ifndef POLLRDNORM0x040
253#define POLLRDNORM0x040 0
254#endif
255
256#ifndef POLLRDBAND0x080
257#define POLLRDBAND0x080 0
258#endif
259
260#ifndef POLLWRNORM0x100
261#define POLLWRNORM0x100 0
262#endif
263
264#ifndef POLLWRBAND0x200
265#define POLLWRBAND0x200 0
266#endif
267
268#define XPOLL_READ(0x001|0x040|0x002|0x080) (POLLIN0x001|POLLRDNORM0x040|POLLPRI0x002|POLLRDBAND0x080)
269#define XPOLL_WRITE(0x004|0x100|0x200) (POLLOUT0x004|POLLWRNORM0x100|POLLWRBAND0x200)
270#define XPOLL_EXCEPT0 0
271
272 if (!ignoreEvents)
273 wf->fdlistlen = wf->num_dpys = app->count;
274 else
275 wf->fdlistlen = wf->num_dpys = 0;
276
277 if (!ignoreInputs && app->input_list != NULL((void*)0)) {
278 int ii;
279 for (ii = 0; ii < (int) app->input_max; ii++)
280 if (app->input_list[ii] != NULL((void*)0))
281 wf->fdlistlen++;
282 }
283
284 if (!wf->fdlist || wf->fdlist == wf->stack) {
285 wf->fdlist = (struct pollfd*)
286 XtStackAlloc (sizeof (struct pollfd) * wf->fdlistlen, wf->stack)((sizeof (struct pollfd) * wf->fdlistlen) <= sizeof(wf->
stack) ? (XtPointer)(wf->stack) : XtMalloc((unsigned)(sizeof
(struct pollfd) * wf->fdlistlen)));
287 } else {
288 wf->fdlist = (struct pollfd*)
289 XtRealloc ((char*) wf->fdlist,
290 sizeof (struct pollfd) * wf->fdlistlen);
291 }
292
293 if (wf->fdlistlen) {
294 struct pollfd* fdlp = wf->fdlist;
295 InputEvent* iep;
296
297 if (!ignoreEvents)
298 for (ii = 0 ; ii < wf->num_dpys; ii++, fdlp++) {
299 fdlp->fd = ConnectionNumber (app->list[ii])(((_XPrivDisplay)app->list[ii])->fd);
300 fdlp->events = POLLIN0x001;
301 }
302 if (!ignoreInputs && app->input_list != NULL((void*)0))
303 for (ii = 0; ii < app->input_max; ii++)
304 if (app->input_list[ii] != NULL((void*)0)) {
305 iep = app->input_list[ii];
306 fdlp->fd = ii;
307 fdlp->events = 0;
308 for ( ; iep; iep = iep->ie_next) {
309 if (iep->ie_condition & XtInputReadMask(1L<<0))
310 fdlp->events |= XPOLL_READ(0x001|0x040|0x002|0x080);
311 if (iep->ie_condition & XtInputWriteMask(1L<<1))
312 fdlp->events |= XPOLL_WRITE(0x004|0x100|0x200);
313 if (iep->ie_condition & XtInputExceptMask(1L<<2))
314 fdlp->events |= XPOLL_EXCEPT0;
315 }
316 fdlp++;
317 }
318 }
319#endif
320}
321
322static void AdjustTimes (
323 XtAppContext app,
324 Boolean block,
325 unsigned long* howlong,
326 Boolean ignoreTimers,
327 wait_times_ptr_t wt)
328{
329 if (app->timerQueue != NULL((void*)0) && !ignoreTimers && block) {
330 if (IS_AFTER (wt->cur_time, app->timerQueue->te_timer_value)(((app->timerQueue->te_timer_value).tv_sec > (wt->
cur_time).tv_sec) || (((app->timerQueue->te_timer_value
).tv_sec == (wt->cur_time).tv_sec)&& ((app->timerQueue
->te_timer_value).tv_usec > (wt->cur_time).tv_usec))
)) {
331 TIMEDELTA (wt->wait_time, app->timerQueue->te_timer_value, wt->cur_time){ if(((wt->wait_time).tv_usec = (app->timerQueue->te_timer_value
).tv_usec - (wt->cur_time).tv_usec) < 0) { (wt->wait_time
).tv_usec += 1000000; (wt->wait_time).tv_sec = (app->timerQueue
->te_timer_value).tv_sec - (wt->cur_time).tv_sec - 1; }
else (wt->wait_time).tv_sec = (app->timerQueue->te_timer_value
).tv_sec - (wt->cur_time).tv_sec; };
332 if (howlong == NULL((void*)0) || IS_AFTER (wt->wait_time, wt->max_wait_time)(((wt->max_wait_time).tv_sec > (wt->wait_time).tv_sec
) || (((wt->max_wait_time).tv_sec == (wt->wait_time).tv_sec
)&& ((wt->max_wait_time).tv_usec > (wt->wait_time
).tv_usec))))
333#ifndef USE_POLL1
334 wt->wait_time_ptr = &wt->wait_time;
335 else
336 wt->wait_time_ptr = &wt->max_wait_time;
337 } else
338 wt->wait_time_ptr = &zero_time;
339 }
340#else
341 wt->poll_wait = wt->wait_time.tv_sec * 1000 + wt->wait_time.tv_usec / 1000;
342 else
343 wt->poll_wait = wt->max_wait_time.tv_sec * 1000 + wt->max_wait_time.tv_usec / 1000;
344 } else
345 wt->poll_wait = X_DONT_BLOCK0;
346 }
347#endif
348}
349
350
351static int IoWait (
352 wait_times_ptr_t wt,
353 wait_fds_ptr_t wf)
354{
355#ifndef USE_POLL1
356 return Select (wf->nfds, &wf->rmask, &wf->wmask, &wf->emask,
357 wt->wait_time_ptr);
358#else
359 return poll (wf->fdlist, wf->fdlistlen, wt->poll_wait);
360#endif
361}
362
363
364static void FindInputs (
365 XtAppContext app,
366 wait_fds_ptr_t wf,
367 int nfds,
368 Boolean ignoreEvents,
369 Boolean ignoreInputs,
370 int* dpy_no,
371 int* found_input)
372{
373 XtInputMask condition;
374 InputEvent *ep;
375 int ii;
376#ifndef USE_POLL1 /* { check ready file descriptors block */
377#ifdef XTHREADS1
378 fd_set rmask;
379#endif
380 int dd;
381 *dpy_no = -1;
382 *found_input = False0;
383
384#ifdef XTHREADS1
385 rmask = app->fds.rmask;
386 for (dd = app->count; dd-- > 0; )
387 FD_SET (ConnectionNumber (app->list[dd]), &rmask)((void) (((&rmask)->__fds_bits)[(((((_XPrivDisplay)app
->list[dd])->fd)) / (8 * (int) sizeof (__fd_mask)))] |=
((__fd_mask) 1 << (((((_XPrivDisplay)app->list[dd])
->fd)) % (8 * (int) sizeof (__fd_mask))))));
388#endif
389
390 for (ii = 0; ii < wf->nfds && nfds > 0; ii++) {
391 condition = 0;
392 if (FD_ISSET (ii, &wf->rmask)((((&wf->rmask)->__fds_bits)[((ii) / (8 * (int) sizeof
(__fd_mask)))] & ((__fd_mask) 1 << ((ii) % (8 * (int
) sizeof (__fd_mask))))) != 0)
393#ifdef XTHREADS1
394 && FD_ISSET (ii, &rmask)((((&rmask)->__fds_bits)[((ii) / (8 * (int) sizeof (__fd_mask
)))] & ((__fd_mask) 1 << ((ii) % (8 * (int) sizeof (
__fd_mask))))) != 0)
395#endif
396 ) {
397 nfds--;
398 if (!ignoreEvents) {
399 for (dd = 0; dd < app->count; dd++) {
400 if (ii == ConnectionNumber (app->list[dd])(((_XPrivDisplay)app->list[dd])->fd)) {
401 if (*dpy_no == -1) {
402 if (XEventsQueued (app->list[dd], QueuedAfterReading1 ))
403 *dpy_no = dd;
404 /*
405 * An error event could have arrived
406 * without any real events, or events
407 * could have been swallowed by Xlib,
408 * or the connection may be broken.
409 * We can't tell the difference, so
410 * assume Xlib will eventually discover
411 * a broken connection.
412 */
413 }
414 goto ENDILOOP;
415 }
416 }
417 }
418 condition = XtInputReadMask(1L<<0);
419 }
420 if (FD_ISSET (ii, &wf->wmask)((((&wf->wmask)->__fds_bits)[((ii) / (8 * (int) sizeof
(__fd_mask)))] & ((__fd_mask) 1 << ((ii) % (8 * (int
) sizeof (__fd_mask))))) != 0)
421#ifdef XTHREADS1
422 && FD_ISSET (ii, &app->fds.wmask)((((&app->fds.wmask)->__fds_bits)[((ii) / (8 * (int
) sizeof (__fd_mask)))] & ((__fd_mask) 1 << ((ii) %
(8 * (int) sizeof (__fd_mask))))) != 0)
423#endif
424 ) {
425 condition |= XtInputWriteMask(1L<<1);
426 nfds--;
427 }
428 if (FD_ISSET (ii, &wf->emask)((((&wf->emask)->__fds_bits)[((ii) / (8 * (int) sizeof
(__fd_mask)))] & ((__fd_mask) 1 << ((ii) % (8 * (int
) sizeof (__fd_mask))))) != 0)
429#ifdef XTHREADS1
430 && FD_ISSET (ii, &app->fds.emask)((((&app->fds.emask)->__fds_bits)[((ii) / (8 * (int
) sizeof (__fd_mask)))] & ((__fd_mask) 1 << ((ii) %
(8 * (int) sizeof (__fd_mask))))) != 0)
431#endif
432 ) {
433 condition |= XtInputExceptMask(1L<<2);
434 nfds--;
435 }
436 if (condition) {
437 for (ep = app->input_list[ii]; ep; ep = ep->ie_next)
438 if (condition & ep->ie_condition) {
439 /* make sure this input isn't already marked outstanding */
440 InputEvent *oq;
441 for (oq = app->outstandingQueue; oq; oq = oq->ie_oq)
442 if (oq == ep)
443 break;
444 if (!oq)
445 {
446 ep->ie_oq = app->outstandingQueue;
447 app->outstandingQueue = ep;
448 }
449 }
450 *found_input = True1;
451 }
452ENDILOOP: ;
453 } /* endfor */
454#else /* }{ */
455 struct pollfd* fdlp;
456
457 *dpy_no = -1;
458 *found_input = False0;
459
460 if (!ignoreEvents) {
461 fdlp = wf->fdlist;
462 for (ii = 0; ii < wf->num_dpys; ii++, fdlp++) {
463 if (*dpy_no == -1 && fdlp->revents & (POLLIN0x001|POLLHUP0x010|POLLERR0x008) &&
464#ifdef XTHREADS1
465 !(fdlp->revents & POLLNVAL0x020) &&
466#endif
467 XEventsQueued (app->list[ii], QueuedAfterReading1)) {
468 *dpy_no = ii;
469 break;
470 }
471 }
472 }
473
474 if (!ignoreInputs) {
475 fdlp = &wf->fdlist[wf->num_dpys];
476 for (ii = wf->num_dpys; ii < wf->fdlistlen; ii++, fdlp++) {
477 condition = 0;
478 if (fdlp->revents) {
479 if (fdlp->revents & (XPOLL_READ(0x001|0x040|0x002|0x080)|POLLHUP0x010|POLLERR0x008)
480#ifdef XTHREADS1
481 && !(fdlp->revents & POLLNVAL0x020)
482#endif
483 )
484 condition = XtInputReadMask(1L<<0);
485 if (fdlp->revents & XPOLL_WRITE(0x004|0x100|0x200))
486 condition |= XtInputWriteMask(1L<<1);
487 if (fdlp->revents & XPOLL_EXCEPT0)
488 condition |= XtInputExceptMask(1L<<2);
489 }
490 if (condition) {
491 *found_input = True1;
492 for (ep = app->input_list[fdlp->fd]; ep; ep = ep->ie_next)
493 if (condition & ep->ie_condition) {
494 InputEvent *oq;
495 /* make sure this input isn't already marked outstanding */
496 for (oq = app->outstandingQueue; oq; oq = oq->ie_oq)
497 if (oq == ep)
498 break;
499 if (!oq)
500 {
501 ep->ie_oq = app->outstandingQueue;
502 app->outstandingQueue = ep;
503 }
504 }
505 }
506 }
507 }
508#endif /* } */
509}
510
511/*
512 * Routine to block in the toolkit. This should be the only call to select.
513 *
514 * This routine returns when there is something to be done.
515 *
516 * Before calling this with ignoreInputs==False, app->outstandingQueue should
517 * be checked; this routine will not verify that an alternate input source
518 * has not already been enqueued.
519 *
520 *
521 * _XtWaitForSomething( appContext,
522 * ignoreEvent, ignoreTimers, ignoreInputs, ignoreSignals,
523 * block, drop_lock, howlong)
524 * XtAppContext app; (Displays to check wait on)
525 *
526 * Boolean ignoreEvents; (Don't return if XEvents are available
527 * Also implies forget XEvents exist)
528 *
529 * Boolean ignoreTimers; (Ditto for timers)
530 *
531 * Boolean ignoreInputs; (Ditto for input callbacks )
532 *
533 * Boolean ignoreSignals; (Ditto for signals)
534 *
535 * Boolean block; (Okay to block)
536 *
537 * Boolean drop_lock (drop lock before going into select/poll)
538 *
539 * TimeVal howlong; (howlong to wait for if blocking and not
540 * doing Timers... Null means forever.
541 * Maybe should mean shortest of both)
542 * Returns display for which input is available, if any
543 * and if ignoreEvents==False, else returns -1
544 *
545 * if ignoring everything && block=True && howlong=NULL, you'll have
546 * lots of time for coffee; better not try it! In fact, it probably
547 * makes little sense to do this regardless of the value of howlong
548 * (bottom line is, we don't bother checking here).
549 *
550 * If drop_lock is FALSE, the app->lock->mutex is not unlocked before
551 * entering select/poll. It is illegal for drop_lock to be FALSE if
552 * ignoreTimers, ignoreInputs, or ignoreSignals is FALSE.
553 */
554int _XtWaitForSomething(
555 XtAppContext app,
556 _XtBooleanBoolean ignoreEvents,
557 _XtBooleanBoolean ignoreTimers,
558 _XtBooleanBoolean ignoreInputs,
559 _XtBooleanBoolean ignoreSignals,
560 _XtBooleanBoolean block,
561#ifdef XTHREADS1
562 _XtBooleanBoolean drop_lock,
563#endif
564 unsigned long *howlong)
565{
566 wait_times_t wt;
567 wait_fds_t wf;
568 int nfds, dpy_no, found_input, dd;
569#ifdef XTHREADS1
570 Boolean push_thread = TRUE1;
571 Boolean pushed_thread = FALSE0;
572 int level = 0;
573#endif
574#ifdef USE_POLL1
575 struct pollfd fdlist[XT_DEFAULT_FDLIST_SIZE32];
576#endif
577
578#ifdef XTHREADS1
579 /* assert ((ignoreTimers && ignoreInputs && ignoreSignals) || drop_lock); */
580 /* If not multi-threaded, never drop lock */
581 if (app->lock == (ThreadAppProc) NULL((void*)0))
582 drop_lock = FALSE0;
583#endif
584
585 InitTimes (block, howlong, &wt);
586
587#ifdef USE_POLL1
588 wf.fdlist = NULL((void*)0);
589 wf.stack = fdlist;
590 wf.fdlistlen = wf.num_dpys = 0;
591#endif
592
593WaitLoop:
594 app->rebuild_fdlist = TRUE1;
595
596 while (1) {
597 AdjustTimes (app, block, howlong, ignoreTimers, &wt);
598
599 if (block && app->block_hook_list) {
600 BlockHook hook;
601 for (hook = app->block_hook_list;
602 hook != NULL((void*)0);
603 hook = hook->next)
604 (*hook->proc) (hook->closure);
605
606 if (!ignoreEvents)
607 /* see if the hook(s) generated any protocol */
608 for (dd = 0; dd < app->count; dd++)
609 if (XEventsQueued(app->list[dd], QueuedAlready0)) {
610#ifdef USE_POLL1
611 XtStackFree ((XtPointer) wf.fdlist, fdlist){ if (((XtPointer) wf.fdlist) != ((XtPointer)(fdlist))) XtFree
((XtPointer) wf.fdlist); };
612#endif
613 return dd;
614 }
615 }
616
617 if (app->rebuild_fdlist)
618 InitFds (app, ignoreEvents, ignoreInputs, &wf);
619
620#ifdef XTHREADS1 /* { */
621 if (drop_lock) {
622 YIELD_APP_LOCK(app, &push_thread, &pushed_thread, &level)if(app && app->yield_lock) (*app->yield_lock)(app
,&push_thread,&pushed_thread,&level);
623 nfds = IoWait (&wt, &wf);
624 RESTORE_APP_LOCK(app, level, &pushed_thread)if(app && app->restore_lock) (*app->restore_lock
)(app,level,&pushed_thread);
625 } else
626#endif /* } */
627 nfds = IoWait (&wt, &wf);
628 if (nfds == -1) {
629 /*
630 * interrupt occured recalculate time value and wait again.
631 */
632 if (errno(*__errno_location ()) == EINTR4 || errno(*__errno_location ()) == EAGAIN11) {
633 if (errno(*__errno_location ()) == EAGAIN11) {
634 errno(*__errno_location ()) = 0; /* errno is not self reseting */
635 continue;
636 }
637 errno(*__errno_location ()) = 0; /* errno is not self reseting */
638
639 /* was it interrupted by a signal that we care about? */
640 if (!ignoreSignals && app->signalQueue != NULL((void*)0)) {
641 SignalEventRec *se_ptr = app->signalQueue;
642 while (se_ptr != NULL((void*)0)) {
643 if (se_ptr->se_notice) {
644 if (block && howlong != NULL((void*)0))
645 AdjustHowLong (howlong, &wt.start_time);
646#ifdef USE_POLL1
647 XtStackFree ((XtPointer) wf.fdlist, fdlist){ if (((XtPointer) wf.fdlist) != ((XtPointer)(fdlist))) XtFree
((XtPointer) wf.fdlist); };
648#endif
649 return -1;
650 }
651 se_ptr = se_ptr->se_next;
652 }
653 }
654
655 if (!ignoreEvents)
656 /* get Xlib to detect a bad connection */
657 for (dd = 0; dd < app->count; dd++)
658 if (XEventsQueued(app->list[dd], QueuedAfterReading1)) {
659#ifdef USE_POLL1
660 XtStackFree ((XtPointer) wf.fdlist, fdlist){ if (((XtPointer) wf.fdlist) != ((XtPointer)(fdlist))) XtFree
((XtPointer) wf.fdlist); };
661#endif
662 return dd;
663 }
664
665 if (block) {
666#ifndef USE_POLL1
667 if (wt.wait_time_ptr == NULL((void*)0))
668#else
669 if (wt.poll_wait == X_BLOCK-1)
670#endif
671 continue;
672 X_GETTIMEOFDAY (&wt.new_time)gettimeofday(&wt.new_time, (struct timezone*)0);
673 FIXUP_TIMEVAL (wt.new_time);
674 TIMEDELTA (wt.time_spent, wt.new_time, wt.cur_time){ if(((wt.time_spent).tv_usec = (wt.new_time).tv_usec - (wt.cur_time
).tv_usec) < 0) { (wt.time_spent).tv_usec += 1000000; (wt.
time_spent).tv_sec = (wt.new_time).tv_sec - (wt.cur_time).tv_sec
- 1; } else (wt.time_spent).tv_sec = (wt.new_time).tv_sec - (
wt.cur_time).tv_sec; };
675 wt.cur_time = wt.new_time;
676#ifndef USE_POLL1
677 if (IS_AFTER (wt.time_spent, *wt.wait_time_ptr)(((*wt.wait_time_ptr).tv_sec > (wt.time_spent).tv_sec) || (
((*wt.wait_time_ptr).tv_sec == (wt.time_spent).tv_sec)&&
((*wt.wait_time_ptr).tv_usec > (wt.time_spent).tv_usec)))) {
678 TIMEDELTA (wt.wait_time, *wt.wait_time_ptr, wt.time_spent){ if(((wt.wait_time).tv_usec = (*wt.wait_time_ptr).tv_usec - (
wt.time_spent).tv_usec) < 0) { (wt.wait_time).tv_usec += 1000000
; (wt.wait_time).tv_sec = (*wt.wait_time_ptr).tv_sec - (wt.time_spent
).tv_sec - 1; } else (wt.wait_time).tv_sec = (*wt.wait_time_ptr
).tv_sec - (wt.time_spent).tv_sec; };
679 wt.wait_time_ptr = &wt.wait_time;
680 continue;
681 } else
682#else
683 if ((wt.time_spent.tv_sec * 1000 + wt.time_spent.tv_usec / 1000) < wt.poll_wait) {
684 wt.poll_wait -= (wt.time_spent.tv_sec * 1000 + wt.time_spent.tv_usec / 1000);
685 continue;
686 } else
687#endif
688 nfds = 0;
689 }
690 } else {
691 char Errno[12];
692 String param = Errno;
693 Cardinal param_count = 1;
694
695 sprintf( Errno, "%d", errno(*__errno_location ()));
696 XtAppWarningMsg(app, "communicationError","select",
697 XtCXtToolkitError,"Select failed; error code %s",
698 &param, &param_count);
699 continue;
700 }
701 } /* timed out or input available */
702 break;
703 }
704
705 if (nfds == 0) {
706 /* Timed out */
707 if (howlong)
708 *howlong = (unsigned long)0;
709#ifdef USE_POLL1
710 XtStackFree ((XtPointer) wf.fdlist, fdlist){ if (((XtPointer) wf.fdlist) != ((XtPointer)(fdlist))) XtFree
((XtPointer) wf.fdlist); };
711#endif
712 return -1;
713 }
714
715 if (block && howlong != NULL((void*)0))
716 AdjustHowLong (howlong, &wt.start_time);
717
718 if (ignoreInputs && ignoreEvents) {
719#ifdef USE_POLL1
720 XtStackFree ((XtPointer) wf.fdlist, fdlist){ if (((XtPointer) wf.fdlist) != ((XtPointer)(fdlist))) XtFree
((XtPointer) wf.fdlist); };
721#endif
722 return -1;
723 } else
724 FindInputs (app, &wf, nfds,
725 ignoreEvents, ignoreInputs,
726 &dpy_no, &found_input);
727
728 if (dpy_no >= 0 || found_input) {
729#ifdef USE_POLL1
730 XtStackFree ((XtPointer) wf.fdlist, fdlist){ if (((XtPointer) wf.fdlist) != ((XtPointer)(fdlist))) XtFree
((XtPointer) wf.fdlist); };
731#endif
732 return dpy_no;
733 }
734 if (block)
735 goto WaitLoop;
736 else {
737#ifdef USE_POLL1
738 XtStackFree ((XtPointer) wf.fdlist, fdlist){ if (((XtPointer) wf.fdlist) != ((XtPointer)(fdlist))) XtFree
((XtPointer) wf.fdlist); };
739#endif
740 return -1;
741 }
742}
743
744#define IeCallProc(ptr)(*ptr->ie_proc) (ptr->ie_closure, &ptr->ie_source
, (XtInputId*)&ptr); \
745 (*ptr->ie_proc) (ptr->ie_closure, &ptr->ie_source, (XtInputId*)&ptr);
746
747#define TeCallProc(ptr)(*ptr->te_proc) (ptr->te_closure, (XtIntervalId*)&ptr
); \
748 (*ptr->te_proc) (ptr->te_closure, (XtIntervalId*)&ptr);
749
750#define SeCallProc(ptr)(*ptr->se_proc) (ptr->se_closure, (XtSignalId*)&ptr
); \
751 (*ptr->se_proc) (ptr->se_closure, (XtSignalId*)&ptr);
752
753/*
754 * Public Routines
755 */
756
757XtIntervalId XtAddTimeOut(
758 unsigned long interval,
759 XtTimerCallbackProc proc,
760 XtPointer closure)
761{
762 return XtAppAddTimeOut(_XtDefaultAppContext(),
763 interval, proc, closure);
764}
765
766static void QueueTimerEvent(
767 XtAppContext app,
768 TimerEventRec *ptr)
769{
770 TimerEventRec *t,**tt;
771 tt = &app->timerQueue;
772 t = *tt;
773 while (t != NULL((void*)0) &&
774 IS_AFTER(t->te_timer_value, ptr->te_timer_value)(((ptr->te_timer_value).tv_sec > (t->te_timer_value)
.tv_sec) || (((ptr->te_timer_value).tv_sec == (t->te_timer_value
).tv_sec)&& ((ptr->te_timer_value).tv_usec > (t
->te_timer_value).tv_usec)))) {
775 tt = &t->te_next;
776 t = *tt;
777 }
778 ptr->te_next = t;
779 *tt = ptr;
780}
781
782XtIntervalId XtAppAddTimeOut(
783 XtAppContext app,
784 unsigned long interval,
785 XtTimerCallbackProc proc,
786 XtPointer closure)
787{
788 TimerEventRec *tptr;
789 struct timeval current_time;
790
791 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
792 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
793 if (freeTimerRecs) {
794 tptr = freeTimerRecs;
795 freeTimerRecs = tptr->te_next;
796 }
797 else tptr = XtNew(TimerEventRec)((TimerEventRec *) XtMalloc((unsigned) sizeof(TimerEventRec))
);
798 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
799
800 tptr->te_next = NULL((void*)0);
801 tptr->te_closure = closure;
802 tptr->te_proc = proc;
803 tptr->app = app;
804 tptr->te_timer_value.tv_sec = interval/1000;
805 tptr->te_timer_value.tv_usec = (interval%1000)*1000;
806 X_GETTIMEOFDAY (&current_time)gettimeofday(&current_time, (struct timezone*)0);
807 FIXUP_TIMEVAL(current_time);
808 ADD_TIME(tptr->te_timer_value,tptr->te_timer_value,current_time){ if(((tptr->te_timer_value).tv_usec = (tptr->te_timer_value
).tv_usec + (current_time).tv_usec) >= 1000000) { (tptr->
te_timer_value).tv_usec -= 1000000; (tptr->te_timer_value)
.tv_sec = (tptr->te_timer_value).tv_sec + (current_time).tv_sec
+ 1 ; } else { (tptr->te_timer_value).tv_sec = (tptr->
te_timer_value).tv_sec + (current_time).tv_sec ; if(((tptr->
te_timer_value).tv_sec >= 1) && (((tptr->te_timer_value
).tv_usec <0))) { (tptr->te_timer_value).tv_sec --;(tptr
->te_timer_value).tv_usec += 1000000; } } };
809 QueueTimerEvent(app, tptr);
810 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
811 return( (XtIntervalId) tptr);
812}
813
814void XtRemoveTimeOut(
815 XtIntervalId id)
816{
817 TimerEventRec *t, *last, *tid = (TimerEventRec *) id;
818 XtAppContext app = tid->app;
819
820 /* find it */
821 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
822 for(t = app->timerQueue, last = NULL((void*)0);
823 t != NULL((void*)0) && t != tid;
824 t = t->te_next) last = t;
825
826 if (t == NULL((void*)0)) {
827 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
828 return; /* couldn't find it */
829 }
830 if(last == NULL((void*)0)) { /* first one on the list */
831 app->timerQueue = t->te_next;
832 } else last->te_next = t->te_next;
833
834 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
835 t->te_next = freeTimerRecs;
836 freeTimerRecs = t;
837 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
838 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
839}
840
841XtWorkProcId XtAddWorkProc(
842 XtWorkProc proc,
843 XtPointer closure)
844{
845 return XtAppAddWorkProc(_XtDefaultAppContext(), proc, closure);
846}
847
848XtWorkProcId XtAppAddWorkProc(
849 XtAppContext app,
850 XtWorkProc proc,
851 XtPointer closure)
852{
853 WorkProcRec *wptr;
854
855 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
856 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
1
Within the expansion of the macro 'LOCK_PROCESS':
a
Assuming '_XtProcessLock' is null
857 if (freeWorkRecs) {
2
Assuming 'freeWorkRecs' is null
3
Taking false branch
858 wptr = freeWorkRecs;
859 freeWorkRecs = wptr->next;
860 } else wptr = XtNew(WorkProcRec)((WorkProcRec *) XtMalloc((unsigned) sizeof(WorkProcRec)));
861 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
4
Within the expansion of the macro 'UNLOCK_PROCESS':
a
Assuming '_XtProcessUnlock' is null
862 wptr->next = app->workQueue;
5
Access to field 'workQueue' results in a dereference of a null pointer (loaded from variable 'app')
863 wptr->closure = closure;
864 wptr->proc = proc;
865 wptr->app = app;
866 app->workQueue = wptr;
867 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
868 return (XtWorkProcId) wptr;
869}
870
871void XtRemoveWorkProc(
872 XtWorkProcId id)
873{
874 WorkProcRec *wid= (WorkProcRec *) id, *w, *last;
875 XtAppContext app = wid->app;
876
877 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
878 /* find it */
879 for(w = app->workQueue, last = NULL((void*)0);
880 w != NULL((void*)0) && w != wid; w = w->next) last = w;
881
882 if (w == NULL((void*)0)) {
883 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
884 return; /* couldn't find it */
885 }
886
887 if(last == NULL((void*)0)) app->workQueue = w->next;
888 else last->next = w->next;
889 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
890 w->next = freeWorkRecs;
891 freeWorkRecs = w;
892 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
893 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
894}
895
896XtSignalId XtAddSignal(
897 XtSignalCallbackProc proc,
898 XtPointer closure)
899{
900 return XtAppAddSignal(_XtDefaultAppContext(), proc, closure);
901}
902
903XtSignalId XtAppAddSignal(
904 XtAppContext app,
905 XtSignalCallbackProc proc,
906 XtPointer closure)
907{
908 SignalEventRec *sptr;
909
910 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
911 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
912 if (freeSignalRecs) {
913 sptr = freeSignalRecs;
914 freeSignalRecs = sptr->se_next;
915 } else
916 sptr = XtNew(SignalEventRec)((SignalEventRec *) XtMalloc((unsigned) sizeof(SignalEventRec
)));
917 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
918 sptr->se_next = app->signalQueue;
919 sptr->se_closure = closure;
920 sptr->se_proc = proc;
921 sptr->app = app;
922 sptr->se_notice = FALSE0;
923 app->signalQueue = sptr;
924 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
925 return (XtSignalId) sptr;
926}
927
928void XtRemoveSignal(
929 XtSignalId id)
930{
931 SignalEventRec *sid = (SignalEventRec*) id, *s, *last = NULL((void*)0);
932 XtAppContext app = sid->app;
933
934 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
935 for (s = app->signalQueue; s != NULL((void*)0) && s != sid; s = s->se_next)
936 last = s;
937 if (s == NULL((void*)0)) {
938 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
939 return;
940 }
941 if (last == NULL((void*)0))
942 app->signalQueue = s->se_next;
943 else
944 last->se_next = s->se_next;
945 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
946 s->se_next = freeSignalRecs;
947 freeSignalRecs = s;
948 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
949 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
950}
951
952void XtNoticeSignal(
953 XtSignalId id)
954{
955 /*
956 * It would be overkill to lock the app to set this flag.
957 * In the worst case, 2..n threads would be modifying this
958 * flag. The last one wins. Since signals occur asynchronously
959 * anyway, this can occur with or without threads.
960 *
961 * The other issue is that thread t1 sets the flag in a
962 * signalrec that has been deleted in thread t2. We rely
963 * on a detail of the implementation, i.e. free'd signalrecs
964 * aren't really free'd, they're just moved to a list of
965 * free recs, so deref'ing one won't hurt anything.
966 *
967 * Lastly, and perhaps most importantly, since POSIX threads
968 * says that the handling of asynchronous signals in a synchronous
969 * threads environment is undefined. Therefor it would be an
970 * error for both signals and threads to be in use in the same
971 * program.
972 */
973 SignalEventRec *sid = (SignalEventRec*) id;
974 sid->se_notice = TRUE1;
975}
976
977XtInputId XtAddInput(
978 int source,
979 XtPointer Condition,
980 XtInputCallbackProc proc,
981 XtPointer closure)
982{
983 return XtAppAddInput(_XtDefaultAppContext(),
984 source, Condition, proc, closure);
985}
986
987XtInputId XtAppAddInput(
988 XtAppContext app,
989 int source,
990 XtPointer Condition,
991 XtInputCallbackProc proc,
992 XtPointer closure)
993{
994 InputEvent* sptr;
995 XtInputMask condition = (XtInputMask) Condition;
996
997 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
998 if (!condition ||
999 condition & ~(XtInputReadMask(1L<<0)|XtInputWriteMask(1L<<1)|XtInputExceptMask(1L<<2)))
1000 XtAppErrorMsg(app,"invalidParameter","xtAddInput",XtCXtToolkitError,
1001 "invalid condition passed to XtAppAddInput",
1002 (String *)NULL((void*)0), (Cardinal *)NULL((void*)0));
1003
1004 if (app->input_max <= source) {
1005 Cardinal n = source + 1;
1006 int ii;
1007 app->input_list = (InputEvent**)XtRealloc((char*) app->input_list,
1008 n * sizeof(InputEvent*));
1009 for (ii = app->input_max; ii < (int) n; ii++)
1010 app->input_list[ii] = (InputEvent*) NULL((void*)0);
1011 app->input_max = n;
1012 }
1013 sptr = XtNew(InputEvent)((InputEvent *) XtMalloc((unsigned) sizeof(InputEvent)));
1014 sptr->ie_proc = proc;
1015 sptr->ie_closure = closure;
1016 sptr->app = app;
1017 sptr->ie_oq = NULL((void*)0);
1018 sptr->ie_source = source;
1019 sptr->ie_condition = condition;
1020 sptr->ie_next = app->input_list[source];
1021 app->input_list[source] = sptr;
1022
1023#ifndef USE_POLL1
1024 if (condition & XtInputReadMask(1L<<0)) FD_SET(source, &app->fds.rmask)((void) (((&app->fds.rmask)->__fds_bits)[((source) /
(8 * (int) sizeof (__fd_mask)))] |= ((__fd_mask) 1 << (
(source) % (8 * (int) sizeof (__fd_mask))))));
1025 if (condition & XtInputWriteMask(1L<<1)) FD_SET(source, &app->fds.wmask)((void) (((&app->fds.wmask)->__fds_bits)[((source) /
(8 * (int) sizeof (__fd_mask)))] |= ((__fd_mask) 1 << (
(source) % (8 * (int) sizeof (__fd_mask))))));
1026 if (condition & XtInputExceptMask(1L<<2)) FD_SET(source, &app->fds.emask)((void) (((&app->fds.emask)->__fds_bits)[((source) /
(8 * (int) sizeof (__fd_mask)))] |= ((__fd_mask) 1 << (
(source) % (8 * (int) sizeof (__fd_mask))))));
1027
1028 if (app->fds.nfds < (source+1)) app->fds.nfds = source+1;
1029#else
1030 if (sptr->ie_next == NULL((void*)0))
1031 app->fds.nfds++;
1032#endif
1033 app->input_count++;
1034 app->rebuild_fdlist = TRUE1;
1035 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1036 return((XtInputId)sptr);
1037}
1038
1039void XtRemoveInput(
1040 register XtInputId id)
1041{
1042 register InputEvent *sptr, *lptr;
1043 XtAppContext app = ((InputEvent *)id)->app;
1044 register int source = ((InputEvent *)id)->ie_source;
1045 Boolean found = False0;
1046
1047 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
1048 sptr = app->outstandingQueue;
1049 lptr = NULL((void*)0);
1050 for (; sptr != NULL((void*)0); sptr = sptr->ie_oq) {
1051 if (sptr == (InputEvent *)id) {
1052 if (lptr == NULL((void*)0)) app->outstandingQueue = sptr->ie_oq;
1053 else lptr->ie_oq = sptr->ie_oq;
1054 }
1055 lptr = sptr;
1056 }
1057
1058 if(app->input_list && (sptr = app->input_list[source]) != NULL((void*)0)) {
1059 for( lptr = NULL((void*)0) ; sptr; sptr = sptr->ie_next ){
1060 if(sptr == (InputEvent *) id) {
1061#ifndef USE_POLL1
1062 XtInputMask condition = 0;
1063#endif
1064 if(lptr == NULL((void*)0)) {
1065 app->input_list[source] = sptr->ie_next;
1066 } else {
1067 lptr->ie_next = sptr->ie_next;
1068 }
1069#ifndef USE_POLL1
1070 for (lptr = app->input_list[source];
1071 lptr; lptr = lptr->ie_next)
1072 condition |= lptr->ie_condition;
1073 if ((sptr->ie_condition & XtInputReadMask(1L<<0)) &&
1074 !(condition & XtInputReadMask(1L<<0)))
1075 FD_CLR(source, &app->fds.rmask)((void) (((&app->fds.rmask)->__fds_bits)[((source) /
(8 * (int) sizeof (__fd_mask)))] &= ~((__fd_mask) 1 <<
((source) % (8 * (int) sizeof (__fd_mask))))));
1076 if ((sptr->ie_condition & XtInputWriteMask(1L<<1)) &&
1077 !(condition & XtInputWriteMask(1L<<1)))
1078 FD_CLR(source, &app->fds.wmask)((void) (((&app->fds.wmask)->__fds_bits)[((source) /
(8 * (int) sizeof (__fd_mask)))] &= ~((__fd_mask) 1 <<
((source) % (8 * (int) sizeof (__fd_mask))))));
1079 if ((sptr->ie_condition & XtInputExceptMask(1L<<2)) &&
1080 !(condition & XtInputExceptMask(1L<<2)))
1081 FD_CLR(source, &app->fds.emask)((void) (((&app->fds.emask)->__fds_bits)[((source) /
(8 * (int) sizeof (__fd_mask)))] &= ~((__fd_mask) 1 <<
((source) % (8 * (int) sizeof (__fd_mask))))));
1082#endif
1083 XtFree((char *) sptr);
1084 found = True1;
1085 break;
1086 }
1087 lptr = sptr;
1088 }
1089 }
1090
1091 if (found) {
1092 app->input_count--;
1093#ifdef USE_POLL1
1094 if (app->input_list[source] == NULL((void*)0))
1095 app->fds.nfds--;
1096#endif
1097 app->rebuild_fdlist = TRUE1;
1098 } else
1099 XtAppWarningMsg(app, "invalidProcedure","inputHandler",
1100 XtCXtToolkitError,
1101 "XtRemoveInput: Input handler not found",
1102 (String *)NULL((void*)0), (Cardinal *)NULL((void*)0));
1103 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1104}
1105
1106void _XtRemoveAllInputs(
1107 XtAppContext app)
1108{
1109 int i;
1110 for (i = 0; i < app->input_max; i++) {
1111 InputEvent* ep = app->input_list[i];
1112 while (ep) {
1113 InputEvent *next = ep->ie_next;
1114 XtFree( (char*)ep );
1115 ep = next;
1116 }
1117 }
1118 XtFree((char *) app->input_list);
1119}
1120
1121/* Do alternate input and timer callbacks if there are any */
1122
1123static void DoOtherSources(
1124 XtAppContext app)
1125{
1126 TimerEventRec *te_ptr;
1127 InputEvent *ie_ptr;
1128 struct timeval cur_time;
1129
1130#define DrainQueue() \
1131 for (ie_ptr = app->outstandingQueue; ie_ptr != NULL((void*)0);) { \
1132 app->outstandingQueue = ie_ptr->ie_oq; \
1133 ie_ptr ->ie_oq = NULL((void*)0); \
1134 IeCallProc(ie_ptr)(*ie_ptr->ie_proc) (ie_ptr->ie_closure, &ie_ptr->
ie_source, (XtInputId*)&ie_ptr);; \
1135 ie_ptr = app->outstandingQueue; \
1136 }
1137/*enddef*/
1138 DrainQueue();
1139 if (app->input_count > 0) {
1140 /* Call _XtWaitForSomething to get input queued up */
1141 (void) _XtWaitForSomething (app,
1142 TRUE1, TRUE1, FALSE0, TRUE1,
1143 FALSE0,
1144#ifdef XTHREADS1
1145 TRUE1,
1146#endif
1147 (unsigned long *)NULL((void*)0));
1148 DrainQueue();
1149 }
1150 if (app->timerQueue != NULL((void*)0)) { /* check timeout queue */
1151 X_GETTIMEOFDAY (&cur_time)gettimeofday(&cur_time, (struct timezone*)0);
1152 FIXUP_TIMEVAL(cur_time);
1153 while(IS_AT_OR_AFTER (app->timerQueue->te_timer_value, cur_time)(((cur_time).tv_sec > (app->timerQueue->te_timer_value
).tv_sec) || (((cur_time).tv_sec == (app->timerQueue->te_timer_value
).tv_sec)&& ((cur_time).tv_usec >= (app->timerQueue
->te_timer_value).tv_usec)))) {
1154 te_ptr = app->timerQueue;
1155 app->timerQueue = te_ptr->te_next;
1156 te_ptr->te_next = NULL((void*)0);
1157 if (te_ptr->te_proc != NULL((void*)0))
1158 TeCallProc(te_ptr)(*te_ptr->te_proc) (te_ptr->te_closure, (XtIntervalId*)
&te_ptr);;
1159 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
1160 te_ptr->te_next = freeTimerRecs;
1161 freeTimerRecs = te_ptr;
1162 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
1163 if (app->timerQueue == NULL((void*)0)) break;
1164 }
1165 }
1166 if (app->signalQueue != NULL((void*)0)) {
1167 SignalEventRec *se_ptr = app->signalQueue;
1168 while (se_ptr != NULL((void*)0)) {
1169 if (se_ptr->se_notice) {
1170 se_ptr->se_notice = FALSE0;
1171 if (se_ptr->se_proc != NULL((void*)0))
1172 SeCallProc(se_ptr)(*se_ptr->se_proc) (se_ptr->se_closure, (XtSignalId*)&
se_ptr);;
1173 }
1174 se_ptr = se_ptr->se_next;
1175 }
1176 }
1177#undef DrainQueue
1178}
1179
1180/* If there are any work procs, call them. Return whether we did so */
1181
1182static Boolean CallWorkProc(
1183 XtAppContext app)
1184{
1185 register WorkProcRec *w = app->workQueue;
1186 Boolean delete;
1187
1188 if (w == NULL((void*)0)) return FALSE0;
1189
1190 app->workQueue = w->next;
1191
1192 delete = (*(w->proc)) (w->closure);
1193
1194 if (delete) {
1195 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
1196 w->next = freeWorkRecs;
1197 freeWorkRecs = w;
1198 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
1199 }
1200 else {
1201 w->next = app->workQueue;
1202 app->workQueue = w;
1203 }
1204 return TRUE1;
1205}
1206
1207/*
1208 * XtNextEvent()
1209 * return next event;
1210 */
1211
1212void XtNextEvent(
1213 XEvent *event)
1214{
1215 XtAppNextEvent(_XtDefaultAppContext(), event);
1216}
1217
1218void _XtRefreshMapping(
1219 XEvent* event,
1220 _XtBooleanBoolean dispatch)
1221{
1222 XtPerDisplay pd;
1223
1224 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
1225 pd = _XtGetPerDisplay(event->xmapping.display);
1226 if (event->xmapping.request != MappingPointer2 &&
1227 pd && pd->keysyms && (event->xmapping.serial >= pd->keysyms_serial))
1228 _XtBuildKeysymTables( event->xmapping.display, pd );
1229 XRefreshKeyboardMapping(&event->xmapping);
1230 if (dispatch && pd && pd->mapping_callbacks)
1231 XtCallCallbackList((Widget) NULL((void*)0),
1232 (XtCallbackList)pd->mapping_callbacks,
1233 (XtPointer)event );
1234 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
1235}
1236
1237void XtAppNextEvent(
1238 XtAppContext app,
1239 XEvent *event)
1240{
1241 int i, d;
1242
1243 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
1244 for (;;) {
1245 if (app->count == 0)
1246 DoOtherSources(app);
1247 else {
1248 for (i = 1; i <= app->count; i++) {
1249 d = (i + app->last) % app->count;
1250 if (d == 0) DoOtherSources(app);
1251 if (XEventsQueued(app->list[d], QueuedAfterReading1))
1252 goto GotEvent;
1253 }
1254 for (i = 1; i <= app->count; i++) {
1255 d = (i + app->last) % app->count;
1256 if (XEventsQueued(app->list[d], QueuedAfterFlush2))
1257 goto GotEvent;
1258 }
1259 }
1260
1261 /* We're ready to wait...if there is a work proc, call it */
1262 if (CallWorkProc(app)) continue;
1263
1264 d = _XtWaitForSomething (app,
1265 FALSE0, FALSE0, FALSE0, FALSE0,
1266 TRUE1,
1267#ifdef XTHREADS1
1268 TRUE1,
1269#endif
1270 (unsigned long *) NULL((void*)0));
1271
1272 if (d != -1) {
1273 GotEvent:
1274 XNextEvent (app->list[d], event);
1275#ifdef XTHREADS1
1276 /* assert(app->list[d] == event->xany.display); */
1277#endif
1278 app->last = d;
1279 if (event->xany.type == MappingNotify34)
1280 _XtRefreshMapping(event, False0);
1281 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1282 return;
1283 }
1284
1285 } /* for */
1286}
1287
1288void XtProcessEvent(
1289 XtInputMask mask)
1290{
1291 XtAppProcessEvent(_XtDefaultAppContext(), mask);
1292}
1293
1294void XtAppProcessEvent(
1295 XtAppContext app,
1296 XtInputMask mask)
1297{
1298 int i, d;
1299 XEvent event;
1300 struct timeval cur_time;
1301
1302 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
1303 if (mask == 0) {
1304 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1305 return;
1306 }
1307
1308 for (;;) {
1309
1310 if (mask & XtIMSignal8 && app->signalQueue != NULL((void*)0)) {
1311 SignalEventRec *se_ptr = app->signalQueue;
1312 while (se_ptr != NULL((void*)0)) {
1313 if (se_ptr->se_notice) {
1314 se_ptr->se_notice = FALSE0;
1315 SeCallProc(se_ptr)(*se_ptr->se_proc) (se_ptr->se_closure, (XtSignalId*)&
se_ptr);;
1316 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1317 return;
1318 }
1319 se_ptr = se_ptr->se_next;
1320 }
1321 }
1322
1323 if (mask & XtIMTimer2 && app->timerQueue != NULL((void*)0)) {
1324 X_GETTIMEOFDAY (&cur_time)gettimeofday(&cur_time, (struct timezone*)0);
1325 FIXUP_TIMEVAL(cur_time);
1326 if (IS_AT_OR_AFTER(app->timerQueue->te_timer_value, cur_time)(((cur_time).tv_sec > (app->timerQueue->te_timer_value
).tv_sec) || (((cur_time).tv_sec == (app->timerQueue->te_timer_value
).tv_sec)&& ((cur_time).tv_usec >= (app->timerQueue
->te_timer_value).tv_usec)))){
1327 TimerEventRec *te_ptr = app->timerQueue;
1328 app->timerQueue = app->timerQueue->te_next;
1329 te_ptr->te_next = NULL((void*)0);
1330 if (te_ptr->te_proc != NULL((void*)0))
1331 TeCallProc(te_ptr)(*te_ptr->te_proc) (te_ptr->te_closure, (XtIntervalId*)
&te_ptr);;
1332 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
1333 te_ptr->te_next = freeTimerRecs;
1334 freeTimerRecs = te_ptr;
1335 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
1336 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1337 return;
1338 }
1339 }
1340
1341 if (mask & XtIMAlternateInput4) {
1342 if (app->input_count > 0 && app->outstandingQueue == NULL((void*)0)) {
1343 /* Call _XtWaitForSomething to get input queued up */
1344 (void) _XtWaitForSomething (app,
1345 TRUE1, TRUE1, FALSE0, TRUE1,
1346 FALSE0,
1347#ifdef XTHREADS1
1348 TRUE1,
1349#endif
1350 (unsigned long *)NULL((void*)0));
1351 }
1352 if (app->outstandingQueue != NULL((void*)0)) {
1353 InputEvent *ie_ptr = app->outstandingQueue;
1354 app->outstandingQueue = ie_ptr->ie_oq;
1355 ie_ptr->ie_oq = NULL((void*)0);
1356 IeCallProc(ie_ptr)(*ie_ptr->ie_proc) (ie_ptr->ie_closure, &ie_ptr->
ie_source, (XtInputId*)&ie_ptr);;
1357 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1358 return;
1359 }
1360 }
1361
1362 if (mask & XtIMXEvent1) {
1363 for (i = 1; i <= app->count; i++) {
1364 d = (i + app->last) % app->count;
1365 if (XEventsQueued(app->list[d], QueuedAfterReading1))
1366 goto GotEvent;
1367 }
1368 for (i = 1; i <= app->count; i++) {
1369 d = (i + app->last) % app->count;
1370 if (XEventsQueued(app->list[d], QueuedAfterFlush2))
1371 goto GotEvent;
1372 }
1373 }
1374
1375 /* Nothing to do...wait for something */
1376
1377 if (CallWorkProc(app)) continue;
1378
1379 d = _XtWaitForSomething (app,
1380 (mask & XtIMXEvent1 ? FALSE0 : TRUE1),
1381 (mask & XtIMTimer2 ? FALSE0 : TRUE1),
1382 (mask & XtIMAlternateInput4 ? FALSE0 : TRUE1),
1383 (mask & XtIMSignal8 ? FALSE0 : TRUE1),
1384 TRUE1,
1385#ifdef XTHREADS1
1386 TRUE1,
1387#endif
1388 (unsigned long *) NULL((void*)0));
1389
1390 if (mask & XtIMXEvent1 && d != -1) {
1391 GotEvent:
1392 XNextEvent(app->list[d], &event);
1393#ifdef XTHREADS1
1394 /* assert(app->list[d] == event.xany.display); */
1395#endif
1396 app->last = d;
1397 if (event.xany.type == MappingNotify34) {
1398 _XtRefreshMapping(&event, False0);
1399 }
1400 XtDispatchEvent(&event);
1401 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1402 return;
1403 }
1404
1405 }
1406}
1407
1408Boolean XtPending(void)
1409{
1410 return (XtAppPending(_XtDefaultAppContext()) != 0);
1411}
1412
1413XtInputMask XtAppPending(
1414 XtAppContext app)
1415{
1416 struct timeval cur_time;
1417 int d;
1418 XtInputMask ret = 0;
1419
1420/*
1421 * Check for pending X events
1422 */
1423 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
1424 for (d = 0; d < app->count; d++) {
1425 if (XEventsQueued(app->list[d], QueuedAfterReading1)) {
1426 ret = XtIMXEvent1;
1427 break;
1428 }
1429 }
1430 if (ret == 0) {
1431 for (d = 0; d < app->count; d++) {
1432 if (XEventsQueued(app->list[d], QueuedAfterFlush2)) {
1433 ret = XtIMXEvent1;
1434 break;
1435 }
1436 }
1437 }
1438
1439 if (app->signalQueue != NULL((void*)0)) {
1440 SignalEventRec *se_ptr = app->signalQueue;
1441 while (se_ptr != NULL((void*)0)) {
1442 if (se_ptr->se_notice) {
1443 ret |= XtIMSignal8;
1444 break;
1445 }
1446 se_ptr = se_ptr->se_next;
1447 }
1448 }
1449
1450/*
1451 * Check for pending alternate input
1452 */
1453 if (app->timerQueue != NULL((void*)0)) { /* check timeout queue */
1454 X_GETTIMEOFDAY (&cur_time)gettimeofday(&cur_time, (struct timezone*)0);
1455 FIXUP_TIMEVAL(cur_time);
1456 if ((IS_AT_OR_AFTER(app->timerQueue->te_timer_value, cur_time)(((cur_time).tv_sec > (app->timerQueue->te_timer_value
).tv_sec) || (((cur_time).tv_sec == (app->timerQueue->te_timer_value
).tv_sec)&& ((cur_time).tv_usec >= (app->timerQueue
->te_timer_value).tv_usec)))) &&
1457 (app->timerQueue->te_proc != NULL((void*)0))) {
1458 ret |= XtIMTimer2;
1459 }
1460 }
1461
1462 if (app->outstandingQueue != NULL((void*)0)) ret |= XtIMAlternateInput4;
1463 else {
1464 /* This won't cause a wait, but will enqueue any input */
1465
1466 if(_XtWaitForSomething (app,
1467 FALSE0, TRUE1, FALSE0, TRUE1,
1468 FALSE0,
1469#ifdef XTHREADS1
1470 TRUE1,
1471#endif
1472 (unsigned long *) NULL((void*)0)) != -1)
1473 ret |= XtIMXEvent1;
1474 if (app->outstandingQueue != NULL((void*)0)) ret |= XtIMAlternateInput4;
1475 }
1476 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1477 return ret;
1478}
1479
1480/* Peek at alternate input and timer callbacks if there are any */
1481
1482static Boolean PeekOtherSources(
1483 XtAppContext app)
1484{
1485 struct timeval cur_time;
1486
1487 if (app->outstandingQueue != NULL((void*)0)) return TRUE1;
1488
1489 if (app->signalQueue != NULL((void*)0)) {
1490 SignalEventRec *se_ptr = app->signalQueue;
1491 while (se_ptr != NULL((void*)0)) {
1492 if (se_ptr->se_notice)
1493 return TRUE1;
1494 se_ptr = se_ptr->se_next;
1495 }
1496 }
1497
1498 if (app->input_count > 0) {
1499 /* Call _XtWaitForSomething to get input queued up */
1500 (void) _XtWaitForSomething (app,
1501 TRUE1, TRUE1, FALSE0, TRUE1,
1502 FALSE0,
1503#ifdef XTHREADS1
1504 TRUE1,
1505#endif
1506 (unsigned long *)NULL((void*)0));
1507 if (app->outstandingQueue != NULL((void*)0)) return TRUE1;
1508 }
1509
1510 if (app->timerQueue != NULL((void*)0)) { /* check timeout queue */
1511 X_GETTIMEOFDAY (&cur_time)gettimeofday(&cur_time, (struct timezone*)0);
1512 FIXUP_TIMEVAL(cur_time);
1513 if (IS_AT_OR_AFTER (app->timerQueue->te_timer_value, cur_time)(((cur_time).tv_sec > (app->timerQueue->te_timer_value
).tv_sec) || (((cur_time).tv_sec == (app->timerQueue->te_timer_value
).tv_sec)&& ((cur_time).tv_usec >= (app->timerQueue
->te_timer_value).tv_usec))))
1514 return TRUE1;
1515 }
1516
1517 return FALSE0;
1518}
1519
1520Boolean XtPeekEvent(
1521 XEvent *event)
1522{
1523 return XtAppPeekEvent(_XtDefaultAppContext(), event);
1524}
1525
1526Boolean XtAppPeekEvent_SkipTimer;
1527
1528Boolean XtAppPeekEvent(
1529 XtAppContext app,
1530 XEvent *event)
1531{
1532 int i, d;
1533 Boolean foundCall = FALSE0;
1534
1535 LOCK_APP(app)if(app && app->lock)(*app->lock)(app);
1536 for (i = 1; i <= app->count; i++) {
1537 d = (i + app->last) % app->count;
1538 if (d == 0) foundCall = PeekOtherSources(app);
1539 if (XEventsQueued(app->list[d], QueuedAfterReading1))
1540 goto GotEvent;
1541 }
1542 for (i = 1; i <= app->count; i++) {
1543 d = (i + app->last) % app->count;
1544 if (XEventsQueued(app->list[d], QueuedAfterFlush2))
1545 goto GotEvent;
1546 }
1547
1548 if (foundCall) {
1549 event->xany.type = 0;
1550 event->xany.display = NULL((void*)0);
1551 event->xany.window = 0;
1552 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1553 return FALSE0;
1554 }
1555
1556 while (1) {
1557 d = _XtWaitForSomething (app,
1558 FALSE0, FALSE0, FALSE0, FALSE0,
1559 TRUE1,
1560#ifdef XTHREADS1
1561 TRUE1,
1562#endif
1563 (unsigned long *) NULL((void*)0));
1564
1565 if (d != -1) { /* event */
1566 GotEvent:
1567 XPeekEvent(app->list[d], event);
1568 app->last = (d == 0 ? app->count : d) - 1;
1569 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1570 return TRUE1;
1571 }
1572 else { /* input or timer or signal */
1573 /*
1574 * Check to see why a -1 was returned, if a timer expired,
1575 * call it and block some more
1576 */
1577 if ((app->timerQueue != NULL((void*)0)) && ! XtAppPeekEvent_SkipTimer) { /* timer */
1578 struct timeval cur_time;
1579 Boolint did_timer = False0;
1580
1581 X_GETTIMEOFDAY (&cur_time)gettimeofday(&cur_time, (struct timezone*)0);
1582 FIXUP_TIMEVAL(cur_time);
1583 while (IS_AT_OR_AFTER(app->timerQueue->te_timer_value, cur_time)(((cur_time).tv_sec > (app->timerQueue->te_timer_value
).tv_sec) || (((cur_time).tv_sec == (app->timerQueue->te_timer_value
).tv_sec)&& ((cur_time).tv_usec >= (app->timerQueue
->te_timer_value).tv_usec)))) {
1584 TimerEventRec *te_ptr = app->timerQueue;
1585 app->timerQueue = app->timerQueue->te_next;
1586 te_ptr->te_next = NULL((void*)0);
1587 if (te_ptr->te_proc != NULL((void*)0)) {
1588 TeCallProc(te_ptr)(*te_ptr->te_proc) (te_ptr->te_closure, (XtIntervalId*)
&te_ptr);;
1589 did_timer = True1;
1590 }
1591 LOCK_PROCESSif(_XtProcessLock)(*_XtProcessLock)();
1592 te_ptr->te_next = freeTimerRecs;
1593 freeTimerRecs = te_ptr;
1594 UNLOCK_PROCESSif(_XtProcessUnlock)(*_XtProcessUnlock)();
1595 if (app->timerQueue == NULL((void*)0)) break;
1596 }
1597 if (did_timer)
1598 {
1599 for (d = 0; d < app->count; d++)
1600 /* the timer's procedure may have caused an event */
1601 if (XEventsQueued(app->list[d], QueuedAfterFlush2)) {
1602 goto GotEvent;
1603 }
1604 continue; /* keep blocking */
1605 }
1606 }
1607 /*
1608 * spec is vague here; we'll assume signals also return FALSE,
1609 * of course to determine whether a signal is pending requires
1610 * walking the signalQueue looking for se_notice flags which
1611 * this code doesn't do.
1612 */
1613#if 0
1614 if (app->signalQueue != NULL((void*)0)) { /* signal */
1615 event->xany.type = 0;
1616 event->xany.display = NULL((void*)0);
1617 event->xany.window = 0;
1618 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1619 return FALSE0;
1620 }
1621 else
1622#endif
1623 { /* input */
1624 event->xany.type = 0;
1625 event->xany.display = NULL((void*)0);
1626 event->xany.window = 0;
1627 UNLOCK_APP(app)if(app && app->unlock)(*app->unlock)(app);
1628 return FALSE0;
1629 }
1630 }
1631 } /* end while */
1632}