ProvaPratica 2010.07.12

http://www.cs.unibo.it/~renzo/so/compiti/2010-07-12.tot.pdf

Esercizio 1

monitor priocoop{
condition run[9];
int waiting[9]=0,0,0,0,0,0,0,0,0;
int maxprio=0;
int occupato=0;

procedure entry init(prio){	
	if(occupato==1)
	{
		if(maxprio < prio)
		{
		maxprio=prio;
		}
	waiting[prio]++;			
	run[prio].wait();
	waiting[prio]--;
	}
occupato=1;
}

procedure entry yield(prio){
run[maxprio].signal();
        if(maxprio < prio)
	{
	maxprio=prio;
	}
waiting[prio]++;
run[prio].wait();
waiting[prio]--;
}

procedure entry fini(prio){
int i;
occupato=0;
waiting[prio]--;
	if(waiting[maxprio] == 0)
	{
	maxprio=0;
		for(i=prio;i>=0;i--)
		{
			if(waiting[i]!=0)
			{
			maxprio=0;
			}
		}		
	run[maxprio].signal();
	}
}

Alessandro

//Processo con prioritá 0 = Processo con piú alta prioritá
//Processo con prioritá 9 = Processo con meno prioritá
monitor priocoop {
	condition oktogo[10];
	int wait[10] = 0,0,0,0,0,0,0,0,0;
	int running;
	priocoop.init(prio) {
		if(running != 0) {
			wait[prio]++;
			oktogo[prio].wait;
			wait[prio]--;
		}

		running++;
	}

	priocoop.yield(prio) {
		running--;
		for(int i = 0;i<10;i++) {
			if(wait[i] != 0) {
				oktogo[i].signal();
				wait[prio]++;
				oktogo[prio].wait;
				wait[prio]--;
				break();
			}
		}
		running++;
	}

	priocoop.fini() {
		running--;
		for(int i = 0;i<10;i++) {
			if(wait[i] != 0) {
				oktogo[i].signal();
				break();
			}
		}

	}
}

-Midolo

//0: priorita' maggiore
//9: priorita' minore
cond oktoenter[10];
int count[10];
bool running = false;

//restituisce la priorita' maggiore che ha un processo in attesa
getprio() {
      	for(i=0;i<10;i++) {
		 if(count[i]>0)
			 break;
	 }
	 return i;
}

priocoop() {
	init (prio) {
		if (running) {
			count[prio]++;
			oktoenter[prio].wait();
			count[prio]--;
		}
		running = true;
	}
	yield(prio) {
		i=getprio();
		if (i < 10) {
			// running = false; 
			oktoenter[i].signal();
			count(prio)++
			oktoenter[proc].wait();
	                // running = true;
        	        count[prio]--;
		}
	}
	fini(prio){
		i=getprio();
		if(i<10)
			oktoenter[i].signal;
		else
			running=false;
	}
}

-Stefano B.

---

monitor priocoop{
	condition oktoenter[10];
	queue waiting[10];
	
	procedure entry init(int prio){
		if(!(prio >= 0 && prio<=9))
			exit(0);
	}
	
	procedure entry yield(int prio){
		int priority=-1;
		for (i=0; i<10; i++) {
			if (! waiting[i].isempty())
				priority=i;
		}
		oktoenter[priority].signal();
		if(priority>=0){ /* se non ci fosse questo controllo avremmo un caso di deadlock
						  * in quanto le code sono vuote */
			waiting[prio].enqueue();
			oktoenter[prio].wait();
			waiting[prio].dequeue(); 
		}
	}
	
	procedure entry fini(){
		int priority=-1;
		for (i=0; i<10; i++) {
			if (! waiting[i].isempty())
				priority=i;
		}
		oktoenter[priority].signal();
	}
}

Francesca e Giulia

Esercizio 2

db.getpriortymax(); //funzione che restituisce il messaggio con prioritá maggiore e lo rimuove dal db o 0 nel caso il db sia vuoto
Process n: {

	psend(dest, prio,msg) {
		asend((msg, prio),dest);
	}

	precv(sender) {
		while((msg,prio) = arecv(sender)) {
			db[sender].insert((msg,prio));
		}
		return (db[sender].getpriortymax());
	}

}

-Midolo