fsal_context.c

Go to the documentation of this file.

/*
 * vim:expandtab:shiftwidth=8:tabstop=8:
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#ifdef _SOLARIS
#include "solaris_port.h"
#endif                          /* _SOLARIS */

#ifdef _USE_GSSRPC
#include <gssrpc/rpc.h>
#include <gssrpc/clnt.h>
#include <gssrpc/auth.h>
#else
#include <rpc/rpc.h>
#include <rpc/xdr.h>
#include <rpc/clnt.h>
#include <rpc/auth.h>
#endif
#include "fsal.h"
#include "fsal_internal.h"
#include "fsal_common.h"
#include "fsal_nfsv4_macros.h"
#include <pwd.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <netdb.h> /* For rresvport */

extern proxyfs_specific_initinfo_t global_fsal_proxy_specific_info;

/* define your specific NFS export options here : */
enum
{
  YOUR_OPTION_1 = 0,
  YOUR_OPTION_2 = 1,
  YOUR_OPTION_3 = 2,
  YOUR_OPTION_4 = 3,
};

const char *fs_specific_opts[] = {
  "option1",
  "option2",
  "option3",
  "option4",
  NULL
};

static int Getsubopt(char **optionp, const char *const *tokens, char **valuep)
{
  char *endp, *vstart;
  int cnt;

  if(**optionp == '\0')
    return -1;

  /* Find end of next token.  */
  endp = strchr(*optionp, ',');
  if(endp == NULL)
    endp = strchr(*optionp, '\0');

  /* Find start of value.  */
  vstart = memchr(*optionp, '=', endp - *optionp);
  if(vstart == NULL)
    vstart = endp;

  /* Try to match the characters between *OPTIONP and VSTART against
     one of the TOKENS.  */
  for(cnt = 0; tokens[cnt] != NULL; ++cnt)
    if(memcmp(*optionp, tokens[cnt], vstart - *optionp) == 0
       && tokens[cnt][vstart - *optionp] == '\0')
      {
        /* We found the current option in TOKENS.  */
        *valuep = vstart != endp ? vstart + 1 : NULL;

        if(*endp != '\0')
          *endp++ = '\0';
        *optionp = endp;

        return cnt;
      }

  /* The current suboption does not match any option.  */
  *valuep = *optionp;

  if(*endp != '\0')
    *endp++ = '\0';
  *optionp = endp;

  return -1;
}

fsal_status_t PROXYFSAL_BuildExportContext(fsal_export_context_t * p_export_context,       /* OUT */
                                           fsal_path_t * p_export_path, /* IN */
                                           char *fs_specific_options    /* IN */
    )
{
  char subopts[256];
  char *p_subop;
  char *value;

  /* sanity check */
  if(!p_export_context)
    Return(ERR_FSAL_FAULT, 0, INDEX_FSAL_BuildExportContext);

  /* Save pointer to fsal_staticfsinfo_t in export context */
  p_export_context->fe_static_fs_info = &global_fs_info;

  if((fs_specific_options != NULL) && (fs_specific_options[0] != '\0'))
    {

      /* copy the option string (because it is modified by getsubopt call) */
      strncpy(subopts, fs_specific_options, 256);
      subopts[255] = '\0';
      p_subop = subopts;        /* set initial pointer */

      /* parse the FS specific option string */

      switch (Getsubopt(&p_subop, fs_specific_opts, &value))
        {
        case YOUR_OPTION_1:
          /* analyze your option 1 and fill the export_context structure */
          break;

        case YOUR_OPTION_2:
          /* analyze your option 2 and fill the export_context structure */
          break;

        case YOUR_OPTION_3:
          /* analyze your option 3 and fill the export_context structure */
          break;

        case YOUR_OPTION_4:
          /* analyze your option 4 and fill the export_context structure */
          break;

        default:
          {
            LogCrit(COMPONENT_FSAL,
                    "FSAL LOAD PARAMETER: ERROR: Invalid suboption found in EXPORT::FS_Specific : %s : xxxxxx expected.",
                    value);
            Return(ERR_FSAL_INVAL, 0, INDEX_FSAL_BuildExportContext);
          }
        }

    }

  Return(ERR_FSAL_NO_ERROR, 0, INDEX_FSAL_BuildExportContext);
}

fsal_status_t PROXYFSAL_InitClientContext(fsal_op_context_t *context)
{
  fsal_status_t fsal_status;
  proxyfsal_op_context_t * p_thr_context = (proxyfsal_op_context_t *)context;

  /* sanity check */
  if(!p_thr_context)
    Return(ERR_FSAL_FAULT, 0, INDEX_FSAL_InitClientContext);

  /* initialy set the export entry to none */
  p_thr_context->export_context = NULL;

  /* It is now time to initiate the rpc client within the thread's specific material */
  /* Keep here the reference to the server */
  p_thr_context->srv_prognum = global_fsal_proxy_specific_info.srv_prognum;
  p_thr_context->srv_addr = global_fsal_proxy_specific_info.srv_addr;
  p_thr_context->srv_port = global_fsal_proxy_specific_info.srv_port;
  p_thr_context->srv_sendsize = global_fsal_proxy_specific_info.srv_sendsize;
  p_thr_context->srv_recvsize = global_fsal_proxy_specific_info.srv_recvsize;
  p_thr_context->use_privileged_client_port = global_fsal_proxy_specific_info.use_privileged_client_port;
  p_thr_context->retry_sleeptime = global_fsal_proxy_specific_info.retry_sleeptime;
  p_thr_context->file_counter = 0LL;
  strncpy(p_thr_context->srv_proto, global_fsal_proxy_specific_info.srv_proto, MAXNAMLEN);
  pthread_mutex_init(&p_thr_context->lock, NULL);


  fsal_status = fsal_proxy_create_rpc_clnt(p_thr_context);
  if(FSAL_IS_ERROR(fsal_status))
    ReturnStatus(fsal_status, INDEX_FSAL_InitClientContext);

  fsal_status = FSAL_proxy_setclientid(p_thr_context);
  if(FSAL_IS_ERROR(fsal_status))
    Return(ERR_FSAL_FAULT, 0, INDEX_FSAL_InitClientContext);

  Return(ERR_FSAL_NO_ERROR, 0, INDEX_FSAL_InitClientContext);
}

/* @} */