// Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of "Eclipse Public License v1.0"
// which accompanies this distribution, and is available
// at the URL "http://www.eclipse.org/legal/epl-v10.html".
//
// Initial Contributors:
// Nokia Corporation - initial contribution.
//
// Contributors:
//
// Description:
//
/**
@file
@internalTechnology
*/
#ifndef __SS_NODEMESSAGES_INTERNAL_H__
#define __SS_NODEMESSAGES_INTERNAL_H__
#include <comms-infras/ss_nodemessages.h>
#include <es_enum.h>
#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS
#include <es_enum_partner.h>
#endif
#include <elements/nm_address.h>
#include <elements/nm_messages_base.h>
#include <comms-infras/ss_common.h>
#include <comms-infras/ss_logext.h>
class CSockManData; //must be seen in global namespace before being a friend in ESock namespace
//otherwise silly compiler confused since it interprets friend class as a forward declaration
//for no reason
class CParameterBundleBase;
namespace Messages
{
class RNodeInterface;
}
namespace ESock
{
class MPlatsecApiExt;
class CCommsFactoryBase;
class CMetaConnectionProviderFactoryBase;
struct TFlowParams
/** Conveys attributes of a flow request
*/
{
enum TFlowRequestType
{
EImplicit, EExplicitSubConnection, EExplicitConnection
};
explicit TFlowParams(
TInt aAddrFamily,
TInt aSocketType,
TInt aProtocol,
TInt aFlowRequestType,
TAny* aSessionProxy,
TBool aFlowLoadsProtocol = ETrue
) :
iAddrFamily(aAddrFamily),
iSocketType(aSocketType),
iProtocol(aProtocol),
iFlowRequestType(aFlowRequestType),
iSessionProxy(aSessionProxy),
iFlowLoadsProtocol(aFlowLoadsProtocol) {}
explicit TFlowParams() :
iAddrFamily(NULL), iSocketType(NULL), iProtocol(NULL),
iFlowRequestType(NULL), iSessionProxy(NULL), iFlowLoadsProtocol(ETrue) {}
TInt iAddrFamily;
TInt iProtocol;
TInt iSocketType;
TInt iFlowRequestType;
TAny* iSessionProxy;
TBool iFlowLoadsProtocol;
};
/**
@internalTechnology
Special Meta Type to increase refcount on RMetaExtensionContainers when they are posted.
Relies on fact that one serialisation will occur per post.
*/
NONSHARABLE_CLASS(TMetaExtensionContainerMetaType) : public Meta::MMetaType
{
public:
inline static Meta::MMetaType* NewL(const TAny* aMem, const TAny* aData)
{
return ::new ((TUint8*)aMem) TMetaExtensionContainerMetaType(reinterpret_cast<const RMetaExtensionContainerC*>(aData));
}
inline virtual TInt Load(TPtrC8& aBuffer)
{
TInt len = Length();
if (aBuffer.Length() < len)
{
return KErrArgument;
}
Mem::Copy(const_cast<RMetaExtensionContainerC*>(iData), aBuffer.Ptr(), len);
aBuffer.Set(aBuffer.Ptr()+len, aBuffer.Length()-len); //update pointer
return KErrNone;
}
inline virtual TInt Store(TDes8& aBuffer) const
{
const_cast<RMetaExtensionContainerC*>(iData)->Open();
TInt len = Length();
if (aBuffer.MaxLength() - aBuffer.Length() < len)
{
return KErrOverflow;
}
aBuffer.Append((TUint8*)iData, len);
return KErrNone;
}
inline virtual void Copy(const TAny* aData)
{
Mem::Copy((TAny*)iData, aData, Length());
}
inline virtual TInt Length() const
{
return sizeof(RMetaExtensionContainerC);
}
private:
inline TMetaExtensionContainerMetaType::TMetaExtensionContainerMetaType(const RMetaExtensionContainerC* aData)
: iData(aData)
{
__ASSERT_DEBUG(iData!=NULL, User::Panic(_L("RMECMeta"),KErrArgument));
}
private:
const RMetaExtensionContainerC* iData;
};
//
// Signature classes
//
DECLARE_MESSAGE_SIG_1(SigConnectionInfo, TConnectionInfo, ConnectionInfo)
DECLARE_MESSAGE_SIG_1(SigSubConNotification, CRefCountOwnedSubConNotification*, RefCountOwnedSubConNotification)
DECLARE_MESSAGE_SIG_1(SigPlaneNotification, CRefCountOwnedNotification*, RefCountOwnedNotification)
DECLARE_MESSAGE_SIG_1(SigSubConnOpenedEvent, TSubConnectionOpenedEvent, SubConnectionOpenedEvent)
DECLARE_MESSAGE_SIG_1(SigSubConnClosedEvent, TSubConnectionClosedEvent, SubConnectionClosedEvent)
DECLARE_MESSAGE_SIG_1(SigStateChange, Elements::TStateChange, StateChange)
DECLARE_MESSAGE_SIG_1(SigFlowParams, TFlowParams, FlowParams)
class CConnectionInfo;
DECLARE_MESSAGE_SIG_1(SigConnectionInfoPtr, ESock::CConnectionInfo*, Ptr)
#ifdef SYMBIAN_NETWORKING_UPS
struct TPolicyCheckRequestParams
/**
Parameters passed in a TPolicyCheckRequest message
*/
{
inline TPolicyCheckRequestParams()
{ };
inline TPolicyCheckRequestParams(const TProcessId& aProcessId, const TThreadId& aThreadId, TInt aPlatSecResult,
const TUpsDestinationAddr& aDestinationAddr, const TUpsDestinationAddrType& aDestinationAddrType)
: iProcessId(aProcessId), iThreadId(aThreadId), iPlatSecResult(aPlatSecResult),
iDestinationAddr(aDestinationAddr), iDestinationAddrType(aDestinationAddrType),
iCommsId(Messages::TNodeId::NullId())
{ };
inline TPolicyCheckRequestParams(const TProcessId& aProcessId, const TThreadId& aThreadId, TInt aPlatSecResult,
const TUpsDestinationAddr& aDestinationAddr, const TUpsDestinationAddrType& aDestinationAddrType, const Messages::TNodeId& aCommsId)
: iProcessId(aProcessId), iThreadId(aThreadId), iPlatSecResult(aPlatSecResult),
iDestinationAddr(aDestinationAddr), iDestinationAddrType(aDestinationAddrType), iCommsId(aCommsId)
{ };
TProcessId iProcessId;
TThreadId iThreadId;
TInt iPlatSecResult; // result of Platform Security policy check
TUpsDestinationAddr iDestinationAddr; // destination (e.g. IP address where available)
TUpsDestinationAddrType iDestinationAddrType; // form of iDestinationAddr (e.g. string, IP address etc)
Messages::TNodeId iCommsId;
};
DECLARE_MESSAGE_SIG_1(SigUpsParameters, TPolicyCheckRequestParams, Params)
struct TUPSStatusChangeParams
/**
Parameters passed in a UPS Status Change message
*/
{
inline TUPSStatusChangeParams()
{ };
inline TUPSStatusChangeParams(const TProcessId& aProcessId, const TThreadId& aThreadId, const Messages::TNodeId& aCommsId)
: iProcessId(aProcessId), iThreadId(aThreadId), iCommsId(aCommsId)
{ };
TProcessId iProcessId;
TThreadId iThreadId;
Messages::TNodeId iCommsId;
};
DECLARE_MESSAGE_SIG_1(SigUpsStatusChangeParameters, TUPSStatusChangeParams, Params)
#endif
template<TInt id, TInt32 realm> struct TMessageSigSelectionPrefs;
template<TInt id, TInt32 realm> struct TCFMessageSigConnPrefList;
template<TInt id, TInt32 realm> struct TMessageSigSelectComplete;
template<TInt id, TInt32 realm> struct TCFMessageTransportHookError;
//any new enum added here needs to go into one of the utracedecoder definition files
//NEVER INSERT ANYTHING IN HERE ONLY ADD THE PENALTY IS SUDDEN DEATH!
class TCFMessage
{
private:
enum
{
ECFSubConnDataTransferred = 94, //email details to remek including comparison of conn and subconn
EStateChange = 95,
ECFTransportNotification = 100, // For SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
ECFProvisionConnectionInfo = 101,
ECFDestroyOrphans = 102
};
protected:
friend class ::CSockManData;
/*
* Utility functions to register/deregister internal transport messages
* @internalComponent
* @released 9.3
*/
static void RegisterL();
static void DeRegister();
public:
enum { ERealmId = 0x10285A57 }; //UID allocated on 21/11/2007
/*==========================================================================
<<Keys:>>
[Name]: <messagename>
[Semantics]: Message semantics
[Type]: Request for <responsemsg>|Response to <requestmsg>|Notification/[Peerless]
Where:
Request - request to perform an action. Sender should expect <responsemsg>
to ackowledge the completion of the action.
Response - acknowledgement that the previous request is now completed.
Notification - a one-off message flagging an event.
Peerless - the message is peerless, i.e.: the sender doesn't have to
be the recipient's client.
[Fallible]: Yes|No
Only applicable to requests and denotes whether the request can fail or not,
or, in other words, whether the request can be completed to with TError.
[Structure]:
Every message defined in this realm has at least:
param iSender - the message sender
param iActivityId - depending on the message type:
Request - the activity id the response should be addressed to.
Request senders fill up this param to match the response
with the local activity. Activity id on the sender side
should uniquelly identify the activity expecting the response.
Response - the activity on the recipient side expecting this response.
the activityid to put here has been previously conveyed
with the request.
Notification - ignored.
===========================================================================*/
//[399TODO] RZ: the list of messages that follow is pretty long. I was then thinking
//that perhaps we could chop it (with namespaces) into conceptual interfaces. Even better,
//perhaps we could even make some runtime checks on message reception to panic if a message
//received doesn't belong to any of the interfaces implemented locally.
//--Generic framework--
//typedef Messages::TMessageSigVoid<ECFNull, TCFMessage::ERealmId> TNull;
/****************************************************************************
**
****************************************************************************
**
**
**
**
**
**
** INTERFACE: Unasigned
**
**
**
**
**
**
****************************************************************************
**
****************************************************************************/
/*==========================================================================
[Name]: TSubConnDataTransferred
[Semantics]: [399TODO] RZ: Simon please finish.
[Type]:
[Fallible]:
[Structure]:
===========================================================================*/
typedef Messages::TMessageSigNumberNumberNumber<ECFSubConnDataTransferred, TCFMessage::ERealmId> TSubConnDataTransferred;
/*==========================================================================
[Name]: TStateChange
[Semantics]: Sender flags its state change. The state represents the legacy concept of a progress
and is only sent during connection start or stop.
[Type]: Notification
===========================================================================*/
typedef TMessageSigStateChange<EStateChange, TCFMessage::ERealmId> TStateChange;
#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
/*==========================================================================
[Name]: TTransportNotification
[Semantics]: Sender sends this message to Data clients which will have a notification.
Presently used to notify the data clients for the change in underlying bearer
which will enable the SAP to used set the TCP receive window size and Maximum
window size (which will be used for scaling negotiation). The window sizes will
be retrieved using the pointer to the Lookup Table.
[Type]: Notification
===========================================================================*/
typedef Messages::TMessageSigVoid <ECFTransportNotification, TCFMessage::ERealmId> TTransportNotification;
#endif //SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
/**
The message provisions connection information during the selection request
@li Type: Notification
IMPORTANT: There is no response to TProvisionConnectionInfo. If the recipient finds out
that the configuration received is in any way inadequate, it cannot flag this
fact until it is requested to do something (e.g.: TCFDataClient::Start)
*/
typedef TMessageSigConnectionInfoPtr<ECFProvisionConnectionInfo, TCFMessage::ERealmId> TProvisionConnectionInfo;
typedef Messages::TMessageSigVoid <ECFDestroyOrphans, TCFMessage::ERealmId> TDestroyOrphans;
};
} //namespace ESock
#endif
// __SS_NODEMESSAGES_INTERNAL_H__