S.G: Esercizio monitor e message passing

2016-12-05T15:11:32Z

Esercizio monitor e message passing

New page

Testo: [http://www.cs.unibo.it/~renzo/so/compiti/2014.06.16.tot.pdf]

== Esercizio c.1 ==
'''Testo esercizio'''

Scrivere il monitor rendezvous che consente ai processi di sincronizzarsi e scambiare dati.
Ogni processo chiama la procedure entry rendezvous.sync specificando due parametri: il numero dei processi con i quali il processo
corrente vuole sincronizzarsi e un vettore di ugual numero di interi. Il primo elemento e' inizializzato con il valore conferito dal
processo chiamante.
I processi devono coordinarsi con altri che abbiano chiesto di sincronizzarsi con un ugual numero di processi. Quindi, se e quando N
processi hanno chiamato la rendezvous.sync chiedendo la sincronizzazione con N processi, tutti N vengono riattivati. Il vettore
passato come secondo parametro deve contenere i valori conferiti dagli N processi, uno in ogni elemento del vettore, seguendo
l'ordine di chiamata della rendezvous.sync.

es. P1: int v1[]={42,0,0}; rendezvous.sync(3,v1) …. P1 si blocca....

P2: int v[]={314,0,0}; rendezvous.sync(3,v) …. P2 si blocca....

P3: int vv[]={1,0}; rendezvous.sync(2,vv) …. P3 si blocca....

P4: int q[]={13,0,0}; rendezvous.sync(3,q) … P4 sblocca anche P1 e P2. Il secondo paramentro per tutti e tre avra' valore [42,314,13]
….P3 si sblocchera' se e quando un altro processo chiamera' rendezvous.sync con primo parametro 2.

<syntaxhighlight lang="C">

#define SIZE N

monitor rendezvous {
generic_type count[];
condition w[];

void rendezvous (void){
int i;
count = new generic_type[SIZE];
w = new condition[SIZE];
for(i=0; i<SIZE; i++)
count[i] = new List[];
}

procedure entry sync(int np, int vp[]){
int i, n;
count[np].append(vp[0]);
n = len(count[np]);
if(n == np){
// Sblocca tutti i processi con richiesta np
for(i=0; i < n; i++){
count[np].remove();
w[np].signal();
}
}
else if(n < np){
// Blocca processo
w[np].wait();
}
}
}
</syntaxhighlight>
[[User:S.G|S.G]] ([[User talk:S.G|talk]]) 16:11, 5 December 2016 (CET)

== Esercizio c.2 ==
'''Testo esercizio'''

Usando semafori implementare un emulatore di un servizio di message passing asincrono.
Occorre quindi implementare le primitive:

void asend(msg m, pid_t dst)

msg arecv(pid_t sender)

facendo uso di semafori (generali, fifo).
(e' presente una chiamata getpid() che fornisce il pid del chiamante). La asend riceve da un mittente specificato (non e' richiesta la
gestione della ricezione da qualunque processo).

<syntaxhighlight lang="C">
/*
* Assumendo che non ci sia limite di grandezza, definisco la seguente
* struttura buffer tridimensionale, in cui le righe rappresentano i pid
* dei processi mittenti e le colonne i pid dei processi destinatari.
* Ad esempio buffer[X][Y] indica il buffer utilizzato dal processo X
* (il cui pid è X) come mittente e dal processo Y come destinatario.
* La terza dimensione, verrà utilizzata per la scrittura e lettura di determinati
* messaggi nel buffer.
*
* La struttura front e rear vengo utilizzate come nel problema dei produttori/consumatori
* per saper in quale punto poter scrivere e leggere nel buffer.
*
* La struttura len[X][Y] indica la lunghezza del buffer utilizzata dal processo X (mittente)
* e Y (destinatario).
*/
msg buffer[][][] = new msg[][][];
int front[][]; // Assumendo che ogni elemento sia inizilizzato a 0
int rear[][]; // Assumendo che ogni elemento sia inizializzato a 0
Semaphore len[][] = new Semaphore[][]; // Assumendo che ogni elemento sia inizializzato a 0

void asend(msg m, pid_t dst){
pid_t sen = getpid();
int f = front[sen][dst]++;
buffer[sen][dst][f] = m;
len[sen][dst].V();
}

msg arecv(pid_t sender){
pid_t dst = getpid();
len[sender][dst].P();
int r = rear[sender][dst]++;
return buffer[sender][dst][r];
}
</syntaxhighlight>
Si potrebbe anche gestire il caso un processo invia un messaggio a più processi e la ricezione da qualunque processo. [[User:S.G|S.G]] ([[User talk:S.G|talk]]) 16:11, 5 December 2016 (CET)

Prova teorica 2014.06.16 - Revision history

S.G: Esercizio monitor e message passing