kernel/device_manager/IOSchedulerSimple.cpp

60 			IOOperation* operation = it.Next();) {
61 		kprintf(" %p", operation);
103 	fFinishedOperationCondition.Init(this, "I/O finished operation");
133 	while (IOOperation* operation = fUnusedOperations.RemoveHead())
134 		delete operation;
152 		IOOperation* operation = new(std::nothrow) IOOperation;
153 		if (operation == NULL)
156 		fUnusedOperations.Add(operation);
285 IOSchedulerSimple::OperationCompleted(IOOperation* operation, status_t status,
290 	// finish operation only once
291 	if (operation->Status() <= 0)
294 	operation->SetStatus(status, transferredBytes);
296 	fCompletedOperations.Add(operation);
323 		IOOperation* operation = fCompletedOperations.RemoveHead();
324 		if (operation == NULL)
329 		TRACE("IOSchedulerSimple::_Finisher(): operation: %p\n", operation);
331 		bool operationFinished = operation->Finish();
334 			this, operation->Parent(), operation);
335 			// Notify for every time the operation is passed to the I/O hook,
339 			TRACE("  operation: %p not finished yet\n", operation);
341 			operation->Parent()->Owner()->operations.Add(operation);
346 		// notify request and remove operation
347 		IORequest* request = operation->Parent();
349 		request->OperationFinished(operation);
351 		// recycle the operation
354 			fDMAResource->RecycleBuffer(operation->Buffer());
357 		fUnusedOperations.Add(operation);
413 			IOOperation* operation = fUnusedOperations.RemoveHead();
414 			if (operation == NULL)
417 			status_t status = fDMAResource->TranslateNext(request, operation,
420 				operation->SetParent(NULL);
421 				fUnusedOperations.Add(operation);
432 //dprintf("  prepared operation %p\n", operation);
434 			off_t bandwidth = operation->Length();
438 			operations.Add(operation);
444 		IOOperation* operation = fUnusedOperations.RemoveHead();
445 		if (operation == NULL)
448 		status_t status = operation->Prepare(request);
450 			operation->SetParent(NULL);
451 			fUnusedOperations.Add(operation);
456 		operation->SetOriginalRange(request->Offset(), request->Length());
459 		off_t bandwidth = operation->Length();
463 		operations.Add(operation);
540 	while (IOOperation* operation = operations.RemoveHead())
541 		fOperationArray[count++] = operation;
557 		IOOperation* operation = sortedOperations.Head();
558 		while (operation != NULL) {
559 			IOOperation* nextOperation = sortedOperations.GetNext(operation);
560 			if (operation->Offset() >= lastOffset) {
561 				sortedOperations.Remove(operation);
562 //dprintf("  adding operation %p\n", operation);
563 				operations.Add(operation);
564 				lastOffset = operation->Offset() + operation->Length();
567 			operation = nextOperation;
619 			while (IOOperation* operation = owner->operations.RemoveHead()) {
622 				// TODO: We should make sure that after the first read operation
623 				// of a partial write, no other write operation to the same
625 				operations.Add(operation);
627 				off_t bandwidth = operation->Length();
687 		while (IOOperation* operation = operations.RemoveHead()) {
689 				"operation %ld: %p\n", i++, operation);
692 				this, operation->Parent(), operation);
694 			fIOCallback(fIOCallbackData, operation);