/*

* Copyright (c) 1995-2009 Nokia Corporation and/or its subsidiary(-ies).

* 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:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description: 

*

*/

#include <new>

#include <queue>

#include <iostream>

#include <fstream>

#include <filesystem.hpp>

#include <thread/thread.hpp>

#include <thread/condition_variable.hpp>

#include "cache/cacheexception.hpp"

#include "cache/cacheentry.hpp"

#include "cache/cacheablelist.hpp"

#include "cache/cachegenerator.hpp"

using namespace std ;

CacheGenerator* CacheGenerator::Only = (CacheGenerator*)0;

CacheGenerator* CacheGenerator::GetInstance(void) throw (CacheException)

{

	if(! CacheGenerator::Only)

	{

		CacheGenerator::Only = new (nothrow) CacheGenerator();

		if(! CacheGenerator::Only)

			throw CacheException(CacheException::RESOURCE_ALLOCATION_FAILURE);

	}

	return CacheGenerator::Only;

}

void CacheGenerator::ProcessFiles(void) throw (CacheException)

{

	while(1)

	{

		//pick one entry from the CacheableList.

		CacheEntry* entryref = CacheableList::GetInstance()->GetCacheable();

		if(! entryref->GetCachedFileBuffer())

			break;

		//write cacheable content into the cache.

		boost::filesystem::path filepath(entryref->GetCachedFilename());

		string filename = filepath.file_string(); 	

		ofstream fileref(filename.c_str(), ios_base::binary | ios_base::out | ios_base::trunc);

		if(! fileref.is_open())

		{

			printf("Cannot write/update cached %s\r\n", filepath.file_string().c_str());

			continue;

		}

		fileref.write(entryref->GetCachedFileBuffer(), entryref->GetCachedFileBufferLen());

		fileref.close();

	}

	return;

}

CacheGenerator::CacheGenerator(void) :  boost::thread(ProcessFiles)

{

	return;

}