fsal_create.c

Go to the documentation of this file.

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

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

#include "fsal.h"
#include "fsal_internal.h"
#include "fsal_convert.h"
#include "fsal_common.h"

fsal_status_t ZFSFSAL_create(fsal_handle_t * parent_hdl,      /* IN */
                             fsal_name_t * p_filename,     /* IN */
                             fsal_op_context_t *context,        /* IN */
                             fsal_accessmode_t accessmode, /* IN */
                             fsal_handle_t * obj_handle,        /* OUT */
                             fsal_attrib_list_t * object_attributes        /* [ IN/OUT ] */
    )
{

  int rc;
  creden_t cred;
  zfsfsal_handle_t * parent_directory_handle = (zfsfsal_handle_t *)parent_hdl;
  zfsfsal_op_context_t * p_context = (zfsfsal_op_context_t * )context;
  zfsfsal_handle_t * object_handle = (zfsfsal_handle_t *)obj_handle;

  /* sanity checks.
   * note : object_attributes is optional.
   */
  if(!parent_directory_handle || !p_context || !object_handle || !p_filename)
    Return(ERR_FSAL_FAULT, 0, INDEX_FSAL_create);

  /* Hook to prevent creating objects in a snapashot */
  if(parent_directory_handle->data.i_snap != 0)
  {
    LogDebug(COMPONENT_FSAL, "Trying to create a file inside a snapshot");
    Return(ERR_FSAL_ROFS, 0, INDEX_FSAL_create);
  }
  cred.uid = p_context->credential.user;
  cred.gid = p_context->credential.group;

  TakeTokenFSCall();

  inogen_t object;
  rc = libzfswrap_create(p_context->export_context->p_vfs, &cred,
                         parent_directory_handle->data.zfs_handle, p_filename->name,
                         fsal2unix_mode(accessmode), &object);

  ReleaseTokenFSCall();

  /* >> interpret returned error << */
  if(rc)
    Return(posix2fsal_error(rc), 0, INDEX_FSAL_create);

  /* >> set output handle << */
  object_handle->data.zfs_handle = object;
  object_handle->data.type = FSAL_TYPE_FILE;
  object_handle->data.i_snap = 0;

  if(object_attributes)
    {
      fsal_status_t status = ZFSFSAL_getattrs(obj_handle, context, object_attributes);

      /* on error, we set a special bit in the mask. */
      if(FSAL_IS_ERROR(status))
        {
          FSAL_CLEAR_MASK(object_attributes->asked_attributes);
          FSAL_SET_MASK(object_attributes->asked_attributes, FSAL_ATTR_RDATTR_ERR);
        }
    }

  /* OK */
  Return(ERR_FSAL_NO_ERROR, 0, INDEX_FSAL_create);

}

fsal_status_t ZFSFSAL_mkdir(fsal_handle_t * parent_hdl,       /* IN */
                            fsal_name_t * p_dirname,       /* IN */
                            fsal_op_context_t *context, /* IN */
                            fsal_accessmode_t accessmode,  /* IN */
                            fsal_handle_t * obj_handle, /* OUT */
                            fsal_attrib_list_t * object_attributes /* [ IN/OUT ] */
    )
{

  int rc;
  mode_t unix_mode;
  creden_t cred;
  zfsfsal_handle_t * parent_directory_handle = (zfsfsal_handle_t *)parent_hdl;
  zfsfsal_op_context_t * p_context = (zfsfsal_op_context_t *)context;
  zfsfsal_handle_t * object_handle = (zfsfsal_handle_t *)obj_handle;

  /* sanity checks.
   * note : object_attributes is optional.
   */
  if(!parent_directory_handle || !p_context || !object_handle || !p_dirname)
    Return(ERR_FSAL_FAULT, 0, INDEX_FSAL_mkdir);

  /* Hook to prevent creating objects in a snapashot */
  if(parent_directory_handle->data.i_snap != 0)
  {
    LogDebug(COMPONENT_FSAL, "Trying to create a directory inside a snapshot");
    Return(ERR_FSAL_ROFS, 0, INDEX_FSAL_mkdir);
  }

  /* convert fsal args to ZFS args */
  unix_mode = fsal2unix_mode(accessmode);


  /* Applying FSAL umask */
  unix_mode = unix_mode & ~global_fs_info.umask;
  cred.uid = p_context->credential.user;
  cred.gid = p_context->credential.group;

  TakeTokenFSCall();

  /* Create the directory */
  inogen_t object;
  rc = libzfswrap_mkdir(p_context->export_context->p_vfs, &cred,
                        parent_directory_handle->data.zfs_handle, p_dirname->name, unix_mode, &object);

  ReleaseTokenFSCall();

  /* >> interpret returned error << */
  if(rc)
    Return(posix2fsal_error(rc), 0, INDEX_FSAL_mkdir);

  /* set output handle */
  object_handle->data.zfs_handle = object;
  object_handle->data.type = FSAL_TYPE_DIR;
  object_handle->data.i_snap = 0;

  if(object_attributes)
    {
      fsal_status_t status = ZFSFSAL_getattrs(obj_handle, context, object_attributes);

      /* on error, we set a special bit in the mask. */
      if(FSAL_IS_ERROR(status))
        {
          FSAL_CLEAR_MASK(object_attributes->asked_attributes);
          FSAL_SET_MASK(object_attributes->asked_attributes, FSAL_ATTR_RDATTR_ERR);
        }

    }

  /* OK */
  Return(ERR_FSAL_NO_ERROR, 0, INDEX_FSAL_mkdir);

}

fsal_status_t ZFSFSAL_link(fsal_handle_t * target_hdl,  /* IN */
                           fsal_handle_t * dir_hdl,     /* IN */
                           fsal_name_t * p_link_name,      /* IN */
                           fsal_op_context_t * context,  /* IN */
                           fsal_attrib_list_t * attributes /* [ IN/OUT ] */
    )
{

  int rc;
  creden_t cred;
  zfsfsal_handle_t * target_handle = (zfsfsal_handle_t *)target_hdl;
  zfsfsal_handle_t * dir_handle = (zfsfsal_handle_t *)dir_hdl;
  zfsfsal_op_context_t * p_context = (zfsfsal_op_context_t *)context;

  /* sanity checks.
   * note : attributes is optional.
   */
  if(!target_handle || !dir_handle || !p_context || !p_link_name)
    Return(ERR_FSAL_FAULT, 0, INDEX_FSAL_link);

  /* Hook to prevent creating objects in a snapashot */
  if(target_handle->data.i_snap != 0)
  {
    LogDebug(COMPONENT_FSAL, "Trying to create hard link inside a snapshot");
    Return(ERR_FSAL_ROFS, 0, INDEX_FSAL_link);
  }

  /* Tests if hardlinking is allowed by configuration. */
  if(!global_fs_info.link_support)
    Return(ERR_FSAL_NOTSUPP, 0, INDEX_FSAL_link);
  cred.uid = p_context->credential.user;
  cred.gid = p_context->credential.group;

  TakeTokenFSCall();

  rc = libzfswrap_link(p_context->export_context->p_vfs, &cred,
                       dir_handle->data.zfs_handle, target_handle->data.zfs_handle, p_link_name->name);

  ReleaseTokenFSCall();

  /* >> interpret returned error << */
  if(rc)
    Return(posix2fsal_error(rc), 0, INDEX_FSAL_link);

  if(attributes)
    {
      fsal_status_t status = ZFSFSAL_getattrs(target_hdl, context, attributes);

      /* on error, we set a special bit in the mask. */
      if(FSAL_IS_ERROR(status))
        {
          FSAL_CLEAR_MASK(attributes->asked_attributes);
          FSAL_SET_MASK(attributes->asked_attributes, FSAL_ATTR_RDATTR_ERR);
        }

    }

  /* OK */
  Return(ERR_FSAL_NO_ERROR, 0, INDEX_FSAL_link);

}

fsal_status_t ZFSFSAL_mknode(fsal_handle_t * parentdir_handle,     /* IN */
                          fsal_name_t * p_node_name,    /* IN */
                          fsal_op_context_t * p_context,        /* IN */
                          fsal_accessmode_t accessmode, /* IN */
                          fsal_nodetype_t nodetype,     /* IN */
                          fsal_dev_t * dev,     /* IN */
                          fsal_handle_t * p_object_handle, /* OUT (handle to the created node) */
                          fsal_attrib_list_t * node_attributes  /* [ IN/OUT ] */
    )
{

  /* sanity checks.
   * note : link_attributes is optional.
   */
  if(!parentdir_handle || !p_context || !nodetype || !dev || !p_node_name)
    Return(ERR_FSAL_FAULT, 0, INDEX_FSAL_mknode);

  /* Not implemented */
  Return(ERR_FSAL_NOTSUPP, 0, INDEX_FSAL_mknode);

}