qos_queue_ksync.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
 */
 
#include <base/logging.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/ksync_init.h>
#include "vrouter/ksync/qos_queue_ksync.h"
 
QosQueueKSyncEntry::QosQueueKSyncEntry(QosQueueKSyncObject *obj,
                                      const QosQueueKSyncEntry *qos_queue):
    KSyncNetlinkDBEntry(), ksync_obj_(obj), id_(qos_queue->id()) {
}
 
QosQueueKSyncEntry::QosQueueKSyncEntry(QosQueueKSyncObject *obj,
                                       const QosQueue *qos_queue):
    KSyncNetlinkDBEntry(), ksync_obj_(obj), id_(qos_queue->id()) {
}
 
QosQueueKSyncEntry::QosQueueKSyncEntry(QosQueueKSyncObject *obj,
                                       uint32_t id):
    KSyncNetlinkDBEntry(), ksync_obj_(obj), id_(id) {
}
 
QosQueueKSyncEntry::~QosQueueKSyncEntry() {
}
 
KSyncDBObject *QosQueueKSyncEntry::GetObject() const {
    return ksync_obj_;
}
 
bool QosQueueKSyncEntry::IsLess(const KSyncEntry &rhs) const {
    const QosQueueKSyncEntry &entry = static_cast<const QosQueueKSyncEntry &>(rhs);
    return id_ < entry.id_;
}
 
std::string QosQueueKSyncEntry::ToString() const {
 
    std::stringstream s;
    s << "Qos Queue id " << id_;
    return s.str();
}
 
bool QosQueueKSyncEntry::Sync(DBEntry *e) {
    return false;
}
 
int QosQueueKSyncEntry::Encode(sandesh_op::type op, char *buf, int buf_len) {
    return 0;
}
 
int QosQueueKSyncEntry::AddMsg(char *buf, int buf_len) {
    return Encode(sandesh_op::ADD, buf, buf_len);
}
 
int QosQueueKSyncEntry::ChangeMsg(char *buf, int buf_len) {
    return Encode(sandesh_op::ADD, buf, buf_len);
}
 
int QosQueueKSyncEntry::DeleteMsg(char *buf, int buf_len) {
    return Encode(sandesh_op::DEL, buf, buf_len);
}
 
KSyncEntry *QosQueueKSyncEntry::UnresolvedReference() {
    return NULL;
}
 
QosQueueKSyncObject::QosQueueKSyncObject(KSync *ksync):
    KSyncDBObject("KSync Qos Queue Object"), ksync_(ksync) {
}
 
QosQueueKSyncObject::~QosQueueKSyncObject() {
 
}
 
void QosQueueKSyncObject::RegisterDBClients() {
    RegisterDb(ksync_->agent()->qos_queue_table());
}
 
KSyncEntry*
QosQueueKSyncObject::Alloc(const KSyncEntry *e, uint32_t index) {
    const QosQueueKSyncEntry *entry = static_cast<const QosQueueKSyncEntry *>(e);
    QosQueueKSyncEntry *new_entry = new QosQueueKSyncEntry(this, entry);
    return static_cast<KSyncEntry *>(new_entry);
}
 
KSyncEntry *QosQueueKSyncObject::DBToKSyncEntry(const DBEntry *e) {
    const QosQueue *qos_queue = static_cast<const QosQueue *>(e);
    QosQueueKSyncEntry *entry = new QosQueueKSyncEntry(this, qos_queue);
    return static_cast<KSyncEntry *>(entry);
}