+++ /dev/null
-/*=========================================================================
-
- Program: ParaView
- Module: $RCSfile$
-
- Copyright (c) Kitware, Inc.
- All rights reserved.
- See Copyright.txt or http://www.paraview.org/HTML/Copyright.html for details.
-
- This software is distributed WITHOUT ANY WARRANTY; without even
- the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
- PURPOSE. See the above copyright notice for more information.
-
- =========================================================================*/
-#include "SMESH_vtkPVUpdateSuppressor.h"
-
-#include "vtkAlgorithmOutput.h"
-#include "vtkCollection.h"
-#include "vtkCommand.h"
-#include "vtkCompositeDataPipeline.h"
-#include "vtkDataObject.h"
-#include "vtkDemandDrivenPipeline.h"
-#include "vtkInformation.h"
-#include "vtkInformationDoubleVectorKey.h"
-#include "vtkInformationExecutivePortKey.h"
-#include "vtkInformationVector.h"
-#include "vtkObjectFactory.h"
-#include "vtkPolyData.h"
-//#include "vtkProcessModule.h"
-#include "vtkSmartPointer.h"
-#include "vtkUnstructuredGrid.h"
-//#include "vtkUpdateSuppressorPipeline.h"
-
-#include <vtkstd/map>
-
-#ifdef MYDEBUG
-# define vtkMyDebug(x)\
- cout << x;
-#else
-# define vtkMyDebug(x)
-#endif
-
-vtkCxxRevisionMacro(vtkPVUpdateSuppressor, "$Revision$")
-;
-vtkStandardNewMacro(vtkPVUpdateSuppressor)
-;
-//----------------------------------------------------------------------------
-vtkPVUpdateSuppressor::vtkPVUpdateSuppressor()
-{
- this->UpdatePiece = 0;
- this->UpdateNumberOfPieces = 1;
-
- this->UpdateTime = 0.0;
- this->UpdateTimeInitialized = false;
-
- this->Enabled = 1;
-
- // vtkProcessModule* pm = vtkProcessModule::GetProcessModule();
- //
- // if (pm)
- // {
- // this->UpdateNumberOfPieces = pm->GetNumberOfLocalPartitions();
- // this->UpdatePiece = pm->GetPartitionId();
- // }
-}
-
-//----------------------------------------------------------------------------
-vtkPVUpdateSuppressor::~vtkPVUpdateSuppressor()
-{
-}
-
-//----------------------------------------------------------------------------
-void vtkPVUpdateSuppressor::SetUpdateTime(double utime)
-{
- this->UpdateTimeInitialized = true;
- if (this->UpdateTime != utime)
- {
- this->Modified();
- this->UpdateTime = utime;
- }
-}
-
-//----------------------------------------------------------------------------
-void vtkPVUpdateSuppressor::SetEnabled(int enable)
-{
- if (this->Enabled == enable)
- {
- return;
- }
- this->Enabled = enable;
- this->Modified();
- // vtkUpdateSuppressorPipeline* executive =
- // vtkUpdateSuppressorPipeline::SafeDownCast(this->GetExecutive());
- // if (executive)
- // {
- // executive->SetEnabled(enable);
- // }
-}
-
-//----------------------------------------------------------------------------
-void vtkPVUpdateSuppressor::ForceUpdate()
-{
- // Make sure that output type matches input type
- this->UpdateInformation();
-
- vtkDataObject *input = this->GetInput();
- if (input == 0)
- {
- vtkErrorMacro("No valid input.");
- return;
- }
- vtkDataObject *output = this->GetOutput();
-
- // int fixme; // I do not like this hack. How can we get rid of it?
- // Assume the input is the collection filter.
- // Client needs to modify the collection filter because it is not
- // connected to a pipeline.
- vtkAlgorithm *source = input->GetProducerPort()->GetProducer();
- if (source && (source->IsA("vtkMPIMoveData")
- || source->IsA("vtkCollectPolyData") || source->IsA("vtkM2NDuplicate")
- || source->IsA("vtkM2NCollect")
- || source->IsA("vtkOrderedCompositeDistributor")
- || source->IsA("vtkClientServerMoveData")))
- {
- source->Modified();
- }
-
- vtkInformation* info = input->GetPipelineInformation();
- vtkStreamingDemandDrivenPipeline
- * sddp =
- vtkStreamingDemandDrivenPipeline::SafeDownCast(
- vtkExecutive::PRODUCER()->GetExecutive(
- info));
- if (sddp)
- {
- sddp->SetUpdateExtent(info, this->UpdatePiece,
- this->UpdateNumberOfPieces, 0);
- }
- else
- {
- input->SetUpdatePiece(this->UpdatePiece);
- input->SetUpdateNumberOfPieces(this->UpdateNumberOfPieces);
- input->SetUpdateGhostLevel(0);
- } vtkMyDebug("ForceUpdate ");
- if (this->UpdateTimeInitialized)
- {
- info->Set(vtkCompositeDataPipeline::UPDATE_TIME_STEPS(),
- &this->UpdateTime, 1);
- vtkMyDebug(this->UpdateTime);
- } vtkMyDebug(endl);
-
- input->Update();
- // Input may have changed, we obtain the pointer again.
- input = this->GetInput();
-
- output->ShallowCopy(input);
- this->PipelineUpdateTime.Modified();
-}
-
-//----------------------------------------------------------------------------
-vtkExecutive* vtkPVUpdateSuppressor::CreateDefaultExecutive()
-{
- vtkUpdateSuppressorPipeline* executive = vtkUpdateSuppressorPipeline::New();
- executive->SetEnabled(this->Enabled);
- return executive;
-}
-
-//----------------------------------------------------------------------------
-int vtkPVUpdateSuppressor::RequestDataObject(
- vtkInformation* vtkNotUsed(reqInfo),
- vtkInformationVector** inputVector,
- vtkInformationVector* outputVector)
-{
- vtkInformation* inInfo = inputVector[0]->GetInformationObject(0);
- if (!inInfo)
- {
- return 0;
- }
-
- vtkDataObject *input = inInfo->Get(vtkDataObject::DATA_OBJECT());
- if (input)
- {
- // for each output
- for (int i = 0; i < this->GetNumberOfOutputPorts(); ++i)
- {
- vtkInformation* outInfo = outputVector->GetInformationObject(i);
- vtkDataObject *output = outInfo->Get(vtkDataObject::DATA_OBJECT());
-
- if (!output || !output->IsA(input->GetClassName()))
- {
- vtkDataObject* newOutput = input->NewInstance();
- newOutput->SetPipelineInformation(outInfo);
- newOutput->Delete();
- this->GetOutputPortInformation(i)->Set(
- vtkDataObject::DATA_EXTENT_TYPE(),
- newOutput->GetExtentType());
- }
- }
- return 1;
- }
- return 0;
-
-}
-
-//----------------------------------------------------------------------------
-int vtkPVUpdateSuppressor::RequestData(vtkInformation* vtkNotUsed(reqInfo),
- vtkInformationVector** inputVector,
- vtkInformationVector* outputVector)
-{
- // RequestData is only called by its executive when
- // (Enabled==off) and thus acting as a passthrough filter
- vtkInformation *outInfo = outputVector->GetInformationObject(0);
- vtkInformation *inInfo = inputVector[0]->GetInformationObject(0);
- vtkDataObject *input = inInfo->Get(vtkDataObject::DATA_OBJECT());
- vtkDataObject *output = outInfo->Get(vtkDataObject::DATA_OBJECT());
-
- output->ShallowCopy(input);
- return 1;
-}
-
-//----------------------------------------------------------------------------
-void vtkPVUpdateSuppressor::PrintSelf(ostream& os, vtkIndent indent)
-{
- this->Superclass::PrintSelf(os, indent);
- os << indent << "UpdatePiece: " << this->UpdatePiece << endl;
- os << indent << "UpdateNumberOfPieces: " << this->UpdateNumberOfPieces
- << endl;
- os << indent << "Enabled: " << this->Enabled << endl;
- os << indent << "UpdateTime: " << this->UpdateTime << endl;
-}
+++ /dev/null
-/*=========================================================================
-
- Program: ParaView
- Module: $RCSfile$
-
- Copyright (c) Kitware, Inc.
- All rights reserved.
- See Copyright.txt or http://www.paraview.org/HTML/Copyright.html for details.
-
- This software is distributed WITHOUT ANY WARRANTY; without even
- the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
- PURPOSE. See the above copyright notice for more information.
-
- =========================================================================*/
-// .NAME vtkPVUpdateSuppressor - prevents propagation of update
-// .SECTION Description
-// vtkPVUpdateSuppressor now uses the vtkProcessModule singleton to set up the
-// default values for UpdateNumberOfPieces and UpdatePiece, so we no longer have
-// to set the default values (in most cases).
-// .SECTION See Also
-// vtkPVCacheKeeper vtkUpdateSuppressorPipeline
-
-#ifndef __vtkPVUpdateSuppressor_h
-#define __vtkPVUpdateSuppressor_h
-
-#include "vtkDataObjectAlgorithm.h"
-
-class VTK_EXPORT vtkPVUpdateSuppressor: public vtkDataObjectAlgorithm
-{
-public:
-vtkTypeRevisionMacro(vtkPVUpdateSuppressor,vtkDataObjectAlgorithm)
- ;
- void PrintSelf(ostream& os, vtkIndent indent);
-
- // Description:
- // Construct with user-specified implicit function.
- static vtkPVUpdateSuppressor *New();
-
- // Description:
- // Force update on the input.
- virtual void ForceUpdate();
-
- // Description:
- // Set number of pieces and piece on the data.
- // This causes the filter to ingore the request from the output.
- // It is here because the user may not have celled update on the output
- // before calling force update (it is an easy fix).
- vtkSetMacro(UpdatePiece, int)
- ;
- vtkGetMacro(UpdatePiece, int)
- ;
- vtkSetMacro(UpdateNumberOfPieces, int)
- ;
- vtkGetMacro(UpdateNumberOfPieces, int)
- ;
-
- // Description:
- // Get/Set if the update suppressor is enabled. If the update suppressor
- // is not enabled, it won't supress any updates. Enabled by default.
- void SetEnabled(int);
- vtkGetMacro(Enabled, int)
- ;
-
- // Description:
- // Get/Set the update time that is sent up the pipeline.
- void SetUpdateTime(double utime);
- vtkGetMacro(UpdateTime, double)
- ;
-
-protected:
- vtkPVUpdateSuppressor();
- ~vtkPVUpdateSuppressor();
-
- int RequestDataObject(vtkInformation* request,
- vtkInformationVector **inputVector,
- vtkInformationVector *outputVector);
- int RequestData(vtkInformation* request, vtkInformationVector **inputVector,
- vtkInformationVector *outputVector);
-
- int UpdatePiece;
- int UpdateNumberOfPieces;
- double UpdateTime;
-
- bool UpdateTimeInitialized;
-
- int Enabled;
-
- vtkTimeStamp PipelineUpdateTime;
-
- // Create a default executive.
- virtual vtkExecutive* CreateDefaultExecutive();
-
-private:
- vtkPVUpdateSuppressor(const vtkPVUpdateSuppressor&); // Not implemented.
- void operator=(const vtkPVUpdateSuppressor&); // Not implemented.
-};
-
-#endif
