Skip to content

Commit 8cc386a

Browse files
committed
Yet another replication postfix
1 parent aa29e8a commit 8cc386a

File tree

2 files changed

+8
-10
lines changed

2 files changed

+8
-10
lines changed

src/jrd/replication/Applier.cpp

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -623,7 +623,7 @@ void Applier::insertRecord(thread_db* tdbb, TraNumber traNum,
623623

624624
#ifdef RESOLVE_CONFLICTS
625625
index_desc idx;
626-
const auto indexed = lookupRecord(tdbb, relation, record, m_bitmap, idx);
626+
const auto indexed = lookupRecord(tdbb, relation, record, idx);
627627

628628
AutoPtr<Record> cleanup;
629629

@@ -720,7 +720,7 @@ void Applier::updateRecord(thread_db* tdbb, TraNumber traNum,
720720
}
721721

722722
index_desc idx;
723-
const auto indexed = lookupRecord(tdbb, relation, orgRecord, m_bitmap, idx);
723+
const auto indexed = lookupRecord(tdbb, relation, orgRecord, idx);
724724

725725
bool found = false;
726726
AutoPtr<Record> cleanup;
@@ -846,7 +846,7 @@ void Applier::deleteRecord(thread_db* tdbb, TraNumber traNum,
846846
record->copyDataFrom(data);
847847

848848
index_desc idx;
849-
const bool indexed = lookupRecord(tdbb, relation, record, m_bitmap, idx);
849+
const bool indexed = lookupRecord(tdbb, relation, record, idx);
850850

851851
bool found = false;
852852
AutoPtr<Record> cleanup;
@@ -1066,15 +1066,14 @@ bool Applier::compareKey(thread_db* tdbb, jrd_rel* relation, const index_desc& i
10661066

10671067
bool Applier::lookupRecord(thread_db* tdbb,
10681068
jrd_rel* relation, Record* record,
1069-
RecordBitmap* bitmap,
10701069
index_desc& idx)
10711070
{
1072-
RecordBitmap::reset(bitmap);
1071+
RecordBitmap::reset(m_bitmap);
10731072

10741073
// Special case: RDB$DATABASE has no keys but it's guaranteed to have only one record
10751074
if (relation->rel_id == rel_database)
10761075
{
1077-
RBM_SET(tdbb->getDefaultPool(), &bitmap, 0);
1076+
RBM_SET(tdbb->getDefaultPool(), &m_bitmap, 0);
10781077
return false;
10791078
}
10801079

@@ -1092,7 +1091,7 @@ bool Applier::lookupRecord(thread_db* tdbb,
10921091
IndexRetrieval retrieval(relation, &idx, idx.idx_count, &key);
10931092
retrieval.irb_generic = irb_equality | (idx.idx_flags & idx_descending ? irb_descending : 0);
10941093

1095-
BTR_evaluate(tdbb, &retrieval, &bitmap, NULL);
1094+
BTR_evaluate(tdbb, &retrieval, &m_bitmap, NULL);
10961095
return true;
10971096
}
10981097

@@ -1147,7 +1146,7 @@ bool Applier::lookupRecord(thread_db* tdbb,
11471146
}
11481147

11491148
if (matched)
1150-
bitmap->set(rpb.rpb_number.getValue());
1149+
RBM_SET(tdbb->getDefaultPool(), &m_bitmap, rpb.rpb_number.getValue());
11511150
}
11521151

11531152
delete rpb.rpb_record;

src/jrd/replication/Applier.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -190,8 +190,7 @@ namespace Jrd
190190
const index_desc& idx,
191191
Record* record1, Record* record2);
192192
bool lookupRecord(thread_db* tdbb, jrd_rel* relation,
193-
Record* record, RecordBitmap* bitmap,
194-
index_desc& idx);
193+
Record* record, index_desc& idx);
195194

196195
const Format* findFormat(thread_db* tdbb, jrd_rel* relation, ULONG length);
197196

0 commit comments

Comments
 (0)