9 : uve_vn_map_(), agent_(agent), uve_vn_map_mutex_(),
12 timer_last_visited_(
""),
14 (*(agent->event_manager())->io_service(),
59 UveVnMap::iterator prev = it;
106 UveVirtualNetworkAgent uve;
116 UveVirtualNetworkAgentTrace::Send(uve);
128 return it->second.get();
142 UveVirtualNetworkAgent s_vn;
144 s_vn.set_deleted(
true);
158 pair<UveVnMap::iterator, bool> ret;
160 UveVnMap::iterator it = ret.first;
229 UveVirtualNetworkAgent uve;
239 const string &vm_name,
242 vn_uve_entry =
Add(vn);
244 UveVirtualNetworkAgent uve;
251 if (vm_name.length()) {
252 vn_uve_entry->
VmAdd(vm_name);
261 if (vm_port == NULL) {
292 if (state->
vm_name_.compare(vm_name) != 0) {
310 UveVirtualNetworkAgent uve;
static const uint32_t kUveCountPerTimer
uint32_t incremental_interval() const
uint32_t default_interval() const
InterfaceTable * interface_table() const
AgentUveBase * uve() const
static const std::string & NullString()
VnTable * vn_table() const
DBState * GetState(DBTableBase *tbl_base, ListenerId listener) const
void ClearState(DBTableBase *tbl_base, ListenerId listener)
void SetState(DBTableBase *tbl_base, ListenerId listener, DBState *state)
ListenerId Register(ChangeCallback callback, const std::string &name="unspecified")
static const int kInvalidId
void Unregister(ListenerId listener)
static const std::string LinkLocalVn()
static const std::string UnknownVn()
The TaskScheduler keeps track of what tasks are currently schedulable. When a task is enqueued it is ...
static bool DeleteTimer(Timer *Timer)
bool Start(int time, Handler handler, ErrorHandler error_handler=NULL)
bool Reschedule(int time)
const string & GetCfgName() const
const VmEntry * vm() const
const VnEntry * vn() const
const string & GetName() const
void set_deleted(bool value)
void VmAdd(const std::string &vm)
void set_vn(const VnEntry *vn)
void set_renewed(bool value)
void set_add_by_vn_notify(bool val)
void InterfaceAdd(const Interface *intf)
void set_changed(bool val)
bool FrameVnMsg(const VnEntry *vn, UveVirtualNetworkAgent &uve)
void InterfaceDelete(const Interface *intf)
bool FrameVnAclRuleCountMsg(const VnEntry *vn, UveVirtualNetworkAgent *uve)
const VnEntry * vn() const
void VmDelete(const std::string &vm)
DBTableBase::ListenerId vn_listener_id_
virtual void SendVnAceStats(VnUveEntryBase *entry, const VnEntry *vn)
VnUveEntryBase * UveEntryFromVn(const VnEntry *vn)
std::string timer_last_visited_
std::pair< std::string, VnUveEntryPtr > UveVnPair
void InterfaceNotify(DBTablePartBase *partition, DBEntryBase *e)
void MarkChanged(const VnEntry *vn)
void Delete(const std::string &name)
VnUveEntryBase * Add(const VnEntry *vn)
VnUveTableBase(Agent *agent, uint32_t default_intvl)
boost::shared_ptr< VnUveEntryBase > VnUveEntryPtr
void SendDeleteVnMsg(const std::string &vn)
virtual VnUveEntryPtr Allocate()
void SendVnAclRuleCount()
void VnNotify(DBTablePartBase *partition, DBEntryBase *e)
virtual ~VnUveTableBase()
void InterfaceDeleteHandler(const std::string &vm, const std::string &vn, const Interface *intf)
void SendVnMsg(VnUveEntryBase *entry, const VnEntry *vn)
virtual void DispatchVnMsg(const UveVirtualNetworkAgent &uve)
void InterfaceAddHandler(const VnEntry *vn, const Interface *intf, const std::string &vm_name, VnUveInterfaceState *state)
void set_expiry_time(int time)
DBTableBase::ListenerId intf_listener_id_
tbb::mutex uve_vn_map_mutex_