Lines Matching defs:item
201 /* removing last item from queue */
275 /* Return an initialized struct of info to be logged. Build one item
276 * per physical disk address, one item per region.
364 /* removing last item in the list */
372 /* removing first item in the list */
378 /* removing an item from the middle of
667 RF_ParityLogData_t *item;
691 /* lock the region for the first item in logData */
711 /* process each item in logData */
713 /* remove an item from logData */
714 item = logData;
716 item->next = NULL;
717 item->prev = NULL;
720 printf("[appending parity log data, region %d, raidAddress %d, numSector %d]\n", item->regionID, (int) item->diskAddress.raidAddress, (int) item->diskAddress.numSector);
723 if (regionID != item->regionID) {
725 regionID = item->regionID;
734 * skip to next item. */
736 /* process item, one sector at a time, until all sectors
738 if (item->diskAddress.numSector > 0)
747 * data item and move to nextItem. */
755 raidPtr->regionInfo[regionID].coreLog = AcquireParityLog(item, finish);
757 raidPtr->regionInfo[regionID].coreLog = AcquireParityLog(item, finish);
771 if (DumpParityLogToDisk(finish, item))
784 raidPtr->regionInfo[regionID].coreLog = AcquireParityLog(item, finish);
786 raidPtr->regionInfo[regionID].coreLog = AcquireParityLog(item, finish);
796 /* if we didn't punt on this item, attempt to add a
806 log->records[logItem].parityAddr = item->diskAddress;
810 log->records[logItem].operation = item->common->operation;
811 memcpy((char *)log->bufPtr + (logItem * (1 << item->common->raidPtr->logBytesPerSector)), ((char *)item->common->bufPtr + (item->bufOffset++ * (1 << item->common->raidPtr->logBytesPerSector))), (1 << item->common->raidPtr->logBytesPerSector));
812 item->diskAddress.numSector--;
813 item->diskAddress.startSector++;
814 if (item->diskAddress.numSector == 0)
820 /* Processed this item completely, decrement count of
822 RF_ASSERT(item->diskAddress.numSector == 0);
823 rf_lock_mutex2(item->common->mutex);
824 item->common->cnt--;
825 if (item->common->cnt == 0)
829 rf_unlock_mutex2(item->common->mutex);
834 timer = item->common->startTime; /* grab initial value of
838 item->common->tracerec->plog_us += RF_ETIMER_VAL_US(timer);
840 printf("[waking process for region %d]\n", item->regionID);
841 wakeFunc = item->common->wakeFunc;
842 wakeArg = item->common->wakeArg;
843 FreeParityLogCommonData(item->common);
844 FreeParityLogData(item);
847 FreeParityLogData(item);