1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
// SPDX-FileCopyrightText: Copyright (c) Ken Martin, Will Schroeder, Bill Lorensen
// SPDX-License-Identifier: BSD-3-Clause
/**
* @class vtkDIYAggregateDataSetFilter
* @brief Aggregates data sets to a reduced number of processes.
*
* This class allows vtkDataSets to be aggregated over a smaller set of processes.
*/
#ifndef vtkDIYAggregateDataSetFilter_h
#define vtkDIYAggregateDataSetFilter_h
#include "vtkAggregateDataSetFilter.h"
#include "vtkFiltersParallelDIY2Module.h" // For export macro
#include <map> // For passing computed data between methods
#include <string> // For passing computed data between methods
#include <vector> // For passing computed data between methods
VTK_ABI_NAMESPACE_BEGIN
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;
/**
* Given a source process id and number of processes, return a target process id for the aggregate
* operation. The target process id ranges from 0 to NumberOfTargetProcesses-1.
* For source process ids that don't have a target process id, a -1 will be
* returned.
*/
int GetTargetProcessId(int sourceProcessId, int numberOfProcesses);
/**
* Given two extents and dimensions (marking whether or not we have cells
* in that dimension with a value of 0 for no), return whether or not the
* extents overlap by at least a single cell. We ignore if they share a
* point as this is not needed to share information. If the extents do
* overlap then the overlapping extent is returned in overlappingExtent
* if it is non-null.
*/
bool DoExtentsOverlap(int extent1[6], int extent2[6], int dimensions[3], int* overlappingExtent);
/**
* Get the extent of the topologically regular dataset.
*/
void GetExtent(vtkDataSet* dataSet, int extent[6]);
/**
* Extract information from source dataset into target dataset.
*/
void ExtractDataSetInformation(vtkDataSet* source, vtkDataSet* target);
/**
* Move data with DIY. Having issues with the serialized XML string.
* so saving for later use.
*/
int MoveDataWithDIY(int inputExtent[6], int wholeExtent[6], int outputExtent[6],
std::map<int, std::string>& serializedDataSets, std::vector<std::string>& receivedDataSets);
/**
* Move data directly with vtkMPIController.
*/
int MoveData(int inputExtent[6], int wholeExtent[6], int outputExtent[6],
std::map<int, std::string>& serializedDataSets, std::vector<std::string>& receivedDataSets);
/**
* Determine which processes I receive data and put those process ranks (in order)
* into *processesIReceiveFrom*.
*/
void ComputeProcessesIReceiveFrom(
int inputExent[6], int wholeExtent[6], int outputExtent[6], vtkIdList* processesIReceiveFrom);
/**
* Put appropriate values from *sourceCoordinates* into *targetCoordinates*
* based on the extents overlap.
*/
void ExtractRectilinearGridCoordinates(int* sourceExtent, int* targetExtent,
vtkDataArray* sourceCoordinates, vtkDataArray* targetCoordinates);
private:
vtkDIYAggregateDataSetFilter(const vtkDIYAggregateDataSetFilter&) = delete;
void operator=(const vtkDIYAggregateDataSetFilter&) = delete;
/**
* Used to keep track of whether or not we've initialized the output
* dataset
*/
bool OutputInitialized;
};
VTK_ABI_NAMESPACE_END
#endif
|
