diff options
author | Stephan Bergmann <sbergman@redhat.com> | 2015-08-18 08:15:56 +0200 |
---|---|---|
committer | Stephan Bergmann <sbergman@redhat.com> | 2015-08-18 08:16:19 +0200 |
commit | 6b7c23b3fb6175c04fcc3f1e12b34bedf5f4e5f8 (patch) | |
tree | 91959d6f615adb2a9e8b019e2b0a012bf61a2f9b /io | |
parent | Some oslCondition -> osl::Condition (diff) | |
download | core-6b7c23b3fb6175c04fcc3f1e12b34bedf5f4e5f8.tar.gz core-6b7c23b3fb6175c04fcc3f1e12b34bedf5f4e5f8.zip |
Some oslCondition -> osl::Condition
Change-Id: Ib2c98db9ffd5871b6422c05f0230bbe27d1ba729
Diffstat (limited to 'io')
-rw-r--r-- | io/source/stm/opipe.cxx | 16 |
1 files 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; } |