- Isis-fish-commits - mailman.cloud.codelutin.com

r2819 - isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher
by chatellier＠users.labs.libre-entreprise.org 11 Dec '09

11 Dec '09

Author: chatellier Date: 2009-12-11 13:41:02 +0000 (Fri, 11 Dec 2009) New Revision: 2819 Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationItem.java Log: Add parameters to know if a zip file can be common to multiples simulations (AS). Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationItem.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationItem.java 2009-12-11 13:22:47 UTC (rev 2818) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationItem.java 2009-12-11 13:41:02 UTC (rev 2819) @@ -35,12 +35,19 @@ * <li>d'informations supplémentaires utiles à certains launcher : * <ul> * <li>standaloneSimulation : la simulation doit être lancée seule, sinon - * les simulations sont indépendantes et peuvent être lancées groupées. + * les simulations sont indépendantes et peuvent être lancées groupées + * ({@code true} par defaut) + * <li>simulationStandaloneZip : si le fichier zip est different pour toute + * les simulations ou s'il peut être commun à un esemble de simulation * <li>simulationNumber : simulation number in non standalone simulation * <li>simulationsCount : total simulation count + * <li>lastSimulation : last simulation in a simulation pool * </ul> * </ul> * + * Les valeurs par defaut sont positionnée de telle sorte qu'une simulation + * est considérée par defaut comme totalement indépendante. + * * @author poussin * @version $Revision$ * @@ -58,6 +65,13 @@ /** Le zip contenant la simulation prete a etre executee. */ protected File simulationZip; + /** + * Si vrai, le fichier zip n'est pas commun à un ensemble de simulations. + * + * Default to {@code true}. + */ + protected boolean standaloneSimulationZip = true; + /** Simulation prescript. */ protected String simulationPrescriptContent; @@ -75,7 +89,7 @@ protected int simulationNumber = -1; /** - * Last simulation. + * last simulation in a simulation pool. */ protected boolean lastSimulation; @@ -133,6 +147,20 @@ } /** + * @return the standaloneSimulationZip + */ + public boolean isStandaloneSimulationZip() { + return standaloneSimulationZip; + } + + /** + * @param standaloneSimulationZip the standaloneSimulationZip to set + */ + public void setStandaloneSimulationZip(boolean standaloneSimulationZip) { + this.standaloneSimulationZip = standaloneSimulationZip; + } + + /** * Get simulation prescript. * * @return the simulationPrescriptPath

1 0

r2818 - isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher
by chatellier＠users.labs.libre-entreprise.org 11 Dec '09

11 Dec '09

Author: chatellier Date: 2009-12-11 13:22:47 +0000 (Fri, 11 Dec 2009) New Revision: 2818 Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationServiceTableModel.java Log: Set empty string value to fix division by 0 Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationServiceTableModel.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationServiceTableModel.java 2009-12-11 11:27:03 UTC (rev 2817) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationServiceTableModel.java 2009-12-11 13:22:47 UTC (rev 2818) @@ -61,13 +61,17 @@ private static Log log = LogFactory .getLog(SimulationServiceTableModel.class); + /** Columns names. */ protected final static String[] columnHeader = new String[] { - _("isisfish.queue.id"), _("isisfish.queue.plan"), - _("isisfish.queue.launcher"), _("isisfish.queue.status"), + _("isisfish.queue.id"), + _("isisfish.queue.plan"), + _("isisfish.queue.launcher"), + _("isisfish.queue.status"), _("isisfish.queue.progression"), }; - /** columns types */ - protected Class<?>[] columnClass = new Class[] { String.class, // id + /** Columns types. */ + protected Class<?>[] columnClass = new Class[] { + String.class, // id String.class, // analyse plan number String.class, // local, remote, batch String.class, // text @@ -201,7 +205,7 @@ // TODO IndexOutOfBoundException here // Concurrent problem ? - if(rowIndex >= jobs.size()) { + if (rowIndex >= jobs.size()) { return null; } @@ -252,14 +256,17 @@ break; case 4: JProgressBar pb = getProgressBar(job); - pb.setMaximum((int)control.getProgressMax()); - pb.setValue((int)control.getProgress()); + pb.setMaximum((int) control.getProgressMax()); + pb.setValue((int) control.getProgress()); // progress can be used for other things Date date = control.getDate(); if (date != null) { pb.setString(date.getMonth() + "/" + date.getYear()); } + else { + pb.setString(""); + } result = pb; break; }

1 0

r2817 - isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher
by chatellier＠users.labs.libre-entreprise.org 11 Dec '09

11 Dec '09

Author: chatellier Date: 2009-12-11 11:27:03 +0000 (Fri, 11 Dec 2009) New Revision: 2817 Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationItem.java Log: Set default simulation number to -1 (non sens) Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationItem.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationItem.java 2009-12-10 18:25:19 UTC (rev 2816) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationItem.java 2009-12-11 11:27:03 UTC (rev 2817) @@ -72,7 +72,7 @@ /** * Simulation number in non standalone simulation. */ - protected int simulationNumber; + protected int simulationNumber = -1; /** * Last simulation.

1 0

r2816 - isis-fish/trunk/src/main/java/fr/ifremer/isisfish
by chatellier＠users.labs.libre-entreprise.org 10 Dec '09

10 Dec '09

Author: chatellier Date: 2009-12-10 18:25:19 +0000 (Thu, 10 Dec 2009) New Revision: 2816 Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/IsisConfig.java Log: Revert comment config Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/IsisConfig.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/IsisConfig.java 2009-12-10 18:21:01 UTC (rev 2815) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/IsisConfig.java 2009-12-10 18:25:19 UTC (rev 2816) @@ -849,7 +849,7 @@ // on supprime car non compatible, les valeurs par defaut sont tres bien "localSimulator", null, "vcs.databaseVersion", null, - //"vcs.hostName", null, + "vcs.hostName", null, "vcs.noPassPhrase", null, "vcs.remoteDatabase", null, "vcs.remotePath", null,

1 0

r2815 - in isis-fish/trunk/src/main: java/fr/ifremer/isisfish java/fr/ifremer/isisfish/ui resources/i18n
by chatellier＠users.labs.libre-entreprise.org 10 Dec '09

10 Dec '09

Author: chatellier Date: 2009-12-10 18:21:01 +0000 (Thu, 10 Dec 2009) New Revision: 2815 Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/IsisConfig.java isis-fish/trunk/src/main/java/fr/ifremer/isisfish/ui/WelcomeUI.jaxx isis-fish/trunk/src/main/resources/i18n/isis-fish-en_GB.properties isis-fish/trunk/src/main/resources/i18n/isis-fish-fr_FR.properties Log: Add monitoring folder Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/IsisConfig.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/IsisConfig.java 2009-12-10 17:00:49 UTC (rev 2814) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/IsisConfig.java 2009-12-10 18:21:01 UTC (rev 2815) @@ -244,8 +244,24 @@ return result; } - + /** + * Retourne le repertoire ou sont stockes les informations relatives + * aux simulations en cours. + * + * @return monitoring directory + */ + public File getMonitoringDirectory() { + File result = getOptionAsFile(Option.MONITORING_DIRECTORY.key); + + if (!result.exists()) { + result.mkdirs(); + } + + return result; + } + + /** * Get javadoc directory. * * Create directory if not exists. @@ -833,7 +849,7 @@ // on supprime car non compatible, les valeurs par defaut sont tres bien "localSimulator", null, "vcs.databaseVersion", null, - "vcs.hostName", null, + //"vcs.hostName", null, "vcs.noPassPhrase", null, "vcs.remoteDatabase", null, "vcs.remotePath", null, @@ -889,6 +905,7 @@ public static enum Option implements OptionDef { COMPILATION_DIRECTORY("compilation.directory", _("isisfish.config.main.compileDirectory.description"), getUserHome() + File.separator + "isis-build"), + MONITORING_DIRECTORY("monitoring.directory", _("isisfish.config.main.monitoringDirectory.description"), getUserHome() + File.separator + "isis-monitoring"), JAVADOC_DIRECTORY("javadoc.directory", _("isisfish.config.main.javadocDirectory.description"), getUserHome() + File.separator + "isis-docs"), CONFIG_FILE(CONFIG_FILE_NAME, _("isisfish.config.main.configFileName.description"), CONFIG_FILENAME), BACKUP_DIRECTORY("backup.directory", _("isisfish.config.main.defaultBackupDirectory.description"), getUserHome() + File.separator + "isis-backup"), Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/ui/WelcomeUI.jaxx =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/ui/WelcomeUI.jaxx 2009-12-10 17:00:49 UTC (rev 2814) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/ui/WelcomeUI.jaxx 2009-12-10 18:21:01 UTC (rev 2815) @@ -112,6 +112,7 @@ IsisConfig.Option.CONFIG_FILE, IsisConfig.Option.DATABASE_DIRECTORY, IsisConfig.Option.COMPILATION_DIRECTORY, + IsisConfig.Option.MONITORING_DIRECTORY, IsisConfig.Option.JAVADOC_DIRECTORY, IsisConfig.Option.BACKUP_DIRECTORY, IsisConfig.Option.DEFAULT_EXPORT_DIRECTORY, Modified: isis-fish/trunk/src/main/resources/i18n/isis-fish-en_GB.properties =================================================================== --- isis-fish/trunk/src/main/resources/i18n/isis-fish-en_GB.properties 2009-12-10 17:00:49 UTC (rev 2814) +++ isis-fish/trunk/src/main/resources/i18n/isis-fish-en_GB.properties 2009-12-10 18:21:01 UTC (rev 2815) @@ -162,6 +162,7 @@ isisfish.config.main.localSimulator.description= isisfish.config.main.locale.description=user locale isisfish.config.main.login.description= +isisfish.config.main.monitoringDirectory.description=Folder containing all necessary information needed to restart simulation isisfish.config.main.password.description= isisfish.config.main.regionMap.description= isisfish.config.main.remoteCaparmor.description= Modified: isis-fish/trunk/src/main/resources/i18n/isis-fish-fr_FR.properties =================================================================== --- isis-fish/trunk/src/main/resources/i18n/isis-fish-fr_FR.properties 2009-12-10 17:00:49 UTC (rev 2814) +++ isis-fish/trunk/src/main/resources/i18n/isis-fish-fr_FR.properties 2009-12-10 18:21:01 UTC (rev 2815) @@ -151,17 +151,18 @@ isisfish.config.main.defaultBackupDirectory.description=le r\u00E9pertoire o\u00F9 stocker les backups des donn\u00E9es isisfish.config.main.defaultExportDirectory.description=le r\u00E9pertoire o\u00F9 exporter les r\u00E9sultats des simulations isisfish.config.main.defaultExportNames.description=les noms des exports \u00E0 effectuer apr\u00E8s une simulation -isisfish.config.main.defaultMapFile.description=TODO +isisfish.config.main.defaultMapFile.description=noms de la carte par d\u00E9faut pour une base sans cartes isisfish.config.main.defaultResultNames.description=les noms des r\u00E9sultats \u00E0 traiter apr\u00E8s une simulation isisfish.config.main.defaultSimulator.description=le nom du simulateur par d\u00E9faut \u00E0 utiliser lors d'une simulation -isisfish.config.main.defaultTagValue.description=TODO +isisfish.config.main.defaultTagValue.description= isisfish.config.main.encoding.description=l'encoding du syst\u00E8me -isisfish.config.main.javadocDirectory.description= +isisfish.config.main.javadocDirectory.description=dossier de g\u00E9n\u00E9ration de la javadoc des scripts isisfish.config.main.javadocURL.description=l'url de la javadoc des scripts isisfish.config.main.launchUI.description= isisfish.config.main.localSimulator.description=pour indiquer si les simulations sont \u00E0 effectuer localement isisfish.config.main.locale.description=la locale utilisateur isisfish.config.main.login.description=le login pour se connecter au serveur de simulations distant +isisfish.config.main.monitoringDirectory.description=Dossier contenant les informations permettant de relancer les simulations isisfish.config.main.password.description=le mot de passe pour se connecter au serveur de simulations distant isisfish.config.main.regionMap.description=le nom du r\u00E9pertoire contenant les maps d'une r\u00E9gion isisfish.config.main.remoteCaparmor.description=lance les simulations sur un serveur distant

1 0

r2814 - isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator
by chatellier＠users.labs.libre-entreprise.org 10 Dec '09

10 Dec '09

Author: chatellier Date: 2009-12-10 17:00:49 +0000 (Thu, 10 Dec 2009) New Revision: 2814 Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulationControl.java Log: Remove xml-rpc client and server Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulationControl.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulationControl.java 2009-12-10 16:58:27 UTC (rev 2813) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulationControl.java 2009-12-10 17:00:49 UTC (rev 2814) @@ -21,8 +21,6 @@ import java.beans.PropertyChangeEvent; import java.beans.PropertyChangeListener; import java.beans.PropertyChangeSupport; -import java.util.Hashtable; -import java.util.Map; import java.util.Properties; import org.apache.commons.logging.Log; @@ -48,7 +46,7 @@ private static Log log = LogFactory.getLog(SimulationControl.class); protected PropertyChangeSupport listeners = new PropertyChangeSupport(this); - protected boolean inUpdateFromHashtable = false; + protected boolean inUpdateFromProperties = false; protected transient SimulationStorage simulation = null; protected String id = null; @@ -60,9 +58,6 @@ protected long progress = 0; protected String text = ""; - /** @deprecated only used in isis xml-rpc server. */ - protected Map<String, Object> update = new Hashtable<String, Object>(); - /** * * @param id simulation id @@ -274,22 +269,6 @@ } /** - * Convert current object in hashtable representation, and clear hashtable - * that contains last modified field. - * - * @return object hashtable representation - * @deprecated only used in xml-rpc isis server - */ - public Hashtable<String, Object> getUpdateHashtable() { - Hashtable<String, Object> result = new Hashtable<String, Object>(update); - update.clear(); - - result.put("id", getId()); - - return result; - } - - /** * Met dans un Properties tous les champs * @return un Properties avec tous les champs */ @@ -315,7 +294,7 @@ * @param props new properties to update from */ public void updateFromProperties(Properties props) { - inUpdateFromHashtable = true; + inUpdateFromProperties = true; if (log.isTraceEnabled()) { log.trace("updateFromProperties properties = " + props.toString()); @@ -359,61 +338,15 @@ setText(text); } } finally { - inUpdateFromHashtable = false; + inUpdateFromProperties = false; } } - /** - * update current object from hashtable representation - * - * @deprecated only used in xml-rpc isis server - */ - public void updateFromHashtable(Hashtable<String, Object> h) { - inUpdateFromHashtable = true; - try { - if (h.containsKey("started")) { - boolean started = (Boolean) h.get("started"); - setStarted(started); - } - if (h.containsKey("running")) { - boolean running = (Boolean) h.get("running"); - setRunning(running); - } - if (h.containsKey("stop")) { - boolean stop = (Boolean) h.get("stop"); - setStopSimulationRequest(stop); - } - if (h.containsKey("date")) { - Date date = new Date((Integer) h.get("date")); - setDate(date); - } - if (h.containsKey("progressMax")) { - long progressMax = (Long) h.get("progressMax"); - setProgressMax(progressMax); - } - if (h.containsKey("progress")) { - long progress = (Long) h.get("progress"); - setProgress(progress); - } - if (h.containsKey("text")) { - String text = (String) h.get("text"); - setText(text); - } - } finally { - inUpdateFromHashtable = false; - } - } - /* * @see java.beans.PropertyChangeListener#propertyChange(java.beans.PropertyChangeEvent) */ public void propertyChange(PropertyChangeEvent e) { - String property = e.getPropertyName(); - if (inUpdateFromHashtable) { - update.remove(property); - } else { - Object value = e.getNewValue(); - update.put(property, value); + if (!inUpdateFromProperties) { if (getSimulation() != null) { getSimulation().saveControl(this); }

1 0

r2813 - in isis-fish/trunk: . src/main/java/fr/ifremer/isisfish/simulator src/main/java/fr/ifremer/isisfish/simulator/launcher
by chatellier＠users.labs.libre-entreprise.org 10 Dec '09

10 Dec '09

Author: chatellier Date: 2009-12-10 16:58:27 +0000 (Thu, 10 Dec 2009) New Revision: 2813 Removed: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulatorServer.java isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/IsisFishServerSimulationLauncher.java Modified: isis-fish/trunk/pom.xml Log: Remove xml-rpc client and server Modified: isis-fish/trunk/pom.xml =================================================================== --- isis-fish/trunk/pom.xml 2009-12-10 15:07:57 UTC (rev 2812) +++ isis-fish/trunk/pom.xml 2009-12-10 16:58:27 UTC (rev 2813) @@ -145,28 +145,6 @@ <version>1.0.12</version> </dependency> -  - <dependency> - <groupId>org.apache.xmlrpc</groupId> - <artifactId>xmlrpc-client</artifactId> - <version>${xmlrpc.version}</version> - <scope>compile</scope> - </dependency> - - <dependency> - <groupId>org.apache.xmlrpc</groupId> - <artifactId>xmlrpc-server</artifactId> - <version>${xmlrpc.version}</version> - <scope>compile</scope> - </dependency> - - <dependency> - <groupId>commons-httpclient</groupId> - <artifactId>commons-httpclient</artifactId> - <version>3.1</version> - <scope>runtime</scope> - </dependency> -  <dependency> <groupId>org.beanshell</groupId> Deleted: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulatorServer.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulatorServer.java 2009-12-10 15:07:57 UTC (rev 2812) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulatorServer.java 2009-12-10 16:58:27 UTC (rev 2813) @@ -1,294 +0,0 @@ -/* *##% - * Copyright (C) 2007, 2009 - * Ifremer, Code Lutin, Cédric Pineau, Benjamin Poussin - * - * This program is free software; you can redistribute it and/or - * modify it under the terms of the GNU General Public License - * as published by the Free Software Foundation; either version 2 - * of the License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. - *##%*/ - -package fr.ifremer.isisfish.simulator; - -import static org.nuiton.i18n.I18n._; - -import java.io.File; -import java.io.IOException; -import java.util.Hashtable; -import java.util.Map; -import java.util.Vector; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.xmlrpc.XmlRpcException; -import org.apache.xmlrpc.XmlRpcHandler; -import org.apache.xmlrpc.XmlRpcRequest; -import org.apache.xmlrpc.XmlRpcRequestConfig; -import org.apache.xmlrpc.common.XmlRpcHttpRequestConfig; -import org.apache.xmlrpc.server.XmlRpcHandlerMapping; -import org.apache.xmlrpc.server.XmlRpcNoSuchHandlerException; -import org.apache.xmlrpc.server.XmlRpcServer; -import org.apache.xmlrpc.webserver.WebServer; -import org.nuiton.util.FileUtil; - -import fr.ifremer.isisfish.IsisFish; -import fr.ifremer.isisfish.datastore.SimulationStorage; -import fr.ifremer.isisfish.simulator.launcher.InProcessSimulatorLauncher; -import fr.ifremer.isisfish.simulator.launcher.SimulationItem; -import fr.ifremer.isisfish.simulator.launcher.SimulatorLauncher; - -/** - * Cette classe permet de lancer un serveur XML-RPC qui attend des demandes - * de simulation. Il est ensuite possible de lui demander ou en est rendu - * une simulation. - * - * Created: Thu Aug 22 2002 - * - * @author <poussin at codelutin.com> Copyright Code Lutin - * - * @version $Revision$ - * - * Mise a jour: $Date$ - * par : $Author$ - * - * @deprecated since ... a long time this implementation is unmaintained. - */ -public class SimulatorServer implements XmlRpcHandler, XmlRpcHandlerMapping { // SimulatorServer - - /** to use log facility, just put in your code: log.info(\"...\"); */ - private static Log log = LogFactory.getLog(SimulatorServer.class); - - /** - * TODO dans SimulationControl ajouter une date de lancement de - * simulation. Si cette date est par exemple > 7 j on supprime - * automatiquement de simulationControls. Et on fait - * ce petit traitement a chaque connexion au serveur. - */ - protected Hashtable<String, SimulationControl> simulationControls = new Hashtable<String, SimulationControl>(); - - /* - * @see org.apache.xmlrpc.server.XmlRpcHandlerMapping#getHandler(java.lang.String) - */ - @Override - public XmlRpcHandler getHandler(String handler) - throws XmlRpcNoSuchHandlerException, XmlRpcException { - - if (log.isDebugEnabled()) { - log.debug("Request handler : " + handler); - } - - return this; - } - - /* - * @see org.apache.xmlrpc.XmlRpcHandler#execute(org.apache.xmlrpc.XmlRpcRequest) - */ - @Override - public Object execute(XmlRpcRequest request) throws XmlRpcException { - - /* - * Parametres: - * method les 2 noms de methodes possibles sont simulate pour - * commencer une nouvelle simulation, et checkPoint pour - * demander ou en est la simulation que l'utilisateur a demande. - * param params si la methode est simulate, il faut donnee l'id, - * et le zip de la simulation. Si la methode est checkPoint - * il faut redonner le meme id que pour le lancement de la - * simulation. - * user le login a utiliser pour pouvoir faire une simulation - * password le mot de passe - * si la methode est simulate retourne un objet - * {@link Simulation} Simulation sous forme XML. Si la - * methode est checkPoint retourne le nombre de mois simule. - */ - - String user = null; - String password = null; - - // get basic connection info - XmlRpcRequestConfig config = request.getConfig(); - if (config instanceof XmlRpcHttpRequestConfig) { - XmlRpcHttpRequestConfig httpConfig = (XmlRpcHttpRequestConfig) config; - user = httpConfig.getBasicUserName(); - password = httpConfig.getBasicPassword(); - } - - // TODO check authenticated users - - // get params - Vector params = new Vector(); - for (int index = 0; index < request.getParameterCount(); ++index) { - params.add(request.getParameter(index)); - } - - // launch requested method - String method = request.getMethodName(); - Object result = null; - try { - if ("simulate".equals(method)) { - result = new SimulatorServer().simulate(params); - } else if ("checkPoint".equals(method)) { - result = checkPoint(params); - } else { - throw new NoSuchMethodException("Erreur: la methode " + method - + " n'existe pas"); - } - } catch (Exception e) { - throw new XmlRpcException("Error during xmlrpc call", e); - } - - return result; - } - - /** - * Lance une nouvelle simulation - * - * @param params les parametres - * <li>String id de simulation - * <li>String xml de la base - * <li>HashTable nom : rule - * <li>HashTable nom : script - * <li>HashTable nom : export - * <li>HashTable SimulationParameter - * @return La simulation sous forme d'un fichier zip representé par byte[] - * @throws Exception - */ - protected Object simulate(Vector params) throws Exception { - // on creer une nouvelle simulation - if (params.size() < 2) { - throw new IllegalArgumentException("Mauvais nombre d'argument"); - } - - String id = (String) params.get(0); - File zip = FileUtil.byteToFile((byte[]) params.get(1)); - - SimulationControl control = new SimulationControl(id); - SimulationStorage simulation = null; - - simulationControls.put(id, control); - try { - SimulatorLauncher launcher = new InProcessSimulatorLauncher(); - SimulationItem item = new SimulationItem(control, null); - item.setSimulationZip(zip); - launcher.simulate(null, item); - // FIXME null - simulation = launcher.getSimulationStorage(null, control); - - zip = simulation.createZip(); - byte[] result = FileUtil.fileToByte(zip); - - return result; - } catch (Exception eee) { - log.warn(_("isisfish.error.during.simulation"), eee); - throw eee; - } finally { - simulationControls.remove(id); - if (simulation != null) { - simulation.delete(false); - } - } - } - - /** - * synchronized two SimulationControl (local and remote) - * - * @param params - * @return - * @throws Exception - */ - synchronized protected Object checkPoint(Vector params) throws Exception { - // on retourne a l'utilisateur on en est la simulation - if (params.size() < 1) { - throw new IllegalArgumentException("Mauvais nombre d'argument"); - } - - Hashtable<String, Object> args = new Hashtable<String, Object>(); - args.putAll((Map<String, Object>) params.get(0)); - - String id = (String) args.get("id"); - SimulationControl callback = (SimulationControl) simulationControls - .get(id); - - if (callback == null) { - throw new SimulatorServerBadIdException("Erreur: " + id - + " n'est pas un identifiant de simulation"); - } - - callback.updateFromHashtable(args); - - return callback.getUpdateHashtable(); - } - - // synchronized protected Object stop(Vector params) throws Exception { - // if (params.size() < 1) - // throw new IllegalArgumentException("Mauvais nombre d'argument"); - // - // String id = (String) params.get(0); - // SimulationControl callback = (SimulationControl) simulationControls - // .get(id); - // if (callback == null) - // throw new SimulationException("Erreur: " + id - // + " n'est pas un identifiant de simulation"); - // - // callback.stopSimulation(); - // - // return ""; - // } - - /** - * Method main permet de lancer un serveur de simulation sur une machine. - * - * @param args - */ - public static void main(String[] args) { - - try { - IsisFish.init(); - } catch (Exception e) { - if (log.isErrorEnabled()) { - log.error("Can't ini IsisFish", e); - } - } - - System.out.println("Usage: SimulatorServer [port]"); - - int p = 9090; - - if (args.length > 0) { - try { - p = Integer.parseInt(args[0]); - } catch (NumberFormatException nfx) { - System.err.println("Error parsing port number: " + args[0]); - } - } - - // FIXME KeepAlive in xmlrpc 3.x ? - //XmlRpc.setKeepAlive(true); - - try { - WebServer webserver = new WebServer(p); - XmlRpcServer xmlRpcServer = webserver.getXmlRpcServer(); - - //xmlRpcServer.addHandler("$default", new SimulatorServer()); // 2.x - xmlRpcServer.setHandlerMapping(new SimulatorServer()); // 3.x - - webserver.start(); - System.out.println("Started web server on port " + p); - - } catch (IOException e) { - if (log.isErrorEnabled()) { - log.error("Error creating web server", e); - } - } - } - -} // SimulatorServer Deleted: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/IsisFishServerSimulationLauncher.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/IsisFishServerSimulationLauncher.java 2009-12-10 15:07:57 UTC (rev 2812) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/IsisFishServerSimulationLauncher.java 2009-12-10 16:58:27 UTC (rev 2813) @@ -1,262 +0,0 @@ -/* *##% - * Copyright (C) 2002-2009 Code Lutin, Benjamin Poussin - * - * This program is free software; you can redistribute it and/or - * modify it under the terms of the GNU General Public License - * as published by the Free Software Foundation; either version 2 - * of the License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, - * USA. - *##%*/ - -package fr.ifremer.isisfish.simulator.launcher; - -import static org.nuiton.i18n.I18n._; - -import java.io.File; -import java.net.URL; -import java.rmi.RemoteException; -import java.util.Hashtable; -import java.util.Vector; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.xmlrpc.client.XmlRpcClient; -import org.apache.xmlrpc.client.XmlRpcClientConfigImpl; -import org.apache.xmlrpc.client.XmlRpcCommonsTransportFactory; -import org.nuiton.util.FileUtil; - -import fr.ifremer.isisfish.IsisFish; -import fr.ifremer.isisfish.datastore.SimulationStorage; -import fr.ifremer.isisfish.simulator.SimulationControl; - -/** - * Launch simulation on remote IsisFish server throw XML-RPC. - * - * @author poussin - * @version $Revision$ - * - * Last update : $Date$ - * By : $Author$ - * - * @deprecated Since ... a long time this implementation is unmaintained. - */ -public class IsisFishServerSimulationLauncher implements SimulatorLauncher { - - /** to use log facility, just put in your code: log.info(\"...\"); */ - private static Log log = LogFactory - .getLog(IsisFishServerSimulationLauncher.class); - - @Override - public void simulate(SimulationService simulationService, - SimulationItem simulationItem) throws RemoteException { - - SimulationControl control = simulationItem.getControl(); - File simulationZip = simulationItem.getSimulationZip(); - - String simulationId = control.getId(); - SimulationStorage simulation = null; - try { - simulation = SimulationStorage.importAndRenameZip(simulationZip, - simulationId); - simulation = remoteSimulate(control, simulation); - } catch (Exception eee) { - log.error(_("Can't do simulation %s", simulationId), eee); - // FIXME simulation allways null here - if (simulation != null) { - simulation.getInformation().setException(eee); - } - } - - // on retourne directement le simulation storage passe en argument - // car la simulation a ete faite avec - //return simulation; - - } - - @Override - public int maxSimulationThread() { - // TODO a rendre configurable - return 1; - } - - /* - * @see fr.ifremer.isisfish.simulator.launcher.SimulatorLauncher#getCheckProgressionInterval() - */ - @Override - public int getCheckProgressionInterval() { - - // par defaut, pour les serveur xmlrpc 20 secondes - - int interval = 20; - return interval; - } - - /** - * execute la simulation en remote - * - * @param control le controleur de simulation, peut-etre null si on ne - * souhaite pas controler la simulation - * @param simulation la simulation a faire - * - * @return le storage après simulation - * @throws Exception pour toute erreur - */ - public SimulationStorage remoteSimulate(SimulationControl control, - SimulationStorage simulation) throws Exception { - // export en zip du storage - File zip = simulation.createZip(); - - if (control != null) { - // creation du thread de surveillance de la simulation distante - // qui sert a mettre a jour les valeurs de control - new SimulationCheckpointRemoteThread(control).start(); - } - - // envoie le zip au serveur de simulation - // appel synchrone pour attendre la fin de la simulation - // recuperation du zip de la simulation terminé - Vector<Object> a = new Vector<Object>(); - //fixme : on peut avori control à null ? - a.add(control.getId()); - a.add(FileUtil.fileToByte(zip)); - - // lancement de la simulation - //XmlRpcClient c = new XmlRpcClient(IsisFish.config.getSimulatorServer()); - //c.setBasicAuthentication(IsisFish.config.getSimulatorUsername(), - // IsisFish.config.getSimulatorPassword()); - - XmlRpcClientConfigImpl xmlrpcconfig = new XmlRpcClientConfigImpl(); - xmlrpcconfig - .setServerURL(new URL(IsisFish.config.getSimulatorServer())); - xmlrpcconfig.setBasicUserName(IsisFish.config.getSimulatorUsername()); - xmlrpcconfig.setBasicPassword(IsisFish.config.getSimulatorPassword()); - XmlRpcClient client = new XmlRpcClient(); - client.setTransportFactory(new XmlRpcCommonsTransportFactory(client)); - client.setConfig(xmlrpcconfig); - - byte[] callResult = (byte[]) client.execute("simulate", a); - - // ecriture du resultat dans un fichier - File tmpzip = FileUtil.byteToFile(callResult); - - // remplacement du storage local par le storage recu - simulation.closeStorage(); - simulation.delete(false); - SimulationStorage result; - result = SimulationStorage.importAndRenameZip(tmpzip, control.getId()); - return result; - } - - /** - * This thread is responsible to synchronized SimulationControl used localy with - * remote simulation control for remote simulation. - * - * This thread dead when {@link SimulationControl#isRunning()} is false - * - * @author poussin - */ - protected class SimulationCheckpointRemoteThread extends Thread { // SimulationCheckpointRemoteThread - - protected SimulationControl control = null; - int badId = 0; - - public SimulationCheckpointRemoteThread(SimulationControl control) { - this.control = control; - } - - public void run() { - int sleepTime = 2000; - while (true) { - try { - Thread.sleep(sleepTime); - - updateControl(control); - // on remet de le temps normal, vu que la connexion a reussi - sleepTime = 2000; - - if (!control.isRunning()) { - return; - } - - } catch (Exception eee) { - // on supporte 10 erreurs puis ensuite on quitte le thread. - if (badId++ > 10) { - log.error("Error !!! ", eee); - break; - } else { - // on a echouer sur une tentative, on allonge un - // peu le temps - sleepTime += 2000; - } - } - } - - } - - public void updateControl(SimulationControl control) throws Exception { - // essai l'ancienne etait en dur: "http://localhost:9090" - - XmlRpcClientConfigImpl xmlrpcconfig = new XmlRpcClientConfigImpl(); - xmlrpcconfig.setServerURL(new URL(IsisFish.config - .getSimulatorServer())); - xmlrpcconfig.setBasicUserName(IsisFish.config - .getSimulatorUsername()); - xmlrpcconfig.setBasicPassword(IsisFish.config - .getSimulatorPassword()); - XmlRpcClient client = new XmlRpcClient(); - client.setTransportFactory(new XmlRpcCommonsTransportFactory( - client)); - client.setConfig(xmlrpcconfig); - - Vector a = new Vector(); - a.add(control.getUpdateHashtable()); - Hashtable<String, Object> result = (Hashtable<String, Object>) client - .execute("checkPoint", a); - // on remet de le temps normal, vu que la connexion a reussi - control.updateFromHashtable(result); - } - } // SimulationCheckpointRemoteThread - - @Override - public String toString() { - return _("Remote IsisFish server"); - } - - /* - * @see fr.ifremer.isisfish.simulator.launcher.SimulatorLauncher#getSimulationStorage(fr.ifremer.isisfish.simulator.launcher.SimulationService, fr.ifremer.isisfish.simulator.SimulationControl) - */ - @Override - public SimulationStorage getSimulationStorage( - SimulationService simulationService, SimulationControl control) - throws RemoteException { - return null; - } - - /* - * @see fr.ifremer.isisfish.simulator.launcher.SimulatorLauncher#updateControl(fr.ifremer.isisfish.simulator.launcher.SimulationService, fr.ifremer.isisfish.simulator.SimulationControl) - */ - @Override - public void updateControl(SimulationService simulationService, - SimulationControl control) throws RemoteException { - - } - - /** - * {@inheritDoc} - * - * Do nothing (no restriction on xml rpc launcher). - */ - @Override - public void simulationStopRequest(SimulationJob job) { - - } -}

1 0

r2812 - in isis-fish/trunk/src/main/java/fr/ifremer/isisfish: simulator/launcher util/ssh
by chatellier＠users.labs.libre-entreprise.org 10 Dec '09

10 Dec '09

Author: chatellier Date: 2009-12-10 15:07:57 +0000 (Thu, 10 Dec 2009) New Revision: 2812 Added: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/util/ssh/ProgressMonitor.java Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SSHSimulatorLauncher.java isis-fish/trunk/src/main/java/fr/ifremer/isisfish/util/ssh/SSHUtils.java Log: Add progression monitor for ssh transfert Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SSHSimulatorLauncher.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SSHSimulatorLauncher.java 2009-12-10 14:30:26 UTC (rev 2811) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SSHSimulatorLauncher.java 2009-12-10 15:07:57 UTC (rev 2812) @@ -49,6 +49,7 @@ import fr.ifremer.isisfish.simulator.SimulationControl; import fr.ifremer.isisfish.util.ClasspathTemplateLoader; import fr.ifremer.isisfish.util.ssh.InvalidPassphraseException; +import fr.ifremer.isisfish.util.ssh.ProgressMonitor; import fr.ifremer.isisfish.util.ssh.SSHAgent; import fr.ifremer.isisfish.util.ssh.SSHException; import fr.ifremer.isisfish.util.ssh.SSHUserInfo; @@ -703,7 +704,8 @@ String remoteFile = getRemoteResultArchivePath(simulationId); try { - SSHUtils.scpFrom(session, remoteFile, localFile); + ProgressMonitor progress = new ControlProgressMonitor(simulationControl); + SSHUtils.scpFrom(session, remoteFile, localFile, progress); } catch(SSHException e) { localFile.delete(); @@ -725,6 +727,51 @@ } /** + * Redefine a custom progress monitor that update control. + */ + protected static class ControlProgressMonitor extends ProgressMonitor { + + /** Control to update. */ + protected SimulationControl control; + + /** + * Constructor with control. + * + * @param control control + */ + public ControlProgressMonitor(SimulationControl control) { + this.control = control; + } + + /* + * @see fr.ifremer.isisfish.util.ssh.ProgressMonitor#init(long) + */ + @Override + public void init(long max) { + super.init(max); + control.setProgressMax(initFileSize); + } + + /* + * @see fr.ifremer.isisfish.util.ssh.ProgressMonitor#count(long) + */ + @Override + public void count(long len) { + super.count(len); + control.setProgress(totalLength); + } + + /* + * @see fr.ifremer.isisfish.util.ssh.ProgressMonitor#end() + */ + @Override + public void end() { + super.end(); + control.setProgress(initFileSize); + } + } + + /** * Download remote simulation control file and store its content into temp * file. * Added: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/util/ssh/ProgressMonitor.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/util/ssh/ProgressMonitor.java (rev 0) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/util/ssh/ProgressMonitor.java 2009-12-10 15:07:57 UTC (rev 2812) @@ -0,0 +1,50 @@ +/* *##% + * Copyright (C) 2009 Code Lutin, Chatellier Eric + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU General Public License + * as published by the Free Software Foundation; either version 2 + * of the License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + *##%*/ + +package fr.ifremer.isisfish.util.ssh; + +/** + * Progress monitor (sftp). + * + * @author chatellier + * @version $Revision$ + * + * Last update : $Date$ + * By : $Author$ + */ +public class ProgressMonitor { + + /** Size of file to download. */ + protected long initFileSize = 0; + + /** Current dowloaded length. */ + protected long totalLength = 0; + + public void init(long max) { + initFileSize = max; + totalLength = 0; + } + + public void count(long len) { + totalLength += len; + } + + public void end() { + + } +} Property changes on: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/util/ssh/ProgressMonitor.java ___________________________________________________________________ Added: svn:keywords + "Author Date Id Revision HeadURL" Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/util/ssh/SSHUtils.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/util/ssh/SSHUtils.java 2009-12-10 14:30:26 UTC (rev 2811) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/util/ssh/SSHUtils.java 2009-12-10 15:07:57 UTC (rev 2812) @@ -238,11 +238,26 @@ * @param remoteFileName remote file name to download * @param localFile local file name to download into * - * @throws SSHException if transfer fail (include md5 control failed) + * @throws SSHException if transfer fail */ public static void scpFrom(Session session, String remoteFileName, File localFile) throws SSHException { + scpFrom(session, remoteFileName, localFile, null); + } + /** + * Download a local file from remote server and check md5sum. + * + * @param session opened valid jsch session + * @param remoteFileName remote file name to download + * @param localFile local file name to download into + * @param monitor progress monitor (can be null) + * + * @throws SSHException if transfer fail + */ + public static void scpFrom(Session session, String remoteFileName, + File localFile, ProgressMonitor monitor) throws SSHException { + String command = "scp -f -r \"" + remoteFileName + "\""; ChannelExec channel = null; @@ -257,7 +272,7 @@ channel.connect(); sendAck(out); - startRemoteCpProtocol(in, out, localFile); + startRemoteCpProtocol(in, out, localFile, monitor); } catch (IOException e) { throw new SSHException(e); } catch (JSchException e) { @@ -292,7 +307,7 @@ // scp protected static void startRemoteCpProtocol(InputStream in, - OutputStream out, File localFile) throws IOException, SSHException { + OutputStream out, File localFile, ProgressMonitor monitor) throws IOException, SSHException { File startFile = localFile; while (true) { // C0644 filesize filename - header for a regular file @@ -311,7 +326,7 @@ } String serverResponse = stream.toString("UTF-8"); if (serverResponse.charAt(0) == 'C') { - parseAndFetchFile(serverResponse, startFile, out, in); + parseAndFetchFile(serverResponse, startFile, out, in, monitor); } else if (serverResponse.charAt(0) == 'D') { startFile = parseAndCreateDirectory(serverResponse, startFile); sendAck(out); @@ -344,7 +359,7 @@ // scp protected static void parseAndFetchFile(String serverResponse, - File localFile, OutputStream out, InputStream in) + File localFile, OutputStream out, InputStream in, ProgressMonitor monitor) throws IOException, SSHException { int start = 0; int end = serverResponse.indexOf(" ", start + 1); @@ -355,29 +370,27 @@ log.debug("Receiving: " + filename + " : " + filesize); File transferFile = (localFile.isDirectory()) ? new File(localFile, filename) : localFile; - fetchFile(transferFile, filesize, out, in); + fetchFile(transferFile, filesize, out, in, monitor); waitForAck(in); sendAck(out); } // scp protected static void fetchFile(File localFile, long filesize, - OutputStream out, InputStream in) throws IOException { + OutputStream out, InputStream in, ProgressMonitor monitor) throws IOException { byte[] buf = new byte[BUFFER_SIZE]; sendAck(out); + // case were progression is requested + if (monitor != null) { + monitor.init(filesize); + } + // read a content of lfile FileOutputStream fos = new FileOutputStream(localFile); int length; long totalLength = 0; - // only track progress for files larger than 100kb in verbose mode - boolean trackProgress = filesize > HUNDRED_KILOBYTES; - // since filesize keeps on decreasing we have to store the - // initial filesize - long initFilesize = filesize; - int percentTransmitted = 0; - try { while (true) { length = in.read(buf, 0, (BUFFER_SIZE < filesize) ? BUFFER_SIZE @@ -392,15 +405,20 @@ break; } - if (trackProgress) { - percentTransmitted = trackProgress(initFilesize, - totalLength, percentTransmitted); + // case were progression is requested + if (monitor != null) { + monitor.count(length); } } } finally { fos.flush(); fos.close(); } + + // case were progression is requested + if (monitor != null) { + monitor.end(); + } } // scp @@ -444,13 +462,6 @@ byte[] buf = new byte[BUFFER_SIZE]; long totalLength = 0; - // only track progress for files larger than 100kb in verbose mode - boolean trackProgress = filesize > HUNDRED_KILOBYTES; - // since filesize keeps on decreasing we have to store the - // initial filesize - long initFilesize = filesize; - int percentTransmitted = 0; - try { while (true) { int len = fis.read(buf, 0, buf.length); @@ -459,11 +470,6 @@ } out.write(buf, 0, len); totalLength += len; - - if (trackProgress) { - percentTransmitted = trackProgress(initFilesize, - totalLength, percentTransmitted); - } } out.flush(); sendAck(out); @@ -476,7 +482,7 @@ /** * Progress monitor (sftp). */ - protected static class ProgressMonitor implements SftpProgressMonitor { + protected static class UtilsProgressMonitor implements SftpProgressMonitor { private long initFileSize = 0; private long totalLength = 0; private int percentTransmitted = 0; @@ -607,7 +613,7 @@ SftpProgressMonitor monitor = null; boolean trackProgress = totalLength > HUNDRED_KILOBYTES; if (trackProgress) { - monitor = new ProgressMonitor(); + monitor = new UtilsProgressMonitor(); } channel.get(remoteFile, localFile.getAbsolutePath(), monitor); } @@ -666,7 +672,7 @@ SftpProgressMonitor monitor = null; if (trackProgress) { - monitor = new ProgressMonitor(); + monitor = new UtilsProgressMonitor(); } channel.put(localFile.getAbsolutePath(), remotePath, monitor);

1 0

r2811 - in isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator: . launcher
by chatellier＠users.labs.libre-entreprise.org 10 Dec '09

10 Dec '09

Author: chatellier Date: 2009-12-10 14:30:26 +0000 (Thu, 10 Dec 2009) New Revision: 2811 Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulationControl.java isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationServiceTableModel.java Log: Change progress type from int to long. Update javadoc. Format code. Make xml-rpc only method deprecated. Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulationControl.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulationControl.java 2009-12-10 14:28:48 UTC (rev 2810) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/SimulationControl.java 2009-12-10 14:30:26 UTC (rev 2811) @@ -1,6 +1,5 @@ /* *##% - * Copyright (C) 2002 - 2009 Code Lutin, Cédric Pineau, - Benjamin Poussin + * Copyright (C) 2002 - 2009 Ifremer, Code Lutin, Cédric Pineau, Benjamin Poussin * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License @@ -51,18 +50,19 @@ protected PropertyChangeSupport listeners = new PropertyChangeSupport(this); protected boolean inUpdateFromHashtable = false; protected transient SimulationStorage simulation = null; - + protected String id = null; protected boolean started = false; protected boolean running = true; protected boolean stop = false; - protected Date date = new Date(); - protected int progressMax = 0; - protected int progress = 0; + protected Date date; + protected long progressMax = 0; + protected long progress = 0; protected String text = ""; - + + /** @deprecated only used in isis xml-rpc server. */ protected Map<String, Object> update = new Hashtable<String, Object>(); - + /** * * @param id simulation id @@ -79,11 +79,11 @@ started = false; running = true; stop = false; - date = new Date(); + date = null; progressMax = 0; progress = 0; } - + /** * Retourne la simulation associe a ce control * @return retourne null si la simulation n'existe pas encore @@ -94,29 +94,30 @@ } return simulation; } - + public void addPropertyChangeListener(String propName, PropertyChangeListener l) { listeners.addPropertyChangeListener(propName, l); } - + public void addPropertyChangeListener(PropertyChangeListener l) { listeners.addPropertyChangeListener(l); } - - public void removePropertyChangeListener(String propName, PropertyChangeListener l) { + + public void removePropertyChangeListener(String propName, + PropertyChangeListener l) { listeners.removePropertyChangeListener(propName, l); } - + public void removePropertyChangeListener(PropertyChangeListener l) { listeners.removePropertyChangeListener(l); } - + public boolean isStarted() { return started; } - + /** - * appelee juste avant de reellement demarrer le thread de simulation + * Appelee juste avant de reellement demarrer le thread de simulation * indique que cette simulation est en cours et qu'il ne faut plus la lancer * * @param started The running to set. @@ -128,7 +129,7 @@ } /** - * Method running + * Method running. * * @return faux une fois que stopSimulation a ete appele. */ @@ -146,14 +147,14 @@ } /** - * Method startSimulation appele lors du debut de la simulation + * Appele lors du debut de la simulation. */ public void startSimulation() { setRunning(true); } /** - * Method stopSimulation appele lors de la fin reelle de la simulation + * Appele lors de la fin reelle de la simulation. */ public void stopSimulation() { setRunning(false); @@ -165,7 +166,7 @@ public String getText() { return this.text; } - + /** * @param text The text to set. */ @@ -177,53 +178,63 @@ this.text = text; listeners.firePropertyChange("text", oldValue, this.text); } - + /** * @return Returns the progressMax. */ - public int getProgressMax() { + public long getProgressMax() { return this.progressMax; } - + /** - * @param progressMax The progressMax to set. + * Set max progress. + * + * @param progressMax progressMax to set. */ - public void setProgressMax(int progressMax) { - int oldValue = this.progressMax; + public void setProgressMax(long progressMax) { + long oldValue = this.progressMax; this.progressMax = progressMax; listeners.firePropertyChange("progressMax", oldValue, this.progressMax); } - + /** - * @return Returns the progress. + * Get current progress. + * + * @return the progress. */ - public int getProgress() { + public long getProgress() { return this.progress; } - + /** - * @param progress The progress to set. + * Set current progress. + * + * @param progress progress to set. */ - public void setProgress(int progress) { - int oldValue = this.progress; + public void setProgress(long progress) { + long oldValue = this.progress; this.progress = progress; - if(log.isTraceEnabled()) { - log.trace("control fire event 'progress' (" + oldValue + "/" + this.progress); + if (log.isTraceEnabled()) { + log.trace("control fire event 'progress' (" + oldValue + "/" + + this.progress); } listeners.firePropertyChange("progress", oldValue, this.progress); } - + /** - * demande l'arret de la simulation - * @param val + * Demande l'arret de la simulation. + * + * @param val {@code true} to stop */ - public void setStopSimulationRequest(boolean val){ + public void setStopSimulationRequest(boolean val) { boolean oldValue = this.stop; this.stop = val; listeners.firePropertyChange("stop", oldValue, this.stop); } - + /** + * Is stop request been asked. + * * @return retourne vrai si l'arret de la simulation a ete demandee */ public boolean isStopSimulationRequest() { @@ -231,7 +242,7 @@ } /** - * Method getId donne id de la simulation + * Method getId donne id de la simulation. * * @return l'id de la simulation */ @@ -240,39 +251,44 @@ } /** - * Method getDate donne la date utiliser par la simulation + * Method getDate donne la date utiliser par la simulation. * * @return donne la date utiliser par la simulation */ public Date getDate() { return date; } - /** - * Modifie la date de la simulation + * Modifie la date de la simulation. + * * @param d la nouvelle date */ public void setDate(Date d) { - int oldValue = this.date.getDate(); + int oldValue = 0; + if (this.date != null) { + oldValue = this.date.getDate(); + } this.date = d; listeners.firePropertyChange("date", oldValue, this.date.getDate()); } /** * Convert current object in hashtable representation, and clear hashtable - * that contains last modified field + * that contains last modified field. + * * @return object hashtable representation + * @deprecated only used in xml-rpc isis server */ public Hashtable<String, Object> getUpdateHashtable() { Hashtable<String, Object> result = new Hashtable<String, Object>(update); update.clear(); - + result.put("id", getId()); - + return result; } - + /** * Met dans un Properties tous les champs * @return un Properties avec tous les champs @@ -283,14 +299,16 @@ result.setProperty("started", String.valueOf(started)); result.setProperty("running", String.valueOf(running)); result.setProperty("stop", String.valueOf(stop)); - result.setProperty("date", String.valueOf(date.getDate())); + if (date != null) { + result.setProperty("date", String.valueOf(date.getDate())); + } result.setProperty("progressMax", String.valueOf(progressMax)); result.setProperty("progress", String.valueOf(progress)); result.setProperty("text", text); - + return result; } - + /** * update current object from Properties representation * @@ -299,36 +317,41 @@ public void updateFromProperties(Properties props) { inUpdateFromHashtable = true; - if(log.isTraceEnabled()) { + if (log.isTraceEnabled()) { log.trace("updateFromProperties properties = " + props.toString()); } - + // warning : props.contains("started") // seems to not works on properties :( // use containsKey() try { if (props.containsKey("started")) { - boolean started = "true".equalsIgnoreCase(props.getProperty("started")); + boolean started = "true".equalsIgnoreCase(props + .getProperty("started")); setStarted(started); } if (props.containsKey("running")) { - boolean running = "true".equalsIgnoreCase(props.getProperty("running")); + boolean running = "true".equalsIgnoreCase(props + .getProperty("running")); setRunning(running); } if (props.containsKey("stop")) { - boolean stop = "true".equalsIgnoreCase(props.getProperty("stop")); + boolean stop = "true".equalsIgnoreCase(props + .getProperty("stop")); setStopSimulationRequest(stop); } if (props.containsKey("date")) { - Date date = new Date(Integer.parseInt(props.getProperty("date"))); + Date date = new Date(Integer + .parseInt(props.getProperty("date"))); setDate(date); } if (props.containsKey("progressMax")) { - int progressMax = Integer.parseInt(props.getProperty("progressMax")); + long progressMax = Long.parseLong(props + .getProperty("progressMax")); setProgressMax(progressMax); } if (props.containsKey("progress")) { - int progress = Integer.parseInt(props.getProperty("progress")); + long progress = Long.parseLong(props.getProperty("progress")); setProgress(progress); } if (props.containsKey("text")) { @@ -339,41 +362,41 @@ inUpdateFromHashtable = false; } } - - + /** * update current object from hashtable representation - * + * + * @deprecated only used in xml-rpc isis server */ public void updateFromHashtable(Hashtable<String, Object> h) { inUpdateFromHashtable = true; try { if (h.containsKey("started")) { - boolean started = (Boolean)h.get("started"); + boolean started = (Boolean) h.get("started"); setStarted(started); } if (h.containsKey("running")) { - boolean running = (Boolean)h.get("running"); + boolean running = (Boolean) h.get("running"); setRunning(running); } if (h.containsKey("stop")) { - boolean stop = (Boolean)h.get("stop"); + boolean stop = (Boolean) h.get("stop"); setStopSimulationRequest(stop); } if (h.containsKey("date")) { - Date date = new Date((Integer)h.get("date")); + Date date = new Date((Integer) h.get("date")); setDate(date); } if (h.containsKey("progressMax")) { - int progressMax = (Integer)h.get("progressMax"); + long progressMax = (Long) h.get("progressMax"); setProgressMax(progressMax); } if (h.containsKey("progress")) { - int progress = (Integer)h.get("progress"); + long progress = (Long) h.get("progress"); setProgress(progress); } if (h.containsKey("text")) { - String text = (String)h.get("text"); + String text = (String) h.get("text"); setText(text); } } finally { @@ -396,5 +419,5 @@ } } } - + } // SimulationControl Modified: isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationServiceTableModel.java =================================================================== --- isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationServiceTableModel.java 2009-12-10 14:28:48 UTC (rev 2810) +++ isis-fish/trunk/src/main/java/fr/ifremer/isisfish/simulator/launcher/SimulationServiceTableModel.java 2009-12-10 14:30:26 UTC (rev 2811) @@ -21,19 +21,23 @@ import static org.nuiton.i18n.I18n._; -import fr.ifremer.isisfish.simulator.SimulationControl; -import fr.ifremer.isisfish.simulator.SimulationParameter; import java.beans.PropertyChangeEvent; import java.beans.PropertyChangeListener; import java.util.ArrayList; import java.util.HashMap; import java.util.Map; import java.util.WeakHashMap; + import javax.swing.JProgressBar; import javax.swing.table.AbstractTableModel; + import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; +import fr.ifremer.isisfish.simulator.SimulationControl; +import fr.ifremer.isisfish.simulator.SimulationParameter; +import fr.ifremer.isisfish.types.Date; + /** * Model de table pour suivre l'evolution des differentes simulations en cours. * @@ -248,10 +252,14 @@ break; case 4: JProgressBar pb = getProgressBar(job); - pb.setMaximum(control.getProgressMax()); - pb.setValue(control.getProgress()); - pb.setString(control.getDate().getMonth() + "/" - + control.getDate().getYear()); + pb.setMaximum((int)control.getProgressMax()); + pb.setValue((int)control.getProgress()); + + // progress can be used for other things + Date date = control.getDate(); + if (date != null) { + pb.setString(date.getMonth() + "/" + date.getYear()); + } result = pb; break; }

1 0

r2810 - isis-fish/trunk
by chatellier＠users.labs.libre-entreprise.org 10 Dec '09

10 Dec '09

Author: chatellier Date: 2009-12-10 14:28:48 +0000 (Thu, 10 Dec 2009) New Revision: 2810 Modified: isis-fish/trunk/pom.xml Log: Revert beta2 use Modified: isis-fish/trunk/pom.xml =================================================================== --- isis-fish/trunk/pom.xml 2009-12-10 14:25:19 UTC (rev 2809) +++ isis-fish/trunk/pom.xml 2009-12-10 14:28:48 UTC (rev 2810) @@ -435,8 +435,8 @@ <properties>  <jaxx.version>1.7.1</jaxx.version> - <eugene.version>2.0.0-beta-2-SNAPSHOT</eugene.version> - <topia.version>2.3.0-beta-2-SNAPSHOT</topia.version> + <eugene.version>2.0.0-beta-SNAPSHOT</eugene.version> + <topia.version>2.3.0-beta-SNAPSHOT</topia.version> <nuiton-utils.version>1.1.2-SNAPSHOT</nuiton-utils.version> <nuiton-i18n.version>1.0.1</nuiton-i18n.version> <nuiton-widgets.version>1.0.1-SNAPSHOT</nuiton-widgets.version>

1 0