CContentionManager Class Reference

class CContentionManager : public CBase

Inherits from

Public Member Functions
CContentionManager(const ESock::CTierManagerBase &)
~CContentionManager()
IMPORT_C TBoolHandleContentionL(ESock::CMetaConnectionProviderBase *, Messages::TNodeId &, TUint)
IMPORT_C TBoolIsUnavailableDueToContention(const ESock::CMetaConnectionProviderBase *)
Protected Member Functions
IMPORT_C voidContentionResolved()
Private Member Functions
voidAddNewContentionRequestItemL(ESock::CMetaConnectionProviderBase *, const Messages::TNodeId &, TUint)
TBool CheckContentionCondition(TUint)
voidContentionOccured(ESock::CMetaConnectionProviderBase &)
voidContentionResolved(const TContentionRequestItem &, TBool)
TInt FindStartedClientWithMinimalPriority(Messages::TNodeId &, TUint &)
TInt GetMostPrioritizedContentionRequestIndex()
voidRejectAllContentionRequests()
voidRejectRequestsWithPriorityLowerThan(TUint)
voidRemoveContentionRequest(TInt)
voidReportContentionAvailabilityStatus(ESock::CMetaConnectionProviderBase &, const ESock::TAvailabilityStatus &)
voidResolveContention()
voidSendAvailabilityNotifications(const ESock::TAvailabilityStatus &)
voidUpdateContentionRequestsPriorities()
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_CCContentionManager(const ESock::CTierManagerBase &aTierManager)

Parameters

const ESock::CTierManagerBase & aTierManager

~CContentionManager()

IMPORT_C~CContentionManager()

Member Functions Documentation

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

voidAddNewContentionRequestItemL(ESock::CMetaConnectionProviderBase *aMcpr,
const Messages::TNodeId &aPendingCprId,
TUintaPriority
)[private]

Parameters

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

CheckContentionCondition(TUint)

TBool CheckContentionCondition(TUintaPriority)const [private]

Parameters

TUint aPriority

ContentionOccured(ESock::CMetaConnectionProviderBase &)

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

ContentionResolved()

IMPORT_C voidContentionResolved()[protected, virtual]

ContentionResolved(const TContentionRequestItem &, TBool)

voidContentionResolved(const TContentionRequestItem &aContentionRequest,
TBoolaResult
)[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 TBoolHandleContentionL(ESock::CMetaConnectionProviderBase *aMcpr,
Messages::TNodeId &aPendingCprId,
TUintaPriority
)

Parameters

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

IsUnavailableDueToContention(const ESock::CMetaConnectionProviderBase *)

IMPORT_C TBoolIsUnavailableDueToContention(const ESock::CMetaConnectionProviderBase *aMetaConnectionProvider)const

Parameters

const ESock::CMetaConnectionProviderBase * aMetaConnectionProvider

RejectAllContentionRequests()

voidRejectAllContentionRequests()[private]

RejectRequestsWithPriorityLowerThan(TUint)

voidRejectRequestsWithPriorityLowerThan(TUintaPriority)[private]

Parameters

TUint aPriority

RemoveContentionRequest(TInt)

voidRemoveContentionRequest(TIntaIndex)[private]

Parameters

TInt aIndex

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

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

ResolveContention()

voidResolveContention()[private]

SendAvailabilityNotifications(const ESock::TAvailabilityStatus &)

voidSendAvailabilityNotifications(const ESock::TAvailabilityStatus &aStatus)const [private]

Parameters

const ESock::TAvailabilityStatus & aStatus

UpdateContentionRequestsPriorities()

voidUpdateContentionRequestsPriorities()[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]