diff options
author | James Cook <james@lindenlab.com> | 2007-01-02 08:33:20 +0000 |
---|---|---|
committer | James Cook <james@lindenlab.com> | 2007-01-02 08:33:20 +0000 |
commit | 420b91db29485df39fd6e724e782c449158811cb (patch) | |
tree | b471a94563af914d3ed3edd3e856d21cb1b69945 /indra/newview/llinventorymodel.cpp |
Print done when done.
Diffstat (limited to 'indra/newview/llinventorymodel.cpp')
-rw-r--r-- | indra/newview/llinventorymodel.cpp | 3493 |
1 files changed, 3493 insertions, 0 deletions
diff --git a/indra/newview/llinventorymodel.cpp b/indra/newview/llinventorymodel.cpp new file mode 100644 index 0000000000..509f040c34 --- /dev/null +++ b/indra/newview/llinventorymodel.cpp @@ -0,0 +1,3493 @@ +/** + * @file llinventorymodel.cpp + * @brief Implementation of the inventory model used to track agent inventory. + * + * Copyright (c) 2002-$CurrentYear$, Linden Research, Inc. + * $License$ + */ + +#include "llviewerprecompiledheaders.h" +#include "llinventorymodel.h" + +#include "llassetstorage.h" +#include "llcrc.h" +#include "lldir.h" +#include "llsys.h" +#include "llxfermanager.h" +#include "message.h" + +#include "llagent.h" +#include "llfloater.h" +#include "llfocusmgr.h" +#include "llinventoryview.h" +#include "llviewerinventory.h" +#include "llviewerwindow.h" +#include "viewer.h" +#include "lldbstrings.h" +#include "llviewerstats.h" +#include "llmutelist.h" +#include "llnotify.h" +#include "llcallbacklist.h" +#include <deque> + +//#define DIFF_INVENTORY_FILES +#ifdef DIFF_INVENTORY_FILES +#include "process.h" +#endif + +BOOL LLInventoryModel::sBackgroundFetchActive = FALSE; +BOOL LLInventoryModel::sAllFoldersFetched = FALSE; +BOOL LLInventoryModel::sFullFetchStarted = FALSE; +S32 LLInventoryModel::sNumFetchRetries = 0; +F32 LLInventoryModel::sMinTimeBetweenFetches = 0.3f; +F32 LLInventoryModel::sMaxTimeBetweenFetches = 10.f; +BOOL LLInventoryModel::sTimelyFetchPending = FALSE; +LLFrameTimer LLInventoryModel::sFetchTimer; + +// RN: for some reason, using std::queue in the header file confuses the compiler which things it's an xmlrpc_queue +static std::deque<LLUUID> sFetchQueue; + +///---------------------------------------------------------------------------- +/// Local function declarations, constants, enums, and typedefs +///---------------------------------------------------------------------------- + +//BOOL decompress_file(const char* src_filename, const char* dst_filename); +const F32 MAX_TIME_FOR_SINGLE_FETCH = 10.f; +const S32 MAX_FETCH_RETRIES = 5; +const char CACHE_FORMAT_STRING[] = "%s.inv"; +const char* NEW_CATEGORY_NAME = "New Folder"; +const char* NEW_CATEGORY_NAMES[LLAssetType::AT_COUNT] = +{ + "Textures", // AT_TEXTURE + "Sounds", // AT_SOUND + "Calling Cards", // AT_CALLINGCARD + "Landmarks", // AT_LANDMARK + "Scripts", // AT_SCRIPT (deprecated?) + "Clothing", // AT_CLOTHING + "Objects", // AT_OBJECT + "Notecards", // AT_NOTECARD + "New Folder", // AT_CATEGORY + "Inventory", // AT_ROOT_CATEGORY + "Scripts", // AT_LSL_TEXT + "Scripts", // AT_LSL_BYTECODE + "Uncompressed Images", // AT_TEXTURE_TGA + "Body Parts", // AT_BODYPART + "Trash", // AT_TRASH + "Photo Album", // AT_SNAPSHOT_CATEGORY + "Lost And Found", // AT_LOST_AND_FOUND + "Uncompressed Sounds", // AT_SOUND_WAV + "Uncompressed Images", // AT_IMAGE_TGA + "Uncompressed Images", // AT_IMAGE_JPEG + "Animations", // AT_ANIMATION + "Gestures", // AT_GESTURE +}; + +struct InventoryIDPtrLess +{ + bool operator()(const LLViewerInventoryCategory* i1, const LLViewerInventoryCategory* i2) const + { + return (i1->getUUID() < i2->getUUID()); + } +}; + +class LLCanCache : public LLInventoryCollectFunctor +{ +public: + LLCanCache(LLInventoryModel* model) : mModel(model) {} + virtual ~LLCanCache() {} + virtual bool operator()(LLInventoryCategory* cat, LLInventoryItem* item); +protected: + LLInventoryModel* mModel; + std::set<LLUUID> mCachedCatIDs; +}; + +bool LLCanCache::operator()(LLInventoryCategory* cat, LLInventoryItem* item) +{ + bool rv = false; + if(item) + { + if(mCachedCatIDs.find(item->getParentUUID()) != mCachedCatIDs.end()) + { + rv = true; + } + } + else if(cat) + { + // HACK: downcast + LLViewerInventoryCategory* c = (LLViewerInventoryCategory*)cat; + if(c->getVersion() != LLViewerInventoryCategory::VERSION_UNKNOWN) + { + S32 descendents_server = c->getDescendentCount(); + LLInventoryModel::cat_array_t* cats; + LLInventoryModel::item_array_t* items; + mModel->getDirectDescendentsOf( + c->getUUID(), + cats, + items); + S32 descendents_actual = 0; + if(cats && items) + { + descendents_actual = cats->count() + items->count(); + } + if(descendents_server == descendents_actual) + { + mCachedCatIDs.insert(c->getUUID()); + rv = true; + } + } + } + return rv; +} + +///---------------------------------------------------------------------------- +/// Class LLInventoryModel +///---------------------------------------------------------------------------- + +// global for the agent inventory. +LLInventoryModel gInventory; + +// Default constructor +LLInventoryModel::LLInventoryModel() : + mModifyMask(LLInventoryObserver::ALL), + mLastItem(NULL) +{ +} + +// Destroys the object +LLInventoryModel::~LLInventoryModel() +{ + empty(); + for (observer_list_t::iterator iter = mObservers.begin(); + iter != mObservers.end(); ++iter) + { + delete *iter; + } +} + +// This is a convenience function to check if one object has a parent +// chain up to the category specified by UUID. +BOOL LLInventoryModel::isObjectDescendentOf(const LLUUID& obj_id, + const LLUUID& cat_id) +{ + LLInventoryObject* obj = getObject(obj_id); + while(obj) + { + const LLUUID& parent_id = obj->getParentUUID(); + if( parent_id.isNull() ) + { + return FALSE; + } + if(parent_id == cat_id) + { + return TRUE; + } + // Since we're scanning up the parents, we only need to check + // in the category list. + obj = getCategory(parent_id); + } + return FALSE; +} + +// Get the object by id. Returns NULL if not found. +LLInventoryObject* LLInventoryModel::getObject(const LLUUID& id) const +{ + LLViewerInventoryCategory* cat = getCategory(id); + if (cat) + { + return cat; + } + LLViewerInventoryItem* item = getItem(id); + if (item) + { + return item; + } + return NULL; +} + +// Get the item by id. Returns NULL if not found. +LLViewerInventoryItem* LLInventoryModel::getItem(const LLUUID& id) const +{ + LLViewerInventoryItem* item = NULL; + if(mLastItem.notNull() && mLastItem->getUUID() == id) + { + item = mLastItem; + } + else + { + item_map_t::const_iterator iter = mItemMap.find(id); + if (iter != mItemMap.end()) + { + item = iter->second; + mLastItem = item; + } + } + return item; +} + +// Get the category by id. Returns NULL if not found +LLViewerInventoryCategory* LLInventoryModel::getCategory(const LLUUID& id) const +{ + LLViewerInventoryCategory* category = NULL; + cat_map_t::const_iterator iter = mCategoryMap.find(id); + if (iter != mCategoryMap.end()) + { + category = iter->second; + } + return category; +} + +S32 LLInventoryModel::getItemCount() const +{ + return mItemMap.size(); +} + +S32 LLInventoryModel::getCategoryCount() const +{ + return mCategoryMap.size(); +} + +// Return the direct descendents of the id provided. The array +// provided points straight into the guts of this object, and +// should only be used for read operations, since modifications +// may invalidate the internal state of the inventory. Set passed +// in values to NULL if the call fails. +void LLInventoryModel::getDirectDescendentsOf(const LLUUID& cat_id, + cat_array_t*& categories, + item_array_t*& items) const +{ + categories = get_ptr_in_map(mParentChildCategoryTree, cat_id); + items = get_ptr_in_map(mParentChildItemTree, cat_id); +} + +// findCategoryUUIDForType() returns the uuid of the category that +// specifies 'type' as what it defaults to containing. The category is +// not necessarily only for that type. *NOTE: This will create a new +// inventory category on the fly if one does not exist. +LLUUID LLInventoryModel::findCategoryUUIDForType(LLAssetType::EType t) +{ + LLUUID rv = findCatUUID(t); + if(rv.isNull()) + { + rv = gAgent.getInventoryRootID(); + if(rv.notNull()) + { + rv = createNewCategory(rv, t, NULL); + } + } + return rv; +} + +// Internal method which looks for a category with the specified +// preferred type. Returns LLUUID::null if not found. +LLUUID LLInventoryModel::findCatUUID(LLAssetType::EType preferred_type) +{ + LLUUID root_id = gAgent.getInventoryRootID(); + if(LLAssetType::AT_CATEGORY == preferred_type) + { + return root_id; + } + if(root_id.notNull()) + { + cat_array_t* cats = NULL; + cats = get_ptr_in_map(mParentChildCategoryTree, root_id); + if(cats) + { + S32 count = cats->count(); + for(S32 i = 0; i < count; ++i) + { + if(cats->get(i)->getPreferredType() == preferred_type) + { + return cats->get(i)->getUUID(); + } + } + } + } + return LLUUID::null; +} + +// Convenience function to create a new category. You could call +// updateCatgory() with a newly generated UUID category, but this +// version will take care of details like what the name should be +// based on preferred type. Returns the UUID of the new category. +LLUUID LLInventoryModel::createNewCategory(const LLUUID& parent_id, + LLAssetType::EType preferred_type, + const LLString& pname) +{ + LLUUID id; + id.generate(); + LLString name = pname; + if(!pname.empty()) + { + name.assign(pname); + } + else if((preferred_type >= LLAssetType::AT_TEXTURE) && + (preferred_type < LLAssetType::AT_COUNT)) + { + name.assign(NEW_CATEGORY_NAMES[preferred_type]); + } + else + { + name.assign(NEW_CATEGORY_NAME); + } + + // Add the category to the internal representation + LLPointer<LLViewerInventoryCategory> cat = + new LLViewerInventoryCategory(id, parent_id, preferred_type, name, gAgent.getID()); + cat->setVersion(LLViewerInventoryCategory::VERSION_INITIAL); + cat->setDescendentCount(0); + LLCategoryUpdate update(cat->getParentUUID(), 1); + accountForUpdate(update); + updateCategory(cat); + + // Create the category on the server. We do this to prevent people + // from munging their protected folders. + LLMessageSystem* msg = gMessageSystem; + msg->newMessage("CreateInventoryFolder"); + msg->nextBlock("AgentData"); + msg->addUUID("AgentID", gAgent.getID()); + msg->addUUID(_PREHASH_SessionID, gAgent.getSessionID()); + msg->nextBlock("FolderData"); + cat->packMessage(msg); + gAgent.sendReliableMessage(); + + // return the folder id of the newly created folder + return id; +} + +// Starting with the object specified, add it's descendents to the +// array provided, but do not add the inventory object specified by +// id. There is no guaranteed order. Neither array will be erased +// before adding objects to it. Do not store a copy of the pointers +// collected - use them, and collect them again later if you need to +// reference the same objects. + +class LLAlwaysCollect : public LLInventoryCollectFunctor +{ +public: + virtual ~LLAlwaysCollect() {} + virtual bool operator()(LLInventoryCategory* cat, + LLInventoryItem* item) + { + return TRUE; + } +}; + +void LLInventoryModel::collectDescendents(const LLUUID& id, + cat_array_t& cats, + item_array_t& items, + BOOL include_trash) +{ + LLAlwaysCollect always; + collectDescendentsIf(id, cats, items, include_trash, always); +} + +void LLInventoryModel::collectDescendentsIf(const LLUUID& id, + cat_array_t& cats, + item_array_t& items, + BOOL include_trash, + LLInventoryCollectFunctor& add) +{ + // Start with categories + if(!include_trash) + { + LLUUID trash_id(findCatUUID(LLAssetType::AT_TRASH)); + if(trash_id.notNull() && (trash_id == id)) + return; + } + cat_array_t* cat_array = get_ptr_in_map(mParentChildCategoryTree, id); + if(cat_array) + { + S32 count = cat_array->count(); + for(S32 i = 0; i < count; ++i) + { + LLViewerInventoryCategory* cat = cat_array->get(i); + if(add(cat,NULL)) + { + cats.put(cat); + } + collectDescendentsIf(cat->getUUID(), cats, items, include_trash, add); + } + } + + // Move onto items + LLViewerInventoryItem* item = NULL; + item_array_t* item_array = get_ptr_in_map(mParentChildItemTree, id); + if(item_array) + { + S32 count = item_array->count(); + for(S32 i = 0; i < count; ++i) + { + item = item_array->get(i); + if(add(NULL, item)) + { + items.put(item); + } + } + } +} + +// Generates a string containing the path to the item specified by +// item_id. +void LLInventoryModel::appendPath(const LLUUID& id, LLString& path) +{ + LLString temp; + LLInventoryObject* obj = getObject(id); + LLUUID parent_id; + if(obj) parent_id = obj->getParentUUID(); + LLString forward_slash("/"); + while(obj) + { + obj = getCategory(parent_id); + if(obj) + { + temp.assign(forward_slash + obj->getName() + temp); + parent_id = obj->getParentUUID(); + } + } + path.append(temp); +} + +// Calling this method with an inventory item will either change an +// existing item with a matching item_id, or will add the item to the +// current inventory. +U32 LLInventoryModel::updateItem(const LLViewerInventoryItem* item) +{ + U32 mask = LLInventoryObserver::NONE; + if(item->getUUID().isNull()) + { + return mask; + } + LLViewerInventoryItem* old_item = getItem(item->getUUID()); + if(old_item) + { + // We already have an old item, modify it's values + LLUUID old_parent_id = old_item->getParentUUID(); + LLUUID new_parent_id = item->getParentUUID(); + if(old_parent_id != new_parent_id) + { + // need to update the parent-child tree + item_array_t* item_array; + item_array = get_ptr_in_map(mParentChildItemTree, old_parent_id); + if(item_array) + { + item_array->removeObj(old_item); + } + item_array = get_ptr_in_map(mParentChildItemTree, new_parent_id); + if(item_array) + { + item_array->put(old_item); + } + mask |= LLInventoryObserver::STRUCTURE; + } + if(old_item->getName() != item->getName()) + { + mask |= LLInventoryObserver::LABEL; + } + old_item->copy(item); + mask |= LLInventoryObserver::INTERNAL; + } + else + { + // Simply add this item + LLPointer<LLViewerInventoryItem> new_item = new LLViewerInventoryItem(item); + addItem(new_item); + + if(item->getParentUUID().isNull()) + { + LLUUID category_id = findCategoryUUIDForType(new_item->getType()); + new_item->setParent(category_id); + item_array_t* item_array = get_ptr_in_map(mParentChildItemTree, category_id); + if( item_array ) + { + // *FIX: bit of a hack to call update server from here... + new_item->updateServer(TRUE); + item_array->put(new_item); + } + else + { + llwarns << "Couldn't find parent-child item tree for " << new_item->getName() << llendl; + } + } + else + { + // *NOTE: The general scheme is that if every byte of the + // uuid is 0, except for the last one or two,the use the + // last two bytes of the parent id, and match that up + // against the type. For now, we're only worried about + // lost & found. + LLUUID parent_id = item->getParentUUID(); + if(parent_id == CATEGORIZE_LOST_AND_FOUND_ID) + { + parent_id = findCategoryUUIDForType(LLAssetType::AT_LOST_AND_FOUND); + new_item->setParent(parent_id); + } + item_array_t* item_array = get_ptr_in_map(mParentChildItemTree, parent_id); + if(item_array) + { + item_array->put(new_item); + } + else + { + // Whoops! No such parent, make one. + llinfos << "Lost item: " << new_item->getUUID() << " - " + << new_item->getName() << llendl; + parent_id = findCategoryUUIDForType(LLAssetType::AT_LOST_AND_FOUND); + new_item->setParent(parent_id); + item_array = get_ptr_in_map(mParentChildItemTree, parent_id); + if(item_array) + { + // *FIX: bit of a hack to call update server from + // here... + new_item->updateServer(TRUE); + item_array->put(new_item); + } + else + { + llwarns << "Lost and found Not there!!" << llendl; + } + } + } + mask |= LLInventoryObserver::ADD; + } + if(item->getType() == LLAssetType::AT_CALLINGCARD) + { + mask |= LLInventoryObserver::CALLING_CARD; + } + addChangedMask(mask, item->getUUID()); + return mask; +} + +// Calling this method with an inventory category will either change +// an existing item with the matching id, or it will add the category. +void LLInventoryModel::updateCategory(const LLViewerInventoryCategory* cat) +{ + if(cat->getUUID().isNull()) + { + return; + } + LLViewerInventoryCategory* old_cat = getCategory(cat->getUUID()); + if(old_cat) + { + // We already have an old category, modify it's values + U32 mask = LLInventoryObserver::NONE; + LLUUID old_parent_id = old_cat->getParentUUID(); + LLUUID new_parent_id = cat->getParentUUID(); + if(old_parent_id != new_parent_id) + { + // need to update the parent-child tree + cat_array_t* cat_array; + cat_array = get_ptr_in_map(mParentChildCategoryTree, old_parent_id); + if(cat_array) + { + cat_array->removeObj(old_cat); + } + cat_array = get_ptr_in_map(mParentChildCategoryTree, new_parent_id); + if(cat_array) + { + cat_array->put(old_cat); + } + mask |= LLInventoryObserver::STRUCTURE; + } + if(old_cat->getName() != cat->getName()) + { + mask |= LLInventoryObserver::LABEL; + } + old_cat->copy(cat); + addChangedMask(mask, cat->getUUID()); + } + else + { + // add this category + LLPointer<LLViewerInventoryCategory> new_cat = new LLViewerInventoryCategory(cat->getParentUUID()); + new_cat->copy(cat); + addCategory(new_cat); + + // make sure this category is correctly referenced by it's parent. + cat_array_t* cat_array; + cat_array = get_ptr_in_map(mParentChildCategoryTree, cat->getParentUUID()); + if(cat_array) + { + cat_array->put(new_cat); + } + + // make space in the tree for this category's children. + cat_array_t* catsp = new cat_array_t; + item_array_t* itemsp = new item_array_t; + mParentChildCategoryTree[new_cat->getUUID()] = catsp; + mParentChildItemTree[new_cat->getUUID()] = itemsp; + addChangedMask(LLInventoryObserver::ADD, cat->getUUID()); + } +} + +void LLInventoryModel::moveObject(const LLUUID& object_id, const LLUUID& cat_id) +{ + lldebugs << "LLInventoryModel::moveObject()" << llendl; + if((object_id == cat_id) || !is_in_map(mCategoryMap, cat_id)) + { + llwarns << "Could not move inventory object " << object_id << " to " + << cat_id << llendl; + return; + } + LLViewerInventoryCategory* cat = getCategory(object_id); + if(cat && (cat->getParentUUID() != cat_id)) + { + cat_array_t* cat_array; + cat_array = get_ptr_in_map(mParentChildCategoryTree, cat->getParentUUID()); + if(cat_array) cat_array->removeObj(cat); + cat_array = get_ptr_in_map(mParentChildCategoryTree, cat_id); + cat->setParent(cat_id); + if(cat_array) cat_array->put(cat); + addChangedMask(LLInventoryObserver::STRUCTURE, object_id); + return; + } + LLViewerInventoryItem* item = getItem(object_id); + if(item && (item->getParentUUID() != cat_id)) + { + item_array_t* item_array; + item_array = get_ptr_in_map(mParentChildItemTree, item->getParentUUID()); + if(item_array) item_array->removeObj(item); + item_array = get_ptr_in_map(mParentChildItemTree, cat_id); + item->setParent(cat_id); + if(item_array) item_array->put(item); + addChangedMask(LLInventoryObserver::STRUCTURE, object_id); + return; + } +} + +// Delete a particular inventory object by ID. +void LLInventoryModel::deleteObject(const LLUUID& id) +{ + lldebugs << "LLInventoryModel::deleteObject()" << llendl; + LLPointer<LLInventoryObject> obj = getObject(id); + if(obj) + { + lldebugs << "Deleting inventory object " << id << llendl; + mLastItem = NULL; + LLUUID parent_id = obj->getParentUUID(); + mCategoryMap.erase(id); + mItemMap.erase(id); + //mInventory.erase(id); + item_array_t* item_list = get_ptr_in_map(mParentChildItemTree, parent_id); + if(item_list) + { + LLViewerInventoryItem* item = (LLViewerInventoryItem*)((LLInventoryObject*)obj); + item_list->removeObj(item); + } + cat_array_t* cat_list = get_ptr_in_map(mParentChildCategoryTree, parent_id); + if(cat_list) + { + LLViewerInventoryCategory* cat = (LLViewerInventoryCategory*)((LLInventoryObject*)obj); + cat_list->removeObj(cat); + } + item_list = get_ptr_in_map(mParentChildItemTree, id); + if(item_list) + { + delete item_list; + mParentChildItemTree.erase(id); + } + cat_list = get_ptr_in_map(mParentChildCategoryTree, id); + if(cat_list) + { + delete cat_list; + mParentChildCategoryTree.erase(id); + } + addChangedMask(LLInventoryObserver::REMOVE, id); + obj = NULL; // delete obj + } +} + +// This is a method which collects the descendents of the id +// provided. If the category is not found, no action is +// taken. This method goes through the long winded process of +// cancelling any calling cards, removing server representation of +// folders, items, etc in a fairly efficient manner. +void LLInventoryModel::purgeDescendentsOf(const LLUUID& id) +{ + EHasChildren children = categoryHasChildren(id); + if(children == CHILDREN_NO) + { + llinfos << "Not purging descendents of " << id << llendl; + return; + } + LLPointer<LLViewerInventoryCategory> cat = getCategory(id); + if(cat.notNull()) + { + // do the cache accounting + llinfos << "LLInventoryModel::purgeDescendentsOf " << cat->getName() + << llendl; + S32 descendents = cat->getDescendentCount(); + if(descendents > 0) + { + LLCategoryUpdate up(id, -descendents); + accountForUpdate(up); + } + + // we know that descendent count is 0, aide since the + // accounting may actually not do an update, we should force + // it here. + cat->setDescendentCount(0); + + // send it upstream + LLMessageSystem* msg = gMessageSystem; + msg->newMessage("PurgeInventoryDescendents"); + msg->nextBlock("AgentData"); + msg->addUUID("AgentID", gAgent.getID()); + msg->addUUID("SessionID", gAgent.getSessionID()); + msg->nextBlock("InventoryData"); + msg->addUUID("FolderID", id); + gAgent.sendReliableMessage(); + + // unceremoniously remove anything we have locally stored. + cat_array_t categories; + item_array_t items; + collectDescendents(id, + categories, + items, + INCLUDE_TRASH); + S32 count = items.count(); + S32 i; + for(i = 0; i < count; ++i) + { + deleteObject(items.get(i)->getUUID()); + } + count = categories.count(); + for(i = 0; i < count; ++i) + { + deleteObject(categories.get(i)->getUUID()); + } + } +} + +void LLInventoryModel::deleteFromServer(LLDynamicArray<LLUUID>& category_ids, + LLDynamicArray<LLUUID>& item_ids) +{ + // Store off tre UUIDS of parents which are being deleted (thus no + // need to increment) and the parents which are being modified. We + // have to increment the version of the parent with each message + // sent upstream since the dataserver will increment each unique + // parent per update message. + std::set<LLUUID> ignore_parents; + update_map_t inc_parents; + + S32 i; + S32 count = category_ids.count(); + BOOL start_new_message = TRUE; + LLMessageSystem* msg = gMessageSystem; + LLPointer<LLViewerInventoryCategory> cat; + for(i = 0; i < count; i++) + { + if(start_new_message) + { + start_new_message = FALSE; + msg->newMessageFast(_PREHASH_RemoveInventoryObjects); + msg->nextBlockFast(_PREHASH_AgentData); + msg->addUUIDFast(_PREHASH_AgentID, gAgent.getID()); + msg->addUUIDFast(_PREHASH_SessionID, gAgent.getSessionID()); + } + LLUUID cat_id = category_ids.get(i); + + msg->nextBlockFast(_PREHASH_FolderData); + msg->addUUIDFast(_PREHASH_FolderID, cat_id); + cat = getCategory(cat_id); + ignore_parents.insert(cat_id); + addChangedMask(LLInventoryObserver::REMOVE | LLInventoryObserver::STRUCTURE, cat_id); + if(cat.notNull() && (ignore_parents.find(cat->getParentUUID())==ignore_parents.end())) + { + --inc_parents[cat->getParentUUID()]; + } + if(msg->isSendFullFast(_PREHASH_FolderData)) + { + start_new_message = TRUE; + msg->nextBlockFast(_PREHASH_ItemData); + msg->addUUIDFast(_PREHASH_ItemID, LLUUID::null); + gAgent.sendReliableMessage(); + accountForUpdate(inc_parents); + inc_parents.clear(); + } + } + + count = item_ids.count(); + std::set<LLUUID>::iterator not_ignored = ignore_parents.end(); + LLPointer<LLViewerInventoryItem> item; + if((0 == count) && (!start_new_message)) + { + msg->nextBlockFast(_PREHASH_ItemData); + msg->addUUIDFast(_PREHASH_ItemID, LLUUID::null); + } + for(i = 0; i < count; i++) + { + if(start_new_message) + { + start_new_message = FALSE; + msg->newMessageFast(_PREHASH_RemoveInventoryObjects); + msg->nextBlockFast(_PREHASH_AgentData); + msg->addUUIDFast(_PREHASH_AgentID, gAgent.getID()); + msg->addUUIDFast(_PREHASH_SessionID, gAgent.getSessionID()); + msg->nextBlockFast(_PREHASH_FolderData); + msg->addUUIDFast(_PREHASH_FolderID, LLUUID::null); + } + LLUUID item_id = item_ids.get(i); + msg->nextBlockFast(_PREHASH_ItemData); + msg->addUUIDFast(_PREHASH_ItemID, item_id); + item = getItem(item_id); + addChangedMask(LLInventoryObserver::REMOVE | LLInventoryObserver::STRUCTURE, item_id); + if(item.notNull() && (ignore_parents.find(item->getParentUUID()) == not_ignored)) + { + --inc_parents[item->getParentUUID()]; + } + if(msg->isSendFullFast(_PREHASH_ItemData)) + { + start_new_message = TRUE; + gAgent.sendReliableMessage(); + accountForUpdate(inc_parents); + inc_parents.clear(); + } + } + if(!start_new_message) + { + gAgent.sendReliableMessage(); + accountForUpdate(inc_parents); + } +} + +// Add/remove an observer. If the observer is destroyed, be sure to +// remove it. +void LLInventoryModel::addObserver(LLInventoryObserver* observer) +{ + mObservers.insert(observer); +} + +void LLInventoryModel::removeObserver(LLInventoryObserver* observer) +{ + mObservers.erase(observer); +} + +// Call this method when it's time to update everyone on a new state, +// by default, the inventory model will not update observers +// automatically. +void LLInventoryModel::notifyObservers() +{ + for (observer_list_t::iterator iter = mObservers.begin(); + iter != mObservers.end(); ) + { + LLInventoryObserver* observer = *iter; + observer->changed(mModifyMask); + // safe way to incrament since changed may delete entries! (@!##%@!@&*!) + iter = mObservers.upper_bound(observer); + } + + mModifyMask = LLInventoryObserver::NONE; + mChangedItemIDs.clear(); +} + +// store flag for change +// and id of object change applies to +void LLInventoryModel::addChangedMask(U32 mask, const LLUUID& referent) +{ + mModifyMask |= mask; + if (referent.notNull()) + { + mChangedItemIDs.insert(referent); + } +} + +// This method to prepares a set of mock inventory which provides +// minimal functionality before the actual arrival of inventory. +/* +void LLInventoryModel::mock(const LLUUID& root_id) +{ + llinfos << "LLInventoryModel::mock() " << root_id << llendl; + if(root_id.isNull()) + { + llwarns << "Not a valid root id" << llendl; + return; + } + LLPointer<LLViewerInventoryCategory> cat = new LLViewerInventoryCategory( + root_id, + LLUUID::null, + LLAssetType::AT_CATEGORY, + NEW_CATEGORY_NAMES[LLAssetType::AT_ROOT_CATEGORY], + gAgent.getID()); + addCategory(cat); + gInventory.buildParentChildMap(); +} +*/ + +void LLInventoryModel::fetchDescendentsOf(const LLUUID& folder_id) +{ + LLViewerInventoryCategory* cat = getCategory(folder_id); + if(!cat) + { + llwarns << "Asked to fetch descendents of non-existent folder: " + << folder_id << llendl; + return; + } + //S32 known_descendents = 0; + ///cat_array_t* categories = get_ptr_in_map(mParentChildCategoryTree, folder_id); + //item_array_t* items = get_ptr_in_map(mParentChildItemTree, folder_id); + //if(categories) + //{ + // known_descendents += categories->count(); + //} + //if(items) + //{ + // known_descendents += items->count(); + //} + if(!cat->fetchDescendents()) + { + //llinfos << "Not fetching descendents" << llendl; + } +} + +// static +bool LLInventoryModel::isEverythingFetched() +{ + return (sAllFoldersFetched ? true : false); +} + +//static +BOOL LLInventoryModel::backgroundFetchActive() +{ + return sBackgroundFetchActive; +} + +//static +void LLInventoryModel::startBackgroundFetch(const LLUUID& cat_id) +{ + if (!sAllFoldersFetched) + { + sBackgroundFetchActive = TRUE; + if (cat_id.isNull()) + { + if (!sFullFetchStarted) + { + sFullFetchStarted = TRUE; + sFetchQueue.push_back(gInventoryLibraryRoot); + sFetchQueue.push_back(gAgent.getInventoryRootID()); + gIdleCallbacks.addFunction(&LLInventoryModel::backgroundFetch, NULL); + } + } + else + { + // specific folder requests go to front of queue + if (sFetchQueue.empty() || sFetchQueue.front() != cat_id) + { + sFetchQueue.push_front(cat_id); + gIdleCallbacks.addFunction(&LLInventoryModel::backgroundFetch, NULL); + } + } + } +} + +//static +void LLInventoryModel::stopBackgroundFetch() +{ + if (sBackgroundFetchActive) + { + sBackgroundFetchActive = FALSE; + gIdleCallbacks.deleteFunction(&LLInventoryModel::backgroundFetch, NULL); + } +} + +//static +void LLInventoryModel::backgroundFetch(void*) +{ + if (sBackgroundFetchActive) + { + // no more categories to fetch, stop fetch process + if (sFetchQueue.empty()) + { + llinfos << "Inventory fetch completed" << llendl; + if (sFullFetchStarted) + { + sAllFoldersFetched = TRUE; + } + stopBackgroundFetch(); + return; + } + + F32 fast_fetch_time = lerp(sMinTimeBetweenFetches, sMaxTimeBetweenFetches, 0.1f); + F32 slow_fetch_time = lerp(sMinTimeBetweenFetches, sMaxTimeBetweenFetches, 0.5f); + if (sTimelyFetchPending && sFetchTimer.getElapsedTimeF32() > slow_fetch_time) + { + // double timeouts on failure + sMinTimeBetweenFetches = llmin(sMinTimeBetweenFetches * 2.f, 10.f); + sMaxTimeBetweenFetches = llmin(sMaxTimeBetweenFetches * 2.f, 120.f); + llinfos << "Inventory fetch times grown to (" << sMinTimeBetweenFetches << ", " << sMaxTimeBetweenFetches << ")" << llendl; + // fetch is no longer considered "timely" although we will wait for full time-out + sTimelyFetchPending = FALSE; + } + + while(1) + { + if (sFetchQueue.empty()) + { + break; + } + + if(gDisconnected) + { + // just bail if we are disconnected. + break; + } + + LLViewerInventoryCategory* cat = gInventory.getCategory(sFetchQueue.front()); + + // category has been deleted, remove from queue. + if (!cat) + { + sFetchQueue.pop_front(); + continue; + } + + if (sFetchTimer.getElapsedTimeF32() > sMinTimeBetweenFetches && + LLViewerInventoryCategory::VERSION_UNKNOWN == cat->getVersion()) + { + // category exists but has no children yet, fetch the descendants + // for now, just request every time and rely on retry timer to throttle + if (cat->fetchDescendents()) + { + sFetchTimer.reset(); + sTimelyFetchPending = TRUE; + } + else + { + // The catagory also tracks if it has expired and here it says it hasn't + // yet. Get out of here because nothing is going to happen until we + // update the timers. + break; + } + } + // do I have all my children? + else if (gInventory.isCategoryComplete(sFetchQueue.front())) + { + // finished with this category, remove from queue + sFetchQueue.pop_front(); + + // add all children to queue + parent_cat_map_t::iterator cat_it = gInventory.mParentChildCategoryTree.find(cat->getUUID()); + if (cat_it != gInventory.mParentChildCategoryTree.end()) + { + cat_array_t* child_categories = cat_it->second; + + for (S32 child_num = 0; child_num < child_categories->count(); child_num++) + { + sFetchQueue.push_back(child_categories->get(child_num)->getUUID()); + } + } + + // we received a response in less than the fast time + if (sTimelyFetchPending && sFetchTimer.getElapsedTimeF32() < fast_fetch_time) + { + // shrink timeouts based on success + sMinTimeBetweenFetches = llmax(sMinTimeBetweenFetches * 0.8f, 0.3f); + sMaxTimeBetweenFetches = llmax(sMaxTimeBetweenFetches * 0.8f, 10.f); + //llinfos << "Inventory fetch times shrunk to (" << sMinTimeBetweenFetches << ", " << sMaxTimeBetweenFetches << ")" << llendl; + } + + sTimelyFetchPending = FALSE; + continue; + } + else if (sFetchTimer.getElapsedTimeF32() > sMaxTimeBetweenFetches) + { + // received first packet, but our num descendants does not match db's num descendants + // so try again later + LLUUID fetch_id = sFetchQueue.front(); + sFetchQueue.pop_front(); + + if (sNumFetchRetries++ < MAX_FETCH_RETRIES) + { + // push on back of queue + sFetchQueue.push_back(fetch_id); + } + sTimelyFetchPending = FALSE; + sFetchTimer.reset(); + break; + } + + // not enough time has elapsed to do a new fetch + break; + } + } +} + +void LLInventoryModel::cache( + const LLUUID& parent_folder_id, + const LLUUID& agent_id) +{ + lldebugs << "Caching " << parent_folder_id << " for " << agent_id + << llendl; + LLViewerInventoryCategory* root_cat = getCategory(parent_folder_id); + if(!root_cat) return; + cat_array_t categories; + categories.put(root_cat); + item_array_t items; + + LLCanCache can_cache(this); + can_cache(root_cat, NULL); + collectDescendentsIf( + parent_folder_id, + categories, + items, + INCLUDE_TRASH, + can_cache); + char agent_id_str[UUID_STR_LENGTH]; + char inventory_filename[LL_MAX_PATH]; + agent_id.toString(agent_id_str); + std::string path(gDirUtilp->getExpandedFilename(LL_PATH_CACHE, agent_id_str)); + snprintf( + inventory_filename, + LL_MAX_PATH, + CACHE_FORMAT_STRING, + path.c_str()); + saveToFile(inventory_filename, categories, items); + std::string gzip_filename(inventory_filename); + gzip_filename.append(".gz"); + if(gzip_file(inventory_filename, gzip_filename.c_str())) + { + lldebugs << "Successfully compressed " << inventory_filename << llendl; + LLFile::remove(inventory_filename); + } + else + { + llwarns << "Unable to compress " << inventory_filename << llendl; + } +} + + +void LLInventoryModel::addCategory(LLViewerInventoryCategory* category) +{ + //llinfos << "LLInventoryModel::addCategory()" << llendl; + if(category) + { + // Insert category uniquely into the map + mCategoryMap[category->getUUID()] = category; // LLPointer will deref and delete the old one + //mInventory[category->getUUID()] = category; + } +} + +void LLInventoryModel::addItem(LLViewerInventoryItem* item) +{ + //llinfos << "LLInventoryModel::addItem()" << llendl; + if(item) + { + mItemMap[item->getUUID()] = item; + //mInventory[item->getUUID()] = item; + } +} + +// Empty the entire contents +void LLInventoryModel::empty() +{ +// llinfos << "LLInventoryModel::empty()" << llendl; + std::for_each( + mParentChildCategoryTree.begin(), + mParentChildCategoryTree.end(), + DeletePairedPointer()); + mParentChildCategoryTree.clear(); + std::for_each( + mParentChildItemTree.begin(), + mParentChildItemTree.end(), + DeletePairedPointer()); + mParentChildItemTree.clear(); + mCategoryMap.clear(); // remove all references (should delete entries) + mItemMap.clear(); // remove all references (should delete entries) + mLastItem = NULL; + //mInventory.clear(); +} + +void LLInventoryModel::accountForUpdate(const LLCategoryUpdate& update) +{ + LLViewerInventoryCategory* cat = getCategory(update.mCategoryID); + if(cat) + { + bool accounted = false; + S32 version = cat->getVersion(); + if(version != LLViewerInventoryCategory::VERSION_UNKNOWN) + { + S32 descendents_server = cat->getDescendentCount(); + LLInventoryModel::cat_array_t* cats; + LLInventoryModel::item_array_t* items; + getDirectDescendentsOf(update.mCategoryID, cats, items); + S32 descendents_actual = 0; + if(cats && items) + { + descendents_actual = cats->count() + items->count(); + } + if(descendents_server == descendents_actual) + { + accounted = true; + descendents_actual += update.mDescendentDelta; + cat->setDescendentCount(descendents_actual); + cat->setVersion(++version); + llinfos << "accounted: '" << cat->getName() << "' " + << version << " with " << descendents_actual + << " descendents." << llendl; + } + } + if(!accounted) + { + lldebugs << "No accounting for: '" << cat->getName() << "' " + << version << llendl; + } + } + else + { + llwarns << "No category found for update " << update.mCategoryID + << llendl; + } +} + +void LLInventoryModel::accountForUpdate( + const LLInventoryModel::update_list_t& update) +{ + update_list_t::const_iterator it = update.begin(); + update_list_t::const_iterator end = update.end(); + for(; it != end; ++it) + { + accountForUpdate(*it); + } +} + +void LLInventoryModel::accountForUpdate( + const LLInventoryModel::update_map_t& update) +{ + LLCategoryUpdate up; + update_map_t::const_iterator it = update.begin(); + update_map_t::const_iterator end = update.end(); + for(; it != end; ++it) + { + up.mCategoryID = (*it).first; + up.mDescendentDelta = (*it).second.mValue; + accountForUpdate(up); + } +} + + +/* +void LLInventoryModel::incrementCategoryVersion(const LLUUID& category_id) +{ + LLViewerInventoryCategory* cat = getCategory(category_id); + if(cat) + { + S32 version = cat->getVersion(); + if(LLViewerInventoryCategory::VERSION_UNKNOWN != version) + { + cat->setVersion(version + 1); + llinfos << "IncrementVersion: " << cat->getName() << " " + << cat->getVersion() << llendl; + } + else + { + llinfos << "Attempt to increment version when unknown: " + << category_id << llendl; + } + } + else + { + llinfos << "Attempt to increment category: " << category_id << llendl; + } +} +void LLInventoryModel::incrementCategorySetVersion( + const std::set<LLUUID>& categories) +{ + if(!categories.empty()) + { + std::set<LLUUID>::const_iterator it = categories.begin(); + std::set<LLUUID>::const_iterator end = categories.end(); + for(; it != end; ++it) + { + incrementCategoryVersion(*it); + } + } +} +*/ + + +LLInventoryModel::EHasChildren LLInventoryModel::categoryHasChildren( + const LLUUID& cat_id) const +{ + LLViewerInventoryCategory* cat = getCategory(cat_id); + if(!cat) return CHILDREN_NO; + if(cat->getDescendentCount() > 0) + { + return CHILDREN_YES; + } + if(cat->getDescendentCount() == 0) + { + return CHILDREN_NO; + } + if((cat->getDescendentCount() == LLViewerInventoryCategory::DESCENDENT_COUNT_UNKNOWN) + || (cat->getVersion() == LLViewerInventoryCategory::VERSION_UNKNOWN)) + { + return CHILDREN_MAYBE; + } + + // Shouldn't have to run this, but who knows. + parent_cat_map_t::const_iterator cat_it = mParentChildCategoryTree.find(cat->getUUID()); + if (cat_it != mParentChildCategoryTree.end() && cat_it->second->count() > 0) + { + return CHILDREN_YES; + } + parent_item_map_t::const_iterator item_it = mParentChildItemTree.find(cat->getUUID()); + if (item_it != mParentChildItemTree.end() && item_it->second->count() > 0) + { + return CHILDREN_YES; + } + + return CHILDREN_NO; +} + +bool LLInventoryModel::isCategoryComplete(const LLUUID& cat_id) const +{ + LLViewerInventoryCategory* cat = getCategory(cat_id); + if(cat && (cat->getVersion()!=LLViewerInventoryCategory::VERSION_UNKNOWN)) + { + S32 descendents_server = cat->getDescendentCount(); + LLInventoryModel::cat_array_t* cats; + LLInventoryModel::item_array_t* items; + getDirectDescendentsOf(cat_id, cats, items); + S32 descendents_actual = 0; + if(cats && items) + { + descendents_actual = cats->count() + items->count(); + } + if(descendents_server == descendents_actual) + { + return true; + } + } + return false; +} + +bool LLInventoryModel::loadSkeleton( + const LLInventoryModel::options_t& options, + const LLUUID& owner_id) +{ + lldebugs << "importing inventory skeleton for " << owner_id << llendl; + + typedef std::set<LLPointer<LLViewerInventoryCategory>, InventoryIDPtrLess> cat_set_t; + cat_set_t temp_cats; + + update_map_t child_counts; + + LLUUID id; + LLAssetType::EType preferred_type; + bool rv = true; + for(options_t::const_iterator it = options.begin(); it < options.end(); ++it) + { + LLPointer<LLViewerInventoryCategory> cat = new LLViewerInventoryCategory(owner_id); + response_t::const_iterator no_response = (*it).end(); + response_t::const_iterator skel; + skel = (*it).find("name"); + if(skel == no_response) goto clean_cat; + cat->rename(LLString((*skel).second.c_str())); + skel = (*it).find("folder_id"); + if(skel == no_response) goto clean_cat; + id.set((*skel).second.c_str()); + // if an id is null, it locks the viewer. + if(id.isNull()) goto clean_cat; + cat->setUUID(id); + skel = (*it).find("parent_id"); + if(skel == no_response) goto clean_cat; + id.set((*skel).second.c_str()); + cat->setParent(id); + skel = (*it).find("type_default"); + if(skel == no_response) + { + preferred_type = LLAssetType::AT_NONE; + } + else + { + S32 t = atoi((*skel).second.c_str()); + preferred_type = (LLAssetType::EType)t; + } + cat->setPreferredType(preferred_type); + skel = (*it).find("version"); + if(skel == no_response) goto clean_cat; + cat->setVersion(atoi((*skel).second.c_str())); + temp_cats.insert(cat); + continue; + clean_cat: + llwarns << "Unable to import near " << cat->getName() << llendl; + rv = false; + //delete cat; // automatic when cat is reasigned or destroyed + } + + S32 cached_category_count = 0; + S32 cached_item_count = 0; + if(!temp_cats.empty()) + { + cat_array_t categories; + item_array_t items; + char owner_id_str[UUID_STR_LENGTH]; + owner_id.toString(owner_id_str); + std::string path(gDirUtilp->getExpandedFilename(LL_PATH_CACHE, owner_id_str)); + char inventory_filename[LL_MAX_PATH]; + snprintf( + inventory_filename, + LL_MAX_PATH, + CACHE_FORMAT_STRING, + path.c_str()); + const S32 NO_VERSION = LLViewerInventoryCategory::VERSION_UNKNOWN; + std::string gzip_filename(inventory_filename); + gzip_filename.append(".gz"); + FILE* fp = LLFile::fopen(gzip_filename.c_str(), "rb"); + bool remove_inventory_file = false; + if(fp) + { + fclose(fp); + fp = NULL; + if(gunzip_file(gzip_filename.c_str(), inventory_filename)) + { + // we only want to remove the inventory file if it was + // gzipped before we loaded, and we successfully + // gunziped it. + remove_inventory_file = true; + } + else + { + llinfos << "Unable to gunzip " << gzip_filename << llendl; + } + } + if(loadFromFile(inventory_filename, categories, items)) + { + // We were able to find a cache of files. So, use what we + // found to generate a set of categories we should add. We + // will go through each category loaded and if the version + // does not match, invalidate the version. + S32 count = categories.count(); + cat_set_t::iterator not_cached = temp_cats.end(); + std::set<LLUUID> cached_ids; + for(S32 i = 0; i < count; ++i) + { + LLViewerInventoryCategory* cat = categories[i]; + cat_set_t::iterator cit = temp_cats.find(cat); + LLViewerInventoryCategory* tcat = *cit; + + // we can safely ignore anything loaded from file, but + // not sent down in the skeleton. + if(cit == not_cached) continue; + if(cat->getVersion() != tcat->getVersion()) + { + // if the cached version does not match the server version, + // throw away the version we have so we can fetch the + // correct contents the next time the viewer opens the folder. + tcat->setVersion(NO_VERSION); + } + else + { + cached_ids.insert(tcat->getUUID()); + } + } + + // go ahead and add the cats returned during the download + std::set<LLUUID>::iterator not_cached_id = cached_ids.end(); + cached_category_count = cached_ids.size(); + for(cat_set_t::iterator it = temp_cats.begin(); it != temp_cats.end(); ++it) + { + if(cached_ids.find((*it)->getUUID()) == not_cached_id) + { + // this check is performed so that we do not + // mark new folders in the skeleton (and not in cache) + // as being cached. + LLViewerInventoryCategory *llvic = (*it); + llvic->setVersion(NO_VERSION); + } + addCategory(*it); + ++child_counts[(*it)->getParentUUID()]; + } + + // Add all the items loaded which are parented to a + // category with a correctly cached parent + count = items.count(); + cat_map_t::iterator unparented = mCategoryMap.end(); + for(int i = 0; i < count; ++i) + { + cat_map_t::iterator cit = mCategoryMap.find(items[i]->getParentUUID()); + + if(cit != unparented) + { + LLViewerInventoryCategory* cat = cit->second; + if(cat->getVersion() != NO_VERSION) + { + addItem(items[i]); + cached_item_count += 1; + ++child_counts[cat->getUUID()]; + } + } + } + } + else + { + // go ahead and add everything after stripping the version + // information. + for(cat_set_t::iterator it = temp_cats.begin(); it != temp_cats.end(); ++it) + { + LLViewerInventoryCategory *llvic = (*it); + llvic->setVersion(NO_VERSION); + addCategory(*it); + } + } + + // At this point, we need to set the known descendents for each + // category which successfully cached so that we do not + // needlessly fetch descendents for categories which we have. + update_map_t::iterator no_child_counts = child_counts.end(); + update_map_t::iterator the_count; + for(cat_set_t::iterator it = temp_cats.begin(); it != temp_cats.end(); ++it) + { + LLViewerInventoryCategory* cat = (*it); + if(cat->getVersion() != NO_VERSION) + { + the_count = child_counts.find(cat->getUUID()); + if(the_count != no_child_counts) + { + cat->setDescendentCount((*the_count).second.mValue); + } + else + { + cat->setDescendentCount(0); + } + } + } + + if(remove_inventory_file) + { + // clean up the gunzipped file. + LLFile::remove(inventory_filename); + } + categories.clear(); // will unref and delete entries + } + + llinfos << "Successfully loaded " << cached_category_count + << " categories and " << cached_item_count << " items from cache." + << llendl; + + return rv; +} + +bool LLInventoryModel::loadMeat( + const LLInventoryModel::options_t& options, const LLUUID& owner_id) +{ + llinfos << "importing inventory for " << owner_id << llendl; + LLPermissions default_perm; + default_perm.init(LLUUID::null, owner_id, LLUUID::null, LLUUID::null); + LLPointer<LLViewerInventoryItem> item; + LLUUID id; + LLAssetType::EType type; + LLInventoryType::EType inv_type; + bool rv = true; + for(options_t::const_iterator it = options.begin(); it < options.end(); ++it) + { + item = new LLViewerInventoryItem; + response_t::const_iterator no_response = (*it).end(); + response_t::const_iterator meat; + meat = (*it).find("name"); + if(meat == no_response) goto clean_item; + item->rename(LLString((*meat).second.c_str())); + meat = (*it).find("item_id"); + if(meat == no_response) goto clean_item; + id.set((*meat).second.c_str()); + item->setUUID(id); + meat = (*it).find("parent_id"); + if(meat == no_response) goto clean_item; + id.set((*meat).second.c_str()); + item->setParent(id); + meat = (*it).find("type"); + if(meat == no_response) goto clean_item; + type = (LLAssetType::EType)atoi((*meat).second.c_str()); + item->setType(type); + meat = (*it).find("inv_type"); + if(meat != no_response) + { + inv_type = (LLInventoryType::EType)atoi((*meat).second.c_str()); + item->setInventoryType(inv_type); + } + meat = (*it).find("data_id"); + if(meat == no_response) goto clean_item; + id.set((*meat).second.c_str()); + if(LLAssetType::AT_CALLINGCARD == type) + { + LLPermissions perm; + perm.init(id, owner_id, LLUUID::null, LLUUID::null); + item->setPermissions(perm); + } + else + { + meat = (*it).find("perm_mask"); + if(meat != no_response) + { + PermissionMask perm_mask = atoi((*meat).second.c_str()); + default_perm.initMasks( + perm_mask, perm_mask, perm_mask, perm_mask, perm_mask); + } + else + { + default_perm.initMasks( + PERM_NONE, PERM_NONE, PERM_NONE, PERM_NONE, PERM_NONE); + } + item->setPermissions(default_perm); + item->setAssetUUID(id); + } + meat = (*it).find("flags"); + if(meat != no_response) + { + item->setFlags(strtoul((*meat).second.c_str(), NULL, 0)); + } + meat = (*it).find("time"); + if(meat != no_response) + { + item->setCreationDate(atoi((*meat).second.c_str())); + } + addItem(item); + continue; + clean_item: + llwarns << "Unable to import near " << item->getName() << llendl; + rv = false; + //delete item; // automatic when item is reassigned or destroyed + } + return rv; +} + +// This is a brute force method to rebuild the entire parent-child +// relations. The overall operation has O(NlogN) performance, which +// should be sufficient for our needs. +void LLInventoryModel::buildParentChildMap() +{ + llinfos << "LLInventoryModel::buildParentChildMap()" << llendl; + + // *NOTE: I am skipping the logic around folder version + // synchronization here because it seems if a folder is lost, we + // might actually want to invalidate it at that point - not + // attempt to cache. More time & thought is necessary. + + // First the categories. We'll copy all of the categories into a + // temporary container to iterate over (oh for real iterators.) + // While we're at it, we'll allocate the arrays in the trees. + cat_array_t cats; + cat_array_t* catsp; + item_array_t* itemsp; + + for(cat_map_t::iterator cit = mCategoryMap.begin(); cit != mCategoryMap.end(); ++cit) + { + LLViewerInventoryCategory* cat = cit->second; + cats.put(cat); + if (mParentChildCategoryTree.count(cat->getUUID()) == 0) + { + catsp = new cat_array_t; + mParentChildCategoryTree[cat->getUUID()] = catsp; + } + if (mParentChildItemTree.count(cat->getUUID()) == 0) + { + itemsp = new item_array_t; + mParentChildItemTree[cat->getUUID()] = itemsp; + } + } + + // Insert a special parent for the root - so that lookups on + // LLUUID::null as the parent work correctly. This is kind of a + // blatent wastes of space since we allocate a block of memory for + // the array, but whatever - it's not that much space. + if (mParentChildCategoryTree.count(LLUUID::null) == 0) + { + catsp = new cat_array_t; + mParentChildCategoryTree[LLUUID::null] = catsp; + } + + // Now we have a structure with all of the categories that we can + // iterate over and insert into the correct place in the child + // category tree. + S32 count = cats.count(); + S32 i; + S32 lost = 0; + for(i = 0; i < count; ++i) + { + LLViewerInventoryCategory* cat = cats.get(i); + catsp = get_ptr_in_map(mParentChildCategoryTree, cat->getParentUUID()); + if(catsp) + { + catsp->put(cat); + } + else + { + // *NOTE: This process could be a lot more efficient if we + // used the new MoveInventoryFolder message, but we would + // have to continue to do the update & build here. So, to + // implement it, we would need a set or map of uuid pairs + // which would be (folder_id, new_parent_id) to be sent up + // to the server. + llinfos << "Lost categroy: " << cat->getUUID() << " - " + << cat->getName() << llendl; + ++lost; + // plop it into the lost & found. + LLAssetType::EType pref = cat->getPreferredType(); + if(LLAssetType::AT_NONE == pref) + { + cat->setParent(findCategoryUUIDForType(LLAssetType::AT_LOST_AND_FOUND)); + } + else if(LLAssetType::AT_CATEGORY == pref) + { + // it's the root + cat->setParent(LLUUID::null); + } + else + { + // it's a protected folder. + cat->setParent(gAgent.getInventoryRootID()); + } + cat->updateServer(TRUE); + catsp = get_ptr_in_map(mParentChildCategoryTree, cat->getParentUUID()); + if(catsp) + { + catsp->put(cat); + } + else + { + llwarns << "Lost and found Not there!!" << llendl; + } + } + } + if(lost) + { + llwarns << "Found " << lost << " lost categories." << llendl; + } + + // Now the items. We allocated in the last step, so now all we + // have to do is iterate over the items and put them in the right + // place. + item_array_t items; + if(!mItemMap.empty()) + { + LLPointer<LLViewerInventoryItem> item; + for(item_map_t::iterator iit = mItemMap.begin(); iit != mItemMap.end(); ++iit) + { + item = (*iit).second; + items.put(item); + } + } + count = items.count(); + lost = 0; + std::vector<LLUUID> lost_item_ids; + for(i = 0; i < count; ++i) + { + LLPointer<LLViewerInventoryItem> item; + item = items.get(i); + itemsp = get_ptr_in_map(mParentChildItemTree, item->getParentUUID()); + if(itemsp) + { + itemsp->put(item); + } + else + { + llinfos << "Lost item: " << item->getUUID() << " - " + << item->getName() << llendl; + ++lost; + // plop it into the lost & found. + // + item->setParent(findCategoryUUIDForType(LLAssetType::AT_LOST_AND_FOUND)); + // move it later using a special message to move items. If + // we update server here, the client might crash. + //item->updateServer(); + lost_item_ids.push_back(item->getUUID()); + itemsp = get_ptr_in_map(mParentChildItemTree, item->getParentUUID()); + if(itemsp) + { + itemsp->put(item); + } + else + { + llwarns << "Lost and found Not there!!" << llendl; + } + } + } + if(lost) + { + llwarns << "Found " << lost << " lost items." << llendl; + LLMessageSystem* msg = gMessageSystem; + BOOL start_new_message = TRUE; + LLUUID lnf = findCategoryUUIDForType(LLAssetType::AT_LOST_AND_FOUND); + for(std::vector<LLUUID>::iterator it = lost_item_ids.begin() ; it < lost_item_ids.end(); ++it) + { + if(start_new_message) + { + start_new_message = FALSE; + msg->newMessageFast(_PREHASH_MoveInventoryItem); + msg->nextBlockFast(_PREHASH_AgentData); + msg->addUUIDFast(_PREHASH_AgentID, gAgent.getID()); + msg->addUUIDFast(_PREHASH_SessionID, gAgent.getSessionID()); + msg->addBOOLFast(_PREHASH_Stamp, FALSE); + } + msg->nextBlockFast(_PREHASH_InventoryData); + msg->addUUIDFast(_PREHASH_ItemID, (*it)); + msg->addUUIDFast(_PREHASH_FolderID, lnf); + msg->addString("NewName", NULL); + if(msg->mCurrentSendTotal >= MTUBYTES) + { + start_new_message = TRUE; + gAgent.sendReliableMessage(); + } + } + if(!start_new_message) + { + gAgent.sendReliableMessage(); + } + } +} + +struct LLUUIDAndName +{ + LLUUIDAndName() {} + LLUUIDAndName(const LLUUID& id, const LLString& name); + bool operator==(const LLUUIDAndName& rhs) const; + bool operator<(const LLUUIDAndName& rhs) const; + bool operator>(const LLUUIDAndName& rhs) const; + + LLUUID mID; + LLString mName; +}; + +LLUUIDAndName::LLUUIDAndName(const LLUUID& id, const LLString& name) : + mID(id), mName(name) +{ +} + +bool LLUUIDAndName::operator==(const LLUUIDAndName& rhs) const +{ + return ((mID == rhs.mID) && (mName == rhs.mName)); +} + +bool LLUUIDAndName::operator<(const LLUUIDAndName& rhs) const +{ + return (mID < rhs.mID); +} + +bool LLUUIDAndName::operator>(const LLUUIDAndName& rhs) const +{ + return (mID > rhs.mID); +} + +// Given the current state of the inventory items, figure out the +// clone information. *FIX: This is sub-optimal, since we can insert +// this information snurgically, but this makes sure the implementation +// works before we worry about optimization. +//void LLInventoryModel::recalculateCloneInformation() +//{ +// //dumpInventory(); +// +// // This implements a 'multi-map' like structure to keep track of +// // how many clones we find. +// typedef LLDynamicArray<LLViewerInventoryItem*> viewer_item_array_t; +// typedef std::map<LLUUIDAndName, viewer_item_array_t*> clone_map_t; +// clone_map_t clone_map; +// LLUUIDAndName id_and_name; +// viewer_item_array_t* clones = NULL; +// LLViewerInventoryItem* item = NULL; +// for(item = (LLViewerInventoryItem*)mItemMap.getFirstData(); +// item != NULL; +// item = (LLViewerInventoryItem*)mItemMap.getNextData()) +// { +// if(item->getType() == LLAssetType::AT_CALLINGCARD) +// { +// // if it's a calling card, we key off of the creator id, not +// // the asset id. +// id_and_name.mID = item->getCreatorUUID(); +// } +// else +// { +// // if it's not a calling card, we key clones from the +// // asset id. +// id_and_name.mID = item->getAssetUUID(); +// } +// if(id_and_name.mID == LLUUID::null) +// { +// continue; +// } +// id_and_name.mName = item->getName(); +// if(clone_map.checkData(id_and_name)) +// { +// clones = clone_map.getData(id_and_name); +// } +// else +// { +// clones = new viewer_item_array_t; +// clone_map.addData(id_and_name, clones); +// } +// clones->put(item); +// } +// +// S32 count = 0; +// for(clones = clone_map.getFirstData(); +// clones != NULL; +// clones = clone_map.getNextData()) +// { +// count = clones->count(); +// for(S32 i = 0; i < count; i++) +// { +// item = clones->get(i); +// item->setCloneCount(count - 1); +// //clones[i] = NULL; +// } +// delete clones; +// } +// clone_map.removeAllData(); +// //dumpInventory(); +//} + +// static +bool LLInventoryModel::loadFromFile( + const char* filename, + LLInventoryModel::cat_array_t& categories, + LLInventoryModel::item_array_t& items) +{ + llinfos << "LLInventoryModel::loadFromFile(" << filename << ")" << llendl; + FILE* file = LLFile::fopen(filename, "rb"); + if(!file) + { + llinfos << "unable to load inventory from: " << filename << llendl; + return false; + } + char buffer[MAX_STRING]; + char keyword[MAX_STRING]; + while(!feof(file) && fgets(buffer, MAX_STRING, file)) + { + sscanf(buffer, " %s", keyword); + if(0 == strcmp("inv_category", keyword)) + { + LLPointer<LLViewerInventoryCategory> inv_cat = new LLViewerInventoryCategory(LLUUID::null); + if(inv_cat->importFileLocal(file)) + { + categories.put(inv_cat); + } + else + { + llwarns << "loadInventoryFromFile(). Ignoring invalid inventory category: " << inv_cat->getName() << llendl; + //delete inv_cat; // automatic when inv_cat is reassigned or destroyed + } + } + else if(0 == strcmp("inv_item", keyword)) + { + LLPointer<LLViewerInventoryItem> inv_item = new LLViewerInventoryItem; + if( inv_item->importFileLocal(file) ) + { + // *FIX: Need a better solution, this prevents the + // application from freezing, but breaks inventory + // caching. + if(inv_item->getUUID().isNull()) + { + //delete inv_item; // automatic when inv_cat is reassigned or destroyed + llwarns << "Ignoring inventory with null item id: " + << inv_item->getName() << llendl; + + } + else + { + items.put(inv_item); + } + } + else + { + llwarns << "loadInventoryFromFile(). Ignoring invalid inventory item: " << inv_item->getName() << llendl; + //delete inv_item; // automatic when inv_cat is reassigned or destroyed + } + } + else + { + llwarns << "Unknown token in inventory file '" << keyword << "'" + << llendl; + } + } + fclose(file); + return true; +} + +// static +bool LLInventoryModel::saveToFile( + const char* filename, + const cat_array_t& categories, + const item_array_t& items) +{ + llinfos << "LLInventoryModel::saveToFile(" << filename << ")" << llendl; + FILE* file = LLFile::fopen(filename, "wb"); + if(!file) + { + llwarns << "unable to save inventory to: " << filename << llendl; + return false; + } + + S32 count = categories.count(); + S32 i; + for(i = 0; i < count; ++i) + { + LLViewerInventoryCategory* cat = categories[i]; + if(cat->getVersion() != LLViewerInventoryCategory::VERSION_UNKNOWN) + { + cat->exportFileLocal(file); + } + } + + count = items.count(); + for(i = 0; i < count; ++i) + { + items[i]->exportFile(file); + } + + fclose(file); + return true; +} + +// message handling functionality +// static +void LLInventoryModel::registerCallbacks(LLMessageSystem* msg) +{ + //msg->setHandlerFuncFast(_PREHASH_InventoryUpdate, + // processInventoryUpdate, + // NULL); + //msg->setHandlerFuncFast(_PREHASH_UseCachedInventory, + // processUseCachedInventory, + // NULL); + msg->setHandlerFuncFast(_PREHASH_UpdateCreateInventoryItem, + processUpdateCreateInventoryItem, + NULL); + msg->setHandlerFuncFast(_PREHASH_RemoveInventoryItem, + processRemoveInventoryItem, + NULL); + msg->setHandlerFuncFast(_PREHASH_UpdateInventoryFolder, + processUpdateInventoryFolder, + NULL); + msg->setHandlerFuncFast(_PREHASH_RemoveInventoryFolder, + processRemoveInventoryFolder, + NULL); + //msg->setHandlerFuncFast(_PREHASH_ExchangeCallingCard, + // processExchangeCallingcard, + // NULL); + //msg->setHandlerFuncFast(_PREHASH_AddCallingCard, + // processAddCallingcard, + // NULL); + //msg->setHandlerFuncFast(_PREHASH_DeclineCallingCard, + // processDeclineCallingcard, + // NULL); + msg->setHandlerFuncFast(_PREHASH_SaveAssetIntoInventory, + processSaveAssetIntoInventory, + NULL); + msg->setHandlerFuncFast(_PREHASH_BulkUpdateInventory, + processBulkUpdateInventory, + NULL); + msg->setHandlerFunc("InventoryDescendents", processInventoryDescendents); + msg->setHandlerFunc("MoveInventoryItem", processMoveInventoryItem); + msg->setHandlerFunc("FetchInventoryReply", processFetchInventoryReply); +} + +/* +//struct LLUpdateInventoryInfo +{ + LLString mFilenameAndPath; + BOOL mIsComplete; +}; + +// static +void LLInventoryModel::processInventoryUpdate(LLMessageSystem* msg, void**) +{ + lldebugs << "LLInventoryModel::processInventoryUpdate()" << llendl; + LLUUID agent_id; + msg->getUUIDFast(_PREHASH_InventoryData, _PREHASH_AgentID, agent_id); + if(agent_id != gAgent.getID()) + { + llwarns << "Got an inventory update for the wrong agent." << llendl; + return; + } + + BOOL is_complete; + msg->getBOOLFast(_PREHASH_InventoryData, _PREHASH_IsComplete, is_complete); + char filename[MAX_STRING]; + msg->getStringFast(_PREHASH_InventoryData, _PREHASH_Filename, MAX_STRING, filename); + + LLUpdateInventoryInfo* info = new LLUpdateInventoryInfo; + info->mFilenameAndPath = gDirUtilp->getExpandedFilename( LL_PATH_TEMP, filename ); + info->mIsComplete = is_complete; + + gXferManager->requestFile(info->mFilenameAndPath, + filename, + LL_PATH_CACHE, // The remote file is in the data directory + gUserServer, + TRUE, // Delete the remote file after the transfer + processInventoryFile, + (void*)info, + LLXferManager::HIGH_PRIORITY); +} + +// static +void LLInventoryModel::processInventoryFile(void** user_data, S32 error_code) +{ + llinfos << "LLInventoryModel::processInventoryFile()" << llendl; + //gInventory.dumpInventory(); + LLUpdateInventoryInfo* info = (LLUpdateInventoryInfo*)user_data; + if(info && (0 == error_code)) + { + if(info->mIsComplete) + { + if(gInventory.isLoaded()) + { + // it's a complete update, and we've already loaded + // everything. Therefore, we need to blow away + // everything. + gInventory.empty(); + } + else + { + // We want to merge with anything that's happened + // before the load. Therefore, we only want to get rid + // of the root category. + gInventory.deleteObject(gAgent.getInventoryRootID()); + } + } + + // decompress if necessary + const char* filename = info->mFilenameAndPath.c_str(); + const char* ext = filename + strlen(filename) - 6; + char dst_filename[LL_MAX_PATH]; + if(0 == strnicmp(ext, "gz", 2)) + { + // it's a gz file. decmpress it. + dst_filename[0] = '\0'; + strncat(dst_filename, filename, (ext - filename)); + strcat(dst_filename, "tmp"); + BOOL success = gunzip_file(filename, dst_filename); + LLFile::remove(filename); + if(!success) + { + llwarns << "Error loading inventory file. Return code: " << error_code << llendl; + LLNotifyBox::showXml("InventoryNetworkCorruption"); + goto exit; + } + filename = dst_filename; + } + +#ifdef DIFF_INVENTORY_FILES + char agent_id_string[UUID_STR_LENGTH]; + char inventory_filename[LL_MAX_PATH]; + gAgent.getID().toString(agent_id_string); + sprintf(inventory_filename, CACHE_FORMAT_STRING, gDirUtilp->getExpandedFilename(LL_PATH_CACHE,agent_id_string).c_str()); + char buffer[MAX_STRING]; + sprintf(buffer, + "c:/cygwin/bin/diff %s %s", + inventory_filename, + filename); + llinfos << buffer << llendl; + system(buffer); + +#endif + + // load it all up. + gInventory.loadFromFile(filename); + gInventory.buildParentChildMap(); + //gInventory.recalculateCloneInformation(); + gInventory.addChangedMask(LLInventoryObserver::ALL); + if(info->mIsComplete) + { + // Set loaded to true if it's a complete set because it's + // poosible for someone to accept an inventory category + // before they have their complete inventory. If we marked + // it loaded at that point, when the real inventory + // arrived, it would erase (on the client anyway) the + // existence of that inventory. + gInventory.mIsLoaded = TRUE; + + //retrieveIM(gMessageSystem); + llinfos << "complete inventory update" << llendl; + + // If we promised you a message on load, here it is + if (gViewerStats->getStat(LLViewerStats::ST_INVENTORY_TOO_LONG) > 0.0) + { + LLNotifyBox::showXml("InventoryLoaded"); + } + } + else + { + llinfos << "incomplete inventory update" << llendl; + } + gInventory.notifyObservers(); + LLFile::remove(filename); + } + else + { + llwarns << "Eror loading inventory file. Return code: " << error_code + << llendl; + if(error_code == LL_ERR_TCP_TIMEOUT) + { + //llwarns << "Re-requesting inventory" << llendl; + //gInventory.requestFromServer(gAgent.getID()); + } + } + +exit: + delete info; + //gInventory.dumpInventory(); +} + +// static +void LLInventoryModel::processUseCachedInventory(LLMessageSystem* msg, void**) +{ + llinfos << "LLInventoryModel::processUseCachedInventory()" << llendl; + char agent_id_string[UUID_STR_LENGTH]; + gAgent.getID().toString(agent_id_string); + char filename[LL_MAX_PATH]; + sprintf(filename, CACHE_FORMAT_STRING, gDirUtilp->getExpandedFilename(LL_PATH_CACHE,agent_id_string).c_str()); + // We want to merge with anything that's happened before the + // load. Therefore, we only want to get rid of the root category. + gInventory.deleteObject(gAgent.getInventoryRootID()); + gInventory.loadFromFile(filename); + gInventory.buildParentChildMap(); + //gInventory.recalculateCloneInformation(); + gInventory.addChangedMask(LLInventoryObserver::ALL); + gInventory.mIsLoaded = TRUE; + gInventory.notifyObservers(); + //retrieveIM(); +} +*/ + +// static +void LLInventoryModel::processUpdateCreateInventoryItem(LLMessageSystem* msg, void**) +{ + // do accounting and highlight new items if they arrive + if (gInventory.messageUpdateCore(msg, true, true)) + { + U32 callback_id; + LLUUID item_id; + msg->getUUIDFast(_PREHASH_InventoryData, _PREHASH_ItemID, item_id); + msg->getU32Fast(_PREHASH_InventoryData, _PREHASH_CallbackID, callback_id); + + gInventoryCallbacks.fire(callback_id, item_id); + } + +} + +// static +void LLInventoryModel::processFetchInventoryReply(LLMessageSystem* msg, void**) +{ + // no accounting + gInventory.messageUpdateCore(msg, false, false); +} + + +bool LLInventoryModel::messageUpdateCore(LLMessageSystem* msg, bool account, bool highlight_new) +{ + LLUUID agent_id; + msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id); + if(agent_id != gAgent.getID()) + { + llwarns << "Got a inventory update for the wrong agent: " << agent_id + << llendl; + return false; + } + LLPointer<LLViewerInventoryItem> lastitem; // hack + item_array_t items; + update_map_t update; + S32 count = msg->getNumberOfBlocksFast(_PREHASH_InventoryData); + for(S32 i = 0; i < count; ++i) + { + LLPointer<LLViewerInventoryItem> titem = new LLViewerInventoryItem; + lastitem = titem; + titem->unpackMessage(msg, _PREHASH_InventoryData, i); + lldebugs << "LLInventoryModel::messageUpdateCore() item id:" + << titem->getUUID() << llendl; + items.push_back(titem); + // examine update for changes. + LLViewerInventoryItem* itemp = gInventory.getItem(titem->getUUID()); + if(itemp) + { + if(titem->getParentUUID() == itemp->getParentUUID()) + { + update[titem->getParentUUID()]; + } + else + { + ++update[titem->getParentUUID()]; + --update[itemp->getParentUUID()]; + } + } + else + { + ++update[titem->getParentUUID()]; + } + } + if(account) + { + gInventory.accountForUpdate(update); + } + + U32 changes = 0x0; + for (item_array_t::iterator it = items.begin(); it != items.end(); ++it) + { + changes |= gInventory.updateItem(*it); + } + gInventory.notifyObservers(); + gViewerWindow->getWindow()->decBusyCount(); + + // *HACK: Do the 'show' logic for a new item in the inventory if + // it is a newly created item. + if (highlight_new + && (changes & LLInventoryObserver::ADD) == LLInventoryObserver::ADD) + { + LLUUID trash_id; + trash_id = gInventory.findCategoryUUIDForType(LLAssetType::AT_TRASH); + if(!gInventory.isObjectDescendentOf(lastitem->getUUID(), trash_id)) + { + bool show_keep_discard = lastitem->getPermissions().getCreator() != gAgent.getID(); + switch(lastitem->getType()) + { + case LLAssetType::AT_NOTECARD: + open_notecard( + lastitem->getUUID(), + LLString("Note: ") + lastitem->getName(), + show_keep_discard); + break; + case LLAssetType::AT_LANDMARK: + open_landmark( + lastitem->getUUID(), + LLString(" ") + lastitem->getName(), + show_keep_discard); + break; + case LLAssetType::AT_TEXTURE: + open_texture( + lastitem->getUUID(), + LLString("Texture: ") + lastitem->getName(), + show_keep_discard); + break; + default: + break; + } + LLInventoryView* view = LLInventoryView::getActiveInventory(); + if(view) + { + LLUUID lost_and_found_id = gInventory.findCategoryUUIDForType(LLAssetType::AT_LOST_AND_FOUND); + BOOL inventory_has_focus = gFocusMgr.childHasKeyboardFocus(view); + BOOL user_is_away = gAwayTimer.getStarted(); + + // don't select lost and found items if an active user is working in the inventory + if (!gInventory.isObjectDescendentOf(lastitem->getUUID(), lost_and_found_id) || + !inventory_has_focus || + user_is_away) + { + LLUICtrl* focus_ctrl = gFocusMgr.getKeyboardFocus(); + LLFocusMgr::FocusLostCallback callback = gFocusMgr.getFocusCallback(); + view->getPanel()->setSelection(lastitem->getUUID(), TAKE_FOCUS_NO); + // HACK to open inventory offers that are + // accepted. This information really needs to + // flow through the instant messages and + // inventory restore keyboard focus + gFocusMgr.setKeyboardFocus(focus_ctrl, callback); + } + } + } + } + return true; +} + +// static +void LLInventoryModel::processRemoveInventoryItem(LLMessageSystem* msg, void**) +{ + lldebugs << "LLInventoryModel::processRemoveInventoryItem()" << llendl; + LLUUID agent_id, item_id; + msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id); + if(agent_id != gAgent.getID()) + { + llwarns << "Got a RemoveInventoryItem for the wrong agent." + << llendl; + return; + } + S32 count = msg->getNumberOfBlocksFast(_PREHASH_InventoryData); + std::vector<LLUUID> item_ids; + update_map_t update; + for(S32 i = 0; i < count; ++i) + { + msg->getUUIDFast(_PREHASH_InventoryData, _PREHASH_ItemID, item_id, i); + LLViewerInventoryItem* itemp = gInventory.getItem(item_id); + if(itemp) + { + // we only bother with the delete and account if we found + // the item - this is usually a back-up for permissions, + // so frequently the item will already be gone. + --update[itemp->getParentUUID()]; + item_ids.push_back(item_id); + } + } + gInventory.accountForUpdate(update); + for(std::vector<LLUUID>::iterator it = item_ids.begin(); it != item_ids.end(); ++it) + { + gInventory.deleteObject(*it); + } + gInventory.notifyObservers(); +} + +// static +void LLInventoryModel::processUpdateInventoryFolder(LLMessageSystem* msg, + void**) +{ + lldebugs << "LLInventoryModel::processUpdateInventoryFolder()" << llendl; + LLUUID agent_id, folder_id, parent_id; + //char name[DB_INV_ITEM_NAME_BUF_SIZE]; + msg->getUUIDFast(_PREHASH_FolderData, _PREHASH_AgentID, agent_id); + if(agent_id != gAgent.getID()) + { + llwarns << "Got an UpdateInventoryFolder for the wrong agent." + << llendl; + return; + } + LLPointer<LLViewerInventoryCategory> lastfolder; // hack + cat_array_t folders; + update_map_t update; + S32 count = msg->getNumberOfBlocksFast(_PREHASH_FolderData); + for(S32 i = 0; i < count; ++i) + { + LLPointer<LLViewerInventoryCategory> tfolder = new LLViewerInventoryCategory(gAgent.getID()); + lastfolder = tfolder; + tfolder->unpackMessage(msg, _PREHASH_FolderData, i); + // make sure it's not a protected folder + tfolder->setPreferredType(LLAssetType::AT_NONE); + folders.push_back(tfolder); + // examine update for changes. + LLViewerInventoryCategory* folderp = gInventory.getCategory(tfolder->getUUID()); + if(folderp) + { + if(tfolder->getParentUUID() == folderp->getParentUUID()) + { + update[tfolder->getParentUUID()]; + } + else + { + ++update[tfolder->getParentUUID()]; + --update[folderp->getParentUUID()]; + } + } + else + { + ++update[tfolder->getParentUUID()]; + } + } + gInventory.accountForUpdate(update); + for (cat_array_t::iterator it = folders.begin(); it != folders.end(); ++it) + { + gInventory.updateCategory(*it); + } + gInventory.notifyObservers(); + + // *HACK: Do the 'show' logic for a new item in the inventory. + LLInventoryView* view = LLInventoryView::getActiveInventory(); + if(view) + { + view->getPanel()->setSelection(lastfolder->getUUID(), TAKE_FOCUS_NO); + } +} + +// static +void LLInventoryModel::processRemoveInventoryFolder(LLMessageSystem* msg, + void**) +{ + lldebugs << "LLInventoryModel::processRemoveInventoryFolder()" << llendl; + LLUUID agent_id, folder_id; + msg->getUUIDFast(_PREHASH_FolderData, _PREHASH_AgentID, agent_id); + if(agent_id != gAgent.getID()) + { + llwarns << "Got a RemoveInventoryFolder for the wrong agent." + << llendl; + return; + } + std::vector<LLUUID> folder_ids; + update_map_t update; + S32 count = msg->getNumberOfBlocksFast(_PREHASH_FolderData); + for(S32 i = 0; i < count; ++i) + { + msg->getUUIDFast(_PREHASH_FolderData, _PREHASH_FolderID, folder_id, i); + LLViewerInventoryCategory* folderp = gInventory.getCategory(folder_id); + if(folderp) + { + --update[folderp->getParentUUID()]; + folder_ids.push_back(folder_id); + } + } + gInventory.accountForUpdate(update); + for(std::vector<LLUUID>::iterator it = folder_ids.begin(); it != folder_ids.end(); ++it) + { + gInventory.deleteObject(*it); + } + gInventory.notifyObservers(); +} + +// static +void LLInventoryModel::processSaveAssetIntoInventory(LLMessageSystem* msg, + void**) +{ + LLUUID agent_id; + msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id); + if(agent_id != gAgent.getID()) + { + llwarns << "Got a SaveAssetIntoInventory message for the wrong agent." + << llendl; + return; + } + + LLUUID item_id; + msg->getUUIDFast(_PREHASH_InventoryData, _PREHASH_ItemID, item_id); + LLUUID new_asset_id; + msg->getUUIDFast(_PREHASH_InventoryData, _PREHASH_NewAssetID, new_asset_id); + + lldebugs << "LLInventoryModel::processSaveAssetIntoInventory itemID=" << item_id << llendl; + + LLViewerInventoryItem* item = gInventory.getItem( item_id ); + if( item ) + { + item->setAssetUUID(new_asset_id); + LLCategoryUpdate up(item->getParentUUID(), 0); + gInventory.accountForUpdate(up); + gInventory.addChangedMask( LLInventoryObserver::INTERNAL, item_id ); + gInventory.notifyObservers(); + } + else + { + llinfos << "LLInventoryModel::processSaveAssetIntoInventory item not found: " << item_id << llendl; + } + if(gViewerWindow) + { + gViewerWindow->getWindow()->decBusyCount(); + } +} + +struct InventoryCallbackInfo +{ + InventoryCallbackInfo(U32 callback, const LLUUID& inv_id) : + mCallback(callback), mInvID(inv_id) {} + U32 mCallback; + LLUUID mInvID; +}; + +// static +void LLInventoryModel::processBulkUpdateInventory(LLMessageSystem* msg, void**) +{ + LLUUID agent_id; + msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id); + if(agent_id != gAgent.getID()) + { + llwarns << "Got a BulkUpdateInventory for the wrong agent." << llendl; + return; + } + LLUUID tid; + msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_TransactionID, tid); + llinfos << "Bulk inventory: " << tid << llendl; + + update_map_t update; + cat_array_t folders; + S32 count; + S32 i; + count = msg->getNumberOfBlocksFast(_PREHASH_FolderData); + for(i = 0; i < count; ++i) + { + LLPointer<LLViewerInventoryCategory> tfolder = new LLViewerInventoryCategory(gAgent.getID()); + tfolder->unpackMessage(msg, _PREHASH_FolderData, i); + //llinfos << "unpaked folder '" << tfolder->getName() << "' (" + // << tfolder->getUUID() << ") in " << tfolder->getParentUUID() + // << llendl; + if(tfolder->getUUID().notNull()) + { + folders.push_back(tfolder); + LLViewerInventoryCategory* folderp = gInventory.getCategory(tfolder->getUUID()); + if(folderp) + { + if(tfolder->getParentUUID() == folderp->getParentUUID()) + { + update[tfolder->getParentUUID()]; + } + else + { + ++update[tfolder->getParentUUID()]; + --update[folderp->getParentUUID()]; + } + } + else + { + // we could not find the folder, so it is probably + // new. However, we only want to attempt accounting + // for the parent if we can find the parent. + folderp = gInventory.getCategory(tfolder->getParentUUID()); + if(folderp) + { + ++update[tfolder->getParentUUID()]; + } + } + } + } + + + count = msg->getNumberOfBlocksFast(_PREHASH_ItemData); + std::vector<LLUUID> wearable_ids; + item_array_t items; + std::list<InventoryCallbackInfo> cblist; + for(i = 0; i < count; ++i) + { + LLPointer<LLViewerInventoryItem> titem = new LLViewerInventoryItem; + titem->unpackMessage(msg, _PREHASH_ItemData, i); + //llinfos << "unpaked item '" << titem->getName() << "' in " + // << titem->getParentUUID() << llendl; + U32 callback_id; + msg->getU32Fast(_PREHASH_ItemData, _PREHASH_CallbackID, callback_id); + if(titem->getUUID().notNull()) + { + items.push_back(titem); + cblist.push_back(InventoryCallbackInfo(callback_id, titem->getUUID())); + if (titem->getInventoryType() == LLInventoryType::IT_WEARABLE) + { + wearable_ids.push_back(titem->getUUID()); + } + // examine update for changes. + LLViewerInventoryItem* itemp = gInventory.getItem(titem->getUUID()); + if(itemp) + { + if(titem->getParentUUID() == itemp->getParentUUID()) + { + update[titem->getParentUUID()]; + } + else + { + ++update[titem->getParentUUID()]; + --update[itemp->getParentUUID()]; + } + } + else + { + LLViewerInventoryCategory* folderp = gInventory.getCategory(titem->getParentUUID()); + if(folderp) + { + ++update[titem->getParentUUID()]; + } + } + } + else + { + cblist.push_back(InventoryCallbackInfo(callback_id, LLUUID::null)); + } + } + gInventory.accountForUpdate(update); + + for (cat_array_t::iterator cit = folders.begin(); cit != folders.end(); ++cit) + { + gInventory.updateCategory(*cit); + } + for (item_array_t::iterator iit = items.begin(); iit != items.end(); ++iit) + { + gInventory.updateItem(*iit); + } + gInventory.notifyObservers(); + + // The incoming inventory could span more than one BulkInventoryUpdate packet, + // so record the transaction ID for this purchase, then wear all clothing + // that comes in as part of that transaction ID. JC + if (LLInventoryView::sWearNewClothing) + { + LLInventoryView::sWearNewClothingTransactionID = tid; + LLInventoryView::sWearNewClothing = FALSE; + } + + if (tid == LLInventoryView::sWearNewClothingTransactionID) + { + count = wearable_ids.size(); + for (i = 0; i < count; ++i) + { + LLViewerInventoryItem* wearable_item; + wearable_item = gInventory.getItem(wearable_ids[i]); + wear_inventory_item_on_avatar(wearable_item); + } + } + + std::list<InventoryCallbackInfo>::iterator inv_it; + for (inv_it = cblist.begin(); inv_it != cblist.end(); ++inv_it) + { + InventoryCallbackInfo cbinfo = (*inv_it); + gInventoryCallbacks.fire(cbinfo.mCallback, cbinfo.mInvID); + } + // Don't show the inventory. We used to call showAgentInventory here. + //LLInventoryView* view = LLInventoryView::getActiveInventory(); + //if(view) + //{ + // const BOOL take_keyboard_focus = FALSE; + // view->setSelection(category.getUUID(), take_keyboard_focus ); + // LLView* focus_view = gFocusMgr.getKeyboardFocus(); + // LLFocusMgr::FocusLostCallback callback = gFocusMgr.getFocusCallback(); + // // HACK to open inventory offers that are accepted. This information + // // really needs to flow through the instant messages and inventory + // // transfer/update messages. + // if (LLInventoryView::sOpenNextNewItem) + // { + // view->openSelected(); + // LLInventoryView::sOpenNextNewItem = FALSE; + // } + // + // // restore keyboard focus + // gFocusMgr.setKeyboardFocus(focus_view, callback); + //} +} + +// static +void LLInventoryModel::processInventoryDescendents(LLMessageSystem* msg,void**) +{ + LLUUID agent_id; + msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id); + if(agent_id != gAgent.getID()) + { + llwarns << "Got a UpdateInventoryItem for the wrong agent." + << llendl; + return; + } + LLUUID parent_id; + msg->getUUID("AgentData", "FolderID", parent_id); + LLUUID owner_id; + msg->getUUID("AgentData", "OwnerID", owner_id); + S32 version; + msg->getS32("AgentData", "Version", version); + S32 descendents; + msg->getS32("AgentData", "Descendents", descendents); + S32 i; + S32 count = msg->getNumberOfBlocksFast(_PREHASH_FolderData); + LLPointer<LLViewerInventoryCategory> tcategory = new LLViewerInventoryCategory(owner_id); + for(i = 0; i < count; ++i) + { + tcategory->unpackMessage(msg, _PREHASH_FolderData, i); + gInventory.updateCategory(tcategory); + } + + count = msg->getNumberOfBlocksFast(_PREHASH_ItemData); + LLPointer<LLViewerInventoryItem> titem = new LLViewerInventoryItem; + for(i = 0; i < count; ++i) + { + titem->unpackMessage(msg, _PREHASH_ItemData, i); + gInventory.updateItem(titem); + } + + // set version and descendentcount according to message. + LLViewerInventoryCategory* cat = gInventory.getCategory(parent_id); + if(cat) + { + cat->setVersion(version); + cat->setDescendentCount(descendents); + } + gInventory.notifyObservers(); +} + +// static +void LLInventoryModel::processMoveInventoryItem(LLMessageSystem* msg, void**) +{ + lldebugs << "LLInventoryModel::processMoveInventoryItem()" << llendl; + LLUUID agent_id; + msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id); + if(agent_id != gAgent.getID()) + { + llwarns << "Got a MoveInventoryItem message for the wrong agent." + << llendl; + return; + } + + LLUUID item_id; + LLUUID folder_id; + char new_name[MAX_STRING]; + bool anything_changed = false; + S32 count = msg->getNumberOfBlocksFast(_PREHASH_InventoryData); + for(S32 i = 0; i < count; ++i) + { + msg->getUUIDFast(_PREHASH_InventoryData, _PREHASH_ItemID, item_id, i); + LLViewerInventoryItem* item = gInventory.getItem(item_id); + if(item) + { + LLPointer<LLViewerInventoryItem> new_item = new LLViewerInventoryItem(item); + msg->getUUIDFast(_PREHASH_InventoryData, _PREHASH_FolderID, folder_id, i); + msg->getString("InventoryData", "NewName", MAX_STRING, new_name, i); + + lldebugs << "moving item " << item_id << " to folder " + << folder_id << llendl; + update_list_t update; + LLCategoryUpdate old_folder(item->getParentUUID(), -1); + update.push_back(old_folder); + LLCategoryUpdate new_folder(folder_id, 1); + update.push_back(new_folder); + gInventory.accountForUpdate(update); + + new_item->setParent(folder_id); + if(strlen(new_name) > 0) + { + new_item->rename(new_name); + } + gInventory.updateItem(new_item); + anything_changed = true; + } + else + { + llinfos << "LLInventoryModel::processMoveInventoryItem item not found: " << item_id << llendl; + } + } + if(anything_changed) + { + gInventory.notifyObservers(); + } +} + +// *NOTE: DEBUG functionality +void LLInventoryModel::dumpInventory() +{ + llinfos << "\nBegin Inventory Dump\n**********************:" << llendl; + llinfos << "mCategroy[] contains " << mCategoryMap.size() << " items." << llendl; + for(cat_map_t::iterator cit = mCategoryMap.begin(); cit != mCategoryMap.end(); ++cit) + { + LLViewerInventoryCategory* cat = cit->second; + if(cat) + { + llinfos << " " << cat->getUUID() << " '" << cat->getName() << "' " + << cat->getVersion() << " " << cat->getDescendentCount() + << llendl; + } + else + { + llinfos << " NULL!" << llendl; + } + } + llinfos << "mItemMap[] contains " << mItemMap.size() << " items." << llendl; + for(item_map_t::iterator iit = mItemMap.begin(); iit != mItemMap.end(); ++iit) + { + LLViewerInventoryItem* item = iit->second; + if(item) + { + llinfos << " " << item->getUUID() << " " + << item->getName() << llendl; + } + else + { + llinfos << " NULL!" << llendl; + } + } + llinfos << "\n**********************\nEnd Inventory Dump" << llendl; +} + + +///---------------------------------------------------------------------------- +/// LLInventoryCollectFunctor implementations +///---------------------------------------------------------------------------- + +bool LLIsType::operator()(LLInventoryCategory* cat, LLInventoryItem* item) +{ + if(mType == LLAssetType::AT_CATEGORY) + { + if(cat) return TRUE; + } + if(item) + { + if(item->getType() == mType) return TRUE; + } + return FALSE; +} + +bool LLIsNotType::operator()(LLInventoryCategory* cat, LLInventoryItem* item) +{ + if(mType == LLAssetType::AT_CATEGORY) + { + if(cat) return FALSE; + } + if(item) + { + if(item->getType() == mType) return FALSE; + else return TRUE; + } + return TRUE; +} + +bool LLIsTypeWithPermissions::operator()(LLInventoryCategory* cat, LLInventoryItem* item) +{ + if(mType == LLAssetType::AT_CATEGORY) + { + if(cat) + { + return TRUE; + } + } + if(item) + { + if(item->getType() == mType) + { + LLPermissions perm = item->getPermissions(); + if ((perm.getMaskBase() & mPerm) == mPerm) + { + return TRUE; + } + } + } + return FALSE; +} + + +//bool LLIsClone::operator()(LLInventoryCategory* cat, LLInventoryItem* item) +//{ +// if(cat) return FALSE; +// if(item) +// { +// if(mItemMap->getType() == LLAssetType::AT_CALLINGCARD) +// { +// if((item->getType() == LLAssetType::AT_CALLINGCARD) +// && !(item->getCreatorUUID().isNull()) +// && (item->getCreatorUUID() == mItemMap->getCreatorUUID())) +// { +// return TRUE; +// } +// } +// else +// { +// if((item->getType() == mItemMap->getType()) +// && !(item->getAssetUUID().isNull()) +// && (item->getAssetUUID() == mItemMap->getAssetUUID()) +// && (item->getName() == mItemMap->getName())) +// { +// return TRUE; +// } +// } +// } +// return FALSE; +//} + +bool LLBuddyCollector::operator()(LLInventoryCategory* cat, + LLInventoryItem* item) +{ + if(item) + { + if((LLAssetType::AT_CALLINGCARD == item->getType()) + && (!item->getCreatorUUID().isNull()) + && (item->getCreatorUUID() != gAgent.getID())) + { + return true; + } + } + return false; +} + + +bool LLUniqueBuddyCollector::operator()(LLInventoryCategory* cat, + LLInventoryItem* item) +{ + if(item) + { + if((LLAssetType::AT_CALLINGCARD == item->getType()) + && (item->getCreatorUUID().notNull()) + && (item->getCreatorUUID() != gAgent.getID())) + { + mSeen.insert(item->getCreatorUUID()); + return true; + } + } + return false; +} + + +bool LLParticularBuddyCollector::operator()(LLInventoryCategory* cat, + LLInventoryItem* item) +{ + if(item) + { + if((LLAssetType::AT_CALLINGCARD == item->getType()) + && (item->getCreatorUUID() == mBuddyID)) + { + return TRUE; + } + } + return FALSE; +} + + +bool LLNameCategoryCollector::operator()( + LLInventoryCategory* cat, LLInventoryItem* item) +{ + if(cat) + { + if (!LLString::compareInsensitive(mName.c_str(), cat->getName().c_str())) + { + return true; + } + } + return false; +} + + + +///---------------------------------------------------------------------------- +/// Observers +///---------------------------------------------------------------------------- + +void LLInventoryCompletionObserver::changed(U32 mask) +{ + // scan through the incomplete items and move or erase them as + // appropriate. + if(!mIncomplete.empty()) + { + for(item_ref_t::iterator it = mIncomplete.begin(); it < mIncomplete.end(); ) + { + LLViewerInventoryItem* item = gInventory.getItem(*it); + if(!item) + { + it = mIncomplete.erase(it); + continue; + } + if(item->isComplete()) + { + mComplete.push_back(*it); + it = mIncomplete.erase(it); + continue; + } + ++it; + } + if(mIncomplete.empty()) + { + done(); + } + } +} + +void LLInventoryCompletionObserver::watchItem(const LLUUID& id) +{ + if(id.notNull()) + { + mIncomplete.push_back(id); + } +} + + +void LLInventoryFetchObserver::changed(U32 mask) +{ + // scan through the incomplete items and move or erase them as + // appropriate. + if(!mIncomplete.empty()) + { + for(item_ref_t::iterator it = mIncomplete.begin(); it < mIncomplete.end(); ) + { + LLViewerInventoryItem* item = gInventory.getItem(*it); + if(!item) + { + // BUG: This can cause done() to get called prematurely below. + // This happens with the LLGestureInventoryFetchObserver that + // loads gestures at startup. JC + it = mIncomplete.erase(it); + continue; + } + if(item->isComplete()) + { + mComplete.push_back(*it); + it = mIncomplete.erase(it); + continue; + } + ++it; + } + if(mIncomplete.empty()) + { + done(); + } + } + //llinfos << "LLInventoryFetchObserver::changed() mComplete size " << mComplete.size() << llendl; + //llinfos << "LLInventoryFetchObserver::changed() mIncomplete size " << mIncomplete.size() << llendl; +} + +bool LLInventoryFetchObserver::isEverythingComplete() const +{ + return mIncomplete.empty(); +} + +void LLInventoryFetchObserver::fetchItems( + const LLInventoryFetchObserver::item_ref_t& ids) +{ + LLMessageSystem* msg = gMessageSystem; + BOOL start_new_message = TRUE; + LLUUID owner_id; + for(item_ref_t::const_iterator it = ids.begin(); it < ids.end(); ++it) + { + LLViewerInventoryItem* item = gInventory.getItem(*it); + if(item) + { + if(item->isComplete()) + { + // It's complete, so put it on the complete container. + mComplete.push_back(*it); + continue; + } + else + { + owner_id = item->getPermissions().getOwner(); + } + } + else + { + // assume it's agent inventory. + owner_id = gAgent.getID(); + } + + // It's incomplete, so put it on the incomplete container, and + // pack this on the message. + mIncomplete.push_back(*it); + if(start_new_message) + { + start_new_message = FALSE; + msg->newMessageFast(_PREHASH_FetchInventory); + msg->nextBlockFast(_PREHASH_AgentData); + msg->addUUIDFast(_PREHASH_AgentID, gAgent.getID()); + msg->addUUIDFast(_PREHASH_SessionID, gAgent.getSessionID()); + } + msg->nextBlockFast(_PREHASH_InventoryData); + msg->addUUIDFast(_PREHASH_OwnerID, owner_id); + msg->addUUIDFast(_PREHASH_ItemID, (*it)); + if(msg->getCurrentSendTotal() >= MTUBYTES) + { + start_new_message = TRUE; + gAgent.sendReliableMessage(); + } + } + if(!start_new_message) + { + gAgent.sendReliableMessage(); + } +} + +// virtual +void LLInventoryFetchDescendentsObserver::changed(U32 mask) +{ + for(folder_ref_t::iterator it = mIncompleteFolders.begin(); it < mIncompleteFolders.end();) + { + LLViewerInventoryCategory* cat = gInventory.getCategory(*it); + if(!cat) + { + it = mIncompleteFolders.erase(it); + continue; + } + if(isComplete(cat)) + { + mCompleteFolders.push_back(*it); + it = mIncompleteFolders.erase(it); + continue; + } + ++it; + } + if(mIncompleteFolders.empty()) + { + done(); + } +} + +void LLInventoryFetchDescendentsObserver::fetchDescendents( + const folder_ref_t& ids) +{ + for(folder_ref_t::const_iterator it = ids.begin(); it != ids.end(); ++it) + { + LLViewerInventoryCategory* cat = gInventory.getCategory(*it); + if(!cat) continue; + if(!isComplete(cat)) + { + cat->fetchDescendents(); + mIncompleteFolders.push_back(*it); + } + else + { + mCompleteFolders.push_back(*it); + } + } +} + +bool LLInventoryFetchDescendentsObserver::isEverythingComplete() const +{ + return mIncompleteFolders.empty(); +} + +bool LLInventoryFetchDescendentsObserver::isComplete(LLViewerInventoryCategory* cat) +{ + S32 version = cat->getVersion(); + S32 descendents = cat->getDescendentCount(); + if((LLViewerInventoryCategory::VERSION_UNKNOWN == version) + || (LLViewerInventoryCategory::DESCENDENT_COUNT_UNKNOWN == descendents)) + { + return false; + } + // it might be complete - check known descendents against + // currently available. + LLInventoryModel::cat_array_t* cats; + LLInventoryModel::item_array_t* items; + gInventory.getDirectDescendentsOf(cat->getUUID(), cats, items); + if(!cats || !items) + { + // bit of a hack - pretend we're done if they are gone or + // incomplete. should never know, but it would suck if this + // kept tight looping because of a corrupt memory state. + return true; + } + S32 known = cats->count() + items->count(); + if(descendents == known) + { + // hey - we're done. + return true; + } + return false; +} + +void LLInventoryFetchComboObserver::changed(U32 mask) +{ + if(!mIncompleteItems.empty()) + { + for(item_ref_t::iterator it = mIncompleteItems.begin(); it < mIncompleteItems.end(); ) + { + LLViewerInventoryItem* item = gInventory.getItem(*it); + if(!item) + { + it = mIncompleteItems.erase(it); + continue; + } + if(item->isComplete()) + { + mCompleteItems.push_back(*it); + it = mIncompleteItems.erase(it); + continue; + } + ++it; + } + } + if(!mIncompleteFolders.empty()) + { + for(folder_ref_t::iterator it = mIncompleteFolders.begin(); it < mIncompleteFolders.end();) + { + LLViewerInventoryCategory* cat = gInventory.getCategory(*it); + if(!cat) + { + it = mIncompleteFolders.erase(it); + continue; + } + if(gInventory.isCategoryComplete(*it)) + { + mCompleteFolders.push_back(*it); + it = mIncompleteFolders.erase(it); + continue; + } + ++it; + } + } + if(!mDone && mIncompleteItems.empty() && mIncompleteFolders.empty()) + { + mDone = true; + done(); + } +} + +void LLInventoryFetchComboObserver::fetch( + const folder_ref_t& folder_ids, + const item_ref_t& item_ids) +{ + lldebugs << "LLInventoryFetchComboObserver::fetch()" << llendl; + for(folder_ref_t::const_iterator fit = folder_ids.begin(); fit != folder_ids.end(); ++fit) + { + LLViewerInventoryCategory* cat = gInventory.getCategory(*fit); + if(!cat) continue; + if(!gInventory.isCategoryComplete(*fit)) + { + cat->fetchDescendents(); + lldebugs << "fetching folder " << *fit <<llendl; + mIncompleteFolders.push_back(*fit); + } + else + { + mCompleteFolders.push_back(*fit); + lldebugs << "completing folder " << *fit <<llendl; + } + } + + // Now for the items - we fetch everything which is not a direct + // descendent of an incomplete folder because the item will show + // up in an inventory descendents message soon enough so we do not + // have to fetch it individually. + LLUUID owner_id; + LLMessageSystem* msg = gMessageSystem; + bool start_new_message = true; + for(item_ref_t::const_iterator iit = item_ids.begin(); iit != item_ids.end(); ++iit) + { + LLViewerInventoryItem* item = gInventory.getItem(*iit); + if(!item) + { + lldebugs << "uanble to find item " << *iit << llendl; + continue; + } + if(item->isComplete()) + { + // It's complete, so put it on the complete container. + mCompleteItems.push_back(*iit); + lldebugs << "completing item " << *iit << llendl; + continue; + } + else + { + mIncompleteItems.push_back(*iit); + owner_id = item->getPermissions().getOwner(); + } + if(std::find(mIncompleteFolders.begin(), mIncompleteFolders.end(), item->getParentUUID()) == mIncompleteFolders.end()) + { + lldebugs << "fetching item " << *iit << llendl; + if(start_new_message) + { + start_new_message = false; + msg->newMessageFast(_PREHASH_FetchInventory); + msg->nextBlockFast(_PREHASH_AgentData); + msg->addUUIDFast(_PREHASH_AgentID, gAgent.getID()); + msg->addUUIDFast(_PREHASH_SessionID, gAgent.getSessionID()); + } + msg->nextBlockFast(_PREHASH_InventoryData); + msg->addUUIDFast(_PREHASH_OwnerID, owner_id); + msg->addUUIDFast(_PREHASH_ItemID, (*iit)); + if(msg->isSendFullFast(_PREHASH_InventoryData)) + { + start_new_message = true; + gAgent.sendReliableMessage(); + } + } + else + { + lldebugs << "not worrying about " << *iit << llendl; + } + } + if(!start_new_message) + { + gAgent.sendReliableMessage(); + } +} + +void LLInventoryExistenceObserver::watchItem(const LLUUID& id) +{ + if(id.notNull()) + { + mMIA.push_back(id); + } +} + +void LLInventoryExistenceObserver::changed(U32 mask) +{ + // scan through the incomplete items and move or erase them as + // appropriate. + if(!mMIA.empty()) + { + for(item_ref_t::iterator it = mMIA.begin(); it < mMIA.end(); ) + { + LLViewerInventoryItem* item = gInventory.getItem(*it); + if(!item) + { + ++it; + continue; + } + mExist.push_back(*it); + it = mMIA.erase(it); + } + if(mMIA.empty()) + { + done(); + } + } +} + +LLInventoryTransactionObserver::LLInventoryTransactionObserver( + const LLTransactionID& transaction_id) : + mTransactionID(transaction_id) +{ +} + +void LLInventoryTransactionObserver::changed(U32 mask) +{ + if(mask & LLInventoryObserver::ADD) + { + // This could be it - see if we are processing a bulk update + LLMessageSystem* msg = gMessageSystem; + if(msg->getMessageName() + && (0 == strcmp(msg->getMessageName(), "BulkUpdateInventory"))) + { + // we have a match for the message - now check the + // transaction id. + LLUUID id; + msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_TransactionID, id); + if(id == mTransactionID) + { + // woo hoo, we found it + folder_ref_t folders; + item_ref_t items; + S32 count; + count = msg->getNumberOfBlocksFast(_PREHASH_FolderData); + S32 i; + for(i = 0; i < count; ++i) + { + msg->getUUIDFast(_PREHASH_FolderData, _PREHASH_FolderID, id, i); + if(id.notNull()) + { + folders.push_back(id); + } + } + count = msg->getNumberOfBlocksFast(_PREHASH_ItemData); + for(i = 0; i < count; ++i) + { + msg->getUUIDFast(_PREHASH_ItemData, _PREHASH_ItemID, id, i); + if(id.notNull()) + { + items.push_back(id); + } + } + + // call the derived class the implements this method. + done(folders, items); + } + } + } +} + + +///---------------------------------------------------------------------------- +/// LLAssetIDMatches +///---------------------------------------------------------------------------- +bool LLAssetIDMatches ::operator()(LLInventoryCategory* cat, LLInventoryItem* item) +{ + return (item && item->getAssetUUID() == mAssetID); +} + + +///---------------------------------------------------------------------------- +/// Local function definitions +///---------------------------------------------------------------------------- + + +/* +BOOL decompress_file(const char* src_filename, const char* dst_filename) +{ + BOOL rv = FALSE; + gzFile src = NULL; + U8* buffer = NULL; + FILE* dst = NULL; + S32 bytes = 0; + const S32 DECOMPRESS_BUFFER_SIZE = 32000; + + // open the files + src = gzopen(src_filename, "rb"); + if(!src) goto err_decompress; + dst = LLFile::fopen(dst_filename, "wb"); + if(!dst) goto err_decompress; + + // decompress. + buffer = new U8[DECOMPRESS_BUFFER_SIZE + 1]; + + do + { + bytes = gzread(src, buffer, DECOMPRESS_BUFFER_SIZE); + if (bytes < 0) + { + goto err_decompress; + } + + fwrite(buffer, bytes, 1, dst); + } while(gzeof(src) == 0); + + // success + rv = TRUE; + + err_decompress: + if(src != NULL) gzclose(src); + if(buffer != NULL) delete[] buffer; + if(dst != NULL) fclose(dst); + return rv; +} +*/ |