Subversion Repositories eFlore/Applications.coel

Rev

Go to most recent revision | Details | 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)	{
32
 
1468 jpm 33
		if (Mediateur.DEBUG_CHARGEMENT) System.out.println("[CHARGEMENT] lancerRequeteSynchrone("+vueARafraichir.getClass().getName()+")");
34
		//if (numeroSequence == 0)	{
35
			mediateur.activerChargement(this, "Chargement en cours... Veuillez patienter");
36
		//}
37
 
1320 gduche 38
		numeroSequence++;
1367 cyprien 39
		if (Mediateur.DEBUG) System.out.println("==> Sequenceur : Envoi requete n°" + numeroSequence);
1320 gduche 40
		Requete requete = new Requete(vueARafraichir, numeroSequence);
41
		requetes.put(numeroSequence, requete);
1367 cyprien 42
 
1320 gduche 43
		return numeroSequence;
44
	}
45
 
1373 cyprien 46
	//Offrir la possibilité d'enfiler (=mettre à la fin d'une file d'attente) un rafraichissement dont on a déjà le retour
47
	public int enfilerRafraichissement(Rafraichissable vueARafraichir, Object nouvellesDonnees)	{
1468 jpm 48
		//if (numeroSequence == 0)	{
49
			mediateur.activerChargement(this, "Chargement en cours... Veuillez patienter");
50
		//}
1320 gduche 51
		numeroSequence++;
1367 cyprien 52
		if (Mediateur.DEBUG) System.out.println("|| Sequenceur : Empiler n°" + numeroSequence);
1320 gduche 53
		Requete requete = new Requete(vueARafraichir, numeroSequence);
54
		Reponse reponse = new Reponse(nouvellesDonnees, numeroSequence);
55
		requetes.put(numeroSequence, requete);
56
		rafraichir(reponse);
1468 jpm 57
		mediateur.desactiverChargement(this);
1320 gduche 58
		return numeroSequence;
59
	}
60
 
61
	public void rafraichir(Object nouvellesDonnees) {
1367 cyprien 62
 
1320 gduche 63
		try	{
64
			Reponse reponse = (Reponse) nouvellesDonnees;
1367 cyprien 65
			if (Mediateur.DEBUG) System.out.println("<== Sequenceur : Réception d'une réponse, n°" + reponse.obtenirNumeroSequence() + ", marqueur retour " + marqueurRetour);
1468 jpm 66
 
1320 gduche 67
			if (reponse.obtenirNumeroSequence() == marqueurRetour)	{
68
				// Si le numéro de séquence du retour correspond au marqueur, on rafraichit
69
				Requete requete = requetes.get(marqueurRetour);
1367 cyprien 70
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+reponse.obtenirNumeroSequence()+" à "+requete.getVueARafraichir().getClass().toString());
1468 jpm 71
				mediateur.desactiverChargement(this);
1367 cyprien 72
				requete.rafraichir(reponse.obtenirRetour());
1320 gduche 73
				requetes.remove(marqueurRetour);
74
				marqueurRetour++;
75
				avancerSequence();
76
			} else {
77
				// Sinon, on enregistre le retour
78
				requetes.get(reponse.obtenirNumeroSequence()).setRetour(reponse);
79
			}
80
		} catch (ClassCastException e)	{
1367 cyprien 81
			if (Mediateur.DEBUG) {
82
				System.out.println("<== Sequenceur : Réception d'une réponse incorrecte");
83
				System.out.println("    Le séquenceur ne peut recevoir que des Reponse");
84
				System.out.println("    > nouvellesDonnees = "+nouvellesDonnees.getClass().toString());
85
			}
1468 jpm 86
			mediateur.desactiverChargement(this);
1320 gduche 87
		}
88
	}
89
 
90
	public int obtenirNumeroSequence()	{
91
		return this.numeroSequence;
92
	}
93
 
94
	public void avancerSequence()	{
95
		if (requetes.size()>0)	{
1367 cyprien 96
			// on récupère la première requete dans la file
1320 gduche 97
			Requete premiereRequete = requetes.get(marqueurRetour);
1367 cyprien 98
			if (premiereRequete!=null && premiereRequete.hasResponse())	{
99
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+premiereRequete.obtenirReponse().obtenirNumeroSequence()+" à "+premiereRequete.getVueARafraichir().getClass().toString());
1468 jpm 100
				premiereRequete.rafraichir();
101
				mediateur.desactiverChargement(this);
1320 gduche 102
				requetes.remove(marqueurRetour);
103
				marqueurRetour++;
104
				avancerSequence();
105
			}
1367 cyprien 106
		}
1320 gduche 107
	}
108
 
109
 
110
}