CQoSMan Class Reference

class CQoSMan : public CActive

Inherits from

Public Member Functions
~CQoSMan()
voidClearPendingRequest(CQoSRequestBase *)
voidClose()
voidCreateL(CChannel &, const TQoSSelector &)
CPolicy *FindPolicy(const TQoSSelector &)
voidJoinL(CChannel &, const TQoSSelector &)
voidLeaveL(CChannel &, const TQoSSelector &)
CQoSMan *NewL(TInt)
voidOpen()
voidOpenExistingL(CChannel &, const TQoSSelector &)
CChannel *OpenQoSChannelL(RSocket &)
CPolicy *OpenQoSPolicyL(const TQoSSelector &)
voidRemoveQoSChannel(CChannel *)
voidRemoveQoSPolicy(CPolicy *)
voidSend(CRequest *)
voidSetQoSL(CChannel &)
RSocket &Socket()
const TCheckedUid &Uid()
Protected Member Functions
CQoSMan(TInt)
voidConstructL()
Private Member Functions
voidDoCancel()
voidExecEvent(TPfqosMessage &)
voidExecReply(TPfqosMessage &)
voidFlush()
CChannel *Match(TPfqosMessage &)
CChannel *MatchChannelReply(TPfqosMessage &, TUint8)
CPolicy *MatchPolicyReply(TPfqosMessage &, TUint8)
voidNotify(TPfqosMessage &)
voidRunL()
Inherited Functions
CActive::CActive(TInt)
CActive::Cancel()
CActive::Deque()
CActive::Extension_(TUint,TAny *&,TAny *)
CActive::IsActive()const
CActive::IsAdded()const
CActive::Priority()const
CActive::RunError(TInt)
CActive::SetActive()
CActive::SetPriority(TInt)
CActive::~CActive()
CBase::CBase()
CBase::Delete(CBase *)
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()
Inherited Enumerations
CActive:TPriority
Private Attributes
HBufC8 *iBuf
TSglQue< CChannel >iChannels
TBool iNotifyPending
TPtr8 iRecBuf
TInt iRefCount
CSender *iSender
TBool iShutdown
RSocket iSocket
RSocketServ iSocketServer
TSglQue< CPolicy >iStaticPolicies
TCheckedUid iUid
Inherited Attributes
CActive::iStatus

Constructor & Destructor Documentation

CQoSMan(TInt)

CQoSMan(TIntaPriority = 0)[protected]

Parameters

TInt aPriority = 0

~CQoSMan()

~CQoSMan()

Member Functions Documentation

ClearPendingRequest(CQoSRequestBase *)

voidClearPendingRequest(CQoSRequestBase *aRequest)

Parameters

CQoSRequestBase * aRequest

Close()

voidClose()

ConstructL()

voidConstructL()[protected]

CreateL(CChannel &, const TQoSSelector &)

voidCreateL(CChannel &aChannel,
const TQoSSelector &aSelector
)

Parameters

CChannel & aChannel
const TQoSSelector & aSelector

DoCancel()

voidDoCancel()[private, virtual]

Implements cancellation of an outstanding request.

This function is called as part of the active object's Cancel().

It must call the appropriate cancel function offered by the active object's asynchronous service provider. The asynchronous service provider's cancel is expected to act immediately.

DoCancel() must not wait for event completion; this is handled by Cancel().

CActive::Cancel

ExecEvent(TPfqosMessage &)

voidExecEvent(TPfqosMessage &aMsg)[private]

Parameters

TPfqosMessage & aMsg

ExecReply(TPfqosMessage &)

voidExecReply(TPfqosMessage &aMsg)[private]

Parameters

TPfqosMessage & aMsg

FindPolicy(const TQoSSelector &)

CPolicy *FindPolicy(const TQoSSelector &aSelector)

Parameters

const TQoSSelector & aSelector

Flush()

voidFlush()[private]

JoinL(CChannel &, const TQoSSelector &)

voidJoinL(CChannel &aChannel,
const TQoSSelector &aSelector
)

Parameters

CChannel & aChannel
const TQoSSelector & aSelector

LeaveL(CChannel &, const TQoSSelector &)

voidLeaveL(CChannel &aChannel,
const TQoSSelector &aSelector
)

Parameters

CChannel & aChannel
const TQoSSelector & aSelector

Match(TPfqosMessage &)

CChannel *Match(TPfqosMessage &aMsg)[private]

Parameters

TPfqosMessage & aMsg

MatchChannelReply(TPfqosMessage &, TUint8)

CChannel *MatchChannelReply(TPfqosMessage &aMsg,
TUint8aMsgType
)[private]

Parameters

TPfqosMessage & aMsg
TUint8 aMsgType

MatchPolicyReply(TPfqosMessage &, TUint8)

CPolicy *MatchPolicyReply(TPfqosMessage &aMsg,
TUint8aMsgType
)[private]

Parameters

TPfqosMessage & aMsg
TUint8 aMsgType

NewL(TInt)

CQoSMan *NewL(TIntaPriority = 0)[static]

Parameters

TInt aPriority = 0

Notify(TPfqosMessage &)

voidNotify(TPfqosMessage &aMsg)[private]

Parameters

TPfqosMessage & aMsg

Open()

voidOpen()[inline]

OpenExistingL(CChannel &, const TQoSSelector &)

voidOpenExistingL(CChannel &aChannel,
const TQoSSelector &aSelector
)

Parameters

CChannel & aChannel
const TQoSSelector & aSelector

OpenQoSChannelL(RSocket &)

CChannel *OpenQoSChannelL(RSocket &aSocket)

Parameters

RSocket & aSocket

OpenQoSPolicyL(const TQoSSelector &)

CPolicy *OpenQoSPolicyL(const TQoSSelector &aSelector)

Parameters

const TQoSSelector & aSelector

RemoveQoSChannel(CChannel *)

voidRemoveQoSChannel(CChannel *aChannel)

Parameters

CChannel * aChannel

RemoveQoSPolicy(CPolicy *)

voidRemoveQoSPolicy(CPolicy *aChannel)

Parameters

CPolicy * aChannel

RunL()

voidRunL()[private, virtual]

Handles an active object's request completion event.

A derived class must provide an implementation to handle the completed request. If appropriate, it may issue another request.

The function is called by the active scheduler when a request completion event occurs, i.e. after the active scheduler's WaitForAnyRequest() function completes.

Before calling this active object's RunL() function, the active scheduler has:

1. decided that this is the highest priority active object with a completed request

2. marked this active object's request as complete (i.e. the request is no longer outstanding)

RunL() runs under a trap harness in the active scheduler. If it leaves, then the active scheduler calls RunError() to handle the leave.

Note that once the active scheduler's Start() function has been called, all user code is run under one of the program's active object's RunL() or RunError() functions.

CActiveScheduler::Start CActiveScheduler::Error CActiveScheduler::WaitForAnyRequest TRAPD

Send(CRequest *)

voidSend(CRequest *aRequest)

Parameters

CRequest * aRequest

SetQoSL(CChannel &)

voidSetQoSL(CChannel &aChannel)

Parameters

CChannel & aChannel

Socket()

RSocket &Socket()[inline]

Uid()

const TCheckedUid &Uid()const [inline]

Member Data Documentation

HBufC8 * iBuf

HBufC8 *iBuf[private]

TSglQue< CChannel > iChannels

TSglQue< CChannel >iChannels[private]

TBool iNotifyPending

TBool iNotifyPending[private]

TPtr8 iRecBuf

TPtr8 iRecBuf[private]

TInt iRefCount

TInt iRefCount[private]

CSender * iSender

CSender *iSender[private]

TBool iShutdown

TBool iShutdown[private]

RSocket iSocket

RSocket iSocket[private]

RSocketServ iSocketServer

RSocketServ iSocketServer[private]

TSglQue< CPolicy > iStaticPolicies

TSglQue< CPolicy >iStaticPolicies[private]

TCheckedUid iUid

TCheckedUid iUid[private]