1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
/* $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_ */
|
