dev/raidframe/rf_stripelocks.c

101 			      RF_LockReqDesc_t * lockReqDesc);
254 		     RF_LockReqDesc_t *lockReqDesc)
265 	RF_ASSERT(RF_IO_IS_R_OR_W(lockReqDesc->type));
273 			    tid, (unsigned long) lockTable, stripeID, lockReqDesc->type, lockReqDesc->start,
274 			    lockReqDesc->stop, lockReqDesc->start2, lockReqDesc->stop2);
282 	lockReqDesc->next = NULL;	/* just to be sure */
297 		if (lockReqDesc->type == RF_IO_TYPE_WRITE)
299 		lockDesc->granted = lockReqDesc;
303 			    tid, stripeID, lockReqDesc->type, lockReqDesc->start, lockReqDesc->stop, lockReqDesc->start2, lockReqDesc->stop2);
311 		if (lockReqDesc->type == RF_IO_TYPE_WRITE)
317 			lockReqDesc->next = lockDesc->granted;
318 			lockDesc->granted = lockReqDesc;
322 				    tid, stripeID, lockReqDesc->type, lockReqDesc->start, lockReqDesc->stop, lockReqDesc->start2, lockReqDesc->stop2);
333 				if (STRIPELOCK_CONFLICT(lockReqDesc, p)) {
339 					if (STRIPELOCK_CONFLICT(lockReqDesc, p)) {
345 				lockReqDesc->next = lockDesc->granted;
346 				lockDesc->granted = lockReqDesc;
350 					    tid, stripeID, lockReqDesc->type, lockReqDesc->start, lockReqDesc->stop,
351 					    lockReqDesc->start2, lockReqDesc->stop2);
359 					    tid, stripeID, lockReqDesc->type, lockReqDesc->start, lockReqDesc->stop,
365 				AddToWaitersQueue(lockDesc, lockReqDesc);
377 		     RF_LockReqDesc_t *lockReqDesc)
388 	RF_ASSERT(RF_IO_IS_R_OR_W(lockReqDesc->type));
396 			    tid, stripeID, lockReqDesc->type, lockReqDesc->start, lockReqDesc->stop, lockReqDesc->start2, lockReqDesc->stop2, lockTable);
417 		if (lr == lockReqDesc)
420 	RF_ASSERT(lr && (lr == lockReqDesc));	/* major error to release a
431 	if (lockReqDesc->type == RF_IO_TYPE_WRITE)
492 			if (RANGE_OVERLAP(lockReqDesc, candidate))
634 AddToWaitersQueue(RF_StripeLockDesc_t *lockDesc, RF_LockReqDesc_t *lockReqDesc)
637 		lockDesc->waitersH = lockDesc->waitersT = lockReqDesc;
639 		lockDesc->waitersT->next = lockReqDesc;
640 		lockDesc->waitersT = lockReqDesc;