More styling fixes and other minor inconsistency fixes in inventorymodelbackgroundfetch code. (#2476)
parent
5b832291a8
commit
12d60b3d9b
|
|
@ -113,7 +113,7 @@ class BGItemHttpHandler : public LLInventoryModel::FetchItemHttpHandler
|
|||
LOG_CLASS(BGItemHttpHandler);
|
||||
|
||||
public:
|
||||
BGItemHttpHandler(const LLSD & request_sd)
|
||||
BGItemHttpHandler(const LLSD& request_sd)
|
||||
: LLInventoryModel::FetchItemHttpHandler(request_sd)
|
||||
{
|
||||
LLInventoryModelBackgroundFetch::instance().incrFetchCount(1);
|
||||
|
|
@ -125,8 +125,8 @@ public:
|
|||
}
|
||||
|
||||
protected:
|
||||
BGItemHttpHandler(const BGItemHttpHandler &); // Not defined
|
||||
void operator=(const BGItemHttpHandler &); // Not defined
|
||||
BGItemHttpHandler(const BGItemHttpHandler&); // Not defined
|
||||
void operator=(const BGItemHttpHandler&); // Not defined
|
||||
};
|
||||
|
||||
|
||||
|
|
@ -144,7 +144,7 @@ class BGFolderHttpHandler : public LLCore::HttpHandler
|
|||
LOG_CLASS(BGFolderHttpHandler);
|
||||
|
||||
public:
|
||||
BGFolderHttpHandler(const LLSD & request_sd, const uuid_vec_t & recursive_cats)
|
||||
BGFolderHttpHandler(const LLSD& request_sd, const uuid_vec_t& recursive_cats)
|
||||
: LLCore::HttpHandler(),
|
||||
mRequestSD(request_sd),
|
||||
mRecursiveCatUUIDs(recursive_cats)
|
||||
|
|
@ -158,18 +158,18 @@ public:
|
|||
}
|
||||
|
||||
protected:
|
||||
BGFolderHttpHandler(const BGFolderHttpHandler &); // Not defined
|
||||
void operator=(const BGFolderHttpHandler &); // Not defined
|
||||
BGFolderHttpHandler(const BGFolderHttpHandler&); // Not defined
|
||||
void operator=(const BGFolderHttpHandler&); // Not defined
|
||||
|
||||
public:
|
||||
virtual void onCompleted(LLCore::HttpHandle handle, LLCore::HttpResponse * response);
|
||||
virtual void onCompleted(LLCore::HttpHandle handle, LLCore::HttpResponse* response);
|
||||
|
||||
bool getIsRecursive(const LLUUID & cat_id) const;
|
||||
bool getIsRecursive(const LLUUID& cat_id) const;
|
||||
|
||||
private:
|
||||
void processData(LLSD & body, LLCore::HttpResponse * response);
|
||||
void processFailure(LLCore::HttpStatus status, LLCore::HttpResponse * response);
|
||||
void processFailure(const char * const reason, LLCore::HttpResponse * response);
|
||||
void processData(LLSD& body, LLCore::HttpResponse* response);
|
||||
void processFailure(LLCore::HttpStatus status, LLCore::HttpResponse* response);
|
||||
void processFailure(const char* const reason, LLCore::HttpResponse* response);
|
||||
|
||||
private:
|
||||
LLSD mRequestSD;
|
||||
|
|
@ -177,7 +177,7 @@ private:
|
|||
};
|
||||
|
||||
|
||||
const char * const LOG_INV("Inventory");
|
||||
const char* const LOG_INV("Inventory");
|
||||
|
||||
} // end of namespace anonymous
|
||||
|
||||
|
|
@ -391,7 +391,7 @@ void LLInventoryModelBackgroundFetch::scheduleFolderFetch(const LLUUID& cat_id,
|
|||
else
|
||||
{
|
||||
// Specific folder requests go to front of queue.
|
||||
// version presence acts as dupplicate prevention for normal fetches
|
||||
// version presence acts as duplicate prevention for normal fetches
|
||||
mFetchFolderQueue.emplace_front(cat_id, FT_DEFAULT);
|
||||
}
|
||||
|
||||
|
|
@ -415,7 +415,7 @@ void LLInventoryModelBackgroundFetch::scheduleItemFetch(const LLUUID& item_id, b
|
|||
}
|
||||
else
|
||||
{
|
||||
// 'isFinished' being set acts as dupplicate prevention for normal fetches
|
||||
// 'isFinished' being set acts as duplicate prevention for normal fetches
|
||||
mFetchItemQueue.emplace_front(item_id, FT_DEFAULT, false);
|
||||
}
|
||||
|
||||
|
|
@ -449,7 +449,7 @@ void LLInventoryModelBackgroundFetch::fetchFolderAndLinks(const LLUUID& cat_id,
|
|||
// start idle loop to track completion
|
||||
mBackgroundFetchActive = true;
|
||||
mFolderFetchActive = true;
|
||||
gIdleCallbacks.addFunction(&LLInventoryModelBackgroundFetch::backgroundFetchCB, NULL);
|
||||
gIdleCallbacks.addFunction(&LLInventoryModelBackgroundFetch::backgroundFetchCB, nullptr);
|
||||
}
|
||||
|
||||
void LLInventoryModelBackgroundFetch::fetchCOF(nullary_func_t callback)
|
||||
|
|
@ -513,7 +513,7 @@ boost::signals2::connection LLInventoryModelBackgroundFetch::setFetchCompletionC
|
|||
return mFoldersFetchedSignal.connect(cb);
|
||||
}
|
||||
|
||||
void LLInventoryModelBackgroundFetch::backgroundFetchCB(void *)
|
||||
void LLInventoryModelBackgroundFetch::backgroundFetchCB(void*)
|
||||
{
|
||||
LLInventoryModelBackgroundFetch::instance().backgroundFetch();
|
||||
}
|
||||
|
|
@ -566,7 +566,7 @@ void LLInventoryModelBackgroundFetch::onAISContentCalback(
|
|||
const LLUUID& response_id,
|
||||
EFetchType fetch_type)
|
||||
{
|
||||
// Don't push_front on failure - there is a chance it was fired from inside bulkFetchViaAis
|
||||
// Don't emplace_front on failure - there is a chance it was fired from inside bulkFetchViaAis
|
||||
incrFetchFolderCount(-1);
|
||||
|
||||
uuid_vec_t::const_iterator folder_iter = content_ids.begin();
|
||||
|
|
@ -587,7 +587,7 @@ void LLInventoryModelBackgroundFetch::onAISContentCalback(
|
|||
if (response_id.isNull())
|
||||
{
|
||||
// Failed to fetch, get it individually
|
||||
mFetchFolderQueue.push_back(FetchQueueInfo(*folder_iter, FT_RECURSIVE));
|
||||
mFetchFolderQueue.emplace_back(*folder_iter, FT_RECURSIVE);
|
||||
}
|
||||
else
|
||||
{
|
||||
|
|
@ -601,7 +601,7 @@ void LLInventoryModelBackgroundFetch::onAISContentCalback(
|
|||
it != categories->end();
|
||||
++it)
|
||||
{
|
||||
mFetchFolderQueue.push_back(FetchQueueInfo((*it)->getUUID(), FT_RECURSIVE));
|
||||
mFetchFolderQueue.emplace_back((*it)->getUUID(), FT_RECURSIVE);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -613,12 +613,12 @@ void LLInventoryModelBackgroundFetch::onAISContentCalback(
|
|||
{
|
||||
mBackgroundFetchActive = true;
|
||||
mFolderFetchActive = true;
|
||||
gIdleCallbacks.addFunction(&LLInventoryModelBackgroundFetch::backgroundFetchCB, NULL);
|
||||
gIdleCallbacks.addFunction(&LLInventoryModelBackgroundFetch::backgroundFetchCB, nullptr);
|
||||
}
|
||||
}
|
||||
void LLInventoryModelBackgroundFetch::onAISFolderCalback(const LLUUID &request_id, const LLUUID &response_id, EFetchType fetch_type)
|
||||
void LLInventoryModelBackgroundFetch::onAISFolderCalback(const LLUUID& request_id, const LLUUID& response_id, EFetchType fetch_type)
|
||||
{
|
||||
// Don't push_front on failure - there is a chance it was fired from inside bulkFetchViaAis
|
||||
// Don't emplace_front on failure - there is a chance it was fired from inside bulkFetchViaAis
|
||||
incrFetchFolderCount(-1);
|
||||
std::list<LLUUID>::const_iterator found = std::find(mExpectedFolderIds.begin(), mExpectedFolderIds.end(), request_id);
|
||||
if (found != mExpectedFolderIds.end())
|
||||
|
|
@ -634,7 +634,7 @@ void LLInventoryModelBackgroundFetch::onAISFolderCalback(const LLUUID &request_i
|
|||
|
||||
if (request_id.isNull())
|
||||
{
|
||||
// orhans, no other actions needed
|
||||
// orphans, no other actions needed
|
||||
return;
|
||||
}
|
||||
|
||||
|
|
@ -647,12 +647,12 @@ void LLInventoryModelBackgroundFetch::onAISFolderCalback(const LLUUID &request_i
|
|||
{
|
||||
// A full recursive request failed.
|
||||
// Try requesting folder and nested content separately
|
||||
mFetchFolderQueue.push_back(FetchQueueInfo(request_id, FT_FOLDER_AND_CONTENT));
|
||||
mFetchFolderQueue.emplace_back(request_id, FT_FOLDER_AND_CONTENT);
|
||||
}
|
||||
else if (fetch_type == FT_FOLDER_AND_CONTENT)
|
||||
{
|
||||
LL_WARNS() << "Failed to download folder: " << request_id << " Requesting known content separately" << LL_ENDL;
|
||||
mFetchFolderQueue.push_back(FetchQueueInfo(request_id, FT_CONTENT_RECURSIVE));
|
||||
mFetchFolderQueue.emplace_back(request_id, FT_CONTENT_RECURSIVE);
|
||||
|
||||
// set folder's version to prevent viewer from trying to request folder indefinetely
|
||||
LLViewerInventoryCategory* cat(gInventory.getCategory(request_id));
|
||||
|
|
@ -670,15 +670,15 @@ void LLInventoryModelBackgroundFetch::onAISFolderCalback(const LLUUID &request_i
|
|||
{
|
||||
// Got the folder and content, now verify content
|
||||
// Request content even for FT_RECURSIVE in case of changes, failures
|
||||
// or if depth limit gets imlemented.
|
||||
// or if depth limit gets implemented.
|
||||
// This shouldn't redownload folders if they already have version
|
||||
request_descendants = true;
|
||||
LL_DEBUGS(LOG_INV, "AIS3") << "Got folder " << request_id << ". Requesting content" << LL_ENDL;
|
||||
}
|
||||
else if (fetch_type == FT_FOLDER_AND_CONTENT)
|
||||
{
|
||||
// readd folder for content request
|
||||
mFetchFolderQueue.push_front(FetchQueueInfo(request_id, FT_CONTENT_RECURSIVE));
|
||||
// read folder for content request
|
||||
mFetchFolderQueue.emplace_front(request_id, FT_CONTENT_RECURSIVE);
|
||||
}
|
||||
else
|
||||
{
|
||||
|
|
@ -698,7 +698,7 @@ void LLInventoryModelBackgroundFetch::onAISFolderCalback(const LLUUID &request_i
|
|||
it != categories->end();
|
||||
++it)
|
||||
{
|
||||
mFetchFolderQueue.push_back(FetchQueueInfo((*it)->getUUID(), FT_RECURSIVE));
|
||||
mFetchFolderQueue.emplace_back((*it)->getUUID(), FT_RECURSIVE);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -707,11 +707,11 @@ void LLInventoryModelBackgroundFetch::onAISFolderCalback(const LLUUID &request_i
|
|||
{
|
||||
mBackgroundFetchActive = true;
|
||||
mFolderFetchActive = true;
|
||||
gIdleCallbacks.addFunction(&LLInventoryModelBackgroundFetch::backgroundFetchCB, NULL);
|
||||
gIdleCallbacks.addFunction(&LLInventoryModelBackgroundFetch::backgroundFetchCB, nullptr);
|
||||
}
|
||||
|
||||
// done
|
||||
LLViewerInventoryCategory * cat(gInventory.getCategory(request_id));
|
||||
LLViewerInventoryCategory* cat(gInventory.getCategory(request_id));
|
||||
if (cat)
|
||||
{
|
||||
cat->setFetching(new_state);
|
||||
|
|
@ -749,7 +749,7 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis()
|
|||
|
||||
while (!mFetchFolderQueue.empty() && (U32)mFetchCount < max_concurrent_fetches && curent_time < end_time)
|
||||
{
|
||||
const FetchQueueInfo & fetch_info(mFetchFolderQueue.front());
|
||||
const FetchQueueInfo& fetch_info(mFetchFolderQueue.front());
|
||||
bulkFetchViaAis(fetch_info);
|
||||
mFetchFolderQueue.pop_front();
|
||||
curent_time = LLTimer::getTotalSeconds();
|
||||
|
|
@ -757,7 +757,7 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis()
|
|||
|
||||
// Ideally we shouldn't fetch items if recursive fetch isn't done,
|
||||
// but there is a chance some request will start timeouting and recursive
|
||||
// fetch will get stuck on a signle folder, don't block item fetch in such case
|
||||
// fetch will get stuck on a single folder, don't block item fetch in such case
|
||||
while (!mFetchItemQueue.empty() && (U32)mFetchCount < max_concurrent_fetches && curent_time < end_time)
|
||||
{
|
||||
const FetchQueueInfo& fetch_info(mFetchItemQueue.front());
|
||||
|
|
@ -815,7 +815,7 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis()
|
|||
const LLUUID& marketplacelistings_id = gInventory.findCategoryUUIDForType(LLFolderType::FT_MARKETPLACE_LISTINGS);
|
||||
if (marketplacelistings_id.notNull())
|
||||
{
|
||||
mFetchFolderQueue.push_front(FetchQueueInfo(marketplacelistings_id, FT_FOLDER_AND_CONTENT));
|
||||
mFetchFolderQueue.emplace_front(marketplacelistings_id, FT_FOLDER_AND_CONTENT);
|
||||
}
|
||||
else
|
||||
{
|
||||
|
|
@ -835,11 +835,11 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis(const FetchQueueInfo& fetc
|
|||
{
|
||||
if (fetch_info.mIsCategory)
|
||||
{
|
||||
const LLUUID & cat_id(fetch_info.mUUID);
|
||||
const LLUUID& cat_id(fetch_info.mUUID);
|
||||
if (cat_id.isNull())
|
||||
{
|
||||
incrFetchFolderCount(1);
|
||||
mExpectedFolderIds.push_back(cat_id);
|
||||
mExpectedFolderIds.emplace_back(cat_id);
|
||||
// Lost and found
|
||||
// Should it actually be recursive?
|
||||
AISAPI::FetchOrphans([](const LLUUID& response_id)
|
||||
|
|
@ -851,7 +851,7 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis(const FetchQueueInfo& fetc
|
|||
}
|
||||
else
|
||||
{
|
||||
LLViewerInventoryCategory * cat(gInventory.getCategory(cat_id));
|
||||
LLViewerInventoryCategory* cat(gInventory.getCategory(cat_id));
|
||||
if (cat)
|
||||
{
|
||||
if (fetch_info.mFetchType == FT_CONTENT_RECURSIVE)
|
||||
|
|
@ -886,8 +886,8 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis(const FetchQueueInfo& fetc
|
|||
continue;
|
||||
}
|
||||
|
||||
children.push_back(child_cat->getUUID());
|
||||
mExpectedFolderIds.push_back(child_cat->getUUID());
|
||||
children.emplace_back(child_cat->getUUID());
|
||||
mExpectedFolderIds.emplace_back(child_cat->getUUID());
|
||||
child_cat->setFetching(target_state);
|
||||
|
||||
if (children.size() >= batch_limit)
|
||||
|
|
@ -921,7 +921,7 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis(const FetchQueueInfo& fetc
|
|||
if (content_done)
|
||||
{
|
||||
// This will have a bit of overlap with onAISContentCalback,
|
||||
// but something else might have dowloaded folders, so verify
|
||||
// but something else might have downloaded folders, so verify
|
||||
// every child that is complete has it's children done as well
|
||||
for (LLInventoryModel::cat_array_t::iterator it = categories->begin();
|
||||
it != categories->end();
|
||||
|
|
@ -930,14 +930,14 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis(const FetchQueueInfo& fetc
|
|||
LLViewerInventoryCategory* child_cat = (*it);
|
||||
if (LLViewerInventoryCategory::VERSION_UNKNOWN != child_cat->getVersion())
|
||||
{
|
||||
mFetchFolderQueue.push_back(FetchQueueInfo(child_cat->getUUID(), FT_RECURSIVE));
|
||||
mFetchFolderQueue.emplace_back(child_cat->getUUID(), FT_RECURSIVE);
|
||||
}
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
// send it back to get the rest
|
||||
mFetchFolderQueue.push_back(FetchQueueInfo(cat_id, FT_CONTENT_RECURSIVE));
|
||||
mFetchFolderQueue.emplace_back(cat_id, FT_CONTENT_RECURSIVE);
|
||||
}
|
||||
}
|
||||
else if (LLViewerInventoryCategory::VERSION_UNKNOWN == cat->getVersion()
|
||||
|
|
@ -954,7 +954,7 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis(const FetchQueueInfo& fetc
|
|||
// increment before call in case of immediate callback
|
||||
incrFetchFolderCount(1);
|
||||
cat->setFetching(target_state);
|
||||
mExpectedFolderIds.push_back(cat_id);
|
||||
mExpectedFolderIds.emplace_back(cat_id);
|
||||
|
||||
EFetchType type = fetch_info.mFetchType;
|
||||
LLUUID cat_cb_id = cat_id;
|
||||
|
|
@ -978,15 +978,15 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis(const FetchQueueInfo& fetc
|
|||
if (fetch_info.mFetchType == FT_RECURSIVE
|
||||
|| fetch_info.mFetchType == FT_FOLDER_AND_CONTENT)
|
||||
{
|
||||
LLInventoryModel::cat_array_t * categories(NULL);
|
||||
LLInventoryModel::item_array_t * items(NULL);
|
||||
LLInventoryModel::cat_array_t* categories(NULL);
|
||||
LLInventoryModel::item_array_t* items(NULL);
|
||||
gInventory.getDirectDescendentsOf(cat_id, categories, items);
|
||||
for (LLInventoryModel::cat_array_t::const_iterator it = categories->begin();
|
||||
it != categories->end();
|
||||
++it)
|
||||
{
|
||||
// not push_front to not cause an infinite loop
|
||||
mFetchFolderQueue.push_back(FetchQueueInfo((*it)->getUUID(), FT_RECURSIVE));
|
||||
// not emplace_front to not cause an infinite loop
|
||||
mFetchFolderQueue.emplace_back((*it)->getUUID(), FT_RECURSIVE);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -995,7 +995,7 @@ void LLInventoryModelBackgroundFetch::bulkFetchViaAis(const FetchQueueInfo& fetc
|
|||
}
|
||||
else
|
||||
{
|
||||
LLViewerInventoryItem * itemp(gInventory.getItem(fetch_info.mUUID));
|
||||
LLViewerInventoryItem* itemp(gInventory.getItem(fetch_info.mUUID));
|
||||
|
||||
if (itemp)
|
||||
{
|
||||
|
|
@ -1033,7 +1033,7 @@ void LLInventoryModelBackgroundFetch::bulkFetch()
|
|||
//Background fetch is called from gIdleCallbacks in a loop until background fetch is stopped.
|
||||
//If there are items in mFetchQueue, we want to check the time since the last bulkFetch was
|
||||
//sent. If it exceeds our retry time, go ahead and fire off another batch.
|
||||
LLViewerRegion * region(gAgent.getRegion());
|
||||
LLViewerRegion* region(gAgent.getRegion());
|
||||
if (! region || gDisconnected || LLApp::isExiting())
|
||||
{
|
||||
return;
|
||||
|
|
@ -1053,7 +1053,7 @@ void LLInventoryModelBackgroundFetch::bulkFetch()
|
|||
// Just processed a bunch of items.
|
||||
// Note: do we really need notifyObservers() here?
|
||||
// OnIdle it will be called anyway due to Add flag for processed item.
|
||||
// It seems like in some cases we are updaiting on fail (no flag),
|
||||
// It seems like in some cases we are updating on fail (no flag),
|
||||
// but is there anything to update?
|
||||
gInventory.notifyObservers();
|
||||
}
|
||||
|
|
@ -1071,7 +1071,7 @@ void LLInventoryModelBackgroundFetch::bulkFetch()
|
|||
// *TODO: Think I'd like to get a shared pointer to this and share it
|
||||
// among all the folder requests.
|
||||
uuid_vec_t recursive_cats;
|
||||
uuid_vec_t all_cats; // dupplicate avoidance
|
||||
uuid_vec_t all_cats; // duplicate avoidance
|
||||
|
||||
LLSD folder_request_body;
|
||||
LLSD folder_request_body_lib;
|
||||
|
|
@ -1081,10 +1081,10 @@ void LLInventoryModelBackgroundFetch::bulkFetch()
|
|||
while (! mFetchFolderQueue.empty()
|
||||
&& (item_count + folder_count) < max_batch_size)
|
||||
{
|
||||
const FetchQueueInfo & fetch_info(mFetchFolderQueue.front());
|
||||
const FetchQueueInfo& fetch_info(mFetchFolderQueue.front());
|
||||
if (fetch_info.mIsCategory)
|
||||
{
|
||||
const LLUUID & cat_id(fetch_info.mUUID);
|
||||
const LLUUID& cat_id(fetch_info.mUUID);
|
||||
if (cat_id.isNull()) //DEV-17797 Lost and found
|
||||
{
|
||||
LLSD folder_sd;
|
||||
|
|
@ -1098,7 +1098,7 @@ void LLInventoryModelBackgroundFetch::bulkFetch()
|
|||
}
|
||||
else
|
||||
{
|
||||
const LLViewerInventoryCategory * cat(gInventory.getCategory(cat_id));
|
||||
const LLViewerInventoryCategory* cat(gInventory.getCategory(cat_id));
|
||||
if (cat)
|
||||
{
|
||||
if (LLViewerInventoryCategory::VERSION_UNKNOWN == cat->getVersion())
|
||||
|
|
@ -1128,14 +1128,14 @@ void LLInventoryModelBackgroundFetch::bulkFetch()
|
|||
// May already have this folder, but append child folders to list.
|
||||
if (fetch_info.mFetchType >= FT_CONTENT_RECURSIVE)
|
||||
{
|
||||
LLInventoryModel::cat_array_t * categories(NULL);
|
||||
LLInventoryModel::item_array_t * items(NULL);
|
||||
LLInventoryModel::cat_array_t* categories(NULL);
|
||||
LLInventoryModel::item_array_t* items(NULL);
|
||||
gInventory.getDirectDescendentsOf(cat_id, categories, items);
|
||||
for (LLInventoryModel::cat_array_t::const_iterator it = categories->begin();
|
||||
it != categories->end();
|
||||
++it)
|
||||
{
|
||||
mFetchFolderQueue.push_back(FetchQueueInfo((*it)->getUUID(), fetch_info.mFetchType));
|
||||
mFetchFolderQueue.emplace_back((*it)->getUUID(), fetch_info.mFetchType);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1143,9 +1143,9 @@ void LLInventoryModelBackgroundFetch::bulkFetch()
|
|||
}
|
||||
if (fetch_info.mFetchType >= FT_CONTENT_RECURSIVE)
|
||||
{
|
||||
recursive_cats.push_back(cat_id);
|
||||
recursive_cats.emplace_back(cat_id);
|
||||
}
|
||||
all_cats.push_back(cat_id);
|
||||
all_cats.emplace_back(cat_id);
|
||||
}
|
||||
|
||||
mFetchFolderQueue.pop_front();
|
||||
|
|
@ -1155,9 +1155,9 @@ void LLInventoryModelBackgroundFetch::bulkFetch()
|
|||
while (!mFetchItemQueue.empty()
|
||||
&& (item_count + folder_count) < max_batch_size)
|
||||
{
|
||||
const FetchQueueInfo & fetch_info(mFetchItemQueue.front());
|
||||
const FetchQueueInfo& fetch_info(mFetchItemQueue.front());
|
||||
|
||||
LLViewerInventoryItem * itemp(gInventory.getItem(fetch_info.mUUID));
|
||||
LLViewerInventoryItem* itemp(gInventory.getItem(fetch_info.mUUID));
|
||||
|
||||
if (itemp)
|
||||
{
|
||||
|
|
@ -1245,13 +1245,13 @@ void LLInventoryModelBackgroundFetch::bulkFetch()
|
|||
}
|
||||
}
|
||||
|
||||
bool LLInventoryModelBackgroundFetch::fetchQueueContainsNoDescendentsOf(const LLUUID & cat_id) const
|
||||
bool LLInventoryModelBackgroundFetch::fetchQueueContainsNoDescendentsOf(const LLUUID& cat_id) const
|
||||
{
|
||||
for (fetch_queue_t::const_iterator it = mFetchFolderQueue.begin();
|
||||
it != mFetchFolderQueue.end();
|
||||
++it)
|
||||
{
|
||||
const LLUUID & fetch_id = (*it).mUUID;
|
||||
const LLUUID& fetch_id = (*it).mUUID;
|
||||
if (gInventory.isObjectDescendentOf(fetch_id, cat_id))
|
||||
return false;
|
||||
}
|
||||
|
|
@ -1259,7 +1259,7 @@ bool LLInventoryModelBackgroundFetch::fetchQueueContainsNoDescendentsOf(const LL
|
|||
it != mFetchItemQueue.end();
|
||||
++it)
|
||||
{
|
||||
const LLUUID & fetch_id = (*it).mUUID;
|
||||
const LLUUID& fetch_id = (*it).mUUID;
|
||||
if (gInventory.isObjectDescendentOf(fetch_id, cat_id))
|
||||
return false;
|
||||
}
|
||||
|
|
@ -1274,7 +1274,7 @@ namespace
|
|||
/// Class <anonymous>::BGFolderHttpHandler
|
||||
///----------------------------------------------------------------------------
|
||||
|
||||
void BGFolderHttpHandler::onCompleted(LLCore::HttpHandle handle, LLCore::HttpResponse * response)
|
||||
void BGFolderHttpHandler::onCompleted(LLCore::HttpHandle handle, LLCore::HttpResponse* response)
|
||||
{
|
||||
do // Single-pass do-while used for common exit handling
|
||||
{
|
||||
|
|
@ -1287,7 +1287,7 @@ void BGFolderHttpHandler::onCompleted(LLCore::HttpHandle handle, LLCore::HttpRes
|
|||
}
|
||||
|
||||
// Response body should be present.
|
||||
LLCore::BufferArray * body(response->getBody());
|
||||
LLCore::BufferArray* body(response->getBody());
|
||||
// body = NULL; // Dev tool to force error handling
|
||||
if (! body || ! body->size())
|
||||
{
|
||||
|
|
@ -1336,9 +1336,9 @@ void BGFolderHttpHandler::onCompleted(LLCore::HttpHandle handle, LLCore::HttpRes
|
|||
}
|
||||
|
||||
|
||||
void BGFolderHttpHandler::processData(LLSD & content, LLCore::HttpResponse * response)
|
||||
void BGFolderHttpHandler::processData(LLSD& content, LLCore::HttpResponse* response)
|
||||
{
|
||||
LLInventoryModelBackgroundFetch * fetcher(LLInventoryModelBackgroundFetch::getInstance());
|
||||
LLInventoryModelBackgroundFetch* fetcher(LLInventoryModelBackgroundFetch::getInstance());
|
||||
|
||||
// API V2 and earlier should probably be testing for "error" map
|
||||
// in response as an application-level error.
|
||||
|
|
@ -1356,7 +1356,7 @@ void BGFolderHttpHandler::processData(LLSD & content, LLCore::HttpResponse * res
|
|||
|
||||
//LLUUID agent_id = folder_sd["agent_id"];
|
||||
|
||||
//if(agent_id != gAgent.getID()) //This should never happen.
|
||||
//if (agent_id != gAgent.getID()) //This should never happen.
|
||||
//{
|
||||
// LL_WARNS(LOG_INV) << "Got a UpdateInventoryItem for the wrong agent."
|
||||
// << LL_ENDL;
|
||||
|
|
@ -1388,7 +1388,7 @@ void BGFolderHttpHandler::processData(LLSD & content, LLCore::HttpResponse * res
|
|||
|
||||
LLInventoryModel::update_list_t update;
|
||||
LLInventoryModel::LLCategoryUpdate new_folder(lost_uuid, 1);
|
||||
update.push_back(new_folder);
|
||||
update.emplace_back(new_folder);
|
||||
gInventory.accountForUpdate(update);
|
||||
|
||||
titem->setParent(lost_uuid);
|
||||
|
|
@ -1398,7 +1398,7 @@ void BGFolderHttpHandler::processData(LLSD & content, LLCore::HttpResponse * res
|
|||
}
|
||||
}
|
||||
|
||||
LLViewerInventoryCategory * pcat(gInventory.getCategory(parent_id));
|
||||
LLViewerInventoryCategory* pcat(gInventory.getCategory(parent_id));
|
||||
if (! pcat)
|
||||
{
|
||||
continue;
|
||||
|
|
@ -1436,7 +1436,7 @@ void BGFolderHttpHandler::processData(LLSD & content, LLCore::HttpResponse * res
|
|||
}
|
||||
|
||||
// Set version and descendentcount according to message.
|
||||
LLViewerInventoryCategory * cat(gInventory.getCategory(parent_id));
|
||||
LLViewerInventoryCategory* cat(gInventory.getCategory(parent_id));
|
||||
if (cat)
|
||||
{
|
||||
cat->setVersion(version);
|
||||
|
|
@ -1469,9 +1469,9 @@ void BGFolderHttpHandler::processData(LLSD & content, LLCore::HttpResponse * res
|
|||
}
|
||||
|
||||
|
||||
void BGFolderHttpHandler::processFailure(LLCore::HttpStatus status, LLCore::HttpResponse * response)
|
||||
void BGFolderHttpHandler::processFailure(LLCore::HttpStatus status, LLCore::HttpResponse* response)
|
||||
{
|
||||
const std::string & ct(response->getContentType());
|
||||
const std::string& ct(response->getContentType());
|
||||
LL_WARNS(LOG_INV) << "Inventory folder fetch failure\n"
|
||||
<< "[Status: " << status.toTerseString() << "]\n"
|
||||
<< "[Reason: " << status.toString() << "]\n"
|
||||
|
|
@ -1481,7 +1481,7 @@ void BGFolderHttpHandler::processFailure(LLCore::HttpStatus status, LLCore::Http
|
|||
|
||||
// Could use a 404 test here to try to detect revoked caps...
|
||||
|
||||
if(status == LLCore::HttpStatus(HTTP_FORBIDDEN))
|
||||
if (status == LLCore::HttpStatus(HTTP_FORBIDDEN))
|
||||
{
|
||||
// Too large, split into two if possible
|
||||
if (gDisconnected || LLApp::isExiting())
|
||||
|
|
@ -1511,7 +1511,7 @@ void BGFolderHttpHandler::processFailure(LLCore::HttpStatus status, LLCore::Http
|
|||
LLUUID folder_id = iter->get("folder_id").asUUID();
|
||||
if (std::find(mRecursiveCatUUIDs.begin(), mRecursiveCatUUIDs.end(), folder_id) != mRecursiveCatUUIDs.end())
|
||||
{
|
||||
recursive_cats.push_back(folder_id);
|
||||
recursive_cats.emplace_back(folder_id);
|
||||
}
|
||||
if (folders.size() == (size / 2))
|
||||
{
|
||||
|
|
@ -1542,9 +1542,9 @@ void BGFolderHttpHandler::processFailure(LLCore::HttpStatus status, LLCore::Http
|
|||
// request which tested on HTTP_INTERNAL_ERROR status. This
|
||||
// retry logic was unbounded and lacked discrimination as to the
|
||||
// cause of the retry. The new http library should be doing
|
||||
// adquately on retries but I want to keep the structure of a
|
||||
// adequately on retries but I want to keep the structure of a
|
||||
// retry for reference.
|
||||
LLInventoryModelBackgroundFetch *fetcher = LLInventoryModelBackgroundFetch::getInstance();
|
||||
LLInventoryModelBackgroundFetch* fetcher = LLInventoryModelBackgroundFetch::getInstance();
|
||||
if (false)
|
||||
{
|
||||
// timed out or curl failure
|
||||
|
|
@ -1568,7 +1568,7 @@ void BGFolderHttpHandler::processFailure(LLCore::HttpStatus status, LLCore::Http
|
|||
}
|
||||
|
||||
|
||||
void BGFolderHttpHandler::processFailure(const char * const reason, LLCore::HttpResponse * response)
|
||||
void BGFolderHttpHandler::processFailure(const char* const reason, LLCore::HttpResponse* response)
|
||||
{
|
||||
LL_WARNS(LOG_INV) << "Inventory folder fetch failure\n"
|
||||
<< "[Status: internal error]\n"
|
||||
|
|
@ -1582,7 +1582,7 @@ void BGFolderHttpHandler::processFailure(const char * const reason, LLCore::Http
|
|||
// the same but be aware that this may be a source of problems.
|
||||
// Philosophy is that inventory folders are so essential to
|
||||
// operation that this is a reasonable action.
|
||||
LLInventoryModelBackgroundFetch *fetcher = LLInventoryModelBackgroundFetch::getInstance();
|
||||
LLInventoryModelBackgroundFetch* fetcher = LLInventoryModelBackgroundFetch::getInstance();
|
||||
if (true)
|
||||
{
|
||||
for (LLSD::array_const_iterator folder_it = mRequestSD["folders"].beginArray();
|
||||
|
|
@ -1605,7 +1605,7 @@ void BGFolderHttpHandler::processFailure(const char * const reason, LLCore::Http
|
|||
}
|
||||
|
||||
|
||||
bool BGFolderHttpHandler::getIsRecursive(const LLUUID & cat_id) const
|
||||
bool BGFolderHttpHandler::getIsRecursive(const LLUUID& cat_id) const
|
||||
{
|
||||
return std::find(mRecursiveCatUUIDs.begin(), mRecursiveCatUUIDs.end(), cat_id) != mRecursiveCatUUIDs.end();
|
||||
}
|
||||
|
|
|
|||
|
|
@ -54,7 +54,7 @@ public:
|
|||
void scheduleItemFetch(const LLUUID& item_id, bool forced = false);
|
||||
|
||||
typedef boost::function<void()> nullary_func_t;
|
||||
// AIS3 only, Fetches folder and everithing links inside the folder point to
|
||||
// AIS3 only, Fetches folder and everything links inside the folder point to
|
||||
// Intended for outfits
|
||||
void fetchFolderAndLinks(const LLUUID& cat_id, nullary_func_t callback);
|
||||
// AIS3 only
|
||||
|
|
@ -81,8 +81,8 @@ public:
|
|||
typedef boost::function<void()> folders_fetched_callback_t;
|
||||
boost::signals2::connection setFetchCompletionCallback(folders_fetched_callback_t cb);
|
||||
|
||||
void addRequestAtFront(const LLUUID & id, bool recursive, bool is_category);
|
||||
void addRequestAtBack(const LLUUID & id, bool recursive, bool is_category);
|
||||
void addRequestAtFront(const LLUUID& id, bool recursive, bool is_category);
|
||||
void addRequestAtBack(const LLUUID& id, bool recursive, bool is_category);
|
||||
|
||||
protected:
|
||||
bool isFolderFetchProcessingComplete() const;
|
||||
|
|
@ -108,8 +108,8 @@ protected:
|
|||
};
|
||||
typedef std::deque<FetchQueueInfo> fetch_queue_t;
|
||||
|
||||
void onAISContentCalback(const LLUUID& request_id, const uuid_vec_t &content_ids, const LLUUID& response_id, EFetchType fetch_type);
|
||||
void onAISFolderCalback(const LLUUID &request_id, const LLUUID &response_id, EFetchType fetch_type);
|
||||
void onAISContentCalback(const LLUUID& request_id, const uuid_vec_t& content_ids, const LLUUID& response_id, EFetchType fetch_type);
|
||||
void onAISFolderCalback(const LLUUID& request_id, const LLUUID& response_id, EFetchType fetch_type);
|
||||
void bulkFetchViaAis();
|
||||
void bulkFetchViaAis(const FetchQueueInfo& fetch_info);
|
||||
void bulkFetch();
|
||||
|
|
|
|||
Loading…
Reference in New Issue