sion_fd.c

Go to the documentation of this file.

/****************************************************************************
**  SIONLIB     http://www.fz-juelich.de/jsc/sionlib                       **
*****************************************************************************
**  Copyright (c) 2008-2016                                                **
**  Forschungszentrum Juelich, Juelich Supercomputing Centre               **
**                                                                         **
**  See the file COPYRIGHT in the package base directory for details       **
****************************************************************************/

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <stdarg.h>
#include <assert.h>
#include "sion_lock.h"
#include "sion_fd.h"

#define sion_assert(expr, args) (assert(expr))

#define SION_FDDATA_INITIALIZER {0,0,-1,NULL}

/************************/
static struct _sion_fddata {
  int size;
  int nfree;
  int last_freed;
  struct _sion_fd *list;
} sion_fd_data = SION_FDDATA_INITIALIZER;

static char *text;              /* just a temp hack */

/* some abbreviations for fd functions */
int _sion_newvcd(void *data, int type)
{
  return _sion_new_fd(&sion_fd_data, data, type);
}
int _sion_freevcd(int sid)
{
  return _sion_free_fd(&sion_fd_data, sid, text);
}
void     *_sion_vcdtovcon(int sid)
{
  return _sion_fd2ptr(&sion_fd_data, sid);
}
int _sion_vcdtype(int sid)
{
  return _sion_fd2type(&sion_fd_data, sid, text);
}
int _sion_reassignvcd(int sid, void *data, int type)
{
  return _sion_reassign_fd(&sion_fd_data, sid, data, type, text);
}
/************************/



int _sion_new_fd(sion_fddata *fdd, void *data, int type)
{
  int       i;

  _sion_lock();

  /* if we are sure that we have at least 2 free descriptors,
   * we can guarantee, that we don't need to reuse a freed
   * one immediately
   * so enlarge array of descriptors if we have less than 2 free ones
   */
  if (fdd->nfree < 2) {
    int       new_size;

    new_size = fdd->size + SION_FD_CHUNK;

    if (fdd->list) {
      fdd->list = realloc(fdd->list, new_size * sizeof(struct _sion_fd));
    }
    else {
      fdd->list = malloc(new_size * sizeof(struct _sion_fd));
    }
    sion_assert(fdd->list, ("out of memory"));

    for (i = fdd->size; i < new_size; i++) {
      fdd->list[i].state = 0;   /* free */
      fdd->list[i].type = 0;
      fdd->list[i].data = NULL;
    }

    fdd->size = new_size;
    fdd->nfree += SION_FD_CHUNK;
  }

  /* use first 'fresh' index */
  for (i = 0; i < fdd->size; i++) {
    if (fdd->list[i].state == 0) {
      fdd->list[i].data = data;
      fdd->list[i].type = type;
      fdd->list[i].state = 1;
      fdd->nfree--;
      _sion_unlock();
      return i;
    }
  }

  /* if all have been used before, use a 'closed' one,
   * start seraching a new one AFTER the last freed
   * so this one will not be reused immediately
   */
  for (i = fdd->last_freed + 1; i < fdd->last_freed + 1 + fdd->size; i++) {
    int       imod = i % fdd->size;
    if (fdd->list[imod].state == -1) {
      fdd->list[imod].data = data;
      fdd->list[imod].type = type;
      fdd->list[imod].state = 1;
      fdd->nfree--;
      _sion_unlock();
      return imod;
    }
  }
  sion_assert(0, ("oops - we should never get here"));
  return -1;
}


int _sion_set_fd(sion_fddata *fdd, int fd, void *data, int type, char *text)
{

  if (text && (!*text))
    text = "_sion_set_fd";

  if (fd < 0) {
    if (text) {
      fprintf(stderr, "%s: trying to set an invalid descriptor fd=%d.\n", text, fd);
    }
    return 0;
  }

  _sion_lock();

  if (fd >= fdd->size) {
    /*
     * enlarge descriptor array if neccessary
     *
     */
    int       i, new_size;

    new_size = fdd->size + SION_FD_CHUNK;
    while (fd >= new_size) {
      new_size += SION_FD_CHUNK;
    }

    if (fdd->list) {
      fdd->list = realloc(fdd->list, new_size * sizeof(struct _sion_fd));
    }
    else {
      fdd->list = malloc(new_size * sizeof(struct _sion_fd));
    }
    sion_assert(fdd->list, ("out of memory"));

    for (i = fdd->size; i < new_size; i++) {
      fdd->list[i].state = 0;   /* free */
      fdd->list[i].type = 0;
      fdd->list[i].data = NULL;
    }

    fdd->nfree += new_size - fdd->size;
    fdd->size = new_size;
  }
  else if (fdd->list[fd].state == 1) {
    if (text) {
      fprintf(stderr, "%s: trying to set a descriptor that is in use fd=%d.\n", text, fd);
    }
    _sion_unlock();
    return 0;
  }

  fdd->list[fd].data = data;
  fdd->list[fd].type = type;
  fdd->list[fd].state = 1;
  fdd->nfree--;

  _sion_unlock();
  return 1;
}


int _sion_free_fd(sion_fddata *fdd, int fd, char *text)
{

  _sion_lock();
  if ((fd < fdd->size) && (fd >= 0) && (fdd->list) && (fdd->list[fd].state == 1)) {
    fdd->list[fd].state = -1;
    fdd->nfree++;
    fdd->last_freed = fd;       /* remember this one to avoid immediate reuse */

    if (fdd->nfree == fdd->size) {
      free(fdd->list);
      fdd->list = NULL;
      fdd->nfree = 0;
      fdd->size = 0;
    }

    _sion_unlock();
    return 1;
  }
  else {
    if (text) {
      if (!*text)
        text = "_sion_free_fd";
      fprintf(stderr, "%s: trying to free an invalid descriptor fd=%d.\n", text, fd);
    }
    _sion_unlock();
    return 0;
  }
}


void     *_sion_fd2ptr(sion_fddata *fdd, int fd)
{
  _sion_lock();
  if ((fd < fdd->size) && (fd >= 0) && (fdd->list[fd].state == 1)) {
    void *ptr = fdd->list[fd].data;
    _sion_unlock();
    return ptr;
  }
  else {
    _sion_unlock();
    return NULL;
  }
}


int _sion_fd2type(sion_fddata *fdd, int fd, char *text)
{
  _sion_lock();
  if ((fd < fdd->size) && (fd >= 0) && (fdd->list[fd].state == 1)) {
    int type = fdd->list[fd].type;
    _sion_unlock();
    return type;
  }
  else {
    if (text) {
      if (!*text)
        text = "_sion_fd2type";
      fprintf(stderr, "%s: invalid descriptor fd=%d.\n", text, fd);
    }
    _sion_unlock();
    return -1;
  }
}


int _sion_ptr2fd(sion_fddata *fdd, void *ptr, char *text)
{
  int       i;

  _sion_lock();
  for (i = 0; i < fdd->size; i++) {
    if ((fdd->list[i].state == 1) && (fdd->list[i].data == ptr)) {
      _sion_unlock();
      return i;
    }
  }
  if (text) {
    if (!*text)
      text = "_sion_ptr2fd";
    fprintf(stderr, "%s: invalid pointer ptr=%x.\n", text, (unsigned) (size_t) ptr);
  }
  _sion_unlock();
  return -1;
}


int _sion_reassign_fd(sion_fddata *fdd, int fd, void *data, int type, char *text)
{
  _sion_lock();
  if ((fd < fdd->size) && (fd >= 0) && (fdd->list[fd].state == 1)) {
    fdd->list[fd].data = data;
    fdd->list[fd].type = type;
    _sion_unlock();
    return 1;
  }
  else {
    if (text) {
      if (!*text)
        text = "_sion_reassign_fd";
      fprintf(stderr, "%s: invalid descriptor fd=%d.\n", text, fd);
    }
    _sion_unlock();
    return 0;
  }
}


int _sion_fd_size(sion_fddata *fdd)
{
  /* should be atomic */
  return fdd->size;
}