Subversion Repositories HelenOS

Rev

Rev 2543 | Rev 2560 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

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
	 */
2523 jermar 62
	ipc_answer_fast(iid, EOK, 0, 0);
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
67
	 * each connection open for a while before we close it. The benefit of
68
	 * this is that the client doesn't have to establish a new connection
69
	 * upon each request.  On the other hand, the client must be ready to
70
	 * re-establish a connection if we hang it up due to reaching of maximum
71
	 * number of requests per connection or due to the client timing out.
2520 jermar 72
	 */
2523 jermar 73
 
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);
88
			keep_on_going = false;
89
			break;
90
		case VFS_MOUNT:
91
		case VFS_UNMOUNT:
92
		case VFS_OPEN:
93
		case VFS_CREATE:
94
		case VFS_CLOSE:
95
		case VFS_READ:
96
		case VFS_WRITE:
97
		case VFS_SEEK:
98
		default:
99
			ipc_answer_fast(callid, ENOTSUP, 0, 0);
100
			break;
101
		}
2520 jermar 102
	}
2523 jermar 103
 
104
	/* TODO: cleanup after the client */
105
 
2520 jermar 106
}
107
 
2518 jermar 108
int main(int argc, char **argv)
109
{
2520 jermar 110
	ipcarg_t phonead;
111
 
2532 jermar 112
	printf("VFS: HelenOS VFS server\n");
113
 
2542 jermar 114
	/*
115
	 * Initialize the list of registered file systems.
116
	 */
2526 jermar 117
	list_initialize(&fs_head);
2542 jermar 118
 
119
	/*
120
	 * Allocate and initialize the Path Lookup Buffer.
121
	 */
122
	list_initialize(&plb_head);
123
	plb = as_get_mappable_page(PLB_SIZE);
2543 jermar 124
	if (!plb) {
125
		printf("Cannot allocate a mappable piece of address space\n");
126
		return ENOMEM;
127
	}
128
	if (as_area_create(plb, PLB_SIZE, AS_AREA_READ | AS_AREA_WRITE |
129
	    AS_AREA_CACHEABLE) != plb) {
130
		printf("Cannot create address space area.\n");
131
		return ENOMEM;
132
	}
133
	memset(plb, 0, PLB_SIZE);
2542 jermar 134
 
135
	/*
136
	 * Set a connectio handling function/fibril.
137
	 */
2520 jermar 138
	async_set_client_connection(vfs_connection);
2542 jermar 139
 
140
	/*
141
	 * Register at the naming service.
142
	 */
2520 jermar 143
	ipc_connect_to_me(PHONE_NS, SERVICE_VFS, 0, &phonead);
2542 jermar 144
 
145
	/*
146
	 * Start accepting connections.
147
	 */
2520 jermar 148
	async_manager();
2518 jermar 149
	return 0;
150
}
151
 
152
/**
153
 * @}
154
 */