sandesh_ksync.h

Go to the documentation of this file.

/*
 * Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
 */
#include "vr_types.h"

#include "vrouter/ksync/agent_ksync_types.h"
#include "ksync/ksync_index.h"
#include "ksync/ksync_entry.h"
#include "ksync/ksync_object.h"
#include "ksync/ksync_netlink.h"
#include "ksync/ksync_sock.h"
#include <vrouter/ksync/flowtable_ksync.h>

class KSyncFlowMemory;

/* Sandesh Context used for processing vr_response and vr_flow_req
 * which is in response to Sandesh Adds/Deletes
 */
class KSyncSandeshContext : public AgentSandeshContext {
public:
    KSyncSandeshContext(KSync *obj) : ksync_(obj) {
        Reset();
    }

    virtual void IfMsgHandler(vr_interface_req *req);
    virtual void NHMsgHandler(vr_nexthop_req *req) {
        assert(0);
    }
    virtual void RouteMsgHandler(vr_route_req *req) {
        assert(0);
    }
    virtual void MplsMsgHandler(vr_mpls_req *req) {
        assert(0);
    }
    virtual void MirrorMsgHandler(vr_mirror_req *req) {
        assert(0);
    }
    virtual void VrfAssignMsgHandler(vr_vrf_assign_req *req) {
        assert(0);
    }
    virtual void VrfMsgHandler(vr_vrf_req *req) {
        assert(0);
    }
    virtual void VrfStatsMsgHandler(vr_vrf_stats_req *req) {
        assert(0);
    }
    virtual void DropStatsMsgHandler(vr_drop_stats_req *req) {
        assert(0);
    }
    virtual void VxLanMsgHandler(vr_vxlan_req *req) {
        assert(0);
    }
    virtual void QosConfigMsgHandler(vr_qos_map_req *req) {
        assert(0);
    }
    virtual void ForwardingClassMsgHandler(vr_fc_map_req *req) {
        assert(0);
    }

    virtual int VrResponseMsgHandler(vr_response *r);
    virtual void FlowTableInfoHandler(vr_flow_table_data *r);
    virtual void BridgeTableInfoHandler(vr_bridge_table_data *r);
    virtual void FlowMsgHandler(vr_flow_req *r);
    virtual void FlowResponseHandler(vr_flow_response *r);
    virtual void VrouterHugePageHandler(vr_hugepage_config *r);
    virtual void VrouterOpsMsgHandler(vrouter_ops *r);

    int response_code() const { return response_code_; }
    int context_marker() const { return context_marker_; }
    void Reset() {
        response_code_ = 0;
        context_marker_ = -1;
    }
private:
    KSync *ksync_;
    int response_code_;
    int context_marker_;
    DISALLOW_COPY_AND_ASSIGN(KSyncSandeshContext);
};