开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 游戏引擎 > 查看源码
llmediadataclient_test.cpp
资源名称：snowglobe-src-viewer-2.0.0-r0.tar.gz　[点击查看]
上传用户：king477883
上传日期：2021-03-01
资源大小：9553k
文件大小：34k
源码类别：

游戏引擎

开发平台：

C++ Builder

llmediadataclient_test.cpp：源码内容
  1. /** 
  2.  * @file llmediadataclient_test.cpp
  3.  * @brief LLMediaDatClient tests
  4.  *
  5.  * $LicenseInfo:firstyear=2001&license=viewergpl$
  6.  * 
  7.  * Copyright (c) 2001-2010, Linden Research, Inc.
  8.  * 
  9.  * Second Life Viewer Source Code
  10.  * The source code in this file ("Source Code") is provided by Linden Lab
  11.  * to you under the terms of the GNU General Public License, version 2.0
  12.  * ("GPL"), unless you have obtained a separate licensing agreement
  13.  * ("Other License"), formally executed by you and Linden Lab.  Terms of
  14.  * the GPL can be found in doc/GPL-license.txt in this distribution, or
  15.  * online at http://secondlifegrid.net/programs/open_source/licensing/gplv2
  16.  * 
  17.  * There are special exceptions to the terms and conditions of the GPL as
  18.  * it is applied to this Source Code. View the full text of the exception
  19.  * in the file doc/FLOSS-exception.txt in this software distribution, or
  20.  * online at
  21.  * http://secondlifegrid.net/programs/open_source/licensing/flossexception
  22.  * 
  23.  * By copying, modifying or distributing this software, you acknowledge
  24.  * that you have read and understood your obligations described above,
  25.  * and agree to abide by those obligations.
  26.  * 
  27.  * ALL LINDEN LAB SOURCE CODE IS PROVIDED "AS IS." LINDEN LAB MAKES NO
  28.  * WARRANTIES, EXPRESS, IMPLIED OR OTHERWISE, REGARDING ITS ACCURACY,
  29.  * COMPLETENESS OR PERFORMANCE.
  30.  * $/LicenseInfo$
  31.  */
  33. #include "linden_common.h"
  34. #include "../llviewerprecompiledheaders.h"
  35.  
  36. #include <iostream>
  37. #include "../test/lltut.h"
  39. #include "llsdserialize.h"
  40. #include "llsdutil.h"
  41. #include "llerrorcontrol.h"
  42. #include "llhttpstatuscodes.h"
  44. #include "../llmediadataclient.h"
  45. #include "../llvovolume.h"
  47. #include "../../llprimitive/llmediaentry.cpp"
  48. #include "../../llprimitive/lltextureentry.cpp"
  49. #include "../../llmessage/tests/llcurl_stub.cpp"
  51. #if LL_WINDOWS
  52. #pragma warning (push)
  53. #pragma warning (disable : 4702) // boost::lexical_cast generates this warning
  54. #endif
  55. #include <boost/lexical_cast.hpp>
  56. #if LL_WINDOWS
  57. #pragma warning (pop)
  58. #endif
  60. #define VALID_OBJECT_ID   "3607d5c4-644b-4a8a-871a-8b78471af2a2"
  61. #define VALID_OBJECT_ID_1 "11111111-1111-1111-1111-111111111111"
  62. #define VALID_OBJECT_ID_2 "22222222-2222-2222-2222-222222222222"
  63. #define VALID_OBJECT_ID_3 "33333333-3333-3333-3333-333333333333"
  64. #define VALID_OBJECT_ID_4 "44444444-4444-4444-4444-444444444444"
  66. #define FAKE_OBJECT_MEDIA_CAP_URL "foo_ObjectMedia"
  67. #define FAKE_OBJECT_MEDIA_NAVIGATE_CAP_URL "foo_ObjectMediaNavigate"
  68. #define FAKE_OBJECT_MEDIA_CAP_URL_503 "foo_ObjectMedia_503"
  69. #define FAKE_OBJECT_MEDIA_NAVIGATE_CAP_URL_ERROR "foo_ObjectMediaNavigate_ERROR"
  71. #define MEDIA_DATA "
  72. <array>
  73. <string>foo</string>
  74. <string>bar</string>
  75. <string>baz</string>
  76. </array>"
  78. #define _DATA_URLS(ID,INTEREST,NEW,URL1,URL2) "
  79. <llsd>
  80.   <map>
  81.     <key>uuid</key>
  82.     <string>" ID "</string>
  83.     <key>interest</key>
  84.     <real>" INTEREST "</real>
  85.     <key>cap_urls</key>
  86.     <map>
  87.       <key>ObjectMedia</key>
  88.       <string>" URL1 "</string>
  89.       <key>ObjectMediaNavigate</key>
  90.       <string>" URL2 "</string>
  91.     </map>
  92.     <key>media_data</key>                                       
  93. " MEDIA_DATA "
  94.     <key>is_dead</key>
  95. <boolean>false</boolean>
  96. <key>is_new</key>
  97. <boolean>" NEW "</boolean>
  98.   </map>
  99. </llsd>"
  101. #define _DATA(ID,INTEREST,NEW) _DATA_URLS(ID,INTEREST,NEW,FAKE_OBJECT_MEDIA_CAP_URL,FAKE_OBJECT_MEDIA_NAVIGATE_CAP_URL)
  103. const char *DATA = _DATA(VALID_OBJECT_ID,"1.0","true");
  105. #define STR(I) boost::lexical_cast<std::string>(I)
  107. #define LOG_TEST(N) LL_DEBUGS("LLMediaDataClient") << "n" <<
  108. "================================================================================n" << 
  109. "==================================== TEST " #N " ===================================n" << 
  110. "================================================================================n" << LL_ENDL;
  112. LLSD *gPostRecords = NULL;
  113. F64   gMinimumInterestLevel = (F64)0.0;
  115. // stubs:
  116. void LLHTTPClient::post(
  117. const std::string& url,
  118. const LLSD& body,
  119. LLHTTPClient::ResponderPtr responder,
  120. const LLSD& headers,
  121. const F32 timeout)
  122. {
  123. LLSD record;
  124. record["url"] = url;
  125. record["body"] = body;
  126. record["headers"] = headers;
  127. record["timeout"] = timeout;
  128. gPostRecords->append(record);
  130. // Magic URL that triggers a 503:
  131. LLSD result;
  132. result[LLTextureEntry::OBJECT_ID_KEY] = body[LLTextureEntry::OBJECT_ID_KEY];
  133. if ( url == FAKE_OBJECT_MEDIA_CAP_URL_503 )
  134. {
  135. responder->error(HTTP_SERVICE_UNAVAILABLE, "fake reason");
  136. return;
  137. }
  138. else if (url == FAKE_OBJECT_MEDIA_NAVIGATE_CAP_URL_ERROR) 
  139. {
  140. LLSD error;
  141. error["code"] = LLObjectMediaNavigateClient::ERROR_PERMISSION_DENIED_CODE;
  142. result["error"] = error;
  143. }
  144. responder->result(result);
  145. }
  147. const F32 HTTP_REQUEST_EXPIRY_SECS = 60.0f;
  149. class LLMediaDataClientObjectTest : public LLMediaDataClientObject
  150. {
  151. public:
  152. LLMediaDataClientObjectTest(const char *data) 
  153. {
  154. std::istringstream d(data);
  155. LLSDSerialize::fromXML(mRep, d);
  156. mNumBounceBacks = 0;
  157.             
  158.            // std::cout << ll_pretty_print_sd(mRep) << std::endl;
  159.            // std::cout << "ID: " << getID() << std::endl;
  160. }
  161. LLMediaDataClientObjectTest(const LLSD &rep) 
  162. : mRep(rep), mNumBounceBacks(0) {}
  163. ~LLMediaDataClientObjectTest()
  164. { LL_DEBUGS("LLMediaDataClient") << "~LLMediaDataClientObjectTest" << LL_ENDL; }
  166. virtual U8 getMediaDataCount() const 
  167. { return mRep["media_data"].size(); }
  168. virtual LLSD getMediaDataLLSD(U8 index) const
  169. { return mRep["media_data"][(LLSD::Integer)index]; }
  170. virtual LLUUID getID() const 
  171. { return mRep["uuid"]; }
  172. virtual void mediaNavigateBounceBack(U8 index)
  173. { mNumBounceBacks++; }
  175. virtual bool hasMedia() const
  176. { return mRep.has("media_data"); }
  178. virtual void updateObjectMediaData(LLSD const &media_data_array, const std::string &media_version)
  179. { mRep["media_data"] = media_data_array; mRep["media_version"] = media_version; }
  181. virtual F64 getMediaInterest() const
  182. { return (LLSD::Real)mRep["interest"]; }
  184. virtual bool isInterestingEnough() const
  185. { return getMediaInterest() > gMinimumInterestLevel; }
  187. virtual std::string getCapabilityUrl(const std::string &name) const 
  188. { return mRep["cap_urls"][name]; }
  190. virtual bool isDead() const
  191. { return mRep["is_dead"]; }
  193. virtual U32 getMediaVersion() const
  194. { return (LLSD::Integer)mRep["media_version"]; }
  196. virtual bool isNew() const
  197. { return mRep["is_new"]; }
  199. void setMediaInterest(F64 val)
  200. { mRep["interest"] = val; }
  202. int getNumBounceBacks() const
  203. { return mNumBounceBacks; }
  205. void markDead()
  206. { mRep["is_dead"] = true; }
  208. void markOld()
  209. { mRep["is_new"] = false; }
  211. private:
  212. LLSD mRep;
  213. int mNumBounceBacks;
  214. };
  216. // This special timer delay should ensure that the timer will fire on the very
  217. // next pump, no matter what (though this does make an assumption about the
  218. // implementation of LLEventTimer::updateClass()):
  219. const F32 NO_PERIOD = -1000.0f;
  221. static void pump_timers()
  222. {
  223. LLEventTimer::updateClass();
  224. }
  226. namespace tut
  227. {
  228.     struct mediadataclient
  229.     {
  230. mediadataclient() {
  231. gPostRecords = &mLLSD;
  232. gMinimumInterestLevel = (F64)0.0;
  234. //  LLError::setDefaultLevel(LLError::LEVEL_DEBUG);
  235. //  LLError::setClassLevel("LLMediaDataClient", LLError::LEVEL_DEBUG);
  236. // LLError::setTagLevel("MediaOnAPrim", LLError::LEVEL_DEBUG);
  237. }
  238. LLSD mLLSD;
  239.     };
  240.     
  241. typedef test_group<mediadataclient> mediadataclient_t;
  242. typedef mediadataclient_t::object mediadataclient_object_t;
  243. tut::mediadataclient_t tut_mediadataclient("mediadataclient");
  244.     
  245.     void ensure(const std::string &msg, int value, int expected)
  246.     {
  247.         std::string m = msg;
  248.         m += " value: " + STR(value);
  249.         m += ", expected: " + STR(expected);
  250.         ensure(m, value == expected);
  251.     }
  252.     
  253.     void ensure(const std::string &msg, const std::string & value, const std::string & expected)
  254.     {
  255.         std::string m = msg;
  256.         m += " value: " + value;
  257.         m += ", expected: " + expected;
  258.         ensure(m, value == expected);
  259.     }
  260.     
  261.     void ensure(const std::string &msg, const LLUUID & value, const LLUUID & expected)
  262.     {
  263.         std::string m = msg;
  264.         m += " value: " + value.asString();
  265.         m += ", expected: " + expected.asString();
  266.         ensure(m, value == expected);
  267.     }
  268.     
  269.     void ensure_llsd(const std::string &msg, const LLSD & value, const char *expected)
  270.     {
  271.         LLSD expected_llsd;
  272.         std::istringstream e(expected);
  273.         LLSDSerialize::fromXML(expected_llsd, e);
  274.    
  275.         std::string value_str = ll_pretty_print_sd(value);
  276.         std::string expected_str = ll_pretty_print_sd(expected_llsd);
  277.         std::string m = msg;
  278.         m += " value: " + value_str;
  279.         m += ", expected: " + expected_str;
  280.         ensure(m, value_str == expected_str);
  281.     }
  283. //////////////////////////////////////////////////////////////////////////////////////////
  285. template<> template<>
  286. void mediadataclient_object_t::test<1>()
  287. {
  288. //
  289. // Test fetchMedia()
  290. //
  291. LOG_TEST(1);
  293. LLMediaDataClientObject::ptr_t o = new LLMediaDataClientObjectTest(DATA);
  294. int num_refs_start = o->getNumRefs();
  295. {
  296. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD);
  297. mdc->fetchMedia(o);
  299. // Make sure no posts happened yet...
  300. ensure("post records", gPostRecords->size(), 0);
  302. ::pump_timers();
  304. ensure("post records", gPostRecords->size(), 1);
  305. ensure("post url", (*gPostRecords)[0]["url"], FAKE_OBJECT_MEDIA_CAP_URL);
  306. ensure("post GET", (*gPostRecords)[0]["body"]["verb"], "GET");
  307. ensure("post object id", (*gPostRecords)[0]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID));
  308. ensure("queue empty", mdc->isEmpty());
  309. }
  311. // Make sure everyone's destroyed properly
  312. ensure("REF COUNT", o->getNumRefs(), num_refs_start);
  313.     }
  315. //////////////////////////////////////////////////////////////////////////////////////////
  317. template<> template<>
  318. void mediadataclient_object_t::test<2>()
  319. {
  320. //
  321. // Test updateMedia()
  322. //
  323. LOG_TEST(2);
  325. LLMediaDataClientObject::ptr_t o = new LLMediaDataClientObjectTest(DATA);
  326. {
  327. // queue time w/ no delay ensures that ::pump_timers() will hit the tick()
  328. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD);  
  329. mdc->updateMedia(o);
  330. ensure("post records", gPostRecords->size(), 0);
  331. ::pump_timers();
  333. ensure("post records", gPostRecords->size(), 1);
  334. ensure("post url", (*gPostRecords)[0]["url"], FAKE_OBJECT_MEDIA_CAP_URL);
  335. ensure("post UPDATE", (*gPostRecords)[0]["body"]["verb"], "UPDATE");
  336. ensure("post object id", (*gPostRecords)[0]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID));
  337. ensure_llsd("post data llsd", (*gPostRecords)[0]["body"][LLTextureEntry::OBJECT_MEDIA_DATA_KEY], 
  338. "<llsd>" MEDIA_DATA "</llsd>");
  339. ensure("queue empty", mdc->isEmpty());
  340. }
  342. ensure("REF COUNT", o->getNumRefs(), 1);
  343. }
  345. //////////////////////////////////////////////////////////////////////////////////////////
  347.     template<> template<>
  348.     void mediadataclient_object_t::test<3>()
  349.     {
  350. //
  351. // Test navigate()
  352. //
  353. LOG_TEST(3);
  355. LLMediaDataClientObject::ptr_t o = new LLMediaDataClientObjectTest(DATA);
  356. {
  357. LLPointer<LLObjectMediaNavigateClient> mdc = new LLObjectMediaNavigateClient(NO_PERIOD,NO_PERIOD);
  358. const char *TEST_URL = "http://example.com";
  359. mdc->navigate(o, 0, TEST_URL);
  360. ensure("post records", gPostRecords->size(), 0);
  361. ::pump_timers();
  363. // ensure no bounce back
  364. ensure("bounce back", dynamic_cast<LLMediaDataClientObjectTest*>(static_cast<LLMediaDataClientObject*>(o))->getNumBounceBacks(), 0);
  366. ensure("post records", gPostRecords->size(), 1);
  367. ensure("post url", (*gPostRecords)[0]["url"], FAKE_OBJECT_MEDIA_NAVIGATE_CAP_URL);
  368. ensure("post object id", (*gPostRecords)[0]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID));
  369. ensure("post data", (*gPostRecords)[0]["body"][LLTextureEntry::TEXTURE_INDEX_KEY], 0);
  370. ensure("post data", (*gPostRecords)[0]["body"][LLMediaEntry::CURRENT_URL_KEY], TEST_URL);
  371. ensure("queue empty", mdc->isEmpty());
  372. }
  373. ensure("REF COUNT", o->getNumRefs(), 1);
  374.     }
  376. //////////////////////////////////////////////////////////////////////////////////////////
  378.     template<> template<>
  379.     void mediadataclient_object_t::test<4>()
  380.     {
  381. //
  382. // Test queue ordering
  383. //
  384. LOG_TEST(4);
  386. LLMediaDataClientObject::ptr_t o1 = new LLMediaDataClientObjectTest(
  387. _DATA(VALID_OBJECT_ID_1,"1.0","true"));
  388. LLMediaDataClientObject::ptr_t o2 = new LLMediaDataClientObjectTest(
  389. _DATA(VALID_OBJECT_ID_2,"3.0","true"));
  390. LLMediaDataClientObject::ptr_t o3 = new LLMediaDataClientObjectTest(
  391. _DATA(VALID_OBJECT_ID_3,"2.0","true"));
  392. {
  393. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD);  
  394. const char *ORDERED_OBJECT_IDS[] = { VALID_OBJECT_ID_2, VALID_OBJECT_ID_3, VALID_OBJECT_ID_1 };
  395. mdc->fetchMedia(o1);
  396. mdc->fetchMedia(o2);
  397. mdc->fetchMedia(o3);
  399. // Make sure no posts happened yet...
  400. ensure("post records", gPostRecords->size(), 0);
  402. // tick 3 times...
  403. ::pump_timers();
  404. ensure("post records", gPostRecords->size(), 1);
  405. ::pump_timers();
  406. ensure("post records", gPostRecords->size(), 2);
  407. ::pump_timers();
  408. ensure("post records", gPostRecords->size(), 3);
  410. for( int i=0; i < 3; i++ )
  411. {
  412. ensure("[" + STR(i) + "] post url", (*gPostRecords)[i]["url"], FAKE_OBJECT_MEDIA_CAP_URL);
  413. ensure("[" + STR(i) + "] post GET", (*gPostRecords)[i]["body"]["verb"], "GET");
  414. ensure("[" + STR(i) + "] post object id", (*gPostRecords)[i]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), 
  415.    LLUUID(ORDERED_OBJECT_IDS[i]));
  416. }
  418. ensure("queue empty", mdc->isEmpty());
  419. }
  420. ensure("refcount of o1", o1->getNumRefs(), 1);
  421. ensure("refcount of o2", o2->getNumRefs(), 1);
  422. ensure("refcount of o3", o3->getNumRefs(), 1);
  423.     }
  425. //////////////////////////////////////////////////////////////////////////////////////////
  427. template<> template<>
  428. void mediadataclient_object_t::test<5>()
  429. {
  430. //
  431. // Test fetchMedia() getting a 503 error
  432. //
  433. LOG_TEST(5);
  435. LLMediaDataClientObject::ptr_t o = new LLMediaDataClientObjectTest(
  436. _DATA_URLS(VALID_OBJECT_ID,
  437.    "1.0","true",
  438.    FAKE_OBJECT_MEDIA_CAP_URL_503,
  439.    FAKE_OBJECT_MEDIA_NAVIGATE_CAP_URL));
  440. int num_refs_start = o->getNumRefs();
  441. {
  442. const int NUM_RETRIES = 5;
  443. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD,NUM_RETRIES);
  445. // This should generate a retry
  446. mdc->fetchMedia(o);
  448. // Make sure no posts happened yet...
  449. ensure("post records before", gPostRecords->size(), 0);
  451. // Once, causes retry
  452. // Second, fires retry timer
  453. // Third, fires queue timer again
  454. for (int i=0; i<NUM_RETRIES; ++i)
  455. {
  456. ::pump_timers();  // Should pump (fire) the queue timer, causing a retry timer to be scheduled
  457. // XXX This ensure is not guaranteed, because scheduling a timer might actually get it pumped in the same loop
  458. //ensure("post records " + STR(i), gPostRecords->size(), i+1);
  459. ::pump_timers();  // Should pump (fire) the retry timer, scheduling the queue timer
  460. }
  462. // Do some extra pumps to make sure no other timer work occurs.
  463. ::pump_timers();
  464. ::pump_timers();
  465. ::pump_timers();
  467. // Make sure there were 2 posts
  468. ensure("post records after", gPostRecords->size(), NUM_RETRIES);
  469. for (int i=0; i<NUM_RETRIES; ++i)
  470. {
  471. ensure("[" + STR(i) + "] post url", (*gPostRecords)[i]["url"], FAKE_OBJECT_MEDIA_CAP_URL_503);
  472. ensure("[" + STR(i) + "] post GET", (*gPostRecords)[i]["body"]["verb"], "GET");
  473. ensure("[" + STR(i) + "] post object id", (*gPostRecords)[i]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID));
  474. }
  475. ensure("queue empty", mdc->isEmpty());
  476. }
  478. // Make sure everyone's destroyed properly
  479. ensure("REF COUNT", o->getNumRefs(), num_refs_start);
  480.     }
  482.     template<> template<>
  483.     void mediadataclient_object_t::test<6>()
  484.     {
  485. //
  486. // Test navigate() with a bounce back
  487. //
  488. LOG_TEST(6);
  490. LLMediaDataClientObject::ptr_t o = new LLMediaDataClientObjectTest(
  491. _DATA_URLS(VALID_OBJECT_ID,
  492.    "1.0","true",
  493.    FAKE_OBJECT_MEDIA_CAP_URL,
  494.    FAKE_OBJECT_MEDIA_NAVIGATE_CAP_URL_ERROR));
  495. {
  496. LLPointer<LLObjectMediaNavigateClient> mdc = new LLObjectMediaNavigateClient(NO_PERIOD,NO_PERIOD);
  497. const char *TEST_URL = "http://example.com";
  498. mdc->navigate(o, 0, TEST_URL);
  499. ensure("post records", gPostRecords->size(), 0);
  500. ::pump_timers();
  502. // ensure bounce back
  503. ensure("bounce back", 
  504.    dynamic_cast<LLMediaDataClientObjectTest*>(static_cast<LLMediaDataClientObject*>(o))->getNumBounceBacks(),
  505.    1);
  507. ensure("post records", gPostRecords->size(), 1);
  508. ensure("post url", (*gPostRecords)[0]["url"], FAKE_OBJECT_MEDIA_NAVIGATE_CAP_URL_ERROR);
  509. ensure("post object id", (*gPostRecords)[0]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID));
  510. ensure("post data", (*gPostRecords)[0]["body"][LLTextureEntry::TEXTURE_INDEX_KEY], 0);
  511. ensure("post data", (*gPostRecords)[0]["body"][LLMediaEntry::CURRENT_URL_KEY], TEST_URL);
  512. ensure("queue empty", mdc->isEmpty());
  513. }
  514. ensure("REF COUNT", o->getNumRefs(), 1);
  515.     }
  517. template<> template<>
  518.     void mediadataclient_object_t::test<7>()
  519.     {
  520. // Test LLMediaDataClient::isInQueue()
  521. LOG_TEST(7);
  523. LLMediaDataClientObject::ptr_t o1 = new LLMediaDataClientObjectTest(
  524. _DATA(VALID_OBJECT_ID_1,"3.0","true"));
  525. LLMediaDataClientObject::ptr_t o2 = new LLMediaDataClientObjectTest(
  526. _DATA(VALID_OBJECT_ID_2,"1.0","true"));
  527. int num_refs_start = o1->getNumRefs();
  528. {
  529. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD);
  531. ensure("not in queue yet 1", ! mdc->isInQueue(o1));
  532. ensure("not in queue yet 2", ! mdc->isInQueue(o2));
  534. mdc->fetchMedia(o1);
  536. ensure("is in queue", mdc->isInQueue(o1));
  537. ensure("is not in queue", ! mdc->isInQueue(o2));
  539. ::pump_timers();
  541. ensure("not in queue anymore", ! mdc->isInQueue(o1));
  542. ensure("still is not in queue", ! mdc->isInQueue(o2));
  544. ensure("queue empty", mdc->isEmpty());
  545. }
  547. // Make sure everyone's destroyed properly
  548. ensure("REF COUNT", o1->getNumRefs(), num_refs_start);
  550. }
  552. template<> template<>
  553.     void mediadataclient_object_t::test<8>()
  554.     {
  555. // Test queue handling of objects that are marked dead.
  556. LOG_TEST(8);
  558. LLMediaDataClientObject::ptr_t o1 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_1,"4.0","true"));
  559. LLMediaDataClientObject::ptr_t o2 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_2,"3.0","true"));
  560. LLMediaDataClientObject::ptr_t o3 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_3,"2.0","true"));
  561. LLMediaDataClientObject::ptr_t o4 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_4,"1.0","true"));
  562. {
  563. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD);
  565. // queue up all 4 objects
  566. mdc->fetchMedia(o1);
  567. mdc->fetchMedia(o2);
  568. mdc->fetchMedia(o3);
  569. mdc->fetchMedia(o4);
  571. // and mark the second and fourth ones dead.
  572. dynamic_cast<LLMediaDataClientObjectTest*>(static_cast<LLMediaDataClientObject*>(o2))->markDead();
  573. dynamic_cast<LLMediaDataClientObjectTest*>(static_cast<LLMediaDataClientObject*>(o4))->markDead();
  575. ensure("is in queue 1", mdc->isInQueue(o1));
  576. ensure("is in queue 2", mdc->isInQueue(o2));
  577. ensure("is in queue 3", mdc->isInQueue(o3));
  578. ensure("is in queue 4", mdc->isInQueue(o4));
  579. ensure("post records", gPostRecords->size(), 0);
  581. ::pump_timers();
  583. // The first tick should remove the first one 
  584. ensure("is not in queue 1", !mdc->isInQueue(o1));
  585. ensure("is in queue 2", mdc->isInQueue(o2));
  586. ensure("is in queue 3", mdc->isInQueue(o3));
  587. ensure("is in queue 4", mdc->isInQueue(o4));
  588. ensure("post records", gPostRecords->size(), 1);
  590. ::pump_timers();
  592. // The second tick should skip the second and remove the third
  593. ensure("is not in queue 2", !mdc->isInQueue(o2));
  594. ensure("is not in queue 3", !mdc->isInQueue(o3));
  595. ensure("is in queue 4", mdc->isInQueue(o4));
  596. ensure("post records", gPostRecords->size(), 2);
  598. ::pump_timers();
  600. // The third tick should skip the fourth one and empty the queue.
  601. ensure("is not in queue 4", !mdc->isInQueue(o4));
  602. ensure("post records", gPostRecords->size(), 2);
  604. ensure("queue empty", mdc->isEmpty());
  605. }
  606. ensure("refcount of o1", o1->getNumRefs(), 1);
  607. ensure("refcount of o2", o2->getNumRefs(), 1);
  608. ensure("refcount of o3", o3->getNumRefs(), 1);
  609. ensure("refcount of o4", o4->getNumRefs(), 1);
  611. }
  613. //////////////////////////////////////////////////////////////////////////////////////////
  615.     template<> template<>
  616.     void mediadataclient_object_t::test<9>()
  617.     {
  618. //
  619. // Test queue re-ordering
  620. //
  621. LOG_TEST(9);
  623. LLMediaDataClientObject::ptr_t o1 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_1,"40.0","true"));
  624. LLMediaDataClientObject::ptr_t o2 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_2,"30.0","true"));
  625. LLMediaDataClientObject::ptr_t o3 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_3,"20.0","true"));
  626. LLMediaDataClientObjectTest *object4 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_4,"10.0","true"));
  627. LLMediaDataClientObject::ptr_t o4 = object4;
  628. {
  629. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD);
  631. // queue up all 4 objects.  They should now be in the queue in
  632. // order 1 through 4, with 4 being at the front of the queue
  633. mdc->fetchMedia(o1);
  634. mdc->fetchMedia(o2);
  635. mdc->fetchMedia(o3);
  636. mdc->fetchMedia(o4);
  638. int tick_num = 0;
  640. ensure(STR(tick_num) + ". is in queue 1", mdc->isInQueue(o1));
  641. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  642. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  643. ensure(STR(tick_num) + ". is in queue 4", mdc->isInQueue(o4));
  644. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 0);
  646. ::pump_timers();
  647. ++tick_num;
  649. // The first tick should remove the first one 
  650. ensure(STR(tick_num) + ". is not in queue 1", !mdc->isInQueue(o1));
  651. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  652. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  653. ensure(STR(tick_num) + ". is in queue 4", mdc->isInQueue(o4));
  654. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 1);
  656. // Now, pretend that object 4 moved relative to the avatar such
  657. // that it is now closest
  658. object4->setMediaInterest(50.0);
  660. ::pump_timers();
  661. ++tick_num;
  663. // The second tick should still pick off item 2, but then re-sort
  664. // have picked off object 4
  665. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  666. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  667. ensure(STR(tick_num) + ". is not in queue 4", !mdc->isInQueue(o4));
  668. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 2);
  670. ::pump_timers();
  671. ++tick_num;
  673. // The third tick should pick off object 2
  674. ensure(STR(tick_num) + ". is not in queue 2", !mdc->isInQueue(o2));
  675. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  676. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 3);
  678. // The fourth tick should pick off object 3
  679. ::pump_timers();
  680. ++tick_num;
  682. ensure(STR(tick_num) + ". is not in queue 3", !mdc->isInQueue(o3));
  683. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 4);
  685. ensure("queue empty", mdc->isEmpty());
  686. }
  687. ensure("refcount of o1", o1->getNumRefs(), 1);
  688. ensure("refcount of o2", o2->getNumRefs(), 1);
  689. ensure("refcount of o3", o3->getNumRefs(), 1);
  690. ensure("refcount of o4", o4->getNumRefs(), 1);
  691.     }
  694. template<> template<>
  695.     void mediadataclient_object_t::test<10>()
  696.     {
  697. //
  698. // Test using the "round-robin" queue
  699. //
  700. LOG_TEST(10);
  702. LLMediaDataClientObject::ptr_t o1 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_1,"1.0","true"));
  703. LLMediaDataClientObject::ptr_t o2 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_2,"2.0","true"));
  704. LLMediaDataClientObject::ptr_t o3 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_3,"3.0","false"));
  705. LLMediaDataClientObject::ptr_t o4 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_4,"4.0","false"));
  706. {
  707. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD);
  709. // queue up all 4 objects.  The first two should be in the sorted
  710. // queue [2 1], the second in the round-robin queue.  The queues
  711. // are serviced interleaved, so we should expect:
  712. // 2, 4, 1, 3
  713. mdc->fetchMedia(o1);
  714. mdc->fetchMedia(o2);
  715. mdc->fetchMedia(o3);
  716. mdc->fetchMedia(o4);
  718. int tick_num = 0;
  720. // 0
  721. ensure(STR(tick_num) + ". is in queue 1", mdc->isInQueue(o1));
  722. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  723. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  724. ensure(STR(tick_num) + ". is in queue 4", mdc->isInQueue(o4));
  725. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 0);
  727. ::pump_timers();
  728. ++tick_num;
  730. // 1 The first tick should remove object 2
  731. ensure(STR(tick_num) + ". is not in queue 2", !mdc->isInQueue(o2));
  732. ensure(STR(tick_num) + ". is in queue 1", mdc->isInQueue(o1));
  733. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  734. ensure(STR(tick_num) + ". is in queue 4", mdc->isInQueue(o4));
  735. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 1);
  736. ensure(STR(tick_num) + ". post object id", (*gPostRecords)[0]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID_2));
  738. ::pump_timers();
  739. ++tick_num;
  741. // 2 The second tick should send object 4, but it will still be
  742. // "in the queue"
  743. ensure(STR(tick_num) + ". is not in queue 2", !mdc->isInQueue(o2));
  744. ensure(STR(tick_num) + ". is in queue 1", mdc->isInQueue(o1));
  745. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  746. ensure(STR(tick_num) + ". is in queue 4", mdc->isInQueue(o4));
  747. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 2);
  748. ensure(STR(tick_num) + ". post object id", (*gPostRecords)[1]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID_4));
  750. ::pump_timers();
  751. ++tick_num;
  753. // 3 The third tick should remove object 1
  754. ensure(STR(tick_num) + ". is not in queue 2", !mdc->isInQueue(o2));
  755. ensure(STR(tick_num) + ". is not in queue 1", !mdc->isInQueue(o1));
  756. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  757. ensure(STR(tick_num) + ". is in queue 4", mdc->isInQueue(o4));
  758. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 3);
  759. ensure(STR(tick_num) + ". post object id", (*gPostRecords)[2]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID_1));
  761. ::pump_timers();
  762. ++tick_num;
  764. // 4 The fourth tick should send object 3, but it will still be
  765. // "in the queue"
  766. ensure(STR(tick_num) + ". is not in queue 2", !mdc->isInQueue(o2));
  767. ensure(STR(tick_num) + ". is not in queue 1", !mdc->isInQueue(o1));
  768. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  769. ensure(STR(tick_num) + ". is in queue 4", mdc->isInQueue(o4));
  770. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 4);
  771. ensure(STR(tick_num) + ". post object id", (*gPostRecords)[3]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID_3));
  773. ::pump_timers();
  774. ++tick_num;
  776. // 5 The fifth tick should now identify objects 3 and 4 as no longer
  777. // needing "updating", and remove them from the queue
  778. ensure(STR(tick_num) + ". is not in queue 2", !mdc->isInQueue(o2));
  779. ensure(STR(tick_num) + ". is not in queue 1", !mdc->isInQueue(o1));
  780. ensure(STR(tick_num) + ". is not in queue 3", !mdc->isInQueue(o3));
  781. ensure(STR(tick_num) + ". is not in queue 4", !mdc->isInQueue(o4));
  782. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 4);
  784. ::pump_timers();
  786. // Whew....better be empty
  787. ensure("queue empty", mdc->isEmpty());
  788. }
  789. ensure("refcount of o1", o1->getNumRefs(), 1);
  790. ensure("refcount of o2", o2->getNumRefs(), 1);
  791. ensure("refcount of o3", o3->getNumRefs(), 1);
  792. ensure("refcount of o4", o4->getNumRefs(), 1);
  793. }
  796. template<> template<>
  797. void mediadataclient_object_t::test<11>()
  798. {
  799. //
  800. // Test LLMediaDataClient's destructor
  801. //
  802. LOG_TEST(11);
  804. LLMediaDataClientObject::ptr_t o = new LLMediaDataClientObjectTest(DATA);
  805. int num_refs_start = o->getNumRefs();
  806. {
  807. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD);
  808. mdc->fetchMedia(o);
  809. // must tick enough times to clear refcount of mdc
  810. ::pump_timers();
  811. }
  812. // Make sure everyone's destroyed properly
  813. ensure("REF COUNT", o->getNumRefs(), num_refs_start);
  814. }
  816. template<> template<>
  817.     void mediadataclient_object_t::test<12>()
  818.     {
  819. //
  820. // Test the "not interesting enough" call
  821. //
  822. LOG_TEST(12);
  824. LLMediaDataClientObjectTest *object1 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_1,"1.0","true"));
  825. LLMediaDataClientObject::ptr_t o1 = object1;
  826. LLMediaDataClientObject::ptr_t o2 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_2,"2.0","true"));
  827. LLMediaDataClientObject::ptr_t o3 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_3,"3.0","true"));
  828. LLMediaDataClientObject::ptr_t o4 = new LLMediaDataClientObjectTest(_DATA(VALID_OBJECT_ID_4,"4.0","true"));
  829. {
  830. LLPointer<LLObjectMediaDataClient> mdc = new LLObjectMediaDataClient(NO_PERIOD,NO_PERIOD);
  832. // queue up all 4 objects.  The first two are "interesting enough".
  833. // Firing the timer 4 times should therefore leave them.
  834. // Note that they should be sorted 4,3,2,1
  835. // Then, we'll make one "interesting enough", fire the timer a few 
  836. // times, and make sure only it gets pulled off the queue
  837. gMinimumInterestLevel = 2.5;
  838. mdc->fetchMedia(o1);
  839. mdc->fetchMedia(o2);
  840. mdc->fetchMedia(o3);
  841. mdc->fetchMedia(o4);
  843. int tick_num = 0;
  845. // 0
  846. ensure(STR(tick_num) + ". is in queue 1", mdc->isInQueue(o1));
  847. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  848. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  849. ensure(STR(tick_num) + ". is in queue 4", mdc->isInQueue(o4));
  850. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 0);
  852. ::pump_timers();
  853. ++tick_num;
  855. // 1 The first tick should remove object 4
  856. ensure(STR(tick_num) + ". is in queue 1", mdc->isInQueue(o1));
  857. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  858. ensure(STR(tick_num) + ". is in queue 3", mdc->isInQueue(o3));
  859. ensure(STR(tick_num) + ". is not in queue 4", !mdc->isInQueue(o4));
  860. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 1);
  861. ensure(STR(tick_num) + ". post object id", (*gPostRecords)[0]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID_4));
  863. ::pump_timers();
  864. ++tick_num;
  866. // 2 The second tick should send object 3
  867. ensure(STR(tick_num) + ". is in queue 1", mdc->isInQueue(o1));
  868. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  869. ensure(STR(tick_num) + ". is not in queue 3", !mdc->isInQueue(o3));
  870. ensure(STR(tick_num) + ". is not in queue 4", !mdc->isInQueue(o4));
  871. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 2);
  872. ensure(STR(tick_num) + ". post object id", (*gPostRecords)[1]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID_3));
  874. ::pump_timers();
  875. ++tick_num;
  877. // 3 The third tick should not pull off anything
  878. ensure(STR(tick_num) + ". is in queue 1", mdc->isInQueue(o1));
  879. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  880. ensure(STR(tick_num) + ". is not in queue 3", !mdc->isInQueue(o3));
  881. ensure(STR(tick_num) + ". is not in queue 4", !mdc->isInQueue(o4));
  882. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 2);
  884. ::pump_timers();
  885. ++tick_num;
  887. // 4 The fourth tick (for good measure) should not pull off anything
  888. ensure(STR(tick_num) + ". is in queue 1", mdc->isInQueue(o1));
  889. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  890. ensure(STR(tick_num) + ". is not in queue 3", !mdc->isInQueue(o3));
  891. ensure(STR(tick_num) + ". is not in queue 4", !mdc->isInQueue(o4));
  892. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 2);
  894. // Okay, now futz with object 1's interest, such that it is now 
  895. // "interesting enough"
  896. object1->setMediaInterest((F64)5.0);
  898. // This should sort so that the queue is now [1 2] 
  899. ::pump_timers();
  900. ++tick_num;
  902. // 5 The fifth tick should now identify objects 3 and 4 as no longer
  903. // needing "updating", and remove them from the queue
  904. ensure(STR(tick_num) + ". is not in queue 1", !mdc->isInQueue(o1));
  905. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  906. ensure(STR(tick_num) + ". is not in queue 3", !mdc->isInQueue(o3));
  907. ensure(STR(tick_num) + ". is not in queue 4", !mdc->isInQueue(o4));
  908. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 3);
  909. ensure(STR(tick_num) + ". post object id", (*gPostRecords)[2]["body"][LLTextureEntry::OBJECT_ID_KEY].asUUID(), LLUUID(VALID_OBJECT_ID_1));
  911. ::pump_timers();
  912. ++tick_num;
  914. // 6 The sixth tick should not pull off anything
  915. ensure(STR(tick_num) + ". is not in queue 1", !mdc->isInQueue(o1));
  916. ensure(STR(tick_num) + ". is in queue 2", mdc->isInQueue(o2));
  917. ensure(STR(tick_num) + ". is not in queue 3", !mdc->isInQueue(o3));
  918. ensure(STR(tick_num) + ". is not in queue 4", !mdc->isInQueue(o4));
  919. ensure(STR(tick_num) + ". post records", gPostRecords->size(), 3);
  921. ::pump_timers();
  922. ++tick_num;
  924. // Whew....better NOT be empty ... o2 should still be there
  925. ensure("queue not empty", !mdc->isEmpty());
  927. // But, we need to clear the queue, or else we won't destroy MDC...
  928. // this is a strange interplay between the queue timer and the MDC
  929. ensure("o2 couldn't be removed from queue", mdc->removeFromQueue(o2));
  930. // tick
  931. ::pump_timers();
  932. }
  933. ensure("refcount of o1", o1->getNumRefs(), 1);
  934. ensure("refcount of o2", o2->getNumRefs(), 1);
  935. ensure("refcount of o3", o3->getNumRefs(), 1);
  936. ensure("refcount of o4", o4->getNumRefs(), 1);
  937. }
  938. }