// 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:
// mdnsserver.h
// 
//
/**
@file
@internalTechnology
*/

#ifndef __MDNSSERVER_H__
#define __MDNSSERVER_H__

#include <e32base.h>
#include <es_sock.h>
#include <in_sock.h>
#include <e32property.h>
#include <mdns/dnsconstants.h>

#include "cinternalmessagequeue.h"
#include "mmessagehandler.h"
#include "mdnsdebug.h"

//class TMessageType;
class CMessageHandler;
class CMDNSProbeManager;
class CMDNSCacheConsistencyMgr;
// zeroconf messages policy - all NetworkService

const TUint zeroconfRangeCount = 1;
const TInt zeroconfRanges[zeroconfRangeCount] = 
	{
	0
	};

const TUint8 zeroconfElementsIndex[zeroconfRangeCount] = 
	{
	0
	};

const CPolicyServer::TPolicyElement zeroconfElements[] = 
	{
	{_INIT_SECURITY_POLICY_C1(ECapabilityNetworkServices), CPolicyServer::EFailClient}
	};

const CPolicyServer::TPolicy zeroconfPolicy =
	{
	CPolicyServer::EAlwaysPass,
	zeroconfRangeCount,                   
	zeroconfRanges,
	zeroconfElementsIndex,
	zeroconfElements,
	};

// The zeroconf server class

class CSocketHandler;
class CShutdownTimer;

class CMdnsServer : public CPolicyServer,public MMessageHandler
	{
public:
	static CMdnsServer* NewL();
	static CMdnsServer* NewLC();
	
	CSession2* NewSessionL(const TVersion& aVersion, const RMessage2& aMessage) const;

	TInt NewSession();
	void DropSession();
	void BeginShutdownL();
	void JoinMulticastGroupL(TInetAddr& aMulticastAddr);
	RSocket& Socket();
	CMessageHandler& MessageHandler()const;
	void NotifyClientQuery(TInt aClientHandle);
	void NotifyServicePublishL(const RBuf8& aName,TInt aError, TInt aSessionId);
	~CMdnsServer();
	TDesC8& HostName()const;
	void SetHostNameL(const TDesC8& aName);
	void SetStateHostProbing(TBool aProbing);
	void SetPublishingService(TBool aFlag);
	TBool IsHostProbing()const;
	TBool IsPublishingService() const;
	void ProcessQueuedMessage(const RMessage2& aMessage, const TMessageType aType,TInt aSessionId);
	void NotifyNewServiceL(const RArray<RBuf8>& aName);
	CInternalMessageQueue* MessageQueue();
    //From MMessageHandler
    void OnPacketSendL(TInt aError);        

	
private:
    TInt GetLocalHost ( TSockAddr& aAddr );
	CMdnsServer();
	void ConstructL();
	
	
	
private:
	RSocketServ iSockServ;
	RConnection iConnection;
	RSocket iSocket;

	CShutdownTimer* iShutdownTimer;
	CMessageHandler* iMessageHandler;
	CInternalMessageQueue* iInternalMessageQueue;
	CMDNSCacheConsistencyMgr* iCacheConsistencyMgr;
	TInt iConnectionCount;
	TInt iSessionIdCounter;
	TBool iShutdownInProgress;
	CMDNSProbeManager* iProbeManager;
	RBuf8 iHostName;
	TBool iData;
	TBool iIsHostProbing;
	TBool iIsPublishing;
	/**
	    *FLOGGER debug trace member variable.
	    */
	    __FLOG_DECLARATION_MEMBER_MUTABLE;
	};

#endif /* __MDNSSERVER_H__ */