// 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:
// Contains declaration of CTestStepESockSSA class that is
// base class for all test step classes in this test.
// 
//

#if !defined(SYMBIAN_NETWORKING_ESOCKTEST_TESTSTEPESOCKSSA_H_)
#define SYMBIAN_NETWORKING_ESOCKTEST_TESTSTEPESOCKSSA_H_

#include <test/testexecutestepbase.h>


// Relies upon no competing use of the thread semaphore, ie no request completions/AOs
class RMultipleWait : public RFastLock
	{
public:
	RMultipleWait(TInt aInitialCount);
	void Close();
	void Signal(TInt aDelta);
	void Wait();

	typedef RFastLock inherited;
private:
	TInt iCount;
	RThread iOwnerThread;
	};


class CTestStepESockSSA : public CTestStep
	{
public:
	enum { KBlockedRequestIssueDelay = 1000000, KBlockedRequestCompletionDelay = 1000000 };

	CTestStepESockSSA();
	~CTestStepESockSSA();
	
	virtual TVerdict doTestStepPreambleL();
	virtual TVerdict doTestStepPostambleL();

protected:
	class TDataThreadControl
		{
	public:
		TDataThreadControl(RMultipleWait& aBlockSemaphore, TInt aExpectedResult)
		: iBlockSemaphore(aBlockSemaphore),
		  iExpectedResult(aExpectedResult)
			{
			}
	public:
		enum TRequestType
			{ 
			ESocketOpen, 
			EHostResolverOpen,
			EHostResolverOpenMulti,
			EServiceResolverOpen, 
			ENetDBOpen, 
			ENumProtocols, 
			EGetProtocolInfo,
			EFindProtocol
			};
		TRequestType iRequest;
		RMultipleWait& iBlockSemaphore;
		TBool iBlocked;
		TInt iResult;
		TInt iExpectedResult;
		RThread iThread;
		RSocketServ iSession;
		};

	typedef TInt (*TDataThreadEntryPt)(TDataThreadControl&);
protected:
	void SetDummyBlocking();
	void ClearDummyBlocking();

	TInt CreateDataThread(TDataThreadControl::TRequestType aRequest, TDataThreadControl& aControl);
	TVerdict WaitForDataThreadsToBlock(TDataThreadControl* aThreads, TInt aNumThreads);
	TVerdict WaitForDataThreadsToComplete(TDataThreadControl* aThreads, TInt aNumThreads);

	static TInt DataThreadEntry(TDataThreadControl& aControl);
private:
	static void DoDataThreadL(TDataThreadControl& aControl);
	void UnloadBlockerL();
	void KillC32Start();
	};
	
#endif /* SYMBIAN_NETWORKING_ESOCKTEST_TESTSTEPESOCKSSA_H_ */