dnxSleep.c

Go to the documentation of this file.

/*--------------------------------------------------------------------------
 
   Copyright (c) 2006-2007, Intellectual Reserve, Inc. All rights reserved.
 
   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License version 2 as 
   published by the Free Software Foundation.
 
   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 "dnxSleep.h"

#include <errno.h>
#include <string.h>
#include <time.h>

#if HAVE_CONFIG_H
# include "config.h"
# ifndef HAVE_NANOSLEEP
#  include <sys/time.h>
#  include <pthread.h>
# endif
#endif

/*--------------------------------------------------------------------------
                                 INTERFACE
  --------------------------------------------------------------------------*/

void dnxCancelableSleep(int msecs)
{
#if HAVE_NANOSLEEP
   struct timespec rqt;
   rqt.tv_sec = msecs / 1000;
   rqt.tv_nsec = (msecs % 1000) * 1000L * 1000L;
   while (nanosleep(&rqt, &rqt) == -1 && errno == EINTR)
      ;
#else
   pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
   pthread_cond_t cv  = PTHREAD_COND_INITIALIZER;
   struct timeval now;              // time when we started waiting
   struct timespec timeout;         // timeout value for the wait function

   pthread_mutex_lock(&mutex);

   // timeval uses micro-seconds; timespec uses nano-seconds; 1us == 1000ns.
   gettimeofday(&now, 0);
   timeout.tv_sec = now.tv_sec + (msecs / 1000);
   timeout.tv_nsec = (now.tv_usec + (msecs % 1000) * 1000L) * 1000L;
   pthread_cond_timedwait(&cv, &mutex, &timeout);

   pthread_mutex_unlock(&mutex);
#endif
}

/*--------------------------------------------------------------------------*/