Subversion Repositories eFlore/Applications.coel

Rev

Rev 1468 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
1320 gduche 1
package org.tela_botanica.client.synchronisation;
2
 
3
import java.util.HashMap;
4
import java.util.LinkedList;
5
import java.util.List;
6
 
7
import org.tela_botanica.client.Mediateur;
8
import org.tela_botanica.client.RegistreId;
9
import org.tela_botanica.client.interfaces.Rafraichissable;
10
import org.tela_botanica.client.modeles.Information;
11
import org.tela_botanica.client.util.Debug;
12
 
13
import com.extjs.gxt.ui.client.Registry;
14
import com.extjs.gxt.ui.client.widget.Info;
15
import com.google.gwt.core.client.GWT;
16
import com.google.gwt.user.client.Window;
17
 
18
public class Sequenceur implements Rafraichissable{
19
 
20
	private HashMap<Integer, Requete> requetes;
21
	private int numeroSequence;
22
	private int marqueurRetour = 1;
23
	private Mediateur mediateur = (Mediateur) Registry.get(RegistreId.MEDIATEUR);
24
 
25
	public Sequenceur()	{
26
		requetes = new HashMap<Integer, Requete>();
27
		numeroSequence = 0;
28
	}
29
 
30
	// Retourne le numéro du séquenceur
31
	public int lancerRequeteSynchrone(Rafraichissable vueARafraichir)	{
1468 jpm 32
		if (Mediateur.DEBUG_CHARGEMENT) System.out.println("[CHARGEMENT] lancerRequeteSynchrone("+vueARafraichir.getClass().getName()+")");
33
		//if (numeroSequence == 0)	{
34
			mediateur.activerChargement(this, "Chargement en cours... Veuillez patienter");
35
		//}
36
 
1320 gduche 37
		numeroSequence++;
1367 cyprien 38
		if (Mediateur.DEBUG) System.out.println("==> Sequenceur : Envoi requete n°" + numeroSequence);
1320 gduche 39
		Requete requete = new Requete(vueARafraichir, numeroSequence);
40
		requetes.put(numeroSequence, requete);
1367 cyprien 41
 
1320 gduche 42
		return numeroSequence;
43
	}
44
 
1373 cyprien 45
	//Offrir la possibilité d'enfiler (=mettre à la fin d'une file d'attente) un rafraichissement dont on a déjà le retour
46
	public int enfilerRafraichissement(Rafraichissable vueARafraichir, Object nouvellesDonnees)	{
1468 jpm 47
		//if (numeroSequence == 0)	{
48
			mediateur.activerChargement(this, "Chargement en cours... Veuillez patienter");
49
		//}
1320 gduche 50
		numeroSequence++;
1367 cyprien 51
		if (Mediateur.DEBUG) System.out.println("|| Sequenceur : Empiler n°" + numeroSequence);
1320 gduche 52
		Requete requete = new Requete(vueARafraichir, numeroSequence);
53
		Reponse reponse = new Reponse(nouvellesDonnees, numeroSequence);
54
		requetes.put(numeroSequence, requete);
55
		rafraichir(reponse);
1468 jpm 56
		mediateur.desactiverChargement(this);
1320 gduche 57
		return numeroSequence;
58
	}
59
 
60
	public void rafraichir(Object nouvellesDonnees) {
1367 cyprien 61
 
1320 gduche 62
		try	{
63
			Reponse reponse = (Reponse) nouvellesDonnees;
1367 cyprien 64
			if (Mediateur.DEBUG) System.out.println("<== Sequenceur : Réception d'une réponse, n°" + reponse.obtenirNumeroSequence() + ", marqueur retour " + marqueurRetour);
1468 jpm 65
 
1320 gduche 66
			if (reponse.obtenirNumeroSequence() == marqueurRetour)	{
67
				// Si le numéro de séquence du retour correspond au marqueur, on rafraichit
68
				Requete requete = requetes.get(marqueurRetour);
1367 cyprien 69
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+reponse.obtenirNumeroSequence()+" à "+requete.getVueARafraichir().getClass().toString());
1468 jpm 70
				mediateur.desactiverChargement(this);
1367 cyprien 71
				requete.rafraichir(reponse.obtenirRetour());
1320 gduche 72
				requetes.remove(marqueurRetour);
73
				marqueurRetour++;
74
				avancerSequence();
75
			} else {
76
				// Sinon, on enregistre le retour
77
				requetes.get(reponse.obtenirNumeroSequence()).setRetour(reponse);
78
			}
79
		} catch (ClassCastException e)	{
1367 cyprien 80
			if (Mediateur.DEBUG) {
81
				System.out.println("<== Sequenceur : Réception d'une réponse incorrecte");
82
				System.out.println("    Le séquenceur ne peut recevoir que des Reponse");
83
				System.out.println("    > nouvellesDonnees = "+nouvellesDonnees.getClass().toString());
84
			}
1468 jpm 85
			mediateur.desactiverChargement(this);
1320 gduche 86
		}
87
	}
88
 
89
	public int obtenirNumeroSequence()	{
90
		return this.numeroSequence;
91
	}
92
 
93
	public void avancerSequence()	{
94
		if (requetes.size()>0)	{
1367 cyprien 95
			// on récupère la première requete dans la file
1320 gduche 96
			Requete premiereRequete = requetes.get(marqueurRetour);
1367 cyprien 97
			if (premiereRequete!=null && premiereRequete.hasResponse())	{
98
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+premiereRequete.obtenirReponse().obtenirNumeroSequence()+" à "+premiereRequete.getVueARafraichir().getClass().toString());
1468 jpm 99
				premiereRequete.rafraichir();
100
				mediateur.desactiverChargement(this);
1320 gduche 101
				requetes.remove(marqueurRetour);
102
				marqueurRetour++;
103
				avancerSequence();
104
			}
1367 cyprien 105
		}
1320 gduche 106
	}
107
 
108
 
109
}