/* $Id$
*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to you under the Apache License, Version
* 2.0 (the "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/


#ifdef CONDVAR_INC_HEADER
#include <pthread.h>
#include <time.h>
#include <errno.h>
#endif

#ifdef CONDVAR_INC_MEMBER
private:
  pthread_cond_t mCond;
  pthread_condattr_t mCondAttr;
#endif

#ifdef CONDVAR_INC_IMPL
  inline CondVar::CondVar()
  {
    pthread_condattr_init(&mCondAttr);
    pthread_cond_init(&mCond,&mCondAttr);
  }
  inline CondVar::~CondVar()
  {
    pthread_cond_destroy(&mCond);
    pthread_condattr_destroy(&mCondAttr);
  }
  inline status_t CondVar::signal()
  {
    if(pthread_cond_signal(&mCond) == 0)
    {
      return CAPU_OK;
    }
    else
    {
      return CAPU_ERROR;
    }
  }
  inline status_t CondVar::broadcast()
  {
    if(pthread_cond_broadcast(&mCond) == 0)
    {
      return CAPU_OK;
    }
    else
    {
      return CAPU_ERROR;
    }
  }
  inline status_t CondVar::wait(Mutex *mutex, uint32_t millisec)
  {
    if(mutex == NULL)
    {
      return CAPU_EINVAL;
    }

    if(millisec != 0)
    {
      timespec _time;
      if(clock_gettime(CLOCK_REALTIME, &_time) < 0)
      {
        return CAPU_ERROR;
      }
      _time.tv_sec += (millisec/1000);
      _time.tv_nsec += ((millisec%1000)* 1000000);
      int32_t ret = pthread_cond_timedwait(&mCond, &mutex->mLock, &_time);

      switch(ret)
      {
        case 0:
          return CAPU_OK;
        case ETIMEDOUT:
          return CAPU_ETIMEOUT;
        default:
          return CAPU_ERROR;
      }
    }
    else
    {
      if(pthread_cond_wait(&mCond, &mutex->mLock) == 0)
      {
        return CAPU_OK;
      }
      else
      {
        return CAPU_ERROR;
      }
    }
  }
#endif