firebird/firebird-mirror
firebird/firebird-mirror
8
0
Fork 1
mirror of https://github.com/FirebirdSQL/firebird.git synced 2025-01-23 18:03:04 +01:00
Code Issues

Protected from unexpected operations with a closed stream.

Browse Source
This commit is contained in:
dimitr 2013-12-11 17:11:47 +00:00
parent 82a1736390
commit f1139cc9ab
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/jrd/recsrc/ConditionalStream.cpp
View File

@ -93,6 +93,10 @@ bool ConditionalStream::refetchRecord(thread_db* tdbb) const
{
jrd_req* const request = tdbb->getRequest();
Impure* const impure = request->getImpure<Impure>(m_impure);
if (!(impure->irsb_flags & irsb_open))
return false;
return impure->irsb_next->refetchRecord(tdbb);
}
@ -100,6 +104,10 @@ bool ConditionalStream::lockRecord(thread_db* tdbb) const
{
jrd_req* const request = tdbb->getRequest();
Impure* const impure = request->getImpure<Impure>(m_impure);
if (!(impure->irsb_flags & irsb_open))
return false;
return impure->irsb_next->lockRecord(tdbb);
}
@ -141,13 +149,12 @@ void ConditionalStream::findUsedStreams(StreamList& streams, bool expandAll) con
void ConditionalStream::invalidateRecords(jrd_req* request) const
{
Impure* const impure = request->getImpure<Impure>(m_impure);
impure->irsb_next->invalidateRecords(request);
m_first->invalidateRecords(request);
m_second->invalidateRecords(request);
}
void ConditionalStream::nullRecords(thread_db* tdbb) const
{
jrd_req* const request = tdbb->getRequest();
Impure* const impure = request->getImpure<Impure>(m_impure);
impure->irsb_next->nullRecords(tdbb);
m_first->nullRecords(tdbb);
m_second->nullRecords(tdbb);
}