posixcondition.cpp

来自「这是VCF框架的代码」· C++ 代码 · 共 128 行

//PosixCondition.cpp

/*
Copyright 2000-2004 The VCF Project.
Please see License.txt in the top level directory
where you installed the VCF.
*/


#include "vcf/FoundationKit/FoundationKit.h"
#include "vcf/FoundationKit/FoundationKitPrivate.h"
#include <sys/time.h>
#include <errno.h>

using namespace VCF;

PosixCondition::PosixCondition( Condition* condition )
{
    MutexPeer *mpeer = condition->getMutex()->getPeer();
    mutex_ = (pthread_mutex_t*)(mpeer->getHandleID());
    pthread_cond_init(&cond_, NULL);
}

PosixCondition::~PosixCondition()
{
    pthread_cond_destroy(&cond_);
}

int PosixCondition::wait()
{
    pthread_cond_wait(&cond_, mutex_);
	pthread_mutex_unlock(mutex_);
    return (int)true;
}

int PosixCondition::wait( uint32 milliseconds )
{
    int result;
    struct timespec timeout;
    struct timeval  now;
    unsigned int sec, usec;

	sec = milliseconds / 1000;
    milliseconds *= 1000;
    usec = milliseconds % 1000000;

    gettimeofday(&now, NULL);
    timeout.tv_sec = now.tv_sec + sec;
    timeout.tv_nsec = now.tv_usec + usec;
    timeout.tv_nsec *= 1000;
    if ( timeout.tv_nsec >= 1000000000 )
    {
        timeout.tv_sec++;
        timeout.tv_nsec -= 1000000000;
    }

    result = pthread_cond_timedwait(&cond_, mutex_, &timeout);
	pthread_mutex_unlock(mutex_);
    if ( result == 0 ) {
		return 1;
	}
    else if ( result == ETIMEDOUT ) {
		return 0;
	}
    else {
		return -1;
	}
}

void PosixCondition::signal()
{
    pthread_cond_signal(&cond_);
	pthread_mutex_unlock(mutex_);
}

void PosixCondition::broadcast()
{
    pthread_cond_broadcast(&cond_);
	pthread_mutex_unlock(mutex_);
}


/**
*CVS Log info
*$Log$
*Revision 1.3  2006/04/07 02:35:35  ddiego
*initial checkin of merge from 0.6.9 dev branch.
*
*Revision 1.2.6.1  2006/03/19 00:04:16  obirsoy
*Linux FoundationKit improvements.
*
*Revision 1.2  2004/08/07 02:49:14  ddiego
*merged in the devmain-0-6-5 branch to stable
*
*Revision 1.1.2.2  2004/04/29 04:07:12  marcelloptr
*reformatting of source files: macros and csvlog and copyright sections
*
*Revision 1.1.2.1  2004/04/28 03:29:40  ddiego
*migration towards new directory structure
*
*Revision 1.4  2004/04/03 15:48:47  ddiego
*Merged over code from the 0-6-3 branch.
*
*Revision 1.3.6.1  2004/03/30 01:48:26  ddiego
*updated linux code
*
*Revision 1.3  2003/05/17 20:37:34  ddiego
*this is the checkin for the 0.6.1 release - represents the merge over from
*the devmain-0-6-0 branch plus a few minor bug fixes
*
*Revision 1.2.2.1  2003/03/23 03:23:57  marcelloptr
*3 empty lines at the end of the files
*
*Revision 1.2  2003/02/26 04:30:49  ddiego
*merge of code in the devmain-0-5-9 branch into the current tree.
*most additions are in the area of the current linux port, but the major
*addition to this release is the addition of a Condition class (currently
*still under development) and the change over to using the Delegate class
*exclusively from the older event handler macros.
*
*Revision 1.1.2.1  2003/02/18 20:05:40  catwallader
*Added Condition classes. Also added comments to Thread and Mutex class
*headers.
*
**/