|
version 1.28, 2008/12/16 18:56:46
|
version 1.29, 2009/05/27 05:56:29
|
|
|
|
| PEG_METHOD_EXIT (); | PEG_METHOD_EXIT (); |
| } | } |
| | |
| |
Array<ActiveSubscriptionsTableEntry> |
| |
SubscriptionTable::getAllActiveSubscriptionEntries() |
| |
{ |
| |
PEG_METHOD_ENTER(TRC_INDICATION_SERVICE, |
| |
"SubscriptionTable::getAllActiveSubscriptionEntries"); |
| |
|
| |
Array <ActiveSubscriptionsTableEntry> subscriptionsEntries; |
| |
|
| |
// |
| |
// Iterate through the ActiveSubscriptions table to get all active |
| |
// subscriptions table entries |
| |
// |
| |
|
| |
ReadLock lock(_activeSubscriptionsTableLock); |
| |
|
| |
for (ActiveSubscriptionsTable::Iterator i = |
| |
_activeSubscriptionsTable.start(); i; i++) |
| |
{ |
| |
subscriptionsEntries.append(i.value()); |
| |
} |
| |
|
| |
PEG_METHOD_EXIT(); |
| |
return subscriptionsEntries; |
| |
} |
| |
|
| #ifdef PEGASUS_ENABLE_INDICATION_COUNT | #ifdef PEGASUS_ENABLE_INDICATION_COUNT |
| | |
| void SubscriptionTable::updateMatchedIndicationCounts( | void SubscriptionTable::updateMatchedIndicationCounts( |
|
|
|
| PEG_METHOD_EXIT(); | PEG_METHOD_EXIT(); |
| } | } |
| | |
| Array<ActiveSubscriptionsTableEntry> |
|
| SubscriptionTable::_getAllActiveSubscriptionEntries() |
|
| { |
|
| PEG_METHOD_ENTER(TRC_INDICATION_SERVICE, |
|
| "SubscriptionTable::_getAllActiveSubscriptionEntries"); |
|
| |
|
| Array <ActiveSubscriptionsTableEntry> subscriptionsEntries; |
|
| |
|
| // |
|
| // Iterate through the ActiveSubscriptions table to get all active |
|
| // subscriptions table entries |
|
| // |
|
| |
|
| ReadLock lock(_activeSubscriptionsTableLock); |
|
| |
|
| for (ActiveSubscriptionsTable::Iterator i = |
|
| _activeSubscriptionsTable.start(); i; i++) |
|
| { |
|
| subscriptionsEntries.append(i.value()); |
|
| } |
|
| |
|
| PEG_METHOD_EXIT(); |
|
| return subscriptionsEntries; |
|
| } |
|
| | |
| Array<CIMInstance> | Array<CIMInstance> |
| SubscriptionTable::enumerateSubscriptionIndicationDataInstances() | SubscriptionTable::enumerateSubscriptionIndicationDataInstances() |
|
|
|
| // Get all active subscriptions table entries | // Get all active subscriptions table entries |
| // | // |
| Array<ActiveSubscriptionsTableEntry> activeSubscriptionEntries = | Array<ActiveSubscriptionsTableEntry> activeSubscriptionEntries = |
| _getAllActiveSubscriptionEntries(); |
getAllActiveSubscriptionEntries(); |
| | |
| for (Uint32 i = 0; i < activeSubscriptionEntries.size(); i++) | for (Uint32 i = 0; i < activeSubscriptionEntries.size(); i++) |
| { | { |
|
|
|
| // Get all active subscriptions table entries | // Get all active subscriptions table entries |
| // | // |
| Array<ActiveSubscriptionsTableEntry> activeSubscriptionEntries = | Array<ActiveSubscriptionsTableEntry> activeSubscriptionEntries = |
| _getAllActiveSubscriptionEntries(); |
getAllActiveSubscriptionEntries(); |
| | |
| for (Uint32 i = 0; i < activeSubscriptionEntries.size(); i++) | for (Uint32 i = 0; i < activeSubscriptionEntries.size(); i++) |
| { | { |
Return to
SubscriptionTable.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / IndicationService