Subversion Repositories eFlore/Applications.coel

Rev

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

Rev 1383 Rev 1440
Line 27... Line 27...
27
		numeroSequence = 0;
27
		numeroSequence = 0;
28
	}
28
	}
Line 29... Line 29...
29
	
29
	
30
	// Retourne le numéro du séquenceur
30
	// Retourne le numéro du séquenceur
31
	public int lancerRequeteSynchrone(Rafraichissable vueARafraichir)	{
31
	public int lancerRequeteSynchrone(Rafraichissable vueARafraichir)	{
32
		if (numeroSequence == 0)	{
32
		//if (numeroSequence == 0)	{
33
			mediateur.activerChargement("Chargement en cours... Veuillez patienter");
33
			mediateur.activerChargement(this, "Chargement en cours... Veuillez patienter");
Line 34... Line 34...
34
		}
34
		//}
35
		
35
		
36
		numeroSequence++;
36
		numeroSequence++;
37
		if (Mediateur.DEBUG) System.out.println("==> Sequenceur : Envoi requete n°" + numeroSequence);
37
		if (Mediateur.DEBUG) System.out.println("==> Sequenceur : Envoi requete n°" + numeroSequence);
Line 41... Line 41...
41
		return numeroSequence;
41
		return numeroSequence;
42
	}
42
	}
Line 43... Line 43...
43
	
43
	
44
	//Offrir la possibilité d'enfiler (=mettre à la fin d'une file d'attente) un rafraichissement dont on a déjà le retour
44
	//Offrir la possibilité d'enfiler (=mettre à la fin d'une file d'attente) un rafraichissement dont on a déjà le retour
45
	public int enfilerRafraichissement(Rafraichissable vueARafraichir, Object nouvellesDonnees)	{
45
	public int enfilerRafraichissement(Rafraichissable vueARafraichir, Object nouvellesDonnees)	{
46
		if (numeroSequence == 0)	{
46
		//if (numeroSequence == 0)	{
47
			mediateur.activerChargement("Chargement en cours... Veuillez patienter");
47
			mediateur.activerChargement(this, "Chargement en cours... Veuillez patienter");
48
		}
48
		//}
49
		numeroSequence++;
49
		numeroSequence++;
50
		if (Mediateur.DEBUG) System.out.println("|| Sequenceur : Empiler n°" + numeroSequence);
50
		if (Mediateur.DEBUG) System.out.println("|| Sequenceur : Empiler n°" + numeroSequence);
51
		Requete requete = new Requete(vueARafraichir, numeroSequence);
51
		Requete requete = new Requete(vueARafraichir, numeroSequence);
52
		Reponse reponse = new Reponse(nouvellesDonnees, numeroSequence);
52
		Reponse reponse = new Reponse(nouvellesDonnees, numeroSequence);
53
		requetes.put(numeroSequence, requete);
53
		requetes.put(numeroSequence, requete);
54
		rafraichir(reponse);
54
		rafraichir(reponse);
55
		mediateur.desactiverChargement();
55
		mediateur.desactiverChargement(this);
56
		return numeroSequence;
56
		return numeroSequence;
Line 57... Line 57...
57
	}
57
	}
Line 65... Line 65...
65
			if (reponse.obtenirNumeroSequence() == marqueurRetour)	{
65
			if (reponse.obtenirNumeroSequence() == marqueurRetour)	{
66
				// Si le numéro de séquence du retour correspond au marqueur, on rafraichit
66
				// Si le numéro de séquence du retour correspond au marqueur, on rafraichit
67
				Requete requete = requetes.get(marqueurRetour);
67
				Requete requete = requetes.get(marqueurRetour);
68
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+reponse.obtenirNumeroSequence()+" à "+requete.getVueARafraichir().getClass().toString());
68
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+reponse.obtenirNumeroSequence()+" à "+requete.getVueARafraichir().getClass().toString());
69
				requete.rafraichir(reponse.obtenirRetour());
69
				requete.rafraichir(reponse.obtenirRetour());
70
				mediateur.desactiverChargement();
70
				mediateur.desactiverChargement(this);
71
				requetes.remove(marqueurRetour);
71
				requetes.remove(marqueurRetour);
72
				marqueurRetour++;
72
				marqueurRetour++;
73
				avancerSequence();
73
				avancerSequence();
74
			} else {
74
			} else {
75
				// Sinon, on enregistre le retour
75
				// Sinon, on enregistre le retour
Line 79... Line 79...
79
			if (Mediateur.DEBUG) {
79
			if (Mediateur.DEBUG) {
80
				System.out.println("<== Sequenceur : Réception d'une réponse incorrecte");
80
				System.out.println("<== Sequenceur : Réception d'une réponse incorrecte");
81
				System.out.println("    Le séquenceur ne peut recevoir que des Reponse");
81
				System.out.println("    Le séquenceur ne peut recevoir que des Reponse");
82
				System.out.println("    > nouvellesDonnees = "+nouvellesDonnees.getClass().toString());
82
				System.out.println("    > nouvellesDonnees = "+nouvellesDonnees.getClass().toString());
83
			}
83
			}
84
			mediateur.desactiverChargement();
84
			mediateur.desactiverChargement(this);
85
		}
85
		}
86
	}
86
	}
Line 87... Line 87...
87
	
87
	
88
	public int obtenirNumeroSequence()	{
88
	public int obtenirNumeroSequence()	{
Line 93... Line 93...
93
		if (requetes.size()>0)	{
93
		if (requetes.size()>0)	{
94
			// on récupère la première requete dans la file
94
			// on récupère la première requete dans la file
95
			Requete premiereRequete = requetes.get(marqueurRetour);
95
			Requete premiereRequete = requetes.get(marqueurRetour);
96
			if (premiereRequete!=null && premiereRequete.hasResponse())	{
96
			if (premiereRequete!=null && premiereRequete.hasResponse())	{
97
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+premiereRequete.obtenirReponse().obtenirNumeroSequence()+" à "+premiereRequete.getVueARafraichir().getClass().toString());
97
				if (Mediateur.DEBUG) System.out.println("<|-- Sequenceur : Retourne paquet n°"+premiereRequete.obtenirReponse().obtenirNumeroSequence()+" à "+premiereRequete.getVueARafraichir().getClass().toString());
98
				premiereRequete.rafraichir();
98
				premiereRequete.rafraichir();				
99
				mediateur.desactiverChargement();
99
				mediateur.desactiverChargement(this);
100
				requetes.remove(marqueurRetour);
100
				requetes.remove(marqueurRetour);
101
				marqueurRetour++;
101
				marqueurRetour++;
102
				avancerSequence();
102
				avancerSequence();
103
			} 
103
			} 
104
		}		
104
		}