server/src/common/triggers/timeout.c

/* vi: set ts=2:
 *
 *
 *  Eressea PB(E)M host Copyright (C) 1998-2003
 *      Christian Schlittchen (corwin@amber.kn-bremen.de)
 *      Katja Zedel (katze@felidae.kn-bremen.de)
 *      Henning Peters (faroul@beyond.kn-bremen.de)
 *      Enno Rehling (enno@eressea.de)
 *      Ingo Wilken (Ingo.Wilken@informatik.uni-oldenburg.de)
 *
 * This program may not be used, modified or distributed without
 * prior permission by the authors of Eressea.
 */

#include <config.h>
#include <kernel/eressea.h>
#include "timeout.h"

/* util includes */
#include <util/attrib.h>
#include <util/event.h>
#include <util/log.h>
#include <util/storage.h>

#include <stdio.h>
#include <stdlib.h>
/***
 ** timeout
 **/

typedef struct timeout_data {
  trigger * triggers;
  int timer;
  variant trigger_data;
} timeout_data;

static void
timeout_init(trigger * t)
{
  t->data.v = calloc(sizeof(timeout_data), 1);
}

static void
timeout_free(trigger * t)
{
  timeout_data * td = (timeout_data*)t->data.v;
  free_triggers(td->triggers);
  free(t->data.v);
}

static int
timeout_handle(trigger * t, void * data)
{
  /* call an event handler on timeout.
   * data.v -> ( variant event, int timer )
   */
  timeout_data * td = (timeout_data*)t->data.v;
  if (--td->timer==0) {
    handle_triggers(&td->triggers, NULL);
    return -1;
  }
  unused(data);
  return 0;
}

static void
timeout_write(const trigger * t, struct storage * store)
{
  timeout_data * td = (timeout_data*)t->data.v;
  store->w_int(store, td->timer);
  write_triggers(store, td->triggers);
}

static int
timeout_read(trigger * t, struct storage * store)
{
  timeout_data * td = (timeout_data*)t->data.v;
  td->timer = store->r_int(store);
  read_triggers(store, &td->triggers);
  if (td->timer>20) {
    trigger * tr = td->triggers;
    log_warning(("there is a timeout lasting for another %d turns\n", td->timer));
    while (tr) {
      log_warning(("  timeout triggers: %s\n", tr->type->name));
      tr = tr->next;
    }
  }
  if (td->triggers!=NULL && td->timer>0) return AT_READ_OK;
  return AT_READ_FAIL;
}

trigger_type tt_timeout = {
  "timeout",
  timeout_init,
  timeout_free,
  timeout_handle,
  timeout_write,
  timeout_read
};

trigger *
trigger_timeout(int time, trigger * callbacks)
{
  trigger * t = t_new(&tt_timeout);
  timeout_data * td = (timeout_data*)t->data.v;
  td->triggers = callbacks;
  td->timer = time;
  return t;
}