ProvaTeoria 2011.01.17

TESTO COMPITO

Esercizio 1

/*
Esercizio 1: Scrivere un monitor reqq che gestisca una coda di richieste.
I richiedenti chiamano la funzione che ha la seguente signature:
answer_t reqq.query(request_t request);
Query deve fermare il processo richiedente fino a completamento della richiesta da parte di un gestore. Il valore di ritorno 
e' la risposta del gestore.
Ci sono N gestori che si comportano come segue:
multiq_handler: process[i, i=0,..,N-1] {
	request_t req;
	int type;
	while (1) {
		 req=reqq.getquery(i);
		 reqq.reply(i,handle(req));
 	}
}
Le richieste vengono assegnate ai gestori disponibili o accodate se sono tutti impegnati. Quando un gestore termina la 
gestione (funzione handle, che non implementare!) invia il risultato tramite la reply. Il valore passato alla reply deve 
essere restituito al richiedente come valore di ritorno della funzione query. Se non vi sono richieste disponibili i gestori si 
fermano attendendo nuove richieste.
*/


/*La mia soluzione si basa su una struttura reqEntry contenente un campo per la domanda, uno per la risposta, una condizione oktoexit e un intero per il gestore.
Quando arriva un richiedente inserisce una struttura con una domanda e con i campi risposta e gestore vuoti.
Quando un gestore si occupa di una domanda setta l'opportuno campo gestore al suo indice e, al termine della routine handle(), inserisce la sua risposta nell'opportuno
campo della struct risvegliando il richiedente*/

struct reqEntry
{
	request_t req;
	condition oktoexit;
	answer_t reply=NULL;
	int handler=VOID; //VOID è un valore speciale avente valore diverso dagli indici dei gestori
}
monitor reqq
{
	reqEntry* rq=Queue(); /*coda di reqEntry*/
	condition oktohandle; /*per i gestori*/
	answer_t procedure entry query(request_t request)
	{
		rq.insert(request); 
		rp=rq.searchByReq(request);
		oktohandle.signal(); /*cerco se esiste un gestore in attesa per la mia richiesta*/
		rp->oktoexit.wait();
		risp=rp->reply; 
		remove(rp); /*recupero la risposta e rimuovo la struct dalla coda*/
		return risp;	
	}
	request_t procedure entry  getquery(int index)
	{
		if isEmptyFree(rq) /*isEmptyFree ritorna 1 se non ci sono struct libere (cioè con handler VOID) nella coda di reqEntry*/
		{
			oktohandle.wait();
		}
		rp=rq.searchFree(); /*restituisce un elemento della coda di reqEntry avente handler VOID*/
		rp->handler=index; 
		return rp;
	}
	procedure entry reply(int index, answer_t rep)
	{
		rp=rq.searchByHandler(index); /*cerca nella lista la struct avente handler uguale al mio indice*/
		rp->reply=rep;
		rp->oktoexit.signal();
	}
}

Esercizio 3

struct sendINFO
{
	pid_t receiver;
	int nmsg;
}

sendINFO* listINFO=List(); //ogni processo ha un database di strutture sendINFO per sapere quanti messaggi di ogni destinatario
						   //risultano ancora non recapitati

T* database=List(); //ogni processo ha un database di messaggi 

int iasend(pid_t destination, T message)
{
	T tmpMSG;
	sendINFO tmpINFO;
	asend(destination,message);	
	if ((tmpINFO=listINFO.search(destination))==NULL) //se questo destinatario non ha ancora un'entry nella lista, lo inserisco
		{
			list.insert(destination,0);
			tmpINFO=listINFO.search(destination);
		}
	tmpINFO.nmsg++; 
	
	/*SCORRIMENTO BUFFER DI MESSAGGI E AGGIORNAMENTO LISTA*/
	asend(getpid(),"BOT"); 
	while((tmpMSG=arecv(*))!="BOT")
	{
		if (tmpMSG=="OK")
		{
			tmpINFO=listINFO.search(tmpMSG.sender);
			tmpINFO.nmsg--;
			if (nmsg==0)
				listINFO.remove(tmpINFO);
		}
		else
			db.add(tmpMSG);
	}
	tmpINFO=search(destination);
	if(tmpINFO!=NULL)
		return tmpINFO.nmsg;
	else
		return 0;
}

T iareceive(pid_t sender)
{
	T ris;
	ris=db.search(sender);
	if (ris==NULL)
		ris=arecv(sender);
	asend(sender,"OK");
	return ris;
}

-stefano92