Backported fix for bug #8817 : Fatal lock manager error: invalid lock id

Author: hvlad

src/jrd/Relation.h

@@ -400,6 +400,7 @@ const ULONG REL_jrd_view				= 0x10000;	// relation is VIEW
 const ULONG REL_gc_blocking				= 0x20000;	// request to downgrade\release gc lock
 const ULONG REL_gc_disabled				= 0x40000;	// gc is disabled temporarily
 const ULONG REL_gc_lockneed				= 0x80000;	// gc lock should be acquired
+const ULONG REL_rescan					= 0x100000;	// rescan request was submitted while relation being scanning
 
 
 /// class jrd_rel

src/jrd/dfw.epp

@@ -6117,8 +6117,15 @@ static bool make_version(thread_db* tdbb, SSHORT phase, DeferredWork* work, jrd_
 		DFW_post_work(transaction, dfw_scan_relation, NULL, relation->rel_id);
 
 		// signal others about new format presence
-		LCK_lock(tdbb, relation->rel_rescan_lock, LCK_EX, LCK_WAIT);
 		LCK_release(tdbb, relation->rel_rescan_lock);
+		{
+			// Use temp lock to avoid AST call
+			Lock tmpLock(tdbb, sizeof(SLONG), LCK_rel_rescan);
+			tmpLock.lck_key.lck_long = relation->rel_id;
+
+			LCK_lock(tdbb, &tmpLock, LCK_EX, LCK_WAIT);
+			LCK_release(tdbb, &tmpLock);
+		}
 
 		break;
 	}

src/jrd/met.epp

@@ -126,6 +126,7 @@ static void save_trigger_data(thread_db*, TrigVector**, jrd_rel*, JrdStatement*,
 	const TEXT*, FB_UINT64, bool, USHORT, const MetaName&, const string&,
 	const bid*);
 static void scan_partners(thread_db*, jrd_rel*);
+static void scan_relation(thread_db*, jrd_rel*);
 static void store_dependencies(thread_db*, CompilerScratch*, const jrd_rel*,
 	const MetaName&, int, jrd_tra*);
 static bool verify_TRG_ignore_perm(thread_db*, const MetaName&);
@@ -3800,6 +3801,27 @@ void MET_scan_relation(thread_db* tdbb, jrd_rel* relation)
  *      Scan a relation for view RecordSelExpr, computed by expressions, missing
  *      expressions, and validation expressions.
  *
+ **************************************/
+
+	while (!(relation->rel_flags & (REL_scanned | REL_deleted)))
+	{
+		scan_relation(tdbb, relation);
+	}
+}
+
+
+static void scan_relation(thread_db* tdbb, jrd_rel* relation)
+{
+/**************************************
+ *
+ *      s c a n _ r e l a t i o n
+ *
+ **************************************
+ *
+ * Functional description
+ *      Scan a relation for view RecordSelExpr, computed by expressions, missing
+ *      expressions, and validation expressions.
+ *
  **************************************/
 	SET_TDBB(tdbb);
 	TrigVector* triggers[TRIGGER_MAX];
@@ -3819,10 +3841,13 @@ void MET_scan_relation(thread_db* tdbb, jrd_rel* relation)
 
 	try {
 
-	if (relation->rel_flags & (REL_scanned | REL_deleted))
-		return;
+	fb_assert(!(relation->rel_flags & (REL_scanned | REL_deleted)));
 
 	relation->rel_flags |= REL_being_scanned;
+
+	LCK_lock(tdbb, relation->rel_rescan_lock, LCK_SR, LCK_WAIT);
+	relation->rel_flags &= ~REL_rescan;
+
 	dependencies = (relation->rel_flags & REL_get_dependencies) ? true : false;
 	sys_triggers = (relation->rel_flags & REL_sys_triggers) ? true : false;
 	relation->rel_flags &= ~(REL_get_dependencies | REL_sys_triggers);
@@ -4128,9 +4153,14 @@ void MET_scan_relation(thread_db* tdbb, jrd_rel* relation)
 		MET_release_triggers(tdbb, &tmp_vector);
 	}
 
-	LCK_lock(tdbb, relation->rel_rescan_lock, LCK_SR, LCK_WAIT);
 	relation->rel_flags &= ~REL_being_scanned;
 
+	if (relation->rel_flags & REL_rescan)
+	{
+		LCK_release(tdbb, relation->rel_rescan_lock);
+		relation->rel_flags &= ~(REL_scanned | REL_rescan);
+	}
+
 	relation->rel_current_format = NULL;
 
 	}	// try
@@ -4424,8 +4454,13 @@ static int rescan_ast_relation(void* ast_object)
 
 		AsyncContextHolder tdbb(dbb, FB_FUNCTION, relation->rel_rescan_lock);
 
-		LCK_release(tdbb, relation->rel_rescan_lock);
-		relation->rel_flags &= ~REL_scanned;
+		if (relation->rel_flags & REL_being_scanned)
+			relation->rel_flags |= REL_rescan;
+		else
+		{
+			LCK_release(tdbb, relation->rel_rescan_lock);
+			relation->rel_flags &= ~REL_scanned;
+		}
 	}
 	catch (const Firebird::Exception&)
 	{} // no-op