/*
 * CallWeaver -- An open source telephony toolkit.
 *
 * Copyright (C) 2007, Eris Associates Ltd, UK
 *
 * Mike Jagdis <mjagdis@eris-associates.co.uk>
 *
 * See http://www.callweaver.org for more information about
 * the CallWeaver project. Please do not directly contact
 * any of the maintainers of this project for assistance;
 * the project provides a web site, mailing lists and IRC
 * channels for your use.
 *
 * This program is free software, distributed under the terms of
 * the GNU General Public License Version 2. See the LICENSE file
 * at the top of the source tree.
 */

/*! \file
 *
 * \brief Registry API
 * 
 */
#ifdef HAVE_CONFIG_H
#include "confdefs.h"
#endif

#include <errno.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <signal.h>

#include "callweaver.h"

CALLWEAVER_FILE_VERSION("$HeadURL$", "$Revision$")

#include "callweaver/lock.h"
#include "callweaver/options.h"
#include "callweaver/object.h"
#include "callweaver/registry.h"
#include "callweaver/logger.h"
#include "callweaver/utils.h"


static void registry_purge(struct cw_registry *registry)
{
	struct cw_list *list;

	cw_mutex_lock(&registry->lock);
	list = registry->list.del;
	registry->list.del = NULL;
	cw_mutex_unlock(&registry->lock);

	while (list) {
		struct cw_registry_entry *entry = container_of(list, struct cw_registry_entry, list);
		list = list->del;
		if (cw_object_put_obj(entry->obj) && option_verbose > 1)
			cw_verbose(VERBOSE_PREFIX_2 "Registry %s: purged %s\n", registry->name, registry->obj_name(entry->obj));
		free(entry);
	}
}

struct cw_registry_entry *cw_registry_add(struct cw_registry *registry, struct cw_object *obj)
{
	struct cw_registry_entry *entry = malloc(sizeof(*entry));

	if (entry) {
		cw_list_init(&entry->list);
		entry->obj = cw_object_get_obj(obj);

		cw_mutex_lock(&registry->lock);
		cw_list_add(&registry->list, &entry->list);
		cw_mutex_unlock(&registry->lock);

		if (option_verbose > 1)
			cw_verbose(VERBOSE_PREFIX_2 "Registry %s: registered %s\n", registry->name, registry->obj_name(entry->obj));

		if (registry->onchange)
			registry->onchange();
	} else {
		cw_log(CW_LOG_ERROR, "Out of memory\n");
	}

	return entry;
}

int cw_registry_del(struct cw_registry *registry, struct cw_registry_entry *entry)
{
	atomic_inc(&registry->inuse);

	cw_mutex_lock(&registry->lock);
	cw_list_del(&registry->list, &entry->list);
	cw_mutex_unlock(&registry->lock);

	if (option_verbose > 1 && entry->obj)
		cw_verbose(VERBOSE_PREFIX_2 "Registry %s: unregistered %s\n", registry->name, registry->obj_name(entry->obj));

	if (registry->onchange)
		registry->onchange();

	if (atomic_dec_and_test(&registry->inuse))
		registry_purge(registry);

	return 0;
}


int cw_registry_iterate(struct cw_registry *registry, int (*func)(struct cw_object *, void *), void *data)
{
	struct cw_list *list;
	struct cw_registry_entry *entry;
	int ret = 0;

	atomic_inc(&registry->inuse);

	cw_list_for_each(list, &registry->list) {
		entry = container_of(list, struct cw_registry_entry, list);
		if ((ret = func(entry->obj, data)))
			break;
	}

	if (atomic_dec_and_test(&registry->inuse))
		registry_purge(registry);

	return ret;
}


struct cw_object *cw_registry_find(struct cw_registry *registry, const void *pattern)
{
	struct cw_object *obj = NULL;

	if (registry->obj_match) {
		struct cw_list *list;

		atomic_inc(&registry->inuse);

		cw_list_for_each(list, &registry->list) {
			struct cw_registry_entry *entry = container_of(list, struct cw_registry_entry, list);
			if (registry->obj_match(entry->obj, pattern)) {
				obj = cw_object_dup_obj(entry->obj);
				break;
			}
		}

		if (atomic_dec_and_test(&registry->inuse))
			registry_purge(registry);
	}

	return obj;
}


void cw_registry_init(struct cw_registry *registry)
{
	cw_mutex_init(&registry->lock);
	cw_list_init(&registry->list);
	atomic_set(&registry->inuse, 0);
}