/*
 * Copyright 2002 Marcus Overhagen. All Rights Reserved.
 * This file may be used under the terms of the MIT License.
 */


/*!	This works like a cache for time source objects, to make sure
	each team only has one object representation for each time source.
*/


#include "TimeSourceObjectManager.h"

#include <stdio.h>

#include <Autolock.h>
#include <MediaRoster.h>

#include <MediaDebug.h>
#include <MediaMisc.h>

#include "TimeSourceObject.h"


namespace BPrivate {
namespace media {


TimeSourceObjectManager* gTimeSourceObjectManager;
	// initialized by BMediaRoster.


TimeSourceObjectManager::TimeSourceObjectManager()
	:
	BLocker("time source object manager")
{
}


TimeSourceObjectManager::~TimeSourceObjectManager()
{
	CALLED();

	// force unloading all currently loaded time sources
	NodeMap::iterator iterator = fMap.begin();
	for (; iterator != fMap.end(); iterator++) {
		BTimeSource* timeSource = iterator->second;

		PRINT(1, "Forcing release of TimeSource id %ld...\n", timeSource->ID());
		int32 debugCount = 0;
		while (timeSource->Release() != NULL)
			debugCount++;

		PRINT(1, "Forcing release of TimeSource done, released %d times\n",
			debugCount);
	}
}


/*!	BMediaRoster::MakeTimeSourceFor does use this function to request
	a time source object. If it is already in memory, it will be
	Acquired(), if not, a new TimeSourceObject will be created.
*/
BTimeSource*
TimeSourceObjectManager::GetTimeSource(const media_node& node)
{
	CALLED();
	BAutolock _(this);

	PRINT(1, "TimeSourceObjectManager::GetTimeSource, node id %ld\n",
		node.node);

	NodeMap::iterator found = fMap.find(node.node);
	if (found != fMap.end())
		return dynamic_cast<BTimeSource*>(found->second->Acquire());

	// time sources are not accounted in node reference counting
	BTimeSource* timeSource = new(std::nothrow) TimeSourceObject(node);
	if (timeSource == NULL)
		return NULL;

	fMap.insert(std::make_pair(node.node, timeSource));
	return timeSource;
}


/*!	This function is called during deletion of the time source object.
*/
void
TimeSourceObjectManager::ObjectDeleted(BTimeSource* timeSource)
{
	CALLED();
	BAutolock _(this);

	PRINT(1, "TimeSourceObjectManager::ObjectDeleted, node id %ld\n",
		timeSource->ID());

	fMap.erase(timeSource->ID());

	status_t status = BMediaRoster::Roster()->ReleaseNode(timeSource->Node());
	if (status != B_OK) {
		ERROR("TimeSourceObjectManager::ObjectDeleted, ReleaseNode failed\n");
	}
}


}	// namespace media
}	// namespace BPrivate