WebSVN – HelenOS – Diff – /branches/dynload/uspace/srv/fs/fat/fat.c


/*
 * Copyright (c) 2006 Martin Decky
 * Copyright (c) 2007 Jakub Jermar
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * - Redistributions of source code must retain the above copyright
 *   notice, this list of conditions and the following disclaimer.
 * - Redistributions in binary form must reproduce the above copyright
 *   notice, this list of conditions and the following disclaimer in the
 *   documentation and/or other materials provided with the distribution.
 * - The name of the author may not be used to endorse or promote products
 *   derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */
 
/** @addtogroup fs
 * @{
 */
 
/**
 * @file    fat.c
 * @brief   FAT file system driver for HelenOS.
 */
 
#include <ipc/ipc.h>
#include <ipc/services.h>
#include <async.h>
#include <errno.h>
#include <unistd.h>
#include <stdio.h>>
#include "../../vfs/vfs.h"
 
#define dprintf(...)    printf(__VA_ARGS__)
 
vfs_info_t fat_vfs_info = {
    .name = "fat",
    .ops = {
        [IPC_METHOD_TO_VFS_OP(VFS_REGISTER)] = VFS_OP_DEFINED,
        [IPC_METHOD_TO_VFS_OP(VFS_MOUNT)] = VFS_OP_DEFINED,
        [IPC_METHOD_TO_VFS_OP(VFS_UNMOUNT)] = VFS_OP_DEFINED,
        [IPC_METHOD_TO_VFS_OP(VFS_LOOKUP)] = VFS_OP_DEFINED,
        [IPC_METHOD_TO_VFS_OP(VFS_OPEN)] = VFS_OP_DEFINED,
        [IPC_METHOD_TO_VFS_OP(VFS_CREATE)] = VFS_OP_DEFINED,
        [IPC_METHOD_TO_VFS_OP(VFS_CLOSE)] = VFS_OP_DEFINED,
        [IPC_METHOD_TO_VFS_OP(VFS_READ)] = VFS_OP_DEFINED,
        [IPC_METHOD_TO_VFS_OP(VFS_WRITE)] = VFS_OP_NULL,
        [IPC_METHOD_TO_VFS_OP(VFS_SEEK)] = VFS_OP_DEFAULT
    }
};
 
/*
 * This fibril processes request from the VFS server.
 */
void fat_connection(ipc_callid_t iid, ipc_call_t *icall)
{
    dprintf("Callback connection established.\n");
    while (1) {
        ipc_callid_t callid;
        ipc_call_t call;
   
        callid = async_get_call(&call);
        ipc_answer_fast(callid, ENOTSUP, 0, 0);
    }
}
 
int main(int argc, char **argv)
{
    int vfs_phone;
 
    printf("FAT: HelenOS FAT file system server.\n");
 
    vfs_phone = ipc_connect_me_to(PHONE_NS, SERVICE_VFS, 0);
    while (vfs_phone < EOK) {
        usleep(10000);
        vfs_phone = ipc_connect_me_to(PHONE_NS, SERVICE_VFS, 0);
    }
   
    /*
     * Tell VFS that we are here and want to get registered.
     * We use the async framework because VFS will answer the request
     * out-of-order, when it knows that the operation succeeded or failed.
     */
    ipc_call_t answer;
    aid_t req = async_send_2(vfs_phone, VFS_REGISTER, 0, 0, &answer);
 
    /*
     * Send our VFS info structure to VFS.
     */
    int rc = ipc_data_send(vfs_phone, &fat_vfs_info, sizeof(fat_vfs_info));
    if (rc != EOK) {
        async_wait_for(req, NULL);
        return rc;
    }
 
    /*
     * Ask VFS for callback connection.
     */
    ipcarg_t phonehash;
    ipc_connect_to_me(vfs_phone, 0, 0, &phonehash);
 
    async_new_connection(phonehash, 0, NULL, fat_connection);
 
    /*
     * Pick up the answer for the request to the VFS_REQUEST call.
     */
    async_wait_for(req, NULL);
    dprintf("FAT filesystem registered.\n");
 
    /*
     * TODO: Interestingly, if we merely return, the only thread dies.
     *       If the only thread dies, the whole task is destroyed.
     *       Prevent the thread from exiting when there are active fibrils.
     */
    fibril_schedule_next_adv(FIBRIL_FROM_DEAD);
    /* not reached */
 
    return 0;
}
 
/**
 * @}
 */
 

Subversion Repositories HelenOS

(root)/branches/dynload/uspace/srv/fs/fat/fat.c @ 3674 – Rev 2533 → 2534

Rev 2533		Rev 2534
1	/*	1	/*
2	* Copyright (c) 2006 Martin Decky	2	* Copyright (c) 2006 Martin Decky
3	* Copyright (c) 2007 Jakub Jermar	3	* Copyright (c) 2007 Jakub Jermar
4	* All rights reserved.	4	* All rights reserved.
5	*	5	*
6	* Redistribution and use in source and binary forms, with or without	6	* Redistribution and use in source and binary forms, with or without
7	* modification, are permitted provided that the following conditions	7	* modification, are permitted provided that the following conditions
8	* are met:	8	* are met:
9	*	9	*
10	* - Redistributions of source code must retain the above copyright	10	* - Redistributions of source code must retain the above copyright
11	* notice, this list of conditions and the following disclaimer.	11	* notice, this list of conditions and the following disclaimer.
12	* - Redistributions in binary form must reproduce the above copyright	12	* - Redistributions in binary form must reproduce the above copyright
13	* notice, this list of conditions and the following disclaimer in the	13	* notice, this list of conditions and the following disclaimer in the
14	* documentation and/or other materials provided with the distribution.	14	* documentation and/or other materials provided with the distribution.
15	* - The name of the author may not be used to endorse or promote products	15	* - The name of the author may not be used to endorse or promote products
16	* derived from this software without specific prior written permission.	16	* derived from this software without specific prior written permission.
17	*	17	*
18	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR	18	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
19	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES	19	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
20	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.	20	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
21	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,	21	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
22	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT	22	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
23	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,	23	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
24	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY	24	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
25	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT	25	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
26	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF	26	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
27	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.	27	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28	*/	28	*/
29		29
30	/** @addtogroup fs	30	/** @addtogroup fs
31	* @{	31	* @{
32	*/	32	*/
33		33
34	/**	34	/**
35	* @file fat.c	35	* @file fat.c
36	* @brief FAT file system driver for HelenOS.	36	* @brief FAT file system driver for HelenOS.
37	*/	37	*/
38		38
39	#include <ipc/ipc.h>	39	#include <ipc/ipc.h>
40	#include <ipc/services.h>	40	#include <ipc/services.h>
41	#include <async.h>	41	#include <async.h>
42	#include <errno.h>	42	#include <errno.h>
43	#include <unistd.h>	43	#include <unistd.h>
44	#include <stdio.h>>	44	#include <stdio.h>>
45	#include "../../vfs/vfs.h"	45	#include "../../vfs/vfs.h"
46		46
47	#define dprintf(...) printf(__VA_ARGS__)	47	#define dprintf(...) printf(__VA_ARGS__)
48		48
49	vfs_info_t fat_vfs_info = {	49	vfs_info_t fat_vfs_info = {
50	.name = "fat",	50	.name = "fat",
51	.ops = {	51	.ops = {
52	[IPC_METHOD_TO_VFS_OP(VFS_REGISTER)] = VFS_OP_DEFINED,	52	[IPC_METHOD_TO_VFS_OP(VFS_REGISTER)] = VFS_OP_DEFINED,
53	[IPC_METHOD_TO_VFS_OP(VFS_MOUNT)] = VFS_OP_DEFINED,	53	[IPC_METHOD_TO_VFS_OP(VFS_MOUNT)] = VFS_OP_DEFINED,
54	[IPC_METHOD_TO_VFS_OP(VFS_UNMOUNT)] = VFS_OP_DEFINED,	54	[IPC_METHOD_TO_VFS_OP(VFS_UNMOUNT)] = VFS_OP_DEFINED,
55	[IPC_METHOD_TO_VFS_OP(VFS_LOOKUP)] = VFS_OP_DEFINED,	55	[IPC_METHOD_TO_VFS_OP(VFS_LOOKUP)] = VFS_OP_DEFINED,
56	[IPC_METHOD_TO_VFS_OP(VFS_OPEN)] = VFS_OP_DEFINED,	56	[IPC_METHOD_TO_VFS_OP(VFS_OPEN)] = VFS_OP_DEFINED,
57	[IPC_METHOD_TO_VFS_OP(VFS_CREATE)] = VFS_OP_DEFINED,	57	[IPC_METHOD_TO_VFS_OP(VFS_CREATE)] = VFS_OP_DEFINED,
58	[IPC_METHOD_TO_VFS_OP(VFS_CLOSE)] = VFS_OP_DEFINED,	58	[IPC_METHOD_TO_VFS_OP(VFS_CLOSE)] = VFS_OP_DEFINED,
59	[IPC_METHOD_TO_VFS_OP(VFS_READ)] = VFS_OP_DEFINED,	59	[IPC_METHOD_TO_VFS_OP(VFS_READ)] = VFS_OP_DEFINED,
60	[IPC_METHOD_TO_VFS_OP(VFS_WRITE)] = VFS_OP_NULL,	60	[IPC_METHOD_TO_VFS_OP(VFS_WRITE)] = VFS_OP_NULL,
61	[IPC_METHOD_TO_VFS_OP(VFS_SEEK)] = VFS_OP_DEFAULT	61	[IPC_METHOD_TO_VFS_OP(VFS_SEEK)] = VFS_OP_DEFAULT
62	}	62	}
63	};	63	};
64		64
65	/*	65	/*
66	* This fibril processes request from the VFS server.	66	* This fibril processes request from the VFS server.
67	*/	67	*/
68	void fat_connection(ipc_callid_t iid, ipc_call_t *icall)	68	void fat_connection(ipc_callid_t iid, ipc_call_t *icall)
69	{	69	{
70	dprintf("Callback connection established.\n");	70	dprintf("Callback connection established.\n");
71	while (1) {	71	while (1) {
72	ipc_callid_t callid;	72	ipc_callid_t callid;
73	ipc_call_t call;	73	ipc_call_t call;
74		74
75	callid = async_get_call(&call);	75	callid = async_get_call(&call);
76	ipc_answer_fast(callid, ENOTSUP, 0, 0);	76	ipc_answer_fast(callid, ENOTSUP, 0, 0);
77	}	77	}
78	}	78	}
79		79
80	int main(int argc, char **argv)	80	int main(int argc, char **argv)
81	{	81	{
82	int vfs_phone;	82	int vfs_phone;
83		83
84	printf("FAT: HelenOS FAT file system server.\n");	84	printf("FAT: HelenOS FAT file system server.\n");
85		85
86	vfs_phone = ipc_connect_me_to(PHONE_NS, SERVICE_VFS, 0);	86	vfs_phone = ipc_connect_me_to(PHONE_NS, SERVICE_VFS, 0);
87	while (vfs_phone < EOK) {	87	while (vfs_phone < EOK) {
88	usleep(10000);	88	usleep(10000);
89	vfs_phone = ipc_connect_me_to(PHONE_NS, SERVICE_VFS, 0);	89	vfs_phone = ipc_connect_me_to(PHONE_NS, SERVICE_VFS, 0);
90	}	90	}
91		91
92	/*	92	/*
93	* Tell VFS that we are here and want to get registered.	93	* Tell VFS that we are here and want to get registered.
94	* We use the async framework because VFS will answer the request	94	* We use the async framework because VFS will answer the request
95	* out-of-order, when it knows that the operation succeeded or failed.	95	* out-of-order, when it knows that the operation succeeded or failed.
96	*/	96	*/
97	ipc_call_t answer;	97	ipc_call_t answer;
98	aid_t req = async_send_2(vfs_phone, VFS_REGISTER, 0, 0, &answer);	98	aid_t req = async_send_2(vfs_phone, VFS_REGISTER, 0, 0, &answer);
99		99
100	/*	100	/*
101	* Send our VFS info structure to VFS.	101	* Send our VFS info structure to VFS.
102	*/	102	*/
103	int rc = ipc_data_send(vfs_phone, &fat_vfs_info, sizeof(fat_vfs_info));	103	int rc = ipc_data_send(vfs_phone, &fat_vfs_info, sizeof(fat_vfs_info));
104	if (rc != EOK) {	104	if (rc != EOK) {
105	async_wait_for(req, NULL);	105	async_wait_for(req, NULL);
106	return rc;	106	return rc;
107	}	107	}
108		108
109	/*	109	/*
110	* Ask VFS for callback connection.	110	* Ask VFS for callback connection.
111	*/	111	*/
112	ipcarg_t phonehash;	112	ipcarg_t phonehash;
113	ipc_connect_to_me(vfs_phone, 0, 0, &phonehash);	113	ipc_connect_to_me(vfs_phone, 0, 0, &phonehash);
114		114
115	async_new_connection(phonehash, 0, NULL, fat_connection);	115	async_new_connection(phonehash, 0, NULL, fat_connection);
116		116
117	/*	117	/*
118	* Pick up the answer for the request to the VFS_REQUEST call.	118	* Pick up the answer for the request to the VFS_REQUEST call.
119	*/	119	*/
120	async_wait_for(req, NULL);	120	async_wait_for(req, NULL);
121	dprintf("FAT filesystem registered.\n");	121	dprintf("FAT filesystem registered.\n");
122		122
123	/*	123	/*
124	* TODO: Interestingly, if we return, the only thread dies.	124	* TODO: Interestingly, if we merely return, the only thread dies.
125	* If the only thread dies, the whole task is destroyed.	125	* If the only thread dies, the whole task is destroyed.
126	* Prevent the thread from exiting when there are active fibrils.	126	* Prevent the thread from exiting when there are active fibrils.
127	*/	127	*/
128	while(1)	128	fibril_schedule_next_adv(FIBRIL_FROM_DEAD);
129	usleep(1000000);	129	/* not reached */
130		130
131	return 0;	131	return 0;
132	}	132	}
133		133
134	/**	134	/**
135	* @}	135	* @}
136	*/	136	*/
137		137