[lttv.git] / lttv / modules / gui / lttvwindow / lttvwindow / lttvwindowtraces.c

/* This file is part of the Linux Trace Toolkit Graphic User Interface
 * Copyright (C) 2003-2004 Mathieu Desnoyers
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License Version 2 as
 * published by the Free Software Foundation;
 *
 * 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., 59 Temple Place - Suite 330, Boston, 
 * MA 02111-1307, USA.
 */

/* This file is the API used to launch any background computation on a trace */

/* Here is the implementation of the API */

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <string.h>
#include <inttypes.h>

#include <ltt/time.h>
#include <ltt/trace.h>
#include <glib.h>
#include <lttv/lttv.h>
#include <lttv/traceset.h>
#include <lttv/attribute.h>
#include <lttv/tracecontext.h>
#include <lttvwindow/lttvwindowtraces.h>
#include <lttvwindow/lttvwindow.h> // for CHUNK_NUM_EVENTS
#include <lttvwindow/mainwindow-private.h> /* for main window structure */

extern GSList * g_main_window_list;

typedef struct _BackgroundRequest {
  LttvAttributeName module_name; /* Hook path in global attributes,
                                    where all standard hooks under computation/.
                                    i.e. modulename */
  LttvTrace *trace; /* trace concerned */
  GtkWidget *dialog;  /* Dialog linked with the request, may be NULL */
  GtkWidget *parent_window; /* Parent window the dialog must be transient for */
} BackgroundRequest;

typedef struct _BackgroundNotify {
  gpointer                     owner;
  LttvTrace                   *trace; /* trace */
  LttTime                      notify_time;
  LttvTracesetContextPosition *notify_position;
  LttvHooks                   *notify; /* Hook to call when the notify is
                                          passed, or at the end of trace */
} BackgroundNotify;


/* Prototypes */
gboolean lttvwindowtraces_process_pending_requests(LttvTrace *trace);

/* Get a trace by its path name. 
 *
 * @param path path of the trace on the virtual file system.
 * @return Pointer to trace if found
 *         NULL is returned if the trace is not present
 */

__EXPORT LttvTrace *lttvwindowtraces_get_trace_by_name(gchar *path)
{
  guint i;

  for(i=0;i<lttvwindowtraces_get_number();i++) {
    LttvTrace *trace_v = lttvwindowtraces_get_trace(i);
    LttTrace *trace;
    const gchar *name;
    g_assert(trace_v != NULL);

    trace = lttv_trace(trace_v);
    g_assert(trace != NULL);
    name = g_quark_to_string(ltt_trace_name(trace));

    if(strcmp(name, path) == 0) {
      /* Found */
      return trace_v;
    }
  }
  
  return NULL;
}

/* Get a trace by its number identifier */

__EXPORT LttvTrace *lttvwindowtraces_get_trace(guint num)
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *attribute;
  LttvAttributeType type;
  LttvAttributeName name;
  LttvAttributeValue value;
	gboolean is_named;

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_TRACES));
  g_assert(attribute);
  
  type = lttv_iattribute_get(LTTV_IATTRIBUTE(attribute), num, &name, &value,
			&is_named);

  if(type == LTTV_POINTER) {
    return (LttvTrace *)*(value.v_pointer);
  }

  return NULL;
}

/* Total number of traces */

__EXPORT guint lttvwindowtraces_get_number()
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *attribute;

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_TRACES));
  g_assert(attribute);
 
  return ( lttv_iattribute_get_number(LTTV_IATTRIBUTE(attribute)) );
}

/* Add a trace to the global attributes */

void lttvwindowtraces_add_trace(LttvTrace *trace)
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *attribute;
  LttvAttributeValue value;
  struct stat buf;
  gchar attribute_path[PATH_MAX];
  int result;
  gboolean result_b;

  if(stat(g_quark_to_string(ltt_trace_name(lttv_trace(trace))), &buf)) {
    g_warning("lttvwindowtraces_add_trace: Trace %s not found",
        g_quark_to_string(ltt_trace_name(lttv_trace(trace))));
    return;
  }
  result = snprintf(attribute_path, PATH_MAX, "%" PRIu64 ":%" PRIu64,
		    buf.st_dev, buf.st_ino);
  g_assert(result >= 0);
  
  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_TRACES));
  g_assert(attribute);
    
  value = lttv_attribute_add(attribute,
                     g_quark_from_string(attribute_path),
                     LTTV_POINTER);

  *(value.v_pointer) = (gpointer)trace;
  
  /* create new traceset and tracesetcontext */
  LttvTraceset *ts;
  LttvTracesetStats *tss;
  //LttvTracesetContextPosition *sync_position;
  
  attribute = lttv_trace_attribute(trace);
  result_b = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_COMPUTATION_TRACESET,
                                LTTV_POINTER,
                                &value);
  g_assert(result_b);

  ts = lttv_traceset_new();
  *(value.v_pointer) = ts;
 
  lttv_traceset_add(ts,trace);

  result_b = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_COMPUTATION_TRACESET_CONTEXT,
                                LTTV_POINTER,
                                &value);
  g_assert(result_b);

  tss = g_object_new(LTTV_TRACESET_STATS_TYPE, NULL);
  *(value.v_pointer) = tss;
  
  lttv_context_init(LTTV_TRACESET_CONTEXT(tss), ts);
#if 0
  result_b = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_COMPUTATION_SYNC_POSITION,
                                LTTV_POINTER,
                                &value);
  g_assert(result_b);

  sync_position = lttv_traceset_context_position_new();
  *(value.v_pointer) = sync_position;
#endif //0
  value = lttv_attribute_add(attribute,
                     LTTV_REQUESTS_QUEUE,
                     LTTV_POINTER);

  value = lttv_attribute_add(attribute,
                     LTTV_REQUESTS_CURRENT,
                     LTTV_POINTER);
 
  value = lttv_attribute_add(attribute,
                     LTTV_NOTIFY_QUEUE,
                     LTTV_POINTER);
  
  value = lttv_attribute_add(attribute,
                     LTTV_NOTIFY_CURRENT,
                     LTTV_POINTER);
}

/* Remove a trace from the global attributes */

void lttvwindowtraces_remove_trace(LttvTrace *trace)
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *attribute;
  LttvAttributeValue value;
  guint i;
  gboolean result;

  attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_TRACES));
  g_assert(attribute);

  for(i=0;i<lttvwindowtraces_get_number();i++) {
    LttvTrace *trace_v = lttvwindowtraces_get_trace(i);
    
    g_assert(trace_v != NULL);

    /* Remove and background computation that could be in progress */
    g_idle_remove_by_data(trace_v);
    
    if(trace_v == trace) {
      /* Found */
      LttvAttribute *l_attribute;

      /* destroy traceset and tracesetcontext */
      LttvTraceset *ts;
      LttvTracesetStats *tss;
      //LttvTracesetContextPosition *sync_position;
      
      l_attribute = lttv_trace_attribute(trace);


      lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(l_attribute),
                                     LTTV_REQUESTS_QUEUE);

      lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(l_attribute),
                                     LTTV_REQUESTS_CURRENT);

      lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(l_attribute),
                                     LTTV_NOTIFY_QUEUE);

      lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(l_attribute),
                                     LTTV_NOTIFY_CURRENT);

      result = lttv_iattribute_find(LTTV_IATTRIBUTE(l_attribute),
                                    LTTV_COMPUTATION_TRACESET,
                                    LTTV_POINTER,
                                    &value);
      g_assert(result);

      ts = (LttvTraceset*)*(value.v_pointer);
#if 0   
      result = lttv_iattribute_find(LTTV_IATTRIBUTE(l_attribute),
                                    LTTV_COMPUTATION_SYNC_POSITION,
                                    LTTV_POINTER,
                                    &value);
      g_assert(result);

      sync_position = (LttvTracesetContextPosition*)*(value.v_pointer);
      lttv_traceset_context_position_destroy(sync_position);
      
      lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(l_attribute),
                                     LTTV_COMPUTATION_SYNC_POSITION);

#endif //0
      result = lttv_iattribute_find(LTTV_IATTRIBUTE(l_attribute),
                                    LTTV_COMPUTATION_TRACESET_CONTEXT,
                                    LTTV_POINTER,
                                    &value);
      g_assert(result);

      tss = (LttvTracesetStats*)*(value.v_pointer);
      
      lttv_context_fini(LTTV_TRACESET_CONTEXT(tss));
      g_object_unref(tss);
      lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(l_attribute),
                                     LTTV_COMPUTATION_TRACESET_CONTEXT);
      lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(l_attribute),
                                     LTTV_COMPUTATION_TRACESET);
      /* Destroy the traceset and the trace also */
      lttv_traceset_destroy(ts);

      /* finally, remove the global attribute */
      lttv_attribute_remove(attribute, i);

      return;
    }
  }
}

static void destroy_dialog(BackgroundRequest *bg_req)
{
  gtk_widget_destroy(bg_req->dialog);
  bg_req->dialog = NULL;
}


/**
 * Function to request data from a specific trace
 *
 * The memory allocated for the request will be managed by the API.
 * 
 * @param widget the current Window
 * @param trace the trace to compute
 * @param module_name the name of the module which registered global computation
 *                    hooks.
 */

__EXPORT void lttvwindowtraces_background_request_queue
                     (GtkWidget *widget, LttvTrace *trace, gchar *module_name)
{
  BackgroundRequest *bg_req;
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *module_attribute;
  LttvAttributeValue value;
  LttvAttributeType type;
  GSList **slist;
  gboolean result;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_REQUESTS_QUEUE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  slist = (GSList**)(value.v_pointer);

  /* Verify that the calculator is loaded */
  module_attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_COMPUTATION));
  g_assert(module_attribute);

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     g_quark_from_string(module_name),
                                     &value);
  if(type == LTTV_NONE) {
    g_critical("Missing background calculator %s", module_name);
    return;
  }

  bg_req = g_new(BackgroundRequest,1);
  bg_req->module_name = g_quark_from_string(module_name);
  bg_req->trace = trace;

  *slist = g_slist_append(*slist, bg_req);

  /* Priority lower than live servicing */
  g_idle_remove_by_data(trace);
  g_idle_add_full((G_PRIORITY_HIGH_IDLE + 23),
                  (GSourceFunc)lttvwindowtraces_process_pending_requests,
                  trace,
                  NULL);
  /* FIXME : show message in status bar, need context and message id */
  g_info("Background computation for %s started for trace %p", module_name,
      trace);
  GtkWidget *dialog = 
    gtk_message_dialog_new(
      GTK_WINDOW(widget),
      GTK_DIALOG_DESTROY_WITH_PARENT,
      GTK_MESSAGE_INFO, GTK_BUTTONS_OK, 
      "Background computation for %s started for trace %s", 
      module_name,
      g_quark_to_string(ltt_trace_name(lttv_trace(trace))));
  gtk_window_set_transient_for(GTK_WINDOW(dialog), GTK_WINDOW(widget));
  g_signal_connect_swapped (dialog, "response",
      G_CALLBACK (destroy_dialog),
      bg_req);
  bg_req->dialog = dialog;
  /* the parent window might vanish : only use this pointer for a 
   * comparison with existing windows */
  bg_req->parent_window = gtk_widget_get_toplevel(widget);
  gtk_widget_show(dialog);
}

/**
 * Remove a background request from a trace.
 *
 * This should ONLY be used by the modules which registered the global hooks
 * (module_name). If this is called by the viewers, it may lead to incomplete
 * and incoherent background processing information.
 *
 * Even if the module which deals with the hooks removes the background
 * requests, it may cause a problem if the module gets loaded again in the
 * session : the data will be partially calculated. The calculation function
 * must deal with this case correctly.
 * 
 * @param trace the trace to compute
 * @param module_name the name of the module which registered global computation
 *                    hooks.
 */

void lttvwindowtraces_background_request_remove
                     (LttvTrace *trace, gchar *module_name)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttributeValue value;
  GSList *iter = NULL;
  GSList **slist;
  gboolean result;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_REQUESTS_QUEUE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  slist = (GSList**)(value.v_pointer);

  for(iter=*slist;iter!=NULL;) {
    BackgroundRequest *bg_req = 
              (BackgroundRequest *)iter->data;

    if(bg_req->module_name == g_quark_from_string(module_name)) {
      GSList *rem_iter = iter;
      iter=g_slist_next(iter);
      g_free(bg_req); 
      *slist = g_slist_delete_link(*slist, rem_iter);
    } else {
      iter=g_slist_next(iter);
    }
  }
}
 
/**
 * Find a background request in a trace
 *
 */

__EXPORT gboolean lttvwindowtraces_background_request_find
                     (LttvTrace *trace, gchar *module_name)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttributeValue value;
  GSList *iter = NULL;
  GSList **slist;
  gboolean result;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_REQUESTS_QUEUE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  slist = (GSList**)(value.v_pointer);

  for(iter=*slist;iter!=NULL;) {
    BackgroundRequest *bg_req = 
              (BackgroundRequest *)iter->data;

    if(bg_req->module_name == g_quark_from_string(module_name)) {
      return TRUE;
    } else {
      iter=g_slist_next(iter);
    }
  }
  return FALSE;
}
 
/**
 * Register a callback to be called when requested data is passed in the next
 * queued background processing.
 * 
 * @param owner owner of the background notification
 * @param trace the trace computed
 * @param notify_time time when notification hooks must be called
 * @param notify_position position when notification hooks must be called
 * @param notify  Hook to call when the notify position is passed
 */

__EXPORT void lttvwindowtraces_background_notify_queue
 (gpointer                     owner,
  LttvTrace                   *trace,
  LttTime                      notify_time,
  const LttvTracesetContextPosition *notify_position,
  const LttvHooks                   *notify)
{
  BackgroundNotify *bg_notify;
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttributeValue value;
  GSList **slist;
  gboolean result;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_NOTIFY_QUEUE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  slist = (GSList**)(value.v_pointer);
 
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_COMPUTATION_TRACESET_CONTEXT,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvTracesetContext *tsc = (LttvTracesetContext*)(value.v_pointer);

  bg_notify = g_new(BackgroundNotify,1);

  bg_notify->owner = owner;
  bg_notify->trace = trace;
  bg_notify->notify_time = notify_time;
  if(notify_position != NULL) {
    bg_notify->notify_position = lttv_traceset_context_position_new(tsc);
    lttv_traceset_context_position_copy(bg_notify->notify_position,
                                        notify_position);
  } else {
    bg_notify->notify_position = NULL;
  }

  bg_notify->notify = lttv_hooks_new();
  lttv_hooks_add_list(bg_notify->notify, notify);

  *slist = g_slist_append(*slist, bg_notify);
}

/**
 * Register a callback to be called when requested data is passed in the current
 * background processing.
 * 
 * @param owner owner of the background notification
 * @param trace the trace computed
 * @param notify_time time when notification hooks must be called
 * @param notify_position position when notification hooks must be called
 * @param notify  Hook to call when the notify position is passed
 */

__EXPORT void lttvwindowtraces_background_notify_current
 (gpointer                     owner,
  LttvTrace                   *trace,
  LttTime                      notify_time,
  const LttvTracesetContextPosition *notify_position,
  const LttvHooks                   *notify)
{
  BackgroundNotify *bg_notify;
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttributeValue value;
  GSList **slist;
  gboolean result;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_NOTIFY_CURRENT,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  slist = (GSList**)(value.v_pointer);

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_COMPUTATION_TRACESET_CONTEXT,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvTracesetContext *tsc = (LttvTracesetContext*)(value.v_pointer);


  bg_notify = g_new(BackgroundNotify,1);

  bg_notify->owner = owner;
  bg_notify->trace = trace;
  bg_notify->notify_time = notify_time;
  if(notify_position!= NULL) {
    bg_notify->notify_position = lttv_traceset_context_position_new(tsc);
    lttv_traceset_context_position_copy(bg_notify->notify_position,
                                        notify_position);
  } else {
    bg_notify->notify_position = NULL;
  }
  bg_notify->notify = lttv_hooks_new();
  lttv_hooks_add_list(bg_notify->notify, notify);

  *slist = g_slist_append(*slist, bg_notify);
}


static void notify_request_free(BackgroundNotify *notify_req)
{
  if(notify_req == NULL) return;

  if(notify_req->notify_position != NULL)
    lttv_traceset_context_position_destroy(notify_req->notify_position);
  if(notify_req->notify != NULL)
    lttv_hooks_destroy(notify_req->notify);
  g_free(notify_req);
}

/**
 * Removes all the notifications requests from a specific viewer.
 * 
 * @param owner owner of the background notification
 */

__EXPORT void lttvwindowtraces_background_notify_remove(gpointer owner)
{
  guint i;

  for(i=0;i<lttvwindowtraces_get_number();i++) {
    LttvAttribute *attribute;
    LttvAttributeValue value;
    LttvTrace *trace_v = lttvwindowtraces_get_trace(i);
    GSList **slist;
    GSList *iter = NULL;
    gboolean result;
    
    g_assert(trace_v != NULL);

    attribute = lttv_trace_attribute(trace_v);

    result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                  LTTV_NOTIFY_QUEUE,
                                  LTTV_POINTER,
                                  &value);
    g_assert(result);

    slist = (GSList**)(value.v_pointer);
 
    for(iter=*slist;iter!=NULL;) {
    
      BackgroundNotify *bg_notify = (BackgroundNotify*)iter->data;

      if(bg_notify->owner == owner) {
        GSList *rem_iter = iter;
        iter=g_slist_next(iter);
        notify_request_free(bg_notify);
        *slist = g_slist_remove_link(*slist, rem_iter);
      } else {
        iter=g_slist_next(iter);
      }
    }

    result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                  LTTV_NOTIFY_CURRENT,
                                  LTTV_POINTER,
                                  &value);
    g_assert(result);

    slist = (GSList**)(value.v_pointer);
 
    for(iter=*slist;iter!=NULL;) {
    
      BackgroundNotify *bg_notify = (BackgroundNotify*)iter->data;

      if(bg_notify->owner == owner) {
        GSList *rem_iter = iter;
        iter=g_slist_next(iter);
        notify_request_free(bg_notify);
        *slist = g_slist_remove_link(*slist, rem_iter);
      } else {
        iter=g_slist_next(iter);
      }
    }
  }
}


/* Background processing helper functions */

void lttvwindowtraces_add_computation_hooks(LttvAttributeName module_name,
                                            LttvTracesetContext *tsc,
                                            LttvHooks *hook_adder)
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *module_attribute;
  LttvAttributeType type;
  LttvAttributeValue value;

 
  module_attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_COMPUTATION));
  g_assert(module_attribute);

  module_attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(
                                LTTV_IATTRIBUTE(module_attribute),
                                module_name));
  g_assert(module_attribute);

  /* Call the module's hook adder */
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_HOOK_ADDER,
                                     &value);
  if(type == LTTV_POINTER) {
    //lttv_hooks_call((LttvHooks*)*(value.v_pointer), (gpointer)tss);
    if(hook_adder != NULL)
      lttv_hooks_add_list(hook_adder, (LttvHooks*)*(value.v_pointer));
  }
}
                                            
void lttvwindowtraces_remove_computation_hooks(LttvAttributeName module_name,
                                               LttvTracesetContext *tsc,
                                               LttvHooks *hook_remover)
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *module_attribute;
  LttvAttributeType type;
  LttvAttributeValue value;
 
  module_attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_COMPUTATION));
  g_assert(module_attribute);

  module_attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(
                                LTTV_IATTRIBUTE(module_attribute),
                                module_name));
  g_assert(module_attribute);

  /* Call the module's hook remover */
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_HOOK_REMOVER,
                                     &value);
  if(type == LTTV_POINTER) {
    //lttv_hooks_call((LttvHooks*)*(value.v_pointer), (gpointer)tss);
    if(hook_remover != NULL)
      lttv_hooks_add_list(hook_remover, (LttvHooks*)*(value.v_pointer));
  }
}

void lttvwindowtraces_call_before_chunk(LttvAttributeName module_name,
                                        LttvTracesetContext *tsc)
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *module_attribute;
  LttvAttributeType type;
  LttvAttributeValue value;
  LttvHooks *before_chunk_traceset=NULL;
  LttvHooks *before_chunk_trace=NULL;
  LttvHooks *before_chunk_tracefile=NULL;
  LttvHooks *event_hook=NULL;
  LttvHooksByIdChannelArray *event_hook_by_id_channel=NULL;

 
  module_attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_COMPUTATION));
  g_assert(module_attribute);

  module_attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(
                                LTTV_IATTRIBUTE(module_attribute),
                                module_name));
  g_assert(module_attribute);

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_BEFORE_CHUNK_TRACESET,
                                     &value);
  if(type == LTTV_POINTER) {
    before_chunk_traceset = (LttvHooks*)*(value.v_pointer);
  }

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_BEFORE_CHUNK_TRACE,
                                     &value);
  if(type == LTTV_POINTER) {
    before_chunk_trace = (LttvHooks*)*(value.v_pointer);
  }

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_BEFORE_CHUNK_TRACEFILE,
                                     &value);
  if(type == LTTV_POINTER) {
    before_chunk_tracefile = (LttvHooks*)*(value.v_pointer);
  }

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_EVENT_HOOK,
                                     &value);
  if(type == LTTV_POINTER) {
    event_hook = (LttvHooks*)*(value.v_pointer);
  }

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_EVENT_HOOK_BY_ID_CHANNEL,
                                     &value);
  if(type == LTTV_POINTER) {
    event_hook_by_id_channel = (LttvHooksByIdChannelArray*)*(value.v_pointer);
  }

  lttv_process_traceset_begin(tsc,
                              before_chunk_traceset,
                              before_chunk_trace,
                              before_chunk_tracefile,
                              event_hook,
                              event_hook_by_id_channel);
}


void lttvwindowtraces_call_after_chunk(LttvAttributeName module_name,
                                       LttvTracesetContext *tsc)
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *module_attribute;
  LttvAttributeType type;
  LttvAttributeValue value;
  LttvHooks *after_chunk_traceset=NULL;
  LttvHooks *after_chunk_trace=NULL;
  LttvHooks *after_chunk_tracefile=NULL;
  LttvHooks *event_hook=NULL;
  LttvHooksByIdChannelArray *event_hook_by_id_channel=NULL;
 
  module_attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_COMPUTATION));
  g_assert(module_attribute);

  module_attribute =
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(
                                LTTV_IATTRIBUTE(module_attribute),
                                module_name));
  g_assert(module_attribute);

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_AFTER_CHUNK_TRACESET,
                                     &value);
  if(type == LTTV_POINTER) {
    after_chunk_traceset = (LttvHooks*)*(value.v_pointer);
  }

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_AFTER_CHUNK_TRACE,
                                     &value);
  if(type == LTTV_POINTER) {
    after_chunk_trace = (LttvHooks*)*(value.v_pointer);
  }

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_AFTER_CHUNK_TRACEFILE,
                                     &value);
  if(type == LTTV_POINTER) {
    after_chunk_tracefile = (LttvHooks*)*(value.v_pointer);
  }

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_EVENT_HOOK,
                                     &value);
  if(type == LTTV_POINTER) {
    event_hook = (LttvHooks*)*(value.v_pointer);
  }

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                     LTTV_EVENT_HOOK_BY_ID_CHANNEL,
                                     &value);
  if(type == LTTV_POINTER) {
    event_hook_by_id_channel = (LttvHooksByIdChannelArray*)*(value.v_pointer);
  }
  
  lttv_process_traceset_end(tsc,
                            after_chunk_traceset,
                            after_chunk_trace,
                            after_chunk_tracefile,
                            event_hook,
                            event_hook_by_id_channel);

}


void lttvwindowtraces_set_in_progress(LttvAttributeName module_name,
                                      LttvTrace *trace)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(attribute),
                                module_name));
  g_assert(attribute);
 
  lttv_iattribute_add(LTTV_IATTRIBUTE(attribute),
		      LTTV_IN_PROGRESS,
		      LTTV_INT);
  /* the value is left unset. The only presence of the attribute is necessary.
   */
}

void lttvwindowtraces_unset_in_progress(LttvAttributeName module_name,
                                        LttvTrace *trace)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(attribute),
                                module_name));
  g_assert(attribute);
 
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                         LTTV_IN_PROGRESS);
}

__EXPORT gboolean lttvwindowtraces_get_in_progress(LttvAttributeName module_name,
                                          LttvTrace *trace)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttributeType type;
  LttvAttributeValue value;

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(attribute),
                                module_name));
  g_assert(attribute);
 
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_IN_PROGRESS,
                                     &value);
  /* The only presence of the attribute is necessary. */
  if(type == LTTV_NONE)
    return FALSE;
  else
    return TRUE;
}

void lttvwindowtraces_set_ready(LttvAttributeName module_name,
                                LttvTrace *trace)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(attribute),
                                module_name));
  g_assert(attribute);
 
  lttv_iattribute_add(LTTV_IATTRIBUTE(attribute),
		      LTTV_READY,
		      LTTV_INT);
  /* the value is left unset. The only presence of the attribute is necessary.
   */
}

void lttvwindowtraces_unset_ready(LttvAttributeName module_name,
                                  LttvTrace *trace)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(attribute),
                                module_name));
  g_assert(attribute);
 
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                         LTTV_READY);
}

__EXPORT gboolean lttvwindowtraces_get_ready(LttvAttributeName module_name,
                                    LttvTrace *trace)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttributeType type;
  LttvAttributeValue value;

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(attribute),
                                module_name));
  g_assert(attribute);
 
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_READY,
                                     &value);
  /* The only presence of the attribute is necessary. */
  if(type == LTTV_NONE)
    return FALSE;
  else
    return TRUE;
}

static gint find_window_widget(MainWindow *a, GtkWidget *b)
{
  if(a->mwindow == b) return 0;
  else return -1;
}


/* lttvwindowtraces_process_pending_requests
 *
 * Process the pending background computation requests
 * 
 * This internal function gets called by g_idle, taking care of the pending
 * requests.
 *
 */


gboolean lttvwindowtraces_process_pending_requests(LttvTrace *trace)
{
  LttvTracesetContext *tsc;
  LttvTracesetStats *tss;
  LttvTraceset *ts;
  //LttvTracesetContextPosition *sync_position;
  LttvAttribute *attribute;
  LttvAttribute *g_attribute = lttv_global_attributes();
  GSList **list_out, **list_in, **notify_in, **notify_out;
  LttvAttributeValue value;
  LttvAttributeType type;
  gboolean ret_val;

  if(trace == NULL)
    return FALSE;

  if(lttvwindow_preempt_count > 0) return TRUE;
   
  attribute = lttv_trace_attribute(trace);
  
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_REQUESTS_QUEUE,
                                     &value);
  g_assert(type == LTTV_POINTER);
  list_out = (GSList**)(value.v_pointer);

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_REQUESTS_CURRENT,
                                     &value);
  g_assert(type == LTTV_POINTER);
  list_in = (GSList**)(value.v_pointer);
 
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_NOTIFY_QUEUE,
                                     &value);
  g_assert(type == LTTV_POINTER);
  notify_out = (GSList**)(value.v_pointer);
  
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_NOTIFY_CURRENT,
                                     &value);
  g_assert(type == LTTV_POINTER);
  notify_in = (GSList**)(value.v_pointer);
 
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_COMPUTATION_TRACESET,
                                     &value);
  g_assert(type == LTTV_POINTER);
  ts = (LttvTraceset*)*(value.v_pointer);
 
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_COMPUTATION_TRACESET_CONTEXT,
                                     &value);
  g_assert(type == LTTV_POINTER);
  tsc = (LttvTracesetContext*)*(value.v_pointer);
  tss = (LttvTracesetStats*)*(value.v_pointer);
  g_assert(LTTV_IS_TRACESET_CONTEXT(tsc));
  g_assert(LTTV_IS_TRACESET_STATS(tss));
#if 0
  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_COMPUTATION_SYNC_POSITION,
                                     &value);
  g_assert(type == LTTV_POINTER);
  sync_position = (LttvTracesetContextPosition*)*(value.v_pointer);
#endif //0
  /* There is no events requests pending : we should never have been called! */
  g_assert(g_slist_length(*list_out) != 0 || g_slist_length(*list_in) != 0);
  /* 0.1 Lock traces */
  {
    guint iter_trace=0;
    
    for(iter_trace=0; 
        iter_trace<lttv_traceset_number(tsc->ts);
        iter_trace++) {
      LttvTrace *trace_v = lttv_traceset_get(tsc->ts,iter_trace);

      if(lttvwindowtraces_lock(trace_v) != 0)
        return TRUE; /* Cannot get trace lock, try later */

    }
  }
  /* 0.2 Sync tracefiles */
  //g_assert(lttv_process_traceset_seek_position(tsc, sync_position) == 0);
  lttv_process_traceset_synchronize_tracefiles(tsc);
  /* 1. Before processing */
  {
    /* if list_in is empty */
    if(g_slist_length(*list_in) == 0) {

      {
        /* - Add all requests in list_out to list_in, empty list_out */
        GSList *iter = *list_out;

        while(iter != NULL) {
          gboolean remove = FALSE;
          gboolean free_data = FALSE;

          BackgroundRequest *bg_req = (BackgroundRequest*)iter->data;

          remove = TRUE;
          free_data = FALSE;
          *list_in = g_slist_append(*list_in, bg_req);

          /* Go to next */
          if(remove)
          {
            GSList *remove_iter = iter;

            iter = g_slist_next(iter);
            if(free_data) g_free(remove_iter->data);
            *list_out = g_slist_remove_link(*list_out, remove_iter);
          } else { // not remove
            iter = g_slist_next(iter);
          }
        }
      }

      {
        GSList *iter = *list_in;
        /* - for each request in list_in */
        while(iter != NULL) {
          
          BackgroundRequest *bg_req = (BackgroundRequest*)iter->data;
          /* - set hooks'in_progress flag to TRUE */
          lttvwindowtraces_set_in_progress(bg_req->module_name,
                                           bg_req->trace);

          /* - call before request hook */
          /* Get before request hook */
          LttvAttribute *module_attribute;

          module_attribute =
              LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(
                                 LTTV_IATTRIBUTE(g_attribute),
                                 LTTV_COMPUTATION));
          g_assert(module_attribute);

          module_attribute =
              LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(
                                        LTTV_IATTRIBUTE(module_attribute),
                                        bg_req->module_name));
          g_assert(module_attribute);
          
          type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                             LTTV_BEFORE_REQUEST,
                                             &value);
          g_assert(type == LTTV_POINTER);
          LttvHooks *before_request = (LttvHooks*)*(value.v_pointer);
 
          if(before_request != NULL) lttv_hooks_call(before_request, tsc);
          
          iter = g_slist_next(iter);
        }
      }

      /* - seek trace to start */
      {
        LttTime start = { 0, 0};
        lttv_process_traceset_seek_time(tsc, start);
      }

      /* - Move all notifications from notify_out to notify_in. */
      {
        GSList *iter = *notify_out;
        g_assert(g_slist_length(*notify_in) == 0);

        while(iter != NULL) {
          gboolean remove = FALSE;
          gboolean free_data = FALSE;

          BackgroundNotify *notify_req = (BackgroundNotify*)iter->data;

          remove = TRUE;
          free_data = FALSE;
          *notify_in = g_slist_append(*notify_in, notify_req);

          /* Go to next */
          if(remove)
          {
            GSList *remove_iter = iter;

            iter = g_slist_next(iter);
            if(free_data) 
                 notify_request_free((BackgroundNotify*)remove_iter->data);
            *notify_out = g_slist_remove_link(*notify_out, remove_iter);
          } else { // not remove
            iter = g_slist_next(iter);
          }
        }
      }
      {
        GSList *iter = *list_in;
        LttvHooks *hook_adder = lttv_hooks_new();
        /* - for each request in list_in */
        while(iter != NULL) {
          
          BackgroundRequest *bg_req = (BackgroundRequest*)iter->data;
          /*- add hooks to context*/
          lttvwindowtraces_add_computation_hooks(bg_req->module_name,
                                                 tsc,
                                                 hook_adder);
          iter = g_slist_next(iter);
        }
        lttv_hooks_call(hook_adder,tsc);
        lttv_hooks_destroy(hook_adder);
      }


    }

    {
      GSList *iter = *list_in;
      /* - for each request in list_in */
      while(iter != NULL) {
        
        BackgroundRequest *bg_req = (BackgroundRequest*)iter->data;
        /*- Call before chunk hooks for list_in*/
        lttvwindowtraces_call_before_chunk(bg_req->module_name,
                                               tsc);
        iter = g_slist_next(iter);
      }
    }

  }
  /* 2. call process traceset middle for a chunk */
  {
    /*(assert list_in is not empty! : should not even be called in that case)*/
    LttTime end = ltt_time_infinite;
    g_assert(g_slist_length(*list_in) != 0);
    
    lttv_process_traceset_middle(tsc, end, CHUNK_NUM_EVENTS, NULL);
  }

  /* 3. After the chunk */
  {
    /*  3.1 call after_chunk hooks for list_in */
    {
      GSList *iter = *list_in;
      /* - for each request in list_in */
      while(iter != NULL) {
        
        BackgroundRequest *bg_req = (BackgroundRequest*)iter->data;
        /* - Call after chunk hooks for list_in */
        lttvwindowtraces_call_after_chunk(bg_req->module_name,
                                                  tsc);
        iter = g_slist_next(iter);
      }
    }

    /* 3.2 for each notify_in */
    {
      GSList *iter = *notify_in;
      LttvTracefileContext *tfc = lttv_traceset_context_get_current_tfc(tsc);
        
      while(iter != NULL) {
        gboolean remove = FALSE;
        gboolean free_data = FALSE;

        BackgroundNotify *notify_req = (BackgroundNotify*)iter->data;

        /* - if current time >= notify time, call notify and remove from
         * notify_in.
         * - if current position >= notify position, call notify and remove
         * from notify_in.
         */
        if( (tfc != NULL &&
              ltt_time_compare(notify_req->notify_time, tfc->timestamp) <= 0)
           ||
            (notify_req->notify_position != NULL && 
                     lttv_traceset_context_ctx_pos_compare(tsc,
                              notify_req->notify_position) >= 0)
           ) {

          lttv_hooks_call(notify_req->notify, notify_req);

          remove = TRUE;
          free_data = TRUE;
        }

        /* Go to next */
        if(remove)
        {
          GSList *remove_iter = iter;

          iter = g_slist_next(iter);
          if(free_data) 
               notify_request_free((BackgroundNotify*)remove_iter->data);
          *notify_in = g_slist_remove_link(*notify_in, remove_iter);
        } else { // not remove
          iter = g_slist_next(iter);
        }
      }
    }

    {
      LttvTracefileContext *tfc = lttv_traceset_context_get_current_tfc(tsc);
      /* 3.3 if end of trace reached */
      if(tfc != NULL)
        g_debug("Current time : %lu sec, %lu nsec",
            tfc->timestamp.tv_sec, tfc->timestamp.tv_nsec);
      if(tfc == NULL || ltt_time_compare(tfc->timestamp,
                         tsc->time_span.end_time) > 0) {

        {
          GSList *iter = *list_in;
          LttvHooks *hook_remover = lttv_hooks_new();
          /* - for each request in list_in */
          while(iter != NULL) {
            
            BackgroundRequest *bg_req = (BackgroundRequest*)iter->data;
            /* - remove hooks from context */
            lttvwindowtraces_remove_computation_hooks(bg_req->module_name,
                                                      tsc,
                                                      hook_remover);
            iter = g_slist_next(iter);
          }
          lttv_hooks_call(hook_remover,tsc);
          lttv_hooks_destroy(hook_remover);
        }
          
        /* - for each request in list_in */
        {
          GSList *iter = *list_in;
          
          while(iter != NULL) {
            gboolean remove = FALSE;
            gboolean free_data = FALSE;

            BackgroundRequest *bg_req = (BackgroundRequest*)iter->data;

            /* - set hooks'in_progress flag to FALSE */
            lttvwindowtraces_unset_in_progress(bg_req->module_name,
                                               bg_req->trace);
            /* - set hooks'ready flag to TRUE */
            lttvwindowtraces_set_ready(bg_req->module_name,
                                       bg_req->trace);
            /* - call after request hook */
            /* Get after request hook */
            LttvAttribute *module_attribute;

            module_attribute =
                LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(
                                   LTTV_IATTRIBUTE(g_attribute),
                                   LTTV_COMPUTATION));
            g_assert(module_attribute);

            module_attribute =
                LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(
                                          LTTV_IATTRIBUTE(module_attribute),
                                          bg_req->module_name));
	    g_assert(module_attribute);
            
            type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(module_attribute),
                                               LTTV_AFTER_REQUEST,
                                               &value);
            g_assert(type == LTTV_POINTER);
            LttvHooks *after_request = (LttvHooks*)*(value.v_pointer);
            {
              struct sum_traceset_closure t_closure;
	      t_closure.tss = (LttvTracesetStats*)tsc;
	      t_closure.current_time = ltt_time_infinite;
              if(after_request != NULL) lttv_hooks_call(after_request,
	        &t_closure);
            }
            
            if(bg_req->dialog != NULL)
              gtk_widget_destroy(bg_req->dialog);
            GtkWidget *parent_window;
            if(g_slist_find_custom(g_main_window_list,
                  bg_req->parent_window,
                  (GCompareFunc)find_window_widget))
              parent_window = GTK_WIDGET(bg_req->parent_window);
            else
              parent_window = NULL;

            GtkWidget *dialog = 
              gtk_message_dialog_new(GTK_WINDOW(parent_window),
                GTK_DIALOG_DESTROY_WITH_PARENT,
                GTK_MESSAGE_INFO, GTK_BUTTONS_OK, 
                "Background computation %s finished for trace %s", 
                g_quark_to_string(bg_req->module_name),
                g_quark_to_string(ltt_trace_name(lttv_trace(bg_req->trace))));
            if(parent_window != NULL)
              gtk_window_set_transient_for(GTK_WINDOW(dialog),
                  GTK_WINDOW(parent_window));
            g_signal_connect_swapped (dialog, "response",
                G_CALLBACK (gtk_widget_destroy),
                dialog);
            gtk_widget_show(dialog);

            /* - remove request */
            remove = TRUE;
            free_data = TRUE;

            /* Go to next */
            if(remove)
            {
              GSList *remove_iter = iter;

              iter = g_slist_next(iter);
              if(free_data) g_free(remove_iter->data);
              *list_in = g_slist_remove_link(*list_in, remove_iter);
            } else { // not remove
              iter = g_slist_next(iter);
            }
          }
        }

        /* - for each notifications in notify_in */
        {
          GSList *iter = *notify_in;
          
          while(iter != NULL) {
            gboolean remove = FALSE;
            gboolean free_data = FALSE;

            BackgroundNotify *notify_req = (BackgroundNotify*)iter->data;

            /* - call notify and remove from notify_in */
            lttv_hooks_call(notify_req->notify, notify_req);
            remove = TRUE;
            free_data = TRUE;

            /* Go to next */
            if(remove)
            {
              GSList *remove_iter = iter;

              iter = g_slist_next(iter);
              if(free_data) 
                    notify_request_free((BackgroundNotify*)remove_iter->data);
              *notify_in = g_slist_remove_link(*notify_in, remove_iter);
            } else { // not remove
              iter = g_slist_next(iter);
            }
          }
        }
        {
          /* - reset the context */
          LTTV_TRACESET_CONTEXT_GET_CLASS(tsc)->fini(tsc);
          LTTV_TRACESET_CONTEXT_GET_CLASS(tsc)->init(tsc,ts);
        }
        /* - if list_out is empty */
        if(g_slist_length(*list_out) == 0) {
          /* - return FALSE (scheduler stopped) */
          g_debug("Background computation scheduler stopped");
          g_info("Background computation finished for trace %p", trace);
          /* FIXME : remove status bar info, need context id and message id */

          ret_val = FALSE;
        } else {
          ret_val = TRUE;
        }
      } else {
        /* 3.4 else, end of trace not reached */
        /* - return TRUE (scheduler still registered) */
        g_debug("Background computation left");
        ret_val = TRUE;
      }
    }
  }
  /* 4. Unlock traces */
  {
    lttv_process_traceset_get_sync_data(tsc);
    //lttv_traceset_context_position_save(tsc, sync_position);
    guint iter_trace;
    
    for(iter_trace=0; 
        iter_trace<lttv_traceset_number(tsc->ts);
        iter_trace++) {
      LttvTrace *trace_v = lttv_traceset_get(tsc->ts, iter_trace);

      lttvwindowtraces_unlock(trace_v);
    }
  }
  return ret_val;
}


/**
 * Register the background computation hooks for a specific module. It adds the
 * computation hooks to the global attrubutes, under "computation/module name".
 *
 * @param module_name A GQuark : the name of the module which computes the
 *                    information.
 */
void lttvwindowtraces_register_computation_hooks(LttvAttributeName module_name,
                                        LttvHooks *before_chunk_traceset,
                                        LttvHooks *before_chunk_trace,
                                        LttvHooks *before_chunk_tracefile,
                                        LttvHooks *after_chunk_traceset,
                                        LttvHooks *after_chunk_trace,
                                        LttvHooks *after_chunk_tracefile,
                                        LttvHooks *before_request,
                                        LttvHooks *after_request,
                                        LttvHooks *event_hook,
                                        LttvHooksById *event_hook_by_id_channel,
                                        LttvHooks *hook_adder,
                                        LttvHooks *hook_remover)
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *attribute;
  LttvAttributeValue value;
  gboolean result;

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_COMPUTATION));
  g_assert(attribute);

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(attribute),
                                module_name));
  g_assert(attribute);

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_BEFORE_CHUNK_TRACESET,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  *(value.v_pointer) = before_chunk_traceset;
  
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_BEFORE_CHUNK_TRACE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = before_chunk_trace;
  
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_BEFORE_CHUNK_TRACEFILE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = before_chunk_tracefile;
  
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_AFTER_CHUNK_TRACESET,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = after_chunk_traceset;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_AFTER_CHUNK_TRACE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = after_chunk_trace;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_AFTER_CHUNK_TRACEFILE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = after_chunk_tracefile;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_BEFORE_REQUEST,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = before_request;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_AFTER_REQUEST,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = after_request;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_EVENT_HOOK,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = event_hook;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_EVENT_HOOK_BY_ID_CHANNEL,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = event_hook_by_id_channel;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_HOOK_ADDER,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = hook_adder;

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_HOOK_REMOVER,
                                LTTV_POINTER,
                                &value);
  g_assert(result);
  *(value.v_pointer) = hook_remover;

}


/**
 * It removes all the requests that can be currently processed by the
 * background computation algorithm for all the traces (list_in and list_out).
 *
 * Leaves the flag to in_progress or none.. depending if current or queue
 *
 * @param module_name A GQuark : the name of the module which computes the
 *                    information.
 */
void lttvwindowtraces_unregister_requests(LttvAttributeName module_name)
{
  guint i;
  gboolean result;

  for(i=0;i<lttvwindowtraces_get_number();i++) {
    LttvTrace *trace_v = lttvwindowtraces_get_trace(i);
    g_assert(trace_v != NULL);
    LttvAttribute *attribute = lttv_trace_attribute(trace_v);
    LttvAttributeValue value;
    GSList **queue, **current;
    GSList *iter;
    
    result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                  LTTV_REQUESTS_QUEUE,
                                  LTTV_POINTER,
                                  &value);
    g_assert(result);

    queue = (GSList**)(value.v_pointer);
    
    iter = *queue;
    while(iter != NULL) {
      gboolean remove = FALSE;
      gboolean free_data = FALSE;

      BackgroundRequest *bg_req = (BackgroundRequest*)iter->data;

      if(bg_req->module_name == module_name) {
        remove = TRUE;
        free_data = TRUE;
      }

      /* Go to next */
      if(remove)
      {
        GSList *remove_iter = iter;

        iter = g_slist_next(iter);
        if(free_data) g_free(remove_iter->data);
        *queue = g_slist_remove_link(*queue, remove_iter);
      } else { // not remove
        iter = g_slist_next(iter);
      }
    }
    
        
    result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                  LTTV_REQUESTS_CURRENT,
                                  LTTV_POINTER,
                                  &value);
    g_assert(result);

    current = (GSList**)(value.v_pointer);
    
    iter = *current;
    while(iter != NULL) {
      gboolean remove = FALSE;
      gboolean free_data = FALSE;

      BackgroundRequest *bg_req = (BackgroundRequest*)iter->data;

      if(bg_req->module_name == module_name) {
        remove = TRUE;
        free_data = TRUE;
      }

      /* Go to next */
      if(remove)
      {
        GSList *remove_iter = iter;

        iter = g_slist_next(iter);
        if(free_data) g_free(remove_iter->data);
        *current = g_slist_remove_link(*current, remove_iter);
      } else { // not remove
        iter = g_slist_next(iter);
      }
    }
  }
}


/**
 * Unregister the background computation hooks for a specific module.
 *
 * It also removes all the requests that can be currently processed by the
 * background computation algorithm for all the traces (list_in and list_out).
 *
 * @param module_name A GQuark : the name of the module which computes the
 *                    information.
 */

void lttvwindowtraces_unregister_computation_hooks
                                     (LttvAttributeName module_name)
{
  LttvAttribute *g_attribute = lttv_global_attributes();
  LttvAttribute *attribute;
  LttvAttributeValue value;
  gboolean result;

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_COMPUTATION));
  g_assert(attribute);

  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(attribute),
                                module_name));
  g_assert(attribute);

  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_BEFORE_CHUNK_TRACESET,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *before_chunk_traceset = (LttvHooks*)*(value.v_pointer);
  if(before_chunk_traceset != NULL)
    lttv_hooks_destroy(before_chunk_traceset);
  
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_BEFORE_CHUNK_TRACE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *before_chunk_trace = (LttvHooks*)*(value.v_pointer);
  if(before_chunk_trace != NULL)
    lttv_hooks_destroy(before_chunk_trace);
  
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_BEFORE_CHUNK_TRACEFILE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *before_chunk_tracefile = (LttvHooks*)*(value.v_pointer);
  if(before_chunk_tracefile != NULL)
    lttv_hooks_destroy(before_chunk_tracefile);
  
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_AFTER_CHUNK_TRACESET,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *after_chunk_traceset = (LttvHooks*)*(value.v_pointer);
  if(after_chunk_traceset != NULL)
    lttv_hooks_destroy(after_chunk_traceset);
 
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_AFTER_CHUNK_TRACE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *after_chunk_trace = (LttvHooks*)*(value.v_pointer);
  if(after_chunk_trace != NULL)
    lttv_hooks_destroy(after_chunk_trace);
 
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_AFTER_CHUNK_TRACEFILE,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *after_chunk_tracefile = (LttvHooks*)*(value.v_pointer);
  if(after_chunk_tracefile != NULL)
    lttv_hooks_destroy(after_chunk_tracefile);
 
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_BEFORE_REQUEST,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *before_request = (LttvHooks*)*(value.v_pointer);
  if(before_request != NULL)
    lttv_hooks_destroy(before_request);
 
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_AFTER_REQUEST,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *after_request = (LttvHooks*)*(value.v_pointer);
  if(after_request != NULL)
    lttv_hooks_destroy(after_request);
 
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_EVENT_HOOK,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *event_hook = (LttvHooks*)*(value.v_pointer);
  if(event_hook != NULL)
    lttv_hooks_destroy(event_hook);
 
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_EVENT_HOOK_BY_ID_CHANNEL,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooksByIdChannelArray *event_hook_by_id_channel = (LttvHooksByIdChannelArray*)*(value.v_pointer);
  if(event_hook_by_id_channel != NULL)
    lttv_hooks_by_id_channel_destroy(event_hook_by_id_channel);
 
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_HOOK_ADDER,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *hook_adder = (LttvHooks*)*(value.v_pointer);
  if(hook_adder != NULL)
    lttv_hooks_destroy(hook_adder);
 
  result = lttv_iattribute_find(LTTV_IATTRIBUTE(attribute),
                                LTTV_HOOK_REMOVER,
                                LTTV_POINTER,
                                &value);
  g_assert(result);

  LttvHooks *hook_remover = (LttvHooks*)*(value.v_pointer);
  if(hook_remover != NULL)
    lttv_hooks_destroy(hook_remover);
 

  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_EVENT_HOOK_BY_ID_CHANNEL);
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_EVENT_HOOK);

  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_AFTER_REQUEST);
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_BEFORE_REQUEST);

  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_AFTER_CHUNK_TRACEFILE);
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_AFTER_CHUNK_TRACE);
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_AFTER_CHUNK_TRACESET);

  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_BEFORE_CHUNK_TRACEFILE);
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_BEFORE_CHUNK_TRACE);
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_BEFORE_CHUNK_TRACESET);
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_HOOK_ADDER);
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_HOOK_REMOVER);

  /* finally, remove module name */
  attribute = 
      LTTV_ATTRIBUTE(lttv_iattribute_find_subdir(LTTV_IATTRIBUTE(g_attribute),
                                LTTV_COMPUTATION));
  g_assert(attribute);
  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                                     module_name);

}

/**
 * Lock a trace so no other instance can use it.
 *
 * @param trace The trace to lock.
 * @return 0 on success, -1 if cannot get lock.
 */
gint lttvwindowtraces_lock(LttvTrace *trace)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttributeValue value;
  LttvAttributeType type;

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_LOCK,
                                     &value);
  /* Verify the absence of the lock. */
  if(type != LTTV_NONE) {
    g_critical("Cannot take trace lock");
    return -1;
  }

  value = lttv_iattribute_add(LTTV_IATTRIBUTE(attribute),
                              LTTV_LOCK,
                              LTTV_INT);
  /* the value is left unset. The only presence of the attribute is necessary.
   */

  return 0;
}

/**
 * Unlock a trace.
 *
 * @param trace The trace to unlock.
 * @return 0 on success, -1 if cannot unlock (not locked ?).
 */
gint lttvwindowtraces_unlock(LttvTrace *trace)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttributeType type;
  LttvAttributeValue value;

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_LOCK,
                                     &value);
  /* Verify the presence of the lock. */
  if(type == LTTV_NONE) {
    g_critical("Cannot release trace lock");
    return -1;
  }

  lttv_iattribute_remove_by_name(LTTV_IATTRIBUTE(attribute),
                         LTTV_LOCK);

  return 0;
}

/**
 * Verify if a trace is locked.
 *
 * @param trace The trace to verify.
 * @return TRUE if locked, FALSE is unlocked.
 */
gint lttvwindowtraces_get_lock_state(LttvTrace *trace)
{
  LttvAttribute *attribute = lttv_trace_attribute(trace);
  LttvAttributeType type;
  LttvAttributeValue value;

  type = lttv_iattribute_get_by_name(LTTV_IATTRIBUTE(attribute),
                                     LTTV_LOCK,
                                     &value);
  /* The only presence of the attribute is necessary. */
  if(type == LTTV_NONE)
    return FALSE;
  else
    return TRUE;
}