nfs41_op_sequence.c

Go to the documentation of this file.

/*
 * vim:expandtab:shiftwidth=8:tabstop=8:
 *
 * Copyright CEA/DAM/DIF  (2008)
 * contributeur : Philippe DENIEL   philippe.deniel@cea.fr
 *                Thomas LEIBOVICI  thomas.leibovici@cea.fr
 *
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public License
 * as published by the Free Software Foundation; either version 3 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
 * 02110-1301 USA
 *
 * ---------------------------------------
 */

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

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

#include "sal_functions.h"

int nfs41_op_sequence(struct nfs_argop4 *op,
                      compound_data_t * data, struct nfs_resop4 *resp)
{
#define arg_SEQUENCE4  op->nfs_argop4_u.opsequence
#define res_SEQUENCE4  resp->nfs_resop4_u.opsequence

  nfs41_session_t *psession;

  resp->resop = NFS4_OP_SEQUENCE;
  res_SEQUENCE4.sr_status = NFS4_OK;

  /* OP_SEQUENCE is always the first operation of the request */
  if(data->oppos != 0)
    {
      res_SEQUENCE4.sr_status = NFS4ERR_SEQUENCE_POS;
      return res_SEQUENCE4.sr_status;
    }

  if(!nfs41_Session_Get_Pointer(arg_SEQUENCE4.sa_sessionid, &psession))
    {
      res_SEQUENCE4.sr_status = NFS4ERR_BADSESSION;
      return res_SEQUENCE4.sr_status;
    }

  /* Check if lease is expired and reserve it */
  P(psession->pclientid_record->cid_mutex);

  if(!reserve_lease(psession->pclientid_record))
    {
      V(psession->pclientid_record->cid_mutex);

      dec_client_id_ref(psession->pclientid_record);

      if(isDebug(COMPONENT_SESSIONS))
        LogDebug(COMPONENT_SESSIONS,
                 "SEQUENCE returning NFS4ERR_EXPIRED");
      else
        LogDebug(COMPONENT_CLIENTID,
                 "SEQUENCE returning NFS4ERR_EXPIRED");

      res_SEQUENCE4.sr_status = NFS4ERR_EXPIRED;
      return res_SEQUENCE4.sr_status;
    }

  data->preserved_clientid = psession->pclientid_record;

  V(psession->pclientid_record->cid_mutex);

  /* Check is slot is compliant with ca_maxrequests */
  if(arg_SEQUENCE4.sa_slotid >= psession->fore_channel_attrs.ca_maxrequests)
    {
      res_SEQUENCE4.sr_status = NFS4ERR_BADSLOT;
      return res_SEQUENCE4.sr_status;
    }

  /* By default, no DRC replay */
  data->use_drc = FALSE;

  P(psession->slots[arg_SEQUENCE4.sa_slotid].lock);
  if(psession->slots[arg_SEQUENCE4.sa_slotid].sequence + 1 != arg_SEQUENCE4.sa_sequenceid)
    {
      if(psession->slots[arg_SEQUENCE4.sa_slotid].sequence == arg_SEQUENCE4.sa_sequenceid)
        {
          if(psession->slots[arg_SEQUENCE4.sa_slotid].cache_used == TRUE)
            {
              /* Replay operation through the DRC */
              data->use_drc = TRUE;
              data->pcached_res = &psession->slots[arg_SEQUENCE4.sa_slotid].cached_result;

              LogFullDebug(COMPONENT_SESSIONS,
                           "Use sesson slot %"PRIu32"=%p for DRC",
                           arg_SEQUENCE4.sa_slotid, data->pcached_res);

              res_SEQUENCE4.sr_status = NFS4_OK;
              return res_SEQUENCE4.sr_status;
            }
          else
            {
              /* Illegal replay */
              res_SEQUENCE4.sr_status = NFS4ERR_RETRY_UNCACHED_REP;
              return res_SEQUENCE4.sr_status;
            }
        }
      V(psession->slots[arg_SEQUENCE4.sa_slotid].lock);
      res_SEQUENCE4.sr_status = NFS4ERR_SEQ_MISORDERED;
      return res_SEQUENCE4.sr_status;
    }

  /* Keep memory of the session in the COMPOUND's data */
  data->psession = psession;

  /* Update the sequence id within the slot */
  psession->slots[arg_SEQUENCE4.sa_slotid].sequence += 1;

  memcpy((char *)res_SEQUENCE4.SEQUENCE4res_u.sr_resok4.sr_sessionid,
         (char *)arg_SEQUENCE4.sa_sessionid, NFS4_SESSIONID_SIZE);
  res_SEQUENCE4.SEQUENCE4res_u.sr_resok4.sr_sequenceid =
      psession->slots[arg_SEQUENCE4.sa_slotid].sequence;
  res_SEQUENCE4.SEQUENCE4res_u.sr_resok4.sr_slotid = arg_SEQUENCE4.sa_slotid;
  res_SEQUENCE4.SEQUENCE4res_u.sr_resok4.sr_highest_slotid = NFS41_NB_SLOTS - 1;
  res_SEQUENCE4.SEQUENCE4res_u.sr_resok4.sr_target_highest_slotid = arg_SEQUENCE4.sa_slotid;    /* Maybe not the best choice */
  res_SEQUENCE4.SEQUENCE4res_u.sr_resok4.sr_status_flags = 0;   /* What is to be set here ? */

  if(arg_SEQUENCE4.sa_cachethis == TRUE)
    {
      data->pcached_res = &psession->slots[arg_SEQUENCE4.sa_slotid].cached_result;
      psession->slots[arg_SEQUENCE4.sa_slotid].cache_used = TRUE;

      LogFullDebug(COMPONENT_SESSIONS,
                   "Use sesson slot %"PRIu32"=%p for DRC",
                   arg_SEQUENCE4.sa_slotid, data->pcached_res);
    }
  else
    {
      data->pcached_res = NULL;
      psession->slots[arg_SEQUENCE4.sa_slotid].cache_used = FALSE;

      LogFullDebug(COMPONENT_SESSIONS,
                   "Don't use sesson slot %"PRIu32"=NULL for DRC",
                   arg_SEQUENCE4.sa_slotid);
    }
  V(psession->slots[arg_SEQUENCE4.sa_slotid].lock);

  res_SEQUENCE4.sr_status = NFS4_OK;
  return res_SEQUENCE4.sr_status;
}                               /* nfs41_op_sequence */

void nfs41_op_sequence_Free(SEQUENCE4res * resp)
{
  /* Nothing to be done */
  return;
}                               /* nfs4_op_sequence_Free */