BootstrapManager.hpp

Go to the documentation of this file.

#ifndef BOOTSTRAPMANAGER_HPP_
#define BOOTSTRAPMANAGER_HPP_

#include <vector>

#include "kaa/KaaThread.hpp"
#include "kaa/bootstrap/IBootstrapManager.hpp"
#include "kaa/bootstrap/BootstrapTransport.hpp"
#include "kaa/channel/GenericTransportInfo.hpp"
#include "kaa/utils/KaaTimer.hpp"
#include "kaa/IKaaClientContext.hpp"

namespace kaa {

class BootstrapManager : public IBootstrapManager, public boost::noncopyable {
public:
    BootstrapManager(IKaaClientContext &context) : bootstrapTransport_(nullptr), channelManager_(nullptr), context_(context), retryTimer_("BootstrapManager retryTimer") { }
    ~BootstrapManager() { }

    virtual void setFailoverStrategy(IFailoverStrategyPtr strategy);
    virtual void receiveOperationsServerList();
    virtual void useNextOperationsServer(const TransportProtocolId& protocolId);
    virtual void useNextOperationsServerByAccessPointId(std::int32_t id);
    virtual void setTransport(IBootstrapTransport* transport);
    virtual void setChannelManager(IKaaChannelManager* manager);
    virtual void onServerListUpdated(const std::vector<ProtocolMetaData>& operationsServers);

private:
    typedef std::vector<ITransportConnectionInfoPtr> OperationsServers;

    OperationsServers getOPSByAccessPointId(std::int32_t id);
    void              notifyChannelManangerAboutServer(const OperationsServers& servers);

private:
    std::map<TransportProtocolId, OperationsServers > operationServers_;
    std::map<TransportProtocolId, OperationsServers::iterator > lastOperationsServers_;

    BootstrapTransport *bootstrapTransport_;
    IKaaChannelManager *channelManager_;

    IKaaClientContext &context_;

    IFailoverStrategyPtr failoverStrategy_;

    std::unique_ptr<std::int32_t> serverToApply;

    KaaTimer<void ()>        retryTimer_;

    KAA_R_MUTEX_MUTABLE_DECLARE(guard_);
};

}



#endif /* BOOTSTRAPMANAGER_HPP_ */