resource_backup.h

Go to the documentation of this file.

/*
 * Copyright (c) 2016 Juniper Networks, Inc. All rights reserved.
 */

#ifndef vnsw_agent_resource_backup_hpp
#define vnsw_agent_resource_backup_hpp


#include "resource_manager/resource_manager.h"
#include "resource_manager/sandesh_map.h"

class Timer;
class ResourceSandeshMaps;
class ResourceManager;
class ResourceTable;
class ResourceData;

class ResourceBackupReq {
public:
    enum Op {
        ADD = 1,
        DEL,
    };

    ResourceBackupReq(ResourceManager::KeyPtr key,
                             ResourceManager::DataPtr data,
                             Op op);
    virtual ~ResourceBackupReq();
    void Process();
    ResourceManager::KeyPtr key() {return key_;}
    ResourceManager::DataPtr data() {return data_;}


private:
    ResourceManager::KeyPtr key_;
    ResourceManager::DataPtr data_;
    Op op_;
    DISALLOW_COPY_AND_ASSIGN(ResourceBackupReq);
};
//Backup manager is to Process the Resource data and store
//it in to a file using Sandesh encoding.
class ResourceBackupManager {
public:
    typedef boost::shared_ptr<ResourceBackupReq> ResourceBackupReqPtr;
    ResourceBackupManager(ResourceManager *mgr);
    virtual ~ResourceBackupManager();

    void Init();
    ResourceSandeshMaps& sandesh_maps();
    static uint32_t ReadResourceDataFromFile(const std::string &file_name,
                                             std::unique_ptr<uint8_t> *buf);

    Agent *agent() {return agent_;}
    ResourceManager *resource_manager() {return resource_manager_;}
    bool WorkQueueBackUpProcess(ResourceBackupReqPtr backup_data);
    void BackupResource(ResourceManager::KeyPtr key,
                        ResourceManager::DataPtr data,
                        ResourceBackupReq::Op op);
    void AuditDone();

private:
    ResourceManager *resource_manager_;
    Agent *agent_;
    ResourceSandeshMaps sandesh_maps_;
    // Work queue to backup the data.
    WorkQueue<ResourceBackupReqPtr> backup_work_queue_;
    EventNotifyHandle::Ptr audit_handle_;
    DISALLOW_COPY_AND_ASSIGN(ResourceBackupManager);
};

#endif