axmol/tests/cpp-tests/Source/SchedulerTest/SchedulerTest.cpp

/****************************************************************************
 Copyright (c) 2017-2018 Xiamen Yaji Software Co., Ltd.

 https://axmolengine.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 ax::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<Ref*>(c);
        auto node = static_cast<Node*>(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<ControlSlider*>(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<ControlSlider*>(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()
    {
        ax::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<bool>();
    *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<int>(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()->runOnAxmolThread([this]() { _sprite->setVisible(false); });
    Director::getInstance()->getScheduler()->runOnAxmolThread([this]() { _sprite->setVisible(false); });
    Director::getInstance()->getScheduler()->runOnAxmolThread([this]() { _sprite->setVisible(false); });
    Director::getInstance()->getScheduler()->runOnAxmolThread([this]() { _sprite->setVisible(false); });
    Director::getInstance()->getScheduler()->runOnAxmolThread([this]() { _sprite->setVisible(false); });
    if (!TestController::getInstance()->isAutoTestRunning())
        Director::getInstance()->getScheduler()->removeAllPendingActions();
}

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.emplace_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, ax::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)
    {
        ax::log("Error: unscheduled callback must not be called.");
        return;
    }

    _scheduled = false;

    Scheduler* const scheduler(Director::getInstance()->getScheduler());
    scheduler->unschedule(SEL_SCHEDULE(&SchedulerRemoveSelectorDuringCall::callback), this);
}