timer-posix.cpp@ 82968

Last change on this file since 82968 was 82968, checked in by vboxsync, 5 years ago
Copyright year updates by scm.
Property svn:eol-style set to `native` Property svn:keywords set to `Id Revision`
File size: 27.2 KB

Line
1	/* $Id: timer-posix.cpp 82968 2020-02-04 10:35:17Z vboxsync $ */
2	/** @file
3	* IPRT - Timer, POSIX.
4	*/
5
6	/*
7	* Copyright (C) 2006-2020 Oracle Corporation
8	*
9	* This file is part of VirtualBox Open Source Edition (OSE), as
10	* available from http://www.virtualbox.org. This file is free software;
11	* you can redistribute it and/or modify it under the terms of the GNU
12	* General Public License (GPL) as published by the Free Software
13	* Foundation, in version 2 as it comes in the "COPYING" file of the
14	* VirtualBox OSE distribution. VirtualBox OSE is distributed in the
15	* hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
16	*
17	* The contents of this file may alternatively be used under the terms
18	* of the Common Development and Distribution License Version 1.0
19	* (CDDL) only, as it comes in the "COPYING.CDDL" file of the
20	* VirtualBox OSE distribution, in which case the provisions of the
21	* CDDL are applicable instead of those of the GPL.
22	*
23	* You may elect to license modified versions of this file under the
24	* terms and conditions of either the GPL or the CDDL or both.
25	*/
26
27
28	/*********************************************************************************************************************************
29	* Defined Constants And Macros *
30	*********************************************************************************************************************************/
31	/** Enables the use of POSIX RT timers. */
32	#ifndef RT_OS_SOLARIS /* Solaris 10 doesn't have SIGEV_THREAD */
33	# define IPRT_WITH_POSIX_TIMERS
34	#endif /* !RT_OS_SOLARIS */
35
36	/** @def RT_TIMER_SIGNAL
37	* The signal number that the timers use.
38	* We currently use SIGALRM for both setitimer and posix real time timers
39	* out of simplicity, but we might want change this later for the posix ones. */
40	#ifdef IPRT_WITH_POSIX_TIMERS
41	# define RT_TIMER_SIGNAL SIGALRM
42	#else
43	# define RT_TIMER_SIGNAL SIGALRM
44	#endif
45
46
47	/*********************************************************************************************************************************
48	* Header Files *
49	*********************************************************************************************************************************/
50	#define LOG_GROUP RTLOGGROUP_TIMER
51	#include <iprt/timer.h>
52	#include <iprt/alloc.h>
53	#include <iprt/assert.h>
54	#include <iprt/thread.h>
55	#include <iprt/log.h>
56	#include <iprt/asm.h>
57	#include <iprt/semaphore.h>
58	#include <iprt/string.h>
59	#include <iprt/once.h>
60	#include <iprt/err.h>
61	#include <iprt/initterm.h>
62	#include <iprt/critsect.h>
63	#include "internal/magics.h"
64
65	#include <unistd.h>
66	#include <sys/fcntl.h>
67	#include <sys/ioctl.h>
68	#ifdef RT_OS_LINUX
69	# include <linux/rtc.h>
70	#endif
71	#include <sys/time.h>
72	#include <signal.h>
73	#include <errno.h>
74	#include <pthread.h>
75
76
77	/*********************************************************************************************************************************
78	* Global Variables *
79	*********************************************************************************************************************************/
80	#ifdef IPRT_WITH_POSIX_TIMERS
81	/** Init the critsect on first call. */
82	static RTONCE g_TimerOnce = RTONCE_INITIALIZER;
83	/** Global critsect that serializes timer creation and destruction.
84	* This is lazily created on the first RTTimerCreateEx call and will not be
85	* freed up (I'm afraid). */
86	static RTCRITSECT g_TimerCritSect;
87	/**
88	* Global counter of RTTimer instances. The signal thread is
89	* started when it changes from 0 to 1. The signal thread
90	* terminates when it becomes 0 again.
91	*/
92	static uint32_t volatile g_cTimerInstances;
93	/** The signal handling thread. */
94	static RTTHREAD g_TimerThread;
95	#endif /* IPRT_WITH_POSIX_TIMERS */
96
97
98	/*********************************************************************************************************************************
99	* Structures and Typedefs *
100	*********************************************************************************************************************************/
101	/**
102	* The internal representation of a timer handle.
103	*/
104	typedef struct RTTIMER
105	{
106	/** Magic.
107	* This is RTTIMER_MAGIC, but changes to something else before the timer
108	* is destroyed to indicate clearly that thread should exit. */
109	uint32_t volatile u32Magic;
110	/** Flag indicating the timer is suspended. */
111	uint8_t volatile fSuspended;
112	/** Flag indicating that the timer has been destroyed. */
113	uint8_t volatile fDestroyed;
114	#ifndef IPRT_WITH_POSIX_TIMERS /** @todo We have to take the signals on a dedicated timer thread as
115	* we (might) have code assuming that signals doesn't screw around
116	* on existing threads. (It would be sufficient to have one thread
117	* per signal of course since the signal will be masked while it's
118	* running, however, it may just cause more complications than its
119	* worth - sigwait/sigwaitinfo work atomically anyway...)
120	* Also, must block the signal in the thread main procedure too. */
121	/** The timer thread. */
122	RTTHREAD Thread;
123	/** Event semaphore on which the thread is blocked. */
124	RTSEMEVENT Event;
125	#endif /* !IPRT_WITH_POSIX_TIMERS */
126	/** User argument. */
127	void *pvUser;
128	/** Callback. */
129	PFNRTTIMER pfnTimer;
130	/** The timer interval. 0 if one-shot. */
131	uint64_t u64NanoInterval;
132	#ifndef IPRT_WITH_POSIX_TIMERS
133	/** The first shot interval. 0 if ASAP. */
134	uint64_t volatile u64NanoFirst;
135	#endif /* !IPRT_WITH_POSIX_TIMERS */
136	/** The current timer tick. */
137	uint64_t volatile iTick;
138	#ifndef IPRT_WITH_POSIX_TIMERS
139	/** The error/status of the timer.
140	* Initially -1, set to 0 when the timer have been successfully started, and
141	* to errno on failure in starting the timer. */
142	int volatile iError;
143	#else /* IPRT_WITH_POSIX_TIMERS */
144	timer_t NativeTimer;
145	#endif /* IPRT_WITH_POSIX_TIMERS */
146
147	} RTTIMER;
148
149
150
151	#ifdef IPRT_WITH_POSIX_TIMERS
152
153	/**
154	* RTOnce callback that initializes the critical section.
155	*
156	* @returns RTCritSectInit return code.
157	* @param pvUser NULL, ignored.
158	*
159	*/
160	static DECLCALLBACK(int) rtTimerOnce(void *pvUser)
161	{
162	NOREF(pvUser);
163	return RTCritSectInit(&g_TimerCritSect);
164	}
165	#endif
166
167
168	/**
169	* Signal handler which ignore everything it gets.
170	*
171	* @param iSignal The signal number.
172	*/
173	static void rttimerSignalIgnore(int iSignal)
174	{
175	//AssertBreakpoint();
176	NOREF(iSignal);
177	}
178
179
180	/**
181	* RT_TIMER_SIGNAL wait thread.
182	*/
183	static DECLCALLBACK(int) rttimerThread(RTTHREAD hThreadSelf, void *pvArg)
184	{
185	NOREF(hThreadSelf); NOREF(pvArg);
186	#ifndef IPRT_WITH_POSIX_TIMERS
187	PRTTIMER pTimer = (PRTTIMER)pvArg;
188	RTTIMER Timer = *pTimer;
189	Assert(pTimer->u32Magic == RTTIMER_MAGIC);
190	#endif /* !IPRT_WITH_POSIX_TIMERS */
191
192	/*
193	* Install signal handler.
194	*/
195	struct sigaction SigAct;
196	memset(&SigAct, 0, sizeof(SigAct));
197	SigAct.sa_flags = SA_RESTART;
198	sigemptyset(&SigAct.sa_mask);
199	SigAct.sa_handler = rttimerSignalIgnore;
200	if (sigaction(RT_TIMER_SIGNAL, &SigAct, NULL))
201	{
202	SigAct.sa_flags &= ~SA_RESTART;
203	if (sigaction(RT_TIMER_SIGNAL, &SigAct, NULL))
204	AssertMsgFailed(("sigaction failed, errno=%d\n", errno));
205	}
206
207	/*
208	* Mask most signals except those which might be used by the pthread implementation (linux).
209	*/
210	sigset_t SigSet;
211	sigfillset(&SigSet);
212	sigdelset(&SigSet, SIGTERM);
213	sigdelset(&SigSet, SIGHUP);
214	sigdelset(&SigSet, SIGINT);
215	sigdelset(&SigSet, SIGABRT);
216	sigdelset(&SigSet, SIGKILL);
217	#ifdef SIGRTMIN
218	for (int iSig = SIGRTMIN; iSig < SIGRTMAX; iSig++)
219	sigdelset(&SigSet, iSig);
220	#endif
221	if (sigprocmask(SIG_SETMASK, &SigSet, NULL))
222	{
223	#ifdef IPRT_WITH_POSIX_TIMERS
224	int rc = RTErrConvertFromErrno(errno);
225	#else
226	int rc = pTimer->iError = RTErrConvertFromErrno(errno);
227	#endif
228	AssertMsgFailed(("sigprocmask -> errno=%d\n", errno));
229	return rc;
230	}
231
232	/*
233	* The work loop.
234	*/
235	RTThreadUserSignal(hThreadSelf);
236
237	#ifndef IPRT_WITH_POSIX_TIMERS
238	while ( !pTimer->fDestroyed
239	&& pTimer->u32Magic == RTTIMER_MAGIC)
240	{
241	/*
242	* Wait for a start or destroy event.
243	*/
244	if (pTimer->fSuspended)
245	{
246	int rc = RTSemEventWait(pTimer->Event, RT_INDEFINITE_WAIT);
247	if (RT_FAILURE(rc) && rc != VERR_INTERRUPTED)
248	{
249	AssertRC(rc);
250	if (pTimer->fDestroyed)
251	continue;
252	RTThreadSleep(1000); /* Don't cause trouble! */
253	}
254	if ( pTimer->fSuspended
255	\|\| pTimer->fDestroyed)
256	continue;
257	}
258
259	/*
260	* Start the timer.
261	*
262	* For some SunOS (/SysV?) threading compatibility Linux will only
263	* deliver the RT_TIMER_SIGNAL to the thread calling setitimer(). Therefore
264	* we have to call it here.
265	*
266	* It turns out this might not always be the case, see RT_TIMER_SIGNAL killing
267	* processes on RH 2.4.21.
268	*/
269	struct itimerval TimerVal;
270	if (pTimer->u64NanoFirst)
271	{
272	uint64_t u64 = RT_MAX(1000, pTimer->u64NanoFirst);
273	TimerVal.it_value.tv_sec = u64 / 1000000000;
274	TimerVal.it_value.tv_usec = (u64 % 1000000000) / 1000;
275	}
276	else
277	{
278	TimerVal.it_value.tv_sec = 0;
279	TimerVal.it_value.tv_usec = 10;
280	}
281	if (pTimer->u64NanoInterval)
282	{
283	uint64_t u64 = RT_MAX(1000, pTimer->u64NanoInterval);
284	TimerVal.it_interval.tv_sec = u64 / 1000000000;
285	TimerVal.it_interval.tv_usec = (u64 % 1000000000) / 1000;
286	}
287	else
288	{
289	TimerVal.it_interval.tv_sec = 0;
290	TimerVal.it_interval.tv_usec = 0;
291	}
292
293	if (setitimer(ITIMER_REAL, &TimerVal, NULL))
294	{
295	ASMAtomicXchgU8(&pTimer->fSuspended, true);
296	pTimer->iError = RTErrConvertFromErrno(errno);
297	RTThreadUserSignal(hThreadSelf);
298	continue; /* back to suspended mode. */
299	}
300	pTimer->iError = 0;
301	RTThreadUserSignal(hThreadSelf);
302
303	/*
304	* Timer Service Loop.
305	*/
306	sigemptyset(&SigSet);
307	sigaddset(&SigSet, RT_TIMER_SIGNAL);
308	do
309	{
310	siginfo_t SigInfo;
311	RT_ZERO(SigInfo);
312	#ifdef RT_OS_DARWIN
313	if (RT_LIKELY(sigwait(&SigSet, &SigInfo.si_signo) >= 0))
314	{
315	#else
316	if (RT_LIKELY(sigwaitinfo(&SigSet, &SigInfo) >= 0))
317	{
318	if (RT_LIKELY(SigInfo.si_signo == RT_TIMER_SIGNAL))
319	#endif
320	{
321	if (RT_UNLIKELY( pTimer->fSuspended
322	\|\| pTimer->fDestroyed
323	\|\| pTimer->u32Magic != RTTIMER_MAGIC))
324	break;
325
326	pTimer->pfnTimer(pTimer, pTimer->pvUser, ++pTimer->iTick);
327
328	/* auto suspend one-shot timers. */
329	if (RT_UNLIKELY(!pTimer->u64NanoInterval))
330	{
331	ASMAtomicWriteU8(&pTimer->fSuspended, true);
332	break;
333	}
334	}
335	}
336	else if (errno != EINTR)
337	AssertMsgFailed(("sigwaitinfo -> errno=%d\n", errno));
338	} while (RT_LIKELY( !pTimer->fSuspended
339	&& !pTimer->fDestroyed
340	&& pTimer->u32Magic == RTTIMER_MAGIC));
341
342	/*
343	* Disable the timer.
344	*/
345	struct itimerval TimerVal2 = {{0,0}, {0,0}};
346	if (setitimer(ITIMER_REAL, &TimerVal2, NULL))
347	AssertMsgFailed(("setitimer(ITIMER_REAL,&{0}, NULL) failed, errno=%d\n", errno));
348
349	/*
350	* ACK any pending suspend request.
351	*/
352	if (!pTimer->fDestroyed)
353	{
354	pTimer->iError = 0;
355	RTThreadUserSignal(hThreadSelf);
356	}
357	}
358
359	/*
360	* Exit.
361	*/
362	pTimer->iError = 0;
363	RTThreadUserSignal(hThreadSelf);
364
365	#else /* IPRT_WITH_POSIX_TIMERS */
366
367	sigemptyset(&SigSet);
368	sigaddset(&SigSet, RT_TIMER_SIGNAL);
369	while (g_cTimerInstances)
370	{
371	siginfo_t SigInfo;
372	RT_ZERO(SigInfo);
373	if (RT_LIKELY(sigwaitinfo(&SigSet, &SigInfo) >= 0))
374	{
375	LogFlow(("rttimerThread: signo=%d pTimer=%p\n", SigInfo.si_signo, SigInfo.si_value.sival_ptr));
376	if (RT_LIKELY( SigInfo.si_signo == RT_TIMER_SIGNAL
377	&& SigInfo.si_code == SI_TIMER)) /* The SI_TIMER check is essential because of the pthread_kill. */
378	{
379	PRTTIMER pTimer = (PRTTIMER)SigInfo.si_value.sival_ptr;
380	AssertPtr(pTimer);
381	if (RT_UNLIKELY( !VALID_PTR(pTimer)
382	\|\| ASMAtomicUoReadU8(&pTimer->fSuspended)
383	\|\| ASMAtomicUoReadU8(&pTimer->fDestroyed)
384	\|\| pTimer->u32Magic != RTTIMER_MAGIC))
385	continue;
386
387	pTimer->pfnTimer(pTimer, pTimer->pvUser, ++pTimer->iTick);
388
389	/* auto suspend one-shot timers. */
390	if (RT_UNLIKELY(!pTimer->u64NanoInterval))
391	ASMAtomicWriteU8(&pTimer->fSuspended, true);
392	}
393	}
394	}
395	#endif /* IPRT_WITH_POSIX_TIMERS */
396
397	return VINF_SUCCESS;
398	}
399
400
401	RTDECL(int) RTTimerCreateEx(PRTTIMER ppTimer, uint64_t u64NanoInterval, uint32_t fFlags, PFNRTTIMER pfnTimer, void pvUser)
402	{
403	/*
404	* We don't support the fancy MP features.
405	*/
406	if (fFlags & RTTIMER_FLAGS_CPU_SPECIFIC)
407	return VERR_NOT_SUPPORTED;
408
409	/*
410	* We need the signal masks to be set correctly, which they won't be in
411	* unobtrusive mode.
412	*/
413	if (RTR3InitIsUnobtrusive())
414	return VERR_NOT_SUPPORTED;
415
416	#ifndef IPRT_WITH_POSIX_TIMERS
417	/*
418	* Check if timer is busy.
419	*/
420	struct itimerval TimerVal;
421	if (getitimer(ITIMER_REAL, &TimerVal))
422	{
423	AssertMsgFailed(("getitimer() -> errno=%d\n", errno));
424	return VERR_NOT_IMPLEMENTED;
425	}
426	if ( TimerVal.it_value.tv_usec
427	\|\| TimerVal.it_value.tv_sec
428	\|\| TimerVal.it_interval.tv_usec
429	\|\| TimerVal.it_interval.tv_sec)
430	{
431	AssertMsgFailed(("A timer is running. System limit is one timer per process!\n"));
432	return VERR_TIMER_BUSY;
433	}
434	#endif /* !IPRT_WITH_POSIX_TIMERS */
435
436	/*
437	* Block RT_TIMER_SIGNAL from calling thread.
438	*/
439	sigset_t SigSet;
440	sigemptyset(&SigSet);
441	sigaddset(&SigSet, RT_TIMER_SIGNAL);
442	sigprocmask(SIG_BLOCK, &SigSet, NULL);
443
444	#ifndef IPRT_WITH_POSIX_TIMERS /** @todo combine more of the setitimer/timer_create code. setitimer could also use the global thread. */
445	/** @todo Move this RTC hack else where... */
446	static bool fDoneRTC;
447	if (!fDoneRTC)
448	{
449	fDoneRTC = true;
450	/* check resolution. */
451	TimerVal.it_interval.tv_sec = 0;
452	TimerVal.it_interval.tv_usec = 1000;
453	TimerVal.it_value = TimerVal.it_interval;
454	if ( setitimer(ITIMER_REAL, &TimerVal, NULL)
455	\|\| getitimer(ITIMER_REAL, &TimerVal)
456	\|\| TimerVal.it_interval.tv_usec > 1000)
457	{
458	/*
459	* Try open /dev/rtc to set the irq rate to 1024 and
460	* turn periodic
461	*/
462	Log(("RTTimerCreate: interval={%ld,%ld} trying to adjust /dev/rtc!\n", TimerVal.it_interval.tv_sec, TimerVal.it_interval.tv_usec));
463	# ifdef RT_OS_LINUX
464	int fh = open("/dev/rtc", O_RDONLY);
465	if (fh >= 0)
466	{
467	if ( ioctl(fh, RTC_IRQP_SET, 1024) < 0
468	\|\| ioctl(fh, RTC_PIE_ON, 0) < 0)
469	Log(("RTTimerCreate: couldn't configure rtc! errno=%d\n", errno));
470	ioctl(fh, F_SETFL, O_ASYNC);
471	ioctl(fh, F_SETOWN, getpid());
472	/* not so sure if closing it is a good idea... */
473	//close(fh);
474	}
475	else
476	Log(("RTTimerCreate: couldn't configure rtc! open failed with errno=%d\n", errno));
477	# endif
478	}
479	/* disable it */
480	TimerVal.it_interval.tv_sec = 0;
481	TimerVal.it_interval.tv_usec = 0;
482	TimerVal.it_value = TimerVal.it_interval;
483	setitimer(ITIMER_REAL, &TimerVal, NULL);
484	}
485
486	/*
487	* Create a new timer.
488	*/
489	int rc;
490	PRTTIMER pTimer = (PRTTIMER)RTMemAlloc(sizeof(*pTimer));
491	if (pTimer)
492	{
493	pTimer->u32Magic = RTTIMER_MAGIC;
494	pTimer->fSuspended = true;
495	pTimer->fDestroyed = false;
496	pTimer->Thread = NIL_RTTHREAD;
497	pTimer->Event = NIL_RTSEMEVENT;
498	pTimer->pfnTimer = pfnTimer;
499	pTimer->pvUser = pvUser;
500	pTimer->u64NanoInterval = u64NanoInterval;
501	pTimer->u64NanoFirst = 0;
502	pTimer->iTick = 0;
503	pTimer->iError = 0;
504	rc = RTSemEventCreate(&pTimer->Event);
505	AssertRC(rc);
506	if (RT_SUCCESS(rc))
507	{
508	rc = RTThreadCreate(&pTimer->Thread, rttimerThread, pTimer, 0, RTTHREADTYPE_TIMER, RTTHREADFLAGS_WAITABLE, "Timer");
509	AssertRC(rc);
510	if (RT_SUCCESS(rc))
511	{
512	/*
513	* Wait for the timer thread to initialize it self.
514	* This might take a little while...
515	*/
516	rc = RTThreadUserWait(pTimer->Thread, 45*1000);
517	AssertRC(rc);
518	if (RT_SUCCESS(rc))
519	{
520	rc = RTThreadUserReset(pTimer->Thread); AssertRC(rc);
521	rc = pTimer->iError;
522	AssertRC(rc);
523	if (RT_SUCCESS(rc))
524	{
525	RTThreadYield(); /* <-- Horrible hack to make tstTimer work. (linux 2.6.12) */
526	*ppTimer = pTimer;
527	return VINF_SUCCESS;
528	}
529	}
530
531	/* bail out */
532	ASMAtomicXchgU8(&pTimer->fDestroyed, true);
533	ASMAtomicXchgU32(&pTimer->u32Magic, ~RTTIMER_MAGIC);
534	RTThreadWait(pTimer->Thread, 45*1000, NULL);
535	}
536	RTSemEventDestroy(pTimer->Event);
537	pTimer->Event = NIL_RTSEMEVENT;
538	}
539	RTMemFree(pTimer);
540	}
541	else
542	rc = VERR_NO_MEMORY;
543
544	#else /* IPRT_WITH_POSIX_TIMERS */
545
546	/*
547	* Do the global init first.
548	*/
549	int rc = RTOnce(&g_TimerOnce, rtTimerOnce, NULL);
550	if (RT_FAILURE(rc))
551	return rc;
552
553	/*
554	* Create a new timer structure.
555	*/
556	LogFlow(("RTTimerCreateEx: u64NanoInterval=%llu fFlags=%lu\n", u64NanoInterval, fFlags));
557	PRTTIMER pTimer = (PRTTIMER)RTMemAlloc(sizeof(*pTimer));
558	if (pTimer)
559	{
560	/* Initialize timer structure. */
561	pTimer->u32Magic = RTTIMER_MAGIC;
562	pTimer->fSuspended = true;
563	pTimer->fDestroyed = false;
564	pTimer->pfnTimer = pfnTimer;
565	pTimer->pvUser = pvUser;
566	pTimer->u64NanoInterval = u64NanoInterval;
567	pTimer->iTick = 0;
568
569	/*
570	* Create a timer that deliver RT_TIMER_SIGNAL upon timer expiration.
571	*/
572	struct sigevent SigEvt;
573	SigEvt.sigev_notify = SIGEV_SIGNAL;
574	SigEvt.sigev_signo = RT_TIMER_SIGNAL;
575	SigEvt.sigev_value.sival_ptr = pTimer; /* sigev_value gets copied to siginfo. */
576	int err = timer_create(CLOCK_REALTIME, &SigEvt, &pTimer->NativeTimer);
577	if (!err)
578	{
579	/*
580	* Increment the timer count, do this behind the critsect to avoid races.
581	*/
582	RTCritSectEnter(&g_TimerCritSect);
583
584	if (ASMAtomicIncU32(&g_cTimerInstances) != 1)
585	{
586	Assert(g_cTimerInstances > 1);
587	RTCritSectLeave(&g_TimerCritSect);
588
589	LogFlow(("RTTimerCreateEx: rc=%Rrc pTimer=%p (thread already running)\n", rc, pTimer));
590	*ppTimer = pTimer;
591	return VINF_SUCCESS;
592	}
593
594	/*
595	* Create the signal handling thread. It will wait for the signal
596	* and execute the timer functions.
597	*/
598	rc = RTThreadCreate(&g_TimerThread, rttimerThread, NULL, 0, RTTHREADTYPE_TIMER, RTTHREADFLAGS_WAITABLE, "Timer");
599	if (RT_SUCCESS(rc))
600	{
601	rc = RTThreadUserWait(g_TimerThread, 451000); / this better not fail... */
602	if (RT_SUCCESS(rc))
603	{
604	RTCritSectLeave(&g_TimerCritSect);
605
606	LogFlow(("RTTimerCreateEx: rc=%Rrc pTimer=%p (thread already running)\n", rc, pTimer));
607	*ppTimer = pTimer;
608	return VINF_SUCCESS;
609	}
610	/* darn, what do we do here? */
611	}
612
613	/* bail out */
614	ASMAtomicDecU32(&g_cTimerInstances);
615	Assert(!g_cTimerInstances);
616
617	RTCritSectLeave(&g_TimerCritSect);
618
619	timer_delete(pTimer->NativeTimer);
620	}
621	else
622	{
623	rc = RTErrConvertFromErrno(err);
624	Log(("RTTimerCreateEx: err=%d (%Rrc)\n", err, rc));
625	}
626
627	RTMemFree(pTimer);
628	}
629	else
630	rc = VERR_NO_MEMORY;
631
632	#endif /* IPRT_WITH_POSIX_TIMERS */
633	return rc;
634	}
635
636
637	RTR3DECL(int) RTTimerDestroy(PRTTIMER pTimer)
638	{
639	LogFlow(("RTTimerDestroy: pTimer=%p\n", pTimer));
640
641	/*
642	* Validate input.
643	*/
644	/* NULL is ok. */
645	if (!pTimer)
646	return VINF_SUCCESS;
647	int rc = VINF_SUCCESS;
648	AssertPtrReturn(pTimer, VERR_INVALID_POINTER);
649	AssertReturn(pTimer->u32Magic == RTTIMER_MAGIC, VERR_INVALID_MAGIC);
650	#ifdef IPRT_WITH_POSIX_TIMERS
651	AssertReturn(g_TimerThread != RTThreadSelf(), VERR_INTERNAL_ERROR);
652	#else
653	AssertReturn(pTimer->Thread != RTThreadSelf(), VERR_INTERNAL_ERROR);
654	#endif
655
656	/*
657	* Mark the semaphore as destroyed.
658	*/
659	ASMAtomicWriteU8(&pTimer->fDestroyed, true);
660	ASMAtomicWriteU32(&pTimer->u32Magic, ~RTTIMER_MAGIC);
661
662	#ifdef IPRT_WITH_POSIX_TIMERS
663	/*
664	* Suspend the timer if it's running.
665	*/
666	if (pTimer->fSuspended)
667	{
668	struct itimerspec TimerSpec;
669	TimerSpec.it_value.tv_sec = 0;
670	TimerSpec.it_value.tv_nsec = 0;
671	int err = timer_settime(pTimer->NativeTimer, 0, &TimerSpec, NULL); NOREF(err);
672	AssertMsg(!err, ("%d / %d\n", err, errno));
673	}
674	#endif
675
676	/*
677	* Poke the thread and wait for it to finish.
678	* This is only done for the last timer when using posix timers.
679	*/
680	#ifdef IPRT_WITH_POSIX_TIMERS
681	RTTHREAD Thread = NIL_RTTHREAD;
682	RTCritSectEnter(&g_TimerCritSect);
683	if (ASMAtomicDecU32(&g_cTimerInstances) == 0)
684	{
685	Thread = g_TimerThread;
686	g_TimerThread = NIL_RTTHREAD;
687	}
688	RTCritSectLeave(&g_TimerCritSect);
689	#else /* IPRT_WITH_POSIX_TIMERS */
690	RTTHREAD Thread = pTimer->Thread;
691	rc = RTSemEventSignal(pTimer->Event);
692	AssertRC(rc);
693	#endif /* IPRT_WITH_POSIX_TIMERS */
694	if (Thread != NIL_RTTHREAD)
695	{
696	/* Signal it so it gets out of the sigwait if it's stuck there... */
697	pthread_kill((pthread_t)RTThreadGetNative(Thread), RT_TIMER_SIGNAL);
698
699	/*
700	* Wait for the thread to complete.
701	*/
702	rc = RTThreadWait(Thread, 30 * 1000, NULL);
703	AssertRC(rc);
704	}
705
706
707	/*
708	* Free up the resources associated with the timer.
709	*/
710	#ifdef IPRT_WITH_POSIX_TIMERS
711	timer_delete(pTimer->NativeTimer);
712	#else
713	RTSemEventDestroy(pTimer->Event);
714	pTimer->Event = NIL_RTSEMEVENT;
715	#endif /* !IPRT_WITH_POSIX_TIMERS */
716	if (RT_SUCCESS(rc))
717	RTMemFree(pTimer);
718	return rc;
719	}
720
721
722	RTDECL(int) RTTimerStart(PRTTIMER pTimer, uint64_t u64First)
723	{
724	/*
725	* Validate input.
726	*/
727	AssertPtrReturn(pTimer, VERR_INVALID_POINTER);
728	AssertReturn(pTimer->u32Magic == RTTIMER_MAGIC, VERR_INVALID_MAGIC);
729	#ifndef IPRT_WITH_POSIX_TIMERS
730	AssertReturn(pTimer->Thread != RTThreadSelf(), VERR_INTERNAL_ERROR);
731	#endif
732
733	/*
734	* Already running?
735	*/
736	if (!ASMAtomicXchgU8(&pTimer->fSuspended, false))
737	return VERR_TIMER_ACTIVE;
738	LogFlow(("RTTimerStart: pTimer=%p u64First=%llu u64NanoInterval=%llu\n", pTimer, u64First, pTimer->u64NanoInterval));
739
740	#ifndef IPRT_WITH_POSIX_TIMERS
741	/*
742	* Tell the thread to start servicing the timer.
743	* Wait for it to ACK the request to avoid reset races.
744	*/
745	RTThreadUserReset(pTimer->Thread);
746	ASMAtomicUoWriteU64(&pTimer->u64NanoFirst, u64First);
747	ASMAtomicUoWriteU64(&pTimer->iTick, 0);
748	ASMAtomicWriteU8(&pTimer->fSuspended, false);
749	int rc = RTSemEventSignal(pTimer->Event);
750	if (RT_SUCCESS(rc))
751	{
752	rc = RTThreadUserWait(pTimer->Thread, 45*1000);
753	AssertRC(rc);
754	RTThreadUserReset(pTimer->Thread);
755	}
756	else
757	AssertRC(rc);
758
759	#else /* IPRT_WITH_POSIX_TIMERS */
760	/*
761	* Start the timer.
762	*/
763	struct itimerspec TimerSpec;
764	TimerSpec.it_value.tv_sec = u64First / 1000000000; /* nanosec => sec */
765	TimerSpec.it_value.tv_nsec = u64First ? u64First % 1000000000 : 10; /* 0 means disable, replace it with 10. */
766	TimerSpec.it_interval.tv_sec = pTimer->u64NanoInterval / 1000000000;
767	TimerSpec.it_interval.tv_nsec = pTimer->u64NanoInterval % 1000000000;
768	int err = timer_settime(pTimer->NativeTimer, 0, &TimerSpec, NULL);
769	int rc = err == 0 ? VINF_SUCCESS : RTErrConvertFromErrno(errno);
770	#endif /* IPRT_WITH_POSIX_TIMERS */
771
772	if (RT_FAILURE(rc))
773	ASMAtomicXchgU8(&pTimer->fSuspended, false);
774	return rc;
775	}
776
777
778	RTDECL(int) RTTimerStop(PRTTIMER pTimer)
779	{
780	/*
781	* Validate input.
782	*/
783	AssertPtrReturn(pTimer, VERR_INVALID_POINTER);
784	AssertReturn(pTimer->u32Magic == RTTIMER_MAGIC, VERR_INVALID_MAGIC);
785
786	/*
787	* Already running?
788	*/
789	if (ASMAtomicXchgU8(&pTimer->fSuspended, true))
790	return VERR_TIMER_SUSPENDED;
791	LogFlow(("RTTimerStop: pTimer=%p\n", pTimer));
792
793	#ifndef IPRT_WITH_POSIX_TIMERS
794	/*
795	* Tell the thread to stop servicing the timer.
796	*/
797	RTThreadUserReset(pTimer->Thread);
798	ASMAtomicXchgU8(&pTimer->fSuspended, true);
799	int rc = VINF_SUCCESS;
800	if (RTThreadSelf() != pTimer->Thread)
801	{
802	pthread_kill((pthread_t)RTThreadGetNative(pTimer->Thread), RT_TIMER_SIGNAL);
803	rc = RTThreadUserWait(pTimer->Thread, 45*1000);
804	AssertRC(rc);
805	RTThreadUserReset(pTimer->Thread);
806	}
807
808	#else /* IPRT_WITH_POSIX_TIMERS */
809	/*
810	* Stop the timer.
811	*/
812	struct itimerspec TimerSpec;
813	TimerSpec.it_value.tv_sec = 0;
814	TimerSpec.it_value.tv_nsec = 0;
815	int err = timer_settime(pTimer->NativeTimer, 0, &TimerSpec, NULL);
816	int rc = err == 0 ? VINF_SUCCESS : RTErrConvertFromErrno(errno);
817	#endif /* IPRT_WITH_POSIX_TIMERS */
818
819	return rc;
820	}
821
822
823	RTDECL(int) RTTimerChangeInterval(PRTTIMER pTimer, uint64_t u64NanoInterval)
824	{
825	AssertPtrReturn(pTimer, VERR_INVALID_POINTER);
826	AssertReturn(pTimer->u32Magic == RTTIMER_MAGIC, VERR_INVALID_MAGIC);
827	NOREF(u64NanoInterval);
828	return VERR_NOT_SUPPORTED;
829	}
830

Note: See TracBrowser for help on using the repository browser.

source: vbox/trunk/src/VBox/Runtime/r3/posix/timer-posix.cpp@ 82968

Download in other formats: