source: XIOS3/trunk/src/filter/server_from_client_source_filter.cpp @ 2628

#include "server_from_client_source_filter.hpp"
#include "grid.hpp"
#include "exception.hpp"
#include "calendar_util.hpp"
#include "context.hpp"
#include "workflow_graph.hpp"

namespace xios
{
  extern CLogType logProfile ;
  CServerFromClientSourceFilter::CServerFromClientSourceFilter(CGarbageCollector& gc, CGrid* grid)
    : COutputPin(gc)
    , grid_(grid)
  {
    if (!grid_)
      ERROR("CServerFromClientSourceFilter::CServerFromClientSourceFilter(CGarbageCollector& gc, CGrid* grid)",
            "Impossible to construct a source filter without providing a grid.");
  }

  void CServerFromClientSourceFilter::streamData(CEventServer& event)
  {
    Time timeStamp ;
    for (auto& subEvent : event.subEvents) (*subEvent.buffer) >> timeStamp  ;
    CDataPacketPtr packet(new CDataPacket);
    packet->date = CContext::getCurrent()->getCalendar()->getTimeOrigin() + timeStamp*Second; // very bad, better to pass directly the date
    packet->timestamp = timeStamp;
    packet->status = CDataPacket::NO_ERROR;
    if (info.isActive(logProfile)) CTimer::get("Server workflow data entry").resume();
    grid_->getServerFromClientConnector()->transfer(event,packet->data) ;
    if (info.isActive(logProfile)) CTimer::get("Server workflow data entry").suspend();

    if(this->graphEnabled)
    {
      this->graphPackage->filterId = CWorkflowGraph::getNodeSize();
      packet->graphPackage = new CGraphDataPackage;
      packet->graphPackage->fromFilter = this->graphPackage->filterId;
      packet->graphPackage->currentField = this->graphPackage->inFields[0];
      CWorkflowGraph::addNode("Server from Client Source filter", 1, false, 0, packet);
    }
    if (info.isActive(logProfile)) CTimer::get("Server workflow").resume();
    onOutputReady(packet);
    if (info.isActive(logProfile)) CTimer::get("Server workflow").suspend();
  }

 
  
} // namespace xios