summaryrefslogtreecommitdiff
path: root/io
diff options
context:
space:
mode:
authorStephan Bergmann <sbergman@redhat.com>2015-08-18 08:15:56 +0200
committerStephan Bergmann <sbergman@redhat.com>2015-08-18 08:16:19 +0200
commit6b7c23b3fb6175c04fcc3f1e12b34bedf5f4e5f8 (patch)
tree91959d6f615adb2a9e8b019e2b0a012bf61a2f9b /io
parent88f12d9c7e58a3465f4d9a50fafb9e47fe67c537 (diff)
Some oslCondition -> osl::Condition
Change-Id: Ib2c98db9ffd5871b6422c05f0230bbe27d1ba729
Diffstat (limited to 'io')
-rw-r--r--io/source/stm/opipe.cxx16
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;
}