void process_update_prepared_statement_requests()

in src/afs.cc [3380:3438]

• 59 lines of code
• 6 McCabe index (conditional complexity)

	void process_update_prepared_statement_requests()
	{
#ifdef AFS_VERBOSE
		const char* tag = "update prepared statement";
#endif
		std::lock_guard<std::mutex> lock(mutex_);
		for (auto it = updatePreparedStatementRequests_.begin();
		     it != updatePreparedStatementRequests_.end();)
		{
			auto& request = *it;
			auto session = static_cast<SharedSessionData*>(
				dshash_find(sessions_, &(request->localSession->id), false));
			if (!session)
			{
				request->finished = true;
				request->localSession->errorMessage =
					std::string("stolen session: ") +
					std::to_string(request->localSession->id);
				it = updatePreparedStatementRequests_.erase(it);
				continue;
			}
			if (request->processing)
			{
				SharedSessionReleaser sessionReleaser(sessions_, session);
				if (DsaPointerIsValid(session->errorMessage))
				{
					request->processing = false;
					request->finished = true;
					it = updatePreparedStatementRequests_.erase(it);
				}
				else if (session->nUpdatedRecords >= 0)
				{
					request->processing = false;
					request->finished = true;
					request->nUpdatedRecords = session->nUpdatedRecords;
					it = updatePreparedStatementRequests_.erase(it);
				}
				else
				{
					++it;
				}
			}
			else
			{
				auto executorPID = session->executorPID;
				{
					SharedSessionReleaser sessionReleaser(sessions_, session);
					ProcessorLockGuard lock(this);
					set_shared_string(session->preparedStatementHandle, request->handle);
					session->action = Action::UpdatePreparedStatement;
					session->nUpdatedRecords = -1;
				}
				P("%s: %s: %s: kill executor: %d", Tag, tag_, tag, executorPID);
				kill(executorPID, SIGUSR1);
				request->processing = true;
				++it;
			}
		}
	}