diff options
author | Alex AUVOLAT <alex.auvolat@ens.fr> | 2014-03-20 16:39:16 +0100 |
---|---|---|
committer | Alex AUVOLAT <alex.auvolat@ens.fr> | 2014-03-20 16:39:16 +0100 |
commit | 9b9bc4e787d6ecebcf15182a562fc47d27d9880d (patch) | |
tree | b629d6a0c3c6f0d80dbde8e0bc6252d99f1d834e /src/kahnsock.ml | |
parent | 084745ffe51234e366ed6627d9f697c47d87bb4a (diff) | |
download | SystemeReseaux-Projet-9b9bc4e787d6ecebcf15182a562fc47d27d9880d.tar.gz SystemeReseaux-Projet-9b9bc4e787d6ecebcf15182a562fc47d27d9880d.zip |
Added implementation with pipes.
Diffstat (limited to 'src/kahnsock.ml')
-rw-r--r-- | src/kahnsock.ml | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/src/kahnsock.ml b/src/kahnsock.ml new file mode 100644 index 0000000..6cdfadd --- /dev/null +++ b/src/kahnsock.ml @@ -0,0 +1,45 @@ +Random.self_init () + +type ident = (int * int * int * int) +let gen_ident () = + Random.int 1000000000, Random.int 1000000000, + Random.int 1000000000, Random.int 1000000000 + +module Sock : Kahn.S = struct + + (* L'idée : + - L'ensemble des noeuds qui font du calcul est un arbre. + Le premier noeud lancé est la racine de l'arbre ; tous les + noeuds qui se connectent par la suite se connectent à un + noeud déjà présent et sont donc son fils. + - Les processus sont des fermetures de type unit -> unit, + transmises par des canaux + - Un noeud de calcul est un processus ocaml avec un seul + thread. Le parallélisme est coopératif (penser à faire + des binds assez souvent). + - Les noeuds publient régulièrement leur load, ie le nombre + de processus en attente et qui ne sont pas en train + d'attendre des données depuis un canal. Si un noeud a un + voisin dont le load est plus faible que le sien d'une + quantité plus grande que 2, il délègue une tâche. + - Le noeud racine délègue toutes ses tâches et sert uniquement + pour les entrées-sorties + - Comportement indéterminé lorsqu'un noeud se déconnecte + (des processus peuvent disparaître, le réseau est cassé...) + - Les canaux sont identifiés par le type ident décrit + ci-dessus. Lorsque quelqu'un écrit sur un canal, tout le + monde le sait. Lorsque quelqu'un lit sur un canal, tout le + monde le sait. (on n'est pas capable de déterminer + quel est le noeud propriétaire du processus devant lire + le message) Les communications sont donc coûteuses. + *) + + type 'a process = (unit -> 'a) + + type 'a in_port = ident + type 'a out_port = ident + + let cin = (0, 0, 0, 0) + let cout = (0, 0, 0, 1) + +end |