kernel/fs/fifo.cpp

173 									ReadRequest& request);
179 			void				AddReadRequest(ReadRequest& request);
180 			void				RemoveReadRequest(ReadRequest& request);
181 			status_t			WaitForReadRequest(ReadRequest& request);
356 	mutex_init(&fRequestLock, "pipe request");
380 	request lock must be held when calling this method.
398 	// A request up to VFS_FIFO_ATOMIC_WRITE_SIZE bytes shall not be
414 			WriteRequest request(thread_get_current_thread(), minToWrite);
415 			fWriteRequests.Add(&request);
421 			fWriteRequests.Remove(&request);
459 	bool isUser, ReadRequest& request)
464 	// wait until our request is first in queue
466 	if (fReadRequests.Head() != &request) {
470 		TRACE("Inode %p::%s(): wait for request %p to become the first "
471 			"request.\n", this, __FUNCTION__, &request);
473 		error = WaitForReadRequest(request);
486 		TRACE("Inode %p::%s(): wait for data, request %p\n", this, __FUNCTION__,
487 			&request);
489 		error = WaitForReadRequest(request);
512 Inode::AddReadRequest(ReadRequest& request)
514 	fReadRequests.Add(&request);
519 Inode::RemoveReadRequest(ReadRequest& request)
521 	fReadRequests.Remove(&request);
526 Inode::WaitForReadRequest(ReadRequest& request)
530 		THREAD_BLOCK_TYPE_OTHER, "fifo read request");
532 	request.SetNotified(false);
540 	request.SetNotified(true);
563 		WriteRequest* request;
565 		while ((request = iterator.Next()) != NULL) {
566 			size_t minWriteCount = request->MinimalWriteCount();
582 		if (ReadRequest* request = fReadRequests.First())
583 			request->Notify();
596 		if (ReadRequest* request = fReadRequests.First())
597 			request->Notify();
614 			while (ReadRequest* request = iterator.Next())
615 				request->Notify();
666 	while (ReadRequest* request = iterator.Next()) {
667 		if (request->Cookie() == cookie)
668 			request->Notify(B_FILE_ERROR);
758 			ReadRequest* request = it.Next();) {
759 			kprintf("    %p: thread %" B_PRId32 ", cookie: %p\n", request,
760 				request->GetThread()->id, request->Cookie());
767 			WriteRequest* request = it.Next();) {
768 			kprintf("    %p:  thread %" B_PRId32 ", min count: %zu\n", request,
769 				request->GetThread()->id, request->MinimalWriteCount());
952 	// issue read request
954 	ReadRequest request(cookie);
955 	inode->AddReadRequest(request);
957 	TRACE("  issue read request %p\n", &request);
962 		request);
964 	inode->RemoveReadRequest(request);
967 	TRACE("  done reading request %p, length %zu\n", &request, length);