--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/sdkcreationmw/sdkruntimes/wsock/src/WinsockAgent.cpp	Mon Mar 08 12:09:11 2010 +0530
@@ -0,0 +1,381 @@
+/*
+* Copyright (c) 2004-2005 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: 
+*
+*/
+
+
+#define TRACE_PREFIX "WSOCK: Agent: "
+#include "wsock.h"
+#include "WinsockAgent.h"
+#include "WinsockAgentCallback.h"
+#include "WinsockProtocolFamily.h"
+
+#ifdef SYMBIAN_NETWORKING_PLATSEC
+#define ACCESS_METHOD1(_ret,_what,_p1) \
+    _ret CWinsockAgent::Do##_what(_p1, const RMessagePtr2* /*aMessage*/ )
+#define ACCESS_METHOD2(_ret,_what,_p1,_p2) \
+    _ret CWinsockAgent::Do##_what(_p1, _p2, const RMessagePtr2* /*aMessage*/ )
+#else /* SYMBIAN_NETWORKING_PLATSEC */
+#define ACCESS_METHOD1(_ret,_what,_p1) \
+    _ret CWinsockAgent::_what(_p1)
+#define ACCESS_METHOD2(_ret,_what,_p1,_p2) \
+    _ret CWinsockAgent::_what(_p1,_p2)
+#endif /* SYMBIAN_NETWORKING_PLATSEC */
+
+// Settings
+_LIT(KIfName,"IfName");                 // IF_NAME
+_LIT(KIfNetworks,"IfNetworks");         // SERVICE_IF_NETWORKS
+_LIT(KIAPBearerType,"IAP\\IAPBearerType");
+_LIT(KIAPServiceType,"IAP\\IAPServiceType");
+_LIT(KIAPName,"IAP\\Name");
+_LIT(KIAPId,"IAP\\Id");
+_LIT(KIAPService,"IAP\\IAPService");
+_LIT(KIAPNetwork,"IAP\\IAPNetwork");
+_LIT(KLANBearerName,"LANBearer\\Name");
+_LIT(KLANBearerLastSocketActivityTimeout,"LANBearer\\LastSocketActivityTimeout");
+_LIT(KLANBearerLastSocketActivityTimeout2,"LastSocketActivityTimeout");
+_LIT(KLANBearerLastSessionClosedTimeout,"LANBearer\\LastSessionClosedTimeout");
+_LIT(KLANBearerLastSessionClosedTimeout2,"LastSessionClosedTimeout");
+_LIT(KLANBearerLastSocketClosedTimeout,"LANBearer\\LastSocketClosedTimeout");
+_LIT(KLANBearerLastSocketClosedTimeout2,"LastSocketClosedTimeout");
+
+CWinsockAgent* CWinsockAgent::NewL()
+{
+    CWinsockAgent* self = new(ELeave)CWinsockAgent;
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    CleanupStack::Pop(self);
+    return self;
+}
+
+CWinsockAgent::CWinsockAgent()
+{
+}
+
+CWinsockAgent::~CWinsockAgent()
+{
+    if (iConnector)
+    {
+        iConnector->Cancel();
+        delete iConnector;
+    }
+    if (iDisconnector)
+    {
+        iDisconnector->Cancel();
+        delete iDisconnector;
+    }
+}
+
+void CWinsockAgent::ConstructL()
+{
+    WsockCheckCommDbL(iIapId, iIapNetwork, iIapService, iIapBearer);
+}
+
+void CWinsockAgent::Info(TNifAgentInfo& aInfo) const
+{
+    aInfo.iVersion = TVersion(1,0,0);
+    aInfo.iName = KWinsockAgent;
+}
+
+void CWinsockAgent::Connect(TAgentConnectType aType)
+{
+    Connect(aType, NULL);
+}
+
+void CWinsockAgent::Connect(TAgentConnectType DEBUG_ONLY(aType), 
+                            CStoreableOverrideSettings* /*aOverride*/)
+{
+    TRACE1("Connect(%d)",aType);
+    ASSERT(iNotify);
+    ScheduleConnectNotification();
+    iNotify->ServiceStarted();
+}
+
+void CWinsockAgent::CancelConnect()
+{
+    TRACE("CancelConnect()");
+    CancelConnectNotification();
+}
+
+void CWinsockAgent::Reconnect()
+{
+    TRACE("Reconnect()");
+    ScheduleConnectNotification();
+}
+
+void CWinsockAgent::CancelReconnect()
+{
+    TRACE("CancelReconnect()");
+    CancelConnectNotification();
+}
+
+void CWinsockAgent::Authenticate(TDes& /*aUsername*/, TDes& /*aPassword*/)
+{
+    TRACE("Authenticate()");
+    ASSERT(iNotify);
+    iNotify->AuthenticateComplete(KErrNone);
+}
+
+void CWinsockAgent::CancelAuthenticate()
+{
+    TRACE("CancelAuthenticate()");
+}
+
+void CWinsockAgent::Disconnect(TInt aReason)
+{
+    TRACE1("Disconnect(%d)",aReason);
+    iDisconnectReason = aReason;
+    if (!iDisconnector)
+    {
+        iDisconnector = new CWinsockAgentCallback(this,DisconnectComplete);
+    }
+    if (iDisconnector)
+    {
+        // Schedule asynchronous disconnect notification
+        ASSERT(iDisconnector->Agent() == this);
+        iDisconnector->InvokeLater();
+    }
+}
+
+TInt CWinsockAgent::GetExcessData(TDes8& aBuffer)
+{
+    TRACE("GetExcessData()");
+    aBuffer.SetLength(0);
+    return KErrNone;
+}
+
+ACCESS_METHOD2(TInt, ReadInt, const TDesC& aField, TUint32& aValue)
+{
+    if (aField == KIAPId)
+    {
+        aValue = iIapId;
+    }
+    else if (aField == KIAPNetwork)
+    {
+        aValue = iIapNetwork;
+    }
+    else if (aField == KIAPService)
+    {
+        aValue = iIapService;
+    }
+    else if (aField == KLANBearerLastSocketActivityTimeout ||
+             aField == KLANBearerLastSocketActivityTimeout2)
+    {
+        aValue = KWinsockSocketActivityTimeout;
+    }
+    else if (aField == KLANBearerLastSessionClosedTimeout ||
+             aField == KLANBearerLastSessionClosedTimeout2)
+    {
+        aValue = KWinsockSessionClosedTimeout;
+    }
+    else if (aField == KLANBearerLastSocketClosedTimeout ||
+             aField == KLANBearerLastSocketClosedTimeout2)
+    {
+        aValue = KWinsockSocketClosedTimeout;
+    }
+    else
+    {
+        TRACE1("ReadInt(%S)  -> KErrNotFound",&aField);
+        return KErrNotFound;
+    }
+    TRACE2("ReadInt(%S) = %d",&aField,aValue);
+    return KErrNone;
+}
+
+ACCESS_METHOD2(TInt, WriteInt, const TDesC& DEBUG_ONLY(aField), 
+               TUint32 DEBUG_ONLY(aValue))
+{
+    TRACE2("WriteInt(%S,%d)",&aField,aValue);
+    return KErrNotSupported;
+}
+
+ACCESS_METHOD2(TInt, ReadDes, const TDesC& DEBUG_ONLY(aField), 
+               TDes8& /*aValue*/)
+{
+    TRACE1("ReadDes8(%S)",&aField);
+    return KErrNotFound;
+}
+
+ACCESS_METHOD2(TInt, WriteDes, const TDesC& DEBUG_ONLY(aField),
+               const TDesC8& /*aValue*/)
+{
+    TRACE1("WriteDes8(%S)",&aField);
+    return KErrNotSupported;
+}
+
+ACCESS_METHOD2(TInt, ReadDes, const TDesC& aField, TDes16& aValue)
+{
+    if (aField == KIfName)
+    {
+        aValue = KWinsockInterface;
+    }
+    else if (aField == KIfNetworks)
+    {
+        CWinsockProtocolFamily::ProtocolNames(aValue);
+    }
+    else if (aField == KIAPBearerType)
+    {
+        aValue = KWinsockBearerType;
+    }
+    else if (aField == KIAPServiceType)
+    {
+        aValue = KWinsockServiceType;
+    }
+    else if (aField == KIAPName)
+    {
+        aValue = KWinsockAPName;
+    }
+    else if (aField == KLANBearerName)
+    {
+        aValue = KWinsockBearerName;
+    }
+    else 
+    {
+        TRACE1("ReadDes16(%S) -> KErrNotFound",&aField);
+        return KErrNotFound;
+    }
+    TRACE2("ReadDes16(%S) = %S",&aField,&aValue);
+    return KErrNone;
+}
+
+ACCESS_METHOD2(TInt, WriteDes, const TDesC& DEBUG_ONLY(aField),
+               const TDesC16& /*aValue*/)
+{
+    TRACE1("WriteDes16(%S)",&aField);
+    return KErrNotSupported;
+}
+
+ACCESS_METHOD2(TInt, ReadBool, const TDesC& DEBUG_ONLY(aField),
+               TBool& /*aValue*/)
+{
+    TRACE1("ReadBool(%S)",&aField);
+    return KErrNotFound;
+}
+
+ACCESS_METHOD2(TInt, WriteBool, const TDesC& DEBUG_ONLY(aField),
+               TBool DEBUG_ONLY(aValue))
+{
+    TRACE2("WriteBool(%S,%d)",&aField,aValue);
+    return KErrNotSupported;
+}
+
+ACCESS_METHOD1(HBufC*, ReadLongDesLC, const TDesC& DEBUG_ONLY(aField))
+{
+    TRACE1("ReadLongDesLC(%S)",&aField);
+    return NULL;
+}
+
+TInt CWinsockAgent::Notification(TNifToAgentEventType DEBUG_ONLY(aEvent),
+                                 TAny* /*aInfo*/)
+{
+    TRACE1("Notification(%d)",aEvent);
+    return KErrNotSupported;
+}
+
+TInt CWinsockAgent::IncomingConnectionReceived()
+{
+    TRACE("IncomingConnectionReceived()");
+    return KErrNotSupported;
+}
+
+void CWinsockAgent::GetLastError(TInt& aError)
+{
+    TRACE("GetLastError()");
+    aError = KErrNone;
+}
+
+TBool CWinsockAgent::IsActive() const
+{
+    return ETrue;
+}
+
+TBool CWinsockAgent::IsReconnect() const
+{
+    return EFalse;
+}
+
+void CWinsockAgent::SetConnectionSettingsL(const TConnectionSettings& aSettings)
+{
+    TRACE("SetConnectionSettingsL()");
+    iSettings = aSettings;
+}
+
+TConnectionSettings& CWinsockAgent::ConnectionSettingsL()
+{
+    TRACE("ConnectionSettingsL()");
+    return iSettings;
+}
+
+void CWinsockAgent::SetOverridesL(CStoreableOverrideSettings* /*aOverride*/)
+{
+    TRACE("SetOverridesL()");
+}
+
+CStoreableOverrideSettings* CWinsockAgent::OverridesL()
+{
+    TRACE("OverridesL()");
+    User::Leave(KErrNotSupported);
+    return NULL;
+}
+
+void CWinsockAgent::RequestNotificationOfServiceChangeL(
+    MAgentSessionNotify* /*aSession*/)
+{
+    User::Leave(KErrNotSupported);
+}
+
+void CWinsockAgent::CancelRequestNotificationOfServiceChange(
+    MAgentSessionNotify* /*aSession*/)
+{
+}
+
+// Private methods
+
+void CWinsockAgent::ScheduleConnectNotification()
+{
+    ASSERT(iNotify);
+    if (!iConnector && iNotify)
+    {
+        iConnector = new CWinsockAgentCallback(this,ConnectComplete);
+    }
+    if (iConnector)
+    {
+        // Schedule asynchronous connect notification
+        ASSERT(iConnector->Agent() == this);
+        iConnector->InvokeLater();
+    }
+}
+
+void CWinsockAgent::CancelConnectNotification()
+{
+    if (iConnector)
+    {
+        iConnector->Cancel();
+    }
+}
+
+void CWinsockAgent::ConnectComplete()
+{
+    TRACE("firing connection notification");
+    iNotify->AgentProgress(KConnectionOpen, KErrNone);
+    iNotify->ConnectComplete(KErrNone);
+}
+
+void CWinsockAgent::DisconnectComplete()
+{
+    TRACE("firing disconnect notification");
+    iNotify->AgentProgress(KConnectionClosed, iDisconnectReason);
+    iNotify->DisconnectComplete();
+}