SheepShaver/src/timer.cpp

/*
 *  timer.cpp - Time Manager emulation
 *
 *  SheepShaver (C) 1997-2008 Christian Bauer and Marc Hellwig
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

#include "sysdeps.h"
#include "timer.h"
#include "macos_util.h"
#include "main.h"
#include "cpu_emulation.h"

#ifdef PRECISE_TIMING_POSIX
#include <pthread.h>
#include <semaphore.h>
#endif

#define DEBUG 0
#include "debug.h"


#define TM_QUEUE 0                      // Enable TMQueue management (doesn't work)


// Definitions for Time Manager
enum {  // TMTask struct
        tmAddr = 6,
        tmCount = 10,
        tmWakeUp = 14,
        tmReserved = 18
};


// Array of additional info for each installed TMTask
struct TMDesc {
        uint32 task;            // Mac address of associated TMTask
        tm_time_t wakeup;       // Time this task is scheduled for execution
        bool in_use;            // Flag: descriptor in use
};

const int NUM_DESCS = 64;               // Maximum number of descriptors
static TMDesc desc[NUM_DESCS];

#if PRECISE_TIMING
#ifdef PRECISE_TIMING_BEOS
static thread_id timer_thread = -1;
static bool thread_active = true;
static const tm_time_t wakeup_time_max = 0x7fffffffffffffff; 
static volatile tm_time_t wakeup_time = wakeup_time_max;
static sem_id wakeup_time_sem = -1;
static int32 timer_func(void *arg);
#endif
#ifdef PRECISE_TIMING_POSIX
static pthread_t timer_thread;
static bool timer_thread_active = false;
static volatile bool timer_thread_cancel = false;
static tm_time_t wakeup_time_max = { 0x7fffffff, 999999999 };
static tm_time_t wakeup_time = wakeup_time_max;
static pthread_mutex_t wakeup_time_lock = PTHREAD_MUTEX_INITIALIZER;
static void *timer_func(void *arg);
#endif
#endif


/*
 *  Allocate descriptor for given TMTask in list
 */

static int alloc_desc(uint32 tm)
{
        // Search for first free descriptor
        for (int i=0; i<NUM_DESCS; i++)
                if (!desc[i].in_use) {
                        desc[i].task = tm;
                        desc[i].in_use = true;
                        return i;
                }
        return -1;
}


/*
 *  Free descriptor in list
 */

inline static void free_desc(int i)
{
        desc[i].in_use = false;
}


/*
 *  Find descriptor associated with given TMTask
 */

inline static int find_desc(uint32 tm)
{
        for (int i=0; i<NUM_DESCS; i++)
                if (desc[i].in_use && desc[i].task == tm)
                        return i;
        return -1;
}


/*
 *  Enqueue task in Time Manager queue
 */

static void enqueue_tm(uint32 tm)
{
#if TM_QUEUE
        uint32 tm_var = ReadMacInt32(0xb30);
        WriteMacInt32(tm + qLink, ReadMacInt32(tm_var));
        WriteMacInt32(tm_var, tm);
#endif
}


/*
 *  Remove task from Time Manager queue
 */

static void dequeue_tm(uint32 tm)
{
#if TM_QUEUE
        uint32 p = ReadMacInt32(0xb30);
        while (p) {
                uint32 next = ReadMacInt32(p + qLink);
                if (next == tm) {
                        WriteMacInt32(p + qLink, ReadMacInt32(next + qLink));
                        return;
                }
        }
#endif
}


/*
 *  Timer thread operations
 */

#ifdef PRECISE_TIMING_POSIX
const int SIGSUSPEND = SIGRTMIN + 6;
const int SIGRESUME  = SIGRTMIN + 7;
static struct sigaction sigsuspend_action;
static struct sigaction sigresume_action;

static int suspend_count = 0;
static pthread_mutex_t suspend_count_lock = PTHREAD_MUTEX_INITIALIZER;
static sem_t suspend_ack_sem;
static sigset_t suspend_handler_mask;

// Signal handler for suspended thread
static void sigsuspend_handler(int sig)
{
        sem_post(&suspend_ack_sem);
        sigsuspend(&suspend_handler_mask);
}

// Signal handler for resumed thread
static void sigresume_handler(int sig)
{
        /* simply trigger a signal to stop clock_nanosleep() */
}

// Initialize timer thread
static bool timer_thread_init(void)
{
        // Install suspend signal handler
        sigemptyset(&sigsuspend_action.sa_mask);
        sigaddset(&sigsuspend_action.sa_mask, SIGRESUME);
        sigsuspend_action.sa_handler = sigsuspend_handler;
        sigsuspend_action.sa_flags = SA_RESTART;
#ifdef HAVE_SIGNAL_SA_RESTORER
        sigsuspend_action.sa_restorer = NULL;
#endif
        if (sigaction(SIGSUSPEND, &sigsuspend_action, NULL) < 0)
                return false;

        // Install resume signal handler
        sigemptyset(&sigresume_action.sa_mask);
        sigresume_action.sa_handler = sigresume_handler;
        sigresume_action.sa_flags = SA_RESTART;
#ifdef HAVE_SIGNAL_SA_RESTORER
        sigresume_action.sa_restorer = NULL;
#endif
        if (sigaction(SIGRESUME, &sigresume_action, NULL) < 0)
                return false;

        // Initialize semaphore
        if (sem_init(&suspend_ack_sem, 0, 0) < 0)
                return false;

        // Initialize suspend_handler_mask, it excludes SIGRESUME
        if (sigfillset(&suspend_handler_mask) != 0)
                return false;
        if (sigdelset(&suspend_handler_mask, SIGRESUME) != 0)
                return false;

        // Create thread in running state
        suspend_count = 0;
        return (pthread_create(&timer_thread, NULL, timer_func, NULL) == 0);
}

// Kill timer thread
static void timer_thread_kill(void)
{
        timer_thread_cancel = true;
#ifdef HAVE_PTHREAD_CANCEL
        pthread_cancel(timer_thread);
#endif
        pthread_join(timer_thread, NULL);
}

// Suspend timer thread
static void timer_thread_suspend(void)
{
        pthread_mutex_lock(&suspend_count_lock);
        if (suspend_count == 0) {
                suspend_count ++;
                if (pthread_kill(timer_thread, SIGSUSPEND) == 0)
                        sem_wait(&suspend_ack_sem);
        }
        pthread_mutex_unlock(&suspend_count_lock);
}

// Resume timer thread
static void timer_thread_resume(void)
{
        pthread_mutex_lock(&suspend_count_lock);
        assert(suspend_count > 0);
        if (suspend_count == 1) {
                suspend_count = 0;
                pthread_kill(timer_thread, SIGRESUME);
        }
        pthread_mutex_unlock(&suspend_count_lock);
}
#endif


/*
 *  Initialize Time Manager
 */

void TimerInit(void)
{
        // Mark all descriptors as inactive
        for (int i=0; i<NUM_DESCS; i++)
                free_desc(i);

#if PRECISE_TIMING
        // Start timer thread
#ifdef PRECISE_TIMING_BEOS
        wakeup_time_sem = create_sem(1, "Wakeup Time");
        timer_thread = spawn_thread(timer_func, "Time Manager", B_REAL_TIME_PRIORITY, NULL);
        resume_thread(timer_thread);
#endif
#ifdef PRECISE_TIMING_POSIX
        timer_thread_active = timer_thread_init();
#endif
#endif
}


/*
 *  Exit Time Manager
 */

void TimerExit(void)
{
#if PRECISE_TIMING
        // Quit timer thread
        if (timer_thread > 0) {
#ifdef PRECISE_TIMING_BEOS
                status_t l;
                thread_active = false;
                suspend_thread(timer_thread);
                resume_thread(timer_thread);
                wait_for_thread(timer_thread, &l);
                delete_sem(wakeup_time_sem);
#endif
#ifdef PRECISE_TIMING_POSIX
                timer_thread_kill();
#endif
        }
#endif
}


/*
 *  Emulator reset, remove all timer tasks
 */

void TimerReset(void)
{
        // Mark all descriptors as inactive
        for (int i=0; i<NUM_DESCS; i++)
                free_desc(i);
}


/*
 *  Insert timer task
 */

int16 InsTime(uint32 tm, uint16 trap)
{
        D(bug("InsTime %08lx, trap %04x\n", tm, trap));
        WriteMacInt16((uint32)tm + qType, ReadMacInt16((uint32)tm + qType) & 0x1fff | (trap << 4) & 0x6000);
        if (find_desc(tm) >= 0)
                printf("WARNING: InsTime(): Task re-inserted\n");
        else {
                int i = alloc_desc(tm);
                if (i < 0)
                        printf("FATAL: InsTime(): No free Time Manager descriptor\n");
        }
        return 0;
}


/*
 *  Remove timer task
 */

int16 RmvTime(uint32 tm)
{
        D(bug("RmvTime %08lx\n", tm));

        // Find descriptor
        int i = find_desc(tm);
        if (i < 0) {
                printf("WARNING: RmvTime(%08lx): Descriptor not found\n", tm);
                return 0;
        }

        // Task active?
#if PRECISE_TIMING_BEOS
        while (acquire_sem(wakeup_time_sem) == B_INTERRUPTED) ;
        suspend_thread(timer_thread);
#endif
#if PRECISE_TIMING_POSIX
        timer_thread_suspend();
        pthread_mutex_lock(&wakeup_time_lock);
#endif
        if (ReadMacInt16(tm + qType) & 0x8000) {

                // Yes, make task inactive and remove it from the Time Manager queue
                WriteMacInt16(tm + qType, ReadMacInt16(tm + qType) & 0x7fff);
                dequeue_tm(tm);
#if PRECISE_TIMING
                // Look for next task to be called and set wakeup_time
                wakeup_time = wakeup_time_max;
                for (int j=0; j<NUM_DESCS; j++) {
                        if (desc[j].in_use && (ReadMacInt16(desc[j].task + qType) & 0x8000))
                                if (timer_cmp_time(desc[j].wakeup, wakeup_time) < 0)
                                        wakeup_time = desc[j].wakeup;
                }
#endif

                // Compute remaining time
                tm_time_t remaining, current;
                timer_current_time(current);
                timer_sub_time(remaining, desc[i].wakeup, current);
                WriteMacInt32(tm + tmCount, timer_host2mac_time(remaining));
        } else
                WriteMacInt32(tm + tmCount, 0);
        D(bug(" tmCount %ld\n", ReadMacInt32(tm + tmCount)));
#if PRECISE_TIMING_BEOS
        release_sem(wakeup_time_sem);
        thread_info info;
        do {
                resume_thread(timer_thread);                    // This will unblock the thread
                get_thread_info(timer_thread, &info);
        } while (info.state == B_THREAD_SUSPENDED);     // Sometimes, resume_thread() doesn't work (BeOS bug?)
#endif
#if PRECISE_TIMING_POSIX
        pthread_mutex_unlock(&wakeup_time_lock);
        timer_thread_resume();
        assert(suspend_count == 0);
#endif

        // Free descriptor
        free_desc(i);
        return 0;
}


/*
 *  Start timer task
 */

int16 PrimeTime(uint32 tm, int32 time)
{
        D(bug("PrimeTime %08lx, time %ld\n", tm, time));

        // Find descriptor
        int i = find_desc(tm);
        if (i < 0) {
                printf("FATAL: PrimeTime(): Descriptor not found\n");
                return 0;
        }

        // Convert delay time
        tm_time_t delay;
        timer_mac2host_time(delay, time);

        // Extended task?
        if (ReadMacInt16(tm + qType) & 0x4000) {

                // Yes, tmWakeUp set?
                if (ReadMacInt32(tm + tmWakeUp)) {

                        // PrimeTime(0) can either mean (a) "the task runs as soon as interrupts are enabled"
                        // or (b) "continue previous delay" if an expired task was stopped via RmvTime() and
                        // then re-installed using InsXTime(). Since tmWakeUp was set, this is case (b).
                        // The remaining time was saved in tmCount by RmvTime().
                        if (time == 0) {
                                timer_mac2host_time(delay, ReadMacInt16(tm + tmCount));
                        }

                        // Yes, calculate wakeup time relative to last scheduled time
                        tm_time_t wakeup;
                        timer_add_time(wakeup, desc[i].wakeup, delay);
                        desc[i].wakeup = wakeup;

                } else {

                        // No, calculate wakeup time relative to current time
                        tm_time_t now;
                        timer_current_time(now);
                        timer_add_time(desc[i].wakeup, now, delay);
                }

                // Set tmWakeUp to indicate that task was scheduled
                WriteMacInt32(tm + tmWakeUp, 0x12345678);

        } else {

                // Not extended task, calculate wakeup time relative to current time
                tm_time_t now;
                timer_current_time(now);
                timer_add_time(desc[i].wakeup, now, delay);
        }

        // Make task active and enqueue it in the Time Manager queue
#if PRECISE_TIMING_BEOS
        while (acquire_sem(wakeup_time_sem) == B_INTERRUPTED) ;
        suspend_thread(timer_thread);
#endif
#if PRECISE_TIMING_POSIX
        timer_thread_suspend();
        pthread_mutex_lock(&wakeup_time_lock);
#endif
        WriteMacInt16(tm + qType, ReadMacInt16(tm + qType) | 0x8000);
        enqueue_tm(tm);
#if PRECISE_TIMING
        // Look for next task to be called and set wakeup_time
        wakeup_time = wakeup_time_max;
        for (int j=0; j<NUM_DESCS; j++) {
                if (desc[j].in_use && (ReadMacInt16(desc[j].task + qType) & 0x8000))
                        if (timer_cmp_time(desc[j].wakeup, wakeup_time) < 0)
                                wakeup_time = desc[j].wakeup;
        }
#ifdef PRECISE_TIMING_BEOS
        release_sem(wakeup_time_sem);
        thread_info info;
        do {
                resume_thread(timer_thread);                    // This will unblock the thread
                get_thread_info(timer_thread, &info);
        } while (info.state == B_THREAD_SUSPENDED);     // Sometimes, resume_thread() doesn't work (BeOS bug?)
#endif
#ifdef PRECISE_TIMING_POSIX
        pthread_mutex_unlock(&wakeup_time_lock);
        timer_thread_resume();
        assert(suspend_count == 0);
#endif
#endif
        return 0;
}


/*
 *  Time Manager thread
 */

#ifdef PRECISE_TIMING_BEOS
static int32 timer_func(void *arg)
{
        while (thread_active) {

                // Wait until time specified by wakeup_time
                snooze_until(wakeup_time, B_SYSTEM_TIMEBASE);

                while (acquire_sem(wakeup_time_sem) == B_INTERRUPTED) ;
                if (wakeup_time < system_time()) {

                        // Timer expired, trigger interrupt
                        wakeup_time = 0x7fffffffffffffff;
                        SetInterruptFlag(INTFLAG_TIMER);
                        TriggerInterrupt();
                }
                release_sem(wakeup_time_sem);
        }
        return 0;
}
#endif

#ifdef PRECISE_TIMING_POSIX
static void *timer_func(void *arg)
{
        while (!timer_thread_cancel) {

                // Wait until time specified by wakeup_time
                clock_nanosleep(CLOCK_REALTIME, TIMER_ABSTIME, &wakeup_time, NULL);

                tm_time_t system_time;
                timer_current_time(system_time);
                if (timer_cmp_time(wakeup_time, system_time) < 0) {

                        // Timer expired, trigger interrupt
                        pthread_mutex_lock(&wakeup_time_lock);
                        wakeup_time = wakeup_time_max;
                        pthread_mutex_unlock(&wakeup_time_lock);
                        SetInterruptFlag(INTFLAG_TIMER);
                        TriggerInterrupt();
                }
        }
        return NULL;
}
#endif


/*
 *  Timer interrupt function (executed as part of 60Hz interrupt)
 */

void TimerInterrupt(void)
{
//      D(bug("TimerIRQ\n"));

        // Look for active TMTasks that have expired
        tm_time_t now;
        timer_current_time(now);
        for (int i=0; i<NUM_DESCS; i++)
                if (desc[i].in_use) {
                        uint32 tm = desc[i].task;
                        if ((ReadMacInt16(tm + qType) & 0x8000) && timer_cmp_time(desc[i].wakeup, now) <= 0) {

                                // Found one, mark as inactive and remove it from the Time Manager queue
                                WriteMacInt16(tm + qType, ReadMacInt16(tm + qType) & 0x7fff);
                                dequeue_tm(tm);

                                // Call timer function
                                uint32 addr = ReadMacInt32(tm + tmAddr);
                                if (addr) {
                                        D(bug("Calling TimeTask %08lx, addr %08lx\n", tm, addr));
                                        M68kRegisters r;
                                        r.a[0] = addr;
                                        r.a[1] = tm;
                                        Execute68k(r.a[0], &r);
                                        D(bug(" returned from TimeTask\n"));
                                }
                        }
                }

#if PRECISE_TIMING
        // Look for next task to be called and set wakeup_time
#if PRECISE_TIMING_BEOS
        while (acquire_sem(wakeup_time_sem) == B_INTERRUPTED) ;
        suspend_thread(timer_thread);
#endif
#if PRECISE_TIMING_POSIX
        timer_thread_suspend();
        pthread_mutex_lock(&wakeup_time_lock);
#endif
        wakeup_time = wakeup_time_max;
        for (int j=0; j<NUM_DESCS; j++) {
                if (desc[j].in_use && (ReadMacInt16(desc[j].task + qType) & 0x8000))
                        if (timer_cmp_time(desc[j].wakeup, wakeup_time) < 0)
                                wakeup_time = desc[j].wakeup;
        }
#if PRECISE_TIMING_BEOS
        release_sem(wakeup_time_sem);
        thread_info info;
        do {
                resume_thread(timer_thread);                    // This will unblock the thread
                get_thread_info(timer_thread, &info);
        } while (info.state == B_THREAD_SUSPENDED);     // Sometimes, resume_thread() doesn't work (BeOS bug?)
#endif
#if PRECISE_TIMING_POSIX
        pthread_mutex_unlock(&wakeup_time_lock);
        timer_thread_resume();
        assert(suspend_count == 0);
#endif
#endif
}
Revision:	1.11
Committed:	2009-08-01T07:02:41Z (14 years, 9 months ago) by asvitkine
Branch:	MAIN
Changes since 1.10:	+3 -1 lines
Log Message:	only "continue previous delay" if delay is 0
#	User	Rev	Content
1	cebix	1.1	/*
2			* timer.cpp - Time Manager emulation
3			*
4	gbeauche	1.8	* SheepShaver (C) 1997-2008 Christian Bauer and Marc Hellwig
5	cebix	1.1	*
6			* This program is free software; you can redistribute it and/or modify
7			* it under the terms of the GNU General Public License as published by
8			* the Free Software Foundation; either version 2 of the License, or
9			* (at your option) any later version.
10			*
11			* This program is distributed in the hope that it will be useful,
12			* but WITHOUT ANY WARRANTY; without even the implied warranty of
13			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14			* GNU General Public License for more details.
15			*
16			* You should have received a copy of the GNU General Public License
17			* along with this program; if not, write to the Free Software
18			* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19			*/
20
21			#include "sysdeps.h"
22			#include "timer.h"
23			#include "macos_util.h"
24			#include "main.h"
25			#include "cpu_emulation.h"
26
27	gbeauche	1.4	#ifdef PRECISE_TIMING_POSIX
28			#include <pthread.h>
29			#include <semaphore.h>
30			#endif
31
32	cebix	1.1	#define DEBUG 0
33			#include "debug.h"
34
35
36			#define TM_QUEUE 0 // Enable TMQueue management (doesn't work)
37
38
39			// Definitions for Time Manager
40			enum { // TMTask struct
41			tmAddr = 6,
42			tmCount = 10,
43			tmWakeUp = 14,
44			tmReserved = 18
45			};
46
47
48			// Array of additional info for each installed TMTask
49			struct TMDesc {
50			uint32 task; // Mac address of associated TMTask
51			tm_time_t wakeup; // Time this task is scheduled for execution
52			bool in_use; // Flag: descriptor in use
53			};
54
55			const int NUM_DESCS = 64; // Maximum number of descriptors
56			static TMDesc desc[NUM_DESCS];
57
58			#if PRECISE_TIMING
59	gbeauche	1.4	#ifdef PRECISE_TIMING_BEOS
60	cebix	1.1	static thread_id timer_thread = -1;
61			static bool thread_active = true;
62	gbeauche	1.4	static const tm_time_t wakeup_time_max = 0x7fffffffffffffff;
63			static volatile tm_time_t wakeup_time = wakeup_time_max;
64	cebix	1.1	static sem_id wakeup_time_sem = -1;
65			static int32 timer_func(void *arg);
66			#endif
67	gbeauche	1.4	#ifdef PRECISE_TIMING_POSIX
68			static pthread_t timer_thread;
69	gbeauche	1.5	static bool timer_thread_active = false;
70			static volatile bool timer_thread_cancel = false;
71	gbeauche	1.4	static tm_time_t wakeup_time_max = { 0x7fffffff, 999999999 };
72			static tm_time_t wakeup_time = wakeup_time_max;
73	gbeauche	1.6	static pthread_mutex_t wakeup_time_lock = PTHREAD_MUTEX_INITIALIZER;
74	gbeauche	1.4	static void timer_func(void arg);
75			#endif
76			#endif
77	cebix	1.1
78
79			/*
80			* Allocate descriptor for given TMTask in list
81			*/
82
83			static int alloc_desc(uint32 tm)
84			{
85			// Search for first free descriptor
86			for (int i=0; i<NUM_DESCS; i++)
87			if (!desc[i].in_use) {
88			desc[i].task = tm;
89			desc[i].in_use = true;
90			return i;
91			}
92			return -1;
93			}
94
95
96			/*
97			* Free descriptor in list
98			*/
99
100			inline static void free_desc(int i)
101			{
102			desc[i].in_use = false;
103			}
104
105
106			/*
107			* Find descriptor associated with given TMTask
108			*/
109
110			inline static int find_desc(uint32 tm)
111			{
112			for (int i=0; i<NUM_DESCS; i++)
113			if (desc[i].in_use && desc[i].task == tm)
114			return i;
115			return -1;
116			}
117
118
119			/*
120			* Enqueue task in Time Manager queue
121			*/
122
123			static void enqueue_tm(uint32 tm)
124			{
125			#if TM_QUEUE
126			uint32 tm_var = ReadMacInt32(0xb30);
127			WriteMacInt32(tm + qLink, ReadMacInt32(tm_var));
128			WriteMacInt32(tm_var, tm);
129			#endif
130			}
131
132
133			/*
134			* Remove task from Time Manager queue
135			*/
136
137			static void dequeue_tm(uint32 tm)
138			{
139			#if TM_QUEUE
140			uint32 p = ReadMacInt32(0xb30);
141			while (p) {
142			uint32 next = ReadMacInt32(p + qLink);
143			if (next == tm) {
144			WriteMacInt32(p + qLink, ReadMacInt32(next + qLink));
145			return;
146			}
147			}
148			#endif
149			}
150
151
152			/*
153	gbeauche	1.4	* Timer thread operations
154			*/
155
156			#ifdef PRECISE_TIMING_POSIX
157			const int SIGSUSPEND = SIGRTMIN + 6;
158			const int SIGRESUME = SIGRTMIN + 7;
159			static struct sigaction sigsuspend_action;
160			static struct sigaction sigresume_action;
161
162			static int suspend_count = 0;
163			static pthread_mutex_t suspend_count_lock = PTHREAD_MUTEX_INITIALIZER;
164			static sem_t suspend_ack_sem;
165	gbeauche	1.5	static sigset_t suspend_handler_mask;
166	gbeauche	1.4
167			// Signal handler for suspended thread
168			static void sigsuspend_handler(int sig)
169			{
170			sem_post(&suspend_ack_sem);
171	gbeauche	1.5	sigsuspend(&suspend_handler_mask);
172	gbeauche	1.4	}
173
174			// Signal handler for resumed thread
175			static void sigresume_handler(int sig)
176			{
177			/* simply trigger a signal to stop clock_nanosleep() */
178			}
179
180			// Initialize timer thread
181			static bool timer_thread_init(void)
182			{
183			// Install suspend signal handler
184	gbeauche	1.6	sigemptyset(&sigsuspend_action.sa_mask);
185			sigaddset(&sigsuspend_action.sa_mask, SIGRESUME);
186	gbeauche	1.4	sigsuspend_action.sa_handler = sigsuspend_handler;
187			sigsuspend_action.sa_flags = SA_RESTART;
188			#ifdef HAVE_SIGNAL_SA_RESTORER
189			sigsuspend_action.sa_restorer = NULL;
190			#endif
191			if (sigaction(SIGSUSPEND, &sigsuspend_action, NULL) < 0)
192			return false;
193
194			// Install resume signal handler
195	gbeauche	1.6	sigemptyset(&sigresume_action.sa_mask);
196	gbeauche	1.4	sigresume_action.sa_handler = sigresume_handler;
197			sigresume_action.sa_flags = SA_RESTART;
198			#ifdef HAVE_SIGNAL_SA_RESTORER
199			sigresume_action.sa_restorer = NULL;
200			#endif
201			if (sigaction(SIGRESUME, &sigresume_action, NULL) < 0)
202			return false;
203
204			// Initialize semaphore
205			if (sem_init(&suspend_ack_sem, 0, 0) < 0)
206			return false;
207
208	gbeauche	1.5	// Initialize suspend_handler_mask, it excludes SIGRESUME
209			if (sigfillset(&suspend_handler_mask) != 0)
210			return false;
211			if (sigdelset(&suspend_handler_mask, SIGRESUME) != 0)
212			return false;
213
214	gbeauche	1.4	// Create thread in running state
215			suspend_count = 0;
216			return (pthread_create(&timer_thread, NULL, timer_func, NULL) == 0);
217			}
218
219			// Kill timer thread
220			static void timer_thread_kill(void)
221			{
222	gbeauche	1.5	timer_thread_cancel = true;
223	gbeauche	1.4	#ifdef HAVE_PTHREAD_CANCEL
224			pthread_cancel(timer_thread);
225			#endif
226			pthread_join(timer_thread, NULL);
227			}
228
229			// Suspend timer thread
230			static void timer_thread_suspend(void)
231			{
232			pthread_mutex_lock(&suspend_count_lock);
233			if (suspend_count == 0) {
234			suspend_count ++;
235			if (pthread_kill(timer_thread, SIGSUSPEND) == 0)
236			sem_wait(&suspend_ack_sem);
237			}
238			pthread_mutex_unlock(&suspend_count_lock);
239			}
240
241			// Resume timer thread
242			static void timer_thread_resume(void)
243			{
244			pthread_mutex_lock(&suspend_count_lock);
245			assert(suspend_count > 0);
246			if (suspend_count == 1) {
247			suspend_count = 0;
248			pthread_kill(timer_thread, SIGRESUME);
249			}
250			pthread_mutex_unlock(&suspend_count_lock);
251			}
252			#endif
253
254
255			/*
256	cebix	1.1	* Initialize Time Manager
257			*/
258
259			void TimerInit(void)
260			{
261			// Mark all descriptors as inactive
262			for (int i=0; i<NUM_DESCS; i++)
263			free_desc(i);
264
265			#if PRECISE_TIMING
266			// Start timer thread
267	gbeauche	1.4	#ifdef PRECISE_TIMING_BEOS
268	cebix	1.1	wakeup_time_sem = create_sem(1, "Wakeup Time");
269			timer_thread = spawn_thread(timer_func, "Time Manager", B_REAL_TIME_PRIORITY, NULL);
270			resume_thread(timer_thread);
271			#endif
272	gbeauche	1.4	#ifdef PRECISE_TIMING_POSIX
273	gbeauche	1.5	timer_thread_active = timer_thread_init();
274	gbeauche	1.4	#endif
275			#endif
276	cebix	1.1	}
277
278
279			/*
280			* Exit Time Manager
281			*/
282
283			void TimerExit(void)
284			{
285			#if PRECISE_TIMING
286			// Quit timer thread
287			if (timer_thread > 0) {
288	gbeauche	1.4	#ifdef PRECISE_TIMING_BEOS
289	cebix	1.1	status_t l;
290			thread_active = false;
291			suspend_thread(timer_thread);
292			resume_thread(timer_thread);
293			wait_for_thread(timer_thread, &l);
294			delete_sem(wakeup_time_sem);
295	gbeauche	1.4	#endif
296			#ifdef PRECISE_TIMING_POSIX
297			timer_thread_kill();
298			#endif
299	cebix	1.1	}
300			#endif
301			}
302
303
304			/*
305			* Emulator reset, remove all timer tasks
306			*/
307
308			void TimerReset(void)
309			{
310			// Mark all descriptors as inactive
311			for (int i=0; i<NUM_DESCS; i++)
312			free_desc(i);
313			}
314
315
316			/*
317			* Insert timer task
318			*/
319
320			int16 InsTime(uint32 tm, uint16 trap)
321			{
322			D(bug("InsTime %08lx, trap %04x\n", tm, trap));
323			WriteMacInt16((uint32)tm + qType, ReadMacInt16((uint32)tm + qType) & 0x1fff \| (trap << 4) & 0x6000);
324			if (find_desc(tm) >= 0)
325			printf("WARNING: InsTime(): Task re-inserted\n");
326			else {
327			int i = alloc_desc(tm);
328			if (i < 0)
329			printf("FATAL: InsTime(): No free Time Manager descriptor\n");
330			}
331			return 0;
332			}
333
334
335			/*
336			* Remove timer task
337			*/
338
339			int16 RmvTime(uint32 tm)
340			{
341			D(bug("RmvTime %08lx\n", tm));
342
343			// Find descriptor
344			int i = find_desc(tm);
345			if (i < 0) {
346			printf("WARNING: RmvTime(%08lx): Descriptor not found\n", tm);
347			return 0;
348			}
349
350			// Task active?
351	gbeauche	1.4	#if PRECISE_TIMING_BEOS
352	cebix	1.1	while (acquire_sem(wakeup_time_sem) == B_INTERRUPTED) ;
353			suspend_thread(timer_thread);
354			#endif
355	gbeauche	1.4	#if PRECISE_TIMING_POSIX
356			timer_thread_suspend();
357	gbeauche	1.6	pthread_mutex_lock(&wakeup_time_lock);
358	gbeauche	1.4	#endif
359	cebix	1.1	if (ReadMacInt16(tm + qType) & 0x8000) {
360
361			// Yes, make task inactive and remove it from the Time Manager queue
362			WriteMacInt16(tm + qType, ReadMacInt16(tm + qType) & 0x7fff);
363			dequeue_tm(tm);
364			#if PRECISE_TIMING
365			// Look for next task to be called and set wakeup_time
366	gbeauche	1.4	wakeup_time = wakeup_time_max;
367	cebix	1.1	for (int j=0; j<NUM_DESCS; j++) {
368			if (desc[j].in_use && (ReadMacInt16(desc[j].task + qType) & 0x8000))
369	gbeauche	1.4	if (timer_cmp_time(desc[j].wakeup, wakeup_time) < 0)
370	cebix	1.1	wakeup_time = desc[j].wakeup;
371			}
372			#endif
373
374			// Compute remaining time
375			tm_time_t remaining, current;
376			timer_current_time(current);
377			timer_sub_time(remaining, desc[i].wakeup, current);
378			WriteMacInt32(tm + tmCount, timer_host2mac_time(remaining));
379			} else
380			WriteMacInt32(tm + tmCount, 0);
381			D(bug(" tmCount %ld\n", ReadMacInt32(tm + tmCount)));
382	gbeauche	1.4	#if PRECISE_TIMING_BEOS
383	cebix	1.1	release_sem(wakeup_time_sem);
384			thread_info info;
385			do {
386			resume_thread(timer_thread); // This will unblock the thread
387			get_thread_info(timer_thread, &info);
388			} while (info.state == B_THREAD_SUSPENDED); // Sometimes, resume_thread() doesn't work (BeOS bug?)
389			#endif
390	gbeauche	1.4	#if PRECISE_TIMING_POSIX
391	gbeauche	1.6	pthread_mutex_unlock(&wakeup_time_lock);
392	gbeauche	1.4	timer_thread_resume();
393			assert(suspend_count == 0);
394			#endif
395	cebix	1.1
396			// Free descriptor
397			free_desc(i);
398			return 0;
399			}
400
401
402			/*
403			* Start timer task
404			*/
405
406			int16 PrimeTime(uint32 tm, int32 time)
407			{
408			D(bug("PrimeTime %08lx, time %ld\n", tm, time));
409
410			// Find descriptor
411			int i = find_desc(tm);
412			if (i < 0) {
413			printf("FATAL: PrimeTime(): Descriptor not found\n");
414			return 0;
415			}
416
417			// Convert delay time
418			tm_time_t delay;
419			timer_mac2host_time(delay, time);
420
421			// Extended task?
422			if (ReadMacInt16(tm + qType) & 0x4000) {
423
424			// Yes, tmWakeUp set?
425			if (ReadMacInt32(tm + tmWakeUp)) {
426
427	asvitkine	1.9	// PrimeTime(0) can either mean (a) "the task runs as soon as interrupts are enabled"
428			// or (b) "continue previous delay" if an expired task was stopped via RmvTime() and
429	asvitkine	1.10	// then re-installed using InsXTime(). Since tmWakeUp was set, this is case (b).
430			// The remaining time was saved in tmCount by RmvTime().
431	asvitkine	1.11	if (time == 0) {
432			timer_mac2host_time(delay, ReadMacInt16(tm + tmCount));
433			}
434	cebix	1.1
435			// Yes, calculate wakeup time relative to last scheduled time
436			tm_time_t wakeup;
437			timer_add_time(wakeup, desc[i].wakeup, delay);
438			desc[i].wakeup = wakeup;
439
440			} else {
441
442			// No, calculate wakeup time relative to current time
443			tm_time_t now;
444			timer_current_time(now);
445			timer_add_time(desc[i].wakeup, now, delay);
446			}
447
448			// Set tmWakeUp to indicate that task was scheduled
449			WriteMacInt32(tm + tmWakeUp, 0x12345678);
450
451			} else {
452
453			// Not extended task, calculate wakeup time relative to current time
454			tm_time_t now;
455			timer_current_time(now);
456			timer_add_time(desc[i].wakeup, now, delay);
457			}
458
459			// Make task active and enqueue it in the Time Manager queue
460	gbeauche	1.4	#if PRECISE_TIMING_BEOS
461	cebix	1.1	while (acquire_sem(wakeup_time_sem) == B_INTERRUPTED) ;
462			suspend_thread(timer_thread);
463			#endif
464	gbeauche	1.4	#if PRECISE_TIMING_POSIX
465			timer_thread_suspend();
466	gbeauche	1.6	pthread_mutex_lock(&wakeup_time_lock);
467	gbeauche	1.4	#endif
468	cebix	1.1	WriteMacInt16(tm + qType, ReadMacInt16(tm + qType) \| 0x8000);
469			enqueue_tm(tm);
470			#if PRECISE_TIMING
471			// Look for next task to be called and set wakeup_time
472	gbeauche	1.4	wakeup_time = wakeup_time_max;
473	cebix	1.1	for (int j=0; j<NUM_DESCS; j++) {
474			if (desc[j].in_use && (ReadMacInt16(desc[j].task + qType) & 0x8000))
475	gbeauche	1.4	if (timer_cmp_time(desc[j].wakeup, wakeup_time) < 0)
476	cebix	1.1	wakeup_time = desc[j].wakeup;
477			}
478	gbeauche	1.4	#ifdef PRECISE_TIMING_BEOS
479	cebix	1.1	release_sem(wakeup_time_sem);
480			thread_info info;
481			do {
482			resume_thread(timer_thread); // This will unblock the thread
483			get_thread_info(timer_thread, &info);
484			} while (info.state == B_THREAD_SUSPENDED); // Sometimes, resume_thread() doesn't work (BeOS bug?)
485			#endif
486	gbeauche	1.4	#ifdef PRECISE_TIMING_POSIX
487	gbeauche	1.6	pthread_mutex_unlock(&wakeup_time_lock);
488	gbeauche	1.4	timer_thread_resume();
489			assert(suspend_count == 0);
490			#endif
491			#endif
492	cebix	1.1	return 0;
493			}
494
495
496			/*
497			* Time Manager thread
498			*/
499
500	gbeauche	1.4	#ifdef PRECISE_TIMING_BEOS
501	cebix	1.1	static int32 timer_func(void *arg)
502			{
503			while (thread_active) {
504
505			// Wait until time specified by wakeup_time
506			snooze_until(wakeup_time, B_SYSTEM_TIMEBASE);
507
508			while (acquire_sem(wakeup_time_sem) == B_INTERRUPTED) ;
509			if (wakeup_time < system_time()) {
510
511			// Timer expired, trigger interrupt
512			wakeup_time = 0x7fffffffffffffff;
513			SetInterruptFlag(INTFLAG_TIMER);
514			TriggerInterrupt();
515			}
516			release_sem(wakeup_time_sem);
517			}
518			return 0;
519			}
520			#endif
521
522	gbeauche	1.4	#ifdef PRECISE_TIMING_POSIX
523			static void timer_func(void arg)
524			{
525	gbeauche	1.5	while (!timer_thread_cancel) {
526	gbeauche	1.4
527			// Wait until time specified by wakeup_time
528			clock_nanosleep(CLOCK_REALTIME, TIMER_ABSTIME, &wakeup_time, NULL);
529
530			tm_time_t system_time;
531			timer_current_time(system_time);
532			if (timer_cmp_time(wakeup_time, system_time) < 0) {
533
534			// Timer expired, trigger interrupt
535	gbeauche	1.7	pthread_mutex_lock(&wakeup_time_lock);
536	gbeauche	1.4	wakeup_time = wakeup_time_max;
537	gbeauche	1.7	pthread_mutex_unlock(&wakeup_time_lock);
538	gbeauche	1.4	SetInterruptFlag(INTFLAG_TIMER);
539			TriggerInterrupt();
540			}
541			}
542			return NULL;
543			}
544			#endif
545
546	cebix	1.1
547			/*
548			* Timer interrupt function (executed as part of 60Hz interrupt)
549			*/
550
551			void TimerInterrupt(void)
552			{
553			// D(bug("TimerIRQ\n"));
554
555			// Look for active TMTasks that have expired
556			tm_time_t now;
557			timer_current_time(now);
558			for (int i=0; i<NUM_DESCS; i++)
559			if (desc[i].in_use) {
560			uint32 tm = desc[i].task;
561			if ((ReadMacInt16(tm + qType) & 0x8000) && timer_cmp_time(desc[i].wakeup, now) <= 0) {
562
563			// Found one, mark as inactive and remove it from the Time Manager queue
564			WriteMacInt16(tm + qType, ReadMacInt16(tm + qType) & 0x7fff);
565			dequeue_tm(tm);
566
567			// Call timer function
568			uint32 addr = ReadMacInt32(tm + tmAddr);
569			if (addr) {
570			D(bug("Calling TimeTask %08lx, addr %08lx\n", tm, addr));
571			M68kRegisters r;
572			r.a[0] = addr;
573			r.a[1] = tm;
574			Execute68k(r.a[0], &r);
575			D(bug(" returned from TimeTask\n"));
576			}
577			}
578			}
579
580			#if PRECISE_TIMING
581			// Look for next task to be called and set wakeup_time
582	gbeauche	1.4	#if PRECISE_TIMING_BEOS
583	cebix	1.1	while (acquire_sem(wakeup_time_sem) == B_INTERRUPTED) ;
584			suspend_thread(timer_thread);
585	gbeauche	1.4	#endif
586			#if PRECISE_TIMING_POSIX
587			timer_thread_suspend();
588	gbeauche	1.6	pthread_mutex_lock(&wakeup_time_lock);
589	gbeauche	1.4	#endif
590			wakeup_time = wakeup_time_max;
591	cebix	1.1	for (int j=0; j<NUM_DESCS; j++) {
592			if (desc[j].in_use && (ReadMacInt16(desc[j].task + qType) & 0x8000))
593	gbeauche	1.4	if (timer_cmp_time(desc[j].wakeup, wakeup_time) < 0)
594	cebix	1.1	wakeup_time = desc[j].wakeup;
595			}
596	gbeauche	1.4	#if PRECISE_TIMING_BEOS
597	cebix	1.1	release_sem(wakeup_time_sem);
598			thread_info info;
599			do {
600			resume_thread(timer_thread); // This will unblock the thread
601			get_thread_info(timer_thread, &info);
602			} while (info.state == B_THREAD_SUSPENDED); // Sometimes, resume_thread() doesn't work (BeOS bug?)
603			#endif
604	gbeauche	1.4	#if PRECISE_TIMING_POSIX
605	gbeauche	1.6	pthread_mutex_unlock(&wakeup_time_lock);
606	gbeauche	1.4	timer_thread_resume();
607			assert(suspend_count == 0);
608			#endif
609			#endif
610	cebix	1.1	}