Context Navigation

source: soft/giet_vm/giet_kernel/sys_handler.c @ 715

Last change on this file since 715 was 714, checked in by alain, 9 years ago
Introduce the _sys_fbf_size() function. Modify the _sys_fbf_alloc() / _sys_fbf_release() functions to allow all threads of a given vspace to access the frame buffer. (replace the lock by a multi-threads allocator.
Property svn:executable set to ``*
File size: 118.8 KB

Rev	Line
[258]	1	///////////////////////////////////////////////////////////////////////////////////
	2	// File : sys_handler.c
	3	// Date : 01/04/2012
	4	// Author : alain greiner and joel porquet
	5	// Copyright (c) UPMC-LIP6
	6	///////////////////////////////////////////////////////////////////////////////////
	7
	8	#include <sys_handler.h>
	9	#include <tty_driver.h>
	10	#include <tim_driver.h>
	11	#include <nic_driver.h>
[440]	12	#include <mmc_driver.h>
[519]	13	#include <mwr_driver.h>
[440]	14	#include <cma_driver.h>
[258]	15	#include <ctx_handler.h>
	16	#include <fat32.h>
[707]	17	#include <elf-types.h>
[258]	18	#include <utils.h>
[478]	19	#include <kernel_malloc.h>
[459]	20	#include <tty0.h>
[396]	21	#include <vmem.h>
[322]	22	#include <hard_config.h>
[258]	23	#include <giet_config.h>
	24	#include <mapping_info.h>
[547]	25	#include <irq_handler.h>
[519]	26	#include <io.h>
[258]	27
[709]	28	#if !defined(X_SIZE)
	29	# error: You must define X_SIZE in the hard_config.h file
	30	#endif
	31
	32	#if !defined(Y_SIZE)
	33	# error: You must define Y_SIZE in the hard_config.h file
	34	#endif
	35
	36	#if !defined(NB_PROCS_MAX)
	37	# error: You must define NB_PROCS_MAX in the hard_config.h file
	38	#endif
	39
[322]	40	#if !defined(SEG_BOOT_MAPPING_BASE)
	41	# error: You must define SEG_BOOT_MAPPING_BASE in the hard_config.h file
	42	#endif
	43
[449]	44	#if !defined(NB_TTY_CHANNELS)
	45	# error: You must define NB_TTY_CHANNELS in the hard_config.h file
	46	#endif
	47
[459]	48	#if (NB_TTY_CHANNELS < 1)
	49	# error: NB_TTY_CHANNELS cannot be smaller than 1!
	50	#endif
	51
[449]	52	#if !defined(NB_TIM_CHANNELS)
	53	# error: You must define NB_TIM_CHANNELS in the hard_config.h file
	54	#endif
	55
	56	#if !defined(NB_NIC_CHANNELS)
	57	# error: You must define NB_NIC_CHANNELS in the hard_config.h file
	58	#endif
	59
	60	#if !defined(NB_CMA_CHANNELS)
	61	# error: You must define NB_CMA_CHANNELS in the hard_config.h file
	62	#endif
	63
[478]	64	#if !defined(GIET_NO_HARD_CC)
	65	# error: You must define GIET_NO_HARD_CC in the giet_config.h file
[449]	66	#endif
	67
[478]	68	#if !defined ( GIET_NIC_MAC4 )
	69	# error: You must define GIET_NIC_MAC4 in the giet_config.h file
[449]	70	#endif
	71
[478]	72	#if !defined ( GIET_NIC_MAC2 )
	73	# error: You must define GIET_NIC_MAC2 in the giet_config.h file
[449]	74	#endif
	75
[258]	76	////////////////////////////////////////////////////////////////////////////
[528]	77	// Extern variables
[519]	78	////////////////////////////////////////////////////////////////////////////
	79
[528]	80	// allocated in tty0.c file.
	81	extern sqt_lock_t _tty0_sqt_lock;
[519]	82
[528]	83	// allocated in mwr_driver.c file.
	84	extern simple_lock_t _coproc_lock[X_SIZE*Y_SIZE];
[556]	85	extern unsigned int _coproc_type[X_SIZE*Y_SIZE];
	86	extern unsigned int _coproc_info[X_SIZE*Y_SIZE];
	87	extern unsigned int _coproc_mode[X_SIZE*Y_SIZE];
	88	extern unsigned int _coproc_error[X_SIZE*Y_SIZE];
[709]	89	extern unsigned int _coproc_trdid[X_SIZE*Y_SIZE];
[519]	90
[528]	91	// allocated in tty_driver.c file.
[709]	92	extern tty_fifo_t _tty_rx_fifo[NB_TTY_CHANNELS];
[528]	93
[629]	94	// allocated in kernel_init.c file
	95	extern static_scheduler_t* _schedulers[X_SIZE][Y_SIZE][NB_PROCS_MAX];
	96
[714]	97	// allocated in bdv_driver.c file
	98	spin_lock_t _bdv_lock;
	99
[709]	100	////////////////////////////////////////////////////////////////////////////////
[714]	101	// Allocator protecting exclusive access to FBF by a single application.
	102	// - The number of users in a given application should be set by a single
	103	// thread using an _atomic_test_and_set().
	104	// - The allocator is atomically decremented by each user thread when
	105	// the thread exit.
	106	////////////////////////////////////////////////////////////////////////////////
	107
	108	__attribute__((section(".kdata")))
	109	unsigned int _fbf_alloc = 0;
	110
	111	////////////////////////////////////////////////////////////////////////////////
[709]	112	// Channel allocators for multi-channels peripherals
	113	// - The array _***_channel_allocator[channel] defines the number of user
	114	// threads for a dynamically allocated channel of peripheral ***.
	115	// - The array _***_channel_wti[channel] defines the WTI index and the
	116	// processor coordinates for the processor receiving the channel WTI.
	117	////////////////////////////////////////////////////////////////////////////////
[440]	118
[709]	119	#if NB_TTY_CHANNELS
[494]	120	__attribute__((section(".kdata")))
[709]	121	unsigned int _tty_channel_alloc[NB_TTY_CHANNELS] = {0};
[494]	122
	123	__attribute__((section(".kdata")))
[709]	124	unsigned int _tty_channel_wti[NB_TTY_CHANNELS];
	125	#endif
[494]	126
[709]	127	#if NB_TIM_CHANNELS
[494]	128	__attribute__((section(".kdata")))
[709]	129	unsigned int _tim_channel_alloc[NB_TIM_CHANNELS] = {0};
[494]	130
	131	__attribute__((section(".kdata")))
[709]	132	unsigned int _tim_channel_wti[NB_TIM_CHANNELS];
	133	#endif
[494]	134
[709]	135	#if NB_CMA_CHANNELS
[494]	136	__attribute__((section(".kdata")))
[709]	137	unsigned int _cma_channel_alloc[NB_CMA_CHANNELS] = {0};
[440]	138
[709]	139	__attribute__((section(".kdata")))
	140	unsigned int _cma_channel_wti[NB_CMA_CHANNELS];
	141	#endif
	142
	143	#if NB_NIC_CHANNELS
	144	__attribute__((section(".kdata")))
	145	unsigned int _nic_rx_channel_alloc[NB_NIC_CHANNELS] = {0};
	146
	147	__attribute__((section(".kdata")))
	148	unsigned int _nic_rx_channel_wti[NB_NIC_CHANNELS];
	149
	150	__attribute__((section(".kdata")))
	151	unsigned int _nic_tx_channel_alloc[NB_NIC_CHANNELS] = {0};
	152
	153	__attribute__((section(".kdata")))
	154	unsigned int _nic_tx_channel_wti[NB_NIC_CHANNELS];
	155	#endif
	156
[440]	157	////////////////////////////////////////////////////////////////////////////
[614]	158	// NIC_RX and NIC_TX kernel chbuf arrays
[449]	159	////////////////////////////////////////////////////////////////////////////
	160
[494]	161	__attribute__((section(".kdata")))
[614]	162	ker_chbuf_t _nic_ker_rx_chbuf[NB_NIC_CHANNELS] __attribute__((aligned(64)));
[459]	163
[494]	164	__attribute__((section(".kdata")))
[614]	165	ker_chbuf_t _nic_ker_tx_chbuf[NB_NIC_CHANNELS] __attribute__((aligned(64)));
[459]	166
[478]	167	////////////////////////////////////////////////////////////////////////////
	168	// FBF related chbuf descriptors array, indexed by the CMA channel index.
	169	// Physical addresses of these chbuf descriptors required for L2 cache sync.
[614]	170	// FBF status
[478]	171	////////////////////////////////////////////////////////////////////////////
[459]	172
[494]	173	__attribute__((section(".kdata")))
[478]	174	fbf_chbuf_t _fbf_chbuf[NB_CMA_CHANNELS] __attribute__((aligned(64)));
[459]	175
[494]	176	__attribute__((section(".kdata")))
[478]	177	unsigned long long _fbf_chbuf_paddr[NB_CMA_CHANNELS];
	178
[614]	179	__attribute__((section(".kdata")))
	180	buffer_status_t _fbf_status[NB_CMA_CHANNELS] __attribute__((aligned(64)));
	181
[449]	182	////////////////////////////////////////////////////////////////////////////
[258]	183	// Initialize the syscall vector with syscall handlers
	184	// Note: This array must be synchronised with the define in file stdio.h
	185	////////////////////////////////////////////////////////////////////////////
[494]	186
	187	__attribute__((section(".kdata")))
[258]	188	const void * _syscall_vector[64] =
	189	{
[556]	190	&_sys_proc_xyp, /* 0x00 */
	191	&_get_proctime, /* 0x01 */
[709]	192	&_sys_procs_number, /* 0x02 */
	193	&_sys_xy_from_ptr, /* 0x03 */
	194	&_sys_ukn, /* 0x04 */
[714]	195	&_sys_vseg_get_vbase, /* 0x05 */
	196	&_sys_vseg_get_length, /* 0x06 */
[556]	197	&_sys_heap_info, /* 0x07 */
[714]	198	&_sys_fbf_size, /* 0x08 */
	199	&_sys_fbf_alloc, /* 0x09 */
[556]	200	&_sys_fbf_cma_alloc, /* 0x0A */
[614]	201	&_sys_fbf_cma_init_buf, /* 0x0B */
	202	&_sys_fbf_cma_start, /* 0x0C */
	203	&_sys_fbf_cma_display, /* 0x0D */
	204	&_sys_fbf_cma_stop, /* 0x0E */
[709]	205	&_sys_ukn, /* 0x0F */
[258]	206
[709]	207	&_sys_applications_status, /* 0x10 */
[614]	208	&_sys_fbf_sync_write, /* 0x11 */
	209	&_sys_fbf_sync_read, /* 0x12 */
[709]	210	&_sys_ukn, /* 0x13 */
[556]	211	&_sys_tim_alloc, /* 0x14 */
	212	&_sys_tim_start, /* 0x15 */
	213	&_sys_tim_stop, /* 0x16 */
[629]	214	&_sys_kill_application, /* 0x17 */
	215	&_sys_exec_application, /* 0x18 */
[709]	216	&_sys_ukn, /* 0x19 */
	217	&_sys_pthread_control, /* 0x1A */
	218	&_sys_pthread_yield, /* 0x1B */
	219	&_sys_pthread_kill, /* 0x1C */
	220	&_sys_pthread_create, /* 0x1D */
	221	&_sys_pthread_join, /* 0x1E */
	222	&_sys_pthread_exit, /* 0x1F */
[258]	223
[592]	224	&_fat_open, /* 0x20 */
[709]	225	&_fat_read, /* 0x21 */
[592]	226	&_fat_write, /* 0x22 */
	227	&_fat_lseek, /* 0x23 */
	228	&_fat_file_info, /* 0x24 */
[556]	229	&_fat_close, /* 0x25 */
[592]	230	&_fat_remove, /* 0x26 */
	231	&_fat_rename, /* 0x27 */
	232	&_fat_mkdir, /* 0x28 */
[661]	233	&_fat_opendir, /* 0x29 */
	234	&_fat_closedir, /* 0x2A */
	235	&_fat_readdir, /* 0x2B */
	236	&_sys_ukn, /* 0x2C */
[556]	237	&_sys_ukn, /* 0x2D */
	238	&_sys_ukn, /* 0x2E */
	239	&_sys_ukn, /* 0x2F */
[258]	240
[556]	241	&_sys_nic_alloc, /* 0x30 */
	242	&_sys_nic_start, /* 0x31 */
	243	&_sys_nic_move, /* 0x32 */
	244	&_sys_nic_stop, /* 0x33 */
	245	&_sys_nic_stats, /* 0x34 */
	246	&_sys_nic_clear, /* 0x35 */
[709]	247	&_sys_tty_write, /* 0x36 */
	248	&_sys_tty_read, /* 0x37 */
	249	&_sys_tty_alloc, /* 0x38 */
[556]	250	&_sys_ukn, /* 0x39 */
	251	&_sys_ukn, /* 0x3A */
	252	&_sys_coproc_completed, /* 0x3B */
	253	&_sys_coproc_alloc, /* 0x3C */
	254	&_sys_coproc_channel_init, /* 0x3D */
	255	&_sys_coproc_run, /* 0x3E */
	256	&_sys_coproc_release, /* 0x3F */
[258]	257	};
	258
[709]	259
	260	//////////////////////////////////////////////////////////////////////////////
	261	// Applications related syscall handlers
	262	//////////////////////////////////////////////////////////////////////////////
	263
[707]	264	////////////////////////////////////////////////////////////////////////
[709]	265	// This function is called by the _sys_exec_application function
	266	// to reload all data segments contained in an application.elf file.
[714]	267	// File checking is minimal, because these segments have already
	268	// been loaded by the boot code.
[709]	269	////////////////////////////////////////////////////////////////////////
[707]	270	static unsigned int _load_writable_segments( mapping_vspace_t* vspace )
	271	{
[709]	272
	273	#if GIET_DEBUG_EXEC
[707]	274	unsigned int gpid = _get_procid();
	275	unsigned int cluster_xy = gpid >> P_WIDTH;
	276	unsigned int p = gpid & ((1<<P_WIDTH)-1);
	277	unsigned int x = cluster_xy >> Y_WIDTH;
	278	unsigned int y = cluster_xy & ((1<<Y_WIDTH)-1);
[709]	279	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	280	_printf("\n[DEBUG EXEC] _load_writable_segments() at cycle %d\n"
	281	"P[%d,%d,%d] enters for %s\n",
	282	_get_proctime() , x , y , p , vspace->name );
[707]	283	#endif
[459]	284
[707]	285	mapping_header_t* header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
	286	mapping_vseg_t* vseg = _get_vseg_base(header);
	287
[709]	288	unsigned int vseg_id; // vseg index in mapping
	289	char buf[4096]; // buffer to store one cluster
[714]	290	unsigned int fd = 0; // file descriptor
	291	unsigned int found = 0;
[707]	292
[709]	293	// first scan on vsegs in vspace to find the .elf pathname
[707]	294	for (vseg_id = vspace->vseg_offset;
	295	vseg_id < (vspace->vseg_offset + vspace->vsegs);
	296	vseg_id++)
	297	{
[709]	298	if( vseg[vseg_id].type == VSEG_TYPE_ELF )
[707]	299	{
[709]	300	// open the .elf file associated to vspace
[707]	301	fd = _fat_open( vseg[vseg_id].binpath , O_RDONLY );
[709]	302	if ( fd < 0 ) return 1;
[707]	303
[709]	304	#if GIET_DEBUG_EXEC
	305	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	306	_printf("\n[DEBUG EXEC] _load_writable_segments() at cycle %d\n"
	307	"P[%d,%d,%d] open %s / fd = %d\n",
	308	_get_proctime() , x , y , p , vseg[vseg_id].binpath , fd );
[707]	309	#endif
[714]	310	found = 1;
	311	break;
	312
[707]	313	}
	314	}
[709]	315
[714]	316	// check .elf file found
	317	if ( found == 0 )
	318	{
	319
	320	_printf("@@@ _load_writable_segments() : .elf not found\n");
	321
	322	return 1;
	323	}
	324
[707]	325	// load Elf-Header into buffer from .elf file
[709]	326	if ( _fat_lseek( fd, 0, SEEK_SET ) < 0 )
	327	{
[714]	328
	329	_printf("@@@ _load_writable_segments() : cannot seek\n");
	330
[709]	331	_fat_close( fd );
	332	return 1;
[714]	333
[709]	334	}
	335	if ( _fat_read( fd, (unsigned int)buf, 4096, 0 ) < 0 )
	336	{
[714]	337
	338	_printf("@@@ _load_writable_segments() : cannot read\n");
	339
[709]	340	_fat_close( fd );
	341	return 1;
	342	}
[707]	343
[709]	344	#if GIET_DEBUG_EXEC
	345	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	346	_printf("\n[DEBUG EXEC] _load_writable_segments() at cycle %d\n"
	347	"P[%d,%d,%d] loaded Elf-Header\n",
	348	_get_proctime() , x , y , p );
[707]	349	#endif
	350
	351	// get nsegments and Program-Header-Table offset from Elf-Header
	352	Elf32_Ehdr* elf_header_ptr = (Elf32_Ehdr*)buf;
	353	unsigned int offset = elf_header_ptr->e_phoff;
	354	unsigned int nsegments = elf_header_ptr->e_phnum;
	355
	356	// load Program-Header-Table from .elf file
[709]	357	if ( _fat_lseek( fd, offset, SEEK_SET ) < 0 )
	358	{
	359	_fat_close( fd );
	360	return 1;
	361	}
	362	if ( _fat_read( fd, (unsigned int)buf, 4096, 0 ) < 0 )
	363	{
	364	_fat_close( fd );
	365	return 1;
	366	}
[707]	367
[709]	368	#if GIET_DEBUG_EXEC
	369	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	370	_printf("\n[DEBUG EXEC] _load_writable_segments() at cycle %d\n"
	371	"P[%d,%d,%d] loaded Program-Header-Table\n",
	372	_get_proctime() , x , y , p );
[707]	373	#endif
	374
	375	// set Program-Header-Table pointer
	376	Elf32_Phdr* elf_pht_ptr = (Elf32_Phdr*)buf;
	377
[709]	378	// second scan on vsegs in vspace to load the seg_data segments :
	379	// - type == VSEG_TYPE_ELF
	380	// - non eXecutable
	381	for (vseg_id = vspace->vseg_offset;
	382	vseg_id < (vspace->vseg_offset + vspace->vsegs);
	383	vseg_id++)
[707]	384	{
[709]	385	if( (vseg[vseg_id].type == VSEG_TYPE_ELF) && // type ELF
	386	((vseg[vseg_id].mode & 0x4) == 0) ) // non executable
[707]	387	{
[709]	388	// get vbase and pbase
	389	paddr_t pbase = vseg[vseg_id].pbase;
	390	unsigned int vbase = vseg[vseg_id].vbase;
[707]	391
[709]	392	// scan segments in Progam-Header-Table to find match
	393	// No match checking as the segment was previously found
	394	unsigned int seg;
	395	for (seg = 0 ; seg < nsegments ; seg++)
	396	{
	397	if ( (elf_pht_ptr[seg].p_type == PT_LOAD) && // loadable
	398	(elf_pht_ptr[seg].p_flags & PF_W) && // writable
	399	(elf_pht_ptr[seg].p_vaddr == vbase) ) // matching
	400	{
	401	// Get segment offset and size in .elf file
	402	unsigned int seg_offset = elf_pht_ptr[seg].p_offset;
	403	unsigned int seg_size = elf_pht_ptr[seg].p_filesz;
[707]	404
[709]	405	// compute destination address and extension for _fat_read()
	406	unsigned int dest = (unsigned int)pbase;
	407	unsigned int extend = (unsigned int)(pbase>>32) \| 0xFFFF0000;
	408
	409	// load the segment
	410	if ( _fat_lseek( fd, seg_offset, SEEK_SET ) < 0 )
	411	{
	412	_fat_close( fd );
	413	return 1;
	414	}
	415	if ( _fat_read( fd, dest, seg_size, extend ) < 0 )
	416	{
	417	_fat_close( fd );
	418	return 1;
	419	}
	420	}
	421	}
	422
	423	#if GIET_DEBUG_EXEC
	424	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	425	_printf("\n[DEBUG EXEC] _load_writable_segments() at cycle %d\n"
	426	"P[%d,%d,%d] loaded segment %x\n",
	427	_get_proctime() , x , y , p , vbase );
[707]	428	#endif
	429	}
	430	} // end loop on writable & loadable segments
	431
	432	// close .elf file
	433	_fat_close( fd );
	434
	435	return 0;
	436	} // end load_writable_segments()
	437
[648]	438
[709]	439
[648]	440	///////////////////////////////////////
[709]	441	int _sys_exec_application( char* name )
[648]	442	{
	443	mapping_header_t * header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
	444	mapping_vspace_t * vspace = _get_vspace_base(header);
[709]	445	mapping_thread_t * thread = _get_thread_base(header);
	446	mapping_vseg_t * vseg = _get_vseg_base(header);
[648]	447
	448	unsigned int vspace_id;
[709]	449	unsigned int thread_id;
[648]	450
[709]	451	#if GIET_DEBUG_EXEC
	452	unsigned int gpid = _get_procid();
	453	unsigned int cluster_xy = gpid >> P_WIDTH;
	454	unsigned int p = gpid & ((1<<P_WIDTH)-1);
	455	unsigned int x = cluster_xy >> Y_WIDTH;
	456	unsigned int y = cluster_xy & ((1<<Y_WIDTH)-1);
[648]	457	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	458	_printf("\n[DEBUG EXEC] _sys_exec_application() at cycle %d\n"
	459	"P[%d,%d,%d] enters for vspace %s\n",
	460	_get_proctime() , x, y, p, name );
[648]	461	#endif
	462
[709]	463	unsigned int y_size = header->y_size;
	464
	465	// scan vspaces to find matching vspace name
	466	for (vspace_id = 0 ; vspace_id < header->vspaces ; vspace_id++)
[648]	467	{
[709]	468	if ( _strcmp( vspace[vspace_id].name, name ) == 0 ) // vspace found
[648]	469	{
	470
[709]	471	#if GIET_DEBUG_EXEC
	472	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	473	_printf("\n[DEBUG EXEC] _sys_exec_application() at cycle %d\n"
	474	"P[%d,%d,%d] found vspace %s\n",
	475	_get_proctime() , x, y, p, name );
[709]	476	#endif
	477	// reload writable segments
	478	if ( _load_writable_segments( &vspace[vspace_id] ) )
[648]	479	{
[709]	480	_printf("[GIET ERROR] _sys_exec_application() : "
	481	"can't load data segment for vspace %s\n", name );
[714]	482	return SYSCALL_CANNOT_LOAD_DATA_SEGMENT;
[709]	483	}
	484
	485	#if GIET_DEBUG_EXEC
	486	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	487	_printf("\n[DEBUG EXEC] _sys_exec_application() at cycle %d\n"
	488	"P[%d,%d,%d] loaded all writable segments for vspace %s\n",
	489	_get_proctime() , x, y, p, name );
[709]	490	#endif
	491	// scan threads in vspace with three goals :
	492	// - check all threads desactivated
	493	// - re-initialise all threads contexts
	494	// - find main thread
	495	unsigned int main_found = 0;
	496	unsigned int main_ltid = 0;
	497	static_scheduler_t* main_psched = NULL;
	498	unsigned int min = vspace[vspace_id].thread_offset;
	499	unsigned int max = min + vspace[vspace_id].threads;
	500	for ( thread_id = min ; thread_id < max ; thread_id++ )
	501	{
	502	// get thread identifiers : [x,y,p,ltid]
	503	unsigned int cid = thread[thread_id].clusterid;
[648]	504	unsigned int x = cid / y_size;
	505	unsigned int y = cid % y_size;
[709]	506	unsigned int p = thread[thread_id].proclocid;
	507	unsigned int ltid = thread[thread_id].ltid;
	508	unsigned int vsid = thread[thread_id].stack_vseg_id;
[648]	509
[709]	510	// get scheduler pointer
	511	static_scheduler_t* psched = _schedulers[x][y][p];
[648]	512
[709]	513	// check thread non active
	514	if ( psched->context[ltid].slot[CTX_NORUN_ID] == 0 ) // runnable !!!
	515	{
	516	_printf("\n[GIET ERROR] in _sys_exec_application() : "
	517	"thread %s already active in vspace %s\n",
	518	thread[thread_id].name, name );
[714]	519	return SYSCALL_THREAD_ALREADY_ACTIVE;
[709]	520	}
	521
	522	// initialise thread context
	523	unsigned int ctx_epc = psched->context[ltid].slot[CTX_ENTRY_ID];
	524	unsigned int ctx_sp = vseg[vsid].vbase + vseg[vsid].length;
	525	unsigned int ctx_ra = (unsigned int)&_ctx_eret;
	526	unsigned int ctx_sr = GIET_SR_INIT_VALUE;
[648]	527
[709]	528	psched->context[ltid].slot[CTX_EPC_ID] = ctx_epc;
	529	psched->context[ltid].slot[CTX_RA_ID] = ctx_ra;
	530	psched->context[ltid].slot[CTX_SR_ID] = ctx_sr;
	531	psched->context[ltid].slot[CTX_SP_ID] = ctx_sp;
	532
	533	// register information required to activate main thread
	534	// actual activation done when threads initialisation is completed
	535	if ( thread[thread_id].is_main )
	536	{
	537	main_psched = psched;
	538	main_ltid = ltid;
	539	main_found = 1;
	540	}
	541
[648]	542	#if GIET_DEBUG_EXEC
	543	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	544	_printf("\n[DEBUG EXEC] _sys_exec_application() at cycle %d\n"
	545	"P[%d,%d,%d] initialise thread %s in vspace %s\n",
	546	_get_proctime() , x, y, p, thread[thread_id].name , name );
[648]	547	#endif
[714]	548	} // end loop on threads
[648]	549
[709]	550	// activate main thread
	551	if ( main_found )
	552	{
	553	main_psched->context[main_ltid].slot[CTX_NORUN_ID] = 0;
	554	}
	555	else
	556	{
	557	_printf("\n[GIET ERROR] in _sys_exec_application() : "
	558	"main not found in vspace %s\n", name );
[714]	559	return SYSCALL_MAIN_NOT_FOUND;
[709]	560	}
	561
[714]	562	_printf("\n[GIET WARNING] application %s launched : %d threads\n",
	563	name , max-min );
	564
	565	return SYSCALL_OK;
[709]	566	}
	567	} // end of loop on vspaces
[648]	568
[709]	569	// vspace not found
	570	_printf("\n[GIET ERROR] in _sys_exec_application() : "
	571	"vspace %s not found\n", name );
[714]	572	return SYSCALL_VSPACE_NOT_FOUND;
[648]	573
[709]	574	} // end _sys_exec_application()
[648]	575
[709]	576
[648]	577	///////////////////////////////////////
[709]	578	int _sys_kill_application( char* name )
[648]	579	{
	580	mapping_header_t * header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
	581	mapping_vspace_t * vspace = _get_vspace_base(header);
[709]	582	mapping_thread_t * thread = _get_thread_base(header);
[648]	583
	584	unsigned int vspace_id;
[709]	585	unsigned int thread_id;
[648]	586
[707]	587	#if GIET_DEBUG_EXEC
[709]	588	unsigned int gpid = _get_procid();
	589	unsigned int cluster_xy = gpid >> P_WIDTH;
	590	unsigned int p = gpid & ((1<<P_WIDTH)-1);
	591	unsigned int x = cluster_xy >> Y_WIDTH;
	592	unsigned int y = cluster_xy & ((1<<Y_WIDTH)-1);
[648]	593	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	594	_printf("\n[DEBUG EXEC] _sys_kill_application() at cycle %d\n"
	595	"P[%d,%d,%d] enters for vspace %s\n",
	596	_get_proctime() , x , y , p , name );
[648]	597	#endif
	598
[709]	599	// shell cannot be killed
	600	if ( _strcmp( name , "shell" ) == 0 )
[648]	601	{
[709]	602	_printf("\n[GIET ERROR] in _sys_kill_application() : "
	603	"%s application cannot be killed\n", name );
[714]	604	return SYSCALL_APPLI_CANNOT_BE_KILLED;
[707]	605	}
[648]	606
[709]	607	// scan vspaces to find matching vspace name
	608	for (vspace_id = 0; vspace_id < header->vspaces; vspace_id++)
[707]	609	{
[709]	610	if ( _strcmp( vspace[vspace_id].name, name ) == 0 )
	611	{
	612	// scan threads to send KILL signal to all threads in vspace
	613	unsigned int y_size = header->y_size;
	614	unsigned int min = vspace[vspace_id].thread_offset;
	615	unsigned int max = min + vspace[vspace_id].threads;
	616	for ( thread_id = min ; thread_id < max ; thread_id++ )
	617	{
	618	unsigned int cid = thread[thread_id].clusterid;
	619	unsigned int x = cid / y_size;
	620	unsigned int y = cid % y_size;
	621	unsigned int p = thread[thread_id].proclocid;
	622	unsigned int ltid = thread[thread_id].ltid;
[648]	623
[709]	624	// get scheduler pointer for processor running the thread
	625	static_scheduler_t* psched = (static_scheduler_t*)_schedulers[x][y][p];
	626
	627	// set KILL signal bit
	628	_atomic_or( &psched->context[ltid].slot[CTX_SIGS_ID] , SIGS_MASK_KILL );
	629	}
	630
[714]	631	_printf("\n[GIET WARNING] application %s killed / %d threads\n",
	632	name , max-min );
[709]	633
[714]	634	return SYSCALL_OK;
[709]	635	}
	636	} // en loop on vspaces
	637
	638	_printf("\n[GIET ERROR] in _sys_kill_application() : "
	639	"application %s not found\n", name );
[714]	640	return SYSCALL_VSPACE_NOT_FOUND;
[709]	641
	642	} // end _sys_kill_application()
	643
	644
	645
[714]	646	//////////////////////////////////////////
	647	int _sys_applications_status( char* name )
[709]	648	{
	649	mapping_header_t * header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
	650	mapping_thread_t * thread = _get_thread_base(header);
	651	mapping_vspace_t * vspace = _get_vspace_base(header);
	652	mapping_cluster_t * cluster = _get_cluster_base(header);
	653
[714]	654	unsigned int thread_id; // thread index in mapping
	655	unsigned int vspace_id; // vspace index in mapping
[709]	656
[714]	657	// scan vspaces
[709]	658	for( vspace_id = 0 ; vspace_id < header->vspaces ; vspace_id++ )
[707]	659	{
[714]	660	if ( (name == NULL) \|\| (_strcmp(vspace[vspace_id].name , name ) == 0) )
[709]	661	{
[714]	662	_user_printf("\n*** vspace %s\n", vspace[vspace_id].name );
[648]	663
[714]	664	// scan all threads in vspace
	665	unsigned int min = vspace[vspace_id].thread_offset ;
	666	unsigned int max = min + vspace[vspace_id].threads ;
	667	for ( thread_id = min ; thread_id < max ; thread_id++ )
	668	{
	669	unsigned int clusterid = thread[thread_id].clusterid;
	670	unsigned int p = thread[thread_id].proclocid;
	671	unsigned int x = cluster[clusterid].x;
	672	unsigned int y = cluster[clusterid].y;
	673	unsigned int ltid = thread[thread_id].ltid;
	674	static_scheduler_t* psched = (static_scheduler_t*)_schedulers[x][y][p];
	675	unsigned int norun = psched->context[ltid].slot[CTX_NORUN_ID];
	676	unsigned int tty = psched->context[ltid].slot[CTX_TTY_ID];
	677	unsigned int current = psched->current;
	678
	679	if ( current == ltid )
	680	_user_printf(" - thread %s / P[%d,%d,%d] / ltid = %d / "
	681	"TTY = %d / norun = %x : running\n",
	682	thread[thread_id].name, x, y, p, ltid, tty, norun );
	683	else if ( norun == 0 )
	684	_user_printf(" - thread %s / P[%d,%d,%d] / ltid = %d / "
	685	"TTY = %d / norun = %x : runable\n",
	686	thread[thread_id].name, x, y, p, ltid, tty, norun);
	687	else
	688	_user_printf(" - thread %s / P[%d,%d,%d] / ltid = %d / "
	689	"TTY = %d / norun = %x : blocked\n",
	690	thread[thread_id].name, x, y, p, ltid, tty, norun);
	691	}
[648]	692	}
	693	}
[709]	694	_user_printf("\n");
[714]	695
	696	return SYSCALL_OK;
[709]	697	} // end _sys_applications_status()
[648]	698
[709]	699
	700
	701	/////////////////////////////////////////////////////////////////////////////
	702	// Threads related syscall handlers
	703	/////////////////////////////////////////////////////////////////////////////
	704
	705	////////////////////////////////////////////////
	706	int _sys_pthread_create( unsigned int* buffer,
	707	void* attr,
	708	void* function,
	709	void* arg )
	710	{
	711	// attr argument not supported
	712	if ( attr != NULL )
[707]	713	{
[709]	714	_printf("\n[GIET ERROR] in _sys_pthread_create() : "
	715	"attr argument not supported\n" );
	716
[714]	717	return SYSCALL_PTHREAD_ARGUMENT_NOT_SUPPORTED;
[707]	718	}
	719
[709]	720	// get pointers in mapping
	721	mapping_header_t* header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
	722	mapping_thread_t* thread = _get_thread_base(header);
	723	mapping_vspace_t* vspace = _get_vspace_base(header);
	724	mapping_cluster_t* cluster = _get_cluster_base(header);
	725
	726	// get scheduler for processor running the calling thread
	727	static_scheduler_t* psched = (static_scheduler_t*)_get_sched();
	728
	729	// get calling thread local index in scheduler
	730	unsigned int current = psched->current;
	731
	732	// get vspace index
	733	unsigned int vspace_id = psched->context[current].slot[CTX_VSID_ID];
	734
	735	#if GIET_DEBUG_EXEC
[714]	736	unsigned int gpid = _get_procid();
	737	unsigned int cluster_xy = gpid >> P_WIDTH;
	738	unsigned int p = gpid & ((1<<P_WIDTH)-1);
	739	unsigned int x = cluster_xy >> Y_WIDTH;
	740	unsigned int y = cluster_xy & ((1<<Y_WIDTH)-1);
[709]	741	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	742	_printf("\n[DEBUG EXEC] _sys_pthread_create() at cycle %d\n"
	743	"P[%d,%d,%d] enters for vspace %s / entry = %x\n",
	744	_get_proctime() , x , y , p , vspace[vspace_id].name , (unsigned int)function );
[709]	745	#endif
	746
	747	unsigned int thread_id; // searched thread : local index in mapping
	748	unsigned int clusterid; // searched thread : cluster index
	749	unsigned int lpid; // searched thread : processor local index
	750	unsigned int ltid; // searched thread : scheduler thread index
	751	unsigned int cx; // searched thread : X coordinate for searched thread
	752	unsigned int cy; // searched thread : Y coordinate for searched thread
	753	unsigned int entry; // searched thread : entry point
	754	unsigned int norun; // searched thread : norun vector
	755	unsigned int trdid; // searched thread : thread identifier
	756
	757	// scan threads in vspace to find an inactive thread matching function
	758	unsigned int min = vspace[vspace_id].thread_offset;
	759	unsigned int max = min + vspace[vspace_id].threads;
	760	unsigned int found = 0;
	761	for ( thread_id = min ; (thread_id < max) && (found == 0) ; thread_id++ )
[707]	762	{
[709]	763	// get thread coordinates [cx,cy,lpid] and ltid from mapping
	764	ltid = thread[thread_id].ltid;
	765	clusterid = thread[thread_id].clusterid;
	766	lpid = thread[thread_id].proclocid;
	767	cx = cluster[clusterid].x;
	768	cy = cluster[clusterid].y;
[707]	769
[709]	770	// get thread scheduler pointer
	771	psched = _schedulers[cx][cy][lpid];
[707]	772
[709]	773	// get thread entry-point, norun-vector, and trdid from context
	774	entry = psched->context[ltid].slot[CTX_ENTRY_ID];
	775	norun = psched->context[ltid].slot[CTX_NORUN_ID];
	776	trdid = psched->context[ltid].slot[CTX_TRDID_ID];
[707]	777
[709]	778	// check matching
	779	if ( ((unsigned int)function == entry ) &&
	780	(norun & NORUN_MASK_THREAD) ) found = 1;
	781
	782	} // end loop on threads
	783
	784	if ( found ) // one matching inactive thread has been found
	785	{
	786	// set argument value in thread context
	787	if ( arg != NULL ) psched->context[ltid].slot[CTX_A0_ID] = (unsigned int)arg;
	788
	789	// activate thread
	790	psched->context[ltid].slot[CTX_NORUN_ID] = 0;
	791
	792	// return launched thead global identifier
	793	*buffer = trdid;
	794
	795	#if GIET_DEBUG_EXEC
	796	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	797	_printf("\n[DEBUG EXEC] _sys_pthread_create() at cycle %d\n"
	798	"P[%d,%d,%d] exit : thread %x launched in vspace %s\n",
	799	_get_proctime() , x , y , p , trdid , vspace[vspace_id].name );
[709]	800	#endif
[714]	801	return SYSCALL_OK;
[707]	802	}
[709]	803	else // no matching thread found
	804	{
	805	_printf("\n[GIET ERROR] in _sys_pthread_create() : "
	806	"no matching thread for entry = %x in vspace %s\n",
	807	(unsigned int)function , vspace[vspace_id].name );
	808
[714]	809	return SYSCALL_THREAD_NOT_FOUND;
[709]	810	}
[707]	811
[709]	812	} // end _sys_pthread_create()
	813
	814
	815	///////////////////////////////////////////
	816	int _sys_pthread_join( unsigned int trdid,
	817	void* ptr )
	818	{
	819	// ptr argument not supported
	820	if ( ptr != NULL )
	821	{
	822	_printf("\n[GIET ERROR] in _sys_pthread_join() : "
	823	"ptr argument not supported, must be NULL\n" );
	824
[714]	825	return SYSCALL_PTHREAD_ARGUMENT_NOT_SUPPORTED;
[709]	826	}
	827
[714]	828	// get calling thread vspace
	829	unsigned int caller_vspace = _get_context_slot( CTX_VSID_ID );
[709]	830
	831	#if GIET_DEBUG_EXEC
[714]	832	unsigned int gpid = _get_procid();
	833	unsigned int cluster_xy = gpid >> P_WIDTH;
	834	unsigned int p = gpid & ((1<<P_WIDTH)-1);
	835	unsigned int x = cluster_xy >> Y_WIDTH;
	836	unsigned int y = cluster_xy & ((1<<Y_WIDTH)-1);
[648]	837	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	838	_printf("\n[DEBUG EXEC] _sys_pthread_join() at cycle %d\n"
	839	"P[%d,%d,%d] enters for thread %x in vspace %d\n",
	840	_get_proctime() , x , y , p , trdid , caller_vspace );
[648]	841	#endif
	842
[714]	843	// get target thread indexes from trdid
[709]	844	unsigned int cx = (trdid>>24) & 0xFF;
	845	unsigned int cy = (trdid>>16) & 0xFF;
	846	unsigned int lpid = (trdid>>8 ) & 0xFF;
	847	unsigned int ltid = (trdid ) & 0xFF;
	848
	849	// get target thread scheduler, vspace and registered trdid
	850	static_scheduler_t* psched = _schedulers[cx][cy][lpid];
	851	unsigned int target_vspace = psched->context[ltid].slot[CTX_VSID_ID];
	852	unsigned int registered_trdid = psched->context[ltid].slot[CTX_TRDID_ID];
	853
	854	// check trdid
	855	if ( trdid != registered_trdid )
	856	{
	857	_printf("\nerror in _sys_pthread_join() : "
	858	"trdid = %x / registered_trdid = %x\n",
	859	trdid , registered_trdid );
	860
[714]	861	return SYSCALL_UNCOHERENT_THREAD_CONTEXT;
[709]	862	}
	863
	864	// check calling thread and target thread in same vspace
	865	if ( caller_vspace != target_vspace )
	866	{
	867	_printf("\n[GIET ERROR] in _sys_pthread_join() : "
	868	" calling thread and target thread not in same vspace\n");
	869
[714]	870	return SYSCALL_NOT_IN_SAME_VSPACE;
[709]	871	}
	872
	873	// get target thread state
	874	unsigned int* pnorun = &psched->context[ltid].slot[CTX_NORUN_ID];
	875
	876	asm volatile ( "2000: \n"
[714]	877	"move $11, %0 \n" /* $11 <= pnorun */
	878	"lw $11, 0($11) \n" /* $11 <= norun */
[709]	879	"andi $11, $11, 1 \n" /* $11 <= norun & 0x1 */
	880	"beqz $11, 2000b \n"
	881	:
	882	: "r" (pnorun)
	883	: "$11" );
	884
[714]	885	#if GIET_DEBUG_EXEC
	886	if ( _get_proctime() > GIET_DEBUG_EXEC )
	887	_printf("\n[DEBUG EXEC] _sys_pthread_join() at cycle %d\n"
	888	"P[%d,%d,%d] exit for thread %x in vspace %d\n",
	889	_get_proctime() , x , y , p , trdid , caller_vspace );
	890	#endif
[709]	891
[714]	892	return SYSCALL_OK;
	893
[709]	894	} // end _sys_pthread_join()
	895
	896
	897	////////////////////////////////////////
	898	int _sys_pthread_kill( pthread_t trdid,
	899	int signal )
	900	{
	901	// get calling thread vspace
	902	unsigned int caller_vspace = _get_context_slot( CTX_VSID_ID );
	903
[714]	904	#if GIET_DEBUG_EXEC
	905	unsigned int gpid = _get_procid();
	906	unsigned int cluster_xy = gpid >> P_WIDTH;
	907	unsigned int p = gpid & ((1<<P_WIDTH)-1);
	908	unsigned int x = cluster_xy >> Y_WIDTH;
	909	unsigned int y = cluster_xy & ((1<<Y_WIDTH)-1);
	910	if ( _get_proctime() > GIET_DEBUG_EXEC )
	911	_printf("\n[DEBUG EXEC] _sys_pthread_kill() at cycle %d\n"
	912	"P[%d,%d,%d] enters for thread %x in vspace %d\n",
	913	_get_proctime() , x , y , p , trdid , caller_vspace );
	914	#endif
	915
	916
[709]	917	// get and check target thread indexes from trdid
	918	unsigned int cx = (trdid>>24) & 0xFF;
	919	unsigned int cy = (trdid>>16) & 0xFF;
	920	unsigned int lpid = (trdid>>8 ) & 0xFF;
	921	unsigned int ltid = (trdid ) & 0xFF;
	922
	923	// get target thread scheduler, vspace and registered trdid
	924	static_scheduler_t* psched = _schedulers[cx][cy][lpid];
	925	unsigned int target_vspace = psched->context[ltid].slot[CTX_VSID_ID];
	926	unsigned int registered_trdid = psched->context[ltid].slot[CTX_TRDID_ID];
	927
	928	// check trdid
	929	if ( trdid != registered_trdid )
	930	{
	931	_printf("\n[GIET ERROR] in _sys_pthread_kill() : trdid = %x"
	932	" / registered_trdid = %x\n", trdid , registered_trdid );
[714]	933	return SYSCALL_UNCOHERENT_THREAD_CONTEXT;
[709]	934	}
	935
	936	// check calling thread and target thread in same vspace
	937	if ( caller_vspace != target_vspace )
	938	{
	939	_printf("\n[GIET ERROR] in _sys_pthread_kill() : not in same vspace\n");
[714]	940	return SYSCALL_NOT_IN_SAME_VSPACE;
[709]	941	}
	942
	943	// register KILL signal in target thread context if required
	944	if ( signal )
	945	{
	946	_atomic_or( &psched->context[ltid].slot[CTX_SIGS_ID] , SIGS_MASK_KILL );
	947	}
	948
[714]	949	#if GIET_DEBUG_EXEC
	950	if ( _get_proctime() > GIET_DEBUG_EXEC )
	951	_printf("\n[DEBUG EXEC] _sys_pthread_kill() at cycle %d\n"
	952	"P[%d,%d,%d] exit for thread %x in vspace %d\n",
	953	_get_proctime() , x , y , p , trdid , caller_vspace );
	954	#endif
[709]	955
[714]	956	return SYSCALL_OK;
	957
[709]	958	} // end _sys_pthread_kill()
	959
	960
	961	/////////////////////////////////////
	962	int _sys_pthread_exit( void* string )
	963	{
	964	mapping_header_t * header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
	965	mapping_vspace_t * vspace = _get_vspace_base(header);
	966
	967	unsigned int ltid = _get_context_slot(CTX_LTID_ID);
	968	unsigned int trdid = _get_context_slot(CTX_TRDID_ID);
	969	unsigned int vsid = _get_context_slot(CTX_VSID_ID);
	970
	971	// print exit message
	972	if ( string == NULL )
	973	{
[714]	974	_printf("\n[GIET WARNING] Exit thread %x in vspace %s\n",
	975	trdid , vspace[vsid].name );
[709]	976	}
	977	else
	978	{
[714]	979	_printf("\n[GIET WARNING] Exit thread %x in vspace %s\n"
[709]	980	" Cause : %s\n\n",
[714]	981	trdid , vspace[vsid].name , (char*) string );
[709]	982	}
[648]	983
[709]	984	// get scheduler pointer for calling thread
	985	static_scheduler_t* psched = (static_scheduler_t*)_get_sched();
[648]	986
[709]	987	// register KILL signal in calling thread context (suicid request)
	988	_atomic_or( &psched->context[ltid].slot[CTX_SIGS_ID] , SIGS_MASK_KILL );
	989
	990	// deschedule calling thread
	991	unsigned int save_sr;
	992	_it_disable( &save_sr );
	993
	994	_ctx_switch();
	995
[714]	996	return SYSCALL_OK;
[709]	997
	998	} // end _sys_pthread_exit()
	999
	1000	////////////////////////
	1001	int _sys_pthread_yield()
	1002	{
	1003	unsigned int save_sr;
	1004
	1005	_it_disable( &save_sr );
	1006	_ctx_switch();
	1007	_it_restore( &save_sr );
	1008
[714]	1009	return SYSCALL_OK;
[709]	1010	}
	1011
	1012	//////////////////////////////////////////////////
	1013	int _sys_pthread_control( unsigned int command,
	1014	char* vspace_name,
	1015	char* thread_name )
	1016	{
	1017
	1018	#if GIET_DEBUG_EXEC
[714]	1019	unsigned int gpid = _get_procid();
	1020	unsigned int cluster_xy = gpid >> P_WIDTH;
	1021	unsigned int p = gpid & ((1<<P_WIDTH)-1);
	1022	unsigned int x = cluster_xy >> Y_WIDTH;
	1023	unsigned int y = cluster_xy & ((1<<Y_WIDTH)-1);
[709]	1024	if ( _get_proctime() > GIET_DEBUG_EXEC )
[714]	1025	_printf("\n[DEBUG EXEC] _sys_pthread_control() at cycle %d\n"
	1026	"P[%d,%d,%d] enter for vspace %s / thread %s / command = %d\n",
	1027	_get_proctime() , x , y , p , vspace_name, thread_name, command );
[709]	1028	#endif
	1029
	1030	// get pointers in mapping
	1031	mapping_header_t* header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
	1032	mapping_thread_t* thread = _get_thread_base(header);
	1033	mapping_vspace_t* vspace = _get_vspace_base(header);
	1034	mapping_cluster_t* cluster = _get_cluster_base(header);
	1035
	1036	unsigned int found;
	1037
	1038	// search vspace name to get vspace index: vsid
	1039	found = 0;
	1040	unsigned int vsid;
	1041	for( vsid = 0 ; vsid < header->vspaces ; vsid++ )
	1042	{
	1043	if ( _strcmp( vspace[vsid].name, vspace_name ) == 0 )
	1044	{
	1045	found = 1;
	1046	break;
	1047	}
	1048	}
	1049
[714]	1050	if ( found == 0 ) return SYSCALL_VSPACE_NOT_FOUND;
[709]	1051
	1052	// search thread name in vspace to get thread index: tid
	1053	found = 0;
	1054	unsigned int tid;
	1055	unsigned int min = vspace[vsid].thread_offset;
	1056	unsigned int max = min + vspace[vsid].threads;
	1057	for( tid = min ; tid < max ; tid++ )
	1058	{
	1059	if ( _strcmp( thread[tid].name, thread_name ) == 0 )
	1060	{
	1061	found = 1;
	1062	break;
	1063	}
	1064	}
	1065
[714]	1066	if ( found == 0 ) return SYSCALL_THREAD_NOT_FOUND;
[709]	1067
[714]	1068	// get target thread coordinates
[709]	1069	unsigned int cid = thread[tid].clusterid;
[714]	1070	unsigned int cx = cluster[cid].x;
	1071	unsigned int cy = cluster[cid].y;
	1072	unsigned int cp = thread[tid].proclocid;
[709]	1073	unsigned int ltid = thread[tid].ltid;
	1074
[714]	1075	// get target thread scheduler
	1076	static_scheduler_t* psched = _schedulers[cx][cy][cp];
[709]	1077
	1078	// check trdid and vsid
[714]	1079	unsigned int trdid = cx<<24 \| cy<<16 \| cp<<8 \| ltid;
[709]	1080	if ( (psched->context[ltid].slot[CTX_TRDID_ID] != trdid) \|\|
	1081	(psched->context[ltid].slot[CTX_VSID_ID] != vsid) )
[714]	1082	{
	1083	return SYSCALL_UNCOHERENT_THREAD_CONTEXT;
	1084	}
[709]	1085
	1086	// execute command
	1087	if ( command == THREAD_CMD_PAUSE )
	1088	{
	1089	_atomic_or ( &psched->context[ltid].slot[CTX_NORUN_ID], NORUN_MASK_THREAD );
[714]	1090	return SYSCALL_OK;
[709]	1091	}
	1092	else if ( command == THREAD_CMD_RESUME )
	1093	{
	1094	_atomic_and( &psched->context[ltid].slot[CTX_NORUN_ID], ~NORUN_MASK_THREAD );
[714]	1095	return SYSCALL_OK;
[709]	1096	}
	1097	else if ( command == THREAD_CMD_CONTEXT )
	1098	{
	1099	_user_printf( " - CTX_TRDID = %x\n"
	1100	" - CTX_VSID = %x\n"
	1101	" - CTX_EPC = %x\n"
	1102	" - CTX_PTAB = %x\n"
	1103	" - CTX_PTPR = %x\n"
	1104	" - CTX_SR = %x\n"
	1105	" - CTX_RA = %x\n"
	1106	" - CTX_SP = %x\n"
	1107	" - CTX_ENTRY = %x\n"
	1108	" - CTX_NORUN = %x\n"
	1109	" - CTX_SIGS = %x\n"
	1110	" - CTX_LOCKS = %x\n"
	1111	" - CTX_TTY = %x\n"
	1112	" - CTX_NIC_RX = %x\n"
	1113	" - CTX_NIC_TX = %x\n"
	1114	" - CTX_CMA_RX = %x\n"
	1115	" - CTX_CMA_TX = %x\n"
	1116	" - CTX_CMA_FB = %x\n",
	1117	psched->context[ltid].slot[CTX_TRDID_ID],
	1118	psched->context[ltid].slot[CTX_VSID_ID],
	1119	psched->context[ltid].slot[CTX_EPC_ID],
	1120	psched->context[ltid].slot[CTX_PTAB_ID],
	1121	psched->context[ltid].slot[CTX_PTPR_ID],
	1122	psched->context[ltid].slot[CTX_SR_ID],
	1123	psched->context[ltid].slot[CTX_RA_ID],
	1124	psched->context[ltid].slot[CTX_SP_ID],
	1125	psched->context[ltid].slot[CTX_ENTRY_ID],
	1126	psched->context[ltid].slot[CTX_NORUN_ID],
	1127	psched->context[ltid].slot[CTX_SIGS_ID],
	1128	psched->context[ltid].slot[CTX_LOCKS_ID],
	1129	psched->context[ltid].slot[CTX_TTY_ID],
	1130	psched->context[ltid].slot[CTX_NIC_RX_ID],
	1131	psched->context[ltid].slot[CTX_NIC_TX_ID],
	1132	psched->context[ltid].slot[CTX_CMA_RX_ID],
	1133	psched->context[ltid].slot[CTX_CMA_TX_ID],
	1134	psched->context[ltid].slot[CTX_CMA_FB_ID] );
[714]	1135	return SYSCALL_OK;
[709]	1136	}
	1137	else
	1138	{
[714]	1139	return SYSCALL_ILLEGAL_THREAD_COMMAND_TYPE;
[709]	1140	}
	1141
	1142	} // end _sys_pthread_control()
	1143
	1144
	1145
	1146
[648]	1147	//////////////////////////////////////////////////////////////////////////////
[519]	1148	// Coprocessors related syscall handlers
	1149	//////////////////////////////////////////////////////////////////////////////
	1150
	1151	//////////////////////////////////////////////////
	1152	int _sys_coproc_alloc( unsigned int coproc_type,
[556]	1153	unsigned int* coproc_info )
[519]	1154	{
	1155	// In this implementation, the allocation policy is constrained:
[709]	1156	// the coprocessor must be in the same cluster as the calling thread,
[556]	1157	// and there is at most one coprocessor per cluster
[519]	1158
	1159	mapping_header_t * header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
	1160	mapping_cluster_t * cluster = _get_cluster_base(header);
	1161	mapping_periph_t * periph = _get_periph_base(header);
	1162
	1163	// get cluster coordinates and cluster global index
	1164	unsigned int procid = _get_procid();
	1165	unsigned int x = procid >> (Y_WIDTH + P_WIDTH);
	1166	unsigned int y = (procid >> P_WIDTH) & ((1<<Y_WIDTH)-1);
[556]	1167	unsigned int cluster_id = x * Y_SIZE + y;
[519]	1168
	1169	// search coprocessor in cluster
	1170	mapping_periph_t* found = NULL;
	1171	unsigned int min = cluster[cluster_id].periph_offset;
	1172	unsigned int max = min + cluster[cluster_id].periphs;
	1173	unsigned int periph_id;
	1174	for ( periph_id = min ; periph_id < max ; periph_id++ )
	1175	{
	1176	if ( (periph[periph_id].type == PERIPH_TYPE_MWR) &&
	1177	(periph[periph_id].subtype == coproc_type) )
	1178	{
	1179	found = &periph[periph_id];
	1180	break;
	1181	}
	1182	}
	1183
	1184	if ( found != NULL )
	1185	{
	1186	// get the lock (at most one coproc per cluster)
	1187	_simple_lock_acquire( &_coproc_lock[cluster_id] );
[556]	1188
	1189	// register coproc characteristics in kernel arrays
	1190	_coproc_type[cluster_id] = coproc_type;
	1191	_coproc_info[cluster_id] = (found->arg0 & 0xFF) \|
	1192	(found->arg1 & 0xFF)<<8 \|
	1193	(found->arg2 & 0xFF)<<16 \|
	1194	(found->arg3 & 0xFF)<<24 ;
	1195
[519]	1196	// returns coprocessor info
[556]	1197	*coproc_info = _coproc_info[cluster_id];
[519]	1198
[709]	1199	// register coprocessor coordinates in thread context
[556]	1200	unsigned int cluster_xy = (x<<Y_WIDTH) + y;
	1201	_set_context_slot( CTX_COPROC_ID , cluster_xy );
	1202
[519]	1203	#if GIET_DEBUG_COPROC
[714]	1204	_printf("\n[DEBUG COPROC] _sys_coproc_alloc() at cycle %d\n"
	1205	"coproc_info = %x / cluster_xy = %x\n",
	1206	_get_proctime() , *coproc_info , cluster_xy );
[519]	1207	#endif
[714]	1208	return SYSCALL_OK;
[519]	1209	}
	1210	else
	1211	{
[714]	1212	_printf("\n[GIET_ERROR] in _sys_coproc_alloc(): "
	1213	"no coprocessor with type %d in cluster[%d,%d]\n",
[519]	1214	coproc_type , x , y );
[714]	1215
	1216	return SYSCALL_COPROCESSOR_NOT_FOUND;
[519]	1217	}
	1218	} // end _sys_coproc_alloc()
	1219
[556]	1220	////////////////////////////////////////////////////////
	1221	int _sys_coproc_release( unsigned int coproc_reg_index )
[519]	1222	{
[714]	1223	// get thread trdid
	1224	unsigned int trdid = _get_thread_trdid();
	1225
[556]	1226	// get coprocessor coordinates
	1227	unsigned int cluster_xy = _get_context_slot( CTX_COPROC_ID );
[714]	1228
[556]	1229	if ( cluster_xy > 0xFF )
[519]	1230	{
[556]	1231	_printf("\n[GIET_ERROR] in _sys_coproc_release(): "
[714]	1232	"no coprocessor allocated to thread %x\n", trdid );
	1233
	1234	return SYSCALL_COPROCESSOR_NON_ALLOCATED;
[519]	1235	}
	1236
[556]	1237	unsigned int cx = cluster_xy >> Y_WIDTH;
	1238	unsigned int cy = cluster_xy & ((1<<Y_WIDTH)-1);
	1239	unsigned int cluster_id = cx * Y_SIZE + cy;
	1240	unsigned int info = _coproc_info[cluster_id];
	1241	unsigned int nb_to = info & 0xFF;
	1242	unsigned int nb_from = (info>>8) & 0xFF;
	1243	unsigned int channel;
[519]	1244
[556]	1245	// stops coprocessor and communication channels
	1246	_mwr_set_coproc_register( cluster_xy , coproc_reg_index , 0 );
	1247	for ( channel = 0 ; channel < (nb_from + nb_to) ; channel++ )
	1248	{
	1249	_mwr_set_channel_register( cluster_xy , channel , MWR_CHANNEL_RUNNING , 0 );
	1250	}
[519]	1251
[709]	1252	// deallocates coprocessor coordinates in thread context
[556]	1253	_set_context_slot( CTX_COPROC_ID , 0xFFFFFFFF );
	1254
	1255	// release coprocessor lock
	1256	_simple_lock_release( &_coproc_lock[cluster_id] );
	1257
[519]	1258	#if GIET_DEBUG_COPROC
[714]	1259	_printf("\n[DEBUG COPROC] _sys_coproc_release() at cycle %d\n"
	1260	"thread %x release coprocessor in cluster[%d,%d]\n", cx, cy );
[519]	1261	#endif
	1262
[714]	1263	return SYSCALL_OK;
[519]	1264	} // end _sys_coproc_release()
	1265
[556]	1266	//////////////////////////////////////////////////////////////
	1267	int _sys_coproc_channel_init( unsigned int channel,
[519]	1268	giet_coproc_channel_t* desc )
	1269	{
[714]	1270	// get thread trdid
	1271	unsigned int trdid = _get_thread_trdid();
	1272
[556]	1273	// get coprocessor coordinates
	1274	unsigned int cluster_xy = _get_context_slot( CTX_COPROC_ID );
[714]	1275
[556]	1276	if ( cluster_xy > 0xFF )
[519]	1277	{
	1278	_printf("\n[GIET_ERROR] in _sys_coproc_channel_init(): "
[714]	1279	"no coprocessor allocated to thread %x\n", trdid );
	1280
	1281	return SYSCALL_COPROCESSOR_NON_ALLOCATED;
[519]	1282	}
	1283
	1284	// check channel mode
	1285	unsigned mode = desc->channel_mode;
	1286	if ( (mode != MODE_MWMR) &&
	1287	(mode != MODE_DMA_IRQ) &&
	1288	(mode != MODE_DMA_NO_IRQ) )
	1289	{
[556]	1290	_printf("\n[GIET_ERROR] in _sys_coproc_channel_init(): "
[714]	1291	"illegal mode\n");
	1292
	1293	return SYSCALL_COPROCESSOR_ILLEGAL_MODE;
[519]	1294	}
	1295
	1296	// get memory buffer size
	1297	unsigned int size = desc->buffer_size;
	1298
[528]	1299	// physical addresses
[709]	1300	unsigned long long buffer_paddr;
[519]	1301	unsigned int buffer_lsb;
	1302	unsigned int buffer_msb;
[709]	1303	unsigned long long mwmr_paddr = 0;
[519]	1304	unsigned int mwmr_lsb;
	1305	unsigned int mwmr_msb;
[709]	1306	unsigned long long lock_paddr = 0;
[519]	1307	unsigned int lock_lsb;
	1308	unsigned int lock_msb;
	1309
[528]	1310	unsigned int flags; // unused
	1311
[519]	1312	// compute memory buffer physical address
[528]	1313	buffer_paddr = _v2p_translate( desc->buffer_vaddr , &flags );
	1314	buffer_lsb = (unsigned int)buffer_paddr;
	1315	buffer_msb = (unsigned int)(buffer_paddr>>32);
[519]	1316
	1317	// call MWMR_DMA driver
[556]	1318	_mwr_set_channel_register( cluster_xy, channel, MWR_CHANNEL_MODE, mode );
	1319	_mwr_set_channel_register( cluster_xy, channel, MWR_CHANNEL_SIZE, size );
	1320	_mwr_set_channel_register( cluster_xy, channel, MWR_CHANNEL_BUFFER_LSB, buffer_lsb );
	1321	_mwr_set_channel_register( cluster_xy, channel, MWR_CHANNEL_BUFFER_MSB, buffer_msb );
[519]	1322
	1323	if ( mode == MODE_MWMR )
	1324	{
[528]	1325	// compute MWMR descriptor physical address
	1326	mwmr_paddr = _v2p_translate( desc->mwmr_vaddr , &flags );
[519]	1327	mwmr_lsb = (unsigned int)mwmr_paddr;
	1328	mwmr_msb = (unsigned int)(mwmr_paddr>>32);
	1329
[528]	1330	// call MWMR_DMA driver
[556]	1331	_mwr_set_channel_register( cluster_xy, channel, MWR_CHANNEL_MWMR_LSB, mwmr_lsb );
	1332	_mwr_set_channel_register( cluster_xy, channel, MWR_CHANNEL_MWMR_MSB, mwmr_msb );
[528]	1333
	1334	// compute lock physical address
	1335	lock_paddr = _v2p_translate( desc->lock_vaddr , &flags );
[519]	1336	lock_lsb = (unsigned int)lock_paddr;
	1337	lock_msb = (unsigned int)(lock_paddr>>32);
	1338
	1339	// call MWMR_DMA driver
[556]	1340	_mwr_set_channel_register( cluster_xy, channel, MWR_CHANNEL_LOCK_LSB, lock_lsb );
	1341	_mwr_set_channel_register( cluster_xy, channel, MWR_CHANNEL_LOCK_MSB, lock_msb );
[519]	1342	}
	1343
	1344	#if GIET_DEBUG_COPROC
[714]	1345	_printf("\n[DEBUG COPROC] _sys_coproc_channel_init() at cycle %d\n"
	1346	"cluster[%d,%d] / channel = %d / mode = %d / buffer_size = %d\n"
[519]	1347	" buffer_paddr = %l / mwmr_paddr = %l / lock_paddr = %l\n",
[714]	1348	_get_proctime() , x , y , channel , mode , size ,
[519]	1349	buffer_paddr, mwmr_paddr, lock_paddr );
	1350	#endif
	1351
[714]	1352	return SYSCALL_OK;
[519]	1353	} // end _sys_coproc_channel_init()
	1354
[556]	1355	////////////////////////////////////////////////////
	1356	int _sys_coproc_run( unsigned int coproc_reg_index )
[519]	1357	{
[714]	1358	// get thread trdid
	1359	unsigned int trdid = _get_thread_trdid();
	1360
[556]	1361	// get coprocessor coordinates
	1362	unsigned int cluster_xy = _get_context_slot( CTX_COPROC_ID );
[714]	1363
[556]	1364	if ( cluster_xy > 0xFF )
[519]	1365	{
[556]	1366	_printf("\n[GIET_ERROR] in _sys_coproc_run(): "
[714]	1367	"no coprocessor allocated to thread %d\n", trdid );
	1368
	1369	return SYSCALL_COPROCESSOR_NON_ALLOCATED;
[519]	1370	}
	1371
[556]	1372	unsigned int cx = cluster_xy >> Y_WIDTH;
	1373	unsigned int cy = cluster_xy & ((1<<Y_WIDTH)-1);
	1374	unsigned int cluster_id = cx * Y_SIZE + cy;
	1375	unsigned int info = _coproc_info[cluster_id];
	1376	unsigned int nb_to = info & 0xFF;
	1377	unsigned int nb_from = (info>>8) & 0xFF;
	1378	unsigned int mode = 0xFFFFFFFF;
	1379	unsigned int channel;
[519]	1380
[556]	1381	// register coprocessor running mode
	1382	for ( channel = 0 ; channel < (nb_from + nb_to) ; channel++ )
	1383	{
	1384	unsigned int temp;
	1385	temp = _mwr_get_channel_register( cluster_xy , channel , MWR_CHANNEL_MODE );
[519]	1386
[556]	1387	if ( mode == 0xFFFFFFFF )
	1388	{
	1389	mode = temp;
	1390	}
	1391	else if ( temp != mode )
	1392	{
[714]	1393	_printf("\n[GIET_ERROR] in _sys_coproc_run(): "
	1394	"channels don't have same mode in coprocessor[%d,%d]\n", cx , cy );
	1395
	1396	return SYSCALL_COPROCESSOR_ILLEGAL_MODE;
[556]	1397	}
	1398	}
	1399	_coproc_mode[cluster_id] = mode;
[519]	1400
[556]	1401	// start all communication channels
	1402	for ( channel = 0 ; channel < (nb_from + nb_to) ; channel++ )
	1403	{
	1404	_mwr_set_channel_register( cluster_xy , channel , MWR_CHANNEL_RUNNING , 1 );
	1405	}
[519]	1406
[556]	1407	//////////////////////////////////////////////////////////////////////////
	1408	if ( (mode == MODE_MWMR) \|\| (mode == MODE_DMA_NO_IRQ) ) // no descheduling
[519]	1409	{
[556]	1410	// start coprocessor
	1411	_mwr_set_coproc_register( cluster_xy , coproc_reg_index , 1 );
	1412
	1413	#if GIET_DEBUG_COPROC
	1414	if ( mode == MODE_MWMR )
[714]	1415	_printf("\n[DEBUG COPROC] _sys_coproc_run() at cycle %d\n"
	1416	"thread %x starts coprocessor[%d,%d] in MODE_MWMR\n",
	1417	_get_proctime() , trdid , cx , cy );
[556]	1418	else
[714]	1419	_printf("\n[DEBUG COPROC] _sys_coproc_run() at cycle %d\n"
	1420	"thread %x starts coprocessor[%d,%d] in MODE_DMA_NO_IRQ\n",
	1421	_get_proctime() , trdid , cx , cy );
[556]	1422	#endif
	1423
[714]	1424	return SYSCALL_OK;
[519]	1425	}
[556]	1426	///////////////////////////////////////////////////////////////////////////
	1427	else // mode == MODE_DMA_IRQ => descheduling
	1428	{
[714]	1429	// set _coproc_trdid
	1430	unsigned int gpid = _get_procid();
	1431	unsigned int x = gpid >> (Y_WIDTH+P_WIDTH);
	1432	unsigned int y = (gpid >> P_WIDTH) & ((1<<Y_WIDTH)-1);
	1433	unsigned int p = gpid & ((1<<P_WIDTH)-1);
	1434	unsigned int ltid = _get_thread_ltid();
[709]	1435	_coproc_trdid[cluster_id] = (x<<24) + (y<<16) + (p<<8) + ltid;
[519]	1436
[556]	1437	// enters critical section
	1438	unsigned int save_sr;
	1439	_it_disable( &save_sr );
	1440
[629]	1441	// set NORUN_MASK_COPROC bit
	1442	static_scheduler_t* psched = (static_scheduler_t*)_schedulers[x][y][p];
[709]	1443	unsigned int* ptr = &psched->context[ltid].slot[CTX_NORUN_ID];
[629]	1444	_atomic_or( ptr , NORUN_MASK_COPROC );
[556]	1445
	1446	// start coprocessor
	1447	_mwr_set_coproc_register( cluster_xy , coproc_reg_index , 1 );
	1448
[519]	1449	#if GIET_DEBUG_COPROC
[714]	1450	_printf("\n[DEBUG COPROC] _sys_coproc_run() at cycle %d\n"
	1451	"thread %x starts coprocessor[%d,%d] in MODE_DMA_IRQ\n",
	1452	_get_proctime() , trdid , cx , cy );
[519]	1453	#endif
	1454
[709]	1455	// deschedule thread
[556]	1456	_ctx_switch();
[519]	1457
[556]	1458	#if GIET_DEBUG_COPROC
[714]	1459	_printf("\n[DEBUG COPROC] _sys_coproc_run() at cycle %d\n"
	1460	"thread %x resume after coprocessor[%d,%d] completion\n",
	1461	_get_proctime() , trdid , cx , cy );
[556]	1462	#endif
	1463
	1464	// restore SR
	1465	_it_restore( &save_sr );
	1466
	1467	// return error computed by mwr_isr()
	1468	return _coproc_error[cluster_id];
	1469	}
	1470	} // end _sys_coproc_run()
	1471
	1472	///////////////////////////
	1473	int _sys_coproc_completed()
[519]	1474	{
[714]	1475	// get thread trdid
	1476	unsigned int trdid = _get_thread_trdid();
	1477
[556]	1478	// get coprocessor coordinates
	1479	unsigned int cluster_xy = _get_context_slot( CTX_COPROC_ID );
[714]	1480
[556]	1481	if ( cluster_xy > 0xFF )
[519]	1482	{
	1483	_printf("\n[GIET_ERROR] in _sys_coproc_completed(): "
[714]	1484	"no coprocessor allocated to thread %x\n", trdid );
	1485
	1486	return SYSCALL_COPROCESSOR_NON_ALLOCATED;
[519]	1487	}
	1488
[556]	1489	unsigned int cx = cluster_xy >> Y_WIDTH;
	1490	unsigned int cy = cluster_xy & ((1<<Y_WIDTH)-1);
	1491	unsigned int cluster_id = cx * Y_SIZE + cy;
	1492	unsigned int mode = _coproc_mode[cluster_id];
[519]	1493
[556]	1494	// analyse possible errors
	1495	if ( mode == MODE_DMA_NO_IRQ )
	1496	{
	1497	unsigned int info = _coproc_info[cluster_id];
	1498	unsigned int nb_to = info & 0xFF;
	1499	unsigned int nb_from = (info>>8) & 0xFF;
	1500	unsigned int error = 0;
	1501	unsigned int channel;
	1502	unsigned int status;
	1503
[714]	1504	// get status for all channels, and signal reported errors
[556]	1505	for ( channel = 0 ; channel < (nb_to +nb_from) ; channel++ )
	1506	{
	1507	do
	1508	{
[714]	1509	status = _mwr_get_channel_register( cluster_xy, channel,
	1510	MWR_CHANNEL_STATUS );
[556]	1511	if ( status == MWR_CHANNEL_ERROR_DATA )
	1512	{
[714]	1513	_printf("\n[GIET_ERROR] in _sys_coproc_completed(): "
	1514	"channel %d / DATA_ERROR\n", channel );
[556]	1515	error = 1;
	1516	}
	1517	else if ( status == MWR_CHANNEL_ERROR_LOCK )
	1518	{
	1519	_printf("\n[GIET_ERROR] in _sys_coproc_completed()"
	1520	" / channel %d / LOCK_ERROR\n", channel );
	1521	error = 1;
	1522	}
	1523	else if ( status == MWR_CHANNEL_ERROR_DESC )
	1524	{
	1525	_printf("\n[GIET_ERROR] in _sys_coproc_completed()"
	1526	" / channel %d / DESC_ERROR\n", channel );
	1527	error = 1;
	1528	}
[714]	1529	}
	1530	while ( status == MWR_CHANNEL_BUSY );
[556]	1531
	1532	// reset channel
[714]	1533	_mwr_set_channel_register( cluster_xy, channel,
	1534	MWR_CHANNEL_RUNNING , 0 );
[556]	1535
	1536	} // end for channels
	1537
[714]	1538	if ( error )
	1539	{
	1540	return SYSCALL_COPROCESSOR_ILLEGAL_MODE;
	1541	}
	1542	else
	1543	{
	1544
[519]	1545	#if GIET_DEBUG_COPROC
[714]	1546	_printf("\n[DEBUG COPROC] _sys_coproc_completed() at cycle %d\n"
	1547	"coprocessor[%d,%d] successfully completes operation for thread %d\n",
	1548	cx , cy , trdid );
[519]	1549	#endif
[714]	1550	return SYSCALL_OK;
	1551	}
[556]	1552	}
	1553	else // mode == MODE_MWMR or MODE_DMA_IRQ
	1554	{
[714]	1555	_printf("\n[GIET ERROR] in sys_coproc_completed(): "
	1556	"coprocessor[%d,%d] is not running in MODE_DMA_NO_IRQ\n", cx , cy );
	1557
	1558	return SYSCALL_COPROCESSOR_ILLEGAL_MODE;
[556]	1559	}
[519]	1560	} // end _sys_coproc_completed()
	1561
	1562
	1563	//////////////////////////////////////////////////////////////////////////////
[440]	1564	// TTY related syscall handlers
[258]	1565	//////////////////////////////////////////////////////////////////////////////
[440]	1566
[670]	1567	/////////////////////////////////////////
	1568	int _sys_tty_alloc( unsigned int shared )
[258]	1569	{
[709]	1570	unsigned int channel; // allocated TTY channel
[440]	1571
[709]	1572	// get trdid and vsid for the calling thread
	1573	unsigned int vsid = _get_context_slot( CTX_VSID_ID );
	1574	unsigned int trdid = _get_thread_trdid();
	1575
	1576	// check no TTY already allocated to calling thread
[698]	1577	if ( _get_context_slot( CTX_TTY_ID ) < NB_TTY_CHANNELS )
	1578	{
[709]	1579	_printf("\n[GIET_ERROR] in _sys_tty_alloc() : "
	1580	"TTY channel already allocated to thread %x\n", trdid );
[714]	1581	return SYSCALL_CHANNEL_ALREADY_ALLOCATED;
[698]	1582	}
	1583
[709]	1584	mapping_header_t header = (mapping_header_t )SEG_BOOT_MAPPING_BASE;
	1585	mapping_vspace_t *vspace = _get_vspace_base(header);
	1586	mapping_thread_t *thread = _get_thread_base(header);
	1587
	1588	// compute number of users
	1589	unsigned int users;
	1590	if ( shared ) users = vspace[vsid].threads;
	1591	else users = 1;
	1592
	1593	// get a TTY channel
[698]	1594	for ( channel = 0 ; channel < NB_TTY_CHANNELS ; channel++ )
	1595	{
[709]	1596	unsigned int* palloc = &_tty_channel_alloc[channel];
	1597
	1598	if ( _atomic_test_and_set( palloc , users ) == 0 ) break;
[698]	1599	}
[440]	1600	if ( channel >= NB_TTY_CHANNELS )
	1601	{
[709]	1602	_printf("\n[GIET_ERROR] in _sys_tty_alloc() : "
	1603	"no TTY channel available for thread %x\n", trdid );
[714]	1604	return SYSCALL_NO_CHANNEL_AVAILABLE;
[440]	1605	}
[547]	1606
[709]	1607	// initialise allocated TTY channel
	1608	_tty_init( channel );
[648]	1609
[547]	1610	// allocate a WTI mailbox to the calling proc if external IRQ
[709]	1611	unsigned int wti_id;
	1612	if ( USE_PIC ) _ext_irq_alloc( ISR_TTY_RX , channel , &wti_id );
	1613
	1614	// register wti_id and coordinates for processor receiving WTI
	1615	unsigned int procid = _get_procid();
	1616	unsigned int x = procid >> (Y_WIDTH + P_WIDTH);
	1617	unsigned int y = (procid >> P_WIDTH) & ((1<<Y_WIDTH)-1);
	1618	unsigned int p = procid & ((1<<P_WIDTH)-1);
	1619	_tty_channel_wti[channel] = x<<24 \| y<<16 \| p<<8 \| wti_id;
[547]	1620
[670]	1621	// update CTX_TTY_ID
[709]	1622	if ( shared ) // for all threads in vspace
[670]	1623	{
[709]	1624	// scan threads in vspace
	1625	unsigned int tid;
	1626	for (tid = vspace[vsid].thread_offset;
	1627	tid < (vspace[vsid].thread_offset + vspace[vsid].threads);
	1628	tid++)
[670]	1629	{
	1630	unsigned int y_size = header->y_size;
[709]	1631	unsigned int cid = thread[tid].clusterid;
[670]	1632	unsigned int x = cid / y_size;
	1633	unsigned int y = cid % y_size;
[709]	1634	unsigned int p = thread[tid].proclocid;
	1635	unsigned int ltid = thread[tid].ltid;
[670]	1636	static_scheduler_t* psched = (static_scheduler_t*)_schedulers[x][y][p];
[698]	1637
[709]	1638	psched->context[ltid].slot[CTX_TTY_ID] = channel;
[670]	1639	}
	1640	}
[709]	1641	else // for calling thread only
[670]	1642	{
	1643	_set_context_slot( CTX_TTY_ID, channel );
	1644	}
	1645
[714]	1646	return SYSCALL_OK;
[709]	1647	} // end _sys_tty_alloc()
[258]	1648
[709]	1649	//////////////////////
[714]	1650	int _sys_tty_release() // NOTE: not a syscall: used by _ctx_kill_thread()
[695]	1651	{
[698]	1652	unsigned int channel = _get_context_slot( CTX_TTY_ID );
	1653
	1654	if ( channel == -1 )
	1655	{
[709]	1656	unsigned int trdid = _get_thread_trdid();
	1657	_printf("\n[GIET_ERROR] in _sys_tty_release() : "
	1658	"TTY channel already released for thread %x\n", trdid );
[714]	1659
	1660	return SYSCALL_CHANNEL_ALREADY_ALLOCATED;
[698]	1661	}
	1662
[709]	1663	// reset CTX_TTY_ID for the calling thread
	1664	_set_context_slot( CTX_TTY_ID , 0xFFFFFFFF );
[697]	1665
[709]	1666	// atomically decrement the _tty_channel_allocator[] array
	1667	_atomic_increment( &_tty_channel_alloc[channel] , -1 );
[695]	1668
[709]	1669	// release WTI mailbox if TTY channel no more used
	1670	if ( USE_PIC && (_tty_channel_alloc[channel] == 0) )
[698]	1671	{
[709]	1672	_ext_irq_release( ISR_TTY_RX , channel );
[698]	1673	}
	1674
[714]	1675	return SYSCALL_OK;
[709]	1676	} // end sys_tty_release()
[698]	1677
[709]	1678	////////////////////////////////////////
[440]	1679	int _sys_tty_write( const char* buffer,
	1680	unsigned int length, // number of characters
	1681	unsigned int channel) // channel index
	1682	{
	1683	unsigned int nwritten;
	1684
	1685	// compute and check tty channel
	1686	if( channel == 0xFFFFFFFF ) channel = _get_context_slot(CTX_TTY_ID);
	1687
[714]	1688	if( channel >= NB_TTY_CHANNELS )
	1689	{
	1690	_printf("\n[GIET_ERROR] in _sys_tty_write() : "
	1691	"no TTY channel allocated for thread %x\n", _get_thread_trdid() );
	1692
	1693	return SYSCALL_CHANNEL_NON_ALLOCATED;
	1694	}
	1695
[440]	1696	// write string to TTY channel
	1697	for (nwritten = 0; nwritten < length; nwritten++)
	1698	{
	1699	// check tty's status
	1700	if ( _tty_get_register( channel, TTY_STATUS ) & 0x2 ) break;
	1701
	1702	// write one byte
	1703	if (buffer[nwritten] == '\n')
	1704	{
	1705	_tty_set_register( channel, TTY_WRITE, (unsigned int)'\r' );
	1706	}
	1707	_tty_set_register( channel, TTY_WRITE, (unsigned int)buffer[nwritten] );
	1708	}
	1709
	1710	return nwritten;
	1711	}
	1712
[709]	1713	///////////////////////////////////////
[440]	1714	int _sys_tty_read( char* buffer,
	1715	unsigned int length, // unused
	1716	unsigned int channel) // channel index
	1717	{
	1718	// compute and check tty channel
	1719	if( channel == 0xFFFFFFFF ) channel = _get_context_slot(CTX_TTY_ID);
	1720
[714]	1721	if( channel >= NB_TTY_CHANNELS )
	1722	{
	1723	_printf("\n[GIET_ERROR] in _sys_tty_read() : "
	1724	"no TTY channel allocated for thread %x\n", _get_thread_trdid() );
	1725
	1726	return SYSCALL_CHANNEL_NON_ALLOCATED;
	1727	}
	1728
[709]	1729	unsigned int save_sr;
	1730	unsigned int found = 0;
	1731
	1732	// get pointer on TTY_RX FIFO
	1733	tty_fifo_t* fifo = &_tty_rx_fifo[channel];
	1734
	1735	// try to read one character from FIFO
	1736	// blocked in while loop until success
	1737	while ( found == 0 )
[440]	1738	{
[709]	1739	if ( fifo->sts == 0) // FIFO empty => deschedule
	1740	{
	1741	// enters critical section
	1742	_it_disable( &save_sr );
[440]	1743
[709]	1744	// set NORUN_MASK_TTY bit for calling thread
	1745	static_scheduler_t* psched = (static_scheduler_t*)_get_sched();
	1746	unsigned int ltid = psched->current;
	1747	_atomic_or( &psched->context[ltid].slot[CTX_NORUN_ID] , NORUN_MASK_TTY );
[440]	1748
[709]	1749	// register descheduling thread trdid
	1750	fifo->trdid = _get_thread_trdid();
[440]	1751
[709]	1752	// deschedule calling thread
	1753	_ctx_switch();
[440]	1754
[709]	1755	// exit critical section
	1756	_it_restore( &save_sr );
	1757	}
	1758	else // FIFO not empty => get one character
	1759	{
	1760	*buffer = fifo->data[fifo->ptr];
	1761	fifo->sts = fifo->sts - 1;
	1762	fifo->ptr = (fifo->ptr + 1) % TTY_FIFO_DEPTH;
	1763	found = 1;
	1764	}
	1765	}
	1766
	1767	return 1;
[440]	1768	}
	1769
[709]	1770
	1771
[428]	1772	//////////////////////////////////////////////////////////////////////////////
[709]	1773	// TIMER related syscall handlers
[428]	1774	//////////////////////////////////////////////////////////////////////////////
[440]	1775
	1776	////////////////////
	1777	int _sys_tim_alloc()
[428]	1778	{
[440]	1779
[709]	1780	#if NB_TIM_CHANNELS
	1781
	1782	unsigned int channel; // allocated TIMER channel
	1783
	1784	unsigned int trdid = _get_thread_trdid();
	1785
	1786	// check no TIMER already allocated to calling thread
	1787	if ( _get_context_slot( CTX_TIM_ID ) < NB_TIM_CHANNELS )
[440]	1788	{
[709]	1789	_printf("\n[GIET_ERROR] in _sys_tim_alloc() : "
	1790	"TIMER channel already allocated to thread %x\n", trdid );
[714]	1791
	1792	return SYSCALL_CHANNEL_ALREADY_ALLOCATED;
[440]	1793	}
[709]	1794
	1795	// get a TIMER channel
	1796	for ( channel = 0 ; channel < NB_TIM_CHANNELS ; channel++ )
[440]	1797	{
[709]	1798	unsigned int* palloc = &_tim_channel_alloc[channel];
	1799
	1800	if ( _atomic_test_and_set( palloc , 1 ) == 0 ) break;
[440]	1801	}
[709]	1802	if ( channel >= NB_TIM_CHANNELS )
	1803	{
	1804	_printf("\n[GIET_ERROR] in _sys_tim_alloc() : "
	1805	"no TIMER channel available for thread %x\n", trdid );
[714]	1806
	1807	return SYSCALL_NO_CHANNEL_AVAILABLE;
[709]	1808	}
[440]	1809
[709]	1810	// allocate a WTI mailbox to the calling proc if external IRQ
	1811	unsigned int wti_id;
	1812	if ( USE_PIC ) _ext_irq_alloc( ISR_TIMER , channel , &wti_id );
	1813
	1814	// register wti_id and coordinates for processor receiving WTI
	1815	unsigned int procid = _get_procid();
	1816	unsigned int x = procid >> (Y_WIDTH + P_WIDTH);
	1817	unsigned int y = (procid >> P_WIDTH) & ((1<<Y_WIDTH)-1);
	1818	unsigned int p = procid & ((1<<P_WIDTH)-1);
	1819	_tim_channel_wti[channel] = x<<24 \| y<<16 \| p<<8 \| wti_id;
	1820
	1821	// update CTX_TIM_ID in thread context
	1822	_set_context_slot( CTX_TIM_ID, channel );
	1823
[714]	1824	return SYSCALL_OK;
[709]	1825
	1826	#else
	1827
[714]	1828	_printf("\n[GIET ERROR] in _sys_tim_alloc(): NB_TIM_CHANNELS == 0\n");
[709]	1829
[714]	1830	return SYSCALL_NO_CHANNEL_AVAILABLE;
	1831
[709]	1832	#endif
	1833	} // end _sys_tim_alloc()
	1834
	1835
	1836	//////////////////////
[714]	1837	int _sys_tim_release() // NOTE: not a syscall: used by _ctx_kill_thread()
[695]	1838	{
	1839
[709]	1840	#if NB_TIM_CHANNELS
[695]	1841
[709]	1842	unsigned int channel = _get_context_slot( CTX_TIM_ID );
	1843
	1844	if ( channel == -1 )
	1845	{
	1846	unsigned int trdid = _get_thread_trdid();
[714]	1847	_printf("\n[GIET_ERROR] in _sys_tim_release(): "
[709]	1848	"TIMER channel already released for thread %x\n", trdid );
[714]	1849
	1850	return SYSCALL_CHANNEL_ALREADY_ALLOCATED;
[709]	1851	}
	1852
	1853	// reset CTX_TIM_ID for the calling thread
	1854	_set_context_slot( CTX_TIM_ID , 0xFFFFFFFF );
	1855
	1856	// reset the _tim_channel_alloc[] array
	1857	_tim_channel_alloc[channel] = 0;
	1858
	1859	// release WTI mailbox if TTY channel no more used
	1860	if ( USE_PIC )
	1861	{
	1862	_ext_irq_release( PERIPH_TYPE_TIM , channel );
	1863	}
	1864
[714]	1865	return SYSCALL_OK;
[709]	1866
	1867	#else
	1868
[714]	1869	_printf("\n[GIET ERROR] in _sys_tim_release(): NB_TIM_CHANNELS = 0\n");
[709]	1870
[714]	1871	return SYSCALL_NO_CHANNEL_AVAILABLE;
	1872
[709]	1873	#endif
	1874	} // end _sys_tim_release()
	1875
[440]	1876	/////////////////////////////////////////
	1877	int _sys_tim_start( unsigned int period )
	1878	{
[709]	1879
	1880	#if NB_TIM_CHANNELS
	1881
[440]	1882	// get timer index
	1883	unsigned int channel = _get_context_slot( CTX_TIM_ID );
[714]	1884
[440]	1885	if ( channel >= NB_TIM_CHANNELS )
	1886	{
[714]	1887	_printf("\n[GIET_ERROR] in _sys_tim_start(): not enough TIM channels\n");
	1888
	1889	return SYSCALL_NO_CHANNEL_AVAILABLE;
[440]	1890	}
	1891
	1892	// start timer
	1893	_timer_start( channel, period );
	1894
[714]	1895	return SYSCALL_OK;
[709]	1896
	1897	#else
	1898
	1899	_printf("\n[GIET ERROR] in _sys_tim_start() : NB_TIM_CHANNELS = 0\n");
	1900
[714]	1901	return SYSCALL_NO_CHANNEL_AVAILABLE;
	1902
[709]	1903	#endif
[440]	1904	}
	1905
	1906	///////////////////
	1907	int _sys_tim_stop()
	1908	{
[709]	1909
	1910	#if NB_TIM_CHANNELS
	1911
[440]	1912	// get timer index
	1913	unsigned int channel = _get_context_slot( CTX_TIM_ID );
[714]	1914
[440]	1915	if ( channel >= NB_TIM_CHANNELS )
	1916	{
	1917	_printf("\n[GIET_ERROR] in _sys_tim_stop() : illegal timer index\n");
[714]	1918
	1919	return SYSCALL_CHANNEL_NON_ALLOCATED;
[440]	1920	}
	1921
	1922	// stop timer
	1923	_timer_stop( channel );
	1924
[714]	1925	return SYSCALL_OK;
[709]	1926
	1927	#else
	1928
	1929	_printf("\n[GIET ERROR] in _sys_tim_stop() : NB_TIM_CHANNELS = 0\n");
	1930
[714]	1931	return SYSCALL_NO_CHANNEL_AVAILABLE;
	1932
[709]	1933	#endif
[440]	1934	}
	1935
[709]	1936
[440]	1937	//////////////////////////////////////////////////////////////////////////////
	1938	// NIC related syscall handlers
	1939	//////////////////////////////////////////////////////////////////////////////
	1940
[478]	1941	#define NIC_CONTAINER_SIZE 4096
	1942
[709]	1943	#if NB_NIC_CHANNELS
	1944
[494]	1945	////////////////////////////////////////
	1946	int _sys_nic_alloc( unsigned int is_rx,
	1947	unsigned int xmax,
	1948	unsigned int ymax )
[440]	1949	{
[709]	1950	mapping_header_t header = (mapping_header_t )SEG_BOOT_MAPPING_BASE;
	1951	mapping_vspace_t *vspace = _get_vspace_base(header);
	1952	mapping_thread_t *thread = _get_thread_base(header);
	1953
	1954	// get calling thread trdid, vspace index, and number of threads
	1955	unsigned int trdid = _get_thread_trdid();
	1956	unsigned int vsid = _get_context_slot( CTX_VSID_ID );
	1957	unsigned int users = vspace[vsid].threads;
	1958
[494]	1959	// check xmax / ymax parameters
[709]	1960	if ( (xmax > X_SIZE) \|\| (ymax > Y_SIZE) )
[494]	1961	{
[709]	1962	_printf("\n[GIET_ERROR] in _sys_nic_alloc() "
	1963	"xmax or ymax argument too large for thread %x\n", trdid );
[714]	1964
	1965	return SYSCALL_ILLEGAL_XY_ARGUMENTS;
[494]	1966	}
[459]	1967
[614]	1968	////////////////////////////////////////////////////////
	1969	// Step 1: get and register CMA and NIC channel index //
	1970	////////////////////////////////////////////////////////
	1971
[709]	1972	unsigned int nic_channel;
	1973	unsigned int cma_channel;
	1974	unsigned int* palloc;
[440]	1975
[709]	1976	// get a NIC_RX or NIC_TX channel
	1977	for ( nic_channel = 0 ; nic_channel < NB_NIC_CHANNELS ; nic_channel++ )
	1978	{
	1979	if ( is_rx ) palloc = &_nic_rx_channel_alloc[nic_channel];
	1980	else palloc = &_nic_tx_channel_alloc[nic_channel];
[449]	1981
[709]	1982	if ( _atomic_test_and_set( palloc , users ) == 0 ) break;
	1983	}
[449]	1984	if ( (nic_channel >= NB_NIC_CHANNELS) )
[440]	1985	{
[709]	1986	_printf("\n[GIET_ERROR] in _sys_nic_alloc() : "
	1987	"no NIC channel available for thread %x\n", trdid );
[714]	1988
	1989	return SYSCALL_NO_CHANNEL_AVAILABLE;
[440]	1990	}
[449]	1991
[709]	1992	// get a CMA channel
[699]	1993	for ( cma_channel = 0 ; cma_channel < NB_CMA_CHANNELS ; cma_channel++ )
	1994	{
[709]	1995	palloc = &_cma_channel_alloc[cma_channel];
	1996
	1997	if ( _atomic_test_and_set( palloc , users ) == 0 ) break;
[699]	1998	}
[449]	1999	if ( cma_channel >= NB_CMA_CHANNELS )
	2000	{
[709]	2001	_printf("\n[GIET_ERROR] in _sys_nic_alloc() : "
	2002	"no CMA channel available for thread %x\n", trdid );
	2003	if ( is_rx ) _nic_rx_channel_alloc[nic_channel] = 0;
	2004	else _nic_tx_channel_alloc[nic_channel] = 0;
[714]	2005
	2006	return SYSCALL_NO_CHANNEL_AVAILABLE;
[449]	2007	}
[459]	2008
[494]	2009	#if GIET_DEBUG_NIC
[714]	2010	_printf("\n[DEBUG NIC] sys_nic_alloc() at cycle %d\n"
	2011	"thread %d get nic_channel = %d / cma_channel = %d\n",
	2012	_get_proctime() , trdid , nic_channel , cma_channel );
[494]	2013	#endif
	2014
[709]	2015	// register nic_index and cma_index in all threads
	2016	// contexts that are in the same vspace
	2017	unsigned int tid;
	2018	for (tid = vspace[vsid].thread_offset;
	2019	tid < (vspace[vsid].thread_offset + vspace[vsid].threads);
	2020	tid++)
[449]	2021	{
[709]	2022	unsigned int y_size = header->y_size;
	2023	unsigned int cid = thread[tid].clusterid;
	2024	unsigned int x = cid / y_size;
	2025	unsigned int y = cid % y_size;
	2026	unsigned int p = thread[tid].proclocid;
	2027	unsigned int ltid = thread[tid].ltid;
	2028	static_scheduler_t* psched = (static_scheduler_t*)_schedulers[x][y][p];
[440]	2029
[709]	2030	if ( is_rx )
	2031	{
	2032	if ( (psched->context[ltid].slot[CTX_NIC_RX_ID] < NB_NIC_CHANNELS) \|\|
	2033	(psched->context[ltid].slot[CTX_CMA_RX_ID] < NB_CMA_CHANNELS) )
	2034	{
	2035	_printf("\n[GIET_ERROR] in _sys_nic_alloc() : "
	2036	"NIC_RX or CMA_RX channel already allocated for thread %x\n", trdid );
	2037	_nic_rx_channel_alloc[nic_channel] = 0;
	2038	_cma_channel_alloc[cma_channel] = 0;
[714]	2039
	2040	return SYSCALL_CHANNEL_ALREADY_ALLOCATED;
[709]	2041	}
	2042	else
	2043	{
	2044	psched->context[ltid].slot[CTX_NIC_RX_ID] = nic_channel;
	2045	psched->context[ltid].slot[CTX_CMA_RX_ID] = cma_channel;
	2046	}
	2047	}
	2048	else // is_tx
	2049	{
	2050	if ( (psched->context[ltid].slot[CTX_NIC_TX_ID] < NB_NIC_CHANNELS) \|\|
	2051	(psched->context[ltid].slot[CTX_CMA_TX_ID] < NB_CMA_CHANNELS) )
	2052	{
	2053	_printf("\n[GIET_ERROR] in _sys_nic_alloc() : "
	2054	"NIC_TX or CMA_TX channel already allocated for thread %x\n", trdid );
	2055	_nic_tx_channel_alloc[nic_channel] = 0;
	2056	_cma_channel_alloc[cma_channel] = 0;
[714]	2057
	2058	return SYSCALL_CHANNEL_ALREADY_ALLOCATED;
[709]	2059	}
	2060	else
	2061	{
	2062	psched->context[ltid].slot[CTX_NIC_TX_ID] = nic_channel;
	2063	psched->context[ltid].slot[CTX_CMA_TX_ID] = cma_channel;
	2064	}
	2065	}
	2066	} // end loop on threads
	2067
[614]	2068	/////////////////////////////////////////////////////////////////////////////////
	2069	// Step 2: loop on all the clusters //
	2070	// Allocate the kernel containers and status, compute the container and the //
	2071	// status physical addresses, fill and synchronize the kernel CHBUF descriptor //
	2072	/////////////////////////////////////////////////////////////////////////////////
	2073
[494]	2074	// physical addresses to be registered in the CMA registers
[459]	2075	unsigned long long nic_chbuf_pbase; // NIC chbuf physical address
	2076	unsigned long long ker_chbuf_pbase; // kernel chbuf physical address
[449]	2077
[614]	2078	// allocate one kernel container and one status variable per cluster in the
	2079	// (xmax / ymax) mesh
[528]	2080	unsigned int cx; // cluster X coordinate
	2081	unsigned int cy; // cluster Y coordinate
	2082	unsigned int index; // container index in chbuf
	2083	unsigned int vaddr; // virtual address
	2084	unsigned long long cont_paddr; // container physical address
[614]	2085	unsigned long long sts_paddr; // container status physical address
[494]	2086
[528]	2087	unsigned int flags; // for _v2p_translate()
	2088
[494]	2089	for ( cx = 0 ; cx < xmax ; cx++ )
[478]	2090	{
[494]	2091	for ( cy = 0 ; cy < ymax ; cy++ )
[478]	2092	{
	2093	// compute index in chbuf
[494]	2094	index = (cx * ymax) + cy;
[478]	2095
[494]	2096	// allocate the kernel container
[478]	2097	vaddr = (unsigned int)_remote_malloc( NIC_CONTAINER_SIZE, cx, cy );
	2098
[494]	2099	if ( vaddr == 0 ) // not enough kernel heap memory in cluster[cx,cy]
	2100	{
[709]	2101	_printf("\n[GIET_ERROR] in _sys_nic_alloc() : "
[714]	2102	"not enough kernel heap in cluster[%d,%d]\n", cx, cy );
	2103
	2104	return SYSCALL_OUT_OF_KERNEL_HEAP_MEMORY;
[494]	2105	}
	2106
[478]	2107	// compute container physical address
[528]	2108	cont_paddr = _v2p_translate( vaddr , &flags );
[478]	2109
[614]	2110	// checking container address alignment
	2111	if ( cont_paddr & 0x3F )
	2112	{
[709]	2113	_printf("\n[GIET ERROR] in _sys_nic_alloc() : "
[714]	2114	"container address in cluster[%d,%d] not aligned\n", cx, cy);
	2115
	2116	return SYSCALL_ADDRESS_NON_ALIGNED;
[614]	2117	}
	2118
	2119	#if GIET_DEBUG_NIC
[714]	2120	_printf("\n[DEBUG NIC] _sys_nic_alloc() at cycle %d\n"
	2121	"thread %x allocates a container in cluster[%d,%d] / vaddr = %x / paddr = %l\n",
	2122	-get_proctime() , trdid , cx , cy , vaddr, cont_paddr );
[614]	2123	#endif
	2124
	2125	// allocate the kernel container status
	2126	// it occupies 64 bytes but only last bit is useful (1 for full and 0 for empty)
	2127	vaddr = (unsigned int)_remote_malloc( 64, cx, cy );
	2128
	2129	if ( vaddr == 0 ) // not enough kernel heap memory in cluster[cx,cy]
	2130	{
[709]	2131	_printf("\n[GIET_ERROR] in _sys_nic_alloc() : "
	2132	"not enough kernel heap in cluster[%d,%d]\n", cx, cy );
[714]	2133
	2134	return SYSCALL_OUT_OF_KERNEL_HEAP_MEMORY;
[614]	2135	}
	2136
	2137	// compute status physical address
	2138	sts_paddr = _v2p_translate( vaddr , &flags );
	2139
	2140	// checking status address alignment
	2141	if ( sts_paddr & 0x3F )
	2142	{
[709]	2143	_printf("\n[GIET ERROR] in _sys_nic_alloc() : "
[714]	2144	"status address in cluster[%d,%d] not aligned\n", cx, cy);
	2145
	2146	return SYSCALL_ADDRESS_NON_ALIGNED;
[614]	2147	}
	2148
[494]	2149	// initialize chbuf entry
[614]	2150	// The buffer descriptor has the following structure:
	2151	// - the 26 LSB bits contain bits[6:31] of the buffer physical address
	2152	// - the 26 following bits contain bits[6:31] of the physical address where the
	2153	// buffer status is located
	2154	// - the 12 MSB bits contain the common address extension of the buffer and its
	2155	// status
	2156	if ( is_rx )
	2157	_nic_ker_rx_chbuf[nic_channel].buf_desc[index] =
	2158	(unsigned long long)
	2159	((sts_paddr & 0xFFFFFFFFULL) >> 6) +
	2160	(((cont_paddr & 0xFFFFFFFFFFFULL) >> 6) << 26);
	2161	else
	2162	_nic_ker_tx_chbuf[nic_channel].buf_desc[index] =
	2163	(unsigned long long)
	2164	((sts_paddr & 0xFFFFFFC0ULL) >> 6) +
	2165	(((cont_paddr & 0xFFFFFFFFFC0ULL) >> 6) << 26);
[478]	2166
	2167	#if GIET_DEBUG_NIC
[714]	2168	_printf("\n[DEBUG NIC] _sys_nic_alloc() at cycle %d\n"
	2169	"thread %x allocates a status in cluster[%d,%d] / vaddr = %x / paddr = %l\n"
	2170	" descriptor = %l\n",
	2171	_get_proctime() , trdid , cx , cy , vaddr, sts_paddr,
[614]	2172	(unsigned long long)((sts_paddr & 0xFFFFFFFFULL) >> 6) +
	2173	(((cont_paddr & 0xFFFFFFFFFFFULL) >> 6) << 26) );
[478]	2174	#endif
	2175	}
	2176	}
	2177
[494]	2178	// complete kernel chbuf initialisation
	2179	if ( is_rx )
	2180	{
[614]	2181	_nic_ker_rx_chbuf[nic_channel].xmax = xmax;
	2182	_nic_ker_rx_chbuf[nic_channel].ymax = ymax;
[494]	2183	}
	2184	else
	2185	{
[614]	2186	_nic_ker_tx_chbuf[nic_channel].xmax = xmax;
	2187	_nic_ker_tx_chbuf[nic_channel].ymax = ymax;
[494]	2188	}
	2189
[449]	2190	// compute the kernel chbuf descriptor physical address
[614]	2191	if ( is_rx ) vaddr = (unsigned int)( &_nic_ker_rx_chbuf[nic_channel] );
	2192	else vaddr = (unsigned int)( &_nic_ker_tx_chbuf[nic_channel] );
[440]	2193
[528]	2194	ker_chbuf_pbase = _v2p_translate( vaddr , &flags );
	2195
[459]	2196	#if GIET_DEBUG_NIC
[714]	2197	_printf("\n[DEBUG NIC] _sys_nic_alloc() at cycle %d\n"
	2198	"thread %x initialise kernel chbuf / vaddr = %x / paddr = %l\n",
	2199	_get_proctime() , trdid , vaddr , ker_chbuf_pbase );
[459]	2200	#endif
[440]	2201
[459]	2202	// sync the kernel chbuf in L2 after write in L2
[614]	2203	_mmc_sync( ker_chbuf_pbase, sizeof( ker_chbuf_t ) );
[459]	2204
[614]	2205	///////////////////////////////////////////////////////////////
	2206	// Step 3: compute the NIC chbuf descriptor physical address //
	2207	///////////////////////////////////////////////////////////////
	2208
	2209	unsigned int offset;
	2210	if ( is_rx ) offset = 0x4100;
	2211	else offset = 0x4110;
	2212	nic_chbuf_pbase = (((unsigned long long)((X_IO << Y_WIDTH) + Y_IO))<<32) \|
	2213	(SEG_NIC_BASE + (nic_channel<<15) + offset);
	2214
	2215	#if GIET_DEBUG_NIC
[714]	2216	_printf("\n[DEBUG NIC] _sys_nic_alloc() at cycle %d\n"
	2217	"thread %x get NIC chbuf paddr = %l\n",
	2218	_get_proctime() , trdid , nic_chbuf_pbase );
[614]	2219	#endif
	2220
	2221	////////////////////////////////////////////////////////////////////////////////
	2222	// Step 4: initialize CMA registers defining the source & destination chbufs //
	2223	////////////////////////////////////////////////////////////////////////////////
	2224
[459]	2225	if ( is_rx ) // NIC to kernel
	2226	{
	2227	_cma_set_register( cma_channel, CHBUF_SRC_DESC , (unsigned int)(nic_chbuf_pbase) );
	2228	_cma_set_register( cma_channel, CHBUF_SRC_EXT , (unsigned int)(nic_chbuf_pbase>>32) );
	2229	_cma_set_register( cma_channel, CHBUF_SRC_NBUFS, 2 );
	2230	_cma_set_register( cma_channel, CHBUF_DST_DESC , (unsigned int)(ker_chbuf_pbase) );
	2231	_cma_set_register( cma_channel, CHBUF_DST_EXT , (unsigned int)(ker_chbuf_pbase>>32) );
[494]	2232	_cma_set_register( cma_channel, CHBUF_DST_NBUFS, xmax * ymax );
[459]	2233	}
	2234	else // kernel to NIC
	2235	{
	2236	_cma_set_register( cma_channel, CHBUF_SRC_DESC , (unsigned int)(ker_chbuf_pbase) );
	2237	_cma_set_register( cma_channel, CHBUF_SRC_EXT , (unsigned int)(ker_chbuf_pbase>>32) );
[494]	2238	_cma_set_register( cma_channel, CHBUF_SRC_NBUFS, xmax * ymax );
[459]	2239	_cma_set_register( cma_channel, CHBUF_DST_DESC , (unsigned int)(nic_chbuf_pbase) );
	2240	_cma_set_register( cma_channel, CHBUF_DST_EXT , (unsigned int)(nic_chbuf_pbase>>32) );
	2241	_cma_set_register( cma_channel, CHBUF_DST_NBUFS, 2 );
	2242	}
	2243
[494]	2244	#if GIET_DEBUG_NIC
[714]	2245	_printf("\n[DEBUG NIC] _sys_nic_alloc() at cycle %d\n"
	2246	"thread %x exit\n",
	2247	_get_proctime() , trdid );
[494]	2248	#endif
	2249
[714]	2250	return SYSCALL_OK;
[494]	2251	} // end _sys_nic_alloc()
	2252
	2253
[709]	2254	//////////////////////////////////////////
[714]	2255	int _sys_nic_release( unsigned int is_rx ) // NOTE: not a syscall: used by _ctx_kill_thread()
[695]	2256	{
[709]	2257	unsigned int trdid = _get_thread_trdid();
	2258
	2259	unsigned int nic_channel;
	2260	unsigned int cma_channel;
	2261
	2262	// update the kernel tables
[695]	2263	if ( is_rx )
[709]	2264	{
	2265	nic_channel = _get_context_slot( CTX_NIC_RX_ID );
	2266	cma_channel = _get_context_slot( CTX_CMA_RX_ID );
	2267
	2268	if ( (nic_channel >= NB_NIC_CHANNELS) )
	2269	{
	2270	_printf("\n[GIET ERROR] in _sys_nic_release() : "
	2271	"NIC_RX channel already released for thread %x\n", trdid );
[714]	2272
	2273	return SYSCALL_CHANNEL_NON_ALLOCATED;
[709]	2274	}
	2275	if ( (cma_channel >= NB_CMA_CHANNELS) )
	2276	{
	2277	_printf("\n[GIET ERROR] in _sys_nic_release() : "
	2278	"CMA_RX channel already released for thread %x\n", trdid );
[714]	2279
	2280	return SYSCALL_CHANNEL_NON_ALLOCATED;
[709]	2281	}
	2282
	2283	// atomically decrement the NIC and CMA channel allocators
	2284	_atomic_increment( &_nic_rx_channel_alloc[nic_channel] , -1 );
	2285	_atomic_increment( &_cma_channel_alloc[cma_channel] , -1 );
	2286
	2287	// stop the NIC and CMA peripherals channels if no more users
	2288	if ( (_nic_rx_channel_alloc[nic_channel] == 0) &&
	2289	(_cma_channel_alloc[cma_channel] == 0) ) _sys_nic_stop( 1 );
	2290
	2291	// reset the calling thread context slots
	2292	_set_context_slot( CTX_NIC_RX_ID , 0xFFFFFFFF );
	2293	_set_context_slot( CTX_CMA_RX_ID , 0xFFFFFFFF );
	2294	}
[695]	2295	else
[709]	2296	{
	2297	nic_channel = _get_context_slot( CTX_NIC_TX_ID );
	2298	cma_channel = _get_context_slot( CTX_CMA_TX_ID );
[695]	2299
[709]	2300	if ( (nic_channel >= NB_NIC_CHANNELS) )
	2301	{
	2302	_printf("\n[GIET ERROR] in _sys_nic_release() : "
	2303	"NIC_TX channel already released for thread %x\n", trdid );
[714]	2304
	2305	return SYSCALL_CHANNEL_NON_ALLOCATED;
[709]	2306	}
	2307	if ( (cma_channel >= NB_CMA_CHANNELS) )
	2308	{
	2309	_printf("\n[GIET ERROR] in _sys_nic_release() : "
	2310	"CMA_TX channel already released for thread %x\n", trdid );
[714]	2311
	2312	return SYSCALL_CHANNEL_NON_ALLOCATED;
[709]	2313	}
[695]	2314
[709]	2315	// atomically decrement the NIC and CMA channel allocators
	2316	_atomic_increment( &_nic_tx_channel_alloc[nic_channel] , -1 );
	2317	_atomic_increment( &_cma_channel_alloc[cma_channel] , -1 );
	2318
	2319	// stop the NIC and CMA peripherals channels if no more users
	2320	if ( (_nic_tx_channel_alloc[nic_channel] == 0) &&
	2321	(_cma_channel_alloc[cma_channel] == 0) ) _sys_nic_stop( 0 );
[695]	2322
[709]	2323	// reset the calling thread context slots
	2324	_set_context_slot( CTX_NIC_TX_ID , 0xFFFFFFFF );
	2325	_set_context_slot( CTX_CMA_TX_ID , 0xFFFFFFFF );
	2326	}
	2327
[714]	2328	return SYSCALL_OK;
[709]	2329	} // end sys_nic_release()
	2330
	2331
[695]	2332	////////////////////////////////////////
[709]	2333	int _sys_nic_start( unsigned int is_rx )
[494]	2334	{
[709]	2335	unsigned int trdid = _get_context_slot( CTX_TRDID_ID );
	2336
[494]	2337	unsigned int nic_channel;
	2338	unsigned int cma_channel;
	2339
[709]	2340	// get NIC channel index and CMA channel index from thread context
[494]	2341	if ( is_rx )
	2342	{
	2343	nic_channel = _get_context_slot( CTX_NIC_RX_ID );
	2344	cma_channel = _get_context_slot( CTX_CMA_RX_ID );
	2345	}
	2346	else
	2347	{
	2348	nic_channel = _get_context_slot( CTX_NIC_TX_ID );
	2349	cma_channel = _get_context_slot( CTX_CMA_TX_ID );
	2350	}
	2351
	2352	#if GIET_DEBUG_NIC
[714]	2353	_printf("\n[DEBUG NIC] _sys_nic_start() at cycle %d\n"
	2354	"thread %x enter / NIC channel = %d / CMA channel = %d\n",
	2355	_get_proctime() , trdid , nic_channel, cma_channel );
[494]	2356	#endif
	2357
	2358	// check NIC and CMA channels index
[709]	2359	if ( nic_channel >= NB_NIC_CHANNELS )
[494]	2360	{
[709]	2361	_printf("\n[GIET_ERROR] in _sys_nic_start() : "
	2362	"illegal NIC channel for thread %x\n", trdid );
	2363	return -1111;
[494]	2364	}
	2365	if ( cma_channel >= NB_CMA_CHANNELS )
	2366	{
[709]	2367	_printf("\n[GIET_ERROR] in _sys_nic_start() : "
	2368	"illegal CMA channel for thread %x\n", trdid );
	2369	return -1111;
[494]	2370	}
	2371
[449]	2372	// start CMA transfer
[478]	2373	_cma_set_register( cma_channel, CHBUF_BUF_SIZE , NIC_CONTAINER_SIZE );
[505]	2374	_cma_set_register( cma_channel, CHBUF_PERIOD , 0 ); // OUT_OF_ORDER
[449]	2375	_cma_set_register( cma_channel, CHBUF_RUN , 1 );
	2376
	2377	// activates NIC channel
[614]	2378	_nic_channel_start( nic_channel, is_rx, GIET_NIC_MAC4, GIET_NIC_MAC2 );
[459]	2379
	2380	#if GIET_DEBUG_NIC
[714]	2381	_printf("\n[DEBUG NIC] _sys_nic_start() at cycle %d\n"
	2382	"thread %d exit\n",
	2383	_get_proctime() , trdid );
[459]	2384	#endif
	2385
[714]	2386	return SYSCALL_OK;
[505]	2387	} // end _sys_nic_start()
[449]	2388
[494]	2389
[449]	2390	//////////////////////////////////////
	2391	int _sys_nic_move( unsigned int is_rx,
	2392	void* buffer )
	2393	{
[709]	2394	unsigned int trdid = _get_context_slot( CTX_TRDID_ID );
[449]	2395
[709]	2396	unsigned int channel;
	2397
[459]	2398	#if GIET_DEBUG_NIC
[714]	2399	_printf("\n[DEBUG NIC] _sys_nic_move() at cycle %d\n",
	2400	"thread %x enters\n",
	2401	_get_proctime() , trdid );
[459]	2402	#endif
	2403
[709]	2404	// get NIC channel index from thread context
	2405	if ( is_rx ) channel = _get_context_slot( CTX_NIC_RX_ID );
	2406	else channel = _get_context_slot( CTX_NIC_TX_ID );
	2407
[494]	2408	// check NIC channel index
	2409	if ( channel >= NB_NIC_CHANNELS )
	2410	{
[709]	2411	_printf("\n[GIET_ERROR] in _sys_nic_move() : "
[714]	2412	"NIC channel non allocated for thread %x\n", trdid );
	2413
	2414	return SYSCALL_CHANNEL_NON_ALLOCATED;
[494]	2415	}
	2416
	2417	// get kernel chbuf virtual address
[614]	2418	ker_chbuf_t* ker_chbuf;
	2419	if ( is_rx ) ker_chbuf = &_nic_ker_rx_chbuf[channel];
	2420	else ker_chbuf = &_nic_ker_tx_chbuf[channel];
[494]	2421
	2422	// get xmax / ymax parameters
[614]	2423	unsigned int xmax = ker_chbuf->xmax;
	2424	unsigned int ymax = ker_chbuf->ymax;
[494]	2425
[709]	2426	// get cluster coordinates for the processor running the calling thread
[478]	2427	unsigned int procid = _get_procid();
	2428	unsigned int cx = procid >> (Y_WIDTH + P_WIDTH);
	2429	unsigned int cy = (procid >> P_WIDTH) & ((1<<Y_WIDTH)-1);
	2430
[494]	2431	// check processor coordinates / (xmax,ymax)
[714]	2432	if ( (cx >= xmax) \|\| (cy >= ymax) )
[494]	2433	{
[714]	2434	_printf("\n[GIET_ERROR] in _sys_nic_move(): "
	2435	"processor coordinates [%d,%d] larger than (xmax,ymax) = [%d,%d]\n",
	2436	cx , cy , xmax , ymax );
	2437
	2438	return SYSCALL_ILLEGAL_XY_ARGUMENTS;
[494]	2439	}
	2440
[614]	2441	unsigned long long usr_buf_paddr; // user buffer physical address
	2442	unsigned long long ker_buf_paddr; // kernel buffer physical address
	2443	unsigned long long ker_sts_paddr; // kernel buffer status physical address
	2444	unsigned long long ker_buf_desc; // kernel buffer descriptor
	2445	unsigned int ker_sts; // kernel buffer status (full or empty)
	2446	unsigned int index; // kernel buffer index in chbuf
	2447	unsigned int flags; // for _v2P_translate
[459]	2448
	2449	// Compute user buffer physical address and check access rights
[614]	2450	usr_buf_paddr = _v2p_translate( (unsigned int)buffer , &flags );
[478]	2451
[440]	2452	if ( (flags & PTE_U) == 0 )
	2453	{
[714]	2454	_printf("\n[GIET ERROR] in _sys_nic_tx_move() : "
	2455	"buffer address non user accessible\n");
	2456
	2457	return SYSCALL_ADDRESS_NON_USER_ACCESSIBLE;
[440]	2458	}
	2459
[459]	2460	#if GIET_DEBUG_NIC
[714]	2461	_printf("\n[DEBUG NIC] _sys_nic_move() at cycle %d\n"
	2462	"thread %x get user buffer : paddr = %l\n",
	2463	_get_proctime() , trdid , usr_buf_paddr );
[459]	2464	#endif
[440]	2465
[614]	2466	// compute buffer index, buffer descriptor paddr and buffer status paddr
	2467	index = (ymax * cx) + cy;
	2468	ker_buf_desc = ker_chbuf->buf_desc[index];
	2469	ker_sts_paddr = ((ker_buf_desc & 0xFFF0000000000000ULL) >> 20) +
	2470	((ker_buf_desc & 0x3FFFFFFULL) << 6);
[459]	2471
[614]	2472	#if GIET_DEBUG_NIC
[714]	2473	_printf("\n[DEBUG NIC] _sys_nic_move() at cycle %d\n"
	2474	"thread %x get ker_buf_desc %d / paddr = %l\n",
	2475	_get_proctime(), trdid , index , ker_buf_desc );
[614]	2476	#endif
	2477
[494]	2478	// poll local kernel container status until success
[478]	2479	while ( 1 )
[449]	2480	{
[478]	2481	// inval buffer descriptor in L2 before read in L2
[614]	2482	_mmc_inval( ker_sts_paddr, 4 );
	2483	ker_sts = _physical_read( ker_sts_paddr );
[459]	2484
	2485	#if GIET_DEBUG_NIC
[714]	2486	_printf("\n[DEBUG NIC] _sys_nic_move() at cycle %d\n"
	2487	"thread %x get status %d / paddr = %l / status = %x\n",
	2488	_get_proctime() , trdid , index , ker_sts_paddr, ker_sts );
[459]	2489	#endif
	2490
[478]	2491	// test buffer status and break if found
[614]	2492	if ( ( is_rx != 0 ) && ( ker_sts == 0x1 ) ) break;
	2493	if ( ( is_rx == 0 ) && ( ker_sts == 0 ) ) break;
[449]	2494	}
[459]	2495
	2496	// compute kernel buffer physical address
[614]	2497	ker_buf_paddr = (ker_buf_desc & 0xFFFFFFFFFC000000ULL) >> 20;
[449]	2498
[494]	2499	// move one container
	2500	if ( is_rx ) // RX transfer
[459]	2501	{
	2502	// inval kernel buffer in L2 before read in L2
[614]	2503	_mmc_inval( ker_buf_paddr, NIC_CONTAINER_SIZE );
[449]	2504
[459]	2505	// transfer data from kernel buffer to user buffer
[614]	2506	_physical_memcpy( usr_buf_paddr,
	2507	ker_buf_paddr,
[478]	2508	NIC_CONTAINER_SIZE );
	2509	#if GIET_DEBUG_NIC
[714]	2510	_printf("\n[DEBUG NIC] _sys_nic_move() at cycle %d\n"
	2511	"thread %x transfer kernel buffer %l to user buffer %l\n",
	2512	_get_proctime() , trdid , ker_buf_paddr , usr_buf_paddr );
[478]	2513	#endif
[449]	2514
[459]	2515	}
[494]	2516	else // TX transfer
[459]	2517	{
	2518	// transfer data from user buffer to kernel buffer
[614]	2519	_physical_memcpy( ker_buf_paddr,
	2520	usr_buf_paddr,
[478]	2521	NIC_CONTAINER_SIZE );
[449]	2522
[459]	2523	// sync kernel buffer in L2 after write in L2
[614]	2524	_mmc_sync( ker_buf_paddr, NIC_CONTAINER_SIZE );
[478]	2525
	2526	#if GIET_DEBUG_NIC
[714]	2527	_printf("\n[DEBUG NIC] _sys_nic_move() at cycle %d\n"
	2528	"thread %x transfer user buffer %l to kernel buffer %l\n",
	2529	_get_proctime() , trdid , usr_buf_paddr , ker_buf_paddr );
[478]	2530	#endif
	2531
[459]	2532	}
	2533
[478]	2534	// update kernel chbuf status
[614]	2535	if ( is_rx ) _physical_write ( ker_sts_paddr, 0 );
	2536	else _physical_write ( ker_sts_paddr, 0x1 );
[459]	2537
	2538	// sync kernel chbuf in L2 after write in L2
[614]	2539	_mmc_sync( ker_sts_paddr, 4 );
[459]	2540
	2541	#if GIET_DEBUG_NIC
[714]	2542	_printf("\n[DEBUG NIC] _sys_nic_move() at cycle %d\n"
	2543	"thread %x exit\n",
	2544	_get_proctime() , trdid );
[459]	2545	#endif
	2546
[714]	2547	return SYSCALL_OK;
[449]	2548	} // end _sys_nic_move()
[440]	2549
[494]	2550
[709]	2551	///////////////////////////////////////
	2552	int _sys_nic_stop( unsigned int is_rx )
[440]	2553	{
[709]	2554	unsigned int trdid = _get_context_slot( CTX_TRDID_ID );
	2555
[449]	2556	unsigned int nic_channel;
	2557	unsigned int cma_channel;
[440]	2558
[449]	2559	// get NIC channel index and CMA channel index
	2560	if ( is_rx )
[440]	2561	{
[449]	2562	nic_channel = _get_context_slot( CTX_NIC_RX_ID );
	2563	cma_channel = _get_context_slot( CTX_CMA_RX_ID );
[440]	2564	}
[449]	2565	else
	2566	{
	2567	nic_channel = _get_context_slot( CTX_NIC_TX_ID );
	2568	cma_channel = _get_context_slot( CTX_CMA_TX_ID );
	2569	}
[440]	2570
[494]	2571	// check NIC and CMA channels index
[709]	2572	if ( nic_channel >= NB_NIC_CHANNELS )
[440]	2573	{
[709]	2574	_printf("\n[GIET_ERROR] in _sys_nic_stop() : "
[714]	2575	"NIC channel non allocated for thread %x\n", trdid );
	2576
	2577	return SYSCALL_CHANNEL_NON_ALLOCATED;
[440]	2578	}
[449]	2579	if ( cma_channel >= NB_CMA_CHANNELS )
[440]	2580	{
[709]	2581	_printf("\n[GIET_ERROR] in _sys_nic_stop() : "
[714]	2582	"CMA channel non allocated for thread %x\n", trdid );
	2583
	2584	return SYSCALL_CHANNEL_NON_ALLOCATED;
[440]	2585	}
	2586
[709]	2587	// desactivates the CMA channel
	2588	_cma_set_register( cma_channel, CHBUF_RUN , 0 );
	2589
	2590	// wait until CMA channel IDLE
	2591	unsigned int volatile status;
	2592	do
	2593	{
	2594	status = _cma_get_register( cma_channel, CHBUF_STATUS );
[714]	2595	}
	2596	while ( status );
[709]	2597
[449]	2598	// desactivates the NIC channel
	2599	_nic_channel_stop( nic_channel, is_rx );
[440]	2600
[714]	2601	return SYSCALL_OK;
[494]	2602	} // end _sys_nic_stop()
[440]	2603
[459]	2604	////////////////////////////////////////
[709]	2605	int _sys_nic_clear( unsigned int is_rx )
[459]	2606	{
[709]	2607	unsigned int trdid = _get_context_slot( CTX_TRDID_ID );
[459]	2608
[709]	2609	unsigned int channel;
	2610
[459]	2611	// get NIC channel
[709]	2612	if ( is_rx ) channel = _get_context_slot( CTX_NIC_RX_ID );
	2613	else channel = _get_context_slot( CTX_NIC_TX_ID );
[459]	2614
[709]	2615	if ( channel >= NB_NIC_CHANNELS )
[459]	2616	{
[709]	2617	_printf("\n[GIET_ERROR] in _sys_nic_clear() : "
[714]	2618	"NIC channel non allocated for thread %x\n", trdid );
	2619
	2620	return SYSCALL_CHANNEL_NON_ALLOCATED;
[459]	2621	}
	2622
	2623	if ( is_rx )
	2624	{
	2625	_nic_set_global_register( NIC_G_NPKT_RX_G2S_RECEIVED , 0 );
	2626	_nic_set_global_register( NIC_G_NPKT_RX_DES_TOO_SMALL , 0 );
	2627	_nic_set_global_register( NIC_G_NPKT_RX_DES_TOO_BIG , 0 );
	2628	_nic_set_global_register( NIC_G_NPKT_RX_DES_MFIFO_FULL , 0 );
	2629	_nic_set_global_register( NIC_G_NPKT_RX_DES_CRC_FAIL , 0 );
	2630	_nic_set_global_register( NIC_G_NPKT_RX_DISPATCH_RECEIVED , 0 );
	2631	_nic_set_global_register( NIC_G_NPKT_RX_DISPATCH_BROADCAST , 0 );
	2632	_nic_set_global_register( NIC_G_NPKT_RX_DISPATCH_DST_FAIL , 0 );
	2633	_nic_set_global_register( NIC_G_NPKT_RX_DISPATCH_CH_FULL , 0 );
	2634	}
	2635	else
	2636	{
	2637	_nic_set_global_register( NIC_G_NPKT_TX_DISPATCH_RECEIVED , 0 );
	2638	_nic_set_global_register( NIC_G_NPKT_TX_DISPATCH_TRANSMIT , 0 );
	2639	_nic_set_global_register( NIC_G_NPKT_TX_DISPATCH_TOO_BIG , 0 );
	2640	_nic_set_global_register( NIC_G_NPKT_TX_DISPATCH_TOO_SMALL , 0 );
	2641	_nic_set_global_register( NIC_G_NPKT_TX_DISPATCH_SRC_FAIL , 0 );
	2642	_nic_set_global_register( NIC_G_NPKT_TX_DISPATCH_BYPASS , 0 );
	2643	_nic_set_global_register( NIC_G_NPKT_TX_DISPATCH_BROADCAST , 0 );
	2644	}
[714]	2645	return SYSCALL_OK;
[494]	2646	} // en _sys_nic_clear()
[459]	2647
	2648	////////////////////////////////////////
[709]	2649	int _sys_nic_stats( unsigned int is_rx )
[459]	2650	{
[709]	2651	unsigned int trdid = _get_context_slot( CTX_TRDID_ID );
	2652
[459]	2653	unsigned int nic_channel;
	2654
	2655	// get NIC channel
	2656	if ( is_rx ) nic_channel = _get_context_slot( CTX_NIC_RX_ID );
	2657	else nic_channel = _get_context_slot( CTX_NIC_TX_ID );
	2658
[709]	2659	if ( nic_channel >= NB_NIC_CHANNELS )
[459]	2660	{
[709]	2661	_printf("\n[GIET_ERROR] in _sys_nic_stats() : "
[714]	2662	"NIC channel non allocated for thread %x\n", trdid );
	2663
	2664	return SYSCALL_CHANNEL_NON_ALLOCATED;
[459]	2665	}
	2666
	2667	if ( is_rx )
	2668	{
	2669	unsigned int received = _nic_get_global_register( NIC_G_NPKT_RX_G2S_RECEIVED );
	2670	unsigned int too_small = _nic_get_global_register( NIC_G_NPKT_RX_DES_TOO_SMALL );
	2671	unsigned int too_big = _nic_get_global_register( NIC_G_NPKT_RX_DES_TOO_BIG );
	2672	unsigned int fifo_full = _nic_get_global_register( NIC_G_NPKT_RX_DES_MFIFO_FULL );
	2673	unsigned int crc_fail = _nic_get_global_register( NIC_G_NPKT_RX_DES_CRC_FAIL );
	2674	unsigned int broadcast = _nic_get_global_register( NIC_G_NPKT_RX_DISPATCH_BROADCAST );
	2675	unsigned int dst_fail = _nic_get_global_register( NIC_G_NPKT_RX_DISPATCH_DST_FAIL );
	2676	unsigned int ch_full = _nic_get_global_register( NIC_G_NPKT_RX_DISPATCH_CH_FULL );
	2677
	2678	_printf("\n### Network Controller RX Statistics ###\n"
	2679	"- packets received : %d\n"
	2680	"- too small : %d\n"
	2681	"- too big : %d\n"
	2682	"- fifo full : %d\n"
	2683	"- crc fail : %d\n"
	2684	"- dst mac fail : %d\n"
	2685	"- channel full : %d\n"
	2686	"- broadcast : %d\n",
	2687	received,
	2688	too_small,
	2689	too_big,
	2690	fifo_full,
	2691	crc_fail,
	2692	dst_fail,
	2693	ch_full,
	2694	broadcast );
	2695	}
	2696	else
	2697	{
	2698	unsigned int received = _nic_get_global_register( NIC_G_NPKT_TX_DISPATCH_RECEIVED );
	2699	unsigned int too_big = _nic_get_global_register( NIC_G_NPKT_TX_DISPATCH_TOO_BIG );
	2700	unsigned int too_small = _nic_get_global_register( NIC_G_NPKT_TX_DISPATCH_TOO_SMALL );
	2701	unsigned int src_fail = _nic_get_global_register( NIC_G_NPKT_TX_DISPATCH_SRC_FAIL );
	2702	unsigned int bypass = _nic_get_global_register( NIC_G_NPKT_TX_DISPATCH_BYPASS );
	2703	unsigned int broadcast = _nic_get_global_register( NIC_G_NPKT_TX_DISPATCH_BROADCAST );
	2704
	2705	_printf("\n### Network Controller TX Statistics ###\n"
	2706	"- packets received : %d\n"
	2707	"- too small : %d\n"
	2708	"- too big : %d\n"
	2709	"- src mac fail : %d\n"
	2710	"- bypass : %d\n"
	2711	"- broadcast : %d\n",
	2712	received,
	2713	too_big,
	2714	too_small,
	2715	src_fail,
	2716	bypass,
	2717	broadcast );
	2718	}
[714]	2719	return SYSCALL_OK;
[494]	2720	} // end _sys_nic_stats()
[459]	2721
[709]	2722	#endif
	2723
[440]	2724	/////////////////////////////////////////////////////////////////////////////////////////
	2725	// FBF related syscall handlers
	2726	/////////////////////////////////////////////////////////////////////////////////////////
	2727
[714]	2728	//////////////////////////////////////
	2729	int _sys_fbf_size( unsigned int* width,
	2730	unsigned int* height )
	2731	{
	2732	if ( USE_FBF == 0 )
	2733	{
	2734	*width = 0;
	2735	*height = 0;
	2736	}
	2737	else
	2738	{
	2739	*width = FBUF_X_SIZE;
	2740	*height = FBUF_Y_SIZE;
	2741	}
	2742
	2743	return SYSCALL_OK;
	2744	}
	2745
	2746	////////////////////
	2747	int _sys_fbf_alloc()
	2748	{
	2749	mapping_header_t header = (mapping_header_t )SEG_BOOT_MAPPING_BASE;
	2750	mapping_vspace_t *vspace = _get_vspace_base(header);
	2751	mapping_thread_t *thread = _get_thread_base(header);
	2752
	2753	// compute number of users
	2754	unsigned int vsid = _get_context_slot(CTX_VSID_ID);
	2755	unsigned int users = vspace[vsid].threads;
	2756
	2757	// access FBF allocator
	2758	// register it in all threads contexts
	2759	if ( _atomic_test_and_set( &_fbf_alloc , users ) == 0 ) // FBF available
	2760	{
	2761	unsigned int min = vspace[vsid].thread_offset;
	2762	unsigned int max = min + users;
	2763	unsigned int tid;
	2764	for ( tid = min ; tid < max ; tid++ )
	2765	{
	2766	unsigned int y_size = header->y_size;
	2767	unsigned int cid = thread[tid].clusterid;
	2768	unsigned int x = cid / y_size;
	2769	unsigned int y = cid % y_size;
	2770	unsigned int p = thread[tid].proclocid;
	2771	unsigned int ltid = thread[tid].ltid;
	2772	static_scheduler_t* psched = (static_scheduler_t*)_schedulers[x][y][p];
	2773	_atomic_or( &psched->context[ltid].slot[CTX_LOCKS_ID] , LOCKS_MASK_FBF );
	2774	}
	2775	return SYSCALL_OK;
	2776	}
	2777	else // FBF already allocated
	2778	{
	2779	return SYSCALL_SHARED_PERIPHERAL_BUSY;
	2780	}
	2781	}
	2782
	2783	//////////////////////
	2784	int _sys_fbf_release() // not a syscall: used by _ctx_kill_thread()
	2785	{
	2786	// get calling thread scheduler, ltid and trdid
	2787	static_scheduler_t* psched = _get_sched();
	2788	unsigned int ltid = _get_thread_ltid();
	2789	unsigned int trdid = _get_thread_trdid();
	2790
	2791	if ( (psched->context[ltid].slot[CTX_LOCKS_ID] & LOCKS_MASK_FBF) == 0 )
	2792	{
	2793	_printf("\n[GIET ERROR] in _sys_fbf_release() : "
	2794	"FBF not allocated to thread %x\n", trdid );
	2795
	2796	return SYSCALL_CHANNEL_NON_ALLOCATED;
	2797	}
	2798
	2799	// decrement FBF allocator
	2800	// reset the calling thread context
	2801	_atomic_increment( &_fbf_alloc , 0xFFFFFFFF );
	2802	_atomic_and( &psched->context[ltid].slot[CTX_LOCKS_ID] , ~LOCKS_MASK_FBF );
	2803
	2804	return SYSCALL_OK;
	2805	}
	2806
[440]	2807	/////////////////////////////////////////////
	2808	int _sys_fbf_sync_write( unsigned int offset,
	2809	void* buffer,
	2810	unsigned int length )
	2811	{
[714]	2812	// get calling thread scheduler, ltid and trdid
	2813	static_scheduler_t* psched = _get_sched();
	2814	unsigned int ltid = _get_thread_ltid();
	2815	unsigned int trdid = _get_thread_trdid();
	2816
	2817	if ( (psched->context[ltid].slot[CTX_LOCKS_ID] & LOCKS_MASK_FBF) == 0 )
	2818	{
	2819	_printf("\n[GIET ERROR] in _sys_fbf_release() : "
	2820	"FBF not allocated to thread %x\n", trdid );
	2821
	2822	return SYSCALL_CHANNEL_NON_ALLOCATED;
	2823	}
	2824
[440]	2825	char* fbf_address = (char *)SEG_FBF_BASE + offset;
	2826	memcpy( fbf_address, buffer, length);
	2827
[714]	2828	return SYSCALL_OK;
[440]	2829	}
	2830
	2831	/////////////////////////////////////////////
	2832	int _sys_fbf_sync_read( unsigned int offset,
	2833	void* buffer,
	2834	unsigned int length )
	2835	{
[714]	2836	// get calling thread scheduler, ltid and trdid
	2837	static_scheduler_t* psched = _get_sched();
	2838	unsigned int ltid = _get_thread_ltid();
	2839	unsigned int trdid = _get_thread_trdid();
	2840
	2841	if ( (psched->context[ltid].slot[CTX_LOCKS_ID] & LOCKS_MASK_FBF) == 0 )
	2842	{
	2843	_printf("\n[GIET ERROR] in _sys_fbf_release() : "
	2844	"FBF not allocated to thread %x\n", trdid );
	2845
	2846	return SYSCALL_CHANNEL_NON_ALLOCATED;
	2847	}
	2848
[440]	2849	char* fbf_address = (char *)SEG_FBF_BASE + offset;
	2850	memcpy( buffer, fbf_address, length);
	2851
[714]	2852	return SYSCALL_OK;
[440]	2853	}
	2854
	2855	////////////////////////
	2856	int _sys_fbf_cma_alloc()
	2857	{
[709]	2858	unsigned int trdid = _get_thread_trdid();
	2859
[699]	2860	if ( _get_context_slot( CTX_CMA_FB_ID ) < NB_CMA_CHANNELS )
	2861	{
[709]	2862	_printf("\n[GIET ERROR] in _sys_fbf_cma_alloc() : "
	2863	"CMA channel already allocated for thread %x\n", trdid );
[714]	2864
	2865	return SYSCALL_CHANNEL_ALREADY_ALLOCATED;
[699]	2866	}
[440]	2867
[709]	2868	// get a CMA channel
[699]	2869	unsigned int channel;
	2870	for ( channel = 0 ; channel < NB_CMA_CHANNELS ; channel++ )
	2871	{
[709]	2872	unsigned int* palloc = &_cma_channel_alloc[channel];
	2873	if ( _atomic_test_and_set( palloc , 1 ) == 0 ) break;
[699]	2874	}
[440]	2875	if ( channel >= NB_CMA_CHANNELS )
	2876	{
[699]	2877	_printf("\n[GIET ERROR] in _sys_fbf_cma_alloc() : no CMA channel available\n");
[714]	2878
	2879	return SYSCALL_NO_CHANNEL_AVAILABLE;
[440]	2880	}
	2881	else
	2882	{
[449]	2883	_set_context_slot( CTX_CMA_FB_ID, channel );
[714]	2884
	2885	return SYSCALL_OK;
[440]	2886	}
	2887	} // end sys_fbf_cma_alloc()
	2888
[709]	2889	//////////////////////////
	2890	int _sys_fbf_cma_release() // Not a syscall
[700]	2891	{
	2892	unsigned int channel = _get_context_slot( CTX_CMA_FB_ID );
[709]	2893	unsigned int trdid = _get_thread_trdid();
[614]	2894
[700]	2895	if ( channel >= NB_CMA_CHANNELS )
	2896	{
[709]	2897	_printf("\n[GIET_ERROR] in _sys_fbf_cma_release() : "
[714]	2898	"CMA_FB channel already released for thread %x\n", trdid );
	2899
	2900	return SYSCALL_CHANNEL_NON_ALLOCATED;
[700]	2901	}
	2902
[709]	2903	// stop CMA transfer
[700]	2904	_sys_fbf_cma_stop();
	2905
[709]	2906	// reset CTX_CMA_FB_ID for thread
	2907	_set_context_slot( CTX_CMA_FB_ID, 0xFFFFFFFF );
[700]	2908
	2909	// release CMA channel
[709]	2910	_cma_channel_alloc[channel] = 0;
[700]	2911
[714]	2912	return SYSCALL_OK;
[700]	2913	}
	2914
[648]	2915	///////////////////////////////////////////////////
	2916	int _sys_fbf_cma_init_buf( void* buf0_vbase,
	2917	void* buf1_vbase,
	2918	void* sts0_vaddr,
	2919	void* sts1_vaddr )
[440]	2920	{
	2921	unsigned int vaddr; // virtual address
[528]	2922	unsigned int flags; // for _v2p_translate()
[614]	2923	unsigned long long fbf_paddr; // fbf physical address
	2924	unsigned long long fbf_sts_paddr; // fbf status physical address
	2925	unsigned long long buf0_pbase; // buffer 0 base physical address
	2926	unsigned long long sts0_paddr; // buffer 0 status physical address
	2927	unsigned long long buf1_pbase; // buffer 1 base physical address
	2928	unsigned long long sts1_paddr; // buffer 1 status physical address
[440]	2929
[714]	2930	// get calling thread scheduler, ltid and trdid
	2931	static_scheduler_t* psched = _get_sched();
	2932	unsigned int ltid = _get_thread_ltid();
	2933	unsigned int trdid = _get_thread_trdid();
	2934
	2935	// check FBF allocated
	2936	if ( (psched->context[ltid].slot[CTX_LOCKS_ID] & LOCKS_MASK_FBF) == 0 )
	2937	{
	2938	_printf("\n[GIET ERROR] in _sys_fbf_cma_init_buf() : "
	2939	"FBF not allocated to thread %x\n", trdid );
	2940
	2941	return SYSCALL_CHANNEL_NON_ALLOCATED;
	2942	}
	2943
[440]	2944	// get channel index
[449]	2945	unsigned int channel = _get_context_slot( CTX_CMA_FB_ID );
[440]	2946
	2947	if ( channel >= NB_CMA_CHANNELS )
	2948	{
[714]	2949	_printf("\n[GIET ERROR] in _sys_fbf_cma_init_buf() : "
	2950	"CMA channel non allocated to thread %x\n", trdid );
	2951
	2952	return SYSCALL_CHANNEL_NON_ALLOCATED;
[440]	2953	}
	2954
	2955	#if GIET_DEBUG_FBF_CMA
[714]	2956	_printf("\n[FBF_CMA DEBUG] _sys_fbf_cma_init_buf()\n"
[614]	2957	" - channel = %d\n"
	2958	" - buf0 vbase = %x\n"
	2959	" - buf1 vbase = %x\n"
	2960	" - sts0 vaddr = %x\n"
	2961	" - sts1 vaddr = %x\n",
[440]	2962	channel,
[614]	2963	(unsigned int)buf0_vbase,
	2964	(unsigned int)buf1_vbase,
	2965	(unsigned int)sts0_vaddr,
	2966	(unsigned int)sts1_vaddr );
[440]	2967	#endif
	2968
[614]	2969	// checking user buffers virtual addresses alignment
	2970	if ( ((unsigned int)buf0_vbase & 0x3F) \|\|
	2971	((unsigned int)buf1_vbase & 0x3F) )
[440]	2972	{
[714]	2973	_printf("\n[GIET ERROR] in _sys_fbf_cma_init_buf() : "
	2974	"user buffer not aligned for thread %x\n", trdid );
	2975
	2976	return SYSCALL_ADDRESS_NON_ALIGNED;
[440]	2977	}
	2978
[614]	2979	// checking user buffers status virtual addresses alignment
	2980	if ( ((unsigned int)sts0_vaddr & 0x3F) \|\|
	2981	((unsigned int)sts1_vaddr & 0x3F) )
	2982	{
[714]	2983	_printf("\n[GIET ERROR] in _sys_fbf_cma_init_buf() : "
	2984	"user status not aligned for thread %x\n", trdid );
	2985
	2986	return SYSCALL_ADDRESS_NON_ALIGNED;
[614]	2987	}
	2988
[440]	2989	// compute frame buffer physical address and initialize _fbf_chbuf[channel]
[528]	2990	vaddr = (unsigned int)SEG_FBF_BASE;
[614]	2991	fbf_paddr = _v2p_translate( vaddr , &flags );
	2992	vaddr = (unsigned int)&_fbf_status[channel];
	2993	fbf_sts_paddr = _v2p_translate( vaddr , &flags );
[440]	2994
[614]	2995	_fbf_chbuf[channel].fbf_desc =
	2996	(unsigned long long) ((fbf_sts_paddr & 0xFFFFFFFFULL) >> 6) +
	2997	(((fbf_paddr & 0xFFFFFFFFULL) >> 6 ) << 26);
	2998
[528]	2999	// Compute user buffer 0 physical addresses and intialize _fbf_chbuf[channel]
[614]	3000	vaddr = (unsigned int)buf0_vbase;
	3001	buf0_pbase = _v2p_translate( vaddr , &flags );
[440]	3002	if ((flags & PTE_U) == 0)
	3003	{
[714]	3004	_printf("\n[GIET ERROR] in _sys_fbf_cma_init_buf() : "
	3005	"buf0 not in user space for thread %x\n", trdid );
	3006
	3007	return SYSCALL_ADDRESS_NON_USER_ACCESSIBLE;
[440]	3008	}
	3009
[614]	3010	vaddr = (unsigned int)sts0_vaddr;
	3011	sts0_paddr = _v2p_translate( vaddr , &flags );
	3012	if ((flags & PTE_U) == 0)
	3013	{
[714]	3014	_printf("\n[GIET ERROR] in _sys_fbf_cma_init_buf() : "
	3015	"sts0 not in user space for thread %x\n", trdid);
	3016
	3017	return SYSCALL_ADDRESS_NON_USER_ACCESSIBLE;
[614]	3018	}
	3019
	3020	_fbf_chbuf[channel].buf0_desc =
	3021	(unsigned long long) ((sts0_paddr & 0xFFFFFFFFULL) >> 6) +
	3022	(((buf0_pbase & 0xFFFFFFFFULL) >> 6 ) << 26);
	3023
[528]	3024	// Compute user buffer 1 physical addresses and intialize _fbf_chbuf[channel]
[614]	3025	vaddr = (unsigned int)buf1_vbase;
	3026	buf1_pbase = _v2p_translate( vaddr , &flags );
[440]	3027	if ((flags & PTE_U) == 0)
	3028	{
[714]	3029	_printf("\n[GIET ERROR] in _sys_fbf_cma_init_buf() : "
	3030	"buf1 not in user space for thread %x\n", trdid );
	3031
	3032	return SYSCALL_ADDRESS_NON_USER_ACCESSIBLE;
[440]	3033	}
	3034
[614]	3035	vaddr = (unsigned int)sts1_vaddr;
	3036	sts1_paddr = _v2p_translate( vaddr , &flags );
	3037	if ((flags & PTE_U) == 0)
	3038	{
[714]	3039	_printf("\n[GIET ERROR] in _sys_fbf_cma_init_buf() : "
	3040	"sts1 not in user space for thread %x\n", trdid);
	3041
	3042	return SYSCALL_ADDRESS_NON_USER_ACCESSIBLE;
[614]	3043	}
[440]	3044
[614]	3045	_fbf_chbuf[channel].buf1_desc =
	3046	(unsigned long long) ((sts1_paddr & 0xFFFFFFFFULL) >> 6) +
	3047	(((buf1_pbase & 0xFFFFFFFFULL) >> 6 ) << 26);
	3048
[505]	3049	// Compute and register physical adress of the fbf_chbuf descriptor
[528]	3050	vaddr = (unsigned int)&_fbf_chbuf[channel];
	3051	_fbf_chbuf_paddr[channel] = _v2p_translate( vaddr , &flags );
[440]	3052
[614]	3053	#if GIET_DEBUG_FBF_CMA
	3054	_printf(" - fbf pbase = %l\n"
	3055	" - fbf status paddr = %l\n"
	3056	" - buf0 pbase = %l\n"
	3057	" - buf0 status paddr = %l\n"
	3058	" - buf1 pbase = %l\n"
	3059	" - buf0 status paddr = %l\n"
	3060	" - chbuf pbase = %l\n",
	3061	fbf_paddr,
	3062	fbf_sts_paddr,
	3063	buf0_pbase,
	3064	sts0_paddr,
	3065	buf1_pbase,
	3066	sts1_paddr,
	3067	_fbf_chbuf_paddr[channel] );
	3068	#endif
	3069
[714]	3070	return SYSCALL_OK;
[614]	3071
	3072	} // end sys_fbf_cma_init_buf()
	3073
	3074	////////////////////////////////////////////
	3075	int _sys_fbf_cma_start( unsigned int length )
	3076	{
[714]	3077	// get calling thread scheduler, ltid and trdid
	3078	static_scheduler_t* psched = _get_sched();
	3079	unsigned int ltid = _get_thread_ltid();
	3080	unsigned int trdid = _get_thread_trdid();
[614]	3081
[714]	3082	// check FBF allocated
	3083	if ( (psched->context[ltid].slot[CTX_LOCKS_ID] & LOCKS_MASK_FBF) == 0 )
	3084	{
	3085	_printf("\n[GIET ERROR] in _sys_fbf_release() : "
	3086	"FBF not allocated to thread %x\n", trdid );
	3087
	3088	return SYSCALL_CHANNEL_NON_ALLOCATED;
	3089	}
	3090
[614]	3091	// get channel index
	3092	unsigned int channel = _get_context_slot( CTX_CMA_FB_ID );
	3093
	3094	if ( channel >= NB_CMA_CHANNELS )
	3095	{
[714]	3096	_printf("\n[GIET ERROR] in _fbf_cma_start() : "
	3097	"CMA channel non allocated\n");
	3098
	3099	return SYSCALL_CHANNEL_NON_ALLOCATED;
[614]	3100	}
	3101
	3102	// check buffers initialization
	3103	if ( ( _fbf_chbuf[channel].buf0_desc == 0x0ULL ) &&
	3104	( _fbf_chbuf[channel].buf1_desc == 0x0ULL) &&
	3105	( _fbf_chbuf[channel].fbf_desc == 0x0ULL) )
	3106	{
[714]	3107	_printf("\n[GIET ERROR] in _sys_fbf_cma_start(): initialization not done\n");
	3108
	3109	return SYSCALL_MISSING_INITIALISATION;
[614]	3110	}
	3111
	3112	// initializes buffer length
	3113	_fbf_chbuf[channel].length = length;
	3114
[440]	3115	if ( USE_IOB )
	3116	{
[505]	3117	// SYNC request for fbf_chbuf descriptor
	3118	_mmc_sync( _fbf_chbuf_paddr[channel] , sizeof( fbf_chbuf_t ) );
[440]	3119	}
	3120
[505]	3121	// start CMA transfer
	3122	unsigned long long paddr = _fbf_chbuf_paddr[channel];
	3123	unsigned int src_chbuf_paddr_lsb = (unsigned int)(paddr & 0xFFFFFFFF);
	3124	unsigned int src_chbuf_paddr_ext = (unsigned int)(paddr >> 32);
[614]	3125	unsigned int dst_chbuf_paddr_lsb = src_chbuf_paddr_lsb + 16;
[505]	3126	unsigned int dst_chbuf_paddr_ext = src_chbuf_paddr_ext;
	3127
	3128	_cma_set_register( channel, CHBUF_SRC_DESC , src_chbuf_paddr_lsb );
	3129	_cma_set_register( channel, CHBUF_SRC_EXT , src_chbuf_paddr_ext );
	3130	_cma_set_register( channel, CHBUF_SRC_NBUFS, 2 );
	3131	_cma_set_register( channel, CHBUF_DST_DESC , dst_chbuf_paddr_lsb );
	3132	_cma_set_register( channel, CHBUF_DST_EXT , dst_chbuf_paddr_ext );
	3133	_cma_set_register( channel, CHBUF_DST_NBUFS, 1 );
	3134	_cma_set_register( channel, CHBUF_BUF_SIZE , length );
	3135	_cma_set_register( channel, CHBUF_PERIOD , 300 );
	3136	_cma_set_register( channel, CHBUF_RUN , 1 );
	3137
[714]	3138	return SYSCALL_OK;
[440]	3139
	3140	} // end _sys_fbf_cma_start()
	3141
	3142	/////////////////////////////////////////////////////
	3143	int _sys_fbf_cma_display( unsigned int buffer_index )
	3144	{
[505]	3145	volatile unsigned int full = 1;
[440]	3146
[714]	3147	// get calling thread scheduler, ltid and trdid
	3148	static_scheduler_t* psched = _get_sched();
	3149	unsigned int ltid = _get_thread_ltid();
	3150	unsigned int trdid = _get_thread_trdid();
	3151
	3152	// check FBF allocated
	3153	if ( (psched->context[ltid].slot[CTX_LOCKS_ID] & LOCKS_MASK_FBF) == 0 )
	3154	{
	3155	_printf("\n[GIET ERROR] in _sys_fbf_release() : "
	3156	"FBF not allocated to thread %x\n", trdid );
	3157
	3158	return SYSCALL_CHANNEL_NON_ALLOCATED;
	3159	}
	3160
[440]	3161	// get channel index
[449]	3162	unsigned int channel = _get_context_slot( CTX_CMA_FB_ID );
[440]	3163
	3164	if ( channel >= NB_CMA_CHANNELS )
	3165	{
[505]	3166	_printf("\n[GIET ERROR] in _sys_fbf_cma_display() : "
[714]	3167	"CMA channel non allocated\n");
	3168
	3169	return SYSCALL_CHANNEL_NON_ALLOCATED;
[440]	3170	}
	3171
[505]	3172	// get fbf_chbuf descriptor pointer
	3173	fbf_chbuf_t* pdesc = &_fbf_chbuf[channel];
	3174
[440]	3175	#if GIET_DEBUG_FBF_CMA
	3176	_printf("\n[FBF_CMA DEBUG] enters _sys_fb_cma_display()\n"
[614]	3177	" - cma channel = %d\n"
	3178	" - buffer index = %d\n"
	3179	" - buf0_desc value = %l\n"
	3180	" - buf1_desc value = %l\n"
	3181	" - fbf_desc value = %l\n",
[505]	3182	channel , buffer_index,
[614]	3183	_fbf_chbuf[channel].buf0_desc,
	3184	_fbf_chbuf[channel].buf1_desc,
	3185	_fbf_chbuf[channel].fbf_desc );
[440]	3186	#endif
	3187
[614]	3188	unsigned long long buf_sts_paddr;
	3189	unsigned long long buf_paddr;
	3190	unsigned long long fbf_sts_paddr;
	3191
[478]	3192	if ( buffer_index == 0 ) // user buffer 0
	3193	{
[614]	3194	buf_sts_paddr =
	3195	((pdesc->buf0_desc & 0xFFF0000000000000ULL) >> 20) + // compute address extension
	3196	((pdesc->buf0_desc & 0x3FFFFFFULL) << 6); // compute 32 LSB of the address
[505]	3197
[614]	3198	buf_paddr =
	3199	(pdesc->buf0_desc & 0xFFFFFFFFFC000000ULL) >> 20; // compute the entire address
[440]	3200	}
[478]	3201	else // user buffer 1
	3202	{
[614]	3203	buf_sts_paddr =
	3204	((pdesc->buf1_desc & 0xFFF0000000000000ULL) >> 20) +
	3205	((pdesc->buf1_desc & 0x3FFFFFFULL) << 6);
[505]	3206
[614]	3207	buf_paddr =
	3208	(pdesc->buf1_desc & 0xFFFFFFFFFC000000ULL) >> 20;
	3209	}
[478]	3210
[614]	3211	fbf_sts_paddr =
	3212	((pdesc->fbf_desc & 0xFFF0000000000000ULL) >> 20) +
	3213	((pdesc->fbf_desc & 0x3FFFFFFULL) << 6);
[440]	3214
[614]	3215	#if GIET_DEBUG_FBF_CMA
	3216	_printf(" - fbf status paddr = %l\n"
	3217	" - buf pbase = %l\n"
	3218	" - buf status paddr = %l\n",
	3219	fbf_sts_paddr,
	3220	buf_paddr,
	3221	buf_sts_paddr );
	3222	#endif
	3223
	3224	// waiting user buffer released by the CMA component)
	3225	while ( full )
	3226	{
[648]	3227	// INVAL L2 cache copy of user buffer status
[614]	3228	// because it has been modified in RAM by the CMA component
	3229	_mmc_inval( buf_sts_paddr , 4 );
[440]	3230
[614]	3231	full = _physical_read( buf_sts_paddr );
[440]	3232	}
	3233
[614]	3234	// SYNC request for the user buffer, because
	3235	// it will be read from XRAM by the CMA component
	3236	_mmc_sync( buf_paddr , pdesc->length );
[440]	3237
[614]	3238	// set user buffer status
	3239	_physical_write( buf_sts_paddr, 0x1 );
	3240
	3241	// reset fbf buffer status
	3242	_physical_write( fbf_sts_paddr, 0x0 );
	3243
	3244	// SYNC request, because these buffer descriptors
	3245	// will be read from XRAM by the CMA component
	3246	_mmc_sync( buf_sts_paddr, 4 );
	3247	_mmc_sync( fbf_sts_paddr, 4 );
	3248
[714]	3249	return SYSCALL_OK;
[440]	3250
	3251	} // end _sys_fbf_cma_display()
	3252
	3253	///////////////////////
	3254	int _sys_fbf_cma_stop()
	3255	{
	3256	// get channel index
[449]	3257	unsigned int channel = _get_context_slot( CTX_CMA_FB_ID );
[440]	3258
	3259	if ( channel >= NB_CMA_CHANNELS )
	3260	{
[714]	3261	_printf("\n[GIET ERROR] in _sys_fbf_cma_stop() : CMA channel non allocated\n");
	3262
	3263	return SYSCALL_CHANNEL_NON_ALLOCATED;
[440]	3264	}
	3265
	3266	// Desactivate CMA channel
[505]	3267	_cma_set_register( channel, CHBUF_RUN, 0 );
[440]	3268
[714]	3269	return SYSCALL_OK;
[440]	3270
	3271	} // end _sys_fbf_cma_stop()
	3272
	3273
	3274	//////////////////////////////////////////////////////////////////////////////
	3275	// Miscelaneous syscall handlers
	3276	//////////////////////////////////////////////////////////////////////////////
	3277
	3278	///////////////
	3279	int _sys_ukn()
	3280	{
	3281	_printf("\n[GIET ERROR] Undefined System Call / EPC = %x\n", _get_epc() );
[714]	3282
	3283	return SYSCALL_UNDEFINED_SYSTEM_CALL;
[440]	3284	}
	3285
	3286	////////////////////////////////////
	3287	int _sys_proc_xyp( unsigned int* x,
	3288	unsigned int* y,
	3289	unsigned int* p )
	3290	{
[428]	3291	unsigned int gpid = _get_procid(); // global processor index from CPO register
	3292
	3293	*x = (gpid >> (Y_WIDTH + P_WIDTH)) & ((1<<X_WIDTH)-1);
	3294	*y = (gpid >> P_WIDTH) & ((1<<Y_WIDTH)-1);
	3295	*p = gpid & ((1<<P_WIDTH)-1);
[440]	3296
[714]	3297	return SYSCALL_OK;
[428]	3298	}
[440]	3299
[494]	3300	////////////////////////////////////////////
	3301	int _sys_procs_number( unsigned int* x_size,
	3302	unsigned int* y_size,
	3303	unsigned int* nprocs )
[258]	3304	{
[494]	3305	mapping_header_t * header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
[440]	3306	mapping_cluster_t * cluster = _get_cluster_base(header);
	3307
[494]	3308	unsigned int x;
	3309	unsigned int y;
	3310	unsigned int okmin = 1;
	3311	unsigned int okmax = 1;
	3312
	3313	// compute max values
	3314	unsigned int xmax = header->x_size;
	3315	unsigned int ymax = header->y_size;
	3316	unsigned int procs = cluster[0].procs;
	3317
	3318	// check the (ymax-1) lower rows
	3319	for ( y = 0 ; y < ymax-1 ; y++ )
[440]	3320	{
[494]	3321	for ( x = 0 ; x < xmax ; x++ )
	3322	{
	3323	if (cluster[x*ymax+y].procs != procs ) okmin = 0;
	3324	}
[440]	3325	}
[494]	3326
	3327	// check the upper row
	3328	for ( x = 0 ; x < xmax ; x++ )
[440]	3329	{
[494]	3330	if (cluster[x*ymax+ymax-1].procs != procs ) okmax = 0;
[440]	3331	}
[494]	3332
	3333	// return values
	3334	if ( okmin && okmax )
	3335	{
	3336	*x_size = xmax;
	3337	*y_size = ymax;
	3338	*nprocs = procs;
	3339	}
	3340	else if ( okmin )
	3341	{
	3342	*x_size = xmax;
	3343	*y_size = ymax-1;
	3344	*nprocs = procs;
	3345	}
	3346	else
	3347	{
	3348	*x_size = 0;
	3349	*y_size = 0;
	3350	*nprocs = 0;
	3351	}
[714]	3352	return SYSCALL_OK;
[440]	3353	}
	3354
	3355	///////////////////////////////////////////////////////
[516]	3356	int _sys_vseg_get_vbase( char* vspace_name,
	3357	char* vseg_name,
[440]	3358	unsigned int* vbase )
	3359	{
[322]	3360	mapping_header_t * header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
[258]	3361	mapping_vspace_t * vspace = _get_vspace_base(header);
[516]	3362	mapping_vseg_t * vseg = _get_vseg_base(header);
[258]	3363
	3364	unsigned int vspace_id;
[516]	3365	unsigned int vseg_id;
[258]	3366
	3367	// scan vspaces
	3368	for (vspace_id = 0; vspace_id < header->vspaces; vspace_id++)
	3369	{
	3370	if (_strncmp( vspace[vspace_id].name, vspace_name, 31) == 0)
	3371	{
[516]	3372	// scan vsegs
	3373	for (vseg_id = vspace[vspace_id].vseg_offset;
	3374	vseg_id < (vspace[vspace_id].vseg_offset + vspace[vspace_id].vsegs);
	3375	vseg_id++)
[258]	3376	{
[516]	3377	if (_strncmp(vseg[vseg_id].name, vseg_name, 31) == 0)
[258]	3378	{
[516]	3379	*vbase = vseg[vseg_id].vbase;
[714]	3380	return SYSCALL_OK;
[258]	3381	}
	3382	}
	3383	}
	3384	}
[714]	3385	return SYSCALL_VSEG_NOT_FOUND;
[258]	3386	}
	3387
[440]	3388	/////////////////////////////////////////////////////////
[516]	3389	int _sys_vseg_get_length( char* vspace_name,
	3390	char* vseg_name,
[440]	3391	unsigned int* length )
[258]	3392	{
[440]	3393	mapping_header_t * header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
	3394	mapping_vspace_t * vspace = _get_vspace_base(header);
[516]	3395	mapping_vseg_t * vseg = _get_vseg_base(header);
[258]	3396
[440]	3397	unsigned int vspace_id;
[516]	3398	unsigned int vseg_id;
[440]	3399
	3400	// scan vspaces
	3401	for (vspace_id = 0; vspace_id < header->vspaces; vspace_id++)
[258]	3402	{
[440]	3403	if (_strncmp( vspace[vspace_id].name, vspace_name, 31) == 0)
	3404	{
[516]	3405	// scan vsegs
	3406	for (vseg_id = vspace[vspace_id].vseg_offset;
	3407	vseg_id < (vspace[vspace_id].vseg_offset + vspace[vspace_id].vsegs);
	3408	vseg_id++)
[440]	3409	{
[516]	3410	if (_strncmp(vseg[vseg_id].name, vseg_name, 31) == 0)
[440]	3411	{
[516]	3412	*length = vseg[vseg_id].length;
[714]	3413	return SYSCALL_OK;
[440]	3414	}
	3415	}
	3416	}
	3417	}
[714]	3418	return SYSCALL_VSEG_NOT_FOUND;
[258]	3419	}
	3420
[440]	3421	////////////////////////////////////////
	3422	int _sys_xy_from_ptr( void* ptr,
	3423	unsigned int* x,
	3424	unsigned int* y )
[396]	3425	{
	3426	unsigned int flags;
[528]	3427	unsigned long long paddr = _v2p_translate( (unsigned int)ptr , &flags );
[396]	3428
[528]	3429	*x = (paddr>>36) & 0xF;
	3430	*y = (paddr>>32) & 0xF;
[396]	3431
[714]	3432	return SYSCALL_OK;
[396]	3433	}
	3434
[440]	3435	/////////////////////////////////////////
	3436	int _sys_heap_info( unsigned int* vaddr,
	3437	unsigned int* length,
	3438	unsigned int x,
	3439	unsigned int y )
[258]	3440	{
[709]	3441	// checking parameters
	3442	if ( (x >= X_SIZE) \|\| (y >= Y_SIZE) )
	3443	{
	3444	*vaddr = 0;
	3445	*length = 0;
	3446	_printf("\n[GIET ERROR] in _sys_heap_info() : "
	3447	"illegal (%d,%d) coordinates\n", x , y );
[714]	3448	return SYSCALL_ILLEGAL_CLUSTER_COORDINATES;
[709]	3449	}
	3450
[440]	3451	mapping_header_t * header = (mapping_header_t *)SEG_BOOT_MAPPING_BASE;
[709]	3452	mapping_thread_t * thread = _get_thread_base(header);
[516]	3453	mapping_vseg_t * vseg = _get_vseg_base(header);
	3454	mapping_vspace_t * vspace = _get_vspace_base(header);
[294]	3455
[709]	3456	unsigned int thread_id;
[440]	3457	unsigned int vspace_id;
[516]	3458	unsigned int vseg_id = 0xFFFFFFFF;
[258]	3459
[709]	3460	// get calling thread vspace index
	3461	vspace_id = _get_context_slot(CTX_VSID_ID);
	3462
	3463	// scan all threads in vspace to find one in clyster[x,y]
	3464	unsigned int min = vspace[vspace_id].thread_offset ;
	3465	unsigned int max = min + vspace[vspace_id].threads ;
	3466	for ( thread_id = min ; thread_id < max ; thread_id++ )
[440]	3467	{
[709]	3468	if ( thread[thread_id].clusterid == (x * Y_SIZE + y) )
[440]	3469	{
[709]	3470	vseg_id = thread[thread_id].heap_vseg_id;
	3471	break;
[440]	3472	}
	3473	}
	3474
[516]	3475	// analysing the vseg_id
	3476	if ( vseg_id != 0xFFFFFFFF )
[440]	3477	{
[516]	3478	*vaddr = vseg[vseg_id].vbase;
	3479	*length = vseg[vseg_id].length;
[440]	3480	}
	3481	else
	3482	{
	3483	*vaddr = 0;
	3484	*length = 0;
[709]	3485	_printf("error in _sys_heap_info() : no heap in cluster (%d,%d)\n", x , y );
[440]	3486	}
[714]	3487	return SYSCALL_OK;
[440]	3488	} // end _sys_heap_info()
	3489
	3490
[258]	3491	// Local Variables:
	3492	// tab-width: 4
	3493	// c-basic-offset: 4
	3494	// c-file-offsets:((innamespace . 0)(inline-open . 0))
	3495	// indent-tabs-mode: nil
	3496	// End:
	3497	// vim: filetype=c:expandtab:shiftwidth=4:tabstop=4:softtabstop=4
	3498

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

Download in other formats: