vtkDIYAggregateDataSetFilter.h

Go to the documentation of this file.

/*=========================================================================

  Program:   Visualization Toolkit
  Module:    vtkDIYAggregateDataSetFilter.h

  Copyright (c) Ken Martin, Will Schroeder, Bill Lorensen
  All rights reserved.
  See Copyright.txt or http://www.kitware.com/Copyright.htm 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.

=========================================================================*/
#ifndef vtkDIYAggregateDataSetFilter_h
#define vtkDIYAggregateDataSetFilter_h

#include "vtkFiltersParallelDIY2Module.h" // For export macro
#include "vtkAggregateDataSetFilter.h"

#include <map>     // For passing computed data between methods
#include <string>  // For passing computed data between methods
#include <vector>  // For passing computed data between methods

class vtkDataObject;
class vtkIdList;

class VTKFILTERSPARALLELDIY2_EXPORT vtkDIYAggregateDataSetFilter : public vtkAggregateDataSetFilter
{
  vtkTypeMacro(vtkDIYAggregateDataSetFilter, vtkAggregateDataSetFilter);
public:
  static vtkDIYAggregateDataSetFilter* New();
  void PrintSelf(ostream& os, vtkIndent indent) override;

protected:
  vtkDIYAggregateDataSetFilter();
  ~vtkDIYAggregateDataSetFilter() override;

  int RequestData(vtkInformation* request, vtkInformationVector** inputVector,
    vtkInformationVector* outputVector) override;
  int RequestInformation(vtkInformation*,
                         vtkInformationVector**,
                         vtkInformationVector*) override;

  int GetTargetProcessId(int sourceProcessId, int numberOfProcesses);

  bool DoExtentsOverlap(int extent1[6], int extent2[6], int dimensions[3],
                        int* overlappingExtent);

  void GetExtent(vtkDataSet* dataSet, int extent[6]);

  void ExtractDataSetInformation(vtkDataSet* source, vtkDataSet* target);

  int MoveDataWithDIY(int inputExtent[6], int wholeExtent[6], int outputExtent[6],
                      std::map<int, std::string>& serializedDataSets,
                      std::vector<std::string>& receivedDataSets);

  int MoveData(int inputExtent[6], int wholeExtent[6], int outputExtent[6],
               std::map<int, std::string>& serializedDataSets,
               std::vector<std::string>& receivedDataSets);

  void ComputeProcessesIReceiveFrom(
    int inputExent[6], int wholeExtent[6], int outputExtent[6], vtkIdList* processesIReceiveFrom);

  void ExtractRectilinearGridCoordinates(int* sourceExtent, int* targetExtent,
                                         vtkDataArray* sourceCoordinates, vtkDataArray* targetCoordinates);
private:
  vtkDIYAggregateDataSetFilter(const vtkDIYAggregateDataSetFilter&) = delete;
  void operator=(const vtkDIYAggregateDataSetFilter&) = delete;

  bool OutputInitialized;
};

#endif