aboutsummaryrefslogtreecommitdiff
path: root/NvBlast/test/src/unit/SyncTests.cpp
diff options
context:
space:
mode:
authorBryan Galdrikian <[email protected]>2017-02-24 09:32:20 -0800
committerBryan Galdrikian <[email protected]>2017-02-24 09:32:20 -0800
commite1bf674c16e3c8472b29574159c789cd3f0c64e0 (patch)
tree9f0cfce09c71a2c27ff19589fcad6cd83504477c /NvBlast/test/src/unit/SyncTests.cpp
parentfirst commit (diff)
downloadblast-e1bf674c16e3c8472b29574159c789cd3f0c64e0.tar.xz
blast-e1bf674c16e3c8472b29574159c789cd3f0c64e0.zip
Updating to [email protected] and [email protected] with a new directory structure.
NvBlast folder is gone, files have been moved to top level directory. README is changed to reflect this.
Diffstat (limited to 'NvBlast/test/src/unit/SyncTests.cpp')
-rw-r--r--NvBlast/test/src/unit/SyncTests.cpp309
1 files changed, 0 insertions, 309 deletions
diff --git a/NvBlast/test/src/unit/SyncTests.cpp b/NvBlast/test/src/unit/SyncTests.cpp
deleted file mode 100644
index 425210d..0000000
--- a/NvBlast/test/src/unit/SyncTests.cpp
+++ /dev/null
@@ -1,309 +0,0 @@
-#include "TkBaseTest.h"
-
-#include "NvBlastExtSync.h"
-#include "NvBlastTkEvent.h"
-
-#include <map>
-
-///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-// ExtSync Tests
-///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-
-class Base
-{
-public:
- Base(TkTestStrict* test) : m_test(test)
- {
-
- }
-
- void run(std::stringstream& finalState)
- {
- //////// initial setup ////////
-
- m_test->createTestAssets();
-
- TkFramework* fwk = NvBlastTkFrameworkGet();
-
- TkGroupDesc gdesc;
- gdesc.pxTaskManager = m_test->m_taskman;
- m_group = fwk->createGroup(gdesc);
- EXPECT_TRUE(m_group != nullptr);
-
- TkActorDesc adesc(m_test->testAssets[0]);
-
- NvBlastID id;
-
- TkActor* actor0 = fwk->createActor(adesc);
- EXPECT_TRUE(actor0 != nullptr);
- families[0] = &actor0->getFamily();
- memcpy(id.data, "Mumble Jumble Bumble", sizeof(NvBlastID)); // Stuffing an arbitrary 16 bytes (The prefix of the given string)
- families[0]->setID(id);
- m_group->addActor(*actor0);
-
- TkActor* actor1 = fwk->createActor(adesc);
- EXPECT_TRUE(actor1 != nullptr);
- families[1] = &actor1->getFamily();
- memcpy(id.data, "buzzkillerdiller", sizeof(NvBlastID)); // Stuffing an arbitrary 16 bytes (The prefix of the given string)
- families[1]->setID(id);
- m_group->addActor(*actor1);
-
-
- //////// server/client specific impl ////////
-
- impl();
-
-
- //////// write out framework final state ////////
-
- finalState.clear();
- for (auto family : families)
- {
- std::vector<TkActor*> actors(family->getActorCount());
- family->getActors(actors.data(), static_cast<uint32_t>(actors.size()));
- for (auto actor : actors)
- {
- finalState << actor->getVisibleChunkCount();
- finalState << actor->getGraphNodeCount();
- std::vector<uint32_t> chunkIndices(actor->getGraphNodeCount());
- actor->getVisibleChunkIndices(chunkIndices.data(), (uint32_t)chunkIndices.size());
-
- for (uint32_t chunkIndex : chunkIndices)
- finalState << chunkIndex;
- const float* bondHealths = actor->getBondHealths();
- for (uint32_t i = 0; i < actor->getAsset()->getBondCount(); ++i)
- finalState << bondHealths[i];
- }
- }
-
-
- //////// release ////////
-
- m_group->release();
-
- for (auto family : families)
- {
- family->release();
- }
-
- m_test->releaseTestAssets();
- }
-
-protected:
- virtual void impl() = 0;
-
- TkTestStrict* m_test;
- TkGroup* m_group;
- TkFamily* families[2];
-};
-
-
-class Server : public Base
-{
-public:
- Server(TkTestStrict* test, std::vector<ExtSyncEvent*>& syncBuffer) : Base(test), m_syncBuffer(syncBuffer) {}
-
-protected:
- virtual void impl() override
- {
- // create sync ext
- ExtSync* sync = ExtSync::create();
-
- // add sync as listener to family #1
- families[1]->addListener(*sync);
-
- // damage family #0 (make it split)
- {
- TkActor* actor;
- families[0]->getActors(&actor, 1);
- CSParams p(1, 0.0f);
- actor->damage(m_test->getCubeSlicerProgram(), &p, sizeof(p), m_test->getDefaultMaterial());
- }
-
- // process
- m_group->process();
- m_group->sync();
- EXPECT_EQ(families[0]->getActorCount(), 2);
-
- // sync family #0
- sync->syncFamily(*families[0]);
-
- // add sync as listener to family #0
- families[0]->addListener(*sync);
-
- // damage family #0 (make it split fully)
- {
- TkActor* actor;
- families[0]->getActors(&actor, 1, 1);
- NvBlastExtRadialDamageDesc radialDamage = m_test->getRadialDamageDesc(0, 0, 0);
- actor->damage(m_test->getFalloffProgram(), &radialDamage, sizeof(radialDamage), m_test->getDefaultMaterial());
- }
-
-
- // damage family 1 (just damage bonds health)
- {
- TkActor* actor;
- families[1]->getActors(&actor, 1);
- NvBlastExtRadialDamageDesc radialDamage = m_test->getRadialDamageDesc(0, 0, 0, 10.0f, 10.0f, 0.1f);
- actor->damage(m_test->getFalloffProgram(), &radialDamage, sizeof(radialDamage), m_test->getDefaultMaterial());
- }
-
- // process
- m_group->process();
- m_group->sync();
- EXPECT_EQ(families[0]->getActorCount(), 5);
- EXPECT_EQ(families[1]->getActorCount(), 1);
-
- // take sync buffer from sync
- {
- const ExtSyncEvent*const* buffer;
- uint32_t size;
- sync->acquireSyncBuffer(buffer, size);
-
- m_syncBuffer.resize(size);
- for (size_t i = 0; i < size; ++i)
- {
- m_syncBuffer[i] = buffer[i]->clone();
- }
-
- sync->releaseSyncBuffer();
- }
-
- //
- families[0]->removeListener(*sync);
- families[1]->removeListener(*sync);
-
- //
- sync->release();
- }
-
-private:
- std::vector<ExtSyncEvent*>& m_syncBuffer;
-};
-
-
-class Client : public Base, public TkEventListener
-{
-public:
- Client(TkTestStrict* test, std::vector<ExtSyncEvent*>& syncBuffer) : Base(test), m_syncBuffer(syncBuffer) {}
-
-protected:
-
- virtual void impl() override
- {
- ExtSync* sync = ExtSync::create();
-
- // fill map
- for (auto& family : families)
- {
- std::vector<TkActor*> actors(family->getActorCount());
- family->getActors(actors.data(), static_cast<uint32_t>(actors.size()));
- auto& actorsSet = m_actorsPerFamily[family];
- for (auto actor : actors)
- EXPECT_TRUE(actorsSet.insert(actor->getIndex()).second);
- }
-
- // subscribe
- for (auto& family : families)
- {
- family->addListener(*this);
- }
-
- // apply sync buffer
- sync->applySyncBuffer(*NvBlastTkFrameworkGet(), (const Nv::Blast::ExtSyncEvent**)m_syncBuffer.data(), static_cast<uint32_t>(m_syncBuffer.size()), m_group);
-
- // check map
- for (auto& family : families)
- {
- std::vector<TkActor*> actors(family->getActorCount());
- family->getActors(actors.data(), static_cast<uint32_t>(actors.size()));
- std::set<uint32_t> actorsSet;
- for (auto actor : actors)
- EXPECT_TRUE(actorsSet.insert(actor->getIndex()).second);
- EXPECT_TRUE(m_actorsPerFamily[family] == actorsSet);
- }
-
- // unsubscribe
- for (auto& family : families)
- {
- family->removeListener(*this);
- }
-
- m_group->process();
- m_group->sync();
-
- sync->release();
- }
-
- // listen for Split event and update actors map
- virtual void receive(const TkEvent* events, uint32_t eventCount) override
- {
- for (size_t i = 0; i < eventCount; ++i)
- {
- const TkEvent& e = events[i];
- switch (e.type)
- {
- case (TkEvent::Split) :
- {
- const TkSplitEvent* splitEvent = e.getPayload<TkSplitEvent>();
- auto& actorsSet = m_actorsPerFamily[splitEvent->parentData.family];
- if (!isInvalidIndex(splitEvent->parentData.index))
- {
- EXPECT_EQ((size_t)1, actorsSet.erase(splitEvent->parentData.index));
- }
- for (size_t i = 0; i < splitEvent->numChildren; ++i)
- {
- TkActor* a = splitEvent->children[i];
- EXPECT_TRUE(actorsSet.insert(a->getIndex()).second);
- }
- break;
- }
- case (TkEvent::FractureCommand) :
- {
- break;
- }
- case (TkEvent::JointUpdate) :
- {
- FAIL();
- break;
- }
- default:
- break;
- }
- }
- }
-
-private:
- std::map<TkFamily*, std::set<uint32_t>> m_actorsPerFamily;
- std::vector<ExtSyncEvent*>& m_syncBuffer;
-};
-
-TEST_F(TkTestStrict, SyncTest1)
-{
- this->createFramework();
-
- std::vector<ExtSyncEvent*> syncBuffer;
-
- std::stringstream serverFinalState;
- {
- Server s(this, syncBuffer);
- s.run(serverFinalState);
- }
- EXPECT_TRUE(syncBuffer.size() > 0);
-
- std::stringstream clientFinalState;
- {
- Client c(this, syncBuffer);
- c.run(clientFinalState);
- }
-
- for (auto e : syncBuffer)
- {
- e->release();
- }
- syncBuffer.clear();
-
- EXPECT_EQ(serverFinalState.str(), clientFinalState.str());
-
- this->releaseFramework();
-}