fudaa-cvs-commit Mailing List for Fudaa (Page 17)

SourceForge Headquarters 225 Broadway Suite 1600 San Diego, CA 92101 +1 (858) 422-6466

Update of /cvsroot/fudaa/fudaa_devel/dodico/src/org/fudaa/dodico/objet
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv15121/src/org/fudaa/dodico/objet

Modified Files:
	CGestionnaireConnexion.java UsineLib.java 
	RequeteServeurDodico.java DConnexion.java 
Log Message:
MAj

Index: CGestionnaireConnexion.java
===================================================================
RCS file: /cvsroot/fudaa/fudaa_devel/dodico/src/org/fudaa/dodico/objet/CGestionnaireConnexion.java,v
retrieving revision 1.7
retrieving revision 1.8
diff -C2 -d -r1.7 -r1.8
*** CGestionnaireConnexion.java	30 Apr 2004 07:18:36 -0000	1.7
--- CGestionnaireConnexion.java	30 Apr 2004 13:50:59 -0000	1.8
***************
*** 21,29 ****
  public class CGestionnaireConnexion {
    private Hashtable connexions_;
!   //  private Hashtable timeouts_;
    public CGestionnaireConnexion() {
      connexions_= new Hashtable();
      //   timeouts_=new Hashtable();
    }
    public IConnexion[] connexions() {
      IConnexion[] c= new IConnexion[connexions_.size()];
--- 21,34 ----
  public class CGestionnaireConnexion {
    private Hashtable connexions_;
!   /**
!    * Initialisation des connexion
!    */
    public CGestionnaireConnexion() {
      connexions_= new Hashtable();
      //   timeouts_=new Hashtable();
    }
+   /**
+    * @return les connexions etablies
+    */
    public IConnexion[] connexions() {
      IConnexion[] c= new IConnexion[connexions_.size()];
***************
*** 31,34 ****
--- 36,43 ----
      return c;
    }
+   /**
+    * @param p la personne a connecter
+    * @return la connexion pour la personne
+    */
    public IConnexion connexion(IPersonne p) {
  //    IUsine u= UsineLib.findUsine();
***************
*** 44,47 ****
--- 53,60 ----
      return c;
    }
+   /**
+    * @param c la connexion a supprimer
+    * @return true si deconnexion
+    */
    public boolean deconnexion(IConnexion c) {
      if (c == null)
***************
*** 52,95 ****
      //    stopTimeout(c);
      c.connecte(false);
!     String msg= "" + c.utilisateur().enChaine() + " déconnecté";
!     log(c, msg);
      return true;
    }
!   //  private void startTimeout(IConnexion c)
!   //  {
!   //    final IConnexion cc=c;
!   //    TimeoutThread t=new TimeoutThread(cc);
!   //    timeouts_.put(""+c.numero(), t);
!   //    t.start();
!   //  }
!   //
!   //  private void stopTimeout(IConnexion c)
!   //  {
!   //    TimeoutThread t=(TimeoutThread)timeouts_.get(""+c.numero());
!   //    t.arrete();
!   //    try { t.join(); }
!   //    catch( Throwable th ) {}
!   //    timeouts_.remove(""+c.numero());
!   //  }
!   //
!   //  class TimeoutThread extends Thread {
!   //    boolean arrete_=false;
!   //    IConnexion cc_=null;
!   //    public TimeoutThread(IConnexion _cc) { cc_=_cc; }
!   //    public void arrete() { arrete_=true; }
!   //    public void run()
!   //    {
!   //      while( !cc_.timeoutAtteint() && !arrete_ )
!   //        try { Thread.sleep(1000); } catch( InterruptedException e ) {}
!   //      if( arrete_ ) {
!   //        log(cc_, "arrêt du décompte d'inactivité");
!   //      } else {
!   //        log(cc_, "inactif depuis "+
!   //        cc_.tempsInactif()/1000L+
!   //          "s : déconnexion automatique");
!   //        deconnexion(cc_);
!   //      }
!   //    }
!   //  }
    public boolean verifieConnexion(IConnexion c) {
      if (c == null) {
--- 65,76 ----
      //    stopTimeout(c);
      c.connecte(false);
! //    String msg= "" + c.utilisateur().enChaine() + " déconnecté";
!   //  log(c, msg);
      return true;
    }
!   /**
!    * @param c la connexion a verifier
!    * @return true si connexion possible
!    */
    public boolean verifieConnexion(IConnexion c) {
      if (c == null) {
***************
*** 113,118 ****
      return true;
    }
    public void log(IConnexion c, String msg) {
!     c.log(new String[] { msg });
    }
  }
--- 94,103 ----
      return true;
    }
+   /**
+    * @param c la connexion
+    * @param msg le message a suivre
+    */
    public void log(IConnexion c, String msg) {
!     c.log(msg);
    }
  }

Index: UsineLib.java
===================================================================
RCS file: /cvsroot/fudaa/fudaa_devel/dodico/src/org/fudaa/dodico/objet/UsineLib.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** UsineLib.java	30 Apr 2004 07:18:36 -0000	1.1
--- UsineLib.java	30 Apr 2004 13:50:59 -0000	1.2
***************
*** 14,18 ****
  import org.omg.PortableServer.Servant;
  
- import org.fudaa.dodico.boony.BoonyLib;
  import org.fudaa.dodico.commun.DodicoResource;
  import org.fudaa.dodico.corba.objet.IObjet;
--- 14,17 ----
***************
*** 42,45 ****
--- 41,46 ----
    private static IUsine  usine_       = null;
  
+   private static boolean cantChanged_;
+ 
    private static boolean isUsineTypeSet_;
    //true si tous les objets seront locaux : plus rapide
***************
*** 54,69 ****
  
    /**
!    * Permet d'établir la politique corba. Si le fonctionnement est uniquement
!    * en local, l'usine est creee spécialement pour renvoyer des objets java "normaux".
!    * Sinon, des objets corba réels sont utilisés. Si la politique a deja ete
!    * etablie, un message d'erreur est envoyé.
     * @param _b true si tout local
     */
    public static void setAllLocal(boolean _b) {
-     if(_b==isAllLocal_) return;
      if (isUsineTypeSet_) {
        System.err.println("Attention, la politique a déjà été initialisée");
      }
!     usine_=null;
      isUsineTypeSet_ = true;
      isAllLocal_ = _b;
--- 55,82 ----
  
    /**
!    * Seul le cas distant est autorise. Par la suite, il sera impossible de changer le mode de
!    * foncfionnement de corba. Methode a appelee dès le debut de l'appli et ne devrait être appelé que du cote
!    * serveur.
!    */
!   public static void setOnlyDistant() {
!     setAllLocal(false);
!     cantChanged_ = true;
!   }
! 
!   /**
!    * Permet d'établir la politique corba. Si le fonctionnement est uniquement en local, l'usine est
!    * creee spécialement pour renvoyer des objets java "normaux". Sinon, des objets corba réels sont
!    * utilisés. Si la politique a deja ete etablie, un message d'erreur est envoyé.
!    * 
     * @param _b true si tout local
     */
    public static void setAllLocal(boolean _b) {
      if (isUsineTypeSet_) {
        System.err.println("Attention, la politique a déjà été initialisée");
+       if (cantChanged_) {
+         new Throwable("la politique ne peut etre changee").printStackTrace();
+       }
      }
!     usine_ = null;
      isUsineTypeSet_ = true;
      isAllLocal_ = _b;
***************
*** 127,132 ****
      }
      return usine_;
!     
!     
    }
  
--- 140,144 ----
      }
      return usine_;
! 
    }
  
***************
*** 153,179 ****
      }
      if (o == null) return null;
!     
!     else{
!       org.omg.CORBA.Object oc=buildStubFromDObject(o);
        return ITacheHelper.narrow(oc);
      }
    }
!   
!   public static IPersonne createLocalPers(){
!       org.omg.CORBA.Object op=buildStubFromDObject(new DPersonne());
!       IPersonne pers=IPersonneHelper.narrow(op);
!       org.omg.CORBA.Object oo=buildStubFromDObject(new DOrganisme());
!       IOrganisme o=IOrganismeHelper.narrow(oo);
!       pers.nom(DodicoResource.getS("Local"));
!       o.sigle(DodicoResource.getS("Local"));
!       pers.organisme(o);
!       return pers;
!       
    }
  
    /**
     * Recherche une usine. La premiere usine trouvee est sauvegardee dans un champ prive:
!    * l'utilisateur est assuré d'utiliser toujours la meme usine. Si la politique corba est intialisee
!    * "tout local" une usine locale est créée si necessaire.
     * 
     * @param _time le temps a attendre
--- 165,196 ----
      }
      if (o == null) return null;
! 
!     else {
!       org.omg.CORBA.Object oc = buildStubFromDObject(o);
        return ITacheHelper.narrow(oc);
      }
    }
! 
!   /**
!    * Permet de creer une personne sans utiliser l'usine. Pour une connexion a un serveur
!    * local, il ne faut pas créer une personne sur une usine distante.
!    * @return une personne cree dans la machine virtuelle courante.
!    */
!   public static IPersonne createLocalPers() {
!     org.omg.CORBA.Object op = buildStubFromDObject(new DPersonne());
!     IPersonne pers = IPersonneHelper.narrow(op);
!     org.omg.CORBA.Object oo = buildStubFromDObject(new DOrganisme());
!     IOrganisme o = IOrganismeHelper.narrow(oo);
!     pers.nom(DodicoResource.getS("Local"));
!     o.sigle(DodicoResource.getS("Local"));
!     pers.organisme(o);
!     return pers;
! 
    }
  
    /**
     * Recherche une usine. La premiere usine trouvee est sauvegardee dans un champ prive:
!    * l'utilisateur est assuré d'utiliser toujours la meme usine. Si la politique corba est
!    * intialisee "tout local" une usine locale est créée si necessaire.
     * 
     * @param _time le temps a attendre
***************
*** 197,200 ****
--- 214,222 ----
    }
  
+   /**
+    * Cree l'objet corba associe. Si local, le dobjet est renvoyé.
+    * @param _dobjet le delegue
+    * @return l'objet corba correspondante correctement initialise
+    */
    public static org.omg.CORBA.Object buildStubFromDObject(DObjet _dobjet) {
      if (isAllLocal_) {

Index: RequeteServeurDodico.java
===================================================================
RCS file: /cvsroot/fudaa/fudaa_devel/dodico/src/org/fudaa/dodico/objet/RequeteServeurDodico.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -C2 -d -r1.10 -r1.11
*** RequeteServeurDodico.java	30 Apr 2004 07:18:36 -0000	1.10
--- RequeteServeurDodico.java	30 Apr 2004 13:50:59 -0000	1.11
***************
*** 34,37 ****
--- 34,38 ----
    /** */
    public RequeteServeurDodico() {
+     UsineLib.setOnlyDistant();
    }
    /**

Index: DConnexion.java
===================================================================
RCS file: /cvsroot/fudaa/fudaa_devel/dodico/src/org/fudaa/dodico/objet/DConnexion.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -C2 -d -r1.6 -r1.7
*** DConnexion.java	27 Apr 2004 16:05:37 -0000	1.6
--- DConnexion.java	30 Apr 2004 13:51:00 -0000	1.7
***************
*** 23,26 ****
--- 23,29 ----
   */
  public class DConnexion extends DObjet implements IConnexion,IConnexionOperations {
+   /**
+    * 
+    */
    public static java.util.Random RAND= new java.util.Random();
    DateFormat df_;
***************
*** 30,34 ****
    IPersonne utilisateur_;
    int numero_;
-   Vector log_;
    boolean connecte_;
    public DConnexion() {
--- 33,36 ----
***************
*** 40,44 ****
      //    numero(num);
      numero(RAND.nextInt(1000));
-     log_= new Vector();
      //  timeout_=360000000;
      df_= DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.SHORT);
--- 42,45 ----
***************
*** 102,115 ****
      connecte_= c;
    }
!   public String[] log() {
!     String[] res= new String[log_.size()];
!     for (int i= 0; i < res.length; i++)
!       res[i]= (String)log_.get(i);
!     return res;
!   }
!   public void log(String[] msg) {
      dateDerniereAction_= dateCourante();
!     System.err.println("---");
!     for (int i= 0; i < msg.length; i++) {
        String m=
          "CNX #"
--- 103,109 ----
      connecte_= c;
    }
!   public void log(String msg) {
      dateDerniereAction_= dateCourante();
!     System.out.println("---");
        String m=
          "CNX #"
***************
*** 118,126 ****
            + df_.format(new Date(dateDerniereAction_))
            + " : "
!           + msg[i];
!       log_.add(m);
!       System.err.println(m);
!     }
!     System.err.println("---");
    }
  }
--- 112,118 ----
            + df_.format(new Date(dateDerniereAction_))
            + " : "
!           + msg;
!       System.out.println(m);
!     System.out.println("---");
    }
  }

2003	Jan	Feb (89)	Mar (219)	Apr (82)	May (33)	Jun (11)	Jul (129)	Aug (357)	Sep (34)	Oct (37)	Nov (42)	Dec (182)
2004	Jan (59)	Feb (74)	Mar (196)	Apr (205)	May (109)	Jun (268)	Jul	Aug	Sep	Oct	Nov	Dec

fudaa-cvs-commit Mailing List for Fudaa (Page 17)

https://gitlab.com/fudaa

fudaa-cvs-commit — Mailing list for CVS commit messages