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
|
/*=========================================================================
Program: ParaView
Module: vtkCommunicationErrorCatcher.cxx
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 "vtkCommunicationErrorCatcher.h"
#include "vtkCommand.h"
#include "vtkCommunicator.h"
#include "vtkMultiProcessController.h"
#include "vtkObjectFactory.h"
//----------------------------------------------------------------------------
vtkCommunicationErrorCatcher::vtkCommunicationErrorCatcher(
vtkMultiProcessController* controller)
{
this->Controller = controller;
if (controller)
{
this->Communicator = controller->GetCommunicator();
}
this->Initialize();
}
//----------------------------------------------------------------------------
vtkCommunicationErrorCatcher::vtkCommunicationErrorCatcher(vtkCommunicator* communicator)
{
this->Communicator = communicator;
this->Initialize();
}
//----------------------------------------------------------------------------
vtkCommunicationErrorCatcher::~vtkCommunicationErrorCatcher()
{
if (this->Communicator && this->CommunicatorObserverId)
{
this->Communicator->RemoveObserver(this->CommunicatorObserverId);
}
if (this->Controller && this->ControllerObserverId)
{
this->Controller->RemoveObserver(this->ControllerObserverId);
}
}
//----------------------------------------------------------------------------
void vtkCommunicationErrorCatcher::Initialize()
{
this->ErrorsRaised = false;
this->ControllerObserverId = 0;
this->CommunicatorObserverId = 0;
if (this->Controller)
{
this->ControllerObserverId = this->Controller->AddObserver(
vtkCommand::ErrorEvent,
this, &vtkCommunicationErrorCatcher::OnErrorEvent);
}
if (this->Communicator)
{
this->CommunicatorObserverId = this->Communicator->AddObserver(
vtkCommand::ErrorEvent,
this, &vtkCommunicationErrorCatcher::OnErrorEvent);
}
}
//----------------------------------------------------------------------------
void vtkCommunicationErrorCatcher::OnErrorEvent(
vtkObject* caller, unsigned long eventid, void* calldata)
{
if (caller && calldata && eventid == vtkCommand::ErrorEvent)
{
const char* error_message = reinterpret_cast<const char*>(calldata);
if (error_message && error_message[0])
{
this->ErrorMessages += error_message;
}
this->ErrorsRaised = true;
}
}
|
