| /netbsd-src/sys/dev/raidframe/ |
| H A D | rf_reconbuffer.c | 139 rbuf->col, (long) rbuf->parityStripeID, rbuf->which_ru, (long) rbuf->failedDiskSectorOffset); in rf_SubmitReconBufferBasic() 141 RF_LOCK_PSS_MUTEX(raidPtr, rbuf->parityStripeID); in rf_SubmitReconBufferBasic() 150 …pssPtr = rf_LookupRUStatus(raidPtr, reconCtrlPtr->pssTable, rbuf->parityStripeID, rbuf->which_ru, … in rf_SubmitReconBufferBasic() 195 RF_UNLOCK_PSS_MUTEX(raidPtr, rbuf->parityStripeID); in rf_SubmitReconBufferBasic() 239 cb->v = rbuf->parityStripeID; in rf_SubmitReconBufferBasic() 265 t->parityStripeID = rbuf->parityStripeID; in rf_SubmitReconBufferBasic() 288 RF_UNLOCK_PSS_MUTEX(raidPtr, rbuf->parityStripeID); in rf_SubmitReconBufferBasic() 374 (long) rbuf->parityStripeID, rbuf->which_ru); in rf_CheckForFullRbuf() 377 (long) rbuf->parityStripeID, rbuf->which_ru); in rf_CheckForFullRbuf() 385 (long) rbuf->parityStripeID, rbuf->which_ru); in rf_CheckForFullRbuf() [all …]
|
| H A D | rf_psstatus.c | 160 if (p->parityStripeID == psID && p->which_ru == which_ru) in rf_LookupRUStatus() 169 p->parityStripeID = psID; in rf_LookupRUStatus() 202 RF_PSStatusHeader_t *hdr = &(pssTable[RF_HASH_PSID(raidPtr, pssPtr->parityStripeID)]); in rf_PSStatusDelete() 236 if ((p->parityStripeID == psid) && (p->which_ru == which_ru)) in rf_RemoveFromActiveReconTable() 261 Dprintf1("Waking up access waiting on parity stripe ID %ld\n", p->parityStripeID); in rf_RemoveFromActiveReconTable() 306 … (long) p->parityStripeID, p->which_ru, p->blockCount, procsWaiting, blocksWaiting, bufsWaiting); in RealPrintPSStatusTable()
|
| H A D | rf_raid1.c | 576 (long) rbuf->parityStripeID, rbuf->which_ru, in rf_SubmitReconBufferRAID1() 583 (long) rbuf->parityStripeID, (long) rbuf->buffer); in rf_SubmitReconBufferRAID1() 585 (long)rbuf->parityStripeID, b[0], b[1], b[2], b[3], b[4]); in rf_SubmitReconBufferRAID1() 587 RF_LOCK_PSS_MUTEX(raidPtr, rbuf->parityStripeID); in rf_SubmitReconBufferRAID1() 597 rbuf->parityStripeID, rbuf->which_ru, RF_PSS_NONE, NULL); in rf_SubmitReconBufferRAID1() 656 cb->v = rbuf->parityStripeID; in rf_SubmitReconBufferRAID1() 671 t->parityStripeID = rbuf->parityStripeID; in rf_SubmitReconBufferRAID1() 695 RF_UNLOCK_PSS_MUTEX(raidPtr, rbuf->parityStripeID); in rf_SubmitReconBufferRAID1()
|
| H A D | rf_dagdegrd.c | 122 RF_StripeNum_t parityStripeID; in rf_CreateRaidOneDegradedReadDAG() local 128 parityStripeID = rf_RaidAddressToParityStripeID(&(raidPtr->Layout), in rf_CreateRaidOneDegradedReadDAG() 187 rdNode->params[2].v = parityStripeID; in rf_CreateRaidOneDegradedReadDAG() 196 rdNode->params[2].v = parityStripeID; in rf_CreateRaidOneDegradedReadDAG() 278 RF_StripeNum_t parityStripeID; in rf_CreateDegradedReadDAG() local 287 parityStripeID = rf_RaidAddressToParityStripeID(layoutPtr, in rf_CreateDegradedReadDAG() 382 tmprudNode->params[2].v = parityStripeID; in rf_CreateDegradedReadDAG() 400 tmprrdNode->params[2].v = parityStripeID; in rf_CreateDegradedReadDAG() 417 tmprrdNode->params[2].v = parityStripeID; in rf_CreateDegradedReadDAG() 436 rpNode->params[2].v = parityStripeID; in rf_CreateDegradedReadDAG() [all …]
|
| H A D | rf_dagffwr.c | 178 RF_StripeNum_t parityStripeID; in rf_CommonCreateLargeWriteDAG() local 185 parityStripeID = rf_RaidAddressToParityStripeID(layoutPtr, in rf_CommonCreateLargeWriteDAG() 283 tmpNode->params[2].v = parityStripeID; in rf_CommonCreateLargeWriteDAG() 305 tmpNode->params[2].v = parityStripeID; in rf_CommonCreateLargeWriteDAG() 374 wnpNode->params[2].v = parityStripeID; in rf_CommonCreateLargeWriteDAG() 394 wnqNode->params[2].v = parityStripeID; in rf_CommonCreateLargeWriteDAG() 544 RF_StripeNum_t parityStripeID; in rf_CommonCreateSmallWriteDAG() local 551 parityStripeID = rf_RaidAddressToParityStripeID(&(raidPtr->Layout), in rf_CommonCreateSmallWriteDAG() 699 tmpreadDataNode->params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAG() 722 tmpreadParityNode->params[2].v = parityStripeID; in rf_CommonCreateSmallWriteDAG() [all …]
|
| H A D | rf_diskqueue.c | 363 rf_DiskIOPromote(RF_DiskQueue_t *queue, RF_StripeNum_t parityStripeID, in rf_DiskIOPromote() argument 371 retval = (queue->qPtr->Promote) (queue->qHdr, parityStripeID, which_ru); in rf_DiskIOPromote() 379 RF_StripeNum_t parityStripeID, in rf_CreateDiskQueueData() argument 411 p->parityStripeID = parityStripeID; in rf_CreateDiskQueueData()
|
| H A D | rf_cvscan.c | 349 rf_CvscanPromote(void *q_in, RF_StripeNum_t parityStripeID, in rf_CvscanPromote() argument 358 if (tmp->parityStripeID == parityStripeID && tmp->which_ru == which_ru) { in rf_CvscanPromote() 372 if (tmp->parityStripeID == parityStripeID && tmp->which_ru == which_ru) { in rf_CvscanPromote()
|
| H A D | rf_fifo.c | 158 rf_FifoPromote(void *q_in, RF_StripeNum_t parityStripeID, in rf_FifoPromote() argument 169 if (lp->parityStripeID == parityStripeID && lp->which_ru == which_ru) { in rf_FifoPromote()
|
| H A D | rf_dagdegwr.c | 181 RF_StripeNum_t parityStripeID; in rf_CommonCreateSimpleDegradedWriteDAG() local 186 parityStripeID = rf_RaidAddressToParityStripeID(layoutPtr, asmap->raidAddress, in rf_CommonCreateSimpleDegradedWriteDAG() 318 tmprrdNode->params[2].v = parityStripeID; in rf_CommonCreateSimpleDegradedWriteDAG() 335 tmprrdNode->params[2].v = parityStripeID; in rf_CommonCreateSimpleDegradedWriteDAG() 378 wnpNode->params[2].v = parityStripeID; in rf_CommonCreateSimpleDegradedWriteDAG() 396 wnqNode->params[2].v = parityStripeID; in rf_CommonCreateSimpleDegradedWriteDAG() 413 tmpwndNode->params[2].v = parityStripeID; in rf_CommonCreateSimpleDegradedWriteDAG() 707 (_node_).params[2].v = parityStripeID; \ 728 …RF_StripeNum_t parityStripeID = rf_RaidAddressToParityStripeID(layoutPtr, asmap->raidAddress, &whi… in rf_DoubleDegSmallWrite() local
|
| H A D | rf_parityloggingdags.c | 96 …RF_StripeNum_t parityStripeID = rf_RaidAddressToParityStripeID(&(raidPtr->Layout), asmap->raidAddr… in rf_CommonCreateParityLoggingLargeWriteDAG() local 145 rodNodes[nodeNum].params[2].v = parityStripeID; in rf_CommonCreateParityLoggingLargeWriteDAG() 161 wndNodes[i].params[2].v = parityStripeID; in rf_CommonCreateParityLoggingLargeWriteDAG() 342 …RF_StripeNum_t parityStripeID = rf_RaidAddressToParityStripeID(&(raidPtr->Layout), asmap->raidAddr… in rf_CommonCreateParityLoggingSmallWriteDAG() local 408 readDataNodes[i].params[2].v = parityStripeID; in rf_CommonCreateParityLoggingSmallWriteDAG() 423 readParityNodes[i].params[2].v = parityStripeID; in rf_CommonCreateParityLoggingSmallWriteDAG() 438 writeDataNodes[i].params[2].v = parityStripeID; in rf_CommonCreateParityLoggingSmallWriteDAG()
|
| H A D | rf_layout.c | 480 RF_StripeNum_t parityStripeID; in rf_MapStripeIDToParityStripeID() local 487 (layoutPtr->map->MapSIDToPSID) (layoutPtr, stripeID, &parityStripeID, which_ru); in rf_MapStripeIDToParityStripeID() 489 return (parityStripeID); in rf_MapStripeIDToParityStripeID()
|
| H A D | rf_dagfuncs.c | 270 RF_StripeNum_t parityStripeID = (RF_StripeNum_t) node->params[2].v; in rf_DiskReadFuncForThreads() local 277 bf, parityStripeID, which_ru, node->wakeFunc, node, in rf_DiskReadFuncForThreads() 299 RF_StripeNum_t parityStripeID = (RF_StripeNum_t) node->params[2].v; in rf_DiskWriteFuncForThreads() local 307 bf, parityStripeID, which_ru, node->wakeFunc, node, in rf_DiskWriteFuncForThreads()
|
| H A D | rf_reconstruct.c | 993 event->col, rbuf->parityStripeID); in ProcessReconEvent() 995 rbuf->parityStripeID, rbuf->buffer, rbuf->buffer[0] & 0xff, rbuf->buffer[1] & 0xff, in ProcessReconEvent() 1019 rbuf->parityStripeID, rbuf->which_ru, raidPtr->reconControl->percentComplete); in ProcessReconEvent() 1022 rf_RemoveFromActiveReconTable(raidPtr, rbuf->parityStripeID, rbuf->which_ru); in ProcessReconEvent() 1231 rbuf->parityStripeID = ctrl->curPSID; in IssueNextReadRequest() 1494 rbuf->spCol, rbuf->spOffset, rbuf->parityStripeID, in IssueNextWriteRequest() 1497 rbuf->parityStripeID, rbuf->buffer[0] & 0xff, rbuf->buffer[1] & 0xff, in IssueNextWriteRequest() 1504 rbuf->parityStripeID, rbuf->which_ru, in IssueNextWriteRequest() 1577 Dprintf2("Reconstruction completed on psid %ld ru %d\n", rbuf->parityStripeID, rbuf->which_ru); in ReconWriteDoneProc() 1826 new_rbuf->parityStripeID = psid; /* fill in the buffer */ in rf_ForceOrBlockRecon()
|
| H A D | rf_fifo.h | 58 rf_FifoPromote(void *q_in, RF_StripeNum_t parityStripeID,
|
| H A D | rf_cvscan.h | 79 rf_CvscanPromote(void *qptr, RF_StripeNum_t parityStripeID,
|
| H A D | rf_sstf.h | 61 rf_SstfPromote(void *qptr, RF_StripeNum_t parityStripeID,
|
| H A D | rf_sstf.c | 513 rf_SstfPromote(void *qptr, RF_StripeNum_t parityStripeID, RF_ReconUnitNum_t which_ru) in rf_SstfPromote() argument 530 if ((r->parityStripeID == parityStripeID) in rf_SstfPromote()
|
| H A D | rf_reconstruct.h | 52 RF_StripeNum_t parityStripeID; /* the parity stripe that this data member
|
| H A D | rf_diskqueue.h | 61 RF_StripeNum_t parityStripeID; /* the RAID parity stripe ID this member
|
| H A D | rf_psstatus.h | 75 RF_StripeNum_t parityStripeID; /* the parity stripe ID */ member
|
| H A D | rf_pqdegdags.c | 112 (_node_).params[2].v = parityStripeID; \
|