Context Navigation

source: trunk/kernel/vfs/vfs.c @ 131

Last change on this file since 131 was 124, checked in by max@…, 7 years ago
rename hal_wbflush->hal_fence
File size: 44.3 KB

Rev	Line
[1]	1	/*
	2	* vfs.c - Virtual File System implementation.
	3	*
	4	* Author Mohamed Lamine Karaoui (2015)
	5	* Alain Greiner (2016)
	6	*
	7	* Copyright (c) UPMC Sorbonne Universites
	8	*
	9	* This file is part of ALMOS-MKH.
	10	*
	11	* ALMOS-MKH is free software; you can redistribute it and/or modify it
	12	* under the terms of the GNU General Public License as published by
	13	* the Free Software Foundation; version 2.0 of the License.
	14	*
	15	* ALMOS-MKH is distributed in the hope that it will be useful, but
	16	* WITHOUT ANY WARRANTY; without even the implied warranty of
	17	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	18	* General Public License for more details.
	19	*
	20	* You should have received a copy of the GNU General Public License
	21	* along with ALMOS-MKH; if not, write to the Free Software Foundation,
	22	* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
	23	*/
	24
	25
[14]	26	#include <kernel_config.h>
[1]	27	#include <hal_types.h>
	28	#include <hal_atomic.h>
	29	#include <hal_special.h>
	30	#include <readlock.h>
	31	#include <spinlock.h>
	32	#include <printk.h>
	33	#include <list.h>
	34	#include <xlist.h>
	35	#include <slist.h>
	36	#include <xhtab.h>
[23]	37	#include <rpc.h>
[1]	38	#include <errno.h>
	39	#include <kmem.h>
	40	#include <mapper.h>
	41	#include <thread.h>
	42	#include <process.h>
[23]	43	#include <vfs.h>
[1]	44	#include <fatfs.h>
	45	#include <ramfs.h>
[23]	46	#include <devfs.h>
	47	#include <syscalls.h>
[1]	48
	49
	50	//////////////////////////////////////////////////////////////////////////////////////////
[50]	51	// Extern variables
[1]	52	//////////////////////////////////////////////////////////////////////////////////////////
	53
[50]	54	extern vfs_ctx_t fs_context[FS_TYPES_NR]; // allocate in kernel_init.c
	55
[1]	56	//////////////////////////////////////////////////////////////////////////////////////////
	57	// Context related functions
	58	//////////////////////////////////////////////////////////////////////////////////////////
	59
[23]	60	////////////////////////////////////////////
[1]	61	error_t vfs_ctx_inum_alloc( vfs_ctx_t * ctx,
	62	uint32_t * inum )
	63	{
	64	// get lock on inum allocator
	65	spinlock_lock( &ctx->lock );
	66
	67	// get lid from local inum allocator
[23]	68	uint32_t lid = bitmap_ffc( ctx->bitmap , CONFIG_VFS_MAX_INODES );
[1]	69
	70	if( lid == -1 ) // no more free slot => error
	71	{
	72	// release lock
	73	spinlock_unlock( &ctx->lock );
	74
	75	// return error
	76	return 1;
	77	}
	78	else // found => return inum
	79	{
	80	// set slot allocated
[23]	81	bitmap_set( ctx->bitmap , lid );
[1]	82
	83	// release lock
	84	spinlock_unlock( &ctx->lock );
	85
	86	// return inum
	87	*inum = (((uint32_t)local_cxy) << 16) \| (lid & 0xFFFF);
	88	return 0;
	89	}
	90	}
	91
	92	////////////////////////////////////////////
	93	void vfs_ctx_inum_release( vfs_ctx_t * ctx,
	94	uint32_t inum )
	95	{
[23]	96	bitmap_clear( ctx->bitmap , inum & 0xFFFF );
[1]	97	}
	98
	99	//////////////////////////////////////////////////////////////////////////////////////////
	100	// Inode related functions
	101	//////////////////////////////////////////////////////////////////////////////////////////
	102
[23]	103	//////////////////////////////////////////////////////
	104
	105	error_t vfs_inode_create( xptr_t dentry_xp,
	106	vfs_fs_type_t fs_type,
	107	vfs_inode_type_t inode_type,
	108	uint32_t attr,
	109	uint32_t rights,
	110	uid_t uid,
	111	gid_t gid,
	112	xptr_t * inode_xp )
[1]	113	{
	114	mapper_t * mapper; // associated mapper( to be allocated)
	115	vfs_inode_t * inode; // inode descriptor (to be allocated)
	116	uint32_t inum; // inode identifier (to be allocated)
	117	vfs_ctx_t * ctx; // file system context
	118	kmem_req_t req; // request to kernel memory allocator
	119	error_t error;
	120
[23]	121	// check fs type and get pointer on context
	122	if ( fs_type == FS_TYPE_FATFS ) ctx = &fs_context[FS_TYPE_FATFS];
	123	else if( fs_type == FS_TYPE_RAMFS ) ctx = &fs_context[FS_TYPE_RAMFS];
	124	else if( fs_type == FS_TYPE_DEVFS ) ctx = &fs_context[FS_TYPE_DEVFS];
[1]	125	else
	126	{
	127	ctx = NULL;
	128	printk("\n[PANIC] in %s : undefined file system type\n", __FUNCTION__ );
	129	hal_core_sleep();
	130	}
	131
	132	// allocate inum
	133	error = vfs_ctx_inum_alloc( ctx , &inum );
	134
	135	if( error )
	136	{
	137	printk("\n[ERROR] in %s : cannot allocate inum\n", __FUNCTION__ );
	138	return ENOMEM;
	139	}
	140
	141	// allocate memory for mapper
	142	mapper = mapper_create();
	143
	144	if( mapper == NULL )
	145	{
	146	printk("\n[ERROR] in %s : cannot allocate mapper\n", __FUNCTION__ );
	147	vfs_ctx_inum_release( ctx , inum );
	148	return ENOMEM;
	149	}
	150
[23]	151	// allocate memory for VFS inode descriptor
[1]	152	req.type = KMEM_VFS_INODE;
	153	req.size = sizeof(vfs_inode_t);
	154	req.flags = AF_KERNEL \| AF_ZERO;
	155	inode = (vfs_inode_t *)kmem_alloc( &req );
	156
	157	if( inode == NULL )
	158	{
	159	printk("\n[ERROR] in %s : cannot allocate inode descriptor\n", __FUNCTION__ );
	160	vfs_ctx_inum_release( ctx , inum );
	161	mapper_destroy( mapper );
	162	return ENOMEM;
	163	}
	164
	165	// initialize inode descriptor
	166	inode->gc = 0;
[23]	167	inode->type = inode_type;
[1]	168	inode->inum = inum;
	169	inode->attr = attr;
[23]	170	inode->rights = rights;
[1]	171	inode->uid = uid;
	172	inode->gid = gid;
	173	inode->refcount = 0;
	174	inode->parent_xp = dentry_xp;
	175	inode->ctx = ctx;
	176	inode->mapper = NULL;
	177
	178	// initialise threads waiting queue
	179	xlist_root_init( XPTR( local_cxy , &inode->wait_root ) );
	180
	181	// initialize dentries hash table, if new inode is a directory
[23]	182	if( inode_type == INODE_TYPE_DIR ) xhtab_init( &inode->children , XHTAB_DENTRY_TYPE );
[1]	183
	184	// initialize inode locks
[10]	185	remote_rwlock_init( XPTR( local_cxy , &inode->data_lock ) );
[1]	186	remote_spinlock_init( XPTR( local_cxy , &inode->main_lock ) );
	187
	188	// return extended pointer on inode
	189	*inode_xp = XPTR( local_cxy , inode );
	190	return 0;
	191
	192	} // end vfs_inode_create()
	193
	194	/////////////////////////////////////////////
	195	void vfs_inode_destroy( vfs_inode_t * inode )
	196	{
	197	if( inode->refcount )
	198	{
	199	printk("\n[PANIC] in %s : inode refcount non zero\n", __FUNCTION__ );
	200	hal_core_sleep();
	201	}
	202
	203	// release memory allocated for mapper
	204	mapper_destroy( inode->mapper );
	205
	206	// release memory allocate for inode descriptor
	207	kmem_req_t req;
	208	req.ptr = inode;
	209	req.type = KMEM_VFS_INODE;
	210	kmem_free( &req );
	211
	212	} // end vfs_inode_destroy()
	213
	214	////////////////////////////////////////////
	215	void vfs_inode_remote_up( xptr_t inode_xp )
	216	{
	217	// get inode cluster and local pointer
	218	cxy_t inode_cxy = GET_CXY( inode_xp );
	219	vfs_inode_t * inode_ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	220
	221	hal_remote_atomic_add( XPTR( inode_cxy , &inode_ptr->refcount ) , 1 );
	222	}
	223
	224	//////////////////////////////////////////////
	225	void vfs_inode_remote_down( xptr_t inode_xp )
	226	{
	227	// get inode cluster and local pointer
	228	cxy_t inode_cxy = GET_CXY( inode_xp );
	229	vfs_inode_t * inode_ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	230
	231	hal_remote_atomic_add( XPTR( inode_cxy , &inode_ptr->refcount ) , -1 );
	232	}
	233
	234	//////////////////////////////////////////////
	235	uint32_t vfs_inode_get_size( xptr_t inode_xp )
	236	{
	237	// get inode cluster and local pointer
	238	cxy_t cxy = GET_CXY( inode_xp );
	239	vfs_inode_t * ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	240
	241	// get size
[10]	242	remote_rwlock_rd_lock( XPTR( cxy , &ptr->data_lock ) );
[1]	243	uint32_t size = hal_remote_lw( XPTR( cxy , &ptr->size ) );
[10]	244	remote_rwlock_rd_unlock( XPTR( cxy , &ptr->data_lock ) );
[1]	245	return size;
	246	}
	247
[101]	248	////////////////////////////////////////////
	249	void vfs_inode_set_size( xptr_t inode_xp,
[1]	250	uint32_t size )
	251	{
	252	// get inode cluster and local pointer
	253	cxy_t cxy = GET_CXY( inode_xp );
	254	vfs_inode_t * ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	255
	256	// set size
[10]	257	remote_rwlock_wr_unlock( XPTR( cxy , &ptr->data_lock ) );
[1]	258	hal_remote_sw( XPTR( cxy , &ptr->size ) , size );
[10]	259	remote_rwlock_wr_unlock( XPTR( cxy , &ptr->data_lock ) );
[1]	260	}
	261
[101]	262	////////////////////////////////////////
	263	void vfs_inode_unlock( xptr_t inode_xp )
[1]	264	{
	265	// get inode cluster and local pointer
	266	cxy_t cxy = GET_CXY( inode_xp );
	267	vfs_inode_t * ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	268
	269	// release the main lock
	270	remote_spinlock_unlock( XPTR( cxy , &ptr->main_lock ) );
	271	}
	272
[101]	273	//////////////////////////////////////
	274	void vfs_inode_lock( xptr_t inode_xp )
[1]	275	{
	276	// get inode cluster and local pointer
	277	cxy_t cxy = GET_CXY( inode_xp );
	278	vfs_inode_t * ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	279
	280	// get the main lock
	281	remote_spinlock_lock( XPTR( cxy , &ptr->main_lock ) );
	282	}
	283
[101]	284	/////////////////////////////////////////
	285	xptr_t vfs_inode_owner( xptr_t inode_xp )
	286	{
	287	// get inode cluster and local pointer
	288	cxy_t cxy = GET_CXY( inode_xp );
	289	vfs_inode_t * ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	290
	291	// get the main lock
	292	return remote_spinlock_owner( XPTR( cxy , &ptr->main_lock ) );
	293	}
	294
[1]	295	//////////////////////////////////////////////////////////////////////////////////////////
	296	// Dentry related functions
	297	//////////////////////////////////////////////////////////////////////////////////////////
	298
[23]	299	///////////////////////////////////////////////////
	300	error_t vfs_dentry_create( vfs_fs_type_t fs_type,
	301	char * name,
	302	vfs_inode_t * parent,
	303	xptr_t * dentry_xp )
[1]	304	{
	305	vfs_ctx_t * ctx; // context descriptor
	306	vfs_dentry_t * dentry; // dentry descriptor (to be allocated)
	307	kmem_req_t req; // request to kernel memory allocator
	308
	309	// check type and get pointer on context
[23]	310	if ( fs_type == FS_TYPE_FATFS ) ctx = &fs_context[FS_TYPE_FATFS];
	311	else if( fs_type == FS_TYPE_RAMFS ) ctx = &fs_context[FS_TYPE_RAMFS];
	312	else if( fs_type == FS_TYPE_DEVFS ) ctx = &fs_context[FS_TYPE_DEVFS];
[1]	313	else
	314	{
	315	ctx = NULL;
	316	printk("\n[PANIC] in %s : undefined file system type\n", __FUNCTION__ );
	317	hal_core_sleep();
	318	}
	319
	320	// get name length
	321	uint32_t length = strlen( name );
	322
[23]	323	if( length >= CONFIG_VFS_MAX_NAME_LENGTH )
[1]	324	{
	325	printk("\n[ERROR] in %s : name too long\n", __FUNCTION__ );
	326	return EINVAL;
	327	}
	328
	329	// allocate memory for dentry descriptor
	330	req.type = KMEM_VFS_DENTRY;
	331	req.size = sizeof(vfs_dentry_t);
	332	req.flags = AF_KERNEL \| AF_ZERO;
	333	dentry = (vfs_dentry_t *)kmem_alloc( &req );
	334
	335	if( dentry == NULL )
	336	{
	337	printk("\n[ERROR] in %s : cannot allocate dentry descriptor\n", __FUNCTION__ );
	338	return ENOMEM;
	339	}
	340
	341	// initialize dentry descriptor
[23]	342
[1]	343	dentry->ctx = ctx;
	344	dentry->length = length;
	345	dentry->parent = parent;
	346	strcpy( dentry->name , name );
	347
[23]	348	// register dentry in hash table rooted in parent inode
	349	xhtab_insert( XPTR( local_cxy , &parent->children ),
	350	name,
	351	XPTR( local_cxy , &dentry->xlist ) );
	352
	353	// return extended pointer on dentry
[1]	354	*dentry_xp = XPTR( local_cxy , dentry );
	355
	356	return 0;
	357
	358	} // end vfs_dentry_create()
	359
	360	////////////////////////////////////////////////
	361	void vfs_dentry_destroy( vfs_dentry_t * dentry )
	362	{
	363	if( dentry->refcount )
	364	{
	365	printk("\n[PANIC] in %s : dentry refcount non zero\n", __FUNCTION__ );
	366	hal_core_sleep();
	367	}
	368
	369	kmem_req_t req;
	370	req.ptr = dentry;
	371	req.type = KMEM_VFS_DENTRY;
	372	kmem_free( &req );
	373	}
	374
	375
	376	//////////////////////////////////////////////////////////////////////////////////////////
	377	// File descriptor related functions
	378	//////////////////////////////////////////////////////////////////////////////////////////
	379
[23]	380	/////////////////////////////////////////////
	381	error_t vfs_file_create( vfs_inode_t * inode,
	382	uint32_t attr,
	383	xptr_t * file_xp )
	384	{
	385	vfs_file_t * file;
	386	kmem_req_t req;
	387
	388	// allocate memory for new file descriptor
	389	req.type = KMEM_VFS_FILE;
	390	req.size = sizeof(vfs_file_t);
	391	req.flags = AF_KERNEL \| AF_ZERO;
	392	file = (vfs_file_t *)kmem_alloc( &req );
	393
	394	if( file == NULL ) return ENOMEM;
	395
	396	// initializes new file descriptor
	397	file->gc = 0;
	398	file->type = inode->type;
	399	file->attr = attr;
	400	file->offset = 0;
	401	file->refcount = 0;
	402	file->inode = inode;
	403	file->ctx = inode->ctx;
	404	file->mapper = inode->mapper;
	405
	406	remote_rwlock_init( XPTR( local_cxy , &file->lock ) );
	407
	408	*file_xp = XPTR( local_cxy , file );
	409	return 0;
	410
	411	} // end vfs_file_create()
	412
	413	///////////////////////////////////////////
	414	void vfs_file_destroy( vfs_file_t * file )
	415	{
	416	if( file->refcount )
	417	{
	418	printk("\n[PANIC] in %s : file refcount non zero\n", __FUNCTION__ );
	419	hal_core_sleep();
	420	}
	421
	422	kmem_req_t req;
	423	req.ptr = file;
	424	req.type = KMEM_VFS_FILE;
	425	kmem_free( &req );
	426
	427	} // end vfs_file_destroy()
	428
	429
[1]	430	////////////////////////////////////////
	431	void vfs_file_count_up( xptr_t file_xp )
	432	{
	433	// get file cluster and local pointer
	434	cxy_t file_cxy = GET_CXY( file_xp );
	435	vfs_file_t * file_ptr = (vfs_file_t *)GET_PTR( file_xp );
	436
	437	// atomically increment count
	438	hal_remote_atomic_add( XPTR( file_cxy , &file_ptr->refcount ) , 1 );
	439	}
	440
	441	//////////////////////////////////////////
	442	void vfs_file_count_down( xptr_t file_xp )
	443	{
	444	// get file cluster and local pointer
	445	cxy_t file_cxy = GET_CXY( file_xp );
	446	vfs_file_t * file_ptr = (vfs_file_t *)GET_PTR( file_xp );
	447
	448	// atomically decrement count
	449	hal_remote_atomic_add( XPTR( file_cxy , &file_ptr->refcount ) , -1 );
	450	}
	451
[23]	452	//////////////////////////////////////////////////////////////////////////////////////////
	453	// File access related functions
	454	//////////////////////////////////////////////////////////////////////////////////////////
	455
	456	////////////////////////////////////
	457	error_t vfs_open( xptr_t cwd_xp,
	458	char * path,
	459	uint32_t flags,
	460	uint32_t mode,
	461	xptr_t * new_file_xp,
	462	uint32_t * new_file_id )
[1]	463	{
[23]	464	error_t error;
	465	xptr_t inode_xp; // extended pointer on target inode
	466	cxy_t inode_cxy; // inode cluster identifier
	467	vfs_inode_t * inode_ptr; // inode local pointer
	468	uint32_t file_attr; // file descriptor attributes
	469	uint32_t lookup_mode; // lookup working mode
	470	xptr_t file_xp; // extended pointer on created file descriptor
	471	uint32_t file_id; // created file descriptor index in reference fd_array
[1]	472
[101]	473	vfs_dmsg("\n[INFO] %s : enters for <%s> at cycle %d\n",
	474	__FUNCTION__ , path , hal_get_cycles() );
	475
[23]	476	// compute lookup working mode
	477	lookup_mode = VFS_LOOKUP_OPEN;
	478	if( (flags & O_DIR ) ) lookup_mode \|= VFS_LOOKUP_DIR;
	479	if( (flags & O_CREAT ) ) lookup_mode \|= VFS_LOOKUP_CREATE;
	480	if( (flags & O_EXCL ) ) lookup_mode \|= VFS_LOOKUP_EXCL;
	481
	482	// compute attributes for the created file
	483	file_attr = 0;
	484	if( (flags & O_RDONLY ) == 0 ) file_attr \|= FD_ATTR_READ_ENABLE;
	485	if( (flags & O_WRONLY ) == 0 ) file_attr \|= FD_ATTR_WRITE_ENABLE;
	486	if( (flags & O_SYNC ) ) file_attr \|= FD_ATTR_SYNC;
	487	if( (flags & O_APPEND ) ) file_attr \|= FD_ATTR_APPEND;
	488	if( (flags & O_CLOEXEC) ) file_attr \|= FD_ATTR_CLOSE_EXEC;
[1]	489
[23]	490	// get extended pointer on target inode
	491	error = vfs_lookup( cwd_xp , path , lookup_mode , &inode_xp );
	492
[101]	493	vfs_dmsg("\n[INFO] %s : get inode_xp = %l for <%s> at cycle %d\n",
	494	__FUNCTION__ , inode_xp , path , hal_get_cycles() );
	495
[23]	496	if( error ) return error;
	497
	498	// get target inode cluster and local pointer
	499	inode_cxy = GET_CXY( inode_xp );
	500	inode_ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	501
	502	// create a new file descriptor in cluster containing inode
	503	if( inode_cxy == local_cxy ) // target cluster is local
[1]	504	{
[23]	505	error = vfs_file_create( inode_ptr , file_attr , &file_xp );
[1]	506	}
[23]	507	else // target cluster is remote
	508	{
	509	rpc_vfs_file_create_client( inode_cxy , inode_ptr , file_attr , &file_xp , &error );
	510	}
[1]	511
[23]	512	if( error ) return error;
[1]	513
[23]	514	// allocate and register a new file descriptor index in reference cluster fd_array
	515	error = process_fd_register( file_xp , &file_id );
[1]	516
[23]	517	if( error ) return error;
[1]	518
[23]	519	// success
	520	*new_file_xp = file_xp;
	521	*new_file_id = file_id;
	522	return 0;
[1]	523
[23]	524	} // end vfs_open()
	525
	526	/////////////////////////////////////
	527	error_t vfs_move( bool_t to_buffer,
	528	xptr_t file_xp,
	529	void * buffer,
	530	uint32_t size )
	531	{
	532	assert( ( file_xp != XPTR_NULL ) , __FUNCTION__ , "file_xp == XPTR_NULL" );
	533
	534	cxy_t file_cxy; // remote file descriptor cluster
	535	vfs_file_t * file_ptr; // remote file descriptor local pointer
	536	vfs_inode_type_t inode_type;
	537	uint32_t file_offset; // current offset in file
	538	mapper_t * mapper;
	539	error_t error;
	540
	541	// get cluster and local pointer on remote file descriptor
	542	file_cxy = GET_CXY( file_xp );
	543	file_ptr = (vfs_file_t *)GET_PTR( file_xp );
	544
	545	// get inode type from remote file descriptor
	546	inode_type = hal_remote_lw( XPTR( file_cxy , &file_ptr->type ) );
	547
	548	// action depends on inode type
	549	if( inode_type == INODE_TYPE_FILE )
	550	{
	551	// get mapper pointer and file offset from file descriptor
	552	file_offset = hal_remote_lw( XPTR( file_cxy , &file_ptr->offset ) );
	553	mapper = (mapper_t *)hal_remote_lpt( XPTR( file_cxy , &file_ptr->mapper ) );
	554
	555	// move data between mapper and buffer
	556	if( file_cxy == local_cxy )
	557	{
	558	error = mapper_move( mapper,
	559	to_buffer,
	560	file_offset,
	561	buffer,
	562	size );
	563	}
	564	else
	565	{
	566	rpc_mapper_move_client( file_cxy,
	567	mapper,
	568	to_buffer,
	569	file_offset,
	570	buffer,
	571	size,
	572	&error );
	573	}
	574
	575	return error;
	576	}
	577	else if (inode_type == INODE_TYPE_DIR )
	578	{
	579	printk("\n[ERROR] in %s : inode is a directory", __FUNCTION__ );
	580	return EINVAL;
	581	}
	582	else if (inode_type == INODE_TYPE_DEV )
	583	{
	584	// TODO
	585	return 0;
	586	}
	587	else
	588	{
	589	printk("\n[PANIC] in %s : illegal inode type\n", __FUNCTION__ );
	590	hal_core_sleep();
	591	return -1;
	592	}
	593	} // end vfs_access()
	594
	595	//////////////////////////////////////
	596	error_t vfs_lseek( xptr_t file_xp,
	597	uint32_t offset,
	598	uint32_t whence,
	599	uint32_t * new_offset )
	600	{
	601	printk("\n[PANIC] %s non implemented\n", __FUNCTION__ );
	602	hal_core_sleep();
[1]	603	return 0;
	604
[23]	605	assert( ( file_xp != XPTR_NULL ) , __FUNCTION__ , "file_xp == XPTR_NULL" );
	606
	607	} // vfs_lseek()
	608
	609	///////////////////////////////////
	610	error_t vfs_close( xptr_t file_xp,
	611	uint32_t file_id )
[1]	612	{
[23]	613	assert( (file_xp != XPTR_NULL) , __FUNCTION__ , "file_xp == XPTR_NULL" );
	614
	615	assert( (file_id < CONFIG_PROCESS_FILE_MAX_NR) , __FUNCTION__ , "illegal file_id" );
	616
	617	thread_t * this = CURRENT_THREAD;
	618	process_t * process = this->process;
	619
	620	// get cluster and local pointer on remote file descriptor
[1]	621	cxy_t file_cxy = GET_CXY( file_xp );
	622	vfs_file_t * file_ptr = (vfs_file_t *)GET_PTR( file_xp );
	623
[23]	624	// get local pointer on local cluster manager
	625	cluster_t * cluster = LOCAL_CLUSTER;
	626
	627	// get owner process cluster and lpid
	628	cxy_t owner_cxy = CXY_FROM_PID( process->pid );
	629	lpid_t lpid = LPID_FROM_PID( process->pid );
	630
	631	// get extended pointers on copies root and lock
	632	xptr_t root_xp = XPTR( owner_cxy , &cluster->pmgr.copies_root[lpid] );
	633	xptr_t lock_xp = XPTR( owner_cxy , &cluster->pmgr.copies_lock[lpid] );
	634
	635	// take the lock protecting the copies
	636	remote_spinlock_lock( lock_xp );
	637
	638	// 1) loop on the process descriptor copies to cancel all fd_array[file_id] entries
	639	xptr_t iter_xp;
	640	XLIST_FOREACH( root_xp , iter_xp )
[1]	641	{
[23]	642	xptr_t process_xp = XLIST_ELEMENT( iter_xp , process_t , copies_list );
	643	cxy_t process_cxy = GET_CXY( process_xp );
	644	process_t * process_ptr = (process_t *)GET_PTR( process_xp );
[1]	645
[23]	646	xptr_t lock_xp = XPTR( process_cxy , &process_ptr->fd_array.lock );
	647	xptr_t entry_xp = XPTR( process_cxy , &process_ptr->fd_array.array[file_id] );
	648
	649	// lock is required for atomic write of a 64 bits word
	650	remote_rwlock_wr_lock( lock_xp );
	651	hal_remote_swd( entry_xp , XPTR_NULL );
	652	remote_rwlock_wr_unlock( lock_xp );
	653
[124]	654	hal_fence();
[23]	655	}
	656
	657	// 2) release memory allocated to file descriptor in remote cluster
	658	if( file_cxy == local_cxy ) // file cluster is local
[1]	659	{
[23]	660	vfs_file_destroy( file_ptr );
	661	}
	662	else // file cluster is local
	663	{
	664	rpc_vfs_file_destroy_client( file_cxy , file_ptr );
	665	}
[1]	666
[23]	667	return 0;
[1]	668
[23]	669	} // end vfs_close()
[1]	670
	671	////////////////////////////////////
[23]	672	error_t vfs_unlink( xptr_t cwd_xp,
	673	char * path )
[1]	674	{
[23]	675	printk("\n[PANIC] %s non implemented\n", __FUNCTION__ );
	676	hal_core_sleep();
[1]	677	return 0;
[23]	678	} // vfs_unlink()
[1]	679
[23]	680	///////////////////////////////////////
	681	error_t vfs_stat( xptr_t file_xp,
	682	vfs_stat_t * k_stat )
[1]	683	{
[23]	684	printk("\n[PANIC] %s non implemented\n", __FUNCTION__ );
	685	hal_core_sleep();
[1]	686	return 0;
	687	}
	688
[23]	689	////////////////////////////////////////////
	690	error_t vfs_readdir( xptr_t file_xp,
	691	vfs_dirent_t * k_dirent )
[1]	692	{
[23]	693	printk("\n[PANIC] %s non implemented\n", __FUNCTION__ );
	694	hal_core_sleep();
[1]	695	return 0;
	696	}
	697
	698	//////////////////////////////////////
[23]	699	error_t vfs_mkdir( xptr_t file_xp,
	700	char * path,
	701	uint32_t mode )
[1]	702	{
[23]	703	printk("\n[PANIC] %s non implemented\n", __FUNCTION__ );
	704	hal_core_sleep();
[1]	705	return 0;
	706	}
	707
[23]	708	////////////////////////////////////
	709	error_t vfs_rmdir( xptr_t file_xp,
	710	char * path )
[1]	711	{
[23]	712	printk("\n[PANIC] %s non implemented\n", __FUNCTION__ );
	713	hal_core_sleep();
[1]	714	return 0;
	715	}
	716
[23]	717	///////////////////////////////////
	718	error_t vfs_chdir( xptr_t cwd_xp,
	719	char * path )
[1]	720	{
[23]	721	error_t error;
	722	xptr_t inode_xp; // extended pointer on target inode
	723	cxy_t inode_cxy; // target inode cluster identifier
	724	vfs_inode_t * inode_ptr; // target inode local pointer
	725	uint32_t mode; // lookup working mode
	726	vfs_inode_type_t inode_type; // target inode type
	727
	728	// set lookup working mode
	729	mode = 0;
	730
	731	// get extended pointer on target inode
	732	error = vfs_lookup( cwd_xp , path , mode , &inode_xp );
	733
	734	if( error ) return error;
	735
	736	// get inode cluster and local pointer
	737	inode_cxy = GET_CXY( inode_xp );
	738	inode_ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	739
	740	// get inode type from remote file
	741	inode_type = hal_remote_lw( XPTR( inode_cxy , &inode_ptr->type ) );
	742
	743	if( inode_type != INODE_TYPE_DIR )
	744	{
	745	CURRENT_THREAD->errno = ENOTDIR;
	746	return -1;
	747	}
	748
	749	printk("\n[PANIC] %s non fully implemented\n", __FUNCTION__ );
	750	hal_core_sleep();
[1]	751	return 0;
	752	}
	753
[23]	754	///////////////////////////////////
	755	error_t vfs_chmod( xptr_t cwd_xp,
	756	char * path,
	757	uint32_t rights )
[1]	758	{
[23]	759	error_t error;
	760	xptr_t inode_xp; // extended pointer on target inode
	761	cxy_t inode_cxy; // inode cluster identifier
	762	vfs_inode_t * inode_ptr; // inode local pointer
	763	uint32_t mode; // lookup working mode
	764	vfs_inode_type_t inode_type; // target inode type
	765
	766	// set lookup working mode
	767	mode = 0;
	768
	769	// get extended pointer on target inode
	770	error = vfs_lookup( cwd_xp , path , mode , &inode_xp );
	771
	772	if( error ) return error;
	773
	774	// get inode cluster and local pointer
	775	inode_cxy = GET_CXY( inode_xp );
	776	inode_ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	777
	778	// get inode type from remote inode
	779	inode_type = hal_remote_lw( XPTR( inode_cxy , &inode_ptr->type ) );
	780
	781
	782	printk("\n[PANIC] %s non fully implemented\n", __FUNCTION__ );
	783	hal_core_sleep();
[1]	784	return 0;
	785	}
	786
[23]	787	///////////////////////////////////
	788	error_t vfs_mkfifo( xptr_t cwd_xp,
	789	char * path,
	790	uint32_t rights )
	791	{
	792	printk("\n[PANIC] in %s : not implemented yet\n", __FUNCTION__ );
	793	hal_core_sleep();
	794	return 0;
	795	}
[1]	796
	797
	798
[23]	799	/////////////////////////////////////////////////////////////////////////////////////////r
[1]	800	// Inode Tree functions
	801	//////////////////////////////////////////////////////////////////////////////////////////
	802
	803	//////////////////////////////////////////////////////////////////////////////////////////
[23]	804	// This function is used by the vfs_lookup() function.
[1]	805	// It takes an extended pointer on a remote inode (parent directory inode),
	806	// and check access_rights violation for the calling thread.
	807	// It can be used by any thread running in any cluster.
	808	//////////////////////////////////////////////////////////////////////////////////////////
	809	// @ inode_xp : extended pointer on inode.
	810	// @ client_uid : client thread user ID
	811	// @ client_gid : client thread group ID
	812	// @ return true if access rights are violated.
	813	//////////////////////////////////////////////////////////////////////////////////////////
	814	bool_t vfs_access_denied( xptr_t inode_xp,
	815	uint32_t client_uid,
	816	uint32_t client_gid )
	817	{
	818	// get found inode cluster and local pointer
	819	cxy_t inode_cxy = GET_CXY( inode_xp );
	820	vfs_inode_t * inode_ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	821
	822	// get inode access mode, UID, and GID
	823	// TODO uint32_t mode = hal_remote_lw( XPTR( inode_cxy , &inode_ptr->mode ) );
	824	uid_t uid = hal_remote_lw( XPTR( inode_cxy , &inode_ptr->uid ) );
	825	gid_t gid = hal_remote_lw( XPTR( inode_cxy , &inode_ptr->gid ) );
	826
	827	// FIXME : me must use mode
	828	if( (uid == client_uid) \|\| (gid == client_gid) ) return false;
	829	else return true;
	830	}
	831
	832	//////////////////////////////////////////////////////////////////////////////////////////
	833	// This static function is used by the vfs_lookup() function.
	834	// It takes an extended pointer on a remote inode (parent directory inode), a directory
	835	// entry name, and returns an extended pointer on the child inode.
	836	// It can be used by any thread running in any cluster.
	837	//////////////////////////////////////////////////////////////////////////////////////////
	838	// @ parent_xp : extended pointer on parent inode in remote cluster.
	839	// @ name : dentry name
	840	// @ child_xp : [out] buffer for extended pointer on child inode.
	841	// @ return true if success / return false if not found.
	842	//////////////////////////////////////////////////////////////////////////////////////////
	843	static bool_t vfs_get_child( xptr_t parent_xp,
	844	char * name,
	845	xptr_t * child_xp )
	846	{
	847	xptr_t xhtab_xp; // extended pointer on hash table containing children dentries
	848	xptr_t dentry_xp; // extended pointer on children dentry
	849
	850	// get parent inode cluster and local pointer
	851	cxy_t parent_cxy = GET_CXY( parent_xp );
	852	vfs_inode_t * parent_ptr = (vfs_inode_t *)GET_PTR( parent_xp );
	853
	854	// get extended pointer on hash table of children directory entries
	855	xhtab_xp = XPTR( parent_cxy , &parent_ptr->children );
	856
	857	// search extended pointer on matching dentry
	858	dentry_xp = xhtab_lookup( xhtab_xp , name );
	859
	860	if( dentry_xp == XPTR_NULL ) return false;
	861
	862	// get dentry cluster and local pointer
	863	cxy_t dentry_cxy = GET_CXY( dentry_xp );
	864	vfs_dentry_t * dentry_ptr = (vfs_dentry_t *)GET_PTR( dentry_xp );
	865
	866	// return child inode
[101]	867	*child_xp = (xptr_t)hal_remote_lwd( XPTR( dentry_cxy , &dentry_ptr->child_xp ) );
[1]	868	return true;
	869	}
	870
	871	//////////////////////////////////////////////////////////////////////////////////////////
	872	// This static function is used by the vfs_lookup() function.
	873	// It takes the <current> pointer on a buffer containing a complete pathname, and return
	874	// in the <name> buffer, allocated by the caller, a single name in the path.
	875	// It return also in the <next> pointer the next character to analyse in the path.
	876	// Finally it returns a <last> boolean, that is true when the returned <name> is the
	877	// last name in the path. The names are supposed to be separated by one or several '/'
	878	// characters, that are not written in the <name> buffer.
	879	//////////////////////////////////////////////////////////////////////////////////////////
	880	// @ current : pointer on first character to analyse in buffer containing the path.
	881	// @ name : [out] pointer on buffer allocated by the caller for the returned name.
	882	// @ next : [out] pointer on next character to analyse in buffer containing the path.
	883	// @ last : [out] true if the returned name is the last (NUL character found).
	884	// @ return 0 if success / return EINVAL if string empty (first chracter is NUL).
	885	//////////////////////////////////////////////////////////////////////////////////////////
	886	static error_t vfs_get_name_from_path( char * current,
	887	char * name,
	888	char ** next,
	889	bool_t * last )
	890	{
	891	char * ptr = current;
	892
	893	// skip leading '/' characters
	894	while( *ptr == '/' ) ptr++;
	895
	896	// return EINVAL if string empty
	897	if( *ptr == 0 ) return EINVAL;
	898
	899	// copy all characters in name until NUL or '/'
	900	while( (ptr != 0) && (ptr !='/') ) (name++) = (ptr++);
	901
	902	// return last an next
	903	if( *ptr == 0 ) // last found character is NUL => last name in path
	904	{
	905	*last = true;
	906	}
	907	else // last found character is '/' => skip it
	908	{
	909	*last = false;
	910	*next = ptr + 1;
	911	}
	912
	913	return 0;
	914	}
	915
[23]	916	//////////////////////////////////////////////
	917	error_t vfs_lookup( xptr_t cwd_xp,
	918	char * pathname,
	919	uint32_t mode,
	920	xptr_t * inode_xp )
[1]	921	{
[101]	922	char name[CONFIG_VFS_MAX_NAME_LENGTH]; // one name in path
[1]	923
[23]	924	xptr_t parent_xp; // extended pointer on parent inode
	925	cxy_t parent_cxy; // cluster for parent inode
	926	vfs_inode_t * parent_ptr; // local pointer on parent inode
	927	xptr_t child_xp; // extended pointer on child inode
	928	cxy_t child_cxy; // cluster for child inode
	929	vfs_inode_t * child_ptr; // local pointer on child inode
	930	vfs_inode_type_t inode_type; // child inode type
	931	vfs_fs_type_t fs_type; // File system type
	932	vfs_ctx_t * ctx_ptr; // local pointer on FS context
	933	char * current; // current pointer on path
	934	char * next; // next value for current pointer
	935	bool_t last; // true when the name is the last in path
	936	bool_t found; // true when a child has been found
	937	thread_t * this; // pointer on calling thread descriptor
	938	process_t * process; // pointer on calling process descriptor
	939	error_t error;
[1]	940
[101]	941	vfs_dmsg("\n[INFO] %s : enters for <%s>\n",
	942	__FUNCTION__ , pathname );
	943
[1]	944	this = CURRENT_THREAD;
	945	process = this->process;
	946
	947	// get extended pointer on first inode to search
	948	if( pathname[0] == '/' ) parent_xp = process->vfs_root_xp;
	949	else parent_xp = cwd_xp;
	950
[101]	951	// initialise other loop variables
[1]	952	current = pathname;
	953	next = NULL;
	954	last = false;
	955	child_xp = XPTR_NULL;
	956
	957	// take lock on parent inode
[101]	958	vfs_inode_lock( parent_xp );
[1]	959
[101]	960	// load from device if one intermediate node not found
	961	// exit when last name found (i.e. last == true)
[1]	962	do
	963	{
[101]	964	// get one name from path, and the "last" flag
[1]	965	vfs_get_name_from_path( current , name , &next , &last );
	966
[101]	967	vfs_dmsg("\n[INFO] %s : looking for node <%s> / last = %d\n",
	968	__FUNCTION__ , name , last );
	969
[1]	970	// search a child dentry matching name for parent inode
	971	found = vfs_get_child( parent_xp,
	972	name,
	973	&child_xp );
	974
	975	if( found == false ) // child inode not found in inode tree => try to load it
	976	{
[101]	977	vfs_dmsg("\n[INFO] %s : node <%s> not found, try to load it\n",
	978	__FUNCTION__ , name );
	979
[1]	980	// release lock on parent inode
[101]	981	vfs_inode_unlock( parent_xp );
[1]	982
[23]	983	// get cluster and local pointer on parent inode
	984	parent_cxy = GET_CXY( parent_xp );
	985	parent_ptr = (vfs_inode_t *)GET_PTR( parent_xp );
[1]	986
[23]	987	// get parent inode FS type
	988	ctx_ptr = (vfs_ctx_t *)hal_remote_lpt( XPTR( parent_cxy , &parent_ptr->ctx ) );
	989	fs_type = ctx_ptr->type;
	990
	991	// get child inode type
	992	if( (last == false) \|\| (mode & VFS_LOOKUP_DIR) ) inode_type = INODE_TYPE_DIR;
	993	else inode_type = INODE_TYPE_FILE;
	994
	995	// insert a child dentry/inode in parent inode
	996	error = vfs_add_child_in_parent( inode_type,
	997	fs_type,
	998	parent_xp,
	999	name,
	1000	&child_xp );
	1001
[1]	1002	if( error )
	1003	{
	1004	printk("\n[ERROR] in %s : inode %s not found in path %s\n",
	1005	__FUNCTION__ , name , pathname );
	1006	return ENOENT;
	1007	}
	1008
	1009	// take lock on parent inode
[101]	1010	vfs_inode_lock( parent_xp );
[1]	1011	}
	1012
[101]	1013	vfs_dmsg("\n[INFO] %s : node <%s> found / parent = %l / child = %l / last = %d\n",
	1014	__FUNCTION__ , name , parent_xp , child_xp , last );
	1015
	1016	// TODO check access rights
[23]	1017	// error = vfs_access_denied( child_xp,
	1018	// client_uid,
	1019	// client_gid );
	1020	// if( error )
	1021	// {
	1022	// printk("\n[ERROR] in %s : permission denied for %s\n", __FUNCTION__ , name );
	1023	// return EACCES;
	1024	// }
[1]	1025
[101]	1026	printk("\n@@@ bloup 0 : parent lock owner = %l / child lock owner = %l\n",
	1027	vfs_inode_owner( parent_xp ) , vfs_inode_owner( child_xp ) );
	1028
[1]	1029	// take lock on child inode if not last
[101]	1030	if( last == false ) vfs_inode_lock( child_xp );
[1]	1031
[101]	1032	printk("\n@@@ bloup 1\n");
	1033
[1]	1034	// release lock on parent inode
[101]	1035	vfs_inode_unlock( parent_xp );
[1]	1036
[101]	1037	printk("\n@@@ bloup 2\n");
	1038
[1]	1039	// update loop variables
	1040	parent_xp = child_xp;
	1041	current = next;
[101]	1042
	1043	vfs_dmsg("\n[INFO] %s : complete node <%s> / last = %d\n",
	1044	__FUNCTION__ , name , last );
	1045
[1]	1046	}
	1047	while( last == false );
	1048
	1049	vfs_dmsg("\n[INFO] in %s : searched inode found for %s\n",
	1050	__FUNCTION__ , pathname );
	1051
	1052	// get cluster and local pointer on child inode
	1053	child_cxy = GET_CXY( child_xp );
	1054	child_ptr = (vfs_inode_t *)GET_PTR( child_xp );
	1055
	1056	// return searched pointers
	1057	*inode_xp = child_xp;
	1058
	1059	return 0;
	1060
	1061	} // end vfs_lookup()
	1062
	1063
	1064	////////////////////////////////////////////
	1065	error_t vfs_get_path( xptr_t searched_xp,
	1066	char * buffer,
	1067	uint32_t max_size )
	1068	{
	1069	xptr_t dentry_xp; // extended pointer on current dentry
	1070	char * name; // local pointer on current dentry name
	1071	uint32_t length; // length of current dentry name
	1072	uint32_t count; // number of characters written in buffer
	1073	uint32_t index; // slot index in buffer
[23]	1074	xptr_t inode_xp; // extended pointer on
[1]	1075
	1076	// implementation note:
	1077	// we use two variables "index" and "count" because the buffer
	1078	// is actually written in decreasing index order (from leaf to root)
	1079	// TODO : handle conflict with a concurrent rename
	1080	// FIXME : handle synchro in the loop ... [AG]
	1081
	1082	// set the NUL character in buffer / initialise buffer index and count
	1083	buffer[max_size - 1] = 0;
	1084	count = 1;
	1085	index = max_size - 2;
	1086
	1087	// initialize current inode
	1088	inode_xp = searched_xp;
	1089
	1090	// exit when root inode found (i.e. dentry_xp == XPTR_NULL)
	1091	do
	1092	{
	1093	// get inode cluster and local pointer
	1094	cxy_t inode_cxy = GET_CXY( inode_xp );
	1095	vfs_inode_t * inode_ptr = (vfs_inode_t *)GET_PTR( inode_xp );
	1096
	1097	// get extended pointer on parent dentry
	1098	dentry_xp = (xptr_t)hal_remote_lwd( XPTR( inode_cxy , inode_ptr->parent_xp ) );
	1099
	1100	// get dentry cluster and local pointer
	1101	cxy_t dentry_cxy = GET_CXY( dentry_xp );
	1102	vfs_dentry_t * dentry_ptr = (vfs_dentry_t *)GET_PTR( dentry_xp );
	1103
	1104	// get dentry name length and pointer
	1105	length = hal_remote_lw( XPTR( dentry_cxy , &dentry_ptr->length ) );
	1106	name = (char *)hal_remote_lpt( XPTR( dentry_cxy , &dentry_ptr->name ) );
	1107
	1108	// update index and count
	1109	index -= (length + 1);
	1110	count += (length + 1);
	1111
	1112	// check buffer overflow
	1113	if( count >= max_size )
	1114	{
	1115	printk("\n[ERROR] in %s : kernel buffer too small\n", __FUNCTION__ );
	1116	return EINVAL;
	1117	}
	1118
	1119	// update pathname
	1120	hal_remote_memcpy( XPTR( local_cxy , &buffer[index + 1] ) ,
	1121	XPTR( dentry_cxy , name ) , length );
	1122	buffer[index] = '/';
	1123
	1124	// get extended pointer on next inode
	1125	inode_xp = (xptr_t)hal_remote_lwd( XPTR( dentry_cxy , dentry_ptr->parent ) );
	1126	}
	1127	while( (dentry_xp != XPTR_NULL) );
	1128
	1129	return 0;
	1130
	1131	} // end vfs_get_path()
	1132
[23]	1133	///////////////////////////////////////////////////////////////
	1134	error_t vfs_add_child_in_parent( vfs_inode_type_t inode_type,
	1135	vfs_fs_type_t fs_type,
	1136	xptr_t parent_xp,
	1137	char * name,
	1138	xptr_t * child_xp )
[1]	1139	{
[23]	1140	error_t error;
	1141	xptr_t dentry_xp; // extended pointer on created dentry
	1142	xptr_t inode_xp; // extended pointer on created inode
	1143	cxy_t parent_cxy; // parent inode cluster identifier
	1144	vfs_inode_t * parent_ptr; // parent inode local pointer
	1145	vfs_ctx_t * parent_ctx; // parent inode context local pointer
[1]	1146
	1147	// get parent inode cluster and local pointer
[23]	1148	parent_cxy = GET_CXY( parent_xp );
	1149	parent_ptr = (vfs_inode_t *)GET_PTR( parent_xp );
[1]	1150
[23]	1151	// get parent inode context local pointer
	1152	parent_ctx = (vfs_ctx_t *)hal_remote_lpt( XPTR( parent_cxy , &parent_ptr->ctx ) );
	1153
[1]	1154	// create dentry
	1155	if( parent_cxy == local_cxy ) // parent cluster is the local cluster
	1156	{
[23]	1157	error = vfs_dentry_create( fs_type,
[1]	1158	name,
	1159	parent_ptr,
	1160	&dentry_xp );
	1161	}
	1162	else // parent cluster is remote
	1163	{
	1164	rpc_vfs_dentry_create_client( parent_cxy,
[23]	1165	fs_type,
[1]	1166	name,
	1167	parent_ptr,
	1168	&dentry_xp,
	1169	&error );
	1170	}
	1171
	1172	if( error )
	1173	{
	1174	printk("\n[ERROR] in %s : cannot create dentry in cluster %x\n",
	1175	__FUNCTION__ , parent_cxy );
	1176
	1177	return error;
	1178	}
	1179
	1180	// select a target cluster for child inode
	1181	uint32_t x_size = LOCAL_CLUSTER->x_size;
	1182	uint32_t y_size = LOCAL_CLUSTER->y_size;
	1183	uint32_t y_width = LOCAL_CLUSTER->y_width;
[101]	1184	uint32_t index = ( hal_get_cycles() + hal_get_gid() ) % (x_size * y_size);
[1]	1185	uint32_t x = index / y_size;
	1186	uint32_t y = index % y_size;
	1187	cxy_t child_cxy = (x<<y_width) + y;
	1188
	1189	// create child inode TODO : define attr / mode / uid / gid
	1190	uint32_t attr = 0;
	1191	uint32_t mode = 0;
	1192	uint32_t uid = 0;
	1193	uint32_t gid = 0;
	1194
	1195	if( child_cxy == local_cxy ) // child cluster is the local cluster
	1196	{
	1197	error = vfs_inode_create( dentry_xp,
[23]	1198	fs_type,
	1199	inode_type,
[1]	1200	attr,
	1201	mode,
	1202	uid,
	1203	gid,
	1204	&inode_xp );
	1205	}
	1206	else // child cluster is remote
	1207	{
	1208	rpc_vfs_inode_create_client( child_cxy,
	1209	dentry_xp,
[23]	1210	fs_type,
	1211	inode_type,
[1]	1212	attr,
	1213	mode,
	1214	uid,
	1215	gid,
	1216	&inode_xp,
	1217	&error );
	1218	}
	1219
	1220	if( error )
	1221	{
	1222	printk("\n[ERROR] in %s : cannot create inode in cluster %x\n",
	1223	__FUNCTION__ , child_cxy );
	1224
	1225	vfs_dentry_t * dentry = (vfs_dentry_t *)GET_PTR( dentry_xp );
	1226	if( parent_cxy == local_cxy ) vfs_dentry_destroy( dentry );
	1227	else rpc_vfs_dentry_destroy_client( parent_cxy , dentry );
	1228	return error;
	1229	}
	1230
	1231	// success : return extended pointer on child inode
	1232	*child_xp = inode_xp;
	1233	return 0;
	1234
	1235	} // end vfs_add_child_in_parent()
	1236
	1237
[23]	1238
	1239
	1240	//////////////////////////////////////////////////////////////////////////////////////////
	1241	// Mapper related functions
	1242	//////////////////////////////////////////////////////////////////////////////////////////
	1243
	1244	////////////////////////////////////////////////
	1245	error_t vfs_move_page_to_mapper( page_t * page )
	1246	{
	1247	error_t error = 0;
	1248
	1249	assert( (page != NULL) , __FUNCTION__ , "page pointer is NULL\n" );
	1250
	1251	mapper_t * mapper = page->mapper;
	1252
	1253	assert( (mapper != NULL) , __FUNCTION__ , "no mapper for page\n" );
	1254
	1255	// get FS type
	1256	vfs_fs_type_t fs_type = mapper->inode->ctx->type;
	1257
	1258	// update mapper if permitted by file system type
	1259	if( fs_type == FS_TYPE_FATFS )
	1260	{
	1261	// get mapper lock in WRITE_MODE
	1262	rwlock_wr_lock( &mapper->lock );
	1263
	1264	error = fatfs_read_page( page );
	1265
	1266	// release mapper lock
	1267	rwlock_wr_unlock( &mapper->lock );
	1268	}
	1269	else if( fs_type == FS_TYPE_RAMFS )
	1270	{
	1271	assert( false , __FUNCTION__ , "should not be called for RAMFS\n" );
	1272	}
	1273	else if( fs_type == FS_TYPE_DEVFS )
	1274	{
	1275	assert( false , __FUNCTION__ , "should not be called for DEVFS\n" );
	1276	}
	1277	else
	1278	{
	1279	assert( false , __FUNCTION__ , "undefined file system type\n" );
	1280	}
	1281
	1282	return error;
	1283
	1284	} // end vfs_move_page_to_mapper()
	1285
	1286	//////////////////////////////////////////////////
	1287	error_t vfs_move_page_from_mapper( page_t * page )
	1288	{
	1289	error_t error = 0;
	1290
	1291	assert( (page != NULL) , __FUNCTION__ , "page pointer is NULL\n" );
	1292
	1293	mapper_t * mapper = page->mapper;
	1294
	1295	assert( (mapper != NULL) , __FUNCTION__ , "no mapper for page\n" );
	1296
	1297	// get FS type
	1298	vfs_fs_type_t fs_type = mapper->inode->ctx->type;
	1299
	1300	// update file system if permitted by file system type
	1301	if( fs_type == FS_TYPE_FATFS )
	1302	{
	1303	if( page_is_flag( page , PG_DIRTY ) )
	1304	{
	1305	// get mapper lock in READ_MODE
	1306	rwlock_rd_lock( &mapper->lock );
	1307
	1308	error = fatfs_write_page( page );
	1309
	1310	// release mapper lock from READ_MODE
	1311	rwlock_rd_unlock( &mapper->lock );
	1312
	1313	// clear dirty bit if success
	1314	if( error == 0 ) page_undo_dirty( page );
	1315	}
	1316	}
	1317	else if( fs_type == FS_TYPE_RAMFS )
	1318	{
	1319	assert( false , __FUNCTION__ , "should not be called for RAMFS\n" );
	1320	}
	1321	else if( fs_type == FS_TYPE_DEVFS )
	1322	{
	1323	assert( false , __FUNCTION__ , "should not be called for DEVFS\n" );
	1324	}
	1325	else
	1326	{
	1327	assert( false , __FUNCTION__ , "undefined file system type\n" );
	1328	}
	1329
	1330	return error;
	1331
	1332	} // end vfs_move_page_from_mapper()
	1333
	1334

Note: See TracBrowser for help on using the repository browser.

Download in other formats: