Subversion Repositories eFlore/Applications.coel

Rev

Rev 1320 | Rev 1415 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1320 Rev 1367
Line 21... Line 21...
21 
	private int numeroSequence;
 21 
	private int numeroSequence;
22 
	private int marqueurRetour = 1;
 22 
	private int marqueurRetour = 1;
23 
	private Mediateur mediateur = (Mediateur) Registry.get(RegistreId.MEDIATEUR);
 23 
	private Mediateur mediateur = (Mediateur) Registry.get(RegistreId.MEDIATEUR);
Line 24... Line 24...
24
24
25 
	public Sequenceur()	{
 - 
 
26 
		this.mediateur = mediateur;
 - 
 
27 
		//requetes = new LinkedList<Requete>();
 25 
	public Sequenceur()	{
28 
		requetes = new HashMap<Integer, Requete>();
 26 
		requetes = new HashMap<Integer, Requete>();
29 
		numeroSequence = 0;
 27 
		numeroSequence = 0;
Line 30... Line 28...
30 
	}
 28 
	}
Line 34... Line 32...
34 
		if (numeroSequence == 0)	{
 32 
		if (numeroSequence == 0)	{
35 
			mediateur.activerChargement("Chargement en cours... Veuillez patienter");
 33 
			mediateur.activerChargement("Chargement en cours... Veuillez patienter");
36 
		}
 34 
		}
Line 37... Line 35...
37
35
38 
		numeroSequence++;
 36 
		numeroSequence++;
39 
		System.out.println("lancer Requete " + numeroSequence);
 37 
		if (Mediateur.DEBUG) System.out.println("==> Sequenceur : Envoi requete n°" + numeroSequence);
40 
		Requete requete = new Requete(vueARafraichir, numeroSequence);
 - 
 
41 
		//requetes.add(requete);
 38 
		Requete requete = new Requete(vueARafraichir, numeroSequence);
- 
 
 39 
		requetes.put(numeroSequence, requete);
42 
		requetes.put(numeroSequence, requete);
 40
43 
		return numeroSequence;
 41 
		return numeroSequence;
Line 44... Line 42...
44 
	}
 42 
	}
45
43
46 
	//Offrir la possibilité d'empiler à la suite des traitements un rafraichissement dont on a déjà le retour
 44 
	//Offrir la possibilité d'empiler à la suite des traitements un rafraichissement dont on a déjà le retour
47 
	public int empilerRafraichissement(Rafraichissable vueARafraichir, Object nouvellesDonnees)	{
 45 
	public int empilerRafraichissement(Rafraichissable vueARafraichir, Object nouvellesDonnees)	{
48 
		if (numeroSequence == 0)	{
 46 
		if (numeroSequence == 0)	{
49 
			mediateur.activerChargement("Chargement en cours... Veuillez patienter");
 47 
			mediateur.activerChargement("Chargement en cours... Veuillez patienter");
50 
		}
 48 
		}
51 
		numeroSequence++;
 49 
		numeroSequence++;
52 
		System.out.println("empiler " + numeroSequence);
 50 
		if (Mediateur.DEBUG) System.out.println("|| Sequenceur : Empiler n°" + numeroSequence);
53 
		Requete requete = new Requete(vueARafraichir, numeroSequence);
 51 
		Requete requete = new Requete(vueARafraichir, numeroSequence);
54 
		Reponse reponse = new Reponse(nouvellesDonnees, numeroSequence);
 52 
		Reponse reponse = new Reponse(nouvellesDonnees, numeroSequence);
- 
 
 53 
		requetes.put(numeroSequence, requete);
55 
		requetes.put(numeroSequence, requete);
 54 
		rafraichir(reponse);
56 
		rafraichir(reponse);
 55 
		mediateur.desactiverChargement();
Line 57... Line 56...
57 
		return numeroSequence;
 56 
		return numeroSequence;
58 
	}
 57 
	}
59
58
60 
	public void rafraichir(Object nouvellesDonnees) {
 59 
	public void rafraichir(Object nouvellesDonnees) {
61
60 
 
Line 62... Line 61...
62 
		try	{
 61 
		try	{
63 
			Reponse reponse = (Reponse) nouvellesDonnees;
 62 
			Reponse reponse = (Reponse) nouvellesDonnees;
64 
			System.out.println("rafraichir " + reponse.obtenirNumeroSequence() + " marqueur retour " + marqueurRetour);
 63 
			if (Mediateur.DEBUG) System.out.println("<== Sequenceur : Réception d'une réponse, n°" + reponse.obtenirNumeroSequence() + ", marqueur retour " + marqueurRetour);
- 
 
 64
65
65 
			if (reponse.obtenirNumeroSequence() == marqueurRetour)	{
66 
			if (reponse.obtenirNumeroSequence() == marqueurRetour)	{
 66 
				// Si le numéro de séquence du retour correspond au marqueur, on rafraichit
67 
				// Si le numéro de séquence du retour correspond au marqueur, on rafraichit
 67 
				Requete requete = requetes.get(marqueurRetour);
68 
				Requete requete = requetes.get(marqueurRetour);
 68 
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+reponse.obtenirNumeroSequence()+" à "+requete.getVueARafraichir().getClass().toString());
69 
				requete.setRetour(reponse);
 69 
				requete.rafraichir(reponse.obtenirRetour());
70 
				requete.rafraichir();
 70 
				mediateur.desactiverChargement();
71 
				requetes.remove(marqueurRetour);
 71 
				requetes.remove(marqueurRetour);
72 
				marqueurRetour++;
 72 
				marqueurRetour++;
73 
				avancerSequence();
 - 
 
74 
			} else {
 - 
 
75 
				// Sinon, on enregistre le retour
 - 
 
76 
				requetes.get(reponse.obtenirNumeroSequence()).setRetour(reponse);
 73 
				avancerSequence();
77
74 
			} else {
- 
 
 75 
				// Sinon, on enregistre le retour
- 
 
 76 
				requetes.get(reponse.obtenirNumeroSequence()).setRetour(reponse);
78 
				// Vérifier que les requetes précédentes ont été exécutées si elles ont eues un retour
 77 
			}
- 
 
 78 
		} catch (ClassCastException e)	{
- 
 
 79 
			if (Mediateur.DEBUG) {
- 
 
 80 
				System.out.println("<== Sequenceur : Réception d'une réponse incorrecte");
79 
				//avancerSequence();
 81 
				System.out.println("    Le séquenceur ne peut recevoir que des Reponse");
80 
			}
 82 
				System.out.println("    > nouvellesDonnees = "+nouvellesDonnees.getClass().toString());
Line 81... Line 83...
81 
		} catch (ClassCastException e)	{
 83 
			}
82 
			Debug.log("Le séquencuer ne peut recevoir que des Reponse");
 84 
			mediateur.desactiverChargement();
83 
		}
 85 
		}
Line 84... Line 86...
84 
	}
 86 
	}
85
87
- 
 
 88 
	public int obtenirNumeroSequence()	{
86 
	public int obtenirNumeroSequence()	{
 89 
		return this.numeroSequence;
87 
		return this.numeroSequence;
 - 
 
88 
	}
 90 
	}
- 
 
 91
89
92 
	public void avancerSequence()	{
- 
 
 93 
		if (requetes.size()>0)	{
90 
	public void avancerSequence()	{
 94 
			// on récupère la première requete dans la file
91 
		if (requetes.size()>0)	{
 95 
			Requete premiereRequete = requetes.get(marqueurRetour);
92 
			Requete premiereRequete = requetes.get(marqueurRetour);
 96 
			if (premiereRequete!=null && premiereRequete.hasResponse())	{
93 
			System.out.println("premiere Requete " + premiereRequete );
 97 
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+premiereRequete.obtenirReponse().obtenirNumeroSequence()+" à "+premiereRequete.getVueARafraichir().getClass().toString());
94 
			if (premiereRequete!=null && premiereRequete.aRetour())	{
 - 
 
95 
				premiereRequete.rafraichir();
 - 
 
96 
				requetes.remove(marqueurRetour);
 98 
				premiereRequete.rafraichir();
97 
				marqueurRetour++;
 - 
 
98 
				avancerSequence();
 99 
				mediateur.desactiverChargement();
Line 99... Line 100...
99 
			}
100 
				requetes.remove(marqueurRetour);