617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan/*******************************************************************************
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * Copyright (C) 2004-2008 Intel Corp. All rights reserved.
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan *
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * Redistribution and use in source and binary forms, with or without
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * modification, are permitted provided that the following conditions are met:
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan *
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * - Redistributions of source code must retain the above copyright notice,
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * this list of conditions and the following disclaimer.
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan *
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * - Redistributions in binary form must reproduce the above copyright notice,
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * this list of conditions and the following disclaimer in the documentation
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * and/or other materials provided with the distribution.
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan *
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * - Neither the name of Intel Corp. nor the names of its
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * contributors may be used to endorse or promote products derived from this
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * software without specific prior written permission.
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan *
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS ``AS IS''
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * ARE DISCLAIMED. IN NO EVENT SHALL Intel Corp. OR THE CONTRIBUTORS
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan * POSSIBILITY OF SUCH DAMAGE.
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan *******************************************************************************/
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan//////////////////////////////////////////////////////////////////////////
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan// EventLinux.cpp
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan//
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan// This file contains the linux implementation of the Event class
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan//////////////////////////////////////////////////////////////////////////
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan#ifdef HAVE_CONFIG_H
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan#include "config.h"
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan#endif
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan#include "Event.h"
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan#include "SPtr.h"
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan#include <pthread.h>
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan#include <cerrno>
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan#include <sys/time.h>
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan#include <iostream>
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Loganclass OSEvent_s
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan{
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Loganpublic:
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan OSEvent_s()
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_init(&_mut, NULL);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_cond_init(&_cond, NULL);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _set = false;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan }
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan ~OSEvent_s()
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_cond_destroy(&_cond);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_destroy(&_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan }
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_t _mut;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_cond_t _cond;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan bool _set;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan};
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Loganclass OSEvent
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan{
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Loganpublic:
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan OSEvent()
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _ose = SPtr<OSEvent_s>(new OSEvent_s);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan }
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan ~OSEvent()
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _ose = SPtr<OSEvent_s>(NULL);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan }
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan SPtr<OSEvent_s> _ose;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan};
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark LoganEvent::Event(bool manual)
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan{
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent = new OSEvent;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan /*
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent->ose->_set = false;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_init(&_osEvent->ose->_mut, NULL);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_cond_init(&_osEvent->ose->_cond, NULL);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan */
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan}
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark LoganEvent::Event(const Event &rhs)
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan{
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent = new OSEvent;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent->_ose = rhs._osEvent->_ose;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan /*
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent->_mut = rhs._osEvent->_mut;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent->_cond = rhs._osEvent->_cond;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan */
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan}
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark LoganEvent::~Event()
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan{
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan /*
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_cond_destroy(&_osEvent->ose->_cond);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_destroy(&_osEvent->ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan */
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan delete _osEvent;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan}
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Loganbool Event::wait(unsigned long msecs_p)
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan{
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan int retcode = 0;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan if (msecs_p != WAIT_INFINITE) {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan timeval now;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan timespec timeout, time;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan gettimeofday(&now, NULL);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan time.tv_sec = msecs_p / 1000;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan time.tv_nsec = (msecs_p % 1000) * 1000000;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan timeout.tv_sec = now.tv_sec + time.tv_sec;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan timeout.tv_nsec = now.tv_usec + time.tv_nsec;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_lock(&_osEvent->_ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan //printf("@@@@ Event (%p) wait (cond %p), set: %d (to %d)\n",
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan // this, &_osEvent->_ose->_cond, _osEvent->_ose->_set, msecs_p);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan if (!_osEvent->_ose->_set) {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan retcode = pthread_cond_timedwait(&_osEvent->_ose->_cond,
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan &_osEvent->_ose->_mut,
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan &timeout);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan //printf("@@@@ Event (%p) after wait, set: %d\n", this, _osEvent->_ose->_set);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent->_ose->_set = false;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan }
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan //printf("@@@@ Event (%p) after wait, set: %d\n", this, _osEvent->_ose->_set);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_unlock(&_osEvent->_ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan if (retcode == ETIMEDOUT) {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan return false;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan } else {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan return true;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan }
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan } else {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_lock(&_osEvent->_ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan //printf("@@@@ Event (%p) wait (cond %p), set: %d\n",
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan // this, &_osEvent->_ose->_cond, _osEvent->_ose->_set);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan if (!_osEvent->_ose->_set) {
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_cond_wait(&_osEvent->_ose->_cond, &_osEvent->_ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan }
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent->_ose->_set = false;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan //printf("@@@@ Event (%p) after wait, set: %d\n", this, _osEvent->_ose->_set);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_unlock(&_osEvent->_ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan return true;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan }
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan}
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Loganvoid Event::set()
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan{
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_lock(&_osEvent->_ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_cond_signal(&_osEvent->_ose->_cond);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan //printf("@@@@ Event (%p) set (cond %p)\n", this, &_osEvent->_ose->_cond);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent->_ose->_set = true;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_unlock(&_osEvent->_ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan}
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Loganvoid Event::reset()
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan{
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_lock(&_osEvent->_ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan // only way to reset the condition is to destroy it and restart it
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_cond_destroy(&_osEvent->_ose->_cond);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_cond_init(&_osEvent->_ose->_cond, NULL);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan _osEvent->_ose->_set = false;
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan pthread_mutex_unlock(&_osEvent->_ose->_mut);
617e2443dfc17fe44fd44c0675d6aad2ffc9df42Mark Logan}