Method cryptThreadRoutine

src/jrd/CryptoManager.cpp:1003–1160

	}

	void CryptoManager::cryptThreadRoutine()
	{
		FbLocalStatus status_vector;
		bool lckRelease = false;

		try
		{
			// Try to take crypt mutex
			// If can't take that mutex - nothing to do, cryptThread already runs in our process
			MutexEnsureUnlock guard(cryptThreadMtx, FB_FUNCTION);
			if (!guard.tryEnter())
			{
				return;
			}

			// Establish temp context needed to take crypt thread lock
			ThreadContextHolder tempDbb(&dbb, nullptr, &status_vector);

			// Take exclusive threadLock
			// If can't take that lock - nothing to do, cryptThread already runs somewhere
			if (!LCK_lock(tempDbb, threadLock, LCK_EX, LCK_NO_WAIT))
				return;

			try
			{
				// Set running flag
				AutoSetRestore<bool> runFlag(&run, true);

				// Establish context
				// Need real attachment in order to make classic mode happy
				ClumpletWriter writer(ClumpletReader::dpbList, MAX_DPB_SIZE);
				writer.insertString(isc_dpb_user_name, DBA_USER_NAME);
				writer.insertByte(isc_dpb_no_db_triggers, TRUE);
				writer.insertInt(isc_dpb_worker_attach, 1);

				// Avoid races with release_attachment() in jrd.cpp
				XThreadEnsureUnlock releaseGuard(dbb.dbb_thread_mutex, FB_FUNCTION);
				releaseGuard.enter();

				if (!down())
				{
					AutoPlugin<JProvider> jInstance(JProvider::getInstance());
					jInstance->setDbCryptCallback(&status_vector, dbb.dbb_callback);
					check(&status_vector);

					RefPtr<JAttachment> jAtt(REF_NO_INCR, jInstance->attachDatabase(&status_vector,
						dbb.dbb_database_name.c_str(), writer.getBufferLength(), writer.getBuffer()));
					check(&status_vector);

					AttSyncLockGuard attGuard(*(jAtt->getStable()->getSync()), FB_FUNCTION);
					Attachment* att = jAtt->getHandle();
					if (!att)
						Arg::Gds(isc_att_shutdown).raise();
					att->att_flags |= ATT_from_thread;
					releaseGuard.leave();

					ThreadContextHolder tdbb(att->att_database, att, &status_vector);
					tdbb->markAsSweeper();