]> git.sesse.net Git - vlc/blob - src/misc/mtime.c
Also implement msleep() wrt _POSIX_MONOTONIC_CLOCK
[vlc] / src / misc / mtime.c
1 /*****************************************************************************
2  * mtime.c: high resolution time management functions
3  * Functions are prototyped in mtime.h.
4  *****************************************************************************
5  * Copyright (C) 1998-2004 the VideoLAN team
6  * $Id$
7  *
8  * Authors: Vincent Seguin <seguin@via.ecp.fr>
9  *          RĂ©mi Denis-Courmont <rem$videolan,org>
10  *
11  * This program is free software; you can redistribute it and/or modify
12  * it under the terms of the GNU General Public License as published by
13  * the Free Software Foundation; either version 2 of the License, or
14  * (at your option) any later version.
15  *
16  * This program is distributed in the hope that it will be useful,
17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
19  * GNU General Public License for more details.
20  *
21  * You should have received a copy of the GNU General Public License
22  * along with this program; if not, write to the Free Software
23  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
24  *****************************************************************************/
25
26 /*****************************************************************************
27  * Preamble
28  *****************************************************************************/
29 #include <stdio.h>                                              /* sprintf() */
30 #include <time.h>                      /* clock_gettime(), clock_nanosleep() */
31 #include <stdlib.h>                                                /* ldiv() */
32
33 #include <vlc/vlc.h>
34
35 #if defined( PTH_INIT_IN_PTH_H )                                  /* GNU Pth */
36 #   include <pth.h>
37 #endif
38
39 #ifdef HAVE_UNISTD_H
40 #   include <unistd.h>                                           /* select() */
41 #endif
42
43 #ifdef HAVE_KERNEL_OS_H
44 #   include <kernel/OS.h>
45 #endif
46
47 #if defined( WIN32 ) || defined( UNDER_CE )
48 #   include <windows.h>
49 #else
50 #   include <sys/time.h>
51 #endif
52
53 #if defined(HAVE_NANOSLEEP) && !defined(HAVE_STRUCT_TIMESPEC)
54 struct timespec
55 {
56     time_t  tv_sec;
57     int32_t tv_nsec;
58 };
59 #endif
60
61 #if defined(HAVE_NANOSLEEP) && !defined(HAVE_DECL_NANOSLEEP)
62 int nanosleep(struct timespec *, struct timespec *);
63 #endif
64
65 /**
66  * Return a date in a readable format
67  *
68  * This function converts a mtime date into a string.
69  * psz_buffer should be a buffer long enough to store the formatted
70  * date.
71  * \param date to be converted
72  * \param psz_buffer should be a buffer at least MSTRTIME_MAX_SIZE characters
73  * \return psz_buffer is returned so this can be used as printf parameter.
74  */
75 char *mstrtime( char *psz_buffer, mtime_t date )
76 {
77     static mtime_t ll1000 = 1000, ll60 = 60, ll24 = 24;
78
79     snprintf( psz_buffer, MSTRTIME_MAX_SIZE, "%02d:%02d:%02d-%03d.%03d",
80              (int) (date / (ll1000 * ll1000 * ll60 * ll60) % ll24),
81              (int) (date / (ll1000 * ll1000 * ll60) % ll60),
82              (int) (date / (ll1000 * ll1000) % ll60),
83              (int) (date / ll1000 % ll1000),
84              (int) (date % ll1000) );
85     return( psz_buffer );
86 }
87
88 /**
89  * Convert seconds to a time in the format h:mm:ss.
90  *
91  * This function is provided for any interface function which need to print a
92  * time string in the format h:mm:ss
93  * date.
94  * \param secs  the date to be converted
95  * \param psz_buffer should be a buffer at least MSTRTIME_MAX_SIZE characters
96  * \return psz_buffer is returned so this can be used as printf parameter.
97  */
98 char *secstotimestr( char *psz_buffer, int i_seconds )
99 {
100     snprintf( psz_buffer, MSTRTIME_MAX_SIZE, "%d:%2.2d:%2.2d",
101               (int) (i_seconds / (60 *60)),
102               (int) ((i_seconds / 60) % 60),
103               (int) (i_seconds % 60) );
104     return( psz_buffer );
105 }
106
107
108 /**
109  * Return high precision date
110  *
111  * Uses the gettimeofday() function when possible (1 MHz resolution) or the
112  * ftime() function (1 kHz resolution).
113  */
114 mtime_t mdate( void )
115 {
116 #if defined( HAVE_KERNEL_OS_H )
117     return( real_time_clock_usecs() );
118
119 #elif defined( WIN32 ) || defined( UNDER_CE )
120     /* We don't need the real date, just the value of a high precision timer */
121     static mtime_t freq = I64C(-1);
122     mtime_t usec_time;
123
124     if( freq == I64C(-1) )
125     {
126         /* Extract from the Tcl source code:
127          * (http://www.cs.man.ac.uk/fellowsd-bin/TIP/7.html)
128          *
129          * Some hardware abstraction layers use the CPU clock
130          * in place of the real-time clock as a performance counter
131          * reference.  This results in:
132          *    - inconsistent results among the processors on
133          *      multi-processor systems.
134          *    - unpredictable changes in performance counter frequency
135          *      on "gearshift" processors such as Transmeta and
136          *      SpeedStep.
137          * There seems to be no way to test whether the performance
138          * counter is reliable, but a useful heuristic is that
139          * if its frequency is 1.193182 MHz or 3.579545 MHz, it's
140          * derived from a colorburst crystal and is therefore
141          * the RTC rather than the TSC.  If it's anything else, we
142          * presume that the performance counter is unreliable.
143          */
144
145         freq = ( QueryPerformanceFrequency( (LARGE_INTEGER *)&freq ) &&
146                  (freq == I64C(1193182) || freq == I64C(3579545) ) )
147                ? freq : 0;
148     }
149
150     if( freq != 0 )
151     {
152         /* Microsecond resolution */
153         QueryPerformanceCounter( (LARGE_INTEGER *)&usec_time );
154         return ( usec_time * 1000000 ) / freq;
155     }
156     else
157     {
158         /* Fallback on GetTickCount() which has a milisecond resolution
159          * (actually, best case is about 10 ms resolution)
160          * GetTickCount() only returns a DWORD thus will wrap after
161          * about 49.7 days so we try to detect the wrapping. */
162
163         static CRITICAL_SECTION date_lock;
164         static mtime_t i_previous_time = I64C(-1);
165         static int i_wrap_counts = -1;
166
167         if( i_wrap_counts == -1 )
168         {
169             /* Initialization */
170             i_previous_time = I64C(1000) * GetTickCount();
171             InitializeCriticalSection( &date_lock );
172             i_wrap_counts = 0;
173         }
174
175         EnterCriticalSection( &date_lock );
176         usec_time = I64C(1000) *
177             (i_wrap_counts * I64C(0x100000000) + GetTickCount());
178         if( i_previous_time > usec_time )
179         {
180             /* Counter wrapped */
181             i_wrap_counts++;
182             usec_time += I64C(0x100000000000);
183         }
184         i_previous_time = usec_time;
185         LeaveCriticalSection( &date_lock );
186
187         return usec_time;
188     }
189
190 #elif defined (HAVE_CLOCK_GETTIME)
191     struct timespec ts;
192
193 # if (_POSIX_MONOTONIC_CLOCK - 0 >= 0)
194     /* Try to use POSIX monotonic clock if available */
195     if( clock_gettime( CLOCK_MONOTONIC, &ts ) )
196 # endif
197         /* Run-time fallback to real-time clock (always available) */
198         (void)clock_gettime( CLOCK_REALTIME, &ts );
199
200     fprintf (stderr, "%ld\n", (mtime_t)((ts.tv_sec * 1000000) + (ts.tv_nsec / 1000)));
201     return (ts.tv_sec * 1000000) + (ts.tv_nsec / 1000);
202 #else
203     struct timeval tv_date;
204
205     /* gettimeofday() cannot fail given &tv_date is a valid address */
206     (void)gettimeofday( &tv_date, NULL );
207     return( (mtime_t) tv_date.tv_sec * 1000000 + (mtime_t) tv_date.tv_usec );
208 #endif
209 }
210
211 /**
212  * Wait for a date
213  *
214  * This function uses select() and an system date function to wake up at a
215  * precise date. It should be used for process synchronization. If current date
216  * is posterior to wished date, the function returns immediately.
217  * \param date The date to wake up at
218  */
219 void mwait( mtime_t date )
220 {
221 #if defined( HAVE_KERNEL_OS_H )
222     mtime_t delay;
223
224     delay = date - real_time_clock_usecs();
225     if( delay <= 0 )
226     {
227         return;
228     }
229     snooze( delay );
230
231 #elif defined( WIN32 ) || defined( UNDER_CE )
232     mtime_t usec_time, delay;
233
234     usec_time = mdate();
235     delay = date - usec_time;
236     if( delay <= 0 )
237     {
238         return;
239     }
240     msleep( delay );
241
242 #elif defined (HAVE_CLOCK_GETTIME)
243     struct timespec ts;
244     ldiv_t d;
245
246 # if 1
247     /*
248      * Ideally, we'd use absolute time (TIMER_ABSTIME), instead of
249      * computing the time difference... but VLC mtime_t type seems to
250      * overflow way too quickly for this to work properly, or maybe it's a
251      * signedness problem (??).
252      */
253     date -= mdate();
254     if( date <= 0 )
255         return;
256 # endif
257     d = ldiv( date, 1000000 );
258     ts.tv_sec = d.quot;
259     ts.tv_nsec = d.rem * 1000;
260
261 # if (_POSIX_MONOTONIC_CLOCK - 0 >= 0)
262     if( clock_nanosleep( CLOCK_MONOTONIC, 0, &ts, NULL ) )
263 # endif
264         clock_nanosleep( CLOCK_REALTIME, 0, &ts, NULL );
265 #else
266
267     struct timeval tv_date;
268     mtime_t        delay;          /* delay in msec, signed to detect errors */
269
270     /* see mdate() about gettimeofday() possible errors */
271     gettimeofday( &tv_date, NULL );
272
273     /* calculate delay and check if current date is before wished date */
274     delay = date - (mtime_t) tv_date.tv_sec * 1000000
275                  - (mtime_t) tv_date.tv_usec
276                  - 10000;
277
278     /* Linux/i386 has a granularity of 10 ms. It's better to be in advance
279      * than to be late. */
280     if( delay <= 0 )                 /* wished date is now or already passed */
281     {
282         return;
283     }
284
285 #   if defined( PTH_INIT_IN_PTH_H )
286     pth_usleep( delay );
287
288 #   elif defined( ST_INIT_IN_ST_H )
289     st_usleep( delay );
290
291 #   else
292
293 #       if defined( HAVE_NANOSLEEP )
294     {
295         struct timespec ts_delay;
296         ts_delay.tv_sec = delay / 1000000;
297         ts_delay.tv_nsec = (delay % 1000000) * 1000;
298
299         nanosleep( &ts_delay, NULL );
300     }
301
302 #       else
303     tv_date.tv_sec = delay / 1000000;
304     tv_date.tv_usec = delay % 1000000;
305     /* see msleep() about select() errors */
306     select( 0, NULL, NULL, NULL, &tv_date );
307 #       endif
308
309 #   endif
310
311 #endif
312 }
313
314 /**
315  * More precise sleep()
316  *
317  * Portable usleep() function.
318  * \param delay the amount of time to sleep
319  */
320 void msleep( mtime_t delay )
321 {
322 #if defined( HAVE_KERNEL_OS_H )
323     snooze( delay );
324
325 #elif defined( PTH_INIT_IN_PTH_H )
326     pth_usleep( delay );
327
328 #elif defined( ST_INIT_IN_ST_H )
329     st_usleep( delay );
330
331 #elif defined( WIN32 ) || defined( UNDER_CE )
332     Sleep( (int) (delay / 1000) );
333
334 #elif defined( HAVE_CLOCK_GETTIME )
335     ldiv_t d = ldiv( delay, 1000000 );
336     struct timespec ts = { d.quot, d.rem * 1000 };
337 # if (_POSIX_CLOCK_MONOTONIC - 0 >= 0)
338     if (clock_nanosleep( CLOCK_MONOTONIC, 0, &ts, NULL ) )
339 # endif
340         clock_nanosleep( CLOCK_REALTIME, 0, &ts, NULL );
341
342 #elif defined( HAVE_NANOSLEEP )
343     struct timespec ts_delay;
344
345     ts_delay.tv_sec = delay / 1000000;
346     ts_delay.tv_nsec = (delay % 1000000) * 1000;
347
348     nanosleep( &ts_delay, NULL );
349
350 #else
351     struct timeval tv_delay;
352
353     tv_delay.tv_sec = delay / 1000000;
354     tv_delay.tv_usec = delay % 1000000;
355
356     /* select() return value should be tested, since several possible errors
357      * can occur. However, they should only happen in very particular occasions
358      * (i.e. when a signal is sent to the thread, or when memory is full), and
359      * can be ignored. */
360     select( 0, NULL, NULL, NULL, &tv_delay );
361
362 #endif
363 }
364
365 /*
366  * Date management (internal and external)
367  */
368
369 /**
370  * Initialize a date_t.
371  *
372  * \param date to initialize
373  * \param divider (sample rate) numerator
374  * \param divider (sample rate) denominator
375  */
376
377 void date_Init( date_t *p_date, uint32_t i_divider_n, uint32_t i_divider_d )
378 {
379     p_date->date = 0;
380     p_date->i_divider_num = i_divider_n;
381     p_date->i_divider_den = i_divider_d;
382     p_date->i_remainder = 0;
383 }
384
385 /**
386  * Change a date_t.
387  *
388  * \param date to change
389  * \param divider (sample rate) numerator
390  * \param divider (sample rate) denominator
391  */
392
393 void date_Change( date_t *p_date, uint32_t i_divider_n, uint32_t i_divider_d )
394 {
395     p_date->i_divider_num = i_divider_n;
396     p_date->i_divider_den = i_divider_d;
397 }
398
399 /**
400  * Set the date value of a date_t.
401  *
402  * \param date to set
403  * \param date value
404  */
405 void date_Set( date_t *p_date, mtime_t i_new_date )
406 {
407     p_date->date = i_new_date;
408     p_date->i_remainder = 0;
409 }
410
411 /**
412  * Get the date of a date_t
413  *
414  * \param date to get
415  * \return date value
416  */
417 mtime_t date_Get( const date_t *p_date )
418 {
419     return p_date->date;
420 }
421
422 /**
423  * Move forwards or backwards the date of a date_t.
424  *
425  * \param date to move
426  * \param difference value
427  */
428 void date_Move( date_t *p_date, mtime_t i_difference )
429 {
430     p_date->date += i_difference;
431 }
432
433 /**
434  * Increment the date and return the result, taking into account
435  * rounding errors.
436  *
437  * \param date to increment
438  * \param incrementation in number of samples
439  * \return date value
440  */
441 mtime_t date_Increment( date_t *p_date, uint32_t i_nb_samples )
442 {
443     mtime_t i_dividend = (mtime_t)i_nb_samples * 1000000;
444     p_date->date += i_dividend / p_date->i_divider_num * p_date->i_divider_den;
445     p_date->i_remainder += (int)(i_dividend % p_date->i_divider_num);
446
447     if( p_date->i_remainder >= p_date->i_divider_num )
448     {
449         /* This is Bresenham algorithm. */
450         p_date->date += p_date->i_divider_den;
451         p_date->i_remainder -= p_date->i_divider_num;
452     }
453
454     return p_date->date;
455 }