--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/DirectPrint/DirectPrintServer/src/directprintserverjobguard.cpp	Tue May 11 14:10:02 2010 +0800
@@ -0,0 +1,237 @@
+/*
+* Copyright (c) 2010 Kanrikogaku Kenkyusho, Ltd.
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of the License "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:
+* Kanrikogaku Kenkyusho, Ltd. - Initial contribution
+*
+* Contributors:
+*
+* Description:  
+*
+*/
+
+
+
+#include "directprintserverjobguard.h"
+#include "directprintbody.h"
+#include "clog.h"
+#include "directprintmessage.h"
+
+CDirectPrintServerJobGuard* CDirectPrintServerJobGuard::NewL( CDirectPrintBody& aEngine )
+	{
+	CDirectPrintServerJobGuard* self = new ( ELeave ) CDirectPrintServerJobGuard( aEngine );
+	CleanupStack::PushL( self );
+	self->ConstructL();
+	CleanupStack::Pop();    // self
+	return self;
+	}
+
+CDirectPrintServerJobGuard::CDirectPrintServerJobGuard( CDirectPrintBody& aEngine )
+	: iEngine( aEngine )
+	, iRequestActive( EFalse )
+	{
+	}
+
+CDirectPrintServerJobGuard::~CDirectPrintServerJobGuard()
+	{
+	LOG("CDirectPrintServerJobGuard::~CDirectPrintServerJobGuard begin");
+	iImages.ResetAndDestroy();
+	iImages.Close();
+	iBuffer.Close();
+	LOG("CDirectPrintServerJobGuard::~CDirectPrintServerJobGuard end");
+	}
+
+void CDirectPrintServerJobGuard::ConstructL()
+	{
+	}
+
+void CDirectPrintServerJobGuard::PrepareL( TDpMessage& aMessage )
+	{
+	LOG("CDirectPrintServerJobGuard::PrepareL begin");
+	TInt len = aMessage.GetDesLength( 0 );
+	HBufC* buf = HBufC::NewLC( len );
+	TPtr ptr( buf->Des() );
+	aMessage.ReadL( 0, ptr );
+	iImages.AppendL( buf );
+	CleanupStack::Pop(); // buf
+	LOG("CDirectPrintServerJobGuard::PrepareL end");
+	}
+
+void CDirectPrintServerJobGuard::Stop()	
+	{
+	LOG("CDirectPrintServerJobGuard::Stop begin");
+	iImages.ResetAndDestroy();
+	if( iRequestActive )
+		{
+		LOG("CDirectPrintServerJobGuard::Stop cancelling...");
+		iMessage->Complete( KErrCancel );
+		iRequestActive = EFalse;
+		}
+	LOG("CDirectPrintServerJobGuard::Stop end");
+	}
+
+TInt CDirectPrintServerJobGuard::CreateL( TDpMessage& aMessage )
+	{
+	LOG("CDirectPrintServerJobGuard::CreateL begin");
+	iRequestActive = EFalse;
+	iBuffer.Reset();
+	TInt printer = aMessage.Int0();
+	TInt err = iEngine.CreatePrintJobL( printer, iImages, *this );
+	LOG1("CDirectPrintServerJobGuard::CreateL err: %d", err);
+	if( err )
+		{
+		iImages.ResetAndDestroy();
+		}
+	LOG1("CDirectPrintServerJobGuard::CreateL return: %d", err);
+	return err;
+	}
+
+void CDirectPrintServerJobGuard::ContinueCreateL( TDpMessage& aMessage )
+	{
+	LOG("CDirectPrintServerJobGuard::ContinueCreateL begin");
+	if( iMessage ) iMessage->SetDisposable( ETrue );
+	iMessage = &aMessage;
+	iRequestActive = ETrue;
+	if( iBuffer.Count() )
+		{
+		LOG("CDirectPrintServerJobGuard::ContinueCreateL before ProcessL");
+		Process();
+		LOG("CDirectPrintServerJobGuard::ContinueCreateL after ProcessL");
+		}
+	LOG("CDirectPrintServerJobGuard::ContinueCreateL end");
+	}
+
+void CDirectPrintServerJobGuard::PrintJobProgressEvent(TInt aStatus, TInt aPercentCompletion, TInt aJobStateCode)
+	{
+	LOG("CDirectPrintServerJobGuard::PrintJobProgressEvent begin");
+	LOG1("CDirectPrintServerJobGuard::PrintJobProgressEvent aStatus: %d", aStatus);
+	LOG1("CDirectPrintServerJobGuard::PrintJobProgressEvent aPercentCompletion: %d", aPercentCompletion);
+	LOG1("CDirectPrintServerJobGuard::PrintJobProgressEvent aJobStateCode: %d", aJobStateCode);
+	TDirectPrintJobGuardData data;
+	data.iCb = TDirectPrintJobGuardData::EProgressEventCb;
+	data.iStatus = aStatus;
+	data.iPercentCompletion = aPercentCompletion;
+	data.iJobStateCode = aJobStateCode;
+	TRAPD( err, DoPreProcessL( data ) );
+	LOG1("CDirectPrintServerJobGuard::PrintJobProgressEvent DoPreProcessL's TRAP err: %d", err);
+	Process( err );
+	LOG("CDirectPrintServerJobGuard::PrintJobProgressEvent end");
+	}
+
+void CDirectPrintServerJobGuard::PrintJobErrorEvent(TInt aError, TInt aErrorStringCode)
+	{
+	LOG("CDirectPrintServerJobGuard::PrintJobErrorEvent begin");
+	LOG1("CDirectPrintServerJobGuard::PrintJobErrorEvent aError: %d", aError);
+	LOG1("CDirectPrintServerJobGuard::PrintJobErrorEvent aErrorStringCode: %d", aErrorStringCode);
+	TDirectPrintJobGuardData data;
+	data.iCb = TDirectPrintJobGuardData::EErrorEventCb;
+	data.iError = aError;
+	data.iErrorStringCode = aErrorStringCode;
+	TRAPD( err, DoPreProcessL( data ) );
+	LOG1("CDirectPrintServerJobGuard::PrintJobErrorEvent DoPreProcessL's TRAP err: %d", err);
+	Process( err );
+	LOG("CDirectPrintServerJobGuard::PrintJobErrorEvent end");
+	}
+
+void CDirectPrintServerJobGuard::PrinterStatusEvent(TInt aError, TInt aErrorStringCode)
+	{
+	LOG("CDirectPrintServerJobGuard::PrinterStatusEvent begin");
+	LOG1("CDirectPrintServerJobGuard::PrinterStatusEvent aError: %d", aError);
+	LOG1("CDirectPrintServerJobGuard::PrinterStatusEvent aErrorStringCode: %d", aErrorStringCode);
+	TDirectPrintJobGuardData data;
+	data.iCb = TDirectPrintJobGuardData::EStatusEventCb;
+	data.iError = aError;
+	data.iErrorStringCode = aErrorStringCode;
+	TRAPD( err, DoPreProcessL( data ) );
+	LOG1("CDirectPrintServerJobGuard::PrinterStatusEvent DoPreProcessL's TRAP err: %d", err);
+	Process( err );
+	LOG("CDirectPrintServerJobGuard::PrinterStatusEvent end");
+	}
+
+void CDirectPrintServerJobGuard::PreviewImageEvent(TInt aFsBitmapHandle)
+	{
+	LOG("CDirectPrintServerJobGuard::PreviewImageEvent begin");
+	LOG1("CDirectPrintServerJobGuard::PreviewImageEvent aFsBitmapHandle: %d", aFsBitmapHandle);
+	TDirectPrintJobGuardData data;
+	data.iCb = TDirectPrintJobGuardData::EImageEventCb;
+	data.iFsBitmapHandle = aFsBitmapHandle;
+	TRAPD( err, DoPreProcessL( data ) );
+	LOG1("CDirectPrintServerJobGuard::PreviewImageEvent DoPreProcessL's TRAP err: %d", err);
+	Process( err );
+	LOG("CDirectPrintServerJobGuard::PreviewImageEvent end");
+	}
+
+void CDirectPrintServerJobGuard::DoPreProcessL( const TDirectPrintJobGuardData& aData )
+	{
+	LOG("CDirectPrintServerJobGuard::DoPreProcessL begin");
+	User::LeaveIfError( iBuffer.Append( aData ) );
+	LOG("CDirectPrintServerJobGuard::DoPreProcessL end");
+	}
+
+void CDirectPrintServerJobGuard::DoProcessL()
+	{
+	LOG("CDirectPrintServerJobGuard::ProcessL begin");
+	if( iBuffer.Count() && iRequestActive )
+		{
+		LOG("CDirectPrintServerJobGuard::DoProcessL step 1");
+		TPtr8 ptr(reinterpret_cast<TUint8*>(&(iBuffer[0])), sizeof(iBuffer[0]), sizeof(iBuffer[0]));
+		LOG("CDirectPrintServerJobGuard::DoProcessL step 2");
+		iMessage->WriteL( 0, ptr );
+		LOG("CDirectPrintServerJobGuard::DoProcessL step 3");
+		iMessage->Complete( KErrNone );
+		LOG("CDirectPrintServerJobGuard::DoProcessL step 4");
+		iRequestActive = EFalse;
+		LOG("CDirectPrintServerJobGuard::DoProcessL step 5");
+		iBuffer.Remove( 0 );
+		LOG("CDirectPrintServerJobGuard::DoProcessL step 6");
+		}	
+	LOG("CDirectPrintServerJobGuard::ProcessL end");
+	}
+
+void CDirectPrintServerJobGuard::Process( TInt aErr )
+	{
+	LOG("CDirectPrintServerJobGuard::Process begin");
+	if( aErr )
+		{
+		LOG1("CDirectPrintServerJobGuard::Process aErr: %d", aErr);
+		iMessage->Complete( aErr );
+		iRequestActive = EFalse;
+		}
+	else
+		{
+		LOG("CDirectPrintServerJobGuard::Process calling DoProcessL");
+		TRAPD( err, DoProcessL() );
+		LOG1("CDirectPrintServerJobGuard::Process DoProcessL's TRAP err: %d", err);
+		if( err )
+			{
+			iMessage->Complete( err );
+			iRequestActive = EFalse;
+			}
+		}
+	LOG("CDirectPrintServerJobGuard::Process end");	
+	}
+
+
+
+// DEPRECATED
+
+void CDirectPrintServerJobGuard::ShowMessageL( TInt /*aMsgLine1Code*/, TInt /*aMsgLine2Code*/ )
+	{
+	}
+
+TBool CDirectPrintServerJobGuard::AskYesNoQuestionL( TInt /*aMsgLine1Code*/, TInt /*aMsgLine2Code*/ )
+	{
+	return EFalse;
+	}
+
+const TDesC& CDirectPrintServerJobGuard::AskForInputL( TInt /*aMsgLine1Code*/, TInt /*aMsgLine2Code*/ )
+	{
+	return KNullDesC;
+	}
+
+//  End of File