pqPipelineSource.h

Go to the documentation of this file.

// SPDX-FileCopyrightText: Copyright (c) Kitware Inc.
// SPDX-FileCopyrightText: Copyright (c) Sandia Corporation
// SPDX-License-Identifier: BSD-3-Clause

#ifndef pqPipelineSource_h
#define pqPipelineSource_h

#include "pqCoreModule.h"
#include "pqProxy.h"

class pqDataRepresentation;
class pqOutputPort;
class pqPipelineSourceInternal;
class pqView;
class vtkCommand;
class vtkObject;
class vtkPVDataInformation;
class vtkSMSourceProxy;

class PQCORE_EXPORT pqPipelineSource : public pqProxy
{
  Q_OBJECT
  typedef pqProxy Superclass;

public:
  pqPipelineSource(
    const QString& name, vtkSMProxy* proxy, pqServer* server, QObject* parent = nullptr);
  ~pqPipelineSource() override;

  int getNumberOfOutputPorts() const;

  pqOutputPort* getOutputPort(int outputport) const;

  pqOutputPort* getOutputPort(const QString& portName) const;

  QList<pqOutputPort*> getOutputPorts() const;

  int getNumberOfConsumers(int outputport) const;

  int getNumberOfConsumers() const { return this->getNumberOfConsumers(0); }

  pqPipelineSource* getConsumer(int outputport, int index) const;

  pqPipelineSource* getConsumer(int index) const { return this->getConsumer(0, index); }

  QList<pqPipelineSource*> getAllConsumers() const;

  QList<pqDataRepresentation*> getRepresentations(int outputport, pqView* view) const;
  QList<pqDataRepresentation*> getRepresentations(pqView* view) const
  {
    return this->getRepresentations(0, view);
  }

  pqDataRepresentation* getRepresentation(int outputport, pqView* view) const;
  pqDataRepresentation* getRepresentation(pqView* view) const
  {
    return this->getRepresentation(0, view);
  }

  QList<pqView*> getViews() const;

  void renderAllViews(bool force = false);

  void updatePipeline();

  vtkSMSourceProxy* getSourceProxy();

Q_SIGNALS:
  void connectionAdded(pqPipelineSource* source, pqPipelineSource* consumer, int srcOutputPort);
  void preConnectionAdded(pqPipelineSource* source, pqPipelineSource* consumer, int srcOutputPort);

  void connectionRemoved(pqPipelineSource* source, pqPipelineSource* consumer, int srcOutputPort);
  void preConnectionRemoved(
    pqPipelineSource* source, pqPipelineSource* consumer, int srcOutputPort);

  void representationAdded(pqPipelineSource* source, pqDataRepresentation* repr, int srcOutputPort);

  void representationRemoved(
    pqPipelineSource* source, pqDataRepresentation* repr, int srcOutputPort);

  void visibilityChanged(pqPipelineSource* source, pqDataRepresentation* repr);

  void dataUpdated(pqPipelineSource* source);

  void selectionChanged(pqOutputPort* port);

protected Q_SLOTS:
  void onRepresentationVisibilityChanged();

private Q_SLOTS:
  void prePortConnectionAdded(pqOutputPort* op, pqPipelineSource* cons);
  void portConnectionAdded(pqOutputPort* op, pqPipelineSource* cons);
  void prePortConnectionRemoved(pqOutputPort* op, pqPipelineSource* cons);
  void portConnectionRemoved(pqOutputPort* op, pqPipelineSource* cons);
  void portRepresentationAdded(pqOutputPort* op, pqDataRepresentation* cons);
  void portRepresentationRemoved(pqOutputPort* op, pqDataRepresentation* cons);
  void portVisibilityChanged(pqOutputPort* op, pqDataRepresentation* cons);
  void dataUpdated();

  void onSelectionChanged(
    vtkObject*, unsigned long, void* client_data, void* call_data, vtkCommand*);

protected:
  friend class pqPipelineFilter;

  void removeConsumer(int outputport, pqPipelineSource*);
  void addConsumer(int outputport, pqPipelineSource*);

private:
  pqPipelineSourceInternal* Internal; 
};

#endif