--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/pkiutilities/ocsp/test/requestlogger.cpp	Tue Jan 26 15:20:08 2010 +0200
@@ -0,0 +1,113 @@
+// Copyright (c) 2005-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:
+// A transport that logs the ocsp requests made to a file and then calls another
+// transport to send the request.
+// 
+//
+
+#include "requestlogger.h"
+
+#include <f32file.h>
+
+CTOCSPRequestLogger* CTOCSPRequestLogger::NewL(const TDesC& aRequestFile, MOCSPTransport* aTransport)
+	{
+	CTOCSPRequestLogger* self = new (ELeave) CTOCSPRequestLogger;
+	CleanupStack::PushL(self);
+	self->ConstructL(aRequestFile, aTransport);
+	CleanupStack::Pop(self);
+	return self;
+	}
+
+
+CTOCSPRequestLogger::CTOCSPRequestLogger()	
+	{
+	}
+
+
+void CTOCSPRequestLogger::ConstructL(const TDesC& aRequestFile, MOCSPTransport* aTransport)
+	{
+	User::LeaveIfError(iFs.Connect());
+
+	TInt err = iFs.MkDirAll(aRequestFile);
+	if (err != KErrAlreadyExists)
+		{
+		User::LeaveIfError(err);
+		}
+
+	User::LeaveIfError(iWriteStream.Replace(iFs, aRequestFile, EFileWrite | EFileShareExclusive));
+
+	// Initially we write a request count of zero, this gets updates as each
+	// request is logged
+	iWriteStream.WriteUint32L(0);
+
+	iTransport = aTransport;
+	}
+
+
+CTOCSPRequestLogger::~CTOCSPRequestLogger()
+	{
+	iWriteStream.Close();
+	iFs.Close();
+	delete iTransport;
+	}
+
+
+void CTOCSPRequestLogger::SendRequest(const TDesC8& aURI,
+									  const TDesC8& aRequest, 
+									  const TInt aTimeout,
+									  TRequestStatus& aStatus)
+	{
+	TRAPD(err, LogRequestL(aURI, aRequest));
+
+	if (err == KErrNone)
+		{
+		iTransport->SendRequest(aURI, aRequest, aTimeout, aStatus);
+		}
+	else
+		{
+		TRequestStatus* status = &aStatus;
+		User::RequestComplete(status, err);
+		}
+	}
+
+void CTOCSPRequestLogger::LogRequestL(const TDesC8& aURI,
+									  const TDesC8& aRequest)
+	{
+	++iTotalRequests;
+
+	MStreamBuf* sink = iWriteStream.Sink();
+
+	sink->SeekL(MStreamBuf::EWrite, EStreamBeginning, 0);
+	iWriteStream.WriteUint32L(iTotalRequests);
+
+	sink->SeekL(MStreamBuf::EWrite, EStreamEnd, 0);
+	iWriteStream.WriteUint32L(aURI.Length());
+	iWriteStream.WriteL(aURI);
+	iWriteStream.WriteUint32L(aRequest.Length());
+	iWriteStream.WriteL(aRequest);
+
+	iWriteStream.CommitL();
+	}
+
+
+void CTOCSPRequestLogger::CancelRequest()
+	{
+	iTransport->CancelRequest();
+	}
+
+
+TPtrC8 CTOCSPRequestLogger::GetResponse() const
+	{
+	return iTransport->GetResponse();
+	}