timer.c

在ｅｃｏｓ 下mingui 的移植开发

//
// timer.c: The Timer module.
//
// Copyright (C) 1999, Wei Yongming.
//
// Current maintainer: Wei Yongming.
//
// NOTE:
// Some idea come from MyLib by Indrek Mandre.
// 

/*
**  This library is free software; you can redistribute it and/or
**  modify it under the terms of the GNU Library General Public
**  License as published by the Free Software Foundation; either
**  version 2 of the License, or (at your option) any later version.
**
**  This library 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
**  Library General Public License for more details.
**
**  You should have received a copy of the GNU Library General Public
**  License along with this library; if not, write to the Free
**  Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
**  MA 02111-1307, USA
*/

// Create date: 1999.04.21
//
// Modify records:
//
//  Who             When        Where       For What                Status
//-----------------------------------------------------------------------------
//  Wei Yongming    1999.10.05  Tsinghua    Timer as a thread       Working
//
// TODO:
// 

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>

#include <signal.h>
#include <unistd.h>
#include <cyg/kernel/kapi.h>	// for cyg_thread_delay

#include "common.h"
#include "gdi.h"
#include "window.h"
#include "cliprect.h"
#include "gal.h"
#include "internals.h"
#include "timer.h"

#ifndef lint
static char fileid[] = "$Id: timer.c,v 1.8 2000/11/20 05:46:45 ymwei Exp $";
#endif

extern MSGQUEUE DskMsgs;

unsigned int timer_counter = 0;

static TIMER *timerstr[MAX_TIMERS];

PMAINWIN MainWindow (HWND hWnd);

char mytimer_thread_stack[PTHREAD_STACK_MIN*8];
static pthread_t mytimer;
            
static void* myTimerThread (void* data)
{
    int sem_value;

    while(1) {
        cyg_thread_delay(1);	// 10ms
        timer_counter++;

        // alert desktop
        DskMsgs.dwState |= 0x01;
        sem_getvalue (&DskMsgs.wait, &sem_value);
        if (sem_value == 0)
            sem_post (&DskMsgs.wait);
   }         
}

BOOL InitTimer ()
{
    pthread_attr_t attr;
    timer_counter = 0;
    pthread_attr_init( &attr );
    pthread_attr_setstackaddr( &attr, (void *)&mytimer_thread_stack[sizeof(mytimer_thread_stack)] );
    pthread_attr_setstacksize( &attr, sizeof(mytimer_thread_stack) );
    pthread_create(&mytimer, &attr, myTimerThread, 0);
    return TRUE;
}

BOOL TerminateTimer ()
{
    int i;

    pthread_cancel(mytimer);

    for (i=0; i<MAX_TIMERS; i++) {
        if (timerstr[i] != NULL)
            free ( timerstr[i] );
        timerstr[i] = NULL;
    }

    return 1;
}

/************************* Functions run in desktop thread *******************/
void DispatchTimerMessage ()
{
    PMAINWIN pWin;
    PMSGQUEUE pMsgQueue;
    int i, slot;
    int sem_value;

    for ( i=0; i<MAX_TIMERS; i++ ) {
        if ( timerstr[i] ) {
#if _TIMER_UNIT_10MS
    	    timerstr[i]->count += 1;
#else
    	    timerstr[i]->count += 1<<7;
#endif
            if ( timerstr[i]->count >= timerstr[i]->speed ) {

                pWin = MainWindow (timerstr[i]->hWnd);
                pMsgQueue = pWin->pMessages;

                pthread_mutex_lock (&pMsgQueue->lock);
                for (slot=0; slot<8; slot++) {
                    if (pMsgQueue->TimerID[slot] == timerstr[i]->id
                        && pMsgQueue->TimerOwner[slot] == timerstr[i]->hWnd)
                        break;
                }
                if (slot != 8) {
                    pMsgQueue->dwState |= (0x01 << slot);
                    sem_getvalue (&pMsgQueue->wait, &sem_value);
                    if (sem_value == 0)
                        sem_post(&pMsgQueue->wait);
                }
                pthread_mutex_unlock (&pMsgQueue->lock);
                
                timerstr[i]->count -= timerstr[i]->speed;
            }
        }
    }
}

BOOL AddTimer (HWND hWnd, int id, int speed)
{
#if 0
    sigset_t sa_mask;
#endif

    int i;
    PMAINWIN pWin;
    PMSGQUEUE pMsgQueue;
    int slot;

    // Is this window a main window?
    if (!(pWin = MainWindow (hWnd))) return FALSE;

#if 0
    // block SIGALRM temporarily
    sigemptyset (&sa_mask);
    sigaddset (&sa_mask, SIGALRM);
    pthread_sigmask (SIG_BLOCK, &sa_mask, NULL);
#endif

    pMsgQueue = pWin->pMessages;
    // Is there a empty timer slot?
    for (slot=0; slot<8; slot++) {
        if ((pMsgQueue->TimerMask >> slot) & 0x01)
            break;
    }
    if (slot == 8) goto badret;

    for (i=0; i<MAX_TIMERS; i++)
        if ( timerstr[i] != NULL )
            if ( timerstr[i]->hWnd == hWnd && timerstr[i]->id == id)
                goto badret;

    for (i=0; i<MAX_TIMERS; i++)
        if ( timerstr[i] == NULL )
            break;

    if (i == MAX_TIMERS)
        goto badret ;

    timerstr[i] = malloc (sizeof (TIMER));

#if _TIMER_UNIT_10MS
    timerstr[i]->speed = speed;
#else
    timerstr[i]->speed = (1000<<7)/speed;
#endif
    timerstr[i]->hWnd = hWnd;
    timerstr[i]->id = id;
    timerstr[i]->count = 0;

    pMsgQueue->TimerOwner[slot] = hWnd;
    pMsgQueue->TimerID[slot] = id;
    pMsgQueue->TimerMask &= ~(0x01 << slot);

#if 0
    // unblock SIGALRM
    pthread_sigmask (SIG_UNBLOCK, &sa_mask, NULL);
#endif

    return TRUE;
    
badret:

#if 0
    // unblock SIGALRM
    pthread_sigmask (SIG_UNBLOCK, &sa_mask, NULL);
#endif

    return FALSE;
}

BOOL RemoveTimer (HWND hWnd, int id)
{
#if 0
    sigset_t sa_mask;
#endif

    int i;
    PMAINWIN pWin;
    PMSGQUEUE pMsgQueue;
    int slot;
    void* temp;

    // Is this window a main window?
    if (!(pWin = MainWindow (hWnd))) return FALSE;

#if 0
    // block SIGALRM temporarily
    sigemptyset (&sa_mask);
    sigaddset (&sa_mask, SIGALRM);
    pthread_sigmask (SIG_BLOCK, &sa_mask, NULL);
#endif
    
    pMsgQueue = pWin->pMessages;
    for (slot=0; slot<8; slot++) {
        if (pMsgQueue->TimerID[slot] == id)
            break;
    }
    if (slot == 8) goto badret;

    for (i=0; i<MAX_TIMERS; i++)
        if (timerstr[i] != NULL)
            if (timerstr[i]->hWnd == hWnd && timerstr[i]->id == id)
                break;

    if (i == MAX_TIMERS) goto badret;
    
    temp = timerstr[i];
    timerstr[i] = NULL;
    free (temp);

    pMsgQueue->TimerMask |= (0x01 << slot);

#if 0
    // unblock SIGALRM
    pthread_sigmask (SIG_UNBLOCK, &sa_mask, NULL);
#endif
    
    return TRUE;

badret:
#if 0
    // unblock SIGALRM
    pthread_sigmask (SIG_UNBLOCK, &sa_mask, NULL);
#endif

    return FALSE;
}

BOOL GUIAPI IsTimerInstalled (HWND hWnd, int id)
{
    int i;

#if 0
    sigset_t sa_mask;

    // block SIGALRM temporarily
    sigemptyset (&sa_mask);
    sigaddset (&sa_mask, SIGALRM);
    pthread_sigmask (SIG_BLOCK, &sa_mask, NULL);
#endif

    for (i=0; i<MAX_TIMERS; i++) {
        if ( timerstr[i] != NULL ) {
            if ( timerstr[i]->hWnd == hWnd && timerstr[i]->id == id) {
#if 0
                pthread_sigmask (SIG_UNBLOCK, &sa_mask, NULL);
#endif
                return TRUE;
            }
        }
    }

#if 0
    pthread_sigmask (SIG_UNBLOCK, &sa_mask, NULL);
#endif

    return FALSE;
}

BOOL SetTimerSpeed (HWND hWnd, int id, int speed)
{
    int i;
    
#if 0
    sigset_t sa_mask;

    // block SIGALRM temporarily
    sigemptyset (&sa_mask);
    sigaddset (&sa_mask, SIGALRM);
    pthread_sigmask (SIG_BLOCK, &sa_mask, NULL);
#endif

    for (i=0; i<MAX_TIMERS; i++)
	if (timerstr[i]->hWnd == hWnd && timerstr[i]->id == id) {
#if _TIMER_UNIT_10MS
		timerstr[i]->speed = speed;
#else
		timerstr[i]->speed = (1000<<7)/speed;
#endif
		timerstr[i]->count = 0;
#if 0
        pthread_sigmask (SIG_UNBLOCK, &sa_mask, NULL);
#endif
        return TRUE;
	}

#if 0
    pthread_sigmask (SIG_UNBLOCK, &sa_mask, NULL);
#endif

    return FALSE;
}

/****************** Timer Interfaces for applications ************************/
unsigned int GUIAPI GetTickCount ()
{
    return timer_counter;
}

BOOL GUIAPI SetTimer (HWND hWnd, int id, int speed)
{
    TIMER timer;
    
    timer.hWnd = hWnd;
    timer.id = id;
    timer.speed = speed;
    
    return SendMessage (HWND_DESKTOP, MSG_ADDTIMER, 0, (LPARAM)&timer);
}

BOOL GUIAPI KillTimer (HWND hWnd, int id)
{
    TIMER timer;
    
    timer.hWnd = hWnd;
    timer.id = id;
    
    return SendMessage (HWND_DESKTOP, MSG_REMOVETIMER, 0, (LPARAM)&timer);
}

BOOL GUIAPI ResetTimer (HWND hWnd, int id, int speed)
{
    TIMER timer;
    
    timer.hWnd = hWnd;
    timer.id = id;
    timer.speed = speed;
    
    return SendMessage (HWND_DESKTOP, MSG_RESETTIMER, 0, (LPARAM)&timer);
}