From f42ac5b94e384c789de0b2c4e865b087589a940e Mon Sep 17 00:00:00 2001 From: Rider Linden Date: Tue, 22 Jan 2019 09:24:11 -0800 Subject: SL-10387: Move settings intjection to a setting object (and out of llEnvironment) --- indra/newview/llenvironment.cpp | 328 +++++++++++++++++++++++++++++++++++++--- indra/newview/llenvironment.h | 19 ++- 2 files changed, 319 insertions(+), 28 deletions(-) (limited to 'indra/newview') diff --git a/indra/newview/llenvironment.cpp b/indra/newview/llenvironment.cpp index 5acd508d5d..415cdfac6a 100644 --- a/indra/newview/llenvironment.cpp +++ b/indra/newview/llenvironment.cpp @@ -97,6 +97,9 @@ namespace const std::string KEY_PARCELNAME("ParcelName"); // But changing these would also alter the Experience Log requirements. const std::string KEY_COUNT("Count"); + const std::string LISTENER_NAME("LLEnvironmentSingleton"); + const std::string PUMP_EXPERIENCE("experience_permission"); + //--------------------------------------------------------------------- LLTrace::BlockTimerStatHandle FTM_ENVIRONMENT_UPDATE("Update Environment Tick"); LLTrace::BlockTimerStatHandle FTM_SHADER_PARAM_UPDATE("Update Shader Parameters"); @@ -274,7 +277,6 @@ namespace } }; - class LLEnvironmentPushDispatchHandler : public LLDispatchHandler { public: @@ -314,6 +316,187 @@ namespace LLEnvironmentPushDispatchHandler environment_push_dispatch_handler; + template + class LLSettingsInjected : public SETTINGT + { + public: + typedef std::shared_ptr > ptr_t; + + LLSettingsInjected(typename SETTINGT::ptr_t source) : + SETTINGT(), + mSource(source) + {} + + virtual ~LLSettingsInjected() {}; + + typename SETTINGT::ptr_t buildClone() const override; + + typename SETTINGT::ptr_t getSource() const { return mSource; } + void setSource(const typename SETTINGT::ptr_t &source) { mSource = source; setDirtyFlag(true); } + + void injectSetting(const std::string keyname, LLSD value, LLUUID experience_id, F32Seconds transition) + { + Injection::ptr_t injection = std::make_shared(transition, keyname, value, true, experience_id); + + mInjections.push_back(injection); + std::stable_sort(mInjections.begin(), mInjections.end(), [](const Injection::ptr_t &a, const Injection::ptr_t &b) { return a->mTimeRemaining < b->mTimeRemaining; }); + } + + void removeInjection(const std::string keyname, LLUUID experience) + { + auto it = mInjections.begin(); + while (it != mInjections.end()) + { + if (((*it)->mKeyName == keyname) && + (experience.isNull() || (experience == (*it)->mExperience))) + { + mInjections.erase(it++); + } + else + { + ++it; + } + } + + for (auto itexp = mOverrideExps.begin(); itexp != mOverrideExps.end();) + { + if (experience.isNull() || ((*itexp).second == experience)) + { + mOverrideValues.erase((*itexp).first); + mOverrideExps.erase(itexp++); + } + else + ++itexp; + } + } + + void injectExperienceValues(LLSD values, LLUUID experience_id, F32Seconds transition) + { + for (auto it = values.beginMap(); it != values.endMap(); ++it) + { + injectSetting((*it).first, (*it).second, experience_id, transition); + } + setDirtyFlag(true); + } + + protected: + struct Injection + { + struct Injection(F32Seconds transition, const std::string &keyname, LLSD value, bool blendin, LLUUID experince, S32 index = -1) : + mTransition(transition), + mTimeRemaining(transition), + mKeyName(keyname), + mValue(value), + mExperience(experince), + mIndex(index), + mBlendIn(blendin) + {} + + F32Seconds mTransition; + F32Seconds mTimeRemaining; + std::string mKeyName; + LLSD mValue; + LLUUID mExperience; + S32 mIndex; + bool mBlendIn; + + typedef std::shared_ptr ptr_t; + }; + + + virtual void updateSettings() override + { + static LLFrameTimer timer; + + /**TODO: Add texture code + */ + + F32Seconds delta(timer.getElapsedTimeAndResetF32()); + + if (mSource && mSource->isDirty()) + { + mSource->updateSettings(); + } + + mSettings = mSource->getSettings(); + + for (auto ito = mOverrideValues.beginMap(); ito != mOverrideValues.endMap(); ++ito) + { + mSettings[(*ito).first] = mOverrideValues[(*ito).first]; + } + + const stringset_t &slerps = getSlerpKeys(); + const stringset_t &skips = getSkipInterpolateKeys(); + + injections_t::iterator it; + for (it = mInjections.begin(); it != mInjections.end(); ++it) + { + std::string key_name = (*it)->mKeyName; + if (skips.find(key_name) != skips.end()) + continue; + LLSD value = mSettings[key_name]; + LLSD target = (*it)->mValue; + + (*it)->mTimeRemaining -= delta; + + BlendFactor mix = 1.0f - (((*it)->mTransition.value() - (*it)->mTimeRemaining.value()) / (*it)->mTransition.value()); + + if (mix >= 1.0) + { + if ((*it)->mBlendIn) + { + mOverrideValues[key_name] = target; + mOverrideExps[key_name] = (*it)->mExperience; + } + mSettings[key_name] = target; + } + else + { + mSettings[key_name] = interpolateSDValue(key_name, value, target, getParameterMap(), mix, slerps); + } + } + + it = mInjections.begin(); + it = std::find_if(mInjections.begin(), mInjections.end(), [](const Injection::ptr_t &a) { return a->mTimeRemaining > 0.0f; }); + + if (it != mInjections.begin()) + { + + mInjections.erase(mInjections.begin(), mInjections.end()); + } + + SETTINGT::updateSettings(); + + if (!mInjections.empty()) + setDirtyFlag(true); + } + + + private: + typedef std::map key_to_expid_t; + typedef std::deque injections_t; + + typename SETTINGT::ptr_t mSource; + injections_t mInjections; + LLSD mOverrideValues; + key_to_expid_t mOverrideExps; + }; + + template<> + LLSettingsSky::ptr_t LLSettingsInjected::buildClone() const + { + return LLSettingsVOSky::buildSky(getSettings()); + } + + template<> + LLSettingsWater::ptr_t LLSettingsInjected::buildClone() const + { + return LLSettingsVOWater::buildWater(getSettings()); + } + + + typedef LLSettingsInjected LLSettingsInjectedSky; + typedef LLSettingsInjected LLSettingsInjectedWater; } //========================================================================= @@ -374,6 +557,12 @@ void LLEnvironment::initSingleton() gGenericDispatcher.addHandler(MESSAGE_PUSHENVIRONMENT, &environment_push_dispatch_handler); } + LLEventPumps::instance().obtain(PUMP_EXPERIENCE).listen(LISTENER_NAME, [this](LLSD message) { listenExperiencePump(message); return false; }); +} + +void LLEnvironment::cleanupSingleton() +{ + LLEventPumps::instance().obtain(PUMP_EXPERIENCE).stopListening(LISTENER_NAME); } LLEnvironment::~LLEnvironment() @@ -808,12 +997,12 @@ LLSettingsDay::Seconds LLEnvironment::getEnvironmentDayOffset(EnvSelection_t env } -LLEnvironment::fixedEnvironment_t LLEnvironment::getEnvironmentFixed(LLEnvironment::EnvSelection_t env) +LLEnvironment::fixedEnvironment_t LLEnvironment::getEnvironmentFixed(LLEnvironment::EnvSelection_t env, bool resolve) { - if (env == ENV_CURRENT) + if ((env == ENV_CURRENT) || resolve) { fixedEnvironment_t fixed; - for (S32 idx = mSelectedEnvironment; idx < ENV_END; ++idx) + for (S32 idx = ((resolve) ? env : mSelectedEnvironment); idx < ENV_END; ++idx) { if (fixed.first && fixed.second) break; @@ -1800,7 +1989,6 @@ void LLEnvironment::handleEnvironmentPush(LLSD &message) } } - void LLEnvironment::handleEnvironmentPushClear(LLUUID experience_id, LLSD &message, F32 transition) { clearExperienceEnvironment(experience_id, transition); @@ -1837,15 +2025,15 @@ void LLEnvironment::clearExperienceEnvironment(LLUUID experience_id, F32 transit setInstanceBackup(false); /*TODO blend these back out*/ - mSkyExperienceBlends.clear(); - mWaterExperienceBlends.clear(); - mCurrentEnvironment->getSky(); - - injectSettings(experience_id, mSkyExperienceBlends, mSkyOverrides, LLSettingsBase::Seconds(transition_time), false); - injectSettings(experience_id, mWaterExperienceBlends, mWaterOverrides, LLSettingsBase::Seconds(transition_time), false); - - mSkyOverrides = LLSD::emptyMap(); - mWaterOverrides = LLSD::emptyMap(); +// mSkyExperienceBlends.clear(); +// mWaterExperienceBlends.clear(); +// mCurrentEnvironment->getSky(); +// +// injectSettings(experience_id, mSkyExperienceBlends, mSkyOverrides, LLSettingsBase::Seconds(transition_time), false); +// injectSettings(experience_id, mWaterExperienceBlends, mWaterOverrides, LLSettingsBase::Seconds(transition_time), false); +// +// mSkyOverrides = LLSD::emptyMap(); +// mWaterOverrides = LLSD::emptyMap(); } void LLEnvironment::setSharedEnvironment() @@ -1860,8 +2048,10 @@ void LLEnvironment::setExperienceEnvironment(LLUUID experience_id, LLUUID asset_ LLSettingsVOBase::getSettingsAsset(asset_id, [this, experience_id, transition_time](LLUUID asset_id, LLSettingsBase::ptr_t settings, S32 status, LLExtStat) { - mPushEnvironmentExpId = experience_id; - onSetEnvAssetLoaded(ENV_PUSH, asset_id, settings, +// mPushEnvironmentExpId = experience_id; +// removeExperinceInjections(experience_id); + // individual settings will be overridden by the settings. No need to keep injections. + onSetEnvAssetLoaded(ENV_PUSH, asset_id, settings, LLSettingsDay::DEFAULT_DAYLENGTH, LLSettingsDay::DEFAULT_DAYOFFSET, LLSettingsBase::Seconds(transition_time), status, NO_VERSION); }); @@ -1880,15 +2070,63 @@ void LLEnvironment::setExperienceEnvironment(LLUUID experience_id, LLSD data, F3 return; } - setInstanceBackup(true); + LLSettingsInjectedSky::ptr_t pinjectedsky; + LLSettingsInjectedWater::ptr_t pinjectedwater; + + fixedEnvironment_t pushenv = getEnvironmentFixed(ENV_PUSH, true); if (!sky.isUndefined()) - injectSettings(experience_id, mSkyExperienceBlends, sky, LLSettingsBase::Seconds(transition_time), true); + { + bool newsky(false); + + if (pushenv.first) + { + pinjectedsky = std::dynamic_pointer_cast(pushenv.first); + } + if (!pinjectedsky) + { + pinjectedsky = std::make_shared(pushenv.first); + newsky = true; + } + + pinjectedsky->injectExperienceValues(sky, experience_id, F32Seconds(transition_time)); + if (!newsky) + pinjectedsky.reset(); + } + if (!water.isUndefined()) - injectSettings(experience_id, mWaterExperienceBlends, water, LLSettingsBase::Seconds(transition_time), true); + { + bool newwater(false); + if (pushenv.second) + { + pinjectedwater = std::dynamic_pointer_cast(pushenv.second); + } + if (!pinjectedwater) + { + pinjectedwater = std::make_shared(pushenv.second); + newwater = true; + } + + pinjectedwater->injectExperienceValues(water, experience_id, F32Seconds(transition_time)); + if (!newwater) + pinjectedwater.reset(); + } + + if (pinjectedsky || pinjectedwater) + { + setEnvironment(ENV_PUSH, pinjectedsky, pinjectedwater); + updateEnvironment(TRANSITION_INSTANT); + } -} +// setInstanceBackup(true); +// +// if (!sky.isUndefined()) +// injectSettings(experience_id, mSkyExperienceBlends, sky, LLSettingsBase::Seconds(transition_time), true); +// if (!water.isUndefined()) +// injectSettings(experience_id, mWaterExperienceBlends, water, LLSettingsBase::Seconds(transition_time), true); + +} void LLEnvironment::setInstanceBackup(bool dobackup) { @@ -1905,6 +2143,8 @@ void LLEnvironment::injectSettings(LLUUID experience_id, exerienceBlendValues_t for (LLSD::map_iterator it = injections.beginMap(); it != injections.endMap(); ++it) { blends.push_back(ExpBlendValue(transition, (*it).first, (*it).second, blendin, -1)); + if (blendin) + mExperienceOverrides[(*it).first] = experience_id; } std::stable_sort(blends.begin(), blends.end(), [](const ExpBlendValue &a, const ExpBlendValue &b) { return a.mTimeRemaining < b.mTimeRemaining; }); @@ -1926,7 +2166,6 @@ void LLEnvironment::applyInjectedSettings(DayInstance::ptr_t environment, F32Sec } } - void LLEnvironment::applyInjectedValues(LLSettingsBase::ptr_t psetting, LLSD injection) { for (LLSD::map_iterator it = injection.beginMap(); it != injection.endMap(); ++it) @@ -1973,6 +2212,53 @@ void LLEnvironment::blendInjectedValues(LLSettingsBase::ptr_t psetting, exerienc } } +void LLEnvironment::removeExperinceInjections(const LLUUID &experience_id) +{ + auto it = mExperienceOverrides.begin(); + while (it != mExperienceOverrides.end()) + { + if ((*it).second == experience_id) + { + std::string override_key((*it).first); + mExperienceOverrides.erase(it++); + + if (mSkyOverrides.has(override_key)) + mSkyOverrides.erase(override_key); + if (mWaterOverrides.has(override_key)) + mWaterOverrides.erase(override_key); + auto itBlend = std::find_if(mSkyExperienceBlends.begin(), mSkyExperienceBlends.end(), [override_key](const ExpBlendValue &a) { return a.mKeyName == override_key; }); + if (itBlend != mSkyExperienceBlends.end()) + mSkyExperienceBlends.erase(itBlend); + itBlend = std::find_if(mWaterExperienceBlends.begin(), mWaterExperienceBlends.end(), [override_key](const ExpBlendValue &a) { return a.mKeyName == override_key; }); + if (itBlend != mWaterExperienceBlends.end()) + mWaterExperienceBlends.erase(itBlend); + } + else + ++it; + } +} + +void LLEnvironment::removeExperinceSetting(const LLUUID &experience_id) +{ + clearExperienceEnvironment(experience_id, TRANSITION_INSTANT); +} + +void LLEnvironment::listenExperiencePump(const LLSD &message) +{ + LL_WARNS("LAPRAS") << "Have experience event: " << message << LL_ENDL; + + LLUUID experience_id = message["experience"]; + LLSD data = message[experience_id.asString()]; + std::string permission(data["permission"].asString()); + + if ((permission == "Forget") || (permission == "Block")) + { + removeExperinceSetting(experience_id); + } + + +} + //========================================================================= LLEnvironment::DayInstance::DayInstance(EnvSelection_t env) : mDayCycle(), diff --git a/indra/newview/llenvironment.h b/indra/newview/llenvironment.h index c925ea6e7c..9d951202a9 100644 --- a/indra/newview/llenvironment.h +++ b/indra/newview/llenvironment.h @@ -48,7 +48,7 @@ class LLParcel; //------------------------------------------------------------------------- class LLEnvironment : public LLSingleton { - LLSINGLETON(LLEnvironment); + LLSINGLETON_C11(LLEnvironment); LOG_CLASS(LLEnvironment); public: @@ -153,9 +153,9 @@ public: LLSettingsDay::ptr_t getEnvironmentDay(EnvSelection_t env); LLSettingsDay::Seconds getEnvironmentDayLength(EnvSelection_t env); LLSettingsDay::Seconds getEnvironmentDayOffset(EnvSelection_t env); - fixedEnvironment_t getEnvironmentFixed(EnvSelection_t env); - LLSettingsSky::ptr_t getEnvironmentFixedSky(EnvSelection_t env) { return getEnvironmentFixed(env).first; }; - LLSettingsWater::ptr_t getEnvironmentFixedWater(EnvSelection_t env) { return getEnvironmentFixed(env).second; }; + fixedEnvironment_t getEnvironmentFixed(EnvSelection_t env, bool resolve = false); + LLSettingsSky::ptr_t getEnvironmentFixedSky(EnvSelection_t env, bool resolve = false) { return getEnvironmentFixed(env, resolve).first; }; + LLSettingsWater::ptr_t getEnvironmentFixedWater(EnvSelection_t env, bool resolve = false) { return getEnvironmentFixed(env, resolve).second; }; void updateEnvironment(LLSettingsBase::Seconds transition = TRANSITION_DEFAULT, bool forced = false); @@ -299,7 +299,9 @@ public: DayInstance::ptr_t getSharedEnvironmentInstance(); protected: - virtual void initSingleton(); + virtual void initSingleton() override; + virtual void cleanupSingleton() override; + private: LLVector4 toCFR(const LLVector3 vec) const; @@ -360,8 +362,8 @@ private: LLSD mSkyOverrides; LLSD mWaterOverrides; - LLSD mSkyOverrideBlends; - LLSD mWaterOverrideBlends; + typedef std::map experience_overrides_t; + experience_overrides_t mExperienceOverrides; DayInstance::ptr_t getEnvironmentInstance(EnvSelection_t env, bool create = false); @@ -453,6 +455,9 @@ private: void applyInjectedSettings(DayInstance::ptr_t environment, F32Seconds delta); void applyInjectedValues(LLSettingsBase::ptr_t psetting, LLSD injection); void blendInjectedValues(LLSettingsBase::ptr_t psetting, exerienceBlendValues_t &blends, LLSD &overrides, F32Seconds delta); + void removeExperinceInjections(const LLUUID &experience_id); + void removeExperinceSetting(const LLUUID &experience_id); + void listenExperiencePump(const LLSD &message); exerienceBlendValues_t mSkyExperienceBlends; exerienceBlendValues_t mWaterExperienceBlends; -- cgit v1.2.3