resource.c

/* resource.c
 *
 * External resources associated with a connection, for instance
 * processes and ports. Used to kill or release the resource in
 * question when the connection dies.
 *
 * $Id$ */

/* lsh, an implementation of the ssh protocol
 *
 * Copyright (C) 1998 Niels Mller
 *
 * 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; either version 2 of the
 * License, or (at your option) any later version.
 *
 * 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
 */

#include "resource.h"

#include "werror.h"
#include "xalloc.h"

/* Prototypes */
#if 0
void do_mark_resources(struct lsh_queue *q,
		       void (*mark)(struct lsh_object *o));

void do_free_resources(struct lsh_queue *q);
#endif

void dont_free_live_resource(int alive);

#define GABA_DEFINE
#include "resource.h.x"
#undef GABA_DEFINE

#if 0
void do_mark_resources(struct lsh_queue *q,
		       void (*mark)(struct lsh_object *o))
{
  FOR_QUEUE(q, struct resource_node *, n)
    mark(&n->resource->super);
}

void do_free_resources(struct lsh_queue *q)
{
  FOR_QUEUE(q, struct resource_node *, n)
    lsh_space_free(n);
}
#endif

void dont_free_live_resource(int alive)
{
  if (alive)
    fatal("dont_free_live_resource: "
	  "About to garbage collect a live resource!\n");
}

static void do_remember_resource(struct resource_list *self,
						  struct resource *r)
{
  object_queue_add_head(&self->q, &r->super);
}

static void do_kill_all(struct resource_list *self)
{
  while (!object_queue_is_empty(&self->q))
    {
      CAST_SUBTYPE(resource, r, object_queue_remove_head(&self->q));
      KILL_RESOURCE(r);
    }
  #if 0
  /* FIXME: Doesn't deallocate any nodes (but gc should do that
   * later). */
  FOR_QUEUE(&self->q, struct resource_node *, n)
    KILL_RESOURCE(n->resource);
  #endif
}
  
struct resource_list *empty_resource_list(void)
{
  NEW(resource_list, self);
  object_queue_init(&self->q);

  self->remember = do_remember_resource;
  self->kill_all = do_kill_all;
  /* self->kill = do_kill_resource; */

  return self;
}