userlandfs/kernel_add_on/KernelRequestHandler.cpp

60 KernelRequestHandler::HandleRequest(Request* request)
62 	if (request->GetType() == fExpectedReply) {
66 	switch (request->GetType()) {
69 			return _HandleRequest((NotifyListenerRequest*)request);
71 			return _HandleRequest((NotifySelectEventRequest*)request);
73 			return _HandleRequest((NotifyQueryRequest*)request);
76 			return _HandleRequest((GetVNodeRequest*)request);
78 			return _HandleRequest((PutVNodeRequest*)request);
80 			return _HandleRequest((AcquireVNodeRequest*)request);
82 			return _HandleRequest((NewVNodeRequest*)request);
84 			return _HandleRequest((PublishVNodeRequest*)request);
86 			return _HandleRequest((RemoveVNodeRequest*)request);
88 			return _HandleRequest((UnremoveVNodeRequest*)request);
90 			return _HandleRequest((GetVNodeRemovedRequest*)request);
93 			return _HandleRequest((FileCacheCreateRequest*)request);
95 			return _HandleRequest((FileCacheDeleteRequest*)request);
97 			return _HandleRequest((FileCacheSetEnabledRequest*)request);
99 			return _HandleRequest((FileCacheSetSizeRequest*)request);
101 			return _HandleRequest((FileCacheSyncRequest*)request);
103 			return _HandleRequest((FileCacheReadRequest*)request);
105 			return _HandleRequest((FileCacheWriteRequest*)request);
108 			return _HandleRequest((DoIterativeFDIORequest*)request);
110 			return _HandleRequest((ReadFromIORequestRequest*)request);
112 			return _HandleRequest((WriteToIORequestRequest*)request);
114 			return _HandleRequest((NotifyIORequestRequest*)request);
117 			return _HandleRequest((AddNodeListenerRequest*)request);
119 			return _HandleRequest((RemoveNodeListenerRequest*)request);
122 	PRINT(("KernelRequestHandler::HandleRequest(): unexpected request: %"
123 		B_PRIu32 "\n", request->GetType()));
132 KernelRequestHandler::_HandleRequest(NotifyListenerRequest* request)
134 	// check and execute the request
136 	if (fVolume && request->device != fVolume->GetID())
141 	char* name = (char*)request->name.GetData();
142 	int32 nameLen = request->name.GetSize();
149 	char* oldName = (char*)request->oldName.GetData();
150 	int32 oldNameLen = request->oldName.GetSize();
158 		switch (request->operation) {
172 						B_PRId32 "\n", request->operation));
181 	// execute the request
183 		switch (request->operation) {
186 					"\"%s\", %" B_PRId64 ")\n", request->device,
187 					request->directory, name, request->node));
188 				result = notify_entry_created(request->device,
189 					request->directory, name, request->node);
194 					"\"%s\", %" B_PRId64 ")\n", request->device,
195 					request->directory, name, request->node));
196 				result = notify_entry_removed(request->device,
197 					request->directory, name, request->node);
203 					request->device, request->oldDirectory, oldName,
204 					request->directory, name, request->node));
205 				result = notify_entry_moved(request->device,
206 					request->oldDirectory, oldName, request->directory, name,
207 					request->node);
212 					"0x%" B_PRIx32 ")\n", request->device, request->node,
213 					request->details));
214 				result = notify_stat_changed(request->device,
215 					request->directory, request->node, request->details);
220 					"\"%s\", 0x%" B_PRIx32 ")\n", request->device,
221 					request->node, name, (int32)request->details));
222 				result = notify_attribute_changed(request->device,
223 					request->directory, request->node, name,
224 					(int32)request->details);
229 					"\n", request->operation));
250 KernelRequestHandler::_HandleRequest(NotifySelectEventRequest* request)
252 	// check and execute the request
254 	if (fFileSystem->KnowsSelectSyncEntry(request->sync)) {
255 		if (request->unspecifiedEvent) {
258 			notify_select_event(request->sync, B_SELECT_READ);
259 			notify_select_event(request->sync, B_SELECT_WRITE);
260 			notify_select_event(request->sync, B_SELECT_ERROR);
262 			PRINT(("notify_select_event(%p, %d)\n", request->sync,
263 				(int)request->event));
264 			notify_select_event(request->sync, request->event);
284 KernelRequestHandler::_HandleRequest(NotifyQueryRequest* request)
286 	// check and execute the request
288 	if (fVolume && request->device != fVolume->GetID())
292 	char* name = (char*)request->name.GetData();
293 	int32 nameLen = request->name.GetSize();
300 	// execute the request
302 		switch (request->operation) {
306 					request->port, request->token, request->device,
307 					request->directory, name, request->node));
308 				result = notify_query_entry_created(request->port,
309 					request->token, request->device, request->directory, name,
310 					request->node);
316 					request->port, request->token, request->device,
317 					request->directory, name, request->node));
318 				result = notify_query_entry_removed(request->port,
319 					request->token, request->device, request->directory, name,
320 					request->node);
326 					"\n", request->operation));
350 KernelRequestHandler::_HandleRequest(GetVNodeRequest* request)
352 	// check and execute the request
354 	status_t result = _GetVolume(request->nsid, &volume);
358 		result = volume->GetVNode(request->vnid, &node);
373 KernelRequestHandler::_HandleRequest(PutVNodeRequest* request)
375 	// check and execute the request
377 	status_t result = _GetVolume(request->nsid, &volume);
380 		result = volume->PutVNode(request->vnid);
395 KernelRequestHandler::_HandleRequest(AcquireVNodeRequest* request)
397 	// check and execute the request
399 	status_t result = _GetVolume(request->nsid, &volume);
402 		result = volume->AcquireVNode(request->vnid);
419 KernelRequestHandler::_HandleRequest(NewVNodeRequest* request)
421 	// check and execute the request
423 	status_t result = _GetVolume(request->nsid, &volume);
426 		result = volume->NewVNode(request->vnid, request->node,
427 			request->capabilities);
444 KernelRequestHandler::_HandleRequest(PublishVNodeRequest* request)
446 	// check and execute the request
448 	status_t result = _GetVolume(request->nsid, &volume);
451 		result = volume->PublishVNode(request->vnid, request->node,
452 			request->type, request->flags, request->capabilities);
470 KernelRequestHandler::_HandleRequest(RemoveVNodeRequest* request)
472 	// check and execute the request
474 	status_t result = _GetVolume(request->nsid, &volume);
477 		result = volume->RemoveVNode(request->vnid);
491 KernelRequestHandler::_HandleRequest(UnremoveVNodeRequest* request)
493 	// check and execute the request
495 	status_t result = _GetVolume(request->nsid, &volume);
498 		result = volume->UnremoveVNode(request->vnid);
512 KernelRequestHandler::_HandleRequest(GetVNodeRemovedRequest* request)
514 	// check and execute the request
516 	status_t result = _GetVolume(request->nsid, &volume);
520 		result = volume->GetVNodeRemoved(request->vnid, &removed);
539 KernelRequestHandler::_HandleRequest(FileCacheCreateRequest* request)
541 	// check and execute the request
543 	status_t result = _GetVolume(request->nsid, &volume);
547 		result = volume->CreateFileCache(request->vnid, request->size);
564 KernelRequestHandler::_HandleRequest(FileCacheDeleteRequest* request)
566 	// check and execute the request
568 	status_t result = _GetVolume(request->nsid, &volume);
572 		result = volume->DeleteFileCache(request->vnid);
589 KernelRequestHandler::_HandleRequest(FileCacheSetEnabledRequest* request)
591 	// check and execute the request
593 	status_t result = _GetVolume(request->nsid, &volume);
597 		result = volume->SetFileCacheEnabled(request->vnid, request->enabled);
614 KernelRequestHandler::_HandleRequest(FileCacheSetSizeRequest* request)
616 	// check and execute the request
618 	status_t result = _GetVolume(request->nsid, &volume);
622 		result = volume->SetFileCacheSize(request->vnid, request->size);
639 KernelRequestHandler::_HandleRequest(FileCacheSyncRequest* request)
641 	// check and execute the request
643 	status_t result = _GetVolume(request->nsid, &volume);
647 		result = volume->SyncFileCache(request->vnid);
664 KernelRequestHandler::_HandleRequest(FileCacheReadRequest* request)
666 	// check the request
668 	status_t result = _GetVolume(request->nsid, &volume);
671 	size_t size = request->size;
686 	// execute the request
688 		result = volume->ReadFileCache(request->vnid, request->cookie,
689 			request->pos, buffer, &size);
708 KernelRequestHandler::_HandleRequest(FileCacheWriteRequest* request)
710 	// check and execute the request
712 	status_t result = _GetVolume(request->nsid, &volume);
717 		const void* data = request->buffer.GetData();
718 		size = request->size;
720 			if (size != (size_t)request->buffer.GetSize())
725 			result = volume->WriteFileCache(request->vnid, request->cookie,
726 				request->pos, data, &size);
746 KernelRequestHandler::_HandleRequest(DoIterativeFDIORequest* request)
748 	// check and execute the request
750 	status_t result = _GetVolume(request->nsid, &volume);
753 	uint32 vecCount = request->vecCount;
758 		result = volume->DoIterativeFDIO(request->fd, request->request,
759 			request->cookie, request->vecs, vecCount);
776 KernelRequestHandler::_HandleRequest(ReadFromIORequestRequest* request)
778 	// check the request
780 	status_t result = _GetVolume(request->nsid, &volume);
783 	size_t size = request->size;
798 	// execute the request
800 		result = volume->ReadFromIORequest(request->request, buffer, size);
816 KernelRequestHandler::_HandleRequest(WriteToIORequestRequest* request)
818 	// check and execute the request
820 	status_t result = _GetVolume(request->nsid, &volume);
824 		result = volume->WriteToIORequest(request->request,
825 			request->buffer.GetData(), request->buffer.GetSize());
843 KernelRequestHandler::_HandleRequest(NotifyIORequestRequest* request)
845 	// check and execute the request
847 	status_t result = _GetVolume(request->nsid, &volume);
851 		result = volume->NotifyIORequest(request->request, request->status);
867 KernelRequestHandler::_HandleRequest(AddNodeListenerRequest* request)
869 	// check and execute the request
870 	status_t result = fFileSystem->AddNodeListener(request->device,
871 		request->node, request->flags, request->listener);
888 KernelRequestHandler::_HandleRequest(RemoveNodeListenerRequest* request)
890 	// check and execute the request
891 	status_t result = fFileSystem->RemoveNodeListener(request->device,
892 		request->node, request->listener);