--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/locationmgmt/networkgateway/src/cpsyrequestchannel.cpp	Tue Feb 02 01:50:39 2010 +0200
@@ -0,0 +1,153 @@
+// Copyright (c) 2006-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:
+// Definition of PSY request channel component functions.
+// 
+//
+
+/**
+ @file
+ @internalTechnology
+ @released
+*/
+
+#include <e32base.h>
+#include <e32debug.h>
+#include <lbs/lbslocerrors.h>
+#include "lbsdevloggermacros.h"
+#include "lbsprocessuiddefs.h"
+#include "cpsyrequestchannel.h"
+
+
+CPsyRequestChannel::CPsyRequestChannel(MPsyRequestObserver& aObserver) : 
+    CActive(EPriorityStandard),
+    iObserver(aObserver)
+    {
+    }
+    
+CPsyRequestChannel::~CPsyRequestChannel()
+    {
+    Cancel();
+    iPsyResponseChannel.Close();
+    delete iMsgBuffer;
+    }
+
+CPsyRequestChannel* CPsyRequestChannel::NewL(MPsyRequestObserver& aObserver, TUint aChannel)
+    {
+    CPsyRequestChannel* self = new (ELeave) CPsyRequestChannel(aObserver);
+    CleanupStack::PushL(self);
+    self->ConstructL(aChannel);
+    CleanupStack::Pop(self);
+    return self;
+    }
+    
+/**
+Opens the channel specified
+ 
+@param aChannel, Net Internal API channel to use for this object
+*/
+void CPsyRequestChannel::ConstructL(TUint aChannel)
+    {
+    iPsyResponseChannel.OpenL(static_cast<RLbsNetChannel::TLbsNetChannelId> (aChannel), *this);
+    iMsgBuffer = CRequestMessageBuffer::NewL();
+    CActiveScheduler::Add(this);
+    }
+    
+/**
+Handle the ACK from the SendMessage call.
+*/
+void CPsyRequestChannel::RunL()
+    {
+    LBS_RDEBUG_ARGINT("PSY Req Chan", "LBS", "RunL", iStatus.Int());
+
+    User::LeaveIfError(iStatus.Int());
+    SendNextBufferedMessage();
+    }
+    
+void CPsyRequestChannel::DoCancel()
+    {
+    iPsyResponseChannel.CancelSendMessageNotification();
+    }
+    
+TInt CPsyRequestChannel::RunError(TInt aError)
+    {
+    return aError;
+    }
+
+/**
+Sends a message to a Network PSY from the Network Gateway
+ 
+@param aChannel, Net Internal API channel to use for this object
+*/
+void CPsyRequestChannel::SendNetworkResponse(const TLbsNetInternalMsgBase& aMessage)
+    {
+    LBSLOG(ELogP1, "CPsyRequestChannel::SendNetworkResponse:");
+    if (!IsActive())
+        {       
+        // Immediately send the new message.
+        SendMessage(aMessage);
+        }
+    else
+        {
+        // Still waiting for acknowledgement that a previous message
+        // was read, so buffer this new message.
+        TInt err = iMsgBuffer->BufferMessage(aMessage);
+        if (err != KErrNone)
+            {
+            LBSLOG(ELogP1, "BUFFERING MESSAGE FAILED!!");
+            }
+        }
+    }
+
+
+void CPsyRequestChannel::SendMessage(const TLbsNetInternalMsgBase& aMessage)
+    {
+    LBSLOG(ELogP1, "CPsyRequestChannel::SendMessage:");
+    LBSLOG2(ELogP2, "Sending message : Type %d", aMessage.Type());
+    
+    iPsyResponseChannel.SendMessage(aMessage, iStatus);
+    SetActive();
+    }
+
+
+void CPsyRequestChannel::SendNextBufferedMessage()
+    {
+    LBSLOG(ELogP1, "CPsyRequestChannel::SendNextBufferedMessage:");
+    
+    const TLbsNetInternalMsgBase* msg = iMsgBuffer->PeekNextMessage();
+    if (msg != NULL)
+        {
+        // Send the oldest buffered message. This will always
+        // be the one at position zero.
+        LBSLOG2(ELogP2, "Sending buffered message. Type: %d", msg->Type());
+        SendMessage(*msg);
+        iMsgBuffer->RemoveMessage(msg);
+        }
+    }
+
+
+/**
+Passes a message from a Network PSY to the Network Gateway
+ 
+@param aChannel, Net Internal API channel to use for this object
+*/
+void CPsyRequestChannel::ProcessNetChannelMessage(RLbsNetChannel::TLbsNetChannelId aChannelId, const TLbsNetInternalMsgBase& aMessage)
+    {
+    LBSLOG(ELogP1, "CPsyRequestChannel::ProcessNetChannelMessage");
+    __ASSERT_DEBUG(aChannelId == RLbsNetChannel::EChannelNG2SUPLPSY, User::Panic(KLbsNGFault, ENGUnexpectedNetChannelId));
+    (void) aChannelId;
+    iObserver.ProcessPsyMessage(aMessage);
+    }
+
+
+