From 6b7c23b3fb6175c04fcc3f1e12b34bedf5f4e5f8 Mon Sep 17 00:00:00 2001 From: Stephan Bergmann Date: Tue, 18 Aug 2015 08:15:56 +0200 Subject: Some oslCondition -> osl::Condition Change-Id: Ib2c98db9ffd5871b6422c05f0230bbe27d1ba729 --- io/source/stm/opipe.cxx | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/io/source/stm/opipe.cxx b/io/source/stm/opipe.cxx index 4315a999c7a2..5c8af3e6e79c 100644 --- a/io/source/stm/opipe.cxx +++ b/io/source/stm/opipe.cxx @@ -116,7 +116,7 @@ private: bool m_bOutputStreamClosed; bool m_bInputStreamClosed; - oslCondition m_conditionBytesAvail; + osl::Condition m_conditionBytesAvail; Mutex m_mutexAccess; I_FIFO *m_pFIFO; }; @@ -131,12 +131,10 @@ OPipeImpl::OPipeImpl() m_bInputStreamClosed = false; m_pFIFO = new MemFIFO; - m_conditionBytesAvail = osl_createCondition(); } OPipeImpl::~OPipeImpl() { - osl_destroyCondition( m_conditionBytesAvail ); delete m_pFIFO; } @@ -164,7 +162,7 @@ sal_Int32 OPipeImpl::readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRe if( nOccupiedBufferLen < nBytesToRead ) { // wait outside guarded section - osl_resetCondition( m_conditionBytesAvail ); + m_conditionBytesAvail.reset(); } else { // necessary bytes are available @@ -174,7 +172,7 @@ sal_Int32 OPipeImpl::readBytes(Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRe } // end guarded section // wait for new data outside guarded section! - osl_waitCondition( m_conditionBytesAvail , 0 ); + m_conditionBytesAvail.wait(); } } @@ -208,7 +206,7 @@ sal_Int32 OPipeImpl::readSomeBytes(Sequence< sal_Int8 >& aData, sal_Int32 nMaxBy } } - osl_waitCondition( m_conditionBytesAvail , 0 ); + m_conditionBytesAvail.wait(); } } @@ -268,7 +266,7 @@ void OPipeImpl::closeInput() m_pFIFO = 0; // readBytes may throw an exception - osl_setCondition( m_conditionBytesAvail ); + m_conditionBytesAvail.set(); setSuccessor( Reference< XConnectable > () ); return; @@ -334,7 +332,7 @@ void OPipeImpl::writeBytes(const Sequence< sal_Int8 >& aData) } // readBytes may check again if enough bytes are available - osl_setCondition( m_conditionBytesAvail ); + m_conditionBytesAvail.set(); } @@ -355,7 +353,7 @@ void OPipeImpl::closeOutput() MutexGuard guard( m_mutexAccess ); m_bOutputStreamClosed = true; - osl_setCondition( m_conditionBytesAvail ); + m_conditionBytesAvail.set(); setPredecessor( Reference < XConnectable > () ); return; } -- cgit v1.2.3