ParameterDriversList.java

  1. /* Copyright 2002-2019 CS Systèmes d'Information
  2.  * Licensed to CS Systèmes d'Information (CS) under one or more
  3.  * contributor license agreements.  See the NOTICE file distributed with
  4.  * this work for additional information regarding copyright ownership.
  5.  * CS licenses this file to You under the Apache License, Version 2.0
  6.  * (the "License"); you may not use this file except in compliance with
  7.  * the License.  You may obtain a copy of the License at
  8.  *
  9.  *   http://www.apache.org/licenses/LICENSE-2.0
  10.  *
  11.  * Unless required by applicable law or agreed to in writing, software
  12.  * distributed under the License is distributed on an "AS IS" BASIS,
  13.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14.  * See the License for the specific language governing permissions and
  15.  * limitations under the License.
  16.  */
  17. package org.orekit.utils;

  18. import java.util.ArrayList;
  19. import java.util.Collections;
  20. import java.util.Comparator;
  21. import java.util.Iterator;
  22. import java.util.List;

  23. import org.orekit.time.AbsoluteDate;


  24. /** Class managing several {@link ParameterDriver parameter drivers},
  25.  * taking care of duplicated names.
  26.  * <p>
  27.  * Once parameter drivers sharing the same name have been added to
  28.  * an instance of this class, they are permanently bound together and
  29.  * also bound to the {@link #getDrivers() delegating driver} that
  30.  * manages them. This means that if drivers {@code d1}, {@code d2}...
  31.  * {@code dn} are added to the list and both correspond to parameter
  32.  * name "P", then {@link #getDrivers()} will return a list containing
  33.  * a delegating driver {@code delegateD} for the same name "P".
  34.  * Afterwards, whenever either {@link ParameterDriver#setValue(double)}
  35.  * or {@link ParameterDriver#setReferenceDate(AbsoluteDate)} is called
  36.  * on any of the {@code n+1} instances {@code d1}, {@code d2}... {@code dn}
  37.  * or {@code delegateD}, the call will be automatically forwarded to the
  38.  * {@code n} remaining instances, hence ensuring they remain consistent
  39.  * with each other.
  40.  * </p>
  41.  * @author Luc Maisonobe
  42.  * @since 8.0
  43.  */
  44. public class ParameterDriversList {

  45.     /** Managed drivers. */
  46.     private final List<DelegatingDriver> delegating;

  47.     /** Creates an empty list.
  48.      */
  49.     public ParameterDriversList() {
  50.         this.delegating = new ArrayList<DelegatingDriver>();
  51.     }

  52.     /** Add a driver.
  53.      * <p>
  54.      * If the driver is already present, it will not be added.
  55.      * If another driver managing the same parameter is present,
  56.      * both drivers will be managed together, existing drivers
  57.      * being set to the value of the last driver added (i.e.
  58.      * each addition overrides the parameter value).
  59.      * </p>
  60.      * @param driver driver to add
  61.      */
  62.     public void add(final ParameterDriver driver) {

  63.         final DelegatingDriver existingHere = findByName(driver.getName());
  64.         final DelegatingDriver alreadyBound = getAssociatedDelegatingDriver(driver);

  65.         if (existingHere != null) {
  66.             if (alreadyBound != null) {
  67.                 // ensure we don't get intermixed change forwarders that call each other recursively
  68.                 existingHere.setForwarder(alreadyBound.getForwarder());
  69.             } else {
  70.                 // this is a new driver for an already managed parameter
  71.                 existingHere.add(driver);
  72.             }
  73.         } else {
  74.             if (alreadyBound != null) {
  75.                 // the driver is new here, but already bound to other drivers in other lists
  76.                 delegating.add(alreadyBound);
  77.             } else {
  78.                 // this is the first driver we have for this parameter name
  79.                 final DelegatingDriver created   = new DelegatingDriver(driver);
  80.                 final ChangesForwarder forwarder = new ChangesForwarder(created);
  81.                 created.setForwarder(forwarder);
  82.                 delegating.add(created);
  83.             }
  84.         }

  85.     }

  86.     /** Get a {@link DelegatingDriver delegating driver} bound to a driver.
  87.      * @param driver driver to check
  88.      * @return a {@link DelegatingDriver delegating driver} bound to a driver, or
  89.      * null if this driver is not associated with any {@link DelegatingDriver delegating driver}
  90.      * @since 9.1
  91.      */
  92.     private DelegatingDriver getAssociatedDelegatingDriver(final ParameterDriver driver) {
  93.         for (final ParameterObserver observer : driver.getObservers()) {
  94.             if (observer instanceof ChangesForwarder) {
  95.                 return ((ChangesForwarder) observer).getDelegatingDriver();
  96.             }
  97.         }
  98.         return null;
  99.     }

  100.     /** Find  a {@link DelegatingDriver delegating driver} by name.
  101.      * @param name name to check
  102.      * @return a {@link DelegatingDriver delegating driver} managing this parameter name
  103.      * @since 9.1
  104.      */
  105.     public DelegatingDriver findByName(final String name) {
  106.         for (final DelegatingDriver d : delegating) {
  107.             if (d.getName().equals(name)) {
  108.                 return d;
  109.             }
  110.         }
  111.         return null;
  112.     }

  113.     /** Sort the parameters lexicographically.
  114.      */
  115.     public void sort() {
  116.         Collections.sort(delegating, new Comparator<DelegatingDriver>() {
  117.             /** {@inheritDoc} */
  118.             @Override
  119.             public int compare(final DelegatingDriver d1, final DelegatingDriver d2) {
  120.                 return d1.getName().compareTo(d2.getName());
  121.             }
  122.         });
  123.     }

  124.     /** Filter parameters to keep only one type of selection status.
  125.      * @param selected if true, only {@link ParameterDriver#isSelected()
  126.      * selected} parameters will be kept, the other ones will be removed
  127.      */
  128.     public void filter(final boolean selected) {
  129.         for (final Iterator<DelegatingDriver> iterator = delegating.iterator(); iterator.hasNext();) {
  130.             if (iterator.next().isSelected() != selected) {
  131.                 iterator.remove();
  132.             }
  133.         }
  134.     }

  135.     /** Get the number of parameters with different names.
  136.      * @return number of parameters with different names
  137.      */
  138.     public int getNbParams() {
  139.         return delegating.size();
  140.     }

  141.     /** Get delegating drivers for all parameters.
  142.      * <p>
  143.      * The delegating drivers are <em>not</em> the same as
  144.      * the drivers added to the list, but they delegate to them.
  145.      * </p>
  146.      * <p>
  147.      * All delegating drivers manage parameters with different names.
  148.      * </p>
  149.      * @return unmodifiable view of the list of delegating drivers
  150.      */
  151.     public List<DelegatingDriver> getDrivers() {
  152.         return Collections.unmodifiableList(delegating);
  153.     }

  154.     /** Specialized driver delegating to several other managing
  155.      * the same parameter name.
  156.      */
  157.     public static class DelegatingDriver extends ParameterDriver {

  158.         /** Drivers managing the same parameter. */
  159.         private final List<ParameterDriver> drivers;

  160.         /** Observer for propagating changes between all drivers. */
  161.         private ChangesForwarder forwarder;

  162.         /** Simple constructor.
  163.          * @param driver first driver in the series
  164.          */
  165.         DelegatingDriver(final ParameterDriver driver) {
  166.             super(driver.getName(), driver.getReferenceValue(),
  167.                   driver.getScale(), driver.getMinValue(), driver.getMaxValue());
  168.             drivers = new ArrayList<ParameterDriver>();
  169.             drivers.add(driver);

  170.             setValue(driver.getValue());
  171.             setReferenceDate(driver.getReferenceDate());
  172.             setSelected(driver.isSelected());

  173.         }

  174.         /** Set the changes forwarder.
  175.          * @param forwarder new changes forwarder
  176.                   * @since 9.1
  177.          */
  178.         void setForwarder(final ChangesForwarder forwarder) {

  179.             // remove the previous observer if any
  180.             if (this.forwarder != null) {
  181.                 removeObserver(this.forwarder);
  182.                 for (final ParameterDriver driver : drivers) {
  183.                     driver.removeObserver(this.forwarder);
  184.                 }
  185.             }

  186.             // add the new observer
  187.             this.forwarder = forwarder;
  188.             addObserver(forwarder);
  189.             for (final ParameterDriver driver : drivers) {
  190.                 driver.addObserver(forwarder);
  191.             }

  192.         }

  193.         /** Get the changes forwarder.
  194.          * @return changes forwarder
  195.          */
  196.         ChangesForwarder getForwarder() {
  197.             return forwarder;
  198.         }

  199.         /** Add a driver.
  200.          * @param driver driver to add
  201.          */
  202.         private void add(final ParameterDriver driver) {

  203.             for (final ParameterDriver d : drivers) {
  204.                 if (d == driver) {
  205.                     // the driver is already known, don't add it again
  206.                     return;
  207.                 }
  208.             }

  209.             setValue(driver.getValue());
  210.             setReferenceDate(driver.getReferenceDate());

  211.             // if any of the drivers is selected, all must be selected
  212.             if (isSelected()) {
  213.                 driver.setSelected(true);
  214.             } else {
  215.                 setSelected(driver.isSelected());
  216.             }

  217.             driver.addObserver(forwarder);
  218.             drivers.add(driver);

  219.         }

  220.         /** Get the raw drivers to which this one delegates.
  221.          * <p>
  222.          * These raw drivers all manage the same parameter name.
  223.          * </p>
  224.          * @return raw drivers to which this one delegates
  225.          */
  226.         public List<ParameterDriver> getRawDrivers() {
  227.             return Collections.unmodifiableList(drivers);
  228.         }

  229.     }

  230.     /** Local observer for propagating changes, avoiding infinite recursion. */
  231.     private static class ChangesForwarder implements ParameterObserver {

  232.         /** DelegatingDriver we are associated with. */
  233.         private final DelegatingDriver delegating;

  234.         /** Root of the current update chain. */
  235.         private ParameterDriver root;

  236.         /** Depth of the current update chain. */
  237.         private int depth;

  238.         /** Simple constructor.
  239.          * @param delegating delegatingDriver we are associated with
  240.          */
  241.         ChangesForwarder(final DelegatingDriver delegating) {
  242.             this.delegating = delegating;
  243.         }

  244.         /** Get the {@link DelegatingDriver} associated with this instance.
  245.          * @return {@link DelegatingDriver} associated with this instance
  246.          * @since 9.1
  247.          */
  248.         DelegatingDriver getDelegatingDriver() {
  249.             return delegating;
  250.         }

  251.         /** {@inheritDoc} */
  252.         @Override
  253.         public void valueChanged(final double previousValue, final ParameterDriver driver) {
  254.             updateAll(driver, d -> {
  255.                 d.setValue(driver.getValue());
  256.             });
  257.         }

  258.         /** {@inheritDoc} */
  259.         @Override
  260.         public void referenceDateChanged(final AbsoluteDate previousReferenceDate, final ParameterDriver driver) {
  261.             updateAll(driver, d -> d.setReferenceDate(driver.getReferenceDate()));
  262.         }

  263.         /** {@inheritDoc} */
  264.         @Override
  265.         public void nameChanged(final String previousName, final ParameterDriver driver) {
  266.             updateAll(driver, d -> d.setName(driver.getName()));
  267.         }

  268.         /** {@inheritDoc} */
  269.         @Override
  270.         public void selectionChanged(final boolean previousSelection, final ParameterDriver driver) {
  271.             updateAll(driver, d -> d.setSelected(driver.isSelected()));
  272.         }

  273.         /** {@inheritDoc} */
  274.         @Override
  275.         public void referenceValueChanged(final double previousReferenceValue, final ParameterDriver driver) {
  276.             updateAll(driver, d -> d.setReferenceValue(driver.getReferenceValue()));
  277.         }

  278.         /** {@inheritDoc} */
  279.         @Override
  280.         public void minValueChanged(final double previousMinValue, final ParameterDriver driver) {
  281.             updateAll(driver, d -> d.setMinValue(driver.getMinValue()));
  282.         }

  283.         /** {@inheritDoc} */
  284.         @Override
  285.         public void maxValueChanged(final double previousMaxValue, final ParameterDriver driver) {
  286.             updateAll(driver, d -> d.setMaxValue(driver.getMaxValue()));
  287.         }

  288.         /** {@inheritDoc} */
  289.         @Override
  290.         public void scaleChanged(final double previousScale, final ParameterDriver driver) {
  291.             updateAll(driver, d -> d.setScale(driver.getScale()));
  292.         }

  293.         /** Update all bound parameters.
  294.          * @param driver driver triggering the update
  295.          * @param updater updater to use
  296.          */
  297.         private void updateAll(final ParameterDriver driver, final Updater updater) {

  298.             final boolean firstCall = depth++ == 0;
  299.             if (firstCall) {
  300.                 root = driver;
  301.             }

  302.             if (driver == getDelegatingDriver()) {
  303.                 // propagate change downwards, which will trigger recursive calls
  304.                 for (final ParameterDriver d : delegating.drivers) {
  305.                     if (d != root) {
  306.                         updater.update(d);
  307.                     }
  308.                 }
  309.             } else if (firstCall) {
  310.                 // first call started from an underlying driver, propagate change upwards
  311.                 updater.update(getDelegatingDriver());
  312.             }

  313.             if (--depth == 0) {
  314.                 // this is the end of the root call
  315.                 root = null;
  316.             }

  317.         }

  318.     }

  319.     /** Interface for updating parameters. */
  320.     @FunctionalInterface
  321.     private interface Updater {
  322.         /** Update a driver.
  323.          * @param driver driver to update
  324.          */
  325.         void update(ParameterDriver driver);
  326.     }

  327. }