/* -*- Mode: C ; c-basic-offset: 2 -*- */
/*****************************************************************************
 *
 *   This file is part of lv2dynparam plugin library
 *
 *   Copyright (C) 2006,2007,2008,2009 Nedko Arnaudov <nedko@arnaudov.name>
 *
 *   This program is free software; you can redistribute it and/or modify
 *   it under the terms of the GNU General Public License as published by
 *   the Free Software Foundation; version 2 of the License
 *
 *   This program is distributed in the hope that it will be useful,
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *   GNU General Public License for more details.
 *
 *   You should have received a copy of the GNU General Public License
 *   along with this program; if not, write to the Free Software
 *   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
 *
 *****************************************************************************/

#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include <stdbool.h>
#include <lv2.h>

#include "../lv2dynparam.h"
#include "../lv2_rtmempool.h"
#include "plugin.h"
#include "../list.h"
#include "../memory_atomic.h"
#include "internal.h"
//#define LOG_LEVEL LOG_LEVEL_DEBUG
#include "../log.h"

static struct lv2dynparam_plugin_callbacks g_lv2dynparam_plugin_callbacks =
{
  .host_attach = lv2dynparam_plugin_host_attach,

  .group_get_name = lv2dynparam_plugin_group_get_name,

  .parameter_get_type_uri = lv2dynparam_plugin_parameter_get_type_uri,
  .parameter_get_name = lv2dynparam_plugin_parameter_get_name,
  .parameter_get_value = lv2dynparam_plugin_parameter_get_value,
  .parameter_get_range = lv2dynparam_plugin_parameter_get_range,
  .parameter_change = lv2dynparam_plugin_parameter_change
};

static struct list_head g_instances;

void lv2dynparam_plugin_initialise() __attribute__((constructor));
void lv2dynparam_plugin_initialise()
{
  LOG_DEBUG("lv2dynparam_plugin_initialise() called");
  INIT_LIST_HEAD(&g_instances);
}

const void *
get_lv2dynparam_plugin_extension_data(void)
{
  return &g_lv2dynparam_plugin_callbacks;
}

bool
lv2dynparam_plugin_instantiate(
  LV2_Handle lv2instance,
  const LV2_Feature * const * host_features_ptr_ptr,
  const char * root_group_name,
  lv2dynparam_plugin_instance * instance_handle_ptr)
{
  bool ret;
  struct lv2dynparam_plugin_instance * instance_ptr;
  struct lv2_rtsafe_memory_pool_provider * rtmempool_ptr;

  rtmempool_ptr = NULL;

  while (*host_features_ptr_ptr)
  {
    LOG_DEBUG("Host feature <%s> detected", (*host_features_ptr_ptr)->URI);

    if (strcmp((*host_features_ptr_ptr)->URI, LV2_RTSAFE_MEMORY_POOL_URI) == 0)
    {
      rtmempool_ptr = (*host_features_ptr_ptr)->data;
    }

    host_features_ptr_ptr++;
  }

  if (rtmempool_ptr == NULL)
  {
    LOG_ERROR(LV2_RTSAFE_MEMORY_POOL_URI " extension is required");
    ret = false;
    goto exit;
  }

  instance_ptr = malloc(sizeof(struct lv2dynparam_plugin_instance));
  if (instance_ptr == NULL)
  {
    ret = false;
    goto exit;
  }

  if (!rtsafe_memory_init(
        rtmempool_ptr,
        4 * 1024,
        20,
        100,
        &instance_ptr->memory))
  {
    ret = false;
    goto free_instance;
  }

  if (!rtsafe_memory_pool_create(
        rtmempool_ptr,
        "plugin groups",
        sizeof(struct lv2dynparam_plugin_group),
        10,
        100,
        &instance_ptr->groups_pool))
  {
    ret = false;
    goto free_uninit_memory;
  }

  if (!rtsafe_memory_pool_create(
        rtmempool_ptr,
        "plugin parameters",
        sizeof(struct lv2dynparam_plugin_parameter),
        10,
        100,
        &instance_ptr->parameters_pool))
  {
    ret = false;
    goto free_destroy_groups_pool;
  }

  instance_ptr->lv2instance = lv2instance;

  if (!lv2dynparam_plugin_group_init(
        instance_ptr,
        &instance_ptr->root_group,
        NULL,
        NULL,
        root_group_name))
  {
    ret = false;
    goto free_destroy_parameters_pool;
  }

  list_add_tail(&instance_ptr->siblings, &g_instances);

  instance_ptr->host_callbacks = NULL;

  instance_ptr->pending = 0;

  *instance_handle_ptr = instance_ptr;

  ret = true;
  goto exit;

free_destroy_parameters_pool:

free_destroy_groups_pool:

free_uninit_memory:

free_instance:
  free(instance_ptr);

exit:
  return ret;
}

unsigned char
lv2dynparam_plugin_host_attach(
  LV2_Handle instance,
  struct lv2dynparam_host_callbacks * host_callbacks,
  void * instance_host_context)
{
  struct lv2dynparam_plugin_instance * instance_ptr;
  struct list_head * node_ptr;

  list_for_each(node_ptr, &g_instances)
  {
    instance_ptr = list_entry(node_ptr, struct lv2dynparam_plugin_instance, siblings);
    if (instance_ptr->lv2instance == instance)
    {
      goto instance_found;
    }
  }

  return false;

instance_found:
  instance_ptr->host_callbacks = host_callbacks;
  instance_ptr->host_context = instance_host_context;

  //LOG_DEBUG("lv2dynparam_plugin_host_attach(): instance_ptr->pending is %u", instance_ptr->pending);
  //if (instance_ptr->pending != 0) /* optimization */
  {
    lv2dynparam_plugin_group_notify(instance_ptr, &instance_ptr->root_group);
  }

  /* switch to atomic memory mode */
  rtsafe_memory_atomic(instance_ptr->memory);
  rtsafe_memory_pool_atomic(instance_ptr->groups_pool);
  rtsafe_memory_pool_atomic(instance_ptr->parameters_pool);

  return true;
}

#define instance_ptr ((struct lv2dynparam_plugin_instance *)instance_handle)

void
lv2dynparam_plugin_cleanup(
  lv2dynparam_plugin_instance instance_handle)
{
  list_del(&instance_ptr->siblings);
  lv2dynparam_plugin_group_clean(instance_ptr, &instance_ptr->root_group);
  rtsafe_memory_pool_destroy(instance_ptr->parameters_pool);
  rtsafe_memory_pool_destroy(instance_ptr->groups_pool);
  rtsafe_memory_uninit(instance_ptr->memory);
  free(instance_ptr);
}