--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/networkprotocolmodules/suplprotocolmodule/SuplConnectionManager/inc/socketreader.h	Tue Feb 02 01:50:39 2010 +0200
@@ -0,0 +1,141 @@
+// 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
+ @internalComponent
+ @deprecated 
+*/
+
+#ifndef SOCKETREADER_H_
+#define SOCKETREADER_H_
+#include <e32base.h>
+#include <es_sock.h>
+#include <in_sock.h>
+#include <securesocket.h>
+
+#include "observers.h"
+
+// Forwards
+class CSuplAsn1Decoder;
+
+/** Size of buffer used for reading SUPL messages from a socket
+*/
+const TInt KSuplMaxMessageLength = 8192; // Enough to keep all the assistance data
+
+class CSocketReader : public CActive
+	{
+public:
+	static CSocketReader* NewL(RSocket& aSocket, MSuplSocketObserver& aObserver, TUint aCallbackId);
+	~CSocketReader();
+	
+	// CActive
+	void RunL();
+	void DoCancel();
+	void RunError();
+private:
+	// Constructors
+	CSocketReader(RSocket& aSocket, MSuplSocketObserver& aObserver, TUint aCallbackId);
+	void ConstructL();
+	
+	// Methods
+	void SuplMessageLength();
+	void IssueRead();
+	void FireObservation();
+private:
+	// Socket to listen on
+	RSocket& iSocket;
+
+	// Observer for calling back when message received
+	MSuplSocketObserver& iObserver;
+	
+	// Data buffer for message
+	RBuf8 iBuffer;
+	
+	// Size of data read
+	TSockXfrLength iBufferRead;
+	
+	// Is this the first fragment
+	TBool iIsFirstFragment;
+	
+	// Total size of the message we are currently reading
+	TUint iCurrentMessageSize;
+	
+	// Current read data
+	TUint iReadSoFar;
+	
+	// Decoder
+	CSuplAsn1Decoder* iDecoder;   
+	
+	// Ptr into buffer
+	TPtr8 iPtr;
+	
+	// Id for callbacks
+	TUint iCallbackId;
+	};
+
+
+class CSecureSocketReader : public CActive
+	{
+public:
+	static CSecureSocketReader* NewL(CSecureSocket& aSocket, MSuplSocketObserver& aObserver, TUint aCallbackId);
+	~CSecureSocketReader();
+	
+	// CActive
+	void RunL();
+	void DoCancel();
+	void RunError();	
+private:
+	// Constructors
+	CSecureSocketReader(CSecureSocket& aSocket, MSuplSocketObserver& aObserver, TUint aCallbackId);
+	void ConstructL();
+	
+	// Methods
+	void SuplMessageLength();
+	void IssueRead();
+	void FireObservation();	
+private:
+	// Socket to listen on
+	CSecureSocket& iSocket;
+
+	// Observer for calling back when message received
+	MSuplSocketObserver& iObserver;
+	
+	// Data buffer for message
+	RBuf8 iBuffer;
+	
+	// Size of data read
+	TSockXfrLength iBufferRead;
+	
+	// Is this the first fragment
+	TBool iIsFirstFragment;
+	
+	// Total size of the message we are currently reading
+	TUint iCurrentMessageSize;
+	
+	// Current read data
+	TUint iReadSoFar;
+	
+	// Decoder
+	CSuplAsn1Decoder* iDecoder;
+	
+	// Ptr into buffer
+	TPtr8 iPtr;
+	
+	// Id for callbacks
+	TUint iCallbackId;
+	};
+
+#endif /*SOCKETREADER_H_*/