The following changes were made:

1) update documentation.
2) remove some output messages from pvaClientMonitor and pvaClientMultiChannel
3) performance improvement to pvaClientNTMultiPut.
This commit is contained in:
mrkraimer
2021-03-01 10:14:05 -05:00
parent 1211d01800
commit 8a661bb591
5 changed files with 28 additions and 14 deletions

View File

@@ -296,9 +296,7 @@ void PvaClientMonitor::unlisten(MonitorPtr const & monitor)
PvaClientMonitorRequesterPtr req = pvaClientMonitorRequester.lock();
if(req) {
req->unlisten();
return;
}
cerr << pvaClientChannel->getChannel()->getChannelName() + "pvaClientMonitor::unlisten called but no PvaClientMonitorRequester\n";
}

View File

@@ -149,7 +149,6 @@ PvaClientPtr PvaClientMultiChannel::getPvaClient()
PvaClientMultiGetDoublePtr PvaClientMultiChannel::createGet()
{
cout << "PvaClientMultiChannel::createGet\n";
checkConnected();
return PvaClientMultiGetDouble::create(shared_from_this(),pvaClientChannelArray);
}
@@ -157,7 +156,6 @@ cout << "PvaClientMultiChannel::createGet\n";
PvaClientMultiPutDoublePtr PvaClientMultiChannel::createPut()
{
cout << "PvaClientMultiChannel::createPut\n";
checkConnected();
return PvaClientMultiPutDouble::create(shared_from_this(),pvaClientChannelArray);
}
@@ -165,7 +163,6 @@ cout << "PvaClientMultiChannel::createPut\n";
PvaClientMultiMonitorDoublePtr PvaClientMultiChannel::createMonitor()
{
cout << "PvaClientMultiChannel::createMonitor\n";
checkConnected();
return PvaClientMultiMonitorDouble::create(shared_from_this(), pvaClientChannelArray);
}

View File

@@ -146,12 +146,15 @@ void PvaClientNTMultiPut::put()
value[i]->copy(*unionValue[i]->get());
pvaClientPut[i]->issuePut();
}
if(isConnected[i]) {
Status status = pvaClientPut[i]->waitPut();
if(status.isOK()) continue;
string message = string("channel ") +pvaClientChannelArray[i]->getChannelName()
+ " PvaChannelPut::waitPut " + status.getMessage();
throw std::runtime_error(message);
}
for(size_t i=0; i<nchannel; ++i)
{
if(isConnected[i]) {
Status status = pvaClientPut[i]->waitPut();
if(status.isOK()) continue;
string message = string("channel ") +pvaClientChannelArray[i]->getChannelName()
+ " PvaChannelPut::waitPut " + status.getMessage();
throw std::runtime_error(message);
}
}
}