Context Navigation

source: trunk/kernel/fs/vfs.c @ 664

Last change on this file since 664 was 657, checked in by alain, 6 years ago
Introduce remote_buf.c/.h & socket.c/.h files. Update dev_nic.c/.h files.
File size: 129.8 KB

Line
1	/*
2	* vfs.c - Virtual File System implementation.
3	*
4	* Author Mohamed Lamine Karaoui (2015)
5	* Alain Greiner (2016,2017,2018,2019,2020)
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	#include <kernel_config.h>
26	#include <hal_kernel_types.h>
27	#include <hal_atomic.h>
28	#include <hal_special.h>
29	#include <printk.h>
30	#include <list.h>
31	#include <xlist.h>
32	#include <slist.h>
33	#include <xhtab.h>
34	#include <string.h>
35	#include <errno.h>
36	#include <kmem.h>
37	#include <mapper.h>
38	#include <thread.h>
39	#include <chdev.h>
40	#include <process.h>
41	#include <cluster.h>
42	#include <vfs.h>
43	#include <fatfs.h>
44	#include <ramfs.h>
45	#include <devfs.h>
46	#include <syscalls.h>
47
48	//////////////////////////////////////////////////////////////////////////////////////////
49	// Extern variables
50	//////////////////////////////////////////////////////////////////////////////////////////
51
52	extern vfs_ctx_t fs_context[FS_TYPES_NR]; // allocated in kernel_init.c
53	extern chdev_directory_t chdev_dir; // allocated in kernel_init.c
54	extern char * lock_type_str[]; // allocated in kernel_init.c
55
56	///////////////////////////////////////////////////////////////////////////////////////////
57	// VFS Context related functions
58	//////////////////////////////////////////////////////////////////////////////////////////
59
60	///////////////////////////////////////
61	void vfs_ctx_init( cxy_t cxy,
62	vfs_fs_type_t fs_type,
63	uint32_t total_clusters,
64	uint32_t cluster_size,
65	xptr_t vfs_root_xp,
66	void * extend )
67	{
68	// get pointer on relevant VFS context (same in all clusters)
69	vfs_ctx_t * vfs_ctx_ptr = &fs_context[fs_type];
70
71	// initialise VFS context fields
72	hal_remote_s32( XPTR( cxy , &vfs_ctx_ptr->type ) , fs_type );
73	hal_remote_s32( XPTR( cxy , &vfs_ctx_ptr->total_clusters ) , total_clusters );
74	hal_remote_s32( XPTR( cxy , &vfs_ctx_ptr->cluster_size ) , cluster_size );
75	hal_remote_s64( XPTR( cxy , &vfs_ctx_ptr->vfs_root_xp ) , vfs_root_xp );
76	hal_remote_spt( XPTR( cxy , &vfs_ctx_ptr->extend ) , extend );
77
78	// initialize VFS context lock
79	remote_busylock_init( XPTR( cxy , &vfs_ctx_ptr->lock ) , LOCK_VFS_CTX );
80
81	// initialize inum allocator
82	bitmap_remote_init( XPTR( cxy , &vfs_ctx_ptr->bitmap ),
83	BITMAP_SIZE(CONFIG_VFS_MAX_INODES) );
84
85	} // end vfs_ctx_init()
86
87	///////////////////////////////////////////////
88	error_t vfs_ctx_inum_alloc( xptr_t ctx_xp,
89	uint32_t * inum )
90	{
91	// get context cluster and local pointer
92	cxy_t ctx_cxy = GET_CXY( ctx_xp );
93	vfs_ctx_t * ctx_ptr = GET_PTR( ctx_xp );
94
95	// build extended pointer on lock protecting the inum allocator
96	xptr_t lock_xp = XPTR( ctx_cxy , &ctx_ptr->lock );
97
98	// build extended pointer on inum bitmap
99	xptr_t bitmap_xp = XPTR( ctx_cxy , &ctx_ptr->bitmap );
100
101	// get lock on inum allocator
102	remote_busylock_acquire( lock_xp );
103
104	// get lid from local inum allocator
105	uint32_t lid = bitmap_remote_ffc( bitmap_xp , CONFIG_VFS_MAX_INODES );
106
107	if( lid == 0xFFFFFFFF ) // no more free slot => error
108	{
109	// release lock
110	remote_busylock_release( lock_xp );
111
112	// return error
113	return -1;
114	}
115	else // found => return inum
116	{
117	// set slot allocated
118	bitmap_remote_set( bitmap_xp , lid );
119
120	// release lock
121	remote_busylock_release( lock_xp );
122
123	// return inum
124	*inum = (((uint32_t)local_cxy) << 16) \| (lid & 0xFFFF);
125	return 0;
126	}
127	} // end vfs_ctx_inum_alloc()
128
129	/////////////////////////////////////////////
130	void vfs_ctx_inum_release( xptr_t ctx_xp,
131	uint32_t inum )
132	{
133	// get context cluster and local pointer
134	cxy_t ctx_cxy = GET_CXY( ctx_xp );
135	vfs_ctx_t * ctx_ptr = GET_PTR( ctx_xp );
136
137	// build extended pointer on inum bitmap
138	xptr_t bitmap_xp = XPTR( ctx_cxy , &ctx_ptr->bitmap );
139
140	// build extended pointer on lock
141	xptr_t lock_xp = XPTR( ctx_cxy , &ctx_ptr->lock );
142
143	// get lock
144	remote_busylock_acquire( lock_xp );
145
146	bitmap_remote_clear( bitmap_xp , inum & 0xFFFF );
147
148	// release lock
149	remote_busylock_release( lock_xp );
150
151	} // end vfs_ctx_inum_release()
152
153	//////////////////////////////////////////////////////////////////////////////////////////
154	// VFS inode descriptor related functions
155	//////////////////////////////////////////////////////////////////////////////////////////
156
157	const char * vfs_inode_type_str( vfs_inode_type_t type )
158	{
159	switch ( type )
160	{
161	case INODE_TYPE_FILE: return "FILE";
162	case INODE_TYPE_DIR: return "DIR ";
163	case INODE_TYPE_FIFO: return "FIFO";
164	case INODE_TYPE_PIPE: return "PIPE";
165	case INODE_TYPE_SOCK: return "SOCK";
166	case INODE_TYPE_DEV: return "DEV ";
167	case INODE_TYPE_BLK: return "BLK ";
168	case INODE_TYPE_SYML: return "SYML";
169	default: return "undefined";
170	}
171	}
172
173	////////////////////////////////////////////////
174	error_t vfs_inode_create( cxy_t cxy,
175	vfs_fs_type_t fs_type,
176	uint32_t attr,
177	uint32_t rights,
178	uid_t uid,
179	gid_t gid,
180	xptr_t * inode_xp )
181	{
182	xptr_t mapper_xp; // extended pointer on associated mapper
183	mapper_t * mapper_ptr; // local pointer on associated mapper
184	vfs_inode_t * inode_ptr; // local pointer on allocated inode
185	uint32_t inum; // inode identifier (to be allocated)
186	vfs_ctx_t * ctx; // file system context
187	kmem_req_t req; // request to kernel memory allocator
188	error_t error;
189
190	// check fs type and get pointer on context
191	if ( fs_type == FS_TYPE_FATFS ) ctx = &fs_context[FS_TYPE_FATFS];
192	else if( fs_type == FS_TYPE_RAMFS ) ctx = &fs_context[FS_TYPE_RAMFS];
193	else if( fs_type == FS_TYPE_DEVFS ) ctx = &fs_context[FS_TYPE_DEVFS];
194	else
195	{
196	printk("\n[ERROR] in %s : illegal FS type\n", __FUNCTION__ );
197	return -1;
198	}
199
200	// check inode descriptor contained in one page
201	assert( (sizeof(vfs_inode_t) <= CONFIG_PPM_PAGE_SIZE),
202	"inode descriptor must fit in one page" );
203
204	// allocate inum
205	error = vfs_ctx_inum_alloc( XPTR( cxy , ctx ) , &inum );
206
207	if( error )
208	{
209	printk("\n[ERROR] in %s : cannot allocate inum\n", __FUNCTION__ );
210	return -1;
211	}
212
213	// allocate memory for mapper in cluster cxy
214	mapper_xp = mapper_create( cxy , fs_type );
215
216	if( mapper_xp == XPTR_NULL )
217	{
218	printk("\n[ERROR] in %s : cannot allocate mapper\n", __FUNCTION__ );
219	vfs_ctx_inum_release( XPTR( cxy , ctx ) , inum );
220	return -1;
221	}
222
223	mapper_ptr = GET_PTR( mapper_xp );
224
225	// allocate one page for VFS inode descriptor
226	// because the embedded "children" xhtab footprint
227	req.type = KMEM_PPM;
228	req.order = 0;
229	req.flags = AF_KERNEL \| AF_ZERO;
230	inode_ptr = kmem_remote_alloc( cxy , &req );
231
232	if( inode_ptr == NULL )
233	{
234	printk("\n[ERROR] in %s : cannot allocate inode descriptor\n", __FUNCTION__ );
235	vfs_ctx_inum_release( XPTR( cxy , ctx ) , inum );
236	mapper_destroy( mapper_xp );
237	return -1;
238	}
239
240	// initialise inode field in mapper
241	hal_remote_spt( XPTR( cxy , &mapper_ptr->inode ) , inode_ptr );
242
243	// initialize inode descriptor
244	hal_remote_s32( XPTR( cxy , &inode_ptr->type ) , INODE_TYPE_FILE ); // default value
245	hal_remote_s32( XPTR( cxy , &inode_ptr->inum ) , inum );
246	hal_remote_s32( XPTR( cxy , &inode_ptr->attr ) , attr );
247	hal_remote_s32( XPTR( cxy , &inode_ptr->rights ) , rights );
248	hal_remote_s32( XPTR( cxy , &inode_ptr->links ) , 0 );
249	hal_remote_s32( XPTR( cxy , &inode_ptr->uid ) , uid );
250	hal_remote_s32( XPTR( cxy , &inode_ptr->gid ) , gid );
251	hal_remote_spt( XPTR( cxy , &inode_ptr->ctx ) , ctx );
252	hal_remote_spt( XPTR( cxy , &inode_ptr->mapper ) , mapper_ptr );
253	hal_remote_spt( XPTR( cxy , &inode_ptr->extend ) , NULL );
254
255	// initialize chidren dentries xhtab
256	xhtab_init( XPTR( cxy , &inode_ptr->children ) , XHTAB_DENTRY_TYPE );
257
258	// initialize parents dentries xlist
259	xlist_root_init( XPTR( cxy , &inode_ptr->parents ) );
260
261	// initialize lock protecting size
262	remote_rwlock_init( XPTR( cxy , &inode_ptr->size_lock ), LOCK_VFS_SIZE );
263
264	// initialise lock protecting inode tree traversal
265	remote_rwlock_init( XPTR( cxy , &inode_ptr->main_lock ), LOCK_VFS_MAIN );
266
267	// return extended pointer on inode
268	*inode_xp = XPTR( cxy , inode_ptr );
269
270	#if DEBUG_VFS_INODE_CREATE
271	uint32_t cycle = (uint32_t)hal_get_cycles();
272	thread_t * this = CURRENT_THREAD;
273	if( DEBUG_VFS_INODE_CREATE < cycle )
274	printk("\n[%s] thread[%x,%x] created inode (%x,%x) / ctx %x / fs_type %d / cycle %d\n",
275	__FUNCTION__, this->process->pid, this->trdid, cxy, inode_ptr, ctx, ctx->type, cycle );
276	#endif
277
278	return 0;
279
280	} // end vfs_inode_create()
281
282	//////////////////////////////////////////
283	void vfs_inode_destroy( xptr_t inode_xp )
284	{
285	// get cluster and local pointer
286	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
287	cxy_t inode_cxy = GET_CXY( inode_xp );
288
289	// release memory allocated for mapper
290	mapper_destroy( XPTR( inode_cxy , &inode_ptr->mapper ) );
291
292	// release memory allocated for inode descriptor
293	kmem_req_t req;
294	req.type = KMEM_PPM;
295	req.ptr = inode_ptr;
296	kmem_remote_free( inode_cxy , &req );
297
298	} // end vfs_inode_destroy()
299
300	//////////////////////////////////////////////
301	uint32_t vfs_inode_get_size( xptr_t inode_xp )
302	{
303	// get inode cluster and local pointer
304	cxy_t cxy = GET_CXY( inode_xp );
305	vfs_inode_t * ptr = GET_PTR( inode_xp );
306
307	// build extended pointers on lock & size
308	xptr_t lock_xp = XPTR( cxy , &ptr->size_lock );
309	xptr_t size_xp = XPTR( cxy , &ptr->size );
310
311	// take lock in read mode
312	remote_rwlock_rd_acquire( lock_xp );
313
314	// get size
315	uint32_t size = hal_remote_l32( size_xp );
316
317	// release lock from read mode
318	remote_rwlock_rd_release( lock_xp );
319
320	return size;
321	}
322
323	///////////////////////////////////////////////
324	void vfs_inode_update_size( xptr_t inode_xp,
325	uint32_t size )
326	{
327	// get inode cluster and local pointer
328	cxy_t cxy = GET_CXY( inode_xp );
329	vfs_inode_t * ptr = GET_PTR( inode_xp );
330
331	// build extended pointers on lock & size
332	xptr_t lock_xp = XPTR( cxy , &ptr->size_lock );
333	xptr_t size_xp = XPTR( cxy , &ptr->size );
334
335	// take lock in write mode
336	remote_rwlock_wr_acquire( lock_xp );
337
338	// get current size
339	uint32_t current_size = hal_remote_l32( size_xp );
340
341	// set size if required
342	if( current_size < size ) hal_remote_s32( size_xp , size );
343
344	// release lock from write mode
345	remote_rwlock_wr_release( lock_xp );
346	}
347
348	////////////////////////////////////////
349	void vfs_inode_unlock( xptr_t inode_xp )
350	{
351	// get inode cluster and local pointer
352	cxy_t cxy = GET_CXY( inode_xp );
353	vfs_inode_t * ptr = GET_PTR( inode_xp );
354
355	// release the main lock
356	remote_busylock_release( XPTR( cxy , &ptr->main_lock ) );
357	}
358
359	//////////////////////////////////////
360	void vfs_inode_lock( xptr_t inode_xp )
361	{
362	// get inode cluster and local pointer
363	cxy_t cxy = GET_CXY( inode_xp );
364	vfs_inode_t * ptr = GET_PTR( inode_xp );
365
366	// get the main lock
367	remote_busylock_acquire( XPTR( cxy , &ptr->main_lock ) );
368	}
369
370	///////////////////////////////////////////
371	void vfs_inode_get_name( xptr_t inode_xp,
372	char * name )
373	{
374	cxy_t inode_cxy; // inode cluster identifier
375	vfs_inode_t * inode_ptr; // local pointer on inode
376	xptr_t parents_root_xp; // extended pointer on inode parents root
377
378	// get inode cluster and local pointer
379	inode_ptr = GET_PTR( inode_xp );
380	inode_cxy = GET_CXY( inode_xp );
381
382	// build extended pointer on parents dentries root
383	parents_root_xp = XPTR( inode_cxy , &inode_ptr->parents );
384
385	// check VFS root
386	if( xlist_is_empty( parents_root_xp ) ) // inode is the VFS root
387	{
388	strcpy( name , "/" );
389	}
390	else // not the VFS root
391	{
392	xptr_t dentry_xp;
393	cxy_t dentry_cxy;
394	vfs_dentry_t * dentry_ptr;
395
396	// get first name in list of parents
397	dentry_xp = XLIST_FIRST( parents_root_xp , vfs_dentry_t , parents );
398	dentry_cxy = GET_CXY( dentry_xp );
399	dentry_ptr = GET_PTR( dentry_xp );
400
401	hal_remote_strcpy( XPTR( local_cxy , name ) ,
402	XPTR( dentry_cxy , dentry_ptr->name ) );
403	}
404
405	} // end vfs_inode_get_name()
406
407	////////////////////////////////////////////////////
408	error_t vfs_inode_load_all_pages( xptr_t inode_xp )
409	{
410	uint32_t page_id;
411	xptr_t page_xp;
412
413
414	// get inode cluster and local pointer
415	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
416	cxy_t inode_cxy = GET_CXY( inode_xp );
417
418	// get pointer on mapper and size
419	mapper_t * mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
420	uint32_t size = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->size ) );
421
422	#if DEBUG_VFS_INODE_LOAD_ALL
423	char name[CONFIG_VFS_MAX_NAME_LENGTH];
424	uint32_t cycle = (uint32_t)hal_get_cycles();
425	thread_t * this = CURRENT_THREAD;
426	vfs_inode_get_name( inode_xp , name );
427	if( DEBUG_VFS_INODE_LOAD_ALL < cycle )
428	printk("\n[%s] thread[%x,%x] enter for <%s> in cluster %x / cycle %d\n",
429	__FUNCTION__, this->process->pid, this->trdid, name, inode_cxy, cycle );
430	#endif
431
432	// compute number of pages
433	uint32_t npages = size >> CONFIG_PPM_PAGE_SHIFT;
434	if( (size & CONFIG_PPM_PAGE_MASK) \|\| (size == 0) ) npages++;
435
436	// loop on pages
437	for( page_id = 0 ; page_id < npages ; page_id ++ )
438	{
439	// If the mage is missing, this function allocates the missing page,
440	// and load the page from IOC device into mapper
441	page_xp = mapper_get_page( XPTR( inode_cxy , mapper ), page_id );
442
443	if( page_xp == XPTR_NULL ) return -1;
444	}
445
446	#if DEBUG_VFS_INODE_LOAD_ALL
447	cycle = (uint32_t)hal_get_cycles();
448	if( DEBUG_VFS_INODE_LOAD_ALL < cycle )
449	printk("\n[%s] thread[%x,%x] exit for <%s> in cluster %x\n",
450	__FUNCTION__, this->process->pid, this->trdid, name, inode_cxy );
451	#endif
452
453	return 0;
454
455	} // end vfs_inode_load_all_pages()
456
457	/////////////////////////////////////////
458	void vfs_inode_display( xptr_t inode_xp )
459	{
460	assert( (inode_xp != XPTR_NULL), "inode pointer is NULL");
461
462	char name[CONFIG_VFS_MAX_NAME_LENGTH];
463
464	vfs_inode_get_name( inode_xp , name );
465
466	// get inode cluster and local pointer
467	cxy_t inode_cxy = GET_CXY( inode_xp );
468	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
469
470	vfs_inode_type_t type = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->type ) );
471	uint32_t attr = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->attr ) );
472	uint32_t size = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->size ) );
473	uint32_t parents = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->links ) );
474	mapper_t * mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
475	void * extend = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->extend ) );
476
477	printk("\n**** inode <%s>\n"
478	" - type = %s\n"
479	" - attr = %x\n"
480	" - size = %d\n"
481	" - parents = %d\n"
482	" - cxy = %x\n"
483	" - inode = %x\n"
484	" - mapper = %x\n"
485	" - extend = %x\n",
486	name,
487	vfs_inode_type_str( type ),
488	attr,
489	size,
490	parents,
491	inode_cxy,
492	inode_ptr,
493	mapper,
494	extend );
495
496	} // end vfs_inode_display()
497
498
499	////////////////////////////////////////////////////////////////////////////////////////////
500	// VFS dentry descriptor related functions
501	//////////////////////////////////////////////////////////////////////////////////////////
502
503	///////////////////////////////////////////////
504	error_t vfs_dentry_create( cxy_t cxy,
505	vfs_fs_type_t fs_type,
506	char * name,
507	xptr_t * dentry_xp )
508	{
509	kmem_req_t req; // request to kernel memory allocator
510	vfs_ctx_t * ctx = NULL; // context descriptor
511	vfs_dentry_t * dentry_ptr; // dentry descriptor (to be allocated)
512
513	#if DEBUG_VFS_DENTRY_CREATE
514	thread_t * this = CURRENT_THREAD;
515	uint32_t cycle = (uint32_t)hal_get_cycles();
516	if( DEBUG_VFS_DENTRY_CREATE < cycle )
517	printk("\n[%s] thread[%x,%x] enters for <%s> / fs_type %x / cycle %d\n",
518	__FUNCTION__, this->process->pid, this->trdid, name, fs_type, cycle );
519	#endif
520
521	// get pointer on context
522	if ( fs_type == FS_TYPE_FATFS ) ctx = &fs_context[FS_TYPE_FATFS];
523	else if( fs_type == FS_TYPE_RAMFS ) ctx = &fs_context[FS_TYPE_RAMFS];
524	else if( fs_type == FS_TYPE_DEVFS ) ctx = &fs_context[FS_TYPE_DEVFS];
525	else
526	{
527	printk("\n[ERROR] in %s undefined fs_type %d\n", __FUNCTION__, fs_type );
528	return -1;
529	}
530
531	// get name length
532	uint32_t length = strlen( name );
533
534	if( length >= CONFIG_VFS_MAX_NAME_LENGTH ) return -1;
535
536	// allocate memory for dentry descriptor
537	req.type = KMEM_KCM;
538	req.order = bits_log2( sizeof(vfs_dentry_t) );
539	req.flags = AF_KERNEL \| AF_ZERO;
540	dentry_ptr = kmem_remote_alloc( cxy , &req );
541
542	if( dentry_ptr == NULL )
543	{
544	printk("\n[ERROR] in %s : cannot allocate dentry descriptor\n",
545	__FUNCTION__ );
546	return -1;
547	}
548
549	// initialize dentry descriptor
550	hal_remote_spt( XPTR( cxy , &dentry_ptr->ctx ) , ctx );
551	hal_remote_s32( XPTR( cxy , &dentry_ptr->length ) , length );
552	hal_remote_spt( XPTR( cxy , &dentry_ptr->extend ) , NULL );
553
554	// register name
555	hal_remote_strcpy( XPTR( cxy, dentry_ptr->name ),
556	XPTR( local_cxy, name ) );
557
558	// return extended pointer on dentry
559	*dentry_xp = XPTR( cxy , dentry_ptr );
560
561	#if DEBUG_VFS_DENTRY_CREATE
562	if( DEBUG_VFS_DENTRY_CREATE < cycle )
563	printk("\n[%s] thread[%x,%x] exit for <%s> / dentry (%x,%x)\n",
564	__FUNCTION__, this->process->pid, this->trdid, name, cxy, dentry_ptr );
565	#endif
566
567	return 0;
568
569	} // end vfs_dentry_create()
570
571	////////////////////////////////////////////
572	void vfs_dentry_destroy( xptr_t dentry_xp )
573	{
574	// get cluster and local pointer
575	vfs_dentry_t * dentry_ptr = GET_PTR( dentry_xp );
576	cxy_t dentry_cxy = GET_CXY( dentry_xp );
577
578	// release memory allocated to dentry
579	kmem_req_t req;
580	req.type = KMEM_KCM;
581	req.ptr = dentry_ptr;
582	kmem_remote_free( dentry_cxy , &req );
583
584	} // end vfs_dentry_destroy()
585
586
587	//////////////////////////////////////////////////////////////////////////////////////////
588	// VFS file descriptor related functions
589	//////////////////////////////////////////////////////////////////////////////////////////
590
591	/////////////////////////////////////////////
592	error_t vfs_file_create( xptr_t inode_xp,
593	uint32_t attr,
594	xptr_t * file_xp )
595	{
596	vfs_file_t * file_ptr;
597	kmem_req_t req;
598	uint32_t type;
599	mapper_t * mapper;
600	vfs_ctx_t * ctx;
601
602	// get inode cluster and local pointer
603	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
604	cxy_t inode_cxy = GET_CXY( inode_xp );
605
606	#if DEBUG_VFS_FILE_CREATE
607	thread_t * this = CURRENT_THREAD;
608	uint32_t cycle = (uint32_t)hal_get_cycles();
609	if( DEBUG_VFS_OPEN < cycle )
610	printk("\n[%s] thread[%x,%x] enter for inode (%x,%x) / cycle %d\n",
611	__FUNCTION__, this->process->pid, this->trdid, inode_cxy, inode_ptr, cycle );
612	#endif
613
614	// allocate memory for new file descriptor
615	req.type = KMEM_KCM;
616	req.order = bits_log2( sizeof(vfs_file_t) );
617	req.flags = AF_KERNEL \| AF_ZERO;
618	file_ptr = kmem_remote_alloc( inode_cxy , &req );
619
620	if( file_ptr == NULL ) return -1;
621
622	// get type, ctx and mapper from inode descriptor
623	type = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->type ) );
624	ctx = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->ctx ) );
625	mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
626
627	// initializes new file descriptor
628	hal_remote_s32( XPTR( inode_cxy , &file_ptr->type ) , type );
629	hal_remote_s32( XPTR( inode_cxy , &file_ptr->attr ) , attr );
630	hal_remote_s32( XPTR( inode_cxy , &file_ptr->offset ) , 0 );
631	hal_remote_s32( XPTR( inode_cxy , &file_ptr->refcount ) , 1 );
632	hal_remote_spt( XPTR( inode_cxy , &file_ptr->inode ) , inode_ptr );
633	hal_remote_spt( XPTR( inode_cxy , &file_ptr->ctx ) , ctx );
634	hal_remote_spt( XPTR( inode_cxy , &file_ptr->mapper ) , mapper );
635
636	remote_rwlock_init( XPTR( inode_cxy , &file_ptr->lock ), LOCK_VFS_FILE );
637
638	*file_xp = XPTR( inode_cxy , file_ptr );
639
640	#if DEBUG_VFS_FILE_CREATE
641	cycle = (uint32_t)hal_get_cycles();
642	if( DEBUG_VFS_OPEN < cycle )
643	printk("\n[%s] thread[%x,%x] created file (%x,%x) %x\n",
644	__FUNCTION__, this->process->pid, this->trdid, inode_cxy, file_ptr, cycle );
645	#endif
646
647	return 0;
648
649	} // end vfs_file_create()
650
651	////////////////////////////////////////
652	void vfs_file_destroy( xptr_t file_xp )
653	{
654	// get file cluster and local pointer
655	vfs_file_t * file_ptr = GET_PTR( file_xp );
656	cxy_t file_cxy = GET_CXY( file_xp );
657
658	// release file descriptor
659	kmem_req_t req;
660	req.type = KMEM_KCM;
661	req.ptr = file_ptr;
662	kmem_remote_free( file_cxy , &req );
663
664	#if DEBUG_VFS_CLOSE
665	char name[CONFIG_VFS_MAX_NAME_LENGTH];
666	vfs_file_get_name( file_xp , name );
667	thread_t * this = CURRENT_THREAD;
668	uint32_t cycle = (uint32_t)hal_get_cycles();
669	if( DEBUG_VFS_CLOSE < cycle )
670	printk("\n[%s] thread[%x,%x] deleted file <%s> in cluster %x / cycle %d\n",
671	__FUNCTION__, this->process->pid, this->trdid, name, file_cxy, cycle );
672	#endif
673
674	} // end vfs_file_destroy()
675
676
677	////////////////////////////////////////
678	void vfs_file_count_up( xptr_t file_xp )
679	{
680	// get file cluster and local pointer
681	cxy_t file_cxy = GET_CXY( file_xp );
682	vfs_file_t * file_ptr = GET_PTR( file_xp );
683
684	// atomically increment count
685	hal_remote_atomic_add( XPTR( file_cxy , &file_ptr->refcount ) , 1 );
686	}
687
688	//////////////////////////////////////////
689	void vfs_file_count_down( xptr_t file_xp )
690	{
691	// get file cluster and local pointer
692	cxy_t file_cxy = GET_CXY( file_xp );
693	vfs_file_t * file_ptr = GET_PTR( file_xp );
694
695	// atomically decrement count
696	hal_remote_atomic_add( XPTR( file_cxy , &file_ptr->refcount ) , -1 );
697	}
698
699	///////////////////////////////////////
700	void vfs_file_get_name( xptr_t file_xp,
701	char * name )
702	{
703	// get cluster and local pointer on remote file
704	vfs_file_t * file_ptr = GET_PTR( file_xp );
705	cxy_t file_cxy = GET_CXY( file_xp );
706
707	// get pointers on remote inode
708	vfs_inode_t * inode_ptr = hal_remote_lpt( XPTR( file_cxy , &file_ptr->inode ) );
709	xptr_t inode_xp = XPTR( file_cxy , inode_ptr );
710
711	// call the relevant function
712	vfs_inode_get_name( inode_xp , name );
713	}
714
715
716	//////////////////////////////////////////////////////////////////////////////////////////
717	// "syscalls" API related functions
718	//////////////////////////////////////////////////////////////////////////////////////////
719
720	//////////////////////////////////////
721	error_t vfs_open( xptr_t root_xp,
722	char * path,
723	xptr_t process_xp,
724	uint32_t flags,
725	uint32_t mode,
726	xptr_t * new_file_xp,
727	uint32_t * new_file_id )
728	{
729	error_t error;
730	xptr_t inode_xp; // extended pointer on target inode
731	cxy_t inode_cxy; // inode cluster identifier
732	vfs_inode_t * inode_ptr; // inode local pointer
733	uint32_t file_attr; // file descriptor attributes
734	uint32_t lookup_mode; // lookup working mode
735	xptr_t file_xp; // extended pointer on created file descriptor
736	uint32_t file_id; // created file descriptor index in reference fd_array
737	xptr_t vfs_root_xp; // extended pointer on VFS root inode
738	vfs_inode_t * vfs_root_ptr; // local pointer on VFS root inode
739	cxy_t vfs_root_cxy; // VFS root inode cluster identifier
740	xptr_t lock_xp; // extended pointer on Inode Tree lock
741
742	if( mode != 0 )
743	{
744	printk("\n[ERROR] in %s : the mode parameter is not supported yet\n" );
745	return -1;
746	}
747
748	thread_t * this = CURRENT_THREAD;
749	process_t * process = this->process;
750
751	// compute lookup working mode
752	lookup_mode = VFS_LOOKUP_OPEN;
753	if( (flags & O_DIR ) ) lookup_mode \|= VFS_LOOKUP_DIR;
754	if( (flags & O_CREAT ) ) lookup_mode \|= VFS_LOOKUP_CREATE;
755	if( (flags & O_EXCL ) ) lookup_mode \|= VFS_LOOKUP_EXCL;
756
757	#if DEBUG_VFS_OPEN
758	uint32_t cycle = (uint32_t)hal_get_cycles();
759	if( DEBUG_VFS_OPEN < cycle )
760	printk("\n[%s] thread[%x,%x] enter for <%s> / root_inode (%x,%x) / cycle %d\n",
761	__FUNCTION__, process->pid, this->trdid, path, GET_CXY(root_xp), GET_PTR(root_xp), cycle );
762	#endif
763
764	// compute attributes for the created file
765	file_attr = 0;
766	if( (flags & O_RDONLY ) == 0 ) file_attr \|= FD_ATTR_WRITE_ENABLE;
767	if( (flags & O_WRONLY ) == 0 ) file_attr \|= FD_ATTR_READ_ENABLE;
768	if( (flags & O_SYNC ) ) file_attr \|= FD_ATTR_SYNC;
769	if( (flags & O_APPEND ) ) file_attr \|= FD_ATTR_APPEND;
770	if( (flags & O_CLOEXEC) ) file_attr \|= FD_ATTR_CLOSE_EXEC;
771
772	// build extended pointer on lock protecting Inode Tree
773	vfs_root_xp = process->vfs_root_xp;
774	vfs_root_ptr = GET_PTR( vfs_root_xp );
775	vfs_root_cxy = GET_CXY( vfs_root_xp );
776	lock_xp = XPTR( vfs_root_cxy , &vfs_root_ptr->main_lock );
777
778	// take lock protecting Inode Tree in read mode
779	remote_rwlock_rd_acquire( lock_xp );
780
781	// get extended pointer on target inode
782	error = vfs_lookup( root_xp,
783	path,
784	lookup_mode,
785	&inode_xp,
786	NULL );
787
788	// release lock protecting Inode Tree
789	remote_rwlock_rd_release( lock_xp );
790
791	if( error )
792	{
793	printk("\n[ERROR] in %s : cannot get inode <%s>\n",
794	__FUNCTION__ , path );
795	return -1;
796	}
797
798	// get target inode cluster and local pointer
799	inode_cxy = GET_CXY( inode_xp );
800	inode_ptr = GET_PTR( inode_xp );
801
802	#if (DEBUG_VFS_OPEN & 1)
803	cycle = (uint32_t)hal_get_cycles();
804	if( DEBUG_VFS_OPEN < cycle )
805	printk("\n[%s] thread[%x,%x] found inode(%x,%x) for <%s>\n",
806	__FUNCTION__, process->pid, this->trdid, inode_cxy, inode_ptr, path );
807	#endif
808
809	// create a new file descriptor in cluster containing inode
810	error = vfs_file_create( inode_xp , file_attr , &file_xp );
811
812	if( error ) return error;
813
814	#if (DEBUG_VFS_OPEN & 1)
815	cycle = (uint32_t)hal_get_cycles();
816	if( DEBUG_VFS_OPEN < cycle )
817	printk("\n[%s] thread[%x,%x] created file descriptor (%x,%x) for <%s>\n",
818	__FUNCTION__, process->pid, this->trdid, GET_CXY(file_xp), GET_PTR(file_xp), path );
819	#endif
820
821	// allocate and register a new file descriptor index in reference process
822	error = process_fd_register( process_xp , file_xp , &file_id );
823
824	if( error ) return error;
825
826	#if DEBUG_VFS_OPEN
827	cycle = (uint32_t)hal_get_cycles();
828	if( DEBUG_VFS_OPEN < cycle )
829	printk("\n[%s] thread[%x,%x] exit for <%s> / fdid %d / file(%x,%x) / cycle %d\n",
830	__FUNCTION__, process->pid, this->trdid, path, file_id,
831	GET_CXY( file_xp ), GET_PTR( file_xp ), cycle );
832	#endif
833
834	// success
835	*new_file_xp = file_xp;
836	*new_file_id = file_id;
837	return 0;
838
839	} // end vfs_open()
840
841	///////////////////////////////////////////
842	uint32_t vfs_user_move( bool_t to_buffer,
843	xptr_t file_xp,
844	void * buffer,
845	uint32_t count )
846	{
847	cxy_t file_cxy; // remote file descriptor cluster
848	vfs_file_t * file_ptr; // remote file descriptor local pointer
849	mapper_t * mapper; // local pointer on file mapper
850	vfs_inode_t * inode; // local pointer on file inode
851	vfs_inode_type_t type; // inode type
852	uint32_t offset; // current offset in file
853	uint32_t size; // current file size
854	uint32_t nbytes; // number of bytes actually transfered
855	error_t error;
856
857	// check argument
858	assert( (file_xp != XPTR_NULL), "file_xp == XPTR_NULL" );
859
860	// get cluster and local pointer on remote file descriptor
861	file_cxy = GET_CXY( file_xp );
862	file_ptr = GET_PTR( file_xp );
863
864	// get various infos from remote file descriptor
865	type = hal_remote_l32( XPTR( file_cxy , &file_ptr->type ) );
866	offset = hal_remote_l32( XPTR( file_cxy , &file_ptr->offset ) );
867	mapper = hal_remote_lpt( XPTR( file_cxy , &file_ptr->mapper ) );
868	inode = hal_remote_lpt( XPTR( file_cxy , &file_ptr->inode ) );
869	size = hal_remote_l32( XPTR( file_cxy , &inode->size ) );
870
871	// check inode type
872	assert( (type == INODE_TYPE_FILE), "bad inode type" );
873
874	#if DEBUG_VFS_USER_MOVE
875	char name[CONFIG_VFS_MAX_NAME_LENGTH];
876	uint32_t cycle = (uint32_t)hal_get_cycles();
877	thread_t * this = CURRENT_THREAD;
878	vfs_inode_get_name( XPTR( file_cxy , inode ) , name );
879	if( cycle > DEBUG_VFS_USER_MOVE )
880	{
881	if( to_buffer )
882	printk("\n[%s] thread[%x,%x] enter / %d bytes / map(%s) -> buf(%x) / offset %d / cycle %d\n",
883	__FUNCTION__ , this->process->pid, this->trdid, count, name, buffer, offset, cycle );
884	else
885	printk("\n[%s] thread[%x,%x] enter / %d bytes / buf(%x) -> map(%s) / offset %d / cycle %d\n",
886	__FUNCTION__ , this->process->pid, this->trdid, count, buffer, name, offset, cycle );
887	}
888	#endif
889
890	if( to_buffer ) // => compute the number of bytes to move and make the move
891	{
892	// compute number of bytes to move
893	if ( size <= offset ) nbytes = 0;
894	else if( size < offset + count ) nbytes = size - offset;
895	else nbytes = count;
896
897	// move data from mapper to buffer when required
898	if( nbytes > 0 )
899	{
900	error = mapper_move_user( XPTR( file_cxy , mapper ),
901	to_buffer,
902	offset,
903	buffer,
904	nbytes );
905	}
906	else
907	{
908	error = 0;
909	}
910	}
911	else // to mapper => make the move and update the file size if required
912	{
913	nbytes = count;
914
915	// move data from buffer to mapper
916	error = mapper_move_user( XPTR( file_cxy , mapper ),
917	to_buffer,
918	offset,
919	buffer,
920	count );
921
922	// update file size in inode if required
923	if( offset + count > size )
924	{
925	vfs_inode_update_size( XPTR( file_cxy , inode ) , offset + count );
926	}
927	}
928
929	if( error )
930	{
931	printk("\n[ERROR] in %s : cannot move data", __FUNCTION__ );
932	return -1;
933	}
934
935	// update file offset in file descriptor
936	hal_remote_atomic_add( XPTR( file_cxy , &file_ptr->offset ) , nbytes );
937
938	#if DEBUG_VFS_USER_MOVE
939	cycle = (uint32_t)hal_get_cycles();
940	if( cycle > DEBUG_VFS_USER_MOVE )
941	{
942	if( to_buffer )
943	printk("\n[%s] thread[%x,%x] exit / %d bytes moved from mapper to buffer\n",
944	__FUNCTION__ , this->process->pid, nbytes );
945	else
946	printk("\n[%s] thread[%x,%x] exit / %d bytes moved from buffer to mapper\n",
947	__FUNCTION__ , this->process->pid, nbytes );
948	}
949	#endif
950
951	return nbytes;
952
953	} // end vfs_user_move()
954
955	////////////////////////////////////////////
956	error_t vfs_kernel_move( bool_t to_buffer,
957	xptr_t file_xp,
958	xptr_t buffer_xp,
959	uint32_t size )
960	{
961	cxy_t file_cxy; // remote file descriptor cluster
962	vfs_file_t * file_ptr; // remote file descriptor local pointer
963	vfs_inode_type_t inode_type; // remote file type
964	uint32_t file_offset; // current offset in file
965	mapper_t * mapper_ptr; // remote mapper local pointer
966	xptr_t mapper_xp; // remote mapper extended pointer
967	error_t error;
968
969	// check argument
970	assert( (file_xp != XPTR_NULL) , "file_xp == XPTR_NULL" );
971
972	// get cluster and local pointer on remote file descriptor
973	file_cxy = GET_CXY( file_xp );
974	file_ptr = GET_PTR( file_xp );
975
976	// get inode type from remote file descriptor
977	inode_type = hal_remote_l32( XPTR( file_cxy , &file_ptr->type ) );
978
979	// check inode type
980	assert( (inode_type == INODE_TYPE_FILE), "bad file type" );
981
982	// get mapper pointers and file offset from file descriptor
983	file_offset = hal_remote_l32( XPTR( file_cxy , &file_ptr->offset ) );
984	mapper_ptr = hal_remote_lpt( XPTR( file_cxy , &file_ptr->mapper ) );
985	mapper_xp = XPTR( file_cxy , mapper_ptr );
986
987	// move data between mapper and buffer
988	error = mapper_move_kernel( mapper_xp,
989	to_buffer,
990	file_offset,
991	buffer_xp,
992	size );
993	if( error )
994	{
995	printk("\n[ERROR] in %s : cannot move data", __FUNCTION__ );
996	return -1;
997	}
998
999	#if DEBUG_VFS_KERNEL_MOVE
1000	char name[CONFIG_VFS_MAX_NAME_LENGTH];
1001	uint32_t cycle = (uint32_t)hal_get_cycles();
1002	thread_t * this = CURRENT_THREAD;
1003	cxy_t buffer_cxy = GET_CXY( buffer_xp );
1004	void * buffer_ptr = GET_PTR( buffer_xp );
1005	vfs_inode_t * inode = hal_remote_lpt( XPTR( file_cxy , &file_ptr->inode ) );
1006	vfs_inode_get_name( XPTR( file_cxy , inode ) , name );
1007	if( cycle > DEBUG_VFS_KERNEL_MOVE )
1008	{
1009	if( to_buffer )
1010	printk("\n[%s] thread[%x,%x] moves %d bytes from <%s> mapper to buffer(%x,%x) / cycle %d\n",
1011	__FUNCTION__ , this->process->pid, this->trdid, size, name, buffer_cxy, buffer_ptr );
1012	else
1013	printk("\n[%s] thread[%x,%x] moves %d bytes from buffer(%x,%x) to <%s> mapper / cycle %d\n",
1014	__FUNCTION__ , this->process->pid, this->trdid, size, buffer_cxy, buffer_ptr, name );
1015	}
1016	#endif
1017
1018	return 0;
1019
1020	} // end vfs_kernel_move()
1021
1022	//////////////////////////////////////
1023	error_t vfs_lseek( xptr_t file_xp,
1024	uint32_t offset,
1025	uint32_t whence,
1026	uint32_t * new_offset )
1027	{
1028	xptr_t offset_xp;
1029	xptr_t lock_xp;
1030	xptr_t size_xp;
1031	cxy_t file_cxy;
1032	vfs_file_t * file_ptr;
1033	vfs_inode_t * inode_ptr;
1034	uint32_t new;
1035
1036	// check arguments
1037	assert( (file_xp != XPTR_NULL) , "file_xp == XPTR_NULL" );
1038	assert( (new_offset != NULL ) , "new_offset == NULL" );
1039
1040	// get cluster and local pointer on remote file descriptor
1041	file_cxy = GET_CXY( file_xp );
1042	file_ptr = GET_PTR( file_xp );
1043
1044	// get local pointer on remote inode
1045	inode_ptr = (vfs_inode_t *)hal_remote_lpt( XPTR( file_cxy , &file_ptr->inode ) );
1046
1047	// build extended pointers on lock, offset and size
1048	offset_xp = XPTR( file_cxy , &file_ptr->offset );
1049	lock_xp = XPTR( file_cxy , &file_ptr->lock );
1050	size_xp = XPTR( file_cxy , &inode_ptr->size );
1051
1052	// take file descriptor lock
1053	remote_rwlock_wr_acquire( lock_xp );
1054
1055	if ( whence == SEEK_CUR ) // new = current + offset
1056	{
1057	new = hal_remote_l32( offset_xp ) + offset;
1058	}
1059	else if ( whence == SEEK_SET ) // new = offset
1060	{
1061	new = offset;
1062	}
1063	else if ( whence == SEEK_END ) // new = size + offset
1064	{
1065	new = hal_remote_l32( size_xp ) + offset;
1066	}
1067	else
1068	{
1069	printk("\n[ERROR] in %s : illegal whence value\n", __FUNCTION__ );
1070	remote_rwlock_wr_release( lock_xp );
1071	return -1;
1072	}
1073
1074	#if DEBUG_VFS_LSEEK
1075	uint32_t cycle = (uint32_t)hal_get_cycles();
1076	thread_t * this = CURRENT_THREAD;
1077	char name[CONFIG_VFS_MAX_NAME_LENGTH];
1078	vfs_inode_get_name( XPTR( file_cxy , inode_ptr ) , name );
1079	if( cycle > DEBUG_VFS_LSEEK )
1080	printk("\n[%s] thread[%x,%x] for <%s> / new offset %d / cycle %d\n",
1081	__FUNCTION__ , this->process->pid, this->trdid, name, new, cycle );
1082	#endif
1083
1084	// set new offset
1085	hal_remote_s32( offset_xp , new );
1086
1087	// release file descriptor lock
1088	remote_rwlock_wr_release( lock_xp );
1089
1090	// success
1091	*new_offset = new;
1092	return 0;
1093
1094	} // vfs_lseek()
1095
1096	////////////////////////////////////
1097	error_t vfs_close( xptr_t file_xp,
1098	uint32_t file_id )
1099	{
1100	cxy_t file_cxy; // cluster containing the file descriptor.
1101	vfs_file_t * file_ptr; // local pointer on file descriptor
1102	cxy_t owner_cxy; // process owner cluster
1103	pid_t pid; // process identifier
1104	lpid_t lpid; // process local index
1105	xptr_t root_xp; // root of xlist (processes , or dentries)
1106	xptr_t lock_xp; // lock protecting the xlist
1107	xptr_t iter_xp; // iterator on xlist
1108	mapper_t * mapper_ptr; // local pointer on associated mapper
1109	vfs_inode_t * inode_ptr; // local pointer on associated inode
1110	uint32_t size; // current file size (from inode descriptor)
1111	error_t error;
1112
1113	char name[CONFIG_VFS_MAX_NAME_LENGTH]; // file name
1114
1115	// check argument
1116	assert( (file_xp != XPTR_NULL) , "file_xp is XPTR_NULL" );
1117
1118	thread_t * this = CURRENT_THREAD;
1119	process_t * process = this->process;
1120	cluster_t * cluster = LOCAL_CLUSTER;
1121
1122	// get file name
1123	vfs_file_get_name( file_xp , name );
1124
1125	#if DEBUG_VFS_CLOSE
1126	uint32_t cycle = (uint32_t)hal_get_cycles();
1127	if( DEBUG_VFS_CLOSE < cycle )
1128	printk("\n[%s] thread[%x,%x] enter for <%s> / cycle %d\n",
1129	__FUNCTION__, process->pid, this->trdid, name, cycle );
1130	#endif
1131
1132	// get cluster and local pointer on remote file descriptor
1133	file_cxy = GET_CXY( file_xp );
1134	file_ptr = GET_PTR( file_xp );
1135
1136	//////// 1) update all dirty pages from mapper to device
1137
1138	// get local pointer on mapper associated to file
1139	mapper_ptr = hal_remote_lpt( XPTR( file_cxy , &file_ptr->mapper ) );
1140
1141	// copy all dirty pages from mapper to device
1142	error = mapper_sync( XPTR( file_cxy , mapper_ptr ) );
1143
1144	if( error )
1145	{
1146	printk("\n[ERROR] in %s : cannot synchronise dirty pages for <%s>\n",
1147	__FUNCTION__, name );
1148	return -1;
1149	}
1150
1151	#if DEBUG_VFS_CLOSE
1152	if( DEBUG_VFS_CLOSE < cycle )
1153	printk("\n[%s] thread[%x,%x] synchronised mapper of <%s> to device\n",
1154	__FUNCTION__, process->pid, this->trdid, name );
1155	#endif
1156
1157	//////// 2) update file size in all parent directory mapper(s) and update device
1158
1159	// get local pointer on remote inode
1160	inode_ptr = hal_remote_lpt( XPTR( file_cxy , &file_ptr->inode ) );
1161
1162	// get file size from remote inode
1163	size = hal_remote_l32( XPTR( file_cxy , &inode_ptr->size ) );
1164
1165	// get root of list of parents dentry
1166	root_xp = XPTR( file_cxy , &inode_ptr->parents );
1167
1168	// loop on all parents
1169	XLIST_FOREACH( root_xp , iter_xp )
1170	{
1171	// get pointers on parent directory dentry
1172	xptr_t parent_dentry_xp = XLIST_ELEMENT( iter_xp , vfs_dentry_t , parents );
1173	cxy_t parent_cxy = GET_CXY( parent_dentry_xp );
1174	vfs_dentry_t * parent_dentry_ptr = GET_PTR( parent_dentry_xp );
1175
1176	// get local pointer on parent directory inode
1177	vfs_inode_t * parent_inode_ptr = hal_remote_lpt( XPTR( parent_cxy,
1178	&parent_dentry_ptr->parent ) );
1179
1180	// get local pointer on parent directory mapper
1181	mapper_t * parent_mapper_ptr = hal_remote_lpt( XPTR( parent_cxy,
1182	&parent_inode_ptr->mapper ) );
1183
1184	// update dentry size in parent directory mapper
1185	error = vfs_fs_update_dentry( XPTR( parent_cxy , parent_inode_ptr ),
1186	parent_dentry_ptr );
1187
1188	if( error )
1189	{
1190	printk("\n[ERROR] in %s : cannot update size in parent\n",
1191	__FUNCTION__ );
1192	return -1;
1193	}
1194
1195	#if DEBUG_VFS_CLOSE
1196	char parent_name[CONFIG_VFS_MAX_NAME_LENGTH];
1197	vfs_inode_get_name( XPTR( parent_cxy , parent_inode_ptr ) , parent_name );
1198	if( DEBUG_VFS_CLOSE < cycle )
1199	printk("\n[%s] thread[%x,%x] updated <%s> in <%s> / size = %d bytes\n",
1200	__FUNCTION__, process->pid, this->trdid, name, parent_name, size );
1201	#endif
1202
1203	// copy all dirty pages from parent mapper to device
1204	error = mapper_sync( XPTR( parent_cxy , parent_mapper_ptr ) );
1205
1206	if( error )
1207	{
1208	printk("\n[ERROR] in %s : cannot synchronise parent mapper to device\n",
1209	__FUNCTION__ );
1210	return -1;
1211	}
1212
1213	#if DEBUG_VFS_CLOSE
1214	if( DEBUG_VFS_CLOSE < cycle )
1215	printk("\n[%s] thread[%x,%x] synchonized mapper of parent <%s> to device\n",
1216	__FUNCTION__, process->pid, this->trdid, parent_name );
1217	#endif
1218
1219	}
1220
1221	//////// 3) loop on the process copies to reset all fd_array[file_id] entries
1222
1223	// get owner process cluster and lpid
1224	pid = process->pid;
1225	owner_cxy = CXY_FROM_PID( pid );
1226	lpid = LPID_FROM_PID( pid );
1227
1228	// get extended pointers on copies root and lock
1229	root_xp = XPTR( owner_cxy , &cluster->pmgr.copies_root[lpid] );
1230	lock_xp = XPTR( owner_cxy , &cluster->pmgr.copies_lock[lpid] );
1231
1232	// take the lock protecting the list of copies
1233	remote_queuelock_acquire( lock_xp );
1234
1235	XLIST_FOREACH( root_xp , iter_xp )
1236	{
1237	xptr_t process_xp = XLIST_ELEMENT( iter_xp , process_t , copies_list );
1238	cxy_t process_cxy = GET_CXY( process_xp );
1239	process_t * process_ptr = GET_PTR( process_xp );
1240
1241	xptr_t entry_xp = XPTR( process_cxy , &process_ptr->fd_array.array[file_id] );
1242	hal_remote_s64( entry_xp , XPTR_NULL );
1243	vfs_file_count_down( file_xp );
1244	hal_fence();
1245	}
1246
1247	// release the lock protecting the list of copies
1248	remote_queuelock_release( lock_xp );
1249
1250	#if DEBUG_VFS_CLOSE
1251	if( DEBUG_VFS_CLOSE < cycle )
1252	printk("\n[%s] thread[%x,%x] reset all fd-array copies for <%s>\n",
1253	__FUNCTION__, process->pid, this->trdid, name );
1254	#endif
1255
1256	//////// 4) release memory allocated to file descriptor in remote cluster
1257
1258	vfs_file_destroy( file_xp );
1259
1260	#if DEBUG_VFS_CLOSE
1261	cycle = (uint32_t)hal_get_cycles();
1262	if( DEBUG_VFS_CLOSE < cycle )
1263	printk("\n[%s] thread[%x,%x] exit / closed <%s> in process %x / cycle %d\n",
1264	__FUNCTION__, process->pid, this->trdid, name, process->pid, cycle );
1265	#endif
1266
1267	return 0;
1268
1269	} // end vfs_close()
1270
1271	////////////////////////////////////
1272	error_t vfs_mkdir( xptr_t root_xp,
1273	char * path,
1274	uint32_t rights )
1275	{
1276	error_t error;
1277	xptr_t vfs_root_xp; // extended pointer on VFS root inode
1278	vfs_inode_t * vfs_root_ptr; // local pointer on VFS root inode
1279	cxy_t vfs_root_cxy; // VFS root inode cluster identifier
1280	xptr_t lock_xp; // extended pointer on lock protecting Inode Tree
1281	xptr_t inode_xp; // extended pointer on new directory inode
1282	vfs_inode_t * inode_ptr; // local pointer on new directory inode
1283	cxy_t inode_cxy; // new directory inode cluster identifier
1284	xptr_t dentry_xp; // extended pointer on new dentry
1285	vfs_dentry_t * dentry_ptr; // new dentry local pointer
1286	xptr_t parent_xp; // extended pointer on parent inode
1287	vfs_inode_t * parent_ptr; // local pointer on parent inode
1288	cxy_t parent_cxy; // parent inode cluster identifier
1289	vfs_ctx_t * parent_ctx_ptr; // local pointer on parent inode context
1290	uint32_t parent_fs_type; // parent inode file system type
1291
1292	xptr_t parents_root_xp; // extended pointer on parents field in inode (root)
1293	xptr_t parents_entry_xp; // extended pointer on parents field in dentry
1294	xptr_t children_xhtab_xp; // extended pointer on children field in inode (root)
1295	xptr_t children_entry_xp; // extended pointer on children field in dentry
1296
1297	char last_name[CONFIG_VFS_MAX_NAME_LENGTH];
1298
1299	thread_t * this = CURRENT_THREAD;
1300	process_t * process = this->process;
1301
1302	#if DEBUG_VFS_MKDIR
1303	char root_name[CONFIG_VFS_MAX_NAME_LENGTH];
1304	vfs_inode_get_name( root_xp , root_name );
1305	uint32_t cycle = (uint32_t)hal_get_cycles();
1306	if( DEBUG_VFS_MKDIR < cycle )
1307	printk("\n[%s] thread[%x,%x] enter / root <%s> / path <%s> / cycle %d\n",
1308	__FUNCTION__, process->pid, this->trdid, root_name, path, cycle );
1309	#endif
1310
1311	// build extended pointer on lock protecting Inode Tree (in VFS root inode)
1312	vfs_root_xp = process->vfs_root_xp;
1313	vfs_root_ptr = GET_PTR( vfs_root_xp );
1314	vfs_root_cxy = GET_CXY( vfs_root_xp );
1315	lock_xp = XPTR( vfs_root_cxy , &vfs_root_ptr->main_lock );
1316
1317	// take the lock protecting Inode Tree in write mode
1318	remote_rwlock_wr_acquire( lock_xp );
1319
1320	// 1. get pointers on parent inode
1321	error = vfs_lookup( root_xp,
1322	path,
1323	VFS_LOOKUP_DIR \| VFS_LOOKUP_PARENT,
1324	&parent_xp,
1325	last_name );
1326	if( error )
1327	{
1328	remote_rwlock_wr_release( lock_xp );
1329	printk("\n[ERROR] in %s : cannot get parent inode for <%s>\n",
1330	__FUNCTION__, path );
1331	return -1;
1332	}
1333
1334	// get parent inode cluster and local pointer
1335	parent_cxy = GET_CXY( parent_xp );
1336	parent_ptr = GET_PTR( parent_xp );
1337
1338	#if( DEBUG_VFS_MKDIR & 1 )
1339	if( DEBUG_VFS_MKDIR < cycle )
1340	printk("\n[%s] thread[%x,%x] get parent inode (%x,%x) for <%s>\n",
1341	__FUNCTION__, process->pid, this->trdid, parent_cxy, parent_ptr, path );
1342	#endif
1343
1344	// get parent inode context, and FS type
1345	parent_ctx_ptr = hal_remote_lpt( XPTR( parent_cxy , &parent_ptr->ctx ) );
1346	parent_fs_type = hal_remote_l32( XPTR( parent_cxy , &parent_ctx_ptr->type ) );
1347
1348	// 2. create one new dentry in parent cluster
1349	error = vfs_dentry_create( parent_cxy,
1350	parent_fs_type,
1351	last_name,
1352	&dentry_xp );
1353	if( error )
1354	{
1355	remote_rwlock_wr_release( lock_xp );
1356	printk("\n[ERROR] in %s : cannot create new dentry in cluster %x for <%s>\n",
1357	__FUNCTION__, parent_cxy, path );
1358	return -1;
1359	}
1360
1361	// get local pointer on dentry
1362	dentry_ptr = GET_PTR( dentry_xp );
1363
1364	#if( DEBUG_VFS_MKDIR & 1 )
1365	if( DEBUG_VFS_MKDIR < cycle )
1366	printk("\n[%s] thread[%x,%x] created new dentry (%x,%x) for <%s>\n",
1367	__FUNCTION__, process->pid, this->trdid, parent_cxy, dentry_ptr, path );
1368	#endif
1369
1370	// 3. create new directory inode
1371	// TODO : define attr / uid / gid
1372	uint32_t attr = 0;
1373	uint32_t uid = 0;
1374	uint32_t gid = 0;
1375
1376	// select a target cluster for new inode
1377	inode_cxy = cluster_random_select();
1378
1379	// create inode
1380	error = vfs_inode_create( inode_cxy,
1381	parent_fs_type,
1382	attr,
1383	rights,
1384	uid,
1385	gid,
1386	&inode_xp );
1387	if( error )
1388	{
1389	remote_rwlock_wr_release( lock_xp );
1390	printk("\n[ERROR] in %s : cannot create new inode in cluster %x for <%s>\n",
1391	__FUNCTION__ , inode_cxy , path );
1392	vfs_dentry_destroy( dentry_xp );
1393	return -1;
1394	}
1395
1396	// get new inode local pointer
1397	inode_ptr = GET_PTR( inode_xp );
1398
1399	// update inode "type" field
1400	hal_remote_s32( XPTR( inode_cxy , &inode_ptr->type ) , INODE_TYPE_DIR );
1401
1402	#if(DEBUG_VFS_MKDIR & 1)
1403	if( DEBUG_VFS_MKDIR < cycle )
1404	printk("\n[%s] thread[%x,%x] created new inode (%x,%x) for <%s>\n",
1405	__FUNCTION__ , process->pid, this->trdid, inode_cxy, inode_ptr, path );
1406	#endif
1407
1408	// 4. register dentry in new inode list of parents
1409	parents_root_xp = XPTR( inode_cxy , &inode_ptr->parents );
1410	parents_entry_xp = XPTR( parent_cxy , &dentry_ptr->parents );
1411	xlist_add_first( parents_root_xp , parents_entry_xp );
1412	hal_remote_atomic_add( XPTR( inode_cxy , &inode_ptr->links ) , 1 );
1413
1414	// 5. register dentry in parent inode
1415	children_xhtab_xp = XPTR( parent_cxy , &parent_ptr->children );
1416	children_entry_xp = XPTR( parent_cxy , &dentry_ptr->children );
1417	xhtab_insert( children_xhtab_xp , last_name , children_entry_xp );
1418
1419	// 6. update "parent" and "child_xp" fields in dentry
1420	hal_remote_s64( XPTR( parent_cxy , &dentry_ptr->child_xp ) , inode_xp );
1421	hal_remote_spt( XPTR( parent_cxy , &dentry_ptr->parent ) , parent_ptr );
1422
1423	#if(DEBUG_VFS_MKDIR & 1)
1424	if( DEBUG_VFS_MKDIR < cycle )
1425	printk("\n[%s] thread[%x,%x] updated Inode Tree for <%s>\n",
1426	__FUNCTION__, process->pid, this->trdid, path );
1427	#endif
1428
1429	// 7. create the two special dentries <.> and <..> in new directory
1430	// both the new directory mapper, and the Inode Tree are updated
1431	error = vfs_add_special_dentries( inode_xp,
1432	parent_xp );
1433
1434	if( error )
1435	{
1436	remote_rwlock_wr_release( lock_xp );
1437	printk("\n[ERROR] in %s : cannot create new inode in cluster %x for <%s>\n",
1438	__FUNCTION__ , inode_cxy , path );
1439	vfs_dentry_destroy( dentry_xp );
1440	return -1;
1441	}
1442
1443	// release the lock protecting Inode Tree
1444	remote_rwlock_wr_release( lock_xp );
1445
1446	// 8. update parent directory mapper
1447	// and synchronize the parent directory on IOC device
1448	error = vfs_fs_add_dentry( parent_xp,
1449	dentry_ptr );
1450	if( error )
1451	{
1452	printk("\n[ERROR] in %s : cannot update parent directory for <%s>\n",
1453	__FUNCTION__, path );
1454	return -1;
1455	}
1456
1457	#if(DEBUG_VFS_MKDIR & 1)
1458	if( DEBUG_VFS_MKDIR < cycle )
1459	printk("\n[%s] thread[%x,%x] updated parent dir (mapper and IOC) for <%s>\n",
1460	__FUNCTION__, process->pid, this->trdid, path );
1461	#endif
1462
1463	return 0;
1464
1465	} // end vfs_mkdir()
1466
1467	///////////////////////////////////////
1468	error_t vfs_link( xptr_t old_root_xp,
1469	char * old_path,
1470	xptr_t new_root_xp,
1471	char * new_path )
1472	{
1473	error_t error;
1474	xptr_t vfs_root_xp; // extended pointer on VFS root inode
1475	vfs_inode_t * vfs_root_ptr; // local pointer on VFS root inode
1476	cxy_t vfs_root_cxy; // VFS root inode cluster identifier
1477	xptr_t lock_xp; // extended pointer on lock protecting Inode Tree
1478	xptr_t inode_xp; // extended pointer on target inode
1479	vfs_inode_t * inode_ptr; // local pointer on target inode
1480	cxy_t inode_cxy; // target inode cluster identifier
1481	uint32_t inode_type; // target inode type
1482	vfs_ctx_t * inode_ctx_ptr; // local pointer on target inode context
1483	uint32_t inode_fs_type; // target inode file system type
1484	xptr_t dentry_xp; // extended pointer on new dentry
1485	vfs_dentry_t * dentry_ptr; // target dentry local pointer
1486	xptr_t new_parent_xp; // extended pointer on new parent inode
1487	vfs_inode_t * new_parent_ptr; // local pointer on new parent inode
1488	cxy_t new_parent_cxy; // new parent inode cluster identifier
1489
1490	xptr_t parents_root_xp; // extended pointer on parents field in inode (root)
1491	xptr_t parents_entry_xp; // extended pointer on parents field in dentry
1492	xptr_t children_xhtab_xp; // extended pointer on children field in inode (root)
1493	xptr_t children_entry_xp; // extended pointer on children field in dentry
1494
1495	char new_name[CONFIG_VFS_MAX_NAME_LENGTH];
1496
1497	thread_t * this = CURRENT_THREAD;
1498	process_t * process = this->process;
1499
1500	#if DEBUG_VFS_LINK
1501	char old_root_name[CONFIG_VFS_MAX_NAME_LENGTH];
1502	char new_root_name[CONFIG_VFS_MAX_NAME_LENGTH];
1503	vfs_inode_get_name( old_root_xp , old_root_name );
1504	vfs_inode_get_name( new_root_xp , new_root_name );
1505	uint32_t cycle = (uint32_t)hal_get_cycles();
1506	if( DEBUG_VFS_LINK < cycle )
1507	printk("\n[%s] thread[%x,%x] enter / old_root <%s> / old_path <%s> / "
1508	"new_root <%s> / new_path <%s> / cycle %d\n",
1509	__FUNCTION__, process->pid, this->trdid,
1510	old_root_name, old_path, new_root_name, new_path, cycle );
1511	#endif
1512
1513	// build extended pointer on lock protecting Inode Tree (in VFS root inode)
1514	vfs_root_xp = process->vfs_root_xp;
1515	vfs_root_ptr = GET_PTR( vfs_root_xp );
1516	vfs_root_cxy = GET_CXY( vfs_root_xp );
1517	lock_xp = XPTR( vfs_root_cxy , &vfs_root_ptr->main_lock );
1518
1519	// take the lock protecting Inode Tree in write mode
1520	remote_rwlock_wr_acquire( lock_xp );
1521
1522	// get extended pointer on target inode
1523	error = vfs_lookup( old_root_xp,
1524	old_path,
1525	0,
1526	&inode_xp,
1527	NULL );
1528	if( error )
1529	{
1530	remote_rwlock_wr_release( lock_xp );
1531	printk("\n[ERROR] in %s : cannot get target inode for <%s>\n",
1532	__FUNCTION__, old_path );
1533	return -1;
1534	}
1535
1536	#if( DEBUG_VFS_LINK & 1 )
1537	if( DEBUG_VFS_LINK < cycle )
1538	printk("\n[%s] thread[%x,%x] get child inode (%x,%x) for <%s>\n",
1539	__FUNCTION__, process->pid, this->trdid,
1540	GET_CXY(inode_xp), GET_PTR(inode_xp), old_path, cycle );
1541	#endif
1542
1543	// get extended pointer on parent inode in new path
1544	error = vfs_lookup( new_root_xp,
1545	new_path,
1546	VFS_LOOKUP_PARENT,
1547	&new_parent_xp,
1548	new_name );
1549	if( error )
1550	{
1551	remote_rwlock_wr_release( lock_xp );
1552	printk("\n[ERROR] in %s : cannot get parent inode for <%s>\n",
1553	__FUNCTION__, new_path );
1554	return -1;
1555	}
1556
1557	#if( DEBUG_VFS_LINK & 1 )
1558	if( DEBUG_VFS_LINK < cycle )
1559	printk("\n[%s] thread[%x,%x] get parent inode (%x,%x) for <%s>\n",
1560	__FUNCTION__, process->pid, this->trdid,
1561	GET_CXY(new_parent_xp), GET_PTR(new_parent_xp), new_path );
1562	#endif
1563
1564	// get target inode cluster and local pointer
1565	inode_cxy = GET_CXY( inode_xp );
1566	inode_ptr = GET_PTR( inode_xp );
1567
1568	// get target inode type, context, and FS type
1569	inode_type = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->type ) );
1570	inode_ctx_ptr = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->ctx ) );
1571	inode_fs_type = hal_remote_l32( XPTR( inode_cxy , &inode_ctx_ptr->type ) );
1572
1573	// get new parent inode cluster an local pointer
1574	new_parent_ptr = GET_PTR( new_parent_xp );
1575	new_parent_cxy = GET_CXY( new_parent_xp );
1576
1577	///////////////////////////////////////////////////////////////////////
1578	if( (inode_type == INODE_TYPE_FILE) \|\| (inode_type == INODE_TYPE_DIR) )
1579	{
1580	// 1. create one new dentry
1581	error = vfs_dentry_create( new_parent_cxy,
1582	inode_fs_type,
1583	new_name,
1584	&dentry_xp );
1585	if( error )
1586	{
1587	remote_rwlock_wr_release( lock_xp );
1588	printk("\n[ERROR] in %s : cannot create new dentry for <%s>\n",
1589	__FUNCTION__, new_path );
1590	return -1;
1591	}
1592
1593	// get local pointer on dentry
1594	dentry_ptr = GET_PTR( dentry_xp );
1595
1596	// 2. register dentry in target inode
1597	parents_root_xp = XPTR( inode_cxy , &inode_ptr->parents );
1598	parents_entry_xp = XPTR( new_parent_cxy , &dentry_ptr->parents );
1599	xlist_add_first( parents_root_xp , parents_entry_xp );
1600	hal_remote_atomic_add( XPTR( inode_cxy , &inode_ptr->links ) , 1 );
1601
1602	// 3. register dentry in parent inode
1603	children_xhtab_xp = XPTR( new_parent_cxy , &new_parent_ptr->children );
1604	children_entry_xp = XPTR( new_parent_cxy , &dentry_ptr->children );
1605	xhtab_insert( children_xhtab_xp , new_name , children_entry_xp );
1606
1607	// 4. update "parent" and "child_xp" fields in dentry
1608	hal_remote_s64( XPTR( new_parent_cxy , &dentry_ptr->child_xp ) , inode_xp );
1609	hal_remote_spt( XPTR( new_parent_cxy , &dentry_ptr->parent ) , new_parent_ptr );
1610
1611	#if(DEBUG_VFS_LINK & 1)
1612	if( DEBUG_VFS_LINK < cycle )
1613	printk("\n[%s] thread[%x,%x] updated Inode Tree / old <%s> / new <%s>\n",
1614	__FUNCTION__, process->pid, this->trdid, old_path, new_path );
1615	vfs_display( new_parent_xp );
1616	#endif
1617
1618	// release the lock protecting Inode Tree
1619	remote_rwlock_wr_release( lock_xp );
1620
1621	// 5. update new parent directory mapper in Inode Tree
1622	// and synchronize the parent directory on IOC device
1623	if (new_parent_cxy == local_cxy)
1624	error = vfs_fs_add_dentry( new_parent_xp,
1625	dentry_ptr );
1626	if( error )
1627	{
1628	printk("\n[ERROR] in %s : cannot update new parent directory for <%s>\n",
1629	__FUNCTION__, new_path );
1630	return -1;
1631	}
1632
1633	#if(DEBUG_VFS_LINK & 1)
1634	if( DEBUG_VFS_LINK < cycle )
1635	printk("\n[%s] thread[%x,%x] updated new parent dir (mapper and IOC) / old <%s> / new <%s>\n",
1636	__FUNCTION__, process->pid, this->trdid, old_path, new_path );
1637	#endif
1638	return 0;
1639	}
1640	else
1641	{
1642	// release the lock protecting Inode Tree
1643	remote_rwlock_wr_release( lock_xp );
1644
1645	printk("\n[ERROR] in %s : unsupported inode type %s\n",
1646	__FUNCTION__ , vfs_inode_type_str( inode_type ) );
1647	return -1;
1648	}
1649
1650	} // end vfs_link()
1651
1652	/////////////////////////////////////
1653	error_t vfs_unlink( xptr_t root_xp,
1654	char * path )
1655	{
1656	error_t error;
1657	xptr_t vfs_root_xp; // extended pointer on VFS root inode
1658	vfs_inode_t * vfs_root_ptr; // local_pointer on VFS root inode
1659	cxy_t vfs_root_cxy; // VFS root inode cluster identifier
1660	xptr_t lock_xp; // extended pointer on lock protecting Inode Tree
1661	xptr_t parent_xp; // extended pointer on target inode
1662	cxy_t parent_cxy; // target inode cluster identifier
1663	vfs_inode_t * parent_ptr; // target inode local pointer
1664	xptr_t inode_xp; // extended pointer on target inode
1665	cxy_t inode_cxy; // target inode cluster identifier
1666	vfs_inode_t * inode_ptr; // target inode local pointer
1667	uint32_t inode_links; // target inode links count
1668	vfs_inode_type_t inode_type; // target inode type
1669	uint32_t inode_children; // target inode number of children
1670	xptr_t dentry_xp; // extended pointer on dentry to unlink
1671	vfs_dentry_t * dentry_ptr; // local pointer on dentry to unlink
1672	vfs_ctx_t * ctx_ptr; // local pointer on FS context
1673	vfs_fs_type_t fs_type; // File system type
1674
1675	char child_name[CONFIG_VFS_MAX_NAME_LENGTH]; // name of link to remove
1676	char parent_name[CONFIG_VFS_MAX_NAME_LENGTH]; // name of parent directory
1677
1678	thread_t * this = CURRENT_THREAD;
1679	process_t * process = this->process;
1680
1681	#if DEBUG_VFS_UNLINK
1682	uint32_t cycle = (uint32_t)hal_get_cycles();
1683	char root_name[CONFIG_VFS_MAX_NAME_LENGTH];
1684	vfs_inode_get_name( root_xp , root_name );
1685	if( DEBUG_VFS_UNLINK < cycle )
1686	printk("\n[%s] thread[%x,%x] : enter for root <%s> / path <%s> / cycle %d\n",
1687	__FUNCTION__, process->pid, this->trdid, root_name, path, cycle );
1688	#endif
1689
1690	// build extended pointer on lock protecting Inode Tree (in VFS root inode)
1691	vfs_root_xp = process->vfs_root_xp;
1692	vfs_root_ptr = GET_PTR( vfs_root_xp );
1693	vfs_root_cxy = GET_CXY( vfs_root_xp );
1694	lock_xp = XPTR( vfs_root_cxy , &vfs_root_ptr->main_lock );
1695
1696	// take the lock protecting Inode Tree
1697	remote_rwlock_wr_acquire( lock_xp );
1698
1699	// get extended pointer on parent inode
1700	error = vfs_lookup( root_xp,
1701	path,
1702	VFS_LOOKUP_PARENT,
1703	&parent_xp,
1704	child_name );
1705	if( error )
1706	{
1707	remote_rwlock_wr_release( lock_xp );
1708	printk("\n[ERROR] in %s : cannot get parent inode for <%s> in <%s>\n",
1709	__FUNCTION__, child_name, path );
1710	return -1;
1711	}
1712
1713	// get parent inode name, cluster and local pointer
1714	vfs_inode_get_name( parent_xp , parent_name );
1715	parent_cxy = GET_CXY( parent_xp );
1716	parent_ptr = GET_PTR( parent_xp );
1717
1718	#if( DEBUG_VFS_UNLINK & 1 )
1719	if( DEBUG_VFS_UNLINK < cycle )
1720	printk("\n[%s] thread[%x,%x] : parent inode <%s> is (%x,%x)\n",
1721	__FUNCTION__, process->pid, this->trdid, parent_name, parent_cxy, parent_ptr );
1722	#endif
1723
1724	// build extended pointer on parent inode "children" xhtab
1725	xptr_t children_xp = XPTR( parent_cxy , &parent_ptr->children );
1726
1727	// try to get extended pointer on dentry from Inode Tree
1728	dentry_xp = xhtab_lookup( children_xp , child_name );
1729
1730	// when dentry not found in Inode Tree, try to get it from mapper
1731
1732	if( dentry_xp == XPTR_NULL ) // miss target dentry in Inode Tree
1733	{
1734
1735	#if( DEBUG_VFS_UNLINK & 1 )
1736	if( DEBUG_VFS_UNLINK < cycle )
1737	printk("\n[%s] thread[%x,%x] : inode <%s> not found => scan parent mapper <%s>\n",
1738	__FUNCTION__, process->pid, this->trdid, child_name , parent_name );
1739	#endif
1740	// get parent inode FS type
1741	ctx_ptr = hal_remote_lpt( XPTR( parent_cxy , &parent_ptr->ctx ) );
1742	fs_type = hal_remote_l32( XPTR( parent_cxy , &ctx_ptr->type ) );
1743
1744	// select a cluster for new inode
1745	inode_cxy = cluster_random_select();
1746
1747	// speculatively insert a new child dentry/inode couple in inode tree
1748	error = vfs_add_child_in_parent( inode_cxy,
1749	fs_type,
1750	parent_xp,
1751	child_name,
1752	&dentry_xp,
1753	&inode_xp );
1754	if( error )
1755	{
1756	printk("\n[ERROR] in %s : cannot create inode <%s> in Inode Tree\n",
1757	__FUNCTION__ , child_name );
1758	return -1;
1759	}
1760
1761	// get local pointers on new dentry and new inode descriptors
1762	inode_ptr = GET_PTR( inode_xp );
1763	dentry_ptr = GET_PTR( dentry_xp );
1764
1765	// scan parent mapper to find the missing dentry, and complete
1766	// initialisation of new dentry and new inode descriptors In Inode Tree
1767	error = vfs_fs_new_dentry_from_mapper( parent_xp,
1768	dentry_ptr );
1769	if ( error )
1770	{
1771	printk("\n[ERROR] in %s : cannot get entry <%s> in parent <%s> mapper\n",
1772	__FUNCTION__ , child_name, parent_name );
1773	return -1;
1774	}
1775
1776	#if (DEBUG_VFS_UNLINK & 1)
1777	if( DEBUG_VFS_UNLINK < cycle )
1778	printk("\n[%s] thread[%x,%x] : created missing inode & dentry <%s> in cluster %x\n",
1779	__FUNCTION__, process->pid, this->trdid, child_name, inode_cxy );
1780	#endif
1781
1782	}
1783	else // found target dentry in Inode Tree
1784	{
1785	dentry_ptr = GET_PTR( dentry_xp );
1786
1787	// get pointer on target inode from dentry
1788	inode_xp = hal_remote_l64( XPTR( parent_cxy , &dentry_ptr->child_xp ) );
1789	inode_cxy = GET_CXY( inode_xp );
1790	inode_ptr = GET_PTR( inode_xp );
1791	}
1792
1793	// At this point the Inode Tree contains the target dentry and child inode
1794	// we can safely remove this dentry from both the parent mapper, and the Inode Tree.
1795
1796	#if( DEBUG_VFS_UNLINK & 1 )
1797	if( DEBUG_VFS_UNLINK < cycle )
1798	printk("\n[%s] thread[%x,%x] : dentry (%x,%x) / inode (%x,%x)\n",
1799	__FUNCTION__, process->pid, this->trdid, parent_cxy, dentry_ptr, inode_cxy, inode_ptr );
1800	#endif
1801
1802	// get target inode "type" and "links"
1803	inode_type = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->type ) );
1804	inode_links = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->links ) );
1805
1806	///////////////////////////////////////////////////////////////////////
1807	if( (inode_type == INODE_TYPE_FILE) \|\| (inode_type == INODE_TYPE_DIR) )
1808	{
1809
1810	#if( DEBUG_VFS_UNLINK & 1 )
1811	if( DEBUG_VFS_UNLINK < cycle )
1812	printk("\n[%s] thread[%x,%x] : unlink inode <%s> / type %s / %d links\n",
1813	__FUNCTION__, process->pid, this->trdid, child_name,
1814	vfs_inode_type_str(inode_type), inode_links );
1815	#endif
1816
1817	// 1. Release clusters allocated to target inode
1818	// and synchronize the FAT on IOC device if last link.
1819	if( inode_links == 1 )
1820	{
1821	// build extended pointer on target inode "children" number
1822	xptr_t inode_children_xp = XPTR( inode_cxy , &inode_ptr->children.items );
1823
1824	// get target inode number of children
1825	inode_children = hal_remote_l32( inode_children_xp );
1826
1827	// check no children
1828	if( inode_children != 0 )
1829	{
1830	remote_rwlock_wr_release( lock_xp );
1831	printk("\n[ERROR] in %s : cannot remove <%s> inode that has children\n",
1832	__FUNCTION__, path );
1833	return -1;
1834	}
1835
1836	// release clusters on IOC device
1837	error = vfs_fs_release_inode( inode_xp );
1838
1839	if( error )
1840	{
1841	remote_rwlock_wr_release( lock_xp );
1842	printk("\n[ERROR] in %s : cannot update FAT mapper to remove <%s> inode\n",
1843	__FUNCTION__ , path );
1844	return -1;
1845	}
1846
1847	#if(DEBUG_VFS_UNLINK & 1)
1848	if( DEBUG_VFS_UNLINK < cycle )
1849	printk("\n[%s] thread[%x,%x] removed <%s> inode from FAT (mapper and IOC device)\n",
1850	__FUNCTION__, process->pid, this->trdid, path );
1851	#endif
1852	}
1853
1854	// 2. update parent directory mapper
1855	// and synchronize the parent directory on IOC device
1856	error = vfs_fs_remove_dentry( parent_xp,
1857	dentry_ptr );
1858	if( error )
1859	{
1860	remote_rwlock_wr_release( lock_xp );
1861	printk("\n[ERROR] in %s : cannot update dentry on device for <%s>\n",
1862	__FUNCTION__ , path );
1863	return -1;
1864	}
1865
1866	#if(DEBUG_VFS_UNLINK & 1)
1867	if( DEBUG_VFS_UNLINK < cycle )
1868	printk("\n[%s] thread[%x,%x] removed <%s> inode from parent dir (mapper and IOC device)\n",
1869	__FUNCTION__, process->pid, this->trdid, path );
1870	#endif
1871	// 3. remove dentry from Inode Tree (and associated chils inode when last link)
1872	vfs_remove_child_from_parent( dentry_xp );
1873
1874	// release the lock protecting Inode Tree
1875	remote_rwlock_wr_release( lock_xp );
1876
1877	#if DEBUG_VFS_UNLINK
1878	if( DEBUG_VFS_UNLINK < cycle )
1879	printk("\n[%s] thread[%x,%x] exit / removed <%s> inode from Inode Tree / cycle %d\n",
1880	__FUNCTION__, process->pid, this->trdid, path, cycle );
1881	#endif
1882	return 0;
1883	}
1884	else
1885	{
1886	remote_rwlock_wr_release( lock_xp );
1887	printk("\n[ERROR] in %s : unsupported inode type %s\n",
1888	__FUNCTION__ , vfs_inode_type_str( inode_type ) );
1889	return -1;
1890	}
1891
1892	} // end vfs_unlink()
1893
1894	////////////////////////////////////////////////
1895	error_t vfs_stat( xptr_t root_inode_xp,
1896	char * path,
1897	struct stat * st )
1898	{
1899	error_t error;
1900	xptr_t inode_xp; // extended pointer on target inode
1901	vfs_inode_t * inode_ptr; // local pointer on target inode
1902	cxy_t inode_cxy; // target inode cluster identifier
1903	xptr_t vfs_root_xp; // extended pointer on VFS root inode
1904	vfs_inode_t * vfs_root_ptr; // local_pointer on VFS root inode
1905	cxy_t vfs_root_cxy; // VFS root inode cluster identifier
1906	xptr_t lock_xp; // extended pointer on lock protecting Inode Tree
1907
1908	thread_t * this = CURRENT_THREAD;
1909	process_t * process = this->process;
1910
1911	// build extended pointer on lock protecting Inode Tree (in VFS root inode)
1912	vfs_root_xp = process->vfs_root_xp;
1913	vfs_root_ptr = GET_PTR( vfs_root_xp );
1914	vfs_root_cxy = GET_CXY( vfs_root_xp );
1915	lock_xp = XPTR( vfs_root_cxy , &vfs_root_ptr->main_lock );
1916
1917	// get the lock protecting Inode Tree in read mode
1918	remote_rwlock_rd_acquire( lock_xp );
1919
1920	// get extended pointer on target inode
1921	error = vfs_lookup( root_inode_xp,
1922	path,
1923	0,
1924	&inode_xp,
1925	NULL );
1926
1927	// release the lock protecting Inode Tree
1928	remote_rwlock_rd_release( lock_xp );
1929
1930	if( error )
1931	{
1932	printk("\n[ERROR] in %s : cannot found inode <%s>\n",
1933	__FUNCTION__ , path );
1934	return -1;
1935	}
1936
1937	// get cluster and local pointer on inode descriptor
1938	inode_ptr = GET_PTR( inode_xp );
1939	inode_cxy = GET_CXY( inode_xp );
1940
1941	// get relevant infos from inode descriptor
1942	uint32_t inum = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->inum ) );
1943	uint32_t size = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->size ) );
1944	uint32_t uid = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->uid ) );
1945	uint32_t gid = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->gid ) );
1946	uint32_t type = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->type ) );
1947	uint32_t rights = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->rights ) );
1948
1949	// set stat structure fields
1950	st->st_ino = inum;
1951	st->st_gid = gid;
1952	st->st_uid = uid;
1953	st->st_size = size;
1954	st->st_mode = (type << 16) \| rights;
1955
1956	#if DEBUG_VFS_STAT
1957	uint32_t cycle = (uint32_t)hal_get_cycles();
1958	if( DEBUG_VFS_STAT < cycle )
1959	printk("\n[%s] thread[%x,%x] set stat %x for inode %x in cluster %x / cycle %d\n"
1960	" %s / inum %d / size %d\n",
1961	__FUNCTION__, process->pid, this->trdid, st, inode_ptr, inode_cxy, cycle,
1962	vfs_inode_type_str( type ), inum, size );
1963	#endif
1964
1965	return 0;
1966
1967	} // end vfs_stat()
1968
1969	////////////////////////////////////
1970	error_t vfs_chdir( xptr_t root_xp,
1971	char * path )
1972	{
1973	error_t error;
1974	xptr_t inode_xp; // extended pointer on target inode
1975	cxy_t inode_cxy; // target inode cluster identifier
1976	vfs_inode_t * inode_ptr; // target inode local pointer
1977	vfs_inode_type_t inode_type; // target inode type
1978	xptr_t vfs_root_xp; // extended pointer on VFS root inode
1979	vfs_inode_t * vfs_root_ptr; // local_pointer on VFS root inode
1980	cxy_t vfs_root_cxy; // VFS root inode cluster identifier
1981	xptr_t main_lock_xp; // extended pointer on lock protecting Inode Tree
1982	xptr_t ref_xp; // extended pointer on reference process
1983	process_t * ref_ptr; // local pointer on reference process
1984	cxy_t ref_cxy; // reference process cluster
1985	xptr_t cwd_lock_xp; // extended pointer on lock protecting CWD change
1986	xptr_t cwd_xp_xp; // extended pointer on cwd_xp in reference process
1987
1988	thread_t * this = CURRENT_THREAD;
1989	process_t * process = this->process;
1990
1991	#if DEBUG_VFS_CHDIR
1992	uint32_t cycle = (uint32_t)hal_get_cycles();
1993	if( DEBUG_VFS_CHDIR < cycle )
1994	printk("\n[%s] thread[%x,%x] enter for path <%s> / cycle %d\n",
1995	__FUNCTION__, process->pid, this->trdid, path, cycle );
1996	#endif
1997
1998	// build extended pointer on lock protecting Inode Tree (in VFS root inode)
1999	vfs_root_xp = process->vfs_root_xp;
2000	vfs_root_ptr = GET_PTR( vfs_root_xp );
2001	vfs_root_cxy = GET_CXY( vfs_root_xp );
2002	main_lock_xp = XPTR( vfs_root_cxy , &vfs_root_ptr->main_lock );
2003
2004	// take lock protecting Inode Tree in read mode
2005	remote_rwlock_rd_acquire( main_lock_xp );
2006
2007	// get extended pointer on target inode
2008	error = vfs_lookup( root_xp,
2009	path,
2010	VFS_LOOKUP_DIR,
2011	&inode_xp,
2012	NULL );
2013
2014	// release lock protecting Inode Tree in read mode
2015	remote_rwlock_rd_release( main_lock_xp );
2016
2017	if( error )
2018	{
2019	printk("\n[ERROR] in %s : <%s> not found\n",
2020	__FUNCTION__, path );
2021	return -1;
2022	}
2023
2024	// get inode type from remote file
2025	inode_cxy = GET_CXY( inode_xp );
2026	inode_ptr = GET_PTR( inode_xp );
2027	inode_type = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->type ) );
2028
2029	if( inode_type != INODE_TYPE_DIR )
2030	{
2031	printk("\n[ERROR] in %s : <%s> is not a directory\n",
2032	__FUNCTION__, path );
2033	return -1;
2034	}
2035
2036	// build extended pointer on cwd_lock and cwd_xp
2037	ref_xp = process->ref_xp;
2038	ref_ptr = GET_PTR( ref_xp );
2039	ref_cxy = GET_CXY( ref_xp );
2040	cwd_lock_xp = XPTR( ref_cxy , &ref_ptr->cwd_lock );
2041	cwd_xp_xp = XPTR( ref_cxy , &ref_ptr->cwd_xp );
2042
2043	// take lock protecting CWD changes
2044	remote_busylock_acquire( cwd_lock_xp );
2045
2046	// update cwd_xp field in reference process descriptor
2047	hal_remote_s64( cwd_xp_xp , inode_xp );
2048
2049	// release lock protecting CWD changes
2050	remote_busylock_release( cwd_lock_xp );
2051
2052	#if DEBUG_VFS_CHDIR
2053	cycle = (uint32_t)hal_get_cycles();
2054	if( DEBUG_VFS_CHDIR < cycle )
2055	printk("\n[%s] thread[%x,%x] exit : inode (%x,%x) / &cwd_xp (%x,%x) / cycle %d\n",
2056	__FUNCTION__, process->pid, this->trdid, inode_cxy, inode_ptr,
2057	GET_CXY(cwd_xp_xp), GET_PTR(cwd_xp_xp), cycle );
2058	#endif
2059
2060	return 0;
2061
2062	} // end vfs_chdir()
2063
2064	///////////////////////////////////
2065	error_t vfs_chmod( xptr_t cwd_xp,
2066	char * path,
2067	uint32_t rights )
2068	{
2069	error_t error;
2070	xptr_t inode_xp; // extended pointer on target inode
2071	cxy_t inode_cxy; // inode cluster identifier
2072	vfs_inode_t * inode_ptr; // inode local pointer
2073
2074	// check lookup working mode
2075	assert( (rights == 0), "access rights non implemented yet" );
2076
2077	// get extended pointer on target inode
2078	error = vfs_lookup( cwd_xp,
2079	path,
2080	0,
2081	&inode_xp,
2082	NULL );
2083
2084	if( error ) return error;
2085
2086	// get inode cluster and local pointer
2087	inode_cxy = GET_CXY( inode_xp );
2088	inode_ptr = GET_PTR( inode_xp );
2089
2090	// get inode type from remote inode
2091	// inode_type = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->type ) );
2092
2093	// TODO finalize implementation
2094
2095	assert( false , "not implemented" );
2096
2097	// set inode rights in remote inode
2098	hal_remote_s32( XPTR( inode_cxy , &inode_ptr->rights ) , rights );
2099
2100	return 0;
2101	}
2102
2103	///////////////////////////////////
2104	error_t vfs_mkfifo( xptr_t cwd_xp,
2105	char * path,
2106	uint32_t rights )
2107	{
2108	assert( false , "not implemented %l %x %x", cwd_xp, path, rights );
2109	return 0;
2110	}
2111
2112
2113
2114	//////////////////////////////////////////////////////////////////////////////////////////
2115	// Distributed Inode Tree access related functions
2116	//////////////////////////////////////////////////////////////////////////////////////////
2117
2118	//////////////////////////////////////////////////////////////////////////
2119	// This recursive function is called by the vfs_display() function.
2120	// that is supposed to take the TXT0 lock.
2121	//////////////////////////////////////////////////////////////////////////
2122	static void vfs_recursive_display( xptr_t inode_xp,
2123	xptr_t name_xp,
2124	uint32_t indent )
2125	{
2126	cxy_t inode_cxy;
2127	vfs_inode_t * inode_ptr;
2128	vfs_inode_type_t inode_type;
2129	uint32_t inode_size;
2130	uint32_t inode_attr;
2131	void * inode_extd;
2132
2133	xptr_t children_xp; // extended pointer on children xhtab
2134
2135	xptr_t child_dentry_xp;
2136	cxy_t child_dentry_cxy;
2137	vfs_dentry_t * child_dentry_ptr;
2138	xptr_t child_inode_xp;
2139	xptr_t child_dentry_name_xp;
2140	mapper_t * mapper_ptr;
2141
2142	char name[CONFIG_VFS_MAX_NAME_LENGTH];
2143
2144	char * indent_str[] = { "", // level 0
2145	" ", // level 1
2146	" ", // level 2
2147	" ", // level 3
2148	" ", // level 4
2149	" ", // level 5
2150	" ", // level 6
2151	" ", // level 7
2152	" ", // level 8
2153	" ", // level 9
2154	" ", // level 10
2155	" ", // level 11
2156	" ", // level 12
2157	" ", // level 13
2158	" ", // level 14
2159	" " }; // level 15
2160
2161	assert( (inode_xp != XPTR_NULL) , "inode_xp cannot be NULL" );
2162	assert( (name_xp != XPTR_NULL) , "name_xp cannot be NULL" );
2163	assert( (indent < 16) , "depth cannot be larger than 15" );
2164
2165	// get current inode cluster and local pointer
2166	inode_cxy = GET_CXY( inode_xp );
2167	inode_ptr = GET_PTR( inode_xp );
2168
2169	// get inode type, size, attr, mapper, and inum
2170	inode_type = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->type ) );
2171	inode_size = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->size ) );
2172	inode_attr = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->attr ) );
2173	inode_extd = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->extend ) );
2174	mapper_ptr = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
2175
2176	// make a local copy of node name
2177	hal_remote_strcpy( XPTR( local_cxy , name ) , name_xp );
2178
2179	// compute dirty
2180	// inode_dirty = ((inode_attr & INODE_ATTR_DIRTY) != 0); unused [AG] dec 2019
2181
2182	// display inode
2183	nolock_printk("%s<%s> : %s / extd %x / %d bytes / cxy %x / inode %x / mapper %x\n",
2184	indent_str[indent], name, vfs_inode_type_str( inode_type ), (uint32_t)inode_extd,
2185	inode_size, inode_cxy, inode_ptr, mapper_ptr );
2186
2187	// scan directory entries when current inode is a directory
2188	// don't scan the the "." and ".." directories to break loops
2189	if( (inode_type == INODE_TYPE_DIR) &&
2190	(strcmp( name , "." ) != 0) &&
2191	(strcmp( name , ".." ) != 0) )
2192	{
2193	// get extended pointer on directory entries xhtab
2194	children_xp = XPTR( inode_cxy , &inode_ptr->children );
2195
2196	// get xhtab lock
2197	xhtab_lock( children_xp );
2198
2199	// get first dentry from xhtab
2200	child_dentry_xp = xhtab_get_first( children_xp );
2201
2202	while( child_dentry_xp != XPTR_NULL )
2203	{
2204	// get dentry cluster and local pointer
2205	child_dentry_cxy = GET_CXY( child_dentry_xp );
2206	child_dentry_ptr = GET_PTR( child_dentry_xp );
2207
2208	// get extended pointer on child inode
2209	child_inode_xp = hal_remote_l64( XPTR( child_dentry_cxy,
2210	&child_dentry_ptr->child_xp ) );
2211
2212	// get extended pointer on dentry name
2213	child_dentry_name_xp = XPTR( child_dentry_cxy , &child_dentry_ptr->name );
2214
2215	// recursive call on inode display
2216	vfs_recursive_display( child_inode_xp,
2217	child_dentry_name_xp,
2218	indent+1 );
2219
2220	// get next dentry
2221	child_dentry_xp = xhtab_get_next( children_xp );
2222	}
2223
2224	// release xhtab lock
2225	xhtab_unlock( children_xp );
2226	}
2227	} // end vfs_recursive_display()
2228
2229	///////////////////////////////////
2230	void vfs_display( xptr_t inode_xp )
2231	{
2232	xptr_t name_xp;
2233	xptr_t dentry_xp;
2234	cxy_t dentry_cxy;
2235	vfs_dentry_t * dentry_ptr;
2236	xptr_t parents_root_xp; // root of parent dentries xlist
2237
2238	// get target inode cluster and local pointer
2239	cxy_t inode_cxy = GET_CXY( inode_xp );
2240	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
2241
2242	// build extended pointer on parents dentries root
2243	parents_root_xp = XPTR( inode_cxy , &inode_ptr->parents );
2244
2245	// check VFS root
2246	if( xlist_is_empty( parents_root_xp ) ) // inode is the VFS root
2247	{
2248	// build extended pointer on root name
2249	name_xp = XPTR( local_cxy , "/" );
2250	}
2251	else
2252	{
2253	// get first parent dentry cluster and pointers
2254	dentry_xp = XLIST_FIRST( parents_root_xp , vfs_dentry_t , parents );
2255	dentry_cxy = GET_CXY( dentry_xp );
2256	dentry_ptr = GET_PTR( dentry_xp );
2257
2258	// get extended pointer on dentry name
2259	name_xp = XPTR( dentry_cxy , &dentry_ptr->name );
2260	}
2261
2262	// get pointers on TXT0 chdev
2263	xptr_t txt0_xp = chdev_dir.txt_tx[0];
2264	cxy_t txt0_cxy = GET_CXY( txt0_xp );
2265	chdev_t * txt0_ptr = GET_PTR( txt0_xp );
2266
2267	// get extended pointer on remote TXT0 chdev lock
2268	xptr_t lock_xp = XPTR( txt0_cxy , &txt0_ptr->wait_lock );
2269
2270	// get TXT0 lock in busy waiting mode
2271	remote_busylock_acquire( lock_xp );
2272
2273	// print header
2274	nolock_printk("\n***** current VFS state\n\n");
2275
2276	// call recursive function
2277	vfs_recursive_display( inode_xp , name_xp , 0 );
2278
2279	// release lock
2280	remote_busylock_release( lock_xp );
2281
2282	} // end vfs_display()
2283
2284	/*
2285	//////////////////////////////////////////////////////////////////////////////////////////
2286	// This static function is used by the vfs_lookup() function.
2287	// It takes an extended pointer on a remote inode (parent directory inode),
2288	// and check access_rights violation for the calling thread.
2289	// It can be used by any thread running in any cluster.
2290	//////////////////////////////////////////////////////////////////////////////////////////
2291	// @ inode_xp : extended pointer on inode.
2292	// @ client_uid : client thread user ID
2293	// @ client_gid : client thread group ID
2294	// @ return true if access rights are violated.
2295	//////////////////////////////////////////////////////////////////////////////////////////
2296	static bool_t vfs_access_denied( xptr_t inode_xp,
2297	uint32_t client_uid,
2298	uint32_t client_gid )
2299	{
2300	// get found inode cluster and local pointer
2301	cxy_t inode_cxy = GET_CXY( inode_xp );
2302	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
2303
2304	// get inode access mode, UID, and GID
2305	// TODO uint32_t mode = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->mode ) );
2306	uid_t uid = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->uid ) );
2307	gid_t gid = hal_remote_l32( XPTR( inode_cxy , &inode_ptr->gid ) );
2308
2309	// TODO : me must use mode
2310	if( (uid == client_uid) \|\| (gid == client_gid) ) return false;
2311	else return true;
2312	}
2313	*/
2314
2315	//////////////////////////////////////////////////////////////////////////////////////////
2316	// This static function is used by the vfs_lookup() function.
2317	// It takes an extended pointer on a remote parent directory inode, a directory
2318	// entry name, and and scan the XHTAB associated to the parent inode to find the
2319	// searched dentry. It does NOT modify the inode tree in case of miss.
2320	// It can be used by any thread running in any cluster.
2321	//////////////////////////////////////////////////////////////////////////////////////////
2322	// @ parent_xp : extended pointer on parent inode in remote cluster.
2323	// @ name : dentry name
2324	// @ child_xp : [out] buffer for extended pointer on child inode.
2325	// @ return true if success / return false if not found.
2326	//////////////////////////////////////////////////////////////////////////////////////////
2327	static bool_t vfs_get_child( xptr_t parent_xp,
2328	char * name,
2329	xptr_t * child_xp )
2330	{
2331	xptr_t xhtab_xp; // extended pointer on hash table for children dentries
2332	xptr_t dentry_xp; // extended pointer on children dentry
2333	cxy_t dentry_cxy;
2334	vfs_dentry_t * dentry_ptr;
2335
2336	// get parent inode cluster and local pointer
2337	cxy_t parent_cxy = GET_CXY( parent_xp );
2338	vfs_inode_t * parent_ptr = GET_PTR( parent_xp );
2339
2340	// get extended pointer on hash table of children directory entries
2341	xhtab_xp = XPTR( parent_cxy , &parent_ptr->children );
2342
2343	// get pointers on matching dentry
2344	dentry_xp = xhtab_lookup( xhtab_xp , name );
2345	dentry_cxy = GET_CXY( dentry_xp );
2346	dentry_ptr = GET_PTR( dentry_xp );
2347
2348	if( dentry_xp == XPTR_NULL )
2349	{
2350	return false;
2351	}
2352	else
2353	{
2354	*child_xp = (xptr_t)hal_remote_l64( XPTR( dentry_cxy , &dentry_ptr->child_xp ) );
2355	return true;
2356	}
2357
2358	} // end vfs_get_child()
2359
2360	//////////////////////////////////////////////////////////////////////////////////////////
2361	// This static function is used by the vfs_lookup() function.
2362	// It takes the <current> pointer on a buffer containing a complete pathname, and return
2363	// in the <name> buffer, allocated by the caller, a single name in the path.
2364	// It return also in the <next> pointer the next character to analyse in the path.
2365	// Finally it returns a <last> boolean, that is true when the returned <name> is the
2366	// last name in the path. The names are supposed to be separated by one or several '/'
2367	// characters, that are not written in the <name> buffer.
2368	//
2369	// WARNING: the leading characters '/' in the path are skiped before analysis.
2370	// The path "/" identifies the VFS root, and is therefore anaysed as an empty
2371	// string. This empty string is dignaled by the (-1) return value.
2372	//////////////////////////////////////////////////////////////////////////////////////////
2373	// @ current : pointer on first character to analyse in buffer containing the path.
2374	// @ name : [out] pointer on buffer allocated by the caller for the returned name.
2375	// @ next : [out] pointer on next character to analyse in buffer containing the path.
2376	// @ last : [out] true if the returned name is the last (NUL character found).
2377	// @ return 0 if success / return -1 if string empty (first chracter is NUL).
2378	//////////////////////////////////////////////////////////////////////////////////////////
2379	static error_t vfs_get_name_from_path( char * current,
2380	char * name,
2381	char ** next,
2382	bool_t * last )
2383	{
2384	char * ptr = current;
2385
2386	// skip leading '/' characters
2387	while( *ptr == '/' ) ptr++;
2388
2389	// signal empty string
2390	if( *ptr == 0 )
2391	{
2392	*last = true;
2393	return -1;
2394	}
2395
2396	// copy all characters in name until NUL or '/'
2397	while( (ptr != 0) && (ptr !='/') ) (name++) = (ptr++);
2398
2399	// set NUL terminating character in name buffer
2400	*(name++) = 0;
2401
2402	// return last an next
2403	if( *ptr == 0 ) // last found character is NUL => last name in path
2404	{
2405	*last = true;
2406	}
2407	else // last found character is '/' => skip it
2408	{
2409	*last = false;
2410	*next = ptr + 1;
2411	}
2412
2413	return 0;
2414
2415	} // end vfs_get name_from_path()
2416
2417	///////////////////////////////////////////////
2418	error_t vfs_lookup( xptr_t root_xp,
2419	char * pathname,
2420	uint32_t lookup_mode,
2421	xptr_t * inode_xp,
2422	char * last_name )
2423	{
2424	char name[CONFIG_VFS_MAX_NAME_LENGTH]; // one name in path
2425
2426	xptr_t parent_xp; // extended pointer on parent inode
2427	cxy_t parent_cxy; // cluster for parent inode
2428	vfs_inode_t * parent_ptr; // local pointer on parent inode
2429	xptr_t dentry_xp; // extended pointer on dentry
2430	vfs_dentry_t * dentry_ptr; // local pointer on dentry
2431	xptr_t child_xp; // extended pointer on child inode
2432	cxy_t child_cxy; // cluster for child inode
2433	vfs_inode_t * child_ptr; // local pointer on child inode
2434	vfs_fs_type_t fs_type; // File system type
2435	vfs_ctx_t * ctx_ptr; // local pointer on FS context
2436	char * current; // current pointer on path
2437	char * next; // next value for current pointer
2438	bool_t last; // true when the name is the last in path
2439	bool_t found; // true when a child has been found
2440	bool_t create; // searched inode must be created if not found
2441	bool_t excl; // searched inode must not exist
2442	bool_t parent; // searched inode is the parent
2443	thread_t * this; // pointer on calling thread descriptor
2444	process_t * process; // pointer on calling process descriptor
2445	error_t error;
2446
2447	this = CURRENT_THREAD;
2448	process = this->process;
2449
2450	// check pathname / root_xp consistency
2451	assert( ((pathname[0] != '/') \|\| (root_xp == process->vfs_root_xp)),
2452	"root inode must be VFS root for path <%s>", pathname );
2453
2454	#if DEBUG_VFS_LOOKUP
2455	uint32_t cycle = (uint32_t)hal_get_cycles();
2456	char root_name[CONFIG_VFS_MAX_NAME_LENGTH];
2457	vfs_inode_get_name( root_xp , root_name );
2458	if( DEBUG_VFS_LOOKUP < cycle )
2459	printk("\n[%s] thread[%x,%x] enter / root <%s> / path <%s> / mode %x / cycle %d\n",
2460	__FUNCTION__, process->pid, this->trdid, root_name, pathname, lookup_mode, cycle );
2461	#endif
2462
2463	#if ( DEBUG_VFS_LOOKUP & 1 )
2464	if( DEBUG_VFS_LOOKUP < cycle )
2465	vfs_display( root_xp );
2466	#endif
2467
2468	// compute lookup flags
2469	create = (lookup_mode & VFS_LOOKUP_CREATE) == VFS_LOOKUP_CREATE;
2470	excl = (lookup_mode & VFS_LOOKUP_EXCL) == VFS_LOOKUP_EXCL;
2471	parent = (lookup_mode & VFS_LOOKUP_PARENT) == VFS_LOOKUP_PARENT;
2472
2473	// initialise loop variables
2474	parent_xp = root_xp;
2475	current = pathname;
2476	next = NULL;
2477	last = false;
2478	child_xp = XPTR_NULL;
2479	child_cxy = 0;
2480	child_ptr = NULL;
2481
2482	// loop on nodes in pathname
2483	// load from device if one node in path not found in Inode Tree
2484	// exit loop when last name found (i.e. last == true)
2485	while( 1 )
2486	{
2487	// get parent inode cluster and local pointer
2488	parent_cxy = GET_CXY( parent_xp );
2489	parent_ptr = GET_PTR( parent_xp );
2490
2491	// get one "name" from path, and "last" flag
2492	error = vfs_get_name_from_path( current , name , &next , &last );
2493
2494	// handle VFS root case
2495	if ( error )
2496	{
2497
2498	#if DEBUG_VFS_LOOKUP
2499	cycle = (uint32_t)hal_get_cycles();
2500	if( DEBUG_VFS_LOOKUP < cycle )
2501	printk("\n[%s] thread[%x,%x] exit / parent inode(%x,%x) / <%s> / cycle %d\n",
2502	__FUNCTION__ , process->pid, this->trdid, parent_cxy, parent_ptr, pathname, cycle );
2503	#endif
2504	*inode_xp = process->vfs_root_xp;
2505	break;
2506	}
2507
2508	#if (DEBUG_VFS_LOOKUP & 1)
2509	if( DEBUG_VFS_LOOKUP < cycle )
2510	printk("\n[%s] thread[%x,%x] search <%s> in <%s> / last = %d\n",
2511	__FUNCTION__, process->pid, this->trdid, name, pathname, last );
2512	#endif
2513
2514	// search the child dentry matching name in parent inode XHTAB
2515	found = vfs_get_child( parent_xp,
2516	name,
2517	&child_xp );
2518
2519	if( found == false ) // child not found in Inode Tree
2520	{
2521	// when a inode is not found in the Inode Tree:
2522	// - if (last and parent) the Inode Tree is not modified
2523	// - else we speculatively introduce a new (dentry/inode) in inode tree,
2524	// and scan the parent directory mapper to initialise it.
2525	// . if it is not found in the parent mapper:
2526	// - if(last and create), a brand new file or directory is created
2527	// - else, an error is reported
2528	// . if it is found in parent mapper:
2529	// - if( last and excl ), an error is reported
2530	// - else the new child (inode & dentry) is initialised in Inode Tree
2531	// - if the child is a directory, the child mapper is loaded from device
2532
2533	if( last && parent ) // does nothing
2534	{
2535
2536	#if (DEBUG_VFS_LOOKUP & 1)
2537	if( DEBUG_VFS_LOOKUP < cycle )
2538	printk("\n[%s] thread[%x,%x] child not found but only parent requested in <%s>\n",
2539	__FUNCTION__, process->pid, this->trdid, pathname );
2540	#endif
2541	}
2542	else // try to get it from parent mapper
2543	{
2544
2545	#if (DEBUG_VFS_LOOKUP & 1)
2546	if( DEBUG_VFS_LOOKUP < cycle )
2547	printk("\n[%s] thread[%x,%x] miss <%s> inode in Inode Tree => build from parent mapper\n",
2548	__FUNCTION__, process->pid, this->trdid, name );
2549	#endif
2550	// get parent inode FS type
2551	ctx_ptr = hal_remote_lpt( XPTR( parent_cxy , &parent_ptr->ctx ) );
2552	fs_type = hal_remote_l32( XPTR( parent_cxy , &ctx_ptr->type ) );
2553
2554	// select a cluster for new inode
2555	child_cxy = cluster_random_select();
2556
2557	// insert a new child dentry/inode couple in inode tree
2558	error = vfs_add_child_in_parent( child_cxy,
2559	fs_type,
2560	parent_xp,
2561	name,
2562	&dentry_xp,
2563	&child_xp );
2564	if( error )
2565	{
2566	printk("\n[ERROR] in %s : cannot create inode <%s> in path <%s>\n",
2567	__FUNCTION__ , name, pathname );
2568	return -1;
2569	}
2570
2571	// get child inode and dentry local pointers
2572	child_ptr = GET_PTR( child_xp );
2573	dentry_ptr = GET_PTR( dentry_xp );
2574
2575	#if (DEBUG_VFS_LOOKUP & 1)
2576	if( DEBUG_VFS_LOOKUP < cycle )
2577	printk("\n[%s] thread[%x,%x] created missing inode <%s> in cluster %x\n",
2578	__FUNCTION__, process->pid, this->trdid, name, child_cxy );
2579	#endif
2580	// scan parent mapper to find the missing dentry, and complete
2581	// the initialisation of dentry and child inode descriptors
2582	error = vfs_fs_new_dentry_from_mapper( parent_xp,
2583	dentry_ptr );
2584
2585	if ( error ) // an error can be fatal or non-fatal :
2586	{
2587	if ( last && create ) // add a brand new dentry in parent directory
2588	{
2589	error = vfs_fs_new_dentry_to_mapper( parent_xp,
2590	dentry_ptr );
2591	if ( error )
2592	{
2593	printk("\n[ERROR] in %s : cannot add dentry <%s> in parent dir\n",
2594	__FUNCTION__, name );
2595	vfs_remove_child_from_parent( dentry_xp );
2596	return -1;
2597	}
2598
2599	#if (DEBUG_VFS_LOOKUP & 1)
2600	if( DEBUG_VFS_LOOKUP < cycle )
2601	printk("\n[%s] thread[%x,%x] child <%s> not found in parent mapper => created it\n",
2602	__FUNCTION__, process->pid, this->trdid, name );
2603	vfs_inode_display( child_xp );
2604	#endif
2605	}
2606	else // not last or not create => error
2607	{
2608	printk("\n[ERROR] in %s : <%s> node not found in parent for <%s>\n",
2609	__FUNCTION__ , name , pathname );
2610	vfs_remove_child_from_parent( dentry_xp );
2611	return -1;
2612	}
2613	}
2614	else // child has been found in parent mapper
2615	{
2616	// check the excl
2617	if( last && create && excl )
2618	{
2619	printk("\n[ERROR] in %s : node already exist <%s>\n",
2620	__FUNCTION__, name );
2621	return -1;
2622	}
2623
2624	#if (DEBUG_VFS_LOOKUP & 1)
2625	if( DEBUG_VFS_LOOKUP < cycle )
2626	printk("\n[%s] thread[%x,%x] initialised inode <%s> from parent mapper\n",
2627	__FUNCTION__, process->pid, this->trdid, name );
2628	#endif
2629	// load child mapper from device if child is a directory (prefetch)
2630	uint32_t type = hal_remote_l32( XPTR( child_cxy , &child_ptr->type ) );
2631	if( type == INODE_TYPE_DIR )
2632	{
2633	error = vfs_inode_load_all_pages( child_xp );
2634
2635	if ( error )
2636	{
2637	printk("\n[ERROR] in %s : cannot load <%s> from device\n",
2638	__FUNCTION__ , name );
2639	vfs_remove_child_from_parent( dentry_xp );
2640	return -1;
2641	}
2642
2643	#if (DEBUG_VFS_LOOKUP & 1)
2644	if( DEBUG_VFS_LOOKUP < cycle )
2645	printk("\n[%s] thread[%x,%x] loaded directory mapper for <%s> from IOC\n",
2646	__FUNCTION__ , process->pid, this->trdid, name );
2647	#endif
2648	}
2649	}
2650	}
2651	}
2652	else // child found in Inode Tree
2653	{
2654	// get child inode local pointer and cluster
2655	child_ptr = GET_PTR( child_xp );
2656	child_cxy = GET_CXY( child_xp );
2657
2658	#if (DEBUG_VFS_LOOKUP & 1)
2659	if( DEBUG_VFS_LOOKUP < cycle )
2660	printk("\n[%s] thread[%x,%x] found <%s> in Inode Tree / inode (%x,%x)\n",
2661	__FUNCTION__, process->pid, this->trdid, name, child_cxy, child_ptr );
2662	#endif
2663	// check the excl flag
2664	if( last && create && excl )
2665	{
2666	printk("\n[ERROR] in %s : node <%s> already exist\n",
2667	__FUNCTION__, name );
2668	return -1;
2669	}
2670	}
2671
2672	// TODO check access rights here [AG]
2673	// error = vfs_access_denied( child_xp,
2674	// client_uid,
2675	// client_gid );
2676	// if( error )
2677	// {
2678	// printk("\n[ERROR] in %s : thread %x / permission denied for %s\n",
2679	// __FUNCTION__ , this , name );
2680	// return EACCES;
2681	// }
2682
2683	// exit when last
2684	if ( last ) // last inode in path => return relevant info
2685	{
2686	if ( parent ) // return parent inode and child name
2687	{
2688
2689	#if DEBUG_VFS_LOOKUP
2690	cycle = (uint32_t)hal_get_cycles();
2691	if( DEBUG_VFS_LOOKUP < cycle )
2692	printk("\n[%s] thread[%x,%x] exit / parent inode(%x,%x) / <%s> / cycle %d\n",
2693	__FUNCTION__ , process->pid, this->trdid, parent_cxy, parent_ptr, pathname, cycle );
2694	#endif
2695	*inode_xp = parent_xp;
2696	strcpy( last_name , name );
2697	break;
2698	}
2699	else // return child inode name
2700	{
2701
2702	#if DEBUG_VFS_LOOKUP
2703	cycle = (uint32_t)hal_get_cycles();
2704	if( DEBUG_VFS_LOOKUP < cycle )
2705	printk("\n[%s] thread[%x,%x] exit / child inode (%x,%x) / <%s> / cycle %d\n",
2706	__FUNCTION__ , process->pid, this->trdid, child_cxy, child_ptr, pathname, cycle );
2707	#endif
2708	*inode_xp = child_xp;
2709	break;
2710	}
2711	}
2712	else // not the last node in path => update loop variables
2713	{
2714	parent_xp = child_xp;
2715	current = next;
2716	}
2717	} // end while loop on nodes in pathname
2718
2719	#if ( DEBUG_VFS_LOOKUP & 1 )
2720	if( DEBUG_VFS_LOOKUP < cycle )
2721	vfs_display( root_xp );
2722	#endif
2723
2724	return 0;
2725
2726	} // end vfs_lookup()
2727
2728	///////////////////////////////////////////////////
2729	error_t vfs_add_special_dentries( xptr_t child_xp,
2730	xptr_t parent_xp )
2731	{
2732	error_t error;
2733	vfs_inode_t * child_ptr; // local pointer on child inode directory
2734	cxy_t child_cxy; // child inode directory cluster identifier
2735	vfs_ctx_t * ctx_ptr; // local pointer on child inode FS context
2736	vfs_fs_type_t fs_type; // FS type of child inode
2737	xptr_t dentry_xp; // extended pointer on dentry (used for . and ..)
2738	vfs_dentry_t * dentry_ptr; // local pointer on dentry (used for . and ..)
2739	xptr_t children_xhtab_xp; // extended pointer on inode "children" field
2740	xptr_t children_entry_xp; // extended pointer on dentry "children" field
2741
2742	#if DEBUG_VFS_ADD_SPECIAL
2743	uint32_t cycle = (uint32_t)hal_get_cycles();
2744	thread_t * this = CURRENT_THREAD;
2745	char child_name[CONFIG_VFS_MAX_NAME_LENGTH];
2746	char parent_name[CONFIG_VFS_MAX_NAME_LENGTH];
2747	vfs_inode_get_name( child_xp , child_name );
2748	vfs_inode_get_name( parent_xp , parent_name );
2749	if( DEBUG_VFS_ADD_SPECIAL < cycle )
2750	printk("\n[%s] thread[%x,%x] enter for child <%s> in parent <%s> / cycle %d\n",
2751	__FUNCTION__, this->process->pid, this->trdid, child_name, parent_name, cycle );
2752	#endif
2753
2754	// get child directory cluster and local pointer
2755	child_cxy = GET_CXY( child_xp );
2756	child_ptr = GET_PTR( child_xp );
2757
2758	// get child inode FS type
2759	ctx_ptr = hal_remote_lpt( XPTR( child_cxy , &child_ptr->ctx ) );
2760	fs_type = hal_remote_l32( XPTR( child_cxy , &ctx_ptr->type ) );
2761
2762	//////////////////////////// create <.> dentry //////////////////////
2763	error = vfs_dentry_create( child_cxy,
2764	fs_type,
2765	".",
2766	&dentry_xp );
2767	if( error )
2768	{
2769	printk("\n[ERROR] in %s : cannot create dentry <.> in cluster %x\n",
2770	__FUNCTION__ , child_cxy );
2771	return -1;
2772	}
2773
2774	// get <.> dentry local pointer
2775	dentry_ptr = GET_PTR( dentry_xp );
2776
2777	#if(DEBUG_VFS_ADD_SPECIAL & 1)
2778	cycle = (uint32_t)hal_get_cycles();
2779	if( DEBUG_VFS_ADD_SPECIAL < cycle )
2780	printk("\n[%s] thread[%x,%x] created dentry <.> (%x,%x) / cycle %d\n",
2781	__FUNCTION__, this->process->pid, this->trdid, child_cxy, dentry_ptr, cycle );
2782	#endif
2783
2784	// register <.> dentry in child inode xhtab of children
2785	children_xhtab_xp = XPTR( child_cxy , &child_ptr->children );
2786	children_entry_xp = XPTR( child_cxy , &dentry_ptr->children );
2787
2788	error = xhtab_insert( children_xhtab_xp , "." , children_entry_xp );
2789
2790	if( error )
2791	{
2792	printk("\n[ERROR] in %s : cannot register dentry <.> in xhtab\n",
2793	__FUNCTION__ );
2794	return -1;
2795	}
2796
2797	// update "parent" and "child_xp" fields in <.> dentry
2798	hal_remote_s64( XPTR( child_cxy , &dentry_ptr->child_xp ) , child_xp );
2799	hal_remote_spt( XPTR( child_cxy , &dentry_ptr->parent ) , child_ptr );
2800
2801	#if(DEBUG_VFS_ADD_SPECIAL & 1)
2802	cycle = (uint32_t)hal_get_cycles();
2803	if( DEBUG_VFS_ADD_SPECIAL < cycle )
2804	printk("\n[%s] thread[%x,%x] linked dentry <.> to parent and child inodes / cycle %d\n",
2805	__FUNCTION__, this->process->pid, this->trdid, cycle );
2806	#endif
2807
2808	// introduce <.> dentry into child directory mapper
2809	// only if the target directory is not the root VFS
2810	if( child_xp != parent_xp )
2811	{
2812	error = vfs_fs_add_dentry( child_xp,
2813	dentry_ptr );
2814	if( error )
2815	{
2816	printk("\n[ERROR] in %s : cannot introduce dentry <..> in mapper %x\n",
2817	__FUNCTION__ );
2818	return -1;
2819	}
2820
2821	#if(DEBUG_VFS_ADD_SPECIAL & 1)
2822	cycle = (uint32_t)hal_get_cycles();
2823	if( DEBUG_VFS_ADD_SPECIAL < cycle )
2824	printk("\n[%s] thread[%x,%x] registered dentry <.> in child mapper / cycle %d\n",
2825	__FUNCTION__, this->process->pid, this->trdid, cycle );
2826	#endif
2827
2828	}
2829
2830	///////////////////////////// create <..> dentry ///////////////////////
2831	error = vfs_dentry_create( child_cxy,
2832	fs_type,
2833	"..",
2834	&dentry_xp );
2835	if( error )
2836	{
2837	printk("\n[ERROR] in %s : cannot create dentry <..> in cluster %x\n",
2838	__FUNCTION__ , child_cxy );
2839	return -1;
2840	}
2841
2842	// get <..> dentry local pointer
2843	dentry_ptr = GET_PTR( dentry_xp );
2844
2845	#if(DEBUG_VFS_ADD_SPECIAL & 1)
2846	cycle = (uint32_t)hal_get_cycles();
2847	if( DEBUG_VFS_ADD_SPECIAL < cycle )
2848	printk("\n[%s] thread[%x,%x] created dentry <..> (%x,%x) / cycle %d\n",
2849	__FUNCTION__, this->process->pid, this->trdid, child_cxy, dentry_ptr, cycle );
2850	#endif
2851
2852	// register <..> dentry in child_inode xhtab of children
2853	children_xhtab_xp = XPTR( child_cxy , &child_ptr->children );
2854	children_entry_xp = XPTR( child_cxy , &dentry_ptr->children );
2855	error = xhtab_insert( children_xhtab_xp , ".." , children_entry_xp );
2856	if( error )
2857	{
2858	printk("\n[ERROR] in %s : cannot register dentry <..> in xhtab\n",
2859	__FUNCTION__ );
2860	return -1;
2861	}
2862
2863	// don't register <..> dentry in parent_inode xlist of parents
2864
2865	// update "parent" and "child_xp" fields in <..> dentry
2866	hal_remote_s64( XPTR( child_cxy , &dentry_ptr->child_xp ) , parent_xp );
2867	hal_remote_spt( XPTR( child_cxy , &dentry_ptr->parent ) , child_ptr );
2868
2869	#if(DEBUG_VFS_ADD_SPECIAL & 1)
2870	cycle = (uint32_t)hal_get_cycles();
2871	if( DEBUG_VFS_ADD_SPECIAL < cycle )
2872	printk("\n[%s] thread[%x,%x] linked dentry <..> to parent and child inodes / cycle %d\n",
2873	__FUNCTION__, this->process->pid, this->trdid, cycle );
2874	#endif
2875
2876	// introduce <..> dentry into child directory mapper
2877	// only if the target directory is not the root VFS
2878	if( child_xp != parent_xp )
2879	{
2880	error = vfs_fs_add_dentry( child_xp,
2881	dentry_ptr );
2882	if( error )
2883	{
2884	printk("\n[ERROR] in %s : cannot introduce dentry <..> in mapper %x\n",
2885	__FUNCTION__ );
2886	return -1;
2887	}
2888
2889	#if(DEBUG_VFS_ADD_SPECIAL & 1)
2890	cycle = (uint32_t)hal_get_cycles();
2891	if( DEBUG_VFS_ADD_SPECIAL < cycle )
2892	printk("\n[%s] thread[%x,%x] registered dentry <..> in child mapper / cycle %d\n",
2893	__FUNCTION__, this->process->pid, this->trdid, cycle );
2894	#endif
2895
2896	}
2897
2898	#if DEBUG_VFS_ADD_SPECIAL
2899	cycle = (uint32_t)hal_get_cycles();
2900	if( DEBUG_VFS_ADD_SPECIAL < cycle )
2901	printk("\n[%s] thread[%x,%x] exit for child <%s> in parent <%s> / cycle %d\n",
2902	__FUNCTION__, this->process->pid, this->trdid, child_name, parent_name, cycle );
2903	#endif
2904
2905	return 0;
2906
2907	} // end vfs_add_special_dentries()
2908
2909	//////////////////////////////////////////
2910	error_t vfs_get_path( xptr_t inode_xp,
2911	char * buffer,
2912	char ** first,
2913	uint32_t max_size )
2914	{
2915	xptr_t dentry_xp; // extended pointer on current dentry
2916	vfs_dentry_t * dentry_ptr; // local pointer on current dentry
2917	cxy_t dentry_cxy; // current dentry cluster identifier
2918	xptr_t name_xp; // extended pointer on current dentry name
2919	uint32_t length; // length of current dentry name
2920	int32_t index; // slot index in buffer
2921	xptr_t current_xp; // extended pointer on current inode
2922	vfs_inode_t * current_ptr; // local pointer on current inode
2923	cxy_t current_cxy; // current inode cluster identifier
2924	xptr_t vfs_root_xp; // extended pointer on VFS root inode
2925	vfs_inode_t * vfs_root_ptr; // local pointer on VFS root inode
2926	cxy_t vfs_root_cxy; // VFS root inode cluster identifier
2927	xptr_t lock_xp; // extended pointer on Inode Tree lock
2928	xptr_t parents_root_xp; // extended pointer on current inode parents root
2929	bool_t found; // condition to exit the while loop
2930
2931	thread_t * this = CURRENT_THREAD;
2932	process_t * process = this->process;
2933
2934	#if DEBUG_VFS_GET_PATH
2935	uint32_t cycle = (uint32_t)hal_get_cycles();
2936	if( DEBUG_VFS_GET_PATH < cycle )
2937	printk("\n[%s] thread[%x,%x] enter : inode (%x,%x) / cycle %d\n",
2938	__FUNCTION__ , process->pid, this->trdid,
2939	GET_CXY( inode_xp ), GET_PTR( inode_xp ), cycle );
2940	#endif
2941
2942	// set the NUL character in buffer / initialise buffer index
2943	buffer[max_size - 1] = 0;
2944	index = (int32_t)(max_size - 1);
2945
2946	// initialize current inode
2947	current_xp = inode_xp;
2948
2949	// build extended pointer on lock protecting Inode Tree
2950	vfs_root_xp = process->vfs_root_xp;
2951	vfs_root_ptr = GET_PTR( vfs_root_xp );
2952	vfs_root_cxy = GET_CXY( vfs_root_xp );
2953	lock_xp = XPTR( vfs_root_cxy , &vfs_root_ptr->main_lock );
2954
2955	// take lock protecting Inode Tree in read mode
2956	remote_rwlock_rd_acquire( lock_xp );
2957
2958	// traverse Inode Tree from target inode to VFS root
2959	// selecting always the first parent dentry
2960	// the buffer is written in "reverse order" (from target inode to root)
2961	// exit the while loop when the VFS root has been found
2962	do
2963	{
2964	// get current inode cluster and local pointer
2965	current_cxy = GET_CXY( current_xp );
2966	current_ptr = GET_PTR( current_xp );
2967
2968	// build extended pointer on parents dentries root
2969	parents_root_xp = XPTR( current_cxy , &current_ptr->parents );
2970
2971	// compute exit condition <=> current inode is VFS root
2972	found = xlist_is_empty( parents_root_xp );
2973
2974	if( found ) // parent is the VFS root
2975	{
2976	if( index == (int32_t)(max_size - 1) )
2977	{
2978	// update index
2979	index--;
2980
2981	// set separator
2982	buffer[index] = '/';
2983
2984	// check buffer overflow
2985	assert( (index >= 0) , "kernel buffer too small" );
2986
2987	}
2988	}
2989	else // not the VFS root
2990	{
2991	// get first parent dentry cluster and pointers
2992	dentry_xp = XLIST_FIRST( parents_root_xp , vfs_dentry_t , parents );
2993	dentry_cxy = GET_CXY( dentry_xp );
2994	dentry_ptr = GET_PTR( dentry_xp );
2995
2996	// get extended pointer on dentry name and name length
2997	name_xp = XPTR( dentry_cxy , dentry_ptr->name );
2998	length = hal_remote_l32( XPTR( dentry_cxy , &dentry_ptr->length ) );
2999
3000	#if (DEBUG_VFS_GET_PATH & 1)
3001	char debug_name[CONFIG_VFS_MAX_NAME_LENGTH];
3002	hal_remote_strcpy( XPTR( local_cxy , debug_name ) , name_xp );
3003	if( DEBUG_VFS_GET_PATH < cycle )
3004	printk("\n[%s] thread(%x,%s) get current dentry <%s> in cluster %x\n",
3005	__FUNCTION__ , process->pid, this->trdid, debug_name, current_cxy );
3006	#endif
3007	// update index
3008	index -= (length + 1);
3009
3010	// check buffer overflow
3011	assert( (index >= 0) , "kernel buffer too small" );
3012
3013	// update pathname
3014	hal_remote_memcpy( XPTR( local_cxy , &buffer[index + 1] ) ,
3015	name_xp , length );
3016
3017	// set separator
3018	buffer[index] = '/';
3019
3020	// get extended pointer on parent inode
3021	current_xp = XPTR( dentry_cxy ,
3022	hal_remote_lpt( XPTR( dentry_cxy , &dentry_ptr->parent ) ) );
3023	}
3024	}
3025	while( found == false );
3026
3027	// release lock protecting Inode Tree in read mode
3028	remote_rwlock_rd_release( lock_xp );
3029
3030	#if DEBUG_VFS_GET_PATH
3031	cycle = (uint32_t)hal_get_cycles();
3032	if( DEBUG_VFS_GET_PATH < cycle )
3033	printk("\n[%s] thread[%x,%x] exit : path <%s> / cycle %d\n",
3034	__FUNCTION__ , process->pid, this->trdid, &buffer[index], cycle );
3035	#endif
3036
3037	// return pointer on first character in buffer
3038	*first = &buffer[index];
3039	return 0;
3040
3041	} // end vfs_get_path()
3042
3043
3044	//////////////////////////////////////////////////////////////
3045	error_t vfs_add_child_in_parent( cxy_t child_cxy,
3046	vfs_fs_type_t fs_type,
3047	xptr_t parent_inode_xp,
3048	char * name,
3049	xptr_t * child_dentry_xp,
3050	xptr_t * child_inode_xp )
3051	{
3052	error_t error;
3053	cxy_t parent_cxy; // parent inode cluster identifier
3054	vfs_inode_t * parent_inode_ptr; // parent inode local pointer
3055	xptr_t new_dentry_xp; // extended pointer on created dentry
3056	vfs_dentry_t * new_dentry_ptr; // created dentry local pointer
3057	xptr_t new_inode_xp; // extended pointer on created child inode
3058	vfs_inode_t * new_inode_ptr; // local pointer on created child inode
3059
3060	xptr_t parents_root_xp; // extended pointer on child inode "parents" field
3061	xptr_t parents_entry_xp; // extended pointer on child dentry "parents" field
3062	xptr_t children_xhtab_xp; // extended pointer on parent inode "children" field
3063	xptr_t children_entry_xp; // extended pointer on child dentry "children" field
3064
3065	// get parent inode cluster and pointer
3066	parent_cxy = GET_CXY( parent_inode_xp );
3067	parent_inode_ptr = GET_PTR( parent_inode_xp );
3068
3069	#if DEBUG_VFS_ADD_CHILD
3070	char parent_name[CONFIG_VFS_MAX_NAME_LENGTH];
3071	vfs_inode_get_name( parent_inode_xp , parent_name );
3072	uint32_t cycle = (uint32_t)hal_get_cycles();
3073	thread_t * this = CURRENT_THREAD;
3074	if( DEBUG_VFS_ADD_CHILD < cycle )
3075	printk("\n[%s] thread[%x,%x] enter / child <%s> / parent <%s> / cycle %d\n",
3076	__FUNCTION__, this->process->pid, this->trdid, name,
3077	parent_name, (uint32_t)hal_get_cycles() );
3078	#endif
3079
3080	// 1. create dentry in parent cluster
3081	error = vfs_dentry_create( parent_cxy,
3082	fs_type,
3083	name,
3084	&new_dentry_xp );
3085	if( error )
3086	{
3087	printk("\n[ERROR] in %s : cannot create dentry <%s> in cluster %x\n",
3088	__FUNCTION__ , name , parent_cxy );
3089	return -1;
3090	}
3091
3092	// get dentry local pointer
3093	new_dentry_ptr = GET_PTR( new_dentry_xp );
3094
3095	#if(DEBUG_VFS_ADD_CHILD & 1)
3096	if( DEBUG_VFS_ADD_CHILD < cycle )
3097	printk("\n[%s] thread[%x,%x] created dentry <%s> : (%x,%x)\n",
3098	__FUNCTION__, this->process->pid, this->trdid, name, parent_cxy, new_dentry_ptr );
3099	#endif
3100
3101	// 2. create child inode in child cluster
3102	// TODO : define attr / mode / uid / gid
3103	uint32_t attr = 0;
3104	uint32_t mode = 0;
3105	uint32_t uid = 0;
3106	uint32_t gid = 0;
3107
3108	error = vfs_inode_create( child_cxy,
3109	fs_type,
3110	attr,
3111	mode,
3112	uid,
3113	gid,
3114	&new_inode_xp );
3115	if( error )
3116	{
3117	printk("\n[ERROR] in %s : cannot create inode in cluster %x\n",
3118	__FUNCTION__ , child_cxy );
3119
3120	vfs_dentry_destroy( new_dentry_xp );
3121	return -1;
3122	}
3123
3124	// get new inode local pointer
3125	new_inode_ptr = GET_PTR( new_inode_xp );
3126
3127	#if(DEBUG_VFS_ADD_CHILD & 1)
3128	if( DEBUG_VFS_ADD_CHILD < cycle )
3129	printk("\n[%s] thread[%x,%x] created inode <%s> : (%x,%x)\n",
3130	__FUNCTION__ , this->process->pid, this->trdid, name , child_cxy, new_inode_ptr );
3131	#endif
3132
3133	// 3. register new_dentry in new_inode xlist of parents
3134	parents_root_xp = XPTR( child_cxy , &new_inode_ptr->parents );
3135	parents_entry_xp = XPTR( parent_cxy, &new_dentry_ptr->parents );
3136	xlist_add_first( parents_root_xp , parents_entry_xp );
3137	hal_remote_atomic_add( XPTR( child_cxy , &new_inode_ptr->links ) , 1 );
3138
3139	#if(DEBUG_VFS_ADD_CHILD & 1)
3140	if( DEBUG_VFS_ADD_CHILD < cycle )
3141	printk("\n[%s] thread[%x,%x] linked dentry(%x,%x) to child inode(%x,%x)\n",
3142	__FUNCTION__, this->process->pid, this->trdid,
3143	parent_cxy, new_dentry_ptr, child_cxy, new_inode_ptr );
3144	#endif
3145
3146	// 4. register new_dentry in parent_inode xhtab of children
3147	children_xhtab_xp = XPTR( parent_cxy , &parent_inode_ptr->children );
3148	children_entry_xp = XPTR( parent_cxy , &new_dentry_ptr->children );
3149	xhtab_insert( children_xhtab_xp , name , children_entry_xp );
3150
3151	#if(DEBUG_VFS_ADD_CHILD & 1)
3152	if( DEBUG_VFS_ADD_CHILD < cycle )
3153	printk("\n[%s] thread[%x,%x] linked dentry(%x,%x) to parent inode(%x,%x)\n",
3154	__FUNCTION__, this->process->pid, this->trdid,
3155	parent_cxy, new_dentry_ptr, parent_cxy, parent_inode_ptr );
3156	#endif
3157
3158	// 5. update "parent" and "child_xp" fields in new_dentry
3159	hal_remote_s64( XPTR( parent_cxy , &new_dentry_ptr->child_xp ) , new_inode_xp );
3160	hal_remote_spt( XPTR( parent_cxy , &new_dentry_ptr->parent ) , parent_inode_ptr );
3161
3162	#if DEBUG_VFS_ADD_CHILD
3163	cycle = (uint32_t)hal_get_cycles();
3164	if( DEBUG_VFS_ADD_CHILD < cycle )
3165	printk("\n[%s] thread[%x,%x] exit for <%s> / cycle %d\n",
3166	__FUNCTION__, this->process->pid, this->trdid, name, cycle );
3167	#endif
3168
3169	// return extended pointer on dentry & child inode
3170	*child_dentry_xp = new_dentry_xp;
3171	*child_inode_xp = new_inode_xp;
3172	return 0;
3173
3174	} // end vfs_add_child_in_parent()
3175
3176	/////////////////////////////////////////////////////
3177	void vfs_remove_child_from_parent( xptr_t dentry_xp )
3178	{
3179	cxy_t parent_cxy; // parent inode cluster identifier
3180	cxy_t child_cxy; // child inode cluster identifier
3181	vfs_dentry_t * dentry_ptr; // local pointer on dentry
3182	xptr_t child_inode_xp; // extended pointer on child inode
3183	vfs_inode_t * child_inode_ptr; // local pointer on child inode
3184	vfs_inode_t * parent_inode_ptr; // local pointer on parent inode
3185	uint32_t links; // number of child inode parents
3186
3187	char dentry_name[CONFIG_VFS_MAX_NAME_LENGTH];
3188
3189	// get parent cluster and dentry local pointer
3190	parent_cxy = GET_CXY( dentry_xp );
3191	dentry_ptr = GET_PTR( dentry_xp );
3192
3193	// get a local copy of dentry name
3194	hal_remote_strcpy( XPTR( local_cxy , dentry_name ),
3195	XPTR( parent_cxy , &dentry_ptr->name ) );
3196
3197	// get parent_inode local pointer
3198	parent_inode_ptr = hal_remote_lpt( XPTR( parent_cxy , &dentry_ptr->parent ) );
3199
3200	// get child cluster and child_inode pointers
3201	child_inode_xp = hal_remote_l64( XPTR( parent_cxy , &dentry_ptr->child_xp ) );
3202	child_cxy = GET_CXY( child_inode_xp );
3203	child_inode_ptr = GET_PTR( child_inode_xp );
3204
3205	// remove dentry from parent_inode
3206	xhtab_remove( XPTR( parent_cxy , &parent_inode_ptr->children ),
3207	dentry_name,
3208	XPTR( parent_cxy , &dentry_ptr->children ) );
3209
3210	// remove dentry from child_inode
3211	xlist_unlink( XPTR( parent_cxy , &dentry_ptr->parents ) );
3212	links = hal_remote_atomic_add( XPTR( child_cxy , &child_inode_ptr->links ) , -1 );
3213
3214	// delete dentry descriptor
3215	vfs_dentry_destroy( dentry_xp );
3216
3217	// delete child_inode descriptor if last link
3218	if( links == 1 ) vfs_inode_destroy( child_inode_xp );
3219
3220	} // end vfs_remove_child_from_parent()
3221
3222
3223
3224
3225	//////////////////////////////////////////////////////////////////////////////////////////
3226	// API used by VFS to access a specific FS
3227	//////////////////////////////////////////////////////////////////////////////////////////
3228
3229	///////////////////////////////////////////////////
3230	error_t vfs_fs_add_dentry( xptr_t inode_xp,
3231	vfs_dentry_t * dentry_ptr )
3232	{
3233	error_t error = 0;
3234
3235	assert( (inode_xp != XPTR_NULL) , "inode_xp argument is NULL" );
3236	assert( (dentry_ptr != NULL ) , "dentry_ptr argument is NULL" );
3237
3238	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
3239	cxy_t inode_cxy = GET_CXY( inode_xp );
3240
3241	// get inode mapper
3242	mapper_t * mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
3243
3244	assert( (mapper != NULL) , "mapper pointer is NULL")
3245
3246	// get FS type
3247	vfs_fs_type_t fs_type = hal_remote_l32( XPTR( inode_cxy , &mapper->fs_type ) );
3248
3249	// call relevant FS function
3250	if( fs_type == FS_TYPE_FATFS )
3251	{
3252	error = fatfs_add_dentry( inode_xp , dentry_ptr );
3253	}
3254	else if( fs_type == FS_TYPE_RAMFS )
3255	{
3256	error = 0; // does nothing for RAMFS
3257	}
3258	else if( fs_type == FS_TYPE_DEVFS )
3259	{
3260	error = 0; // does nothing for DEVFS
3261	}
3262	else
3263	{
3264	assert( false , "undefined file system type" );
3265	}
3266
3267	return error;
3268
3269	} // end vfs_fs_add_dentry()
3270
3271	//////////////////////////////////////////////////////
3272	error_t vfs_fs_remove_dentry( xptr_t inode_xp,
3273	vfs_dentry_t * dentry_ptr )
3274	{
3275	error_t error = 0;
3276
3277	assert( (inode_xp != XPTR_NULL) , "inode_xp argument is NULL" );
3278	assert( (dentry_ptr != NULL ) , "dentry_ptr argument is NULL" );
3279
3280	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
3281	cxy_t inode_cxy = GET_CXY( inode_xp );
3282
3283	// get inode mapper
3284	mapper_t * mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
3285
3286	assert( (mapper != NULL) , "mapper pointer is NULL")
3287
3288	// get FS type
3289	vfs_fs_type_t fs_type = hal_remote_l32( XPTR( inode_cxy , &mapper->fs_type ) );
3290
3291	// call relevant FS function
3292	if( fs_type == FS_TYPE_FATFS )
3293	{
3294	error = fatfs_remove_dentry( inode_xp , dentry_ptr );
3295
3296	}
3297	else if( fs_type == FS_TYPE_RAMFS )
3298	{
3299	error = 0; // does nothing for RAMFS
3300	}
3301	else if( fs_type == FS_TYPE_DEVFS )
3302	{
3303	error = 0; // does nothing for DEVFS
3304	}
3305	else
3306	{
3307	assert( false , "undefined file system type" );
3308	}
3309
3310	return error;
3311
3312	} // end vfs_fs_remove_dentry()
3313
3314	///////////////////////////////////////////////////////////////
3315	error_t vfs_fs_new_dentry_from_mapper( xptr_t inode_xp,
3316	vfs_dentry_t * dentry_ptr )
3317	{
3318	error_t error = 0;
3319
3320	assert( (inode_xp != XPTR_NULL) , "inode_xp argument is NULL" );
3321	assert( (dentry_ptr != NULL ) , "dentry_ptr argument is NULL" );
3322
3323	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
3324	cxy_t inode_cxy = GET_CXY( inode_xp );
3325
3326	// get inode mapper
3327	mapper_t * mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
3328
3329	assert( (mapper != NULL) , "mapper pointer is NULL")
3330
3331	// get FS type
3332	vfs_fs_type_t fs_type = hal_remote_l32( XPTR( inode_cxy , &mapper->fs_type ) );
3333
3334	// call relevant FS function
3335	if( fs_type == FS_TYPE_FATFS )
3336	{
3337	error = fatfs_new_dentry_from_mapper( inode_xp , dentry_ptr );
3338	}
3339	else if( fs_type == FS_TYPE_RAMFS )
3340	{
3341	assert( false , "should not be called for RAMFS" );
3342	}
3343	else if( fs_type == FS_TYPE_DEVFS )
3344	{
3345	assert( false , "should not be called for DEVFS" );
3346	}
3347	else
3348	{
3349	assert( false , "undefined file system type" );
3350	}
3351
3352	return error;
3353
3354	} // end vfs_fs_new_dentry_from_mapper()
3355
3356	///////////////////////////////////////////////////////////////
3357	error_t vfs_fs_new_dentry_to_mapper( xptr_t inode_xp,
3358	vfs_dentry_t * dentry_ptr )
3359	{
3360	error_t error = 0;
3361
3362	assert( (inode_xp != XPTR_NULL) , "inode_xp argument is NULL" );
3363	assert( (dentry_ptr != NULL ) , "dentry_ptr argument is NULL" );
3364
3365	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
3366	cxy_t inode_cxy = GET_CXY( inode_xp );
3367
3368	// get inode mapper
3369	mapper_t * mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
3370
3371	assert( (mapper != NULL) , "mapper pointer is NULL")
3372
3373	// get FS type
3374	vfs_fs_type_t fs_type = hal_remote_l32( XPTR( inode_cxy , &mapper->fs_type ) );
3375
3376	// call relevant FS function
3377	if( fs_type == FS_TYPE_FATFS )
3378	{
3379	error = fatfs_new_dentry_to_mapper( inode_xp , dentry_ptr );
3380	}
3381	else if( fs_type == FS_TYPE_RAMFS )
3382	{
3383	assert( false , "should not be called for RAMFS" );
3384	}
3385	else if( fs_type == FS_TYPE_DEVFS )
3386	{
3387	assert( false , "should not be called for DEVFS" );
3388	}
3389	else
3390	{
3391	assert( false , "undefined file system type" );
3392	}
3393
3394	return error;
3395
3396	} // end vfs_fs_new_dentry_to_mapper()
3397
3398	//////////////////////////////////////////////////////
3399	error_t vfs_fs_update_dentry( xptr_t inode_xp,
3400	vfs_dentry_t * dentry_ptr )
3401	{
3402	error_t error = 0;
3403
3404	assert( (inode_xp != XPTR_NULL) , "inode_xp argument is NULL" );
3405	assert( (dentry_ptr != NULL ) , "dentry_ptr argument is NULL" );
3406
3407	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
3408	cxy_t inode_cxy = GET_CXY( inode_xp );
3409
3410	// get inode mapper
3411	mapper_t * mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
3412
3413	assert( (mapper != NULL) , "mapper pointer is NULL")
3414
3415	// get FS type
3416	vfs_fs_type_t fs_type = hal_remote_l32( XPTR( inode_cxy , &mapper->fs_type ) );
3417
3418	// call relevant FS function
3419	if( fs_type == FS_TYPE_FATFS )
3420	{
3421	error = fatfs_update_dentry( inode_xp , dentry_ptr );
3422	}
3423	else if( fs_type == FS_TYPE_RAMFS )
3424	{
3425	assert( false , "should not be called for RAMFS" );
3426	}
3427	else if( fs_type == FS_TYPE_DEVFS )
3428	{
3429	assert( false , "should not be called for DEVFS" );
3430	}
3431	else
3432	{
3433	assert( false , "undefined file system type" );
3434	}
3435
3436	return error;
3437
3438	} // end vfs_fs_update_dentry()
3439
3440	///////////////////////////////////////////////////
3441	error_t vfs_fs_get_user_dir( vfs_inode_t * inode,
3442	struct dirent * array,
3443	uint32_t max_dirent,
3444	uint32_t min_dentry,
3445	bool_t detailed,
3446	uint32_t * entries,
3447	bool_t * done )
3448	{
3449	error_t error = 0;
3450
3451	// check arguments
3452	assert( (inode != NULL) , "parent pointer is NULL");
3453	assert( (array != NULL) , "child pointer is NULL");
3454	assert( (detailed == false) , "detailed argument not supported\n");
3455
3456	// check inode type
3457	if( inode->type != INODE_TYPE_DIR )
3458	{
3459	printk("\n[ERROR] in %s : target inode is not a directory\n",
3460	__FUNCTION__ );
3461	return -1;
3462	}
3463
3464	// get parent inode FS type
3465	vfs_fs_type_t fs_type = inode->ctx->type;
3466
3467	// call relevant FS function
3468	if( fs_type == FS_TYPE_FATFS )
3469	{
3470	error = fatfs_get_user_dir( inode,
3471	array,
3472	max_dirent,
3473	min_dentry,
3474	detailed,
3475	entries,
3476	done );
3477	}
3478	else if( fs_type == FS_TYPE_RAMFS )
3479	{
3480	assert( false , "should not be called for RAMFS" );
3481	}
3482	else if( fs_type == FS_TYPE_DEVFS )
3483	{
3484	error = devfs_get_user_dir( inode,
3485	array,
3486	max_dirent,
3487	min_dentry,
3488	detailed,
3489	entries,
3490	done );
3491	}
3492	else
3493	{
3494	assert( false , "undefined file system type" );
3495	}
3496
3497	return error;
3498
3499	} // end vfs_fs_get_user_dir()
3500
3501	/////////////////////////////////////////////
3502	error_t vfs_fs_sync_inode( xptr_t inode_xp )
3503	{
3504	error_t error = 0;
3505
3506	assert( (inode_xp != XPTR_NULL) , "inode_xp argument is NULL");
3507
3508	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
3509	cxy_t inode_cxy = GET_CXY( inode_xp );
3510
3511	// get inode mapper
3512	mapper_t * mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
3513
3514	assert( (mapper != NULL) , "mapper pointer is NULL")
3515
3516	// get FS type
3517	vfs_fs_type_t fs_type = hal_remote_l32( XPTR( inode_cxy , &mapper->fs_type ) );
3518
3519	// call relevant FS function
3520	if( fs_type == FS_TYPE_FATFS )
3521	{
3522	error = fatfs_sync_inode( inode_xp );
3523	}
3524	else if( fs_type == FS_TYPE_RAMFS )
3525	{
3526	assert( false , "should not be called for RAMFS" );
3527	}
3528	else if( fs_type == FS_TYPE_DEVFS )
3529	{
3530	assert( false , "should not be called for DEVFS" );
3531	}
3532	else
3533	{
3534	assert( false , "undefined file system type" );
3535	}
3536
3537	return error;
3538
3539	} // end vfs_fs_sync_inode()
3540
3541	////////////////////////////////////////////////
3542	error_t vfs_fs_sync_fat( vfs_fs_type_t fs_type )
3543	{
3544	error_t error = 0;
3545
3546	// call relevant FS function
3547	if( fs_type == FS_TYPE_FATFS )
3548	{
3549	error = fatfs_sync_fat();
3550	}
3551	else if( fs_type == FS_TYPE_RAMFS )
3552	{
3553	assert( false , "should not be called for RAMFS" );
3554	}
3555	else if( fs_type == FS_TYPE_DEVFS )
3556	{
3557	assert( false , "should not be called for DEVFS" );
3558	}
3559	else
3560	{
3561	assert( false , "undefined file system type" );
3562	}
3563
3564	return error;
3565
3566	} // end vfs_fs_sync_fat()
3567
3568	////////////////////////////////////////////////
3569	error_t vfs_fs_release_inode( xptr_t inode_xp )
3570	{
3571	error_t error = 0;
3572
3573	assert( (inode_xp != XPTR_NULL) , "inode_xp argument is NULL")
3574
3575	vfs_inode_t * inode_ptr = GET_PTR( inode_xp );
3576	cxy_t inode_cxy = GET_CXY( inode_xp );
3577
3578	// get local pointer on mapper
3579	mapper_t * mapper = hal_remote_lpt( XPTR( inode_cxy , &inode_ptr->mapper ) );
3580
3581	assert( (mapper != NULL) , "mapper pointer is NULL")
3582
3583	// get FS type from mapper
3584	vfs_fs_type_t fs_type = hal_remote_l32( XPTR( inode_cxy , &mapper->fs_type ) );
3585
3586	// call relevant FS function
3587	if( fs_type == FS_TYPE_FATFS )
3588	{
3589	error = fatfs_release_inode( inode_xp );
3590	}
3591	else if( fs_type == FS_TYPE_RAMFS )
3592	{
3593	assert( false , "should not be called for RAMFS" );
3594	}
3595	else if( fs_type == FS_TYPE_DEVFS )
3596	{
3597	assert( false , "should not be called for DEVFS" );
3598	}
3599	else
3600	{
3601	assert( false , "undefined file system type" );
3602	}
3603
3604	return error;
3605
3606	} // end vfs_fs_release_inode()
3607
3608	//////////////////////////////////////////////////
3609	error_t vfs_fs_move_page( xptr_t page_xp,
3610	ioc_cmd_type_t cmd_type )
3611	{
3612	error_t error = 0;
3613
3614	assert( (page_xp != XPTR_NULL) , "page pointer is NULL" );
3615
3616	page_t * page_ptr = GET_PTR( page_xp );
3617	cxy_t page_cxy = GET_CXY( page_xp );
3618
3619	// get local pointer on mapper
3620	mapper_t * mapper = hal_remote_lpt( XPTR( page_cxy , &page_ptr->mapper ) );
3621
3622	assert( (mapper != NULL) , "no mapper for page" );
3623
3624	// get FS type
3625	vfs_fs_type_t fs_type = hal_remote_l32( XPTR( page_cxy , &mapper->fs_type ) );
3626
3627	// call relevant FS function
3628	if( fs_type == FS_TYPE_FATFS )
3629	{
3630	error = fatfs_move_page( page_xp , cmd_type );
3631	}
3632	else if( fs_type == FS_TYPE_RAMFS )
3633	{
3634	assert( false , "should not be called for RAMFS\n" );
3635	}
3636	else if( fs_type == FS_TYPE_DEVFS )
3637	{
3638	assert( false , "should not be called for DEVFS\n" );
3639	}
3640	else
3641	{
3642	assert( false , "undefined file system type" );
3643	}
3644
3645	return error;
3646
3647	} // end vfs_fs_move_page()
3648
3649

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

Download in other formats: