WebSVN – HelenOS – Blame – /trunk/uspace/srv/vfs/vfs.c

Rev	Author	Line No.	Line
2518	jermar	1	/*
		2	* Copyright (c) 2007 Jakub Jermar
		3	* All rights reserved.
		4	*
		5	* Redistribution and use in source and binary forms, with or without
		6	* modification, are permitted provided that the following conditions
		7	* are met:
		8	*
		9	* - Redistributions of source code must retain the above copyright
		10	* notice, this list of conditions and the following disclaimer.
		11	* - Redistributions in binary form must reproduce the above copyright
		12	* notice, this list of conditions and the following disclaimer in the
		13	* documentation and/or other materials provided with the distribution.
		14	* - The name of the author may not be used to endorse or promote products
		15	* derived from this software without specific prior written permission.
		16	*
		17	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
		18	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
		19	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
		20	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
		21	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
		22	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
		23	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
		24	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
		25	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
		26	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
		27	*/
		28
		29	/** @addtogroup fs
		30	* @{
		31	*/
		32
		33	/**
		34	* @file vfs.c
2542	jermar	35	* @brief VFS service for HelenOS.
2518	jermar	36	*/
		37
2520	jermar	38	#include <ipc/ipc.h>
		39	#include <ipc/services.h>
		40	#include <async.h>
		41	#include <errno.h>
2532	jermar	42	#include <stdio.h>
2523	jermar	43	#include <bool.h>
2542	jermar	44	#include <string.h>
		45	#include <as.h>
2526	jermar	46	#include <libadt/list.h>
2552	jermar	47	#include <atomic.h>
2520	jermar	48	#include "vfs.h"
		49
2532	jermar	50	#define dprintf(...) printf(__VA_ARGS__)
		51
2520	jermar	52	static void vfs_connection(ipc_callid_t iid, ipc_call_t *icall)
		53	{
2523	jermar	54	bool keep_on_going = 1;
2520	jermar	55
2532	jermar	56	printf("Connection opened from %p\n", icall->in_phone_hash);
		57
2520	jermar	58	/*
		59	* The connection was opened via the IPC_CONNECT_ME_TO call.
		60	* This call needs to be answered.
		61	*/
2619	jermar	62	ipc_answer_0(iid, EOK);
2520	jermar	63
		64	/*
2523	jermar	65	* Here we enter the main connection fibril loop.
		66	* The logic behind this loop and the protocol is that we'd like to keep
2560	jermar	67	* each connection open until the client hangs up. When the client hangs
		68	* up, we will free its VFS state. The act of hanging up the connection
		69	* by the client is equivalent to client termination because we cannot
		70	* distinguish one from the other. On the other hand, the client can
		71	* hang up arbitrarily if it has no open files and reestablish the
		72	* connection later.
2520	jermar	73	*/
2523	jermar	74	while (keep_on_going) {
		75	ipc_callid_t callid;
		76	ipc_call_t call;
		77
		78	callid = async_get_call(&call);
2532	jermar	79
		80	printf("Received call, method=%d\n", IPC_GET_METHOD(call));
2523	jermar	81
		82	switch (IPC_GET_METHOD(call)) {
		83	case IPC_M_PHONE_HUNGUP:
		84	keep_on_going = false;
		85	break;
		86	case VFS_REGISTER:
		87	vfs_register(callid, &call);
2569	jermar	88	keep_on_going = false;
2523	jermar	89	break;
		90	case VFS_MOUNT:
2589	jermar	91	vfs_mount(callid, &call);
		92	break;
		93	case VFS_OPEN:
		94	vfs_open(callid, &call);
		95	break;
2625	jermar	96	case VFS_READ:
		97	vfs_read(callid, &call);
		98	break;
2666	jermar	99	case VFS_WRITE:
		100	vfs_write(callid, &call);
		101	break;
2684	jermar	102	case VFS_SEEK:
		103	vfs_seek(callid, &call);
		104	break;
2523	jermar	105	case VFS_UNMOUNT:
		106	case VFS_CREATE:
		107	case VFS_CLOSE:
2593	jermar	108	case VFS_UNLINK:
		109	case VFS_RENAME:
2523	jermar	110	default:
2619	jermar	111	ipc_answer_0(callid, ENOTSUP);
2523	jermar	112	break;
		113	}
2520	jermar	114	}
2523	jermar	115
		116	/* TODO: cleanup after the client */
		117
2520	jermar	118	}
		119
2518	jermar	120	int main(int argc, char **argv)
		121	{
2520	jermar	122	ipcarg_t phonead;
		123
2532	jermar	124	printf("VFS: HelenOS VFS server\n");
		125
2542	jermar	126	/*
		127	* Initialize the list of registered file systems.
		128	*/
2526	jermar	129	list_initialize(&fs_head);
2542	jermar	130
		131	/*
2596	jermar	132	* Initialize VFS node hash table.
		133	*/
		134	if (!vfs_nodes_init()) {
		135	printf("Failed to initialize the VFS node hash table.\n");
		136	return ENOMEM;
		137	}
		138
		139	/*
2542	jermar	140	* Allocate and initialize the Path Lookup Buffer.
		141	*/
		142	list_initialize(&plb_head);
		143	plb = as_get_mappable_page(PLB_SIZE);
2543	jermar	144	if (!plb) {
		145	printf("Cannot allocate a mappable piece of address space\n");
		146	return ENOMEM;
		147	}
		148	if (as_area_create(plb, PLB_SIZE, AS_AREA_READ \| AS_AREA_WRITE \|
		149	AS_AREA_CACHEABLE) != plb) {
		150	printf("Cannot create address space area.\n");
		151	return ENOMEM;
		152	}
		153	memset(plb, 0, PLB_SIZE);
2542	jermar	154
		155	/*
		156	* Set a connectio handling function/fibril.
		157	*/
2520	jermar	158	async_set_client_connection(vfs_connection);
2542	jermar	159
		160	/*
		161	* Register at the naming service.
		162	*/
2637	cejka	163	ipc_connect_to_me(PHONE_NS, SERVICE_VFS, 0, 0, &phonead);
2542	jermar	164
		165	/*
		166	* Start accepting connections.
		167	*/
2520	jermar	168	async_manager();
2518	jermar	169	return 0;
		170	}
		171
		172	/**
		173	* @}
		174	*/

Subversion Repositories HelenOS

(root)/trunk/uspace/srv/vfs/vfs.c @ 4426 – Rev 2684