bbtkBlackBoxOutputConnector.cxx
Go to the documentation of this file.00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00037 #include "bbtkBlackBoxOutputConnector.h"
00038 #include "bbtkMessageManager.h"
00039 #include "bbtkBlackBox.h"
00040
00041
00042 namespace bbtk
00043 {
00044
00045
00047 class BlackBoxOutputConnector::Pimpl
00048 {
00049 public:
00050 Pimpl() : mStatus(OUTOFDATE) {}
00051 Pimpl(const Pimpl&) {}
00053 BlackBoxWeakPointer mBox;
00055 ConnectionVector mConnection;
00057 IOStatus mStatus;
00059 BlackBox::OutputChangeSignalType mChangeSignal;
00060
00061
00062 };
00063
00064
00065
00066 BBTK_IMPL_PIMPL(BlackBoxOutputConnector)
00067
00068
00069
00070
00071 BlackBoxOutputConnector::BlackBoxOutputConnector(BlackBox::Pointer b)
00072 {
00073 bbtkDebugMessage("kernel",9,
00074 "["<<b->bbGetName()
00075 <<"] BlackBoxOutputConnector()"<<std::endl);
00076 PimplConstruct();
00077 p->mBox = b;
00078 }
00079
00080
00081
00082
00083 BlackBoxOutputConnector::~BlackBoxOutputConnector()
00084 {
00085 bbtkDebugMessage("kernel",9,
00086 "[DEAD BOX] ==> ~BlackBoxOutputConnector()"
00087 <<std::endl);
00088
00089
00090
00091
00092
00093
00094
00095 p->mConnection.clear();
00096 PimplDestruct();
00097
00098 bbtkDebugMessage("kernel",9,
00099 "[DEAD BOX] <== ~BlackBoxOutputConnector()"
00100 <<std::endl);
00101 }
00102
00103
00104
00106 void BlackBoxOutputConnector::SetConnection(Connection* c)
00107 {
00108 bbtkDebugMessage("kernel",9,
00109 "["<<p->mBox.lock()->bbGetName()
00110 <<"] BlackBoxOutputConnector::SetConnection("
00111 <<c<<")"<<std::endl);
00112 p->mConnection.push_back(c);
00113
00114 }
00115
00116
00117
00118
00119 void BlackBoxOutputConnector::UnsetConnection(Connection* c)
00120 {
00121 bbtkDebugMessage("kernel",9,"["<<p->mBox.lock()->bbGetName()
00122 <<"] BlackBoxOutputConnector::UnsetConnection("
00123 <<c<<")"<<std::endl);
00124
00125 if (!c)
00126 {
00127 bbtkInternalError(p->mBox.lock()->bbGetFullName()
00128 <<": BlackBoxOutputConnector::UnsetConnection("
00129 <<c<<") : invalid connection");
00130
00131 }
00132
00133
00134 ConnectionVector::iterator i;
00135
00136 for (i=p->mConnection.begin();
00137 i!=p->mConnection.end();
00138 ++i)
00139 {
00140 if (*i==c) break;
00141 }
00142 if (i==p->mConnection.end())
00143 {
00144 bbtkInternalError(p->mBox.lock()->bbGetFullName()
00145 <<": BlackBoxOutputConnector::UnsetConnection("
00146 <<c
00147 <<") : connection is absent from connections list");
00148 }
00149 p->mConnection.erase(i);
00150
00151
00152
00153 }
00154
00155
00156
00157 const BlackBoxOutputConnector::ConnectionVector&
00158 BlackBoxOutputConnector::GetConnectionVector() const
00159 {
00160 return p->mConnection;
00161 }
00162
00163
00164
00166 IOStatus BlackBoxOutputConnector::GetStatus() const
00167 {
00168 return p->mStatus;
00169 }
00170
00171
00172
00174 void BlackBoxOutputConnector::SetStatus( IOStatus s )
00175 {
00176 p->mStatus = s;
00177 }
00178
00179
00180
00181 void BlackBoxOutputConnector::SignalChange( BlackBox::Pointer box,
00182 const std::string& output )
00183 {
00184 IOStatus s = OUTOFDATE;
00185
00186
00187 bbtkDebugMessage("change",2,
00188 "["<<box->bbGetName()
00189 <<"] ==> BlackBoxOutputConnector::SignalChange('"
00190 <<output<<"','"<<GetIOStatusString(s)<<"') ["
00191 <<this<<"]"
00192 <<std::endl);
00193
00194
00195
00196
00197 p->mChangeSignal(box,output,s);
00198
00199 bbtkDebugMessage("change",2,
00200 "["<<box->bbGetName()
00201 <<"] <== BlackBoxOutputConnector::SignalChange('"
00202 <<output<<"','"<<GetIOStatusString(s)<<"') ["
00203 <<this<<"]"
00204 <<std::endl);
00205 }
00206
00207
00208
00209 void BlackBoxOutputConnector::AddChangeObserver(OutputChangeCallbackType f)
00210 {
00211
00212 p->mChangeSignal.connect(f);
00213 }
00214
00215
00216
00219 void BlackBoxOutputConnector::RemoveChangeObserver(OutputChangeCallbackType f)
00220 {
00221 bbtkError("BlackBoxOutputConnector::RemoveChangeObserver not implemented");
00222
00223
00224 }
00225
00226 }
00227
00228