salhelper/source/condition.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: condition.cxx,v $
  10  * $Revision: 1.5 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31
  32 #include <salhelper/condition.hxx>
  33 #include <osl/time.h>
  34
  35
  36 using namespace salhelper;
  37
  38
  39 /******************************************************************
  40  *                                                                *
  41  *                     Condition                                  *
  42  *                                                                *
  43  ******************************************************************/
  44
  45 Condition::Condition(osl::Mutex& aMutex)
  46     : m_aMutex(aMutex),
  47       m_aCondition(osl_createCondition())
  48 {
  49 }
  50
  51
  52 Condition::~Condition()
  53 {
  54     osl_destroyCondition(m_aCondition);
  55 }
  56
  57
  58 /******************************************************************
  59  *                                                                *
  60  *              ConditionModifier                                 *
  61  *                                                                *
  62  ******************************************************************/
  63
  64 ConditionModifier::ConditionModifier(Condition& aCond)
  65     : m_aCond(aCond)
  66 {
  67     m_aCond.m_aMutex.acquire();
  68 }
  69
  70
  71 ConditionModifier::~ConditionModifier()
  72 {
  73     if(m_aCond.applies())
  74         osl_setCondition(m_aCond.m_aCondition);
  75
  76     m_aCond.m_aMutex.release();
  77 }
  78
  79
  80
  81 /******************************************************************
  82  *                                                                *
  83  *              ConditionWaiter                                   *
  84  *                                                                *
  85  ******************************************************************/
  86
  87 ConditionWaiter::timedout::timedout() {}
  88
  89 ConditionWaiter::timedout::timedout(timedout const &) {}
  90
  91 ConditionWaiter::timedout::~timedout() {}
  92
  93 ConditionWaiter::timedout &
  94 ConditionWaiter::timedout::operator =(timedout const &) { return *this; }
  95
  96 ConditionWaiter::ConditionWaiter(Condition& aCond)
  97     : m_aCond(aCond)
  98 {
  99     while(true) {
 100         osl_waitCondition(m_aCond.m_aCondition,0);
 101         m_aCond.m_aMutex.acquire();
 102
 103         if(m_aCond.applies())
 104             break;
 105         else {
 106             osl_resetCondition(m_aCond.m_aCondition);
 107             m_aCond.m_aMutex.release();
 108         }
 109     }
 110 }
 111
 112
 113 ConditionWaiter::ConditionWaiter(Condition& aCond,sal_uInt32 milliSec)
 114     throw(
 115         ConditionWaiter::timedout
 116     )
 117     : m_aCond(aCond)
 118 {
 119     TimeValue aTime;
 120     aTime.Seconds = milliSec / 1000;
 121     aTime.Nanosec = 1000000 * ( milliSec % 1000 );
 122
 123     while(true) {
 124         if( osl_waitCondition(m_aCond.m_aCondition,&aTime) ==
 125             osl_cond_result_timeout )
 126             throw timedout();
 127
 128         m_aCond.m_aMutex.acquire();
 129
 130         if(m_aCond.applies())
 131             break;
 132         else {
 133             osl_resetCondition(m_aCond.m_aCondition);
 134             m_aCond.m_aMutex.release();
 135         }
 136     }
 137 }
 138
 139
 140 ConditionWaiter::~ConditionWaiter()
 141 {
 142     if(! m_aCond.applies())
 143         osl_resetCondition(m_aCond.m_aCondition);
 144     m_aCond.m_aMutex.release();
 145 }