/**************************************************************************** Copyright (c) 2017-2018 Xiamen Yaji Software Co., Ltd. https://axis-project.github.io/ Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. ****************************************************************************/ #include "SchedulerTest.h" #include "../testResource.h" #include "ui/UIText.h" #include "controller.h" USING_NS_AX; USING_NS_AX_EXT; using namespace axis::ui; enum { kTagAnimationDance = 1, }; SchedulerTests::SchedulerTests() { ADD_TEST_CASE(SchedulerTimeScale); ADD_TEST_CASE(TwoSchedulers); ADD_TEST_CASE(SchedulerAutoremove); ADD_TEST_CASE(SchedulerPauseResume); ADD_TEST_CASE(SchedulerPauseResumeAll); ADD_TEST_CASE(SchedulerPauseResumeAllUser); ADD_TEST_CASE(SchedulerUnscheduleAll); ADD_TEST_CASE(SchedulerUnscheduleAllHard); ADD_TEST_CASE(SchedulerUnscheduleAllUserLevel); ADD_TEST_CASE(SchedulerSchedulesAndRemove); ADD_TEST_CASE(SchedulerUpdate); ADD_TEST_CASE(SchedulerUpdateAndCustom); ADD_TEST_CASE(SchedulerUpdateFromCustom); ADD_TEST_CASE(RescheduleSelector); ADD_TEST_CASE(SchedulerDelayAndRepeat); ADD_TEST_CASE(SchedulerIssue2268); ADD_TEST_CASE(SchedulerIssueWithReschedule); ADD_TEST_CASE(ScheduleCallbackTest); ADD_TEST_CASE(ScheduleUpdatePriority); ADD_TEST_CASE(SchedulerIssue10232); ADD_TEST_CASE(SchedulerRemoveAllFunctionsToBePerformedInCocosThread) ADD_TEST_CASE(SchedulerIssue17149); ADD_TEST_CASE(SchedulerRemoveEntryWhileUpdate); ADD_TEST_CASE(SchedulerRemoveSelectorDuringCall); }; //------------------------------------------------------------------ // // SchedulerAutoremove // //------------------------------------------------------------------ void SchedulerAutoremove::onEnter() { SchedulerTestLayer::onEnter(); schedule(AX_SCHEDULE_SELECTOR(SchedulerAutoremove::autoremove), 0.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerAutoremove::tick), 0.5f); accum = 0; } void SchedulerAutoremove::autoremove(float dt) { accum += dt; AXLOG("autoremove scheduler: Time: %f", accum); if (accum > 3) { unschedule(AX_SCHEDULE_SELECTOR(SchedulerAutoremove::autoremove)); AXLOG("autoremove scheduler: scheduler removed"); } } void SchedulerAutoremove::tick(float /*dt*/) { AXLOG("tick scheduler: This scheduler should not be removed"); } std::string SchedulerAutoremove::title() const { return "Self-remove an scheduler"; } std::string SchedulerAutoremove::subtitle() const { return "1 scheduler will be autoremoved in 3 seconds. See console"; } //------------------------------------------------------------------ // // SchedulerPauseResume // //------------------------------------------------------------------ void SchedulerPauseResume::onEnter() { SchedulerTestLayer::onEnter(); schedule(AX_SCHEDULE_SELECTOR(SchedulerPauseResume::tick1), 0.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerPauseResume::tick2), 0.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerPauseResume::pause), 3.0f); } void SchedulerPauseResume::tick1(float /*dt*/) { AXLOG("tick1"); } void SchedulerPauseResume::tick2(float /*dt*/) { AXLOG("tick2"); } void SchedulerPauseResume::pause(float /*dt*/) { AXLOG("paused, tick1 and tick2 should called six times"); Director::getInstance()->getScheduler()->pauseTarget(this); } std::string SchedulerPauseResume::title() const { return "Pause / Resume"; } std::string SchedulerPauseResume::subtitle() const { return "Scheduler should be paused after 3 seconds. See console"; } //------------------------------------------------------------------ // // SchedulerPauseResumeAll // //------------------------------------------------------------------ SchedulerPauseResumeAll::SchedulerPauseResumeAll() {} SchedulerPauseResumeAll::~SchedulerPauseResumeAll() {} void SchedulerPauseResumeAll::onEnter() { SchedulerTestLayer::onEnter(); auto sprite = Sprite::create("Images/grossinis_sister1.png"); sprite->setPosition(VisibleRect::center()); this->addChild(sprite); sprite->runAction(RepeatForever::create(RotateBy::create(3.0f, 360.0f))); sprite->setTag(123); scheduleUpdate(); schedule(AX_SCHEDULE_SELECTOR(SchedulerPauseResumeAll::tick1), 0.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerPauseResumeAll::tick2), 1.0f); scheduleOnce(AX_SCHEDULE_SELECTOR(SchedulerPauseResumeAll::pause), 3.0f); } void SchedulerPauseResumeAll::update(float /*delta*/) { // do nothing } void SchedulerPauseResumeAll::onExit() { if (!_pausedTargets.empty()) { Director::getInstance()->getScheduler()->resumeTargets(_pausedTargets); } SchedulerTestLayer::onExit(); } void SchedulerPauseResumeAll::tick1(float /*dt*/) { log("tick1"); } void SchedulerPauseResumeAll::tick2(float /*dt*/) { log("tick2"); } void SchedulerPauseResumeAll::pause(float /*dt*/) { log("Pausing, tick1 should be called six times and tick2 three times"); auto scheduler = Director::getInstance()->getScheduler(); _pausedTargets = scheduler->pauseAllTargets(); // should have only 2 items: ActionManager, self AXASSERT(_pausedTargets.size() == 2, "Error: pausedTargets should have only 2 items"); // because target 'this' has been paused above, so use another node(tag:123) as target getChildByTag(123)->scheduleOnce([this](float dt) { this->resume(dt); }, 2.0f, "test resume"); } void SchedulerPauseResumeAll::resume(float /*dt*/) { log("Resuming"); auto director = Director::getInstance(); director->getScheduler()->resumeTargets(_pausedTargets); _pausedTargets.clear(); } std::string SchedulerPauseResumeAll::title() const { return "Pause / Resume All"; } std::string SchedulerPauseResumeAll::subtitle() const { return "Everything will pause after 3s, then resume at 5s. See console"; } //------------------------------------------------------------------ // // SchedulerPauseResumeAllUser // //------------------------------------------------------------------ SchedulerPauseResumeAllUser::SchedulerPauseResumeAllUser() {} SchedulerPauseResumeAllUser::~SchedulerPauseResumeAllUser() {} void SchedulerPauseResumeAllUser::onEnter() { SchedulerTestLayer::onEnter(); auto s = Director::getInstance()->getWinSize(); auto sprite = Sprite::create("Images/grossinis_sister1.png"); sprite->setPosition(Vec2(s.width / 2, s.height / 2)); sprite->setTag(123); this->addChild(sprite); sprite->runAction(RepeatForever::create(RotateBy::create(3.0f, 360.0f))); schedule(AX_SCHEDULE_SELECTOR(SchedulerPauseResumeAllUser::tick1), 1.0f); schedule(AX_SCHEDULE_SELECTOR(SchedulerPauseResumeAllUser::tick2), 1.0f); schedule(AX_SCHEDULE_SELECTOR(SchedulerPauseResumeAllUser::pause), 3.0f, false, 0); } void SchedulerPauseResumeAllUser::onExit() { if (!_pausedTargets.empty()) { Director::getInstance()->getScheduler()->resumeTargets(_pausedTargets); } SchedulerTestLayer::onExit(); } void SchedulerPauseResumeAllUser::tick1(float /*dt*/) { log("tick1"); } void SchedulerPauseResumeAllUser::tick2(float /*dt*/) { log("tick2"); } void SchedulerPauseResumeAllUser::pause(float /*dt*/) { log("Pausing, tick1 and tick2 should be called three times"); auto director = Director::getInstance(); _pausedTargets = director->getScheduler()->pauseAllTargetsWithMinPriority(Scheduler::PRIORITY_NON_SYSTEM_MIN); // because target 'this' has been paused above, so use another node(tag:123) as target getChildByTag(123)->scheduleOnce([this](float dt) { this->resume(dt); }, 2.0f, "test resume"); } void SchedulerPauseResumeAllUser::resume(float /*dt*/) { log("Resuming"); getScheduler()->resumeTargets(_pausedTargets); _pausedTargets.clear(); } std::string SchedulerPauseResumeAllUser::title() const { return "Pause / Resume All User scheduler"; } std::string SchedulerPauseResumeAllUser::subtitle() const { return "ticks will pause after 3s, then resume at 5s. See console"; } //------------------------------------------------------------------ // // SchedulerUnscheduleAll // //------------------------------------------------------------------ void SchedulerUnscheduleAll::onEnter() { SchedulerTestLayer::onEnter(); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAll::tick1), 0.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAll::tick2), 1.0f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAll::tick3), 1.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAll::tick4), 1.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAll::unscheduleAll), 4); } void SchedulerUnscheduleAll::tick1(float /*dt*/) { AXLOG("tick1"); } void SchedulerUnscheduleAll::tick2(float /*dt*/) { AXLOG("tick2"); } void SchedulerUnscheduleAll::tick3(float /*dt*/) { AXLOG("tick3"); } void SchedulerUnscheduleAll::tick4(float /*dt*/) { AXLOG("tick4"); } void SchedulerUnscheduleAll::unscheduleAll(float /*dt*/) { unscheduleAllCallbacks(); } std::string SchedulerUnscheduleAll::title() const { return "Unschedule All selectors"; } std::string SchedulerUnscheduleAll::subtitle() const { return "All scheduled selectors will be unscheduled in 4 seconds. See console"; } //------------------------------------------------------------------ // // SchedulerUnscheduleAllHard // //------------------------------------------------------------------ void SchedulerUnscheduleAllHard::onEnter() { SchedulerTestLayer::onEnter(); auto s = Director::getInstance()->getWinSize(); auto sprite = Sprite::create("Images/grossinis_sister1.png"); sprite->setPosition(Vec2(s.width / 2, s.height / 2)); this->addChild(sprite); sprite->runAction(RepeatForever::create(RotateBy::create(3.0f, 360.0f))); _actionManagerActive = true; schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllHard::tick1), 0.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllHard::tick2), 1.0f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllHard::tick3), 1.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllHard::tick4), 1.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllHard::unscheduleAll), 4); } void SchedulerUnscheduleAllHard::onExit() { if (!_actionManagerActive) { // Restore the director's action manager. auto director = Director::getInstance(); director->getScheduler()->scheduleUpdate(director->getActionManager(), Scheduler::PRIORITY_SYSTEM, false); } SchedulerTestLayer::onExit(); } void SchedulerUnscheduleAllHard::tick1(float /*dt*/) { AXLOG("tick1"); } void SchedulerUnscheduleAllHard::tick2(float /*dt*/) { AXLOG("tick2"); } void SchedulerUnscheduleAllHard::tick3(float /*dt*/) { AXLOG("tick3"); } void SchedulerUnscheduleAllHard::tick4(float /*dt*/) { AXLOG("tick4"); } void SchedulerUnscheduleAllHard::unscheduleAll(float /*dt*/) { Director::getInstance()->getScheduler()->unscheduleAll(); _actionManagerActive = false; } std::string SchedulerUnscheduleAllHard::title() const { return "Unschedule All selectors (HARD)"; } std::string SchedulerUnscheduleAllHard::subtitle() const { return "Unschedules all user selectors after 4s. Action will stop. See console"; } //------------------------------------------------------------------ // // SchedulerUnscheduleAllUserLevel // //------------------------------------------------------------------ void SchedulerUnscheduleAllUserLevel::onEnter() { SchedulerTestLayer::onEnter(); auto s = Director::getInstance()->getWinSize(); auto sprite = Sprite::create("Images/grossinis_sister1.png"); sprite->setPosition(Vec2(s.width / 2, s.height / 2)); this->addChild(sprite); sprite->runAction(RepeatForever::create(RotateBy::create(3.0f, 360.0f))); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllUserLevel::tick1), 0.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllUserLevel::tick2), 1.0f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllUserLevel::tick3), 1.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllUserLevel::tick4), 1.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerUnscheduleAllUserLevel::unscheduleAll), 4); } void SchedulerUnscheduleAllUserLevel::tick1(float /*dt*/) { AXLOG("tick1"); } void SchedulerUnscheduleAllUserLevel::tick2(float /*dt*/) { AXLOG("tick2"); } void SchedulerUnscheduleAllUserLevel::tick3(float /*dt*/) { AXLOG("tick3"); } void SchedulerUnscheduleAllUserLevel::tick4(float /*dt*/) { AXLOG("tick4"); } void SchedulerUnscheduleAllUserLevel::unscheduleAll(float /*dt*/) { Director::getInstance()->getScheduler()->unscheduleAllWithMinPriority(Scheduler::PRIORITY_NON_SYSTEM_MIN); } std::string SchedulerUnscheduleAllUserLevel::title() const { return "Unschedule All user selectors"; } std::string SchedulerUnscheduleAllUserLevel::subtitle() const { return "Unschedules all user selectors after 4s. Action should not stop. See console"; } //------------------------------------------------------------------ // // SchedulerSchedulesAndRemove // //------------------------------------------------------------------ void SchedulerSchedulesAndRemove::onEnter() { SchedulerTestLayer::onEnter(); schedule(AX_SCHEDULE_SELECTOR(SchedulerSchedulesAndRemove::tick1), 0.5f); schedule(AX_SCHEDULE_SELECTOR(SchedulerSchedulesAndRemove::tick2), 1.0f); schedule(AX_SCHEDULE_SELECTOR(SchedulerSchedulesAndRemove::scheduleAndUnschedule), 4.0f); } void SchedulerSchedulesAndRemove::tick1(float /*dt*/) { AXLOG("tick1"); } void SchedulerSchedulesAndRemove::tick2(float /*dt*/) { AXLOG("tick2"); } void SchedulerSchedulesAndRemove::tick3(float /*dt*/) { AXLOG("tick3"); } void SchedulerSchedulesAndRemove::tick4(float /*dt*/) { AXLOG("tick4"); } std::string SchedulerSchedulesAndRemove::title() const { return "Schedule from Schedule"; } std::string SchedulerSchedulesAndRemove::subtitle() const { return "Will unschedule and schedule selectors in 4s. See console"; } void SchedulerSchedulesAndRemove::scheduleAndUnschedule(float /*dt*/) { unschedule(AX_SCHEDULE_SELECTOR(SchedulerSchedulesAndRemove::tick1)); unschedule(AX_SCHEDULE_SELECTOR(SchedulerSchedulesAndRemove::tick2)); unschedule(AX_SCHEDULE_SELECTOR(SchedulerSchedulesAndRemove::scheduleAndUnschedule)); schedule(AX_SCHEDULE_SELECTOR(SchedulerSchedulesAndRemove::tick3), 1.0f); schedule(AX_SCHEDULE_SELECTOR(SchedulerSchedulesAndRemove::tick4), 1.0f); } //------------------------------------------------------------------ // // TestNode // //------------------------------------------------------------------ void TestNode::initWithString(std::string_view str, int priority) { _string = str; scheduleUpdateWithPriority(priority); } TestNode::~TestNode() {} void TestNode::update(float /*dt*/) { log("%s", _string.c_str()); } //------------------------------------------------------------------ // // SchedulerUpdate // //------------------------------------------------------------------ void SchedulerUpdate::onEnter() { SchedulerTestLayer::onEnter(); auto d = new TestNode(); d->initWithString("---", 50); addChild(d); d->release(); auto b = new TestNode(); b->initWithString("3rd", 0); addChild(b); b->release(); auto a = new TestNode(); a->initWithString("1st", -10); addChild(a); a->release(); auto c = new TestNode(); c->initWithString("4th", 10); addChild(c); c->release(); auto e = new TestNode(); e->initWithString("5th", 20); addChild(e); e->release(); auto f = new TestNode(); f->initWithString("2nd", -5); addChild(f); f->release(); schedule(AX_SCHEDULE_SELECTOR(SchedulerUpdate::removeUpdates), 4.0f); } void SchedulerUpdate::removeUpdates(float /*dt*/) { auto& children = getChildren(); for (auto& c : children) { auto obj = static_cast(c); auto node = static_cast(obj); if (!node) { break; } node->unscheduleAllCallbacks(); } } std::string SchedulerUpdate::title() const { return "Schedule update with priority"; } std::string SchedulerUpdate::subtitle() const { return "3 scheduled updates. Priority should work. Stops in 4s. See console"; } //------------------------------------------------------------------ // // SchedulerUpdateAndCustom // //------------------------------------------------------------------ void SchedulerUpdateAndCustom::onEnter() { SchedulerTestLayer::onEnter(); scheduleUpdate(); schedule(AX_SCHEDULE_SELECTOR(SchedulerUpdateAndCustom::tick)); schedule(AX_SCHEDULE_SELECTOR(SchedulerUpdateAndCustom::stopSelectors), 0.4f); } void SchedulerUpdateAndCustom::update(float dt) { AXLOG("update called:%f", dt); } void SchedulerUpdateAndCustom::tick(float dt) { AXLOG("custom selector called:%f", dt); } void SchedulerUpdateAndCustom::stopSelectors(float /*dt*/) { log("SchedulerUpdateAndCustom::stopSelectors"); unscheduleAllCallbacks(); } std::string SchedulerUpdateAndCustom::title() const { return "Schedule Update + custom selector"; } std::string SchedulerUpdateAndCustom::subtitle() const { return "Update + custom selector at the same time. Stops in 4s. See console"; } //------------------------------------------------------------------ // // SchedulerUpdateFromCustom // //------------------------------------------------------------------ void SchedulerUpdateFromCustom::onEnter() { SchedulerTestLayer::onEnter(); schedule(AX_SCHEDULE_SELECTOR(SchedulerUpdateFromCustom::schedUpdate), 2.0f); } void SchedulerUpdateFromCustom::update(float dt) { AXLOG("update called:%f", dt); } void SchedulerUpdateFromCustom::schedUpdate(float /*dt*/) { unschedule(AX_SCHEDULE_SELECTOR(SchedulerUpdateFromCustom::schedUpdate)); scheduleUpdate(); schedule(AX_SCHEDULE_SELECTOR(SchedulerUpdateFromCustom::stopUpdate), 2.0f); } void SchedulerUpdateFromCustom::stopUpdate(float /*dt*/) { unscheduleUpdate(); unschedule(AX_SCHEDULE_SELECTOR(SchedulerUpdateFromCustom::stopUpdate)); } std::string SchedulerUpdateFromCustom::title() const { return "Schedule Update in 2 sec"; } std::string SchedulerUpdateFromCustom::subtitle() const { return "Update schedules in 2 secs. Stops 2 sec later. See console"; } //------------------------------------------------------------------ // // RescheduleSelector // //------------------------------------------------------------------ void RescheduleSelector::onEnter() { SchedulerTestLayer::onEnter(); _interval = 1.0f; _ticks = 0; schedule(AX_SCHEDULE_SELECTOR(RescheduleSelector::schedUpdate), _interval); } std::string RescheduleSelector::title() const { return "Reschedule Selector"; } std::string RescheduleSelector::subtitle() const { return "Interval is 1 second, then 2, then 3..."; } void RescheduleSelector::schedUpdate(float dt) { _ticks++; AXLOG("schedUpdate: %.4f", dt); if (_ticks > 3) { _interval += 1.0f; schedule(AX_SCHEDULE_SELECTOR(RescheduleSelector::schedUpdate), _interval); _ticks = 0; } } // SchedulerDelayAndRepeat void SchedulerDelayAndRepeat::onEnter() { SchedulerTestLayer::onEnter(); schedule(AX_SCHEDULE_SELECTOR(SchedulerDelayAndRepeat::update), 0, 4, 3.f); AXLOG("update is scheduled should begin after 3 seconds"); } std::string SchedulerDelayAndRepeat::title() const { return "Schedule with delay of 3 sec, repeat 4 times"; } std::string SchedulerDelayAndRepeat::subtitle() const { return "After 5 x executed, method unscheduled. See console"; } void SchedulerDelayAndRepeat::update(float dt) { log("update called:%f", dt); } // SchedulerTimeScale ControlSlider* SchedulerTimeScale::sliderCtl() { ControlSlider* slider = ControlSlider::create("extensions/sliderTrack2.png", "extensions/sliderProgress2.png", "extensions/sliderThumb.png"); slider->addTargetWithActionForControlEvents(this, cccontrol_selector(SchedulerTimeScale::sliderAction), Control::EventType::VALUE_CHANGED); slider->setMinimumValue(-3.0f); slider->setMaximumValue(3.0f); slider->setValue(1.0f); return slider; } void SchedulerTimeScale::sliderAction(Ref* sender, Control::EventType /*controlEvent*/) { ControlSlider* pSliderCtl = static_cast(sender); float scale; scale = pSliderCtl->getValue(); Director::getInstance()->getScheduler()->setTimeScale(scale); } void SchedulerTimeScale::onEnter() { SchedulerTestLayer::onEnter(); auto s = Director::getInstance()->getWinSize(); // rotate and jump auto jump1 = JumpBy::create(4, Vec2(-s.width + 80, 0.0f), 100, 4); auto jump2 = jump1->reverse(); auto rot1 = RotateBy::create(4, 360 * 2); auto rot2 = rot1->reverse(); auto seq3_1 = Sequence::create(jump2, jump1, nullptr); auto seq3_2 = Sequence::create(rot1, rot2, nullptr); auto spawn = Spawn::create(seq3_1, seq3_2, nullptr); auto action = Repeat::create(spawn, 50); auto action2 = action->clone(); auto action3 = action->clone(); auto grossini = Sprite::create("Images/grossini.png"); auto tamara = Sprite::create("Images/grossinis_sister1.png"); auto kathia = Sprite::create("Images/grossinis_sister2.png"); grossini->setPosition(Vec2(40.0f, 80.0f)); tamara->setPosition(Vec2(40.0f, 80.0f)); kathia->setPosition(Vec2(40.0f, 80.0f)); addChild(grossini); addChild(tamara); addChild(kathia); grossini->runAction(Speed::create(action, 0.5f)); tamara->runAction(Speed::create(action2, 1.5f)); kathia->runAction(Speed::create(action3, 1.0f)); auto emitter = ParticleFireworks::create(); emitter->setTexture(Director::getInstance()->getTextureCache()->addImage(s_stars1)); addChild(emitter); _sliderCtl = sliderCtl(); _sliderCtl->setPosition(Vec2(s.width / 2.0f, s.height / 3.0f)); addChild(_sliderCtl); } void SchedulerTimeScale::onExit() { // restore scale Director::getInstance()->getScheduler()->setTimeScale(1); SchedulerTestLayer::onExit(); } std::string SchedulerTimeScale::title() const { return "Scheduler timeScale Test"; } std::string SchedulerTimeScale::subtitle() const { return "Fast-forward and rewind using scheduler.timeScale"; } // TwoSchedulers ControlSlider* TwoSchedulers::sliderCtl() { // auto frame = CGRectMake(12.0f, 12.0f, 120.0f, 7.0f); ControlSlider* slider = ControlSlider::create("extensions/sliderTrack2.png", "extensions/sliderProgress2.png", "extensions/sliderThumb.png"); //[[UISlider alloc] initWithFrame:frame]; slider->addTargetWithActionForControlEvents(this, cccontrol_selector(TwoSchedulers::sliderAction), Control::EventType::VALUE_CHANGED); // in case the parent view draws with a custom color or gradient, use a transparent color // slider.backgroundColor = [UIColor clearColor]; slider->setMinimumValue(0.0f); slider->setMaximumValue(2.0f); // slider.continuous = YES; slider->setValue(1.0f); return slider; } void TwoSchedulers::sliderAction(Ref* sender, Control::EventType /*controlEvent*/) { float scale; ControlSlider* slider = static_cast(sender); scale = slider->getValue(); if (sender == sliderCtl1) sched1->setTimeScale(scale); else sched2->setTimeScale(scale); } void TwoSchedulers::onEnter() { SchedulerTestLayer::onEnter(); auto s = Director::getInstance()->getWinSize(); // rotate and jump auto jump1 = JumpBy::create(4, Vec2(0, 0), 100, 4); auto jump2 = jump1->reverse(); auto seq = Sequence::create(jump2, jump1, nullptr); auto action = RepeatForever::create(seq); // // Center // auto grossini = Sprite::create("Images/grossini.png"); addChild(grossini); grossini->setPosition(Vec2(s.width / 2, 100.0f)); grossini->runAction(action->clone()); auto defaultScheduler = Director::getInstance()->getScheduler(); // // Left: // // Create a new scheduler, and link it to the main scheduler sched1 = new Scheduler(); defaultScheduler->scheduleUpdate(sched1, 0, false); // Create a new ActionManager, and link it to the new scheduler actionManager1 = new ActionManager(); sched1->scheduleUpdate(actionManager1, 0, false); for (unsigned int i = 0; i < 10; i++) { auto sprite = Sprite::create("Images/grossinis_sister1.png"); // IMPORTANT: Set the actionManager running any action sprite->setActionManager(actionManager1); addChild(sprite); sprite->setPosition(Vec2(30 + 15 * i, 100.0f)); sprite->runAction(action->clone()); } // // Right: // // Create a new scheduler, and link it to the main scheduler sched2 = new Scheduler(); defaultScheduler->scheduleUpdate(sched2, 0, false); // Create a new ActionManager, and link it to the new scheduler actionManager2 = new ActionManager(); sched2->scheduleUpdate(actionManager2, 0, false); for (unsigned int i = 0; i < 10; i++) { auto sprite = Sprite::create("Images/grossinis_sister2.png"); // IMPORTANT: Set the actionManager running any action sprite->setActionManager(actionManager2); addChild(sprite); sprite->setPosition(Vec2(s.width - 30 - 15 * i, 100.0f)); sprite->runAction(action->clone()); } sliderCtl1 = sliderCtl(); addChild(sliderCtl1); sliderCtl1->retain(); sliderCtl1->setPosition(Vec2(s.width / 4.0f, VisibleRect::top().y - 20)); sliderCtl2 = sliderCtl(); addChild(sliderCtl2); sliderCtl2->retain(); sliderCtl2->setPosition(Vec2(s.width / 4.0f * 3.0f, VisibleRect::top().y - 20)); } TwoSchedulers::~TwoSchedulers() { auto defaultScheduler = Director::getInstance()->getScheduler(); defaultScheduler->unscheduleAllForTarget(sched1); defaultScheduler->unscheduleAllForTarget(sched2); sliderCtl1->release(); sliderCtl2->release(); sched1->release(); sched2->release(); actionManager1->release(); actionManager2->release(); } std::string TwoSchedulers::title() const { return "Two custom schedulers"; } std::string TwoSchedulers::subtitle() const { return "Three schedulers. 2 custom + 1 default. Two different time scales"; } // SchedulerIssue2268 class TestNode2 : public Node { public: CREATE_FUNC(TestNode2); ~TestNode2() { axis::log("Delete TestNode (should not crash)"); this->unscheduleAllCallbacks(); } void update(float /*dt*/) {} }; void SchedulerIssue2268::onEnter() { SchedulerTestLayer::onEnter(); testNode = TestNode2::create(); testNode->retain(); testNode->schedule(SEL_SCHEDULE(&TestNode::update)); this->addChild(testNode); this->scheduleOnce(SEL_SCHEDULE(&SchedulerIssue2268::update), 0.25f); } void SchedulerIssue2268::update(float /*dt*/) { if (testNode != nullptr) { // do something with testNode // at some point we are done, pause the nodes actions and schedulers testNode->removeFromParentAndCleanup(false); // at some other point we are completely done with the node and want to clear it testNode->unscheduleAllCallbacks(); testNode->release(); testNode = nullptr; } } SchedulerIssue2268::~SchedulerIssue2268() { AX_SAFE_RELEASE(testNode); } std::string SchedulerIssue2268::title() const { return "Issue #2268"; } std::string SchedulerIssue2268::subtitle() const { return "Should not crash"; } // SchedulerIssueWithReschedule // https://github.com/cocos2d/cocos2d-x/pull/17706 void SchedulerIssueWithReschedule::onEnter() { SchedulerTestLayer::onEnter(); Size widgetSize = getContentSize(); auto status_text = Text::create("Checking..", "fonts/Marker Felt.ttf", 18); status_text->setColor(Color3B(255, 255, 255)); status_text->setPosition(Vec2(widgetSize.width / 2.0f, widgetSize.height / 2.0f)); addChild(status_text); // schedule(callback, target, interval, repeat, delay, paused, key); auto verified = std::make_shared(); *verified = false; _scheduler->schedule( [this, verified](float dt) { log("SchedulerIssueWithReschedule - first timer"); _scheduler->schedule( [verified](float dt) { log("SchedulerIssueWithReschedule - second timer. OK"); *verified = true; }, this, 0.1f, 0, 0, false, "test_timer"); }, this, 0.1f, 0, 0, false, "test_timer"); _scheduler->schedule( [verified, status_text](float dt) { if (*verified) { log("SchedulerIssueWithReschedule - test OK"); status_text->setString("OK"); status_text->setColor(Color3B(0, 255, 0)); } else { log("SchedulerIssueWithReschedule - test failed!"); status_text->setString("Failed"); status_text->setColor(Color3B(255, 0, 0)); } }, this, 0.5f, 0, 0, false, "test_verify_timer"); } std::string SchedulerIssueWithReschedule::title() const { return "Issue with reschedule"; } std::string SchedulerIssueWithReschedule::subtitle() const { return "reschedule issue with same key"; } // ScheduleCallbackTest ScheduleCallbackTest::~ScheduleCallbackTest() {} std::string ScheduleCallbackTest::title() const { return "ScheduleCallbackTest"; } std::string ScheduleCallbackTest::subtitle() const { return "\n\n\n\nPlease see console.\n\ schedule(lambda, ...)\n\ schedule(AX_CALLBACK_1(XXX::member_function), this), this, ...)\n\ schedule(global_function, ...)\n\ "; } static void ScheduleCallbackTest_global_callback(float dt) { log("In the callback of schedule(global_function, ...), dt = %f", dt); } void ScheduleCallbackTest::onEnter() { SchedulerTestLayer::onEnter(); _scheduler->schedule([](float dt) { log("In the callback of schedule(lambda, ...), dt = %f", dt); }, this, 1.0f, false, "lambda"); _scheduler->schedule(AX_CALLBACK_1(ScheduleCallbackTest::callback, this), this, 1.0f, false, "member_function"); _scheduler->schedule(ScheduleCallbackTest_global_callback, this, 1.0f, false, "global_function"); } void ScheduleCallbackTest::callback(float dt) { log("In the callback of schedule(AX_CALLBACK_1(XXX::member_function), this), this, ...), dt = %f", dt); } // ScheduleUpdatePriority std::string ScheduleUpdatePriority::title() const { return "ScheduleUpdatePriorityTest"; } std::string ScheduleUpdatePriority::subtitle() const { return "click to change update priority with random value"; } bool ScheduleUpdatePriority::onTouchBegan(Touch* /*touch*/, Event* /*event*/) { int priority = static_cast(AXRANDOM_0_1() * 11) - 5; // -5 ~ 5 AXLOG("change update priority to %d", priority); scheduleUpdateWithPriority(priority); return true; } void ScheduleUpdatePriority::onEnter() { SchedulerTestLayer::onEnter(); scheduleUpdate(); auto listener = EventListenerTouchOneByOne::create(); listener->onTouchBegan = AX_CALLBACK_2(ScheduleUpdatePriority::onTouchBegan, this); _eventDispatcher->addEventListenerWithSceneGraphPriority(listener, this); } void ScheduleUpdatePriority::onExit() { Node::onExit(); unscheduleUpdate(); } void ScheduleUpdatePriority::update(float /*dt*/) {} void SchedulerIssue10232::onEnter() { SchedulerTestLayer::onEnter(); this->scheduleOnce(SEL_SCHEDULE(&SchedulerIssue2268::update), 0.25f); this->scheduleOnce([](float /*dt*/) { log("SchedulerIssue10232:Schedules a lambda function"); }, 0.25f, "SchedulerIssue10232"); } void SchedulerIssue10232::update(float /*dt*/) { log("SchedulerIssue10232:Schedules a selector"); } std::string SchedulerIssue10232::title() const { return "Issue #10232"; } std::string SchedulerIssue10232::subtitle() const { return "Should not crash"; } void SchedulerRemoveAllFunctionsToBePerformedInCocosThread::onEnter() { SchedulerTestLayer::onEnter(); _sprite = Sprite::create("Images/grossinis_sister1.png"); _sprite->setPosition(VisibleRect::center()); this->addChild(_sprite); this->scheduleUpdate(); } void SchedulerRemoveAllFunctionsToBePerformedInCocosThread::onExit() { SchedulerTestLayer::onExit(); this->unscheduleUpdate(); } void SchedulerRemoveAllFunctionsToBePerformedInCocosThread::update(float dt) { Director::getInstance()->getScheduler()->performFunctionInCocosThread([this]() { _sprite->setVisible(false); }); Director::getInstance()->getScheduler()->performFunctionInCocosThread([this]() { _sprite->setVisible(false); }); Director::getInstance()->getScheduler()->performFunctionInCocosThread([this]() { _sprite->setVisible(false); }); Director::getInstance()->getScheduler()->performFunctionInCocosThread([this]() { _sprite->setVisible(false); }); Director::getInstance()->getScheduler()->performFunctionInCocosThread([this]() { _sprite->setVisible(false); }); if (!TestController::getInstance()->isAutoTestRunning()) Director::getInstance()->getScheduler()->removeAllFunctionsToBePerformedInCocosThread(); } std::string SchedulerRemoveAllFunctionsToBePerformedInCocosThread::title() const { return "Removing pending main thread tasks"; } std::string SchedulerRemoveAllFunctionsToBePerformedInCocosThread::subtitle() const { return "Sprite should be visible"; } // class SchedulerIssue17149: public SchedulerTestLayer //{ // public: // CREATE_FUNC(SchedulerIssue17149); // // virtual std::string title() const override; // void onEnter() override; // void update(float dt) override; // // private: // class ClassA // { // public: // void update(float dt); // // int _member1; // int _member2; // int _member3; // }; // // class ClassB // { // void update(float dt); // int _member1; // int _member2; // int _member3; // }; // }; // SchedulerIssue17149: https://github.com/cocos2d/cocos2d-x/issues/17149 SchedulerIssue17149::SchedulerIssue17149() { _memoryPool = malloc(2018); } SchedulerIssue17149::~SchedulerIssue17149() { free(_memoryPool); } std::string SchedulerIssue17149::title() const { return "Issue #17149"; } std::string SchedulerIssue17149::subtitle() const { return "see console, result should be 'i'm ClassB: 456'"; } void SchedulerIssue17149::onEnter() { SchedulerTestLayer::onEnter(); scheduleUpdate(); } void SchedulerIssue17149::update(float dt) { auto classa = new (_memoryPool) ClassA(); AXLOG("Address one: %p", classa); Director::getInstance()->getScheduler()->scheduleUpdate(classa, 1, false); Director::getInstance()->getScheduler()->unscheduleUpdate(classa); auto classb = new (_memoryPool) ClassB(); AXLOG("Address one: %p", classb); Director::getInstance()->getScheduler()->scheduleUpdate(classb, 1, false); unscheduleUpdate(); } SchedulerIssue17149::ClassA::ClassA() : _member1(1), _member2(2), _member3(3) {} void SchedulerIssue17149::ClassA::update(float dt) { AXLOG("i'm ClassA: %d%d%d", _member1, _member2, _member3); } SchedulerIssue17149::ClassB::ClassB() : _member1(4), _member2(5), _member3(6) {} void SchedulerIssue17149::ClassB::update(float dt) { AXLOG("i'm ClassB: %d%d%d", _member1, _member2, _member3); Director::getInstance()->getScheduler()->unscheduleUpdate(this); } //------------------------------------------------------------------ // // SchedulerRemoveEntryWhileUpdate // //------------------------------------------------------------------ std::string SchedulerRemoveEntryWhileUpdate::title() const { return "RemoveEntryWhileUpdate"; } std::string SchedulerRemoveEntryWhileUpdate::subtitle() const { return "see console, error message must not be shown."; } void SchedulerRemoveEntryWhileUpdate::onEnter() { SchedulerTestLayer::onEnter(); for (auto i = 0; i < 500; ++i) { TestClass* nextObj = nullptr; if (i != 0) { nextObj = _testvector[i - 1]; } auto obj = new TestClass(i, nextObj, getScheduler()); _testvector.push_back(obj); getScheduler()->scheduleUpdate(obj, 500 - i, false); } } void SchedulerRemoveEntryWhileUpdate::onExit() { for (auto obj : _testvector) { getScheduler()->unscheduleUpdate(obj); delete obj; } _testvector.clear(); SchedulerTestLayer::onExit(); } SchedulerRemoveEntryWhileUpdate::TestClass::TestClass(int index, TestClass* nextObj, axis::Scheduler* scheduler) : _nextObj(nextObj), _index(index), _scheduler(scheduler) {} void SchedulerRemoveEntryWhileUpdate::TestClass::update(float dt) { if (_cleanedUp) { AXLOG("Error: cleaned object must not be called."); return; } if (_index % 50 == 1 && _nextObj != nullptr) { _scheduler->unscheduleUpdate(_nextObj); _nextObj->_cleanedUp = true; } } //------------------------------------------------------------------ // // SchedulerRemoveSelectorDuringCall // //------------------------------------------------------------------ std::string SchedulerRemoveSelectorDuringCall::title() const { return "RemoveSelectorDuringCall"; } std::string SchedulerRemoveSelectorDuringCall::subtitle() const { return "see console, error message must not be shown."; } void SchedulerRemoveSelectorDuringCall::onEnter() { SchedulerTestLayer::onEnter(); Scheduler* const scheduler(Director::getInstance()->getScheduler()); scheduler->setTimeScale(10); scheduler->schedule(SEL_SCHEDULE(&SchedulerRemoveSelectorDuringCall::callback), this, 0.01f, AX_REPEAT_FOREVER, 0.0f, !isRunning()); _scheduled = true; } void SchedulerRemoveSelectorDuringCall::onExit() { Scheduler* const scheduler(Director::getInstance()->getScheduler()); scheduler->setTimeScale(1); scheduler->unschedule(SEL_SCHEDULE(&SchedulerRemoveSelectorDuringCall::callback), this); _scheduled = false; SchedulerTestLayer::onExit(); } void SchedulerRemoveSelectorDuringCall::callback(float) { if (!_scheduled) { axis::log("Error: unscheduled callback must not be called."); return; } _scheduled = false; Scheduler* const scheduler(Director::getInstance()->getScheduler()); scheduler->unschedule(SEL_SCHEDULE(&SchedulerRemoveSelectorDuringCall::callback), this); }