source: XIOS/dev/dev_trunk_omp/src/filter/output_pin.hpp @ 1677

#ifndef __XIOS_COutputPin__
#define __XIOS_COutputPin__

#include "garbage_collector.hpp"
#include "input_pin.hpp"

namespace xios
{
  class CInputPin;
  class CFilter;
  /*!
   * An output pin handles the connections with downstream filters.
   */
  class COutputPin : public InvalidableObject
  {
    public:
      StdString output_field_id;
      int tag;

      std::vector< std::shared_ptr<COutputPin> > parent_filters;

      /*!
       * Constructs an ouput pin with manual or automatic trigger
       * and an associated garbage collector.
       *
       * \param gc the garbage collector associated with this ouput pin
       * \param slotsCount the number of slots
       * \param buildWorkflowGraph indicates whether data will be visualized
       */
      COutputPin(CGarbageCollector& gc, bool manualTrigger = false, bool buildWorkflowGraph = false);

      StdString virtual GetName(void);
      
      /*!
       * Connects to a specific slot of the input pin of a downstream filter.
       * Note that the output pin holds a reference on the downstream filter.
       *
       * \param inputPin the input pin to connect
       * \param inputSlot the input slot number
       */
      void connectOutput(std::shared_ptr<CInputPin> inputPin, size_t inputSlot);

      /*!
       * Triggers the output of any buffered packet for the specified timestamp.
       *
       * \param timestamp the timestamp for which we are triggering the output
       */
      void virtual trigger(Time timestamp);

      /*!
       * Tests if the pin can be triggered.
       *
       * \return true if the pin can be triggered
       */
      bool virtual canBeTriggered() const;

      /*!
       * Tests if the pin must auto-trigger.
       *
       * \return true if the pin must auto-trigger
       */
      bool virtual mustAutoTrigger() const;

      /*!
       * Tests whether data is expected for the specified date.
       *
       * \param date the date associated to the data
       */
      bool virtual isDataExpected(const CDate& date) const;

      /*!
       * Removes all pending packets which are older than the specified timestamp.
       *
       * \param timestamp the timestamp used for invalidation
       */
      void virtual invalidate(Time timestamp);

      void virtual setParentFiltersTag();


    protected:
      /*!
       * Function triggered when a packet is ready to be delivered.
       *
       * \param packet the packet ready for output
       */
      void onOutputReady(CDataPacketPtr packet);

      /*!
       * Informs the downstream pins that this output pin should be triggered.
       */
      void setOutputTriggers();

    private:
      /*!
       * Delivers an output packet to the downstreams filter.
       *
       * \param packet the packet to output
       */
      void deliverOuput(CDataPacketPtr packet);

      CGarbageCollector& gc; //!< The garbage collector associated to the output pin

      //!< Whether the ouput should be triggered manually
      bool manualTrigger;

      //!< The list of connected filters and the corresponding slot numbers
      std::vector<std::pair<std::shared_ptr<CInputPin>, size_t> > outputs;

      //! Output buffer, store the packets until the output is triggered
      std::map<Time, CDataPacketPtr> outputPackets;

      //! Indicates whether the workflow will be visualized
      bool buildWorkflowGraph;


  }; // class COutputPin
} // namespace xios

#endif //__XIOS_COutputPin__