/*	$OpenBSD: rf_psstatus.h,v 1.3 2002/12/16 07:01:04 tdeval Exp $	*/
/*	$NetBSD: rf_psstatus.h,v 1.3 1999/02/05 00:06:15 oster Exp $	*/

/*
 * Copyright (c) 1995 Carnegie-Mellon University.
 * All rights reserved.
 *
 * Author: Mark Holland
 *
 * Permission to use, copy, modify and distribute this software and
 * its documentation is hereby granted, provided that both the copyright
 * notice and this permission notice appear in all copies of the
 * software, derivative works or modified versions, and any portions
 * thereof, and that both notices appear in supporting documentation.
 *
 * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
 * CONDITION.  CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND
 * FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
 *
 * Carnegie Mellon requests users of this software to return to
 *
 *  Software Distribution Coordinator  or  Software.Distribution@CS.CMU.EDU
 *  School of Computer Science
 *  Carnegie Mellon University
 *  Pittsburgh PA 15213-3890
 *
 * any improvements or extensions that they make and grant Carnegie the
 * rights to redistribute these changes.
 */

/*****************************************************************************
 *
 * psstatus.h
 *
 * The reconstruction code maintains a bunch of status related to the parity
 * stripes that are currently under reconstruction. This header file defines
 * the status structures.
 *
 *****************************************************************************/

#ifndef	_RF__RF_PSSTATUS_H_
#define	_RF__RF_PSSTATUS_H_

#include "rf_types.h"
#include "rf_threadstuff.h"
#include "rf_callback.h"

#define	RF_PS_MAX_BUFS			 10	/*
						 * Max number of bufs we'll
						 * accumulate before we do
						 * an XOR.
						 */

#define	RF_PSS_DEFAULT_TABLESIZE	200

/*
 * Macros to acquire/release the mutex lock on a parity stripe status
 * descriptor. Note that we use just one lock for the whole hash chain.
 */
/* Simple hash function. */
#define	RF_HASH_PSID(_raid_,_psid_)	((_psid_) % ((_raid_)->pssTableSize))

#define	RF_LOCK_PSS_MUTEX(_raidPtr,_row,_psid)				\
	RF_LOCK_MUTEX((_raidPtr)->reconControl[_row]			\
	    ->pssTable[RF_HASH_PSID(_raidPtr, _psid)].mutex)
#define	RF_UNLOCK_PSS_MUTEX(_raidPtr, _row, _psid)			\
	RF_UNLOCK_MUTEX((_raidPtr)->reconControl[_row]			\
	    ->pssTable[RF_HASH_PSID(_raidPtr, _psid)].mutex)

struct RF_ReconParityStripeStatus_s {
	RF_StripeNum_t		 parityStripeID;/* The parity stripe ID. */
	RF_ReconUnitNum_t	 which_ru;	/*
						 * Which reconstruction unit
						 * with the indicated parity
						 * stripe.
						 */
	RF_PSSFlags_t		 flags;		/*
						 * Flags indicating various
						 * conditions.
						 */
	void			*rbuf;		/*
						 * This is the accumulating
						 * xor sum.
						 */
	void			*writeRbuf;	/*
						 * DEBUG ONLY:  A pointer to
						 * the rbuf after it has filled
						 * & been sent to disk.
						 */
	void			*rbufsForXor[RF_PS_MAX_BUFS];
						/*
						 * These are buffers still to
						 * be xored into the
						 * accumulating sum.
						 */
	int			 xorBufCount;	/*
						 * Num buffers waiting to be
						 * xored.
						 */
	int			 blockCount;	/*
						 * Count of # proc that have
						 * blocked recon on this parity
						 * stripe.
						 */
	char			*issued;	/*
						 * issued[i]==1 <=> column i
						 * has already issued a read
						 * request for the indicated
						 * RU.
						 */
	RF_CallbackDesc_t	*procWaitList;	/*
						 * List of user procs waiting
						 * for recon to be done.
						 */
	RF_CallbackDesc_t	*blockWaitList;	/*
						 * List of disks blocked
						 * waiting for user write to
						 * complete.
						 */
	RF_CallbackDesc_t	*bufWaitList;	/*
						 * List of disks blocked
						 * waiting to acquire a buffer
						 * for this RU.
						 */
	RF_ReconParityStripeStatus_t *next;
};

struct RF_PSStatusHeader_s {
	RF_DECLARE_MUTEX(mutex);		/* Mutex for this hash chain. */
	RF_ReconParityStripeStatus_t *chain;	/* The hash chain. */
};

/* Masks for the "flags" field above. */
#define	RF_PSS_NONE		0x00000000	/* No flags. */
#define	RF_PSS_UNDER_RECON	0x00000001	/*
						 * This parity stripe is
						 * currently under
						 * reconstruction.
						 */
#define	RF_PSS_FORCED_ON_WRITE	0x00000002	/*
						 * Indicates a recon was
						 * forced due to a user-write
						 * operation.
						 */
#define	RF_PSS_FORCED_ON_READ	0x00000004	/*
						 * Ditto for read, but not
						 * currently implemented.
						 */
#define	RF_PSS_RECON_BLOCKED	0x00000008	/*
						 * Reconstruction is currently
						 * blocked due to a pending
						 * user I/O.
						 */
#define	RF_PSS_CREATE		0x00000010	/*
						 * Tells LookupRUStatus to
						 * create the entry.
						 */
#define	RF_PSS_BUFFERWAIT	0x00000020	/*
						 * Someone is waiting for a
						 * buffer for this RU.
						 */

int  rf_ConfigurePSStatus(RF_ShutdownList_t **, RF_Raid_t *, RF_Config_t *);
RF_PSStatusHeader_t *rf_MakeParityStripeStatusTable(RF_Raid_t *);
void rf_FreeParityStripeStatusTable(RF_Raid_t *, RF_PSStatusHeader_t *);
RF_ReconParityStripeStatus_t *rf_LookupRUStatus(RF_Raid_t *,
	RF_PSStatusHeader_t *, RF_StripeNum_t, RF_ReconUnitNum_t,
	RF_PSSFlags_t, int *);
void rf_PSStatusDelete(RF_Raid_t *, RF_PSStatusHeader_t *,
	RF_ReconParityStripeStatus_t *);
void rf_RemoveFromActiveReconTable(RF_Raid_t *, RF_RowCol_t,
	RF_StripeNum_t, RF_ReconUnitNum_t);
RF_ReconParityStripeStatus_t *rf_AllocPSStatus(RF_Raid_t *);
void rf_FreePSStatus(RF_Raid_t *, RF_ReconParityStripeStatus_t *);
void rf_PrintPSStatusTable(RF_Raid_t *, RF_RowCol_t);

#endif	/* !_RF__RF_PSSTATUS_H_ */