Callback.h

Go to the documentation of this file.

/*
* This file is part of Project SkyFire https://www.projectskyfire.org.
* See LICENSE.md file for Copyright information
*/
 
#ifndef _CALLBACK_H
#define _CALLBACK_H
 
#include "QueryResult.h"
#include "Threading/Future.h"
 
typedef Skyfire::Future<QueryResult> QueryResultFuture;
typedef Skyfire::Future<PreparedQueryResult> PreparedQueryResultFuture;

#define CALLBACK_STAGE_INVALID uint8(-1)
 
template <typename Result, typename ParamType, bool chain = false>
class QueryCallback
{
public:
    QueryCallback() : _param(), _stage(chain ? 0 : CALLBACK_STAGE_INVALID) { }

    void SetFutureResult(Skyfire::Future<Result> value)
    {
        _result = value;
    }
 
    Skyfire::Future<Result> GetFutureResult()
    {
        return _result;
    }
 
    int IsReady()
    {
        return _result.ready();
    }
 
    void GetResult(Result& res)
    {
        _result.get(res);
    }
 
    void FreeResult()
    {
        _result.cancel();
    }
 
    void SetParam(ParamType value)
    {
        _param = value;
    }
 
    ParamType GetParam()
    {
        return _param;
    }

    void ResetStage()
    {
        if (!chain)
            return;
 
        _stage = 0;
    }

    void NextStage()
    {
        if (!chain)
            return;
 
        ++_stage;
    }

    uint8 GetStage()
    {
        return _stage;
    }

    void Reset()
    {
        SetParam(NULL);
        FreeResult();
        ResetStage();
    }
 
private:
    Skyfire::Future<Result> _result;
    ParamType _param;
    uint8 _stage;
    QueryCallback(QueryCallback const& right) = delete;
    QueryCallback& operator=(QueryCallback const& right) = delete;
};
 
template <typename Result, typename ParamType1, typename ParamType2, bool chain = false>
class QueryCallback_2
{
public:
    QueryCallback_2() : _stage(chain ? 0 : CALLBACK_STAGE_INVALID) { }

    void SetFutureResult(Skyfire::Future<Result> value)
    {
        _result = value;
    }
 
    Skyfire::Future<Result> GetFutureResult()
    {
        return _result;
    }
 
    int IsReady()
    {
        return _result.ready();
    }
 
    void GetResult(Result& res)
    {
        _result.get(res);
    }
 
    void FreeResult()
    {
        _result.cancel();
    }
 
    void SetFirstParam(ParamType1 value)
    {
        _param_1 = value;
    }
 
    void SetSecondParam(ParamType2 value)
    {
        _param_2 = value;
    }
 
    ParamType1 GetFirstParam()
    {
        return _param_1;
    }
 
    ParamType2 GetSecondParam()
    {
        return _param_2;
    }

    void ResetStage()
    {
        if (!chain)
            return;
 
        _stage = 0;
    }

    void NextStage()
    {
        if (!chain)
            return;
 
        ++_stage;
    }

    uint8 GetStage()
    {
        return _stage;
    }

    void Reset()
    {
        SetFirstParam(NULL);
        SetSecondParam(NULL);
        FreeResult();
        ResetStage();
    }
 
private:
    Skyfire::Future<Result> _result;
    ParamType1 _param_1;
    ParamType2 _param_2;
    uint8 _stage;
    QueryCallback_2(QueryCallback_2 const& right) = delete;
    QueryCallback_2& operator=(QueryCallback_2 const& right) = delete;
};
 
#endif