OpenSDN source code
|
#include <forwarding_class.h>
Public Member Functions | |
ForwardingClassTable (Agent *agent, DB *db, const std::string &name) | |
virtual | ~ForwardingClassTable () |
virtual std::unique_ptr< DBEntry > | AllocEntry (const DBRequestKey *k) const |
virtual size_t | Hash (const DBEntry *entry) const |
virtual size_t | Hash (const DBRequestKey *key) const |
virtual DBEntry * | OperDBAdd (const DBRequest *req) |
virtual bool | OperDBOnChange (DBEntry *entry, const DBRequest *req) |
virtual bool | OperDBDelete (DBEntry *entry, const DBRequest *req) |
virtual bool | OperDBResync (DBEntry *entry, const DBRequest *req) |
virtual bool | IFNodeToReq (IFMapNode *node, DBRequest &req, const boost::uuids::uuid &u) |
virtual bool | IFNodeToUuid (IFMapNode *node, boost::uuids::uuid &u) |
virtual bool | ProcessConfig (IFMapNode *node, DBRequest &req, const boost::uuids::uuid &u) |
virtual AgentSandeshPtr | GetAgentSandesh (const AgentSandeshArguments *args, const std::string &context) |
ForwardingClassData * | BuildData (IFMapNode *node) |
![]() | |
AgentOperDBTable (DB *db, const std::string &name) | |
AgentOperDBTable (DB *db, const std::string &name, bool del_on_zero_refcount) | |
virtual | ~AgentOperDBTable () |
virtual void | ConfigEventHandler (IFMapNode *node, DBEntry *entry) |
![]() | |
AgentDBTable (DB *db, const std::string &name) | |
AgentDBTable (DB *db, const std::string &name, bool del_on_zero_refcount) | |
virtual | ~AgentDBTable () |
virtual int | PartitionCount () const |
virtual void | Input (DBTablePartition *root, DBClient *client, DBRequest *req) |
virtual DBEntry * | CfgAdd (DBRequest *req) |
virtual void | Clear () |
virtual bool | IFLinkToReq (IFMapLink *link, IFMapNode *node, const std::string &peer_name, IFMapNode *peer, DBRequest &req) |
virtual DBTablePartition * | AllocPartition (int index) |
virtual void | OnZeroRefcount (AgentDBEntry *e) |
virtual void | NotifyEntry (DBEntryBase *entry) |
void | Notify (DBTablePartBase *partition, DBEntryBase *entry) |
DBTableBase::ListenerId | GetRefListenerId () const |
AgentDBEntry * | FindActiveEntry (const DBEntry *key) |
AgentDBEntry * | FindActiveEntryNoLock (const DBEntry *key) |
AgentDBEntry * | FindActiveEntry (const DBRequestKey *key) |
AgentDBEntry * | FindActiveEntryNoLock (const DBRequestKey *key) |
AgentDBEntry * | Find (const DBEntry *key, bool ret_del) |
AgentDBEntry * | Find (const DBRequestKey *key, bool ret_del) |
virtual bool | CanNotify (IFMapNode *dbe) |
virtual void | Process (DBRequest &req) |
void | set_agent (Agent *agent) |
Agent * | agent () const |
void | Flush () |
void | reset_flush_walk_ref () |
SandeshTraceBufferPtr | GetOperDBTraceBuf () const |
![]() | |
DBTable (DB *db, const std::string &name) | |
virtual | ~DBTable () |
void | Init () |
void | NotifyAllEntries () |
DBEntry * | Find (const DBEntry *entry) |
const DBEntry * | Find (const DBEntry *entry) const |
DBEntry * | Find (const DBRequestKey *key, int id=-1) |
const DBEntry * | Find (const DBRequestKey *key, int id=-1) const |
DBEntry * | FindNoLock (const DBEntry *entry) |
DBEntry * | FindNoLock (const DBRequestKey *key) |
virtual DBTablePartBase * | GetTablePartition (const DBRequestKey *key) |
virtual const DBTablePartBase * | GetTablePartition (const DBRequestKey *key) const |
virtual DBTablePartBase * | GetTablePartition (const DBEntryBase *entry) |
virtual const DBTablePartBase * | GetTablePartition (const DBEntryBase *entry) const |
virtual DBTablePartBase * | GetTablePartition (const int index) |
virtual const DBTablePartBase * | GetTablePartition (const int index) const |
virtual void | Change (DBEntryBase *entry) |
virtual size_t | Size () const |
DBTableWalkRef | AllocWalker (WalkFn walk_fn, WalkCompleteFn walk_complete) |
void | ReleaseWalker (DBTableWalkRef &walk) |
void | WalkTable (DBTableWalkRef walk) |
void | WalkAgain (DBTableWalkRef walk) |
void | SetWalkIterationToYield (int count) |
int | GetWalkIterationToYield () |
void | SetWalkTaskId (int task_id) |
int | GetWalkerTaskId () |
![]() | |
DBTableBase (DB *db, const std::string &name) | |
virtual | ~DBTableBase () |
bool | Enqueue (DBRequest *req) |
void | EnqueueRemove (DBEntryBase *db_entry) |
virtual void | AddRemoveCallback (const DBEntryBase *entry, bool add) const |
ListenerId | Register (ChangeCallback callback, const std::string &name="unspecified") |
void | Unregister (ListenerId listener) |
void | RunNotify (DBTablePartBase *tpart, DBEntryBase *entry) |
void | AddToDBStateCount (ListenerId listener, int count) |
uint64_t | GetDBStateCount (ListenerId listener) |
bool | empty () const |
virtual void | RetryDelete () |
virtual bool | MayDelete () const |
DB * | database () |
const DB * | database () const |
const std::string & | name () const |
bool | HasListeners () const |
size_t | GetListenerCount () const |
void | FillListeners (std::vector< ShowTableListener > *listeners) const |
uint64_t | enqueue_count () const |
void | incr_enqueue_count () |
void | reset_enqueue_count () |
uint64_t | input_count () const |
void | incr_input_count () |
void | reset_input_count () |
uint64_t | notify_count () const |
void | incr_notify_count () |
void | reset_notify_count () |
bool | HasWalkers () const |
uint64_t | walker_count () const |
void | incr_walker_count () |
uint64_t | decr_walker_count () |
uint64_t | walk_request_count () const |
uint64_t | walk_complete_count () const |
uint64_t | walk_cancel_count () const |
uint64_t | walk_again_count () const |
uint64_t | walk_count () const |
void | incr_walk_request_count () |
void | incr_walk_complete_count () |
void | incr_walk_cancel_count () |
void | incr_walk_again_count () |
void | incr_walk_count () |
Static Public Member Functions | |
static DBTableBase * | CreateTable (Agent *agent, DB *db, const std::string &name) |
![]() | |
static void | DBStateClear (DBTable *table, ListenerId id) |
Static Public Attributes | |
static const uint32_t | kInvalidIndex =0xFF |
![]() | |
static const int | kPartitionCount = 1 |
![]() | |
static const int | kIterationToYield = 256 |
![]() | |
static const int | kInvalidId = -1 |
Private Member Functions | |
DISALLOW_COPY_AND_ASSIGN (ForwardingClassTable) | |
Additional Inherited Members | |
![]() | |
typedef boost::intrusive_ptr < DBTableWalk > | DBTableWalkRef |
typedef boost::function< bool(DBTablePartBase *, DBEntryBase *)> | WalkFn |
typedef boost::function< void(DBTableWalkRef, DBTableBase *)> | WalkCompleteFn |
![]() | |
typedef boost::function< void(DBTablePartBase *, DBEntryBase *)> | ChangeCallback |
typedef int | ListenerId |
![]() | |
void | UpdateIfMapNode (AgentOperDBEntry *entry, IFMapNode *node) |
virtual DBEntry * | Add (const DBRequest *req) |
virtual bool | OnChange (DBEntry *entry, const DBRequest *req) |
virtual bool | Resync (DBEntry *entry, const DBRequest *req) |
virtual bool | Delete (DBEntry *entry, const DBRequest *req) |
Definition at line 101 of file forwarding_class.h.
|
virtual |
Definition at line 123 of file forwarding_class.cc.
|
virtual |
Implements DBTable.
Definition at line 134 of file forwarding_class.cc.
ForwardingClassData * ForwardingClassTable::BuildData | ( | IFMapNode * | node | ) |
|
static |
|
private |
|
virtual |
Reimplemented from AgentDBTable.
Definition at line 230 of file forwarding_class.cc.
|
inlinevirtual |
Reimplemented from DBTable.
Definition at line 112 of file forwarding_class.h.
|
inlinevirtual |
Reimplemented from DBTable.
Definition at line 113 of file forwarding_class.h.
|
virtual |
Reimplemented from AgentDBTable.
Definition at line 162 of file forwarding_class.cc.
|
virtual |
Reimplemented from AgentDBTable.
Definition at line 176 of file forwarding_class.cc.
Implements AgentOperDBTable.
Definition at line 141 of file forwarding_class.cc.
Implements AgentOperDBTable.
Definition at line 158 of file forwarding_class.cc.
Implements AgentOperDBTable.
Definition at line 149 of file forwarding_class.cc.
Reimplemented from AgentOperDBTable.
Definition at line 154 of file forwarding_class.cc.
|
virtual |
Reimplemented from AgentDBTable.
Definition at line 185 of file forwarding_class.cc.
|
static |
Definition at line 105 of file forwarding_class.h.