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
108
109
110
111
112
113
114
|
/*=========================================================================
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 "vtkSIInputProperty.h"
#include "vtkAlgorithmOutput.h"
#include "vtkClientServerStream.h"
#include "vtkObjectFactory.h"
#include "vtkPVXMLElement.h"
#include "vtkSISourceProxy.h"
#include "vtkSMMessage.h"
#include <assert.h>
vtkStandardNewMacro(vtkSIInputProperty);
//----------------------------------------------------------------------------
vtkSIInputProperty::vtkSIInputProperty()
{
this->PortIndex = 0;
}
//----------------------------------------------------------------------------
vtkSIInputProperty::~vtkSIInputProperty()
{
}
//----------------------------------------------------------------------------
bool vtkSIInputProperty::ReadXMLAttributes(vtkSIProxy* proxyhelper, vtkPVXMLElement* element)
{
if (!this->Superclass::ReadXMLAttributes(proxyhelper, element))
{
return false;
}
int port_index;
if (element->GetScalarAttribute("port_index", &port_index))
{
this->SetPortIndex(port_index);
}
return true;
}
//----------------------------------------------------------------------------
bool vtkSIInputProperty::Push(vtkSMMessage* message, int offset)
{
if (!this->GetCommand())
{
// It is fine to have a property without command but then we do nothing
// here at the server side...
return true;
}
assert(message->ExtensionSize(ProxyState::property) > offset);
const ProxyState_Property* prop = &message->GetExtension(ProxyState::property, offset);
assert(strcmp(prop->name().c_str(), this->GetXMLName()) == 0);
const Variant* variant = &prop->value();
assert(variant->proxy_global_id_size() == variant->port_number_size());
std::vector<vtkTypeUInt32> proxy_ids;
std::vector<int> output_ports;
proxy_ids.resize(variant->proxy_global_id_size());
output_ports.resize(proxy_ids.size());
for (int cc = 0; cc < variant->proxy_global_id_size(); cc++)
{
proxy_ids[cc] = variant->proxy_global_id(cc);
output_ports[cc] = variant->port_number(cc);
}
vtkClientServerStream stream;
if (this->CleanCommand)
{
stream << vtkClientServerStream::Invoke << this->SIProxyObject << "CleanInputs"
<< this->CleanCommand << vtkClientServerStream::End;
}
for (size_t cc = 0; cc < proxy_ids.size(); cc++)
{
vtkSISourceProxy* siProxy = vtkSISourceProxy::SafeDownCast(this->GetSIObject(proxy_ids[cc]));
vtkAlgorithmOutput* input_connection =
(siProxy ? siProxy->GetOutputPort(output_ports[cc]) : NULL);
stream << vtkClientServerStream::Invoke << this->SIProxyObject << "AddInput" << this->PortIndex
<< input_connection << this->GetCommand() << vtkClientServerStream::End;
}
if (this->NullOnEmpty && this->CleanCommand == NULL && proxy_ids.size() == 0)
{
stream << vtkClientServerStream::Invoke << this->SIProxyObject << "AddInput" << this->PortIndex
<< static_cast<vtkObjectBase*>(NULL) << this->GetCommand() << vtkClientServerStream::End;
}
// Save to cache when pulled for collaboration
this->SaveValueToCache(message, offset);
return this->ProcessMessage(stream);
}
//----------------------------------------------------------------------------
void vtkSIInputProperty::PrintSelf(ostream& os, vtkIndent indent)
{
this->Superclass::PrintSelf(os, indent);
}
|
