sion_hints_gpfs.c

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

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <time.h>
#include <assert.h>

#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>

#include "sion.h"
#include "sion_debug.h"
#include "sion_internal.h"
#include "sion_hints_gpfs.h"

#ifdef SION_HINTS_GPFS
#include <gpfs_fcntl.h>
#endif



int  _sion_apply_hint_gpfs_access_range(int fd, long long  start, long long length, int iswrite ) {
  int rc=SION_SUCCESS;

 /* #NODIST# */
#ifdef SION_HINTS_GPFS
  int grc;
  struct
  {
    gpfsFcntlHeader_t hdr;
    gpfsAccessRange_t acc;
  } accHint;
#endif

  DPRINTFP((2, "_sion_apply_hint_gpfs_access_range", -1, "start fd=%d start=%lld length=%lld\n",
        fd, start, length));


#ifdef SION_HINTS_GPFS
  DPRINTFP((2, "_sion_apply_hint_gpfs_access_range", -1, "do apply\n"));

  /* Issue the access range hint */
  accHint.hdr.totalLength = sizeof(accHint);
  accHint.hdr.fcntlVersion = GPFS_FCNTL_CURRENT_VERSION;
  accHint.hdr.fcntlReserved = 0;
  accHint.acc.structLen = sizeof(accHint.acc);
  accHint.acc.structType = GPFS_ACCESS_RANGE;
  accHint.acc.start  = start;
  accHint.acc.length = length;
  accHint.acc.isWrite = iswrite;
  grc = gpfs_fcntl(fd, &accHint);
  if (grc != 0) {
    return(_sion_errorprint(SION_NOT_SUCCESS,_SION_ERROR_RETURN,"cannot set GPFS hint (access) for file fd=%d start=%lld length=%lld   ... rc=%d\n", 
                fd, start, length, rc));
  }
  DPRINTFP((2, "_sion_apply_hint_gpfs_access_range", -1, "apply done rc=%d\n",rc));

#endif
 /* #NODIST# */

  return (rc);
}


int  _sion_apply_hint_gpfs_free_range(int fd, long long  start, long long length, int iswrite ) {
  int rc=SION_SUCCESS;

 /* #NODIST# */
#ifdef SION_HINTS_GPFS
  int grc;
  struct
  {
    gpfsFcntlHeader_t hdr;
    gpfsFreeRange_t free;
  } freeHint;
#endif

  DPRINTFP((2, "_sion_apply_hint_gpfs_free_range", -1, "start fd=%d start=%lld length=%lld\n",
        fd, start, length));


#ifdef SION_HINTS_GPFS
  DPRINTFP((2, "_sion_apply_hint_gpfs_free_range", -1, "do apply\n"));

  /* Issue the free range hint */
  freeHint.hdr.totalLength = sizeof(freeHint);
  freeHint.hdr.fcntlVersion = GPFS_FCNTL_CURRENT_VERSION;
  freeHint.hdr.fcntlReserved = 0;
  freeHint.free.structLen = sizeof(freeHint.free);
  freeHint.free.structType = GPFS_FREE_RANGE;
  freeHint.free.start  = start;
  freeHint.free.length = length;
  grc = gpfs_fcntl(fd, &freeHint);
  if (grc != 0) {
    _sion_errorprint(SION_NOT_SUCCESS,_SION_ERROR_RETURN,"cannot set GPFS hint (free) for file fd=%d start=%lld length=%lld   ... rc=%d\n", 
             fd, start, length, rc);
    return(rc);
  }
  DPRINTFP((2, "_sion_apply_hint_gpfs_free_range", -1, "apply done rc=%d\n",rc));

#endif
 /* #NODIST# */

  return (rc);
}