CContentionManager Class Reference

class CContentionManager : public CBase

Inherits from

Public Member Functions
CContentionManager (const ESock::CTierManagerBase &)
~CContentionManager ()
IMPORT_C TBool HandleContentionL ( ESock::CMetaConnectionProviderBase *, Messages::TNodeId &, TUint )
IMPORT_C TBool IsUnavailableDueToContention (const ESock::CMetaConnectionProviderBase *)
Protected Member Functions
IMPORT_C void ContentionResolved ()
Private Member Functions
void AddNewContentionRequestItemL ( ESock::CMetaConnectionProviderBase *, const Messages::TNodeId &, TUint )
TBool CheckContentionCondition ( TUint )
void ContentionOccured ( ESock::CMetaConnectionProviderBase &)
void ContentionResolved (const TContentionRequestItem &, TBool )
TInt FindStartedClientWithMinimalPriority ( Messages::TNodeId &, TUint &)
TInt GetMostPrioritizedContentionRequestIndex ()
void RejectAllContentionRequests ()
void RejectRequestsWithPriorityLowerThan ( TUint )
void RemoveContentionRequest ( TInt )
void ReportContentionAvailabilityStatus ( ESock::CMetaConnectionProviderBase &, const ESock::TAvailabilityStatus &)
void ResolveContention ()
void SendAvailabilityNotifications (const ESock::TAvailabilityStatus &)
void UpdateContentionRequestsPriorities ()
Inherited Functions
CBase::CBase()
CBase::Delete(CBase *)
CBase::Extension_(TUint,TAny *&,TAny *)
CBase::operator new(TUint)
CBase::operator new(TUint,TAny *)
CBase::operator new(TUint,TLeave)
CBase::operator new(TUint,TLeave,TUint)
CBase::operator new(TUint,TUint)
CBase::~CBase()
Private Attributes
RPointerArray < TContentionRequestItem > iContentionRequests
TBool iHaveFreeResources
TBool iResolvingContention
Messages::TNodeId iStoppingCprId
const ESock::CTierManagerBase & iTierManager

Constructor & Destructor Documentation

CContentionManager(const ESock::CTierManagerBase &)

IMPORT_C CContentionManager ( const ESock::CTierManagerBase & aTierManager )

Parameters

const ESock::CTierManagerBase & aTierManager

~CContentionManager()

IMPORT_C ~CContentionManager ( )

Member Functions Documentation

AddNewContentionRequestItemL(ESock::CMetaConnectionProviderBase *, const Messages::TNodeId &, TUint)

void AddNewContentionRequestItemL ( ESock::CMetaConnectionProviderBase * aMcpr,
const Messages::TNodeId & aPendingCprId,
TUint aPriority
) [private]

Parameters

ESock::CMetaConnectionProviderBase * aMcpr
const Messages::TNodeId & aPendingCprId
TUint aPriority

CheckContentionCondition(TUint)

TBool CheckContentionCondition ( TUint aPriority ) const [private]

Parameters

TUint aPriority

ContentionOccured(ESock::CMetaConnectionProviderBase &)

void ContentionOccured ( ESock::CMetaConnectionProviderBase & aMcpr ) [private, virtual]

ContentionResolved()

IMPORT_C void ContentionResolved ( ) [protected, virtual]

ContentionResolved(const TContentionRequestItem &, TBool)

void ContentionResolved ( const TContentionRequestItem & aContentionRequest,
TBool aResult
) [private, virtual]

Parameters

const TContentionRequestItem & aContentionRequest
TBool aResult

FindStartedClientWithMinimalPriority(Messages::TNodeId &, TUint &)

TInt FindStartedClientWithMinimalPriority ( Messages::TNodeId & aCprId,
TUint & aMinimalPriority
) const [private]

Parameters

Messages::TNodeId & aCprId
TUint & aMinimalPriority

GetMostPrioritizedContentionRequestIndex()

TInt GetMostPrioritizedContentionRequestIndex ( ) [private]

HandleContentionL(ESock::CMetaConnectionProviderBase *, Messages::TNodeId &, TUint)

IMPORT_C TBool HandleContentionL ( ESock::CMetaConnectionProviderBase * aMcpr,
Messages::TNodeId & aPendingCprId,
TUint aPriority
)

Parameters

ESock::CMetaConnectionProviderBase * aMcpr
Messages::TNodeId & aPendingCprId
TUint aPriority

IsUnavailableDueToContention(const ESock::CMetaConnectionProviderBase *)

IMPORT_C TBool IsUnavailableDueToContention ( const ESock::CMetaConnectionProviderBase * aMetaConnectionProvider ) const

Parameters

const ESock::CMetaConnectionProviderBase * aMetaConnectionProvider

RejectAllContentionRequests()

void RejectAllContentionRequests ( ) [private]

RejectRequestsWithPriorityLowerThan(TUint)

void RejectRequestsWithPriorityLowerThan ( TUint aPriority ) [private]

Parameters

TUint aPriority

RemoveContentionRequest(TInt)

void RemoveContentionRequest ( TInt aIndex ) [private]

Parameters

TInt aIndex

ReportContentionAvailabilityStatus(ESock::CMetaConnectionProviderBase &, const ESock::TAvailabilityStatus &)

void ReportContentionAvailabilityStatus ( ESock::CMetaConnectionProviderBase & aMcpr,
const ESock::TAvailabilityStatus & aStatus
) const [private, virtual]

ResolveContention()

void ResolveContention ( ) [private]

SendAvailabilityNotifications(const ESock::TAvailabilityStatus &)

void SendAvailabilityNotifications ( const ESock::TAvailabilityStatus & aStatus ) const [private]

Parameters

const ESock::TAvailabilityStatus & aStatus

UpdateContentionRequestsPriorities()

void UpdateContentionRequestsPriorities ( ) [private]

Member Data Documentation

RPointerArray< TContentionRequestItem > iContentionRequests

RPointerArray < TContentionRequestItem > iContentionRequests [private]

TBool iHaveFreeResources

TBool iHaveFreeResources [private]

TBool iResolvingContention

TBool iResolvingContention [private]

Messages::TNodeId iStoppingCprId

Messages::TNodeId iStoppingCprId [private]

const ESock::CTierManagerBase & iTierManager

const ESock::CTierManagerBase & iTierManager [private]