diff --git a/src/pv/pvaClient.h b/src/pv/pvaClient.h index cd61b8f..c6dc54a 100644 --- a/src/pv/pvaClient.h +++ b/src/pv/pvaClient.h @@ -18,7 +18,7 @@ #include #include #include -#include +#include #include #include #include @@ -36,12 +36,12 @@ #ifdef pvaClientEpicsExportSharedSymbols # define epicsExportSharedSymbols -# undef pvaClientEpicsExportSharedSymbols +# undef pvaClientEpicsExportSharedSymbols #endif #include -namespace epics { namespace pvaClient { +namespace epics { namespace pvaClient { class PvaClient; typedef std::tr1::shared_ptr PvaClientPtr; @@ -161,7 +161,7 @@ public: PvaClientChannelPtr createChannel( std::string const & channelName, std::string const & providerName = "pva"); - + /** @brief Set a requester. * * The default is for PvaClient to handle messages by printing to System.out. @@ -204,7 +204,7 @@ class PvaClientPutCache; typedef std::tr1::shared_ptr PvaClientPutCachePtr; -/** +/** * @brief A callback for change in connection status. * * Overview of PvaClientChannelStateChangeRequester @@ -228,7 +228,7 @@ public: virtual void channelStateChange(PvaClientChannelPtr const & channel, bool isConnected) = 0; }; -/** +/** * @brief An easy to use alternative to directly calling the Channel methods of pvAccess. * * Overview of PvaClientChannel @@ -245,7 +245,7 @@ public: */ ~PvaClientChannel(); /** @brief Set a client stateChangeRequester. - * + * * @param stateChangeRequester The client stateChangeRequester implementation. */ void setStateChangeRequester(PvaClientChannelStateChangeRequesterPtr const &stateChangeRequester); @@ -290,7 +290,7 @@ public: * @throw runtime_error if failure. */ PvaClientProcessPtr createProcess(std::string const & request = ""); - /** Creates a PvaClientProcess. + /** Creates a PvaClientProcess. * * @param pvRequest The syntax of pvRequest is defined by the copy facility of pvData. * @return The interface. @@ -351,7 +351,7 @@ public: epics::pvData::shared_vector getStringArray( std::string const & request = "field(value)"); /** @brief create a PvaClientPut. - * + * * Get a cached PvaClientPut or create and connect to a new PvaClientPut. * Then call it's get method. * @param request The syntax of request is defined by the copy facility of pvData. @@ -397,7 +397,7 @@ public: epics::pvData::shared_vector const & value, std::string const & request = "field(value)"); /** @brief Copy array to the value field. - * + * * @param value The new value. * @param request The syntax of request is defined by the copy facility of pvData. * @throw runtime_error if failure. @@ -450,7 +450,7 @@ public: * @throw runtime_error if failure. */ PvaClientMonitorPtr monitor(std::string const & request = "field(value,alarm,timeStamp)"); - /** @brief Call the next method with request = "field(value,alarm,timeStamp)" + /** @brief Call the next method with request = "field(value,alarm,timeStamp)" * * @param pvaClientMonitorRequester The client callback. * @return The interface. @@ -539,7 +539,7 @@ private: std::string channelName; std::string providerName; ConnectState connectState; - + epics::pvData::CreateRequest::shared_pointer createRequest; PvaClientGetCachePtr pvaClientGetCache; PvaClientPutCachePtr pvaClientPutCache; @@ -561,7 +561,7 @@ public: friend class PvaClient; }; -/** +/** * @brief A base class for PvaClientGetData, PvaClientPutData, and PvaClientMonitorData. * * Overview of PvaClientData @@ -737,7 +737,7 @@ private: friend class PvaClientPutGet; }; -/** +/** * @brief A class that holds data returned by PvaClientGet or PvaClientPutGet * * Overview of PvaClientGetData @@ -764,7 +764,7 @@ private: }; class PvaClientPostHandlerPvt; // private to PvaClientPutData -/** +/** * @brief A class that holds data given to by PvaClientPut or PvaClientPutGet * * Overview of PvaClientPutData @@ -775,7 +775,7 @@ public: POINTER_DEFINITIONS(PvaClientPutData); /** * @brief Destructor - */ + */ ~PvaClientPutData() {} /** @brief Put the value as a double. * @param value The new value. @@ -828,7 +828,7 @@ public: POINTER_DEFINITIONS(PvaClientMonitorData); /** * @brief Destructor - */ + */ ~PvaClientMonitorData() {} /** @brief Get the overrun BitSet for the pvStructure * This shows which fields have had more than one change. @@ -914,7 +914,7 @@ public: PvaClientChannelPtr const & pvaClientChannel, epics::pvData::PVStructurePtr const &pvRequest ); - + /** @brief Destructor */ ~PvaClientProcess(); @@ -968,7 +968,7 @@ private: PvaClientPtr const &pvaClient, PvaClientChannelPtr const & pvaClientChannel, epics::pvData::PVStructurePtr const &pvRequest); - + void checkProcessState(); enum ProcessConnectState {connectIdle,connectActive,connected}; @@ -1279,7 +1279,7 @@ private : PvaClientPtr const &pvaClient, PvaClientChannelPtr const & pvaClientChannel, epics::pvData::PVStructurePtr const &pvRequest); - + void checkConnectState(); enum PutConnectState {connectIdle,connectActive,connected}; @@ -1357,11 +1357,11 @@ public: PvaClientPutGetPtr const & clientPutGet) { } - + }; -/** +/** * @brief An easy to use alternative to ChannelPutGet. * * Overview of PvaClientPutGet @@ -1448,11 +1448,11 @@ public: /** @brief Get the put data. * @return The interface. */ - PvaClientPutDataPtr getPutData(); + PvaClientPutDataPtr getPutData(); /** @brief Get the get data. * @return The interface. */ - PvaClientGetDataPtr getGetData(); + PvaClientGetDataPtr getGetData(); /** @brief Get the PvaClientChannel; * * @return The interface. @@ -1593,7 +1593,7 @@ public: std::string const & request, PvaClientChannelStateChangeRequesterPtr const & stateChangeRequester = PvaClientChannelStateChangeRequesterPtr(), - PvaClientMonitorRequesterPtr const & monitorRequester + PvaClientMonitorRequesterPtr const & monitorRequester = PvaClientMonitorRequesterPtr() ) EPICS_DEPRECATED; /** @brief Destructor @@ -1656,7 +1656,7 @@ public: * * @return The interface. */ - PvaClientMonitorDataPtr getData(); + PvaClientMonitorDataPtr getData(); private: std::string getRequesterName(); void message(std::string const & message,epics::pvData::MessageType messageType); @@ -1687,7 +1687,7 @@ private: epics::pvData::Status monitorConnectStatus; epics::pvData::MonitorPtr monitor; epics::pvData::MonitorElementPtr monitorElement; - + PvaClientMonitorRequesterWPtr pvaClientMonitorRequester; MonitorConnectState connectState; bool userPoll; @@ -1764,7 +1764,7 @@ public: * @brief Set a timeout for a request. * @param responseTimeout The time in seconds to wait for a request to complete. */ - void setResponseTimeout(double responseTimeout) + void setResponseTimeout(double responseTimeout) { this->responseTimeout = responseTimeout; } @@ -1834,12 +1834,12 @@ private: PvaClient::weak_pointer pvaClient; epics::pvAccess::Channel::weak_pointer channel; epics::pvData::PVStructurePtr pvRequest; - + epics::pvData::Mutex mutex; epics::pvData::Event waitForConnect; epics::pvData::Event waitForDone; - PvaClientRPCRequesterWPtr pvaClientRPCRequester; + PvaClientRPCRequesterWPtr pvaClientRPCRequester; RPCRequesterImplPtr rpcRequester; epics::pvAccess::ChannelRPC::shared_pointer channelRPC; epics::pvData::PVStructurePtr pvResponse; @@ -1858,6 +1858,5 @@ private: /** @page Overview Documentation * * pvaClientCPP.html - * + * */ - diff --git a/src/pv/pvaClientMultiChannel.h b/src/pv/pvaClientMultiChannel.h index 09558d8..cb40de0 100644 --- a/src/pv/pvaClientMultiChannel.h +++ b/src/pv/pvaClientMultiChannel.h @@ -21,14 +21,14 @@ #ifdef pvaClientMultiChannelEpicsExportSharedSymbols # define epicsExportSharedSymbols -# undef pvaClientMultiChannelEpicsExportSharedSymbols +# undef pvaClientMultiChannelEpicsExportSharedSymbols #endif #include -namespace epics { namespace pvaClient { +namespace epics { namespace pvaClient { class PvaClientMultiChannel; @@ -115,7 +115,7 @@ public: * @brief create a pvaClientMultiGetDouble * @return The interface. */ - PvaClientMultiGetDoublePtr createGet(); + PvaClientMultiGetDoublePtr createGet(); /** * @brief Create a pvaClientMultiPutDouble. * @return The interface. @@ -152,7 +152,7 @@ private: std::string const & providerName, size_t maxNotConnected); void checkConnected(); - + PvaClientPtr pvaClient; epics::pvData::shared_vector channelName; std::string providerName; @@ -176,7 +176,7 @@ class epicsShareClass PvaClientMultiGetDouble : public: POINTER_DEFINITIONS(PvaClientMultiGetDouble); - + /** * @brief Create a PvaClientMultiGetDouble. * @param pvaClientMultiChannel The interface to PvaClientMultiChannel. @@ -214,7 +214,7 @@ private: PvaClientChannelArray pvaClientChannelArray; size_t nchannel; epics::pvData::Mutex mutex; - + epics::pvData::shared_vector doubleValue; std::vector pvaClientGet; bool isGetConnected; @@ -229,7 +229,7 @@ class epicsShareClass PvaClientMultiPutDouble : public: POINTER_DEFINITIONS(PvaClientMultiPutDouble); - + /** @brief Create a PvaClientMultiPutDouble. * @param pvaClientMultiChannel The interface to PvaClientMultiChannel. * @param pvaClientChannelArray The PvaClientChannel array. @@ -277,7 +277,7 @@ class epicsShareClass PvaClientMultiMonitorDouble : public: POINTER_DEFINITIONS(PvaClientMultiMonitorDouble); - + /** @brief Create a PvaClientMultiMonitorDouble. * @param pvaClientMultiChannel The interface to PvaClientMultiChannel. * @param pvaClientChannelArray The PvaClientChannel array. @@ -388,8 +388,8 @@ private: epics::pvData::PVStructurePtr pvRequest; size_t nchannel; epics::pvData::Mutex mutex; - - + + PvaClientNTMultiDataPtr pvaClientNTMultiData; std::vector pvaClientGet; bool isConnected; @@ -413,7 +413,7 @@ public: static PvaClientNTMultiPutPtr create( PvaClientMultiChannelPtr const &pvaClientMultiChannel, PvaClientChannelArray const &pvaClientChannelArray); - + ~PvaClientNTMultiPut(); /** * @brief Connect a channelPut for each channel. @@ -543,15 +543,15 @@ public: PvaClientChannelArray const &pvaClientChannelArray, epics::pvData::PVStructurePtr const & pvRequest); ~PvaClientNTMultiData(); - + /** * @brief Get the number of channels. * @return The number of channels. */ size_t getNumber(); - + /** - * @brief Set the timeStamp base for computing deltaTimes. + * @brief Set the timeStamp base for computing deltaTimes. */ void startDeltaTime(); /** @@ -564,7 +564,7 @@ public: * @brief Get the time when the last get was made. * @return The timeStamp. */ - epics::pvData::TimeStamp getTimeStamp(); + epics::pvData::TimeStamp getTimeStamp(); /** * @brief Get the NTMultiChannel. * @return The value. @@ -594,7 +594,7 @@ private: std::vector topPVStructure; bool gotAlarm; bool gotTimeStamp; - + epics::pvData::StructureConstPtr ntMultiChannelStructure; epics::pvData::shared_vector unionValue; epics::pvData::shared_vector severity; @@ -615,4 +615,3 @@ private: }} #endif /* PVACLIENTMULTICHANNEL_H */ - diff --git a/src/pvaClient.cpp b/src/pvaClient.cpp index 5545342..f28b692 100644 --- a/src/pvaClient.cpp +++ b/src/pvaClient.cpp @@ -23,7 +23,7 @@ using namespace epics::pvAccess; using namespace epics::pvAccess::ca; using namespace std; -namespace epics { namespace pvaClient { +namespace epics { namespace pvaClient { class epicsShareClass PvaClientChannelCache @@ -42,7 +42,7 @@ public: private: map pvaClientChannelMap; }; - + PvaClientChannelPtr PvaClientChannelCache::getChannel( string const & channelName, string const & providerName) @@ -77,7 +77,7 @@ void PvaClientChannelCache::showCache() string providerName = channel->getProvider()->getProviderName(); cout << "channel " << channelName << " provider " << providerName << endl; pvaChannel->showCache(); - } + } } size_t PvaClientChannelCache::cacheSize() @@ -137,7 +137,7 @@ PvaClient::PvaClient(std::string const & providerNames) } CAClientFactory::start(); caStarted = true; - } else { + } else { if(!channelRegistry->getProvider(providerName)) { cerr << "PvaClient::get provider " << providerName << " not known" << endl; } @@ -191,7 +191,7 @@ PvaClientChannelPtr PvaClient::channel( std::string const & providerName, double timeOut) { - PvaClientChannelPtr pvaClientChannel = + PvaClientChannelPtr pvaClientChannel = pvaClientChannelCache->getChannel(channelName,providerName); if(pvaClientChannel) return pvaClientChannel; pvaClientChannel = createChannel(channelName,providerName); @@ -231,4 +231,3 @@ size_t PvaClient::cacheSize() } }} - diff --git a/src/pvaClientChannel.cpp b/src/pvaClientChannel.cpp index 2ee538e..919204a 100644 --- a/src/pvaClientChannel.cpp +++ b/src/pvaClientChannel.cpp @@ -183,7 +183,7 @@ void PvaClientChannel::channelCreated(const Status& status, Channel::shared_poin throw std::runtime_error(message); } if(channel->isConnected()) { - connectState = connected; + connectState = connected; waitForConnect.signal(); } } @@ -267,7 +267,7 @@ void PvaClientChannel::connect(double timeout) Status status = waitConnect(timeout); if(status.isOK()) return; if(PvaClient::getDebug()) cout << "PvaClientChannel::connect waitConnect failed\n"; - string message = string("channel ") + channelName + string message = string("channel ") + channelName + " PvaClientChannel::connect " + status.getMessage(); throw std::runtime_error(message); } @@ -330,7 +330,7 @@ PvaClientProcessPtr PvaClientChannel::createProcess(string const & request) { PVStructurePtr pvRequest = createRequest->createRequest(request); if(!pvRequest) { - string message = string("channel ") + channelName + string message = string("channel ") + channelName + " PvaClientChannel::createProcess invalid pvRequest: " + createRequest->getMessage(); throw std::runtime_error(message); @@ -364,7 +364,7 @@ PvaClientGetPtr PvaClientChannel::createGet(string const & request) { PVStructurePtr pvRequest = createRequest->createRequest(request); if(!pvRequest) { - string message = string("channel ") + channelName + string message = string("channel ") + channelName + " PvaClientChannel::createGet invalid pvRequest: " + createRequest->getMessage(); throw std::runtime_error(message); @@ -419,7 +419,7 @@ PvaClientPutPtr PvaClientChannel::createPut(string const & request) { PVStructurePtr pvRequest = createRequest->createRequest(request); if(!pvRequest) { - string message = string("channel ") + channelName + string message = string("channel ") + channelName + " PvaClientChannel::createPut invalid pvRequest: " + createRequest->getMessage(); throw std::runtime_error(message); @@ -477,7 +477,7 @@ PvaClientPutGetPtr PvaClientChannel::createPutGet(string const & request) { PVStructurePtr pvRequest = createRequest->createRequest(request); if(!pvRequest) { - string message = string("channel ") + channelName + string message = string("channel ") + channelName + " PvaClientChannel::createPutGet invalid pvRequest: " + createRequest->getMessage(); throw std::runtime_error(message); @@ -499,7 +499,7 @@ PvaClientArrayPtr PvaClientChannel::createArray(string const & request) { PVStructurePtr pvRequest = createRequest->createRequest(request); if(!pvRequest) { - string message = string("channel ") + channelName + string message = string("channel ") + channelName + " PvaClientChannel::createArray invalid pvRequest: " + createRequest->getMessage(); throw std::runtime_error(message); @@ -541,7 +541,7 @@ PvaClientMonitorPtr PvaClientChannel::createMonitor(string const & request) { PVStructurePtr pvRequest = createRequest->createRequest(request); if(!pvRequest) { - string message = string("channel ") + channelName + string message = string("channel ") + channelName + " PvaClientChannel::createMonitor invalid pvRequest: " + createRequest->getMessage(); throw std::runtime_error(message); @@ -561,7 +561,7 @@ PVStructurePtr PvaClientChannel::rpc( PVStructurePtr const & pvRequest, PVStructurePtr const & pvArgument) { - + PvaClientRPCPtr rpc = createRPC(pvRequest); return rpc->request(pvArgument); } diff --git a/src/pvaClientData.cpp b/src/pvaClientData.cpp index 60de4eb..29d336f 100644 --- a/src/pvaClientData.cpp +++ b/src/pvaClientData.cpp @@ -363,7 +363,7 @@ void PvaClientData::parse(const std::vector &args) if(field.size()==std::string::npos) { parse(rest,pvStructure,bitSet); continue; - } + } PVFieldPtr pvField(pvStructure->getSubField(field)); if(!pvField) throw std::runtime_error(messagePrefix + field +" does not exist"); // look for enumerated structure @@ -428,7 +428,7 @@ const PVFieldPtrArray pvFields(pvStructure->getPVFields()); { PVStructurePtr pvStructure = static_pointer_cast(pvField); zeroArrayLength(pvStructure); - } + } break; default: break; diff --git a/src/pvaClientGet.cpp b/src/pvaClientGet.cpp index 0b7398d..81dc41c 100644 --- a/src/pvaClientGet.cpp +++ b/src/pvaClientGet.cpp @@ -55,7 +55,7 @@ public: { PvaClientGetPtr clientGet(pvaClientGet.lock()); if(!clientGet) return; - clientGet->channelGetConnect(status,channelGet,structure); + clientGet->channelGetConnect(status,channelGet,structure); } virtual void getDone( @@ -182,7 +182,7 @@ void PvaClientGet::channelGetConnect( req->channelGetConnect(status,shared_from_this()); } waitForConnect.signal(); - + } void PvaClientGet::getDone( diff --git a/src/pvaClientMonitor.cpp b/src/pvaClientMonitor.cpp index e253366..ef321c5 100644 --- a/src/pvaClientMonitor.cpp +++ b/src/pvaClientMonitor.cpp @@ -57,21 +57,21 @@ public: { PvaClientMonitorPtr clientMonitor(pvaClientMonitor.lock()); if(!clientMonitor) return; - clientMonitor->monitorConnect(status,monitor,structure); + clientMonitor->monitorConnect(status,monitor,structure); } virtual void unlisten(epics::pvData::MonitorPtr const & monitor) { PvaClientMonitorPtr clientMonitor(pvaClientMonitor.lock()); if(!clientMonitor) return; - clientMonitor->unlisten(monitor); + clientMonitor->unlisten(monitor); } virtual void monitorEvent(epics::pvData::MonitorPtr const & monitor) { PvaClientMonitorPtr clientMonitor(pvaClientMonitor.lock()); if(!clientMonitor) return; - clientMonitor->monitorEvent(monitor); + clientMonitor->monitorEvent(monitor); } }; @@ -131,7 +131,7 @@ PvaClientMonitor::PvaClientMonitor( { if(PvaClient::getDebug()) { cout<< "PvaClientMonitor::PvaClientMonitor\n" - << " channelName " << pvaClientChannel->getChannel()->getChannelName() + << " channelName " << pvaClientChannel->getChannel()->getChannelName() << endl; } } @@ -276,7 +276,7 @@ void PvaClientMonitor::monitorEvent(MonitorPtr const & monitor) cout << "PvaClientMonitor::monitorEvent" << " channelName " << pvaClientChannel->getChannel()->getChannelName() << endl; - } + } PvaClientMonitorRequesterPtr req = pvaClientMonitorRequester.lock(); if(req) req->event(shared_from_this()); if(userWait) waitForEvent.signal(); @@ -300,7 +300,7 @@ void PvaClientMonitor::connect() issueConnect(); Status status = waitConnect(); if(status.isOK()) return; - string message = string("channel ") + string message = string("channel ") + pvaClientChannel->getChannel()->getChannelName() + " PvaClientMonitor::connect " + status.getMessage(); diff --git a/src/pvaClientMultiChannel.cpp b/src/pvaClientMultiChannel.cpp index 932dc8a..5267bd1 100644 --- a/src/pvaClientMultiChannel.cpp +++ b/src/pvaClientMultiChannel.cpp @@ -80,7 +80,7 @@ Status PvaClientMultiChannel::connect(double timeout) Status status = Status::Ok; size_t numBad = 0; for(size_t i=0; i< numChannel; ++i) { - if(numBad==0) { + if(numBad==0) { status = pvaClientChannelArray[i]->waitConnect(timeout); } else { status = pvaClientChannelArray[i]->waitConnect(.001); @@ -140,7 +140,7 @@ PvaClientPtr PvaClientMultiChannel::getPvaClient() return pvaClient; } - + PvaClientMultiGetDoublePtr PvaClientMultiChannel::createGet() { diff --git a/src/pvaClientMultiGetDouble.cpp b/src/pvaClientMultiGetDouble.cpp index 3683363..4fe96b2 100644 --- a/src/pvaClientMultiGetDouble.cpp +++ b/src/pvaClientMultiGetDouble.cpp @@ -21,7 +21,7 @@ using namespace epics::pvAccess; using namespace epics::nt; using namespace std; -namespace epics { namespace pvaClient { +namespace epics { namespace pvaClient { PvaClientMultiGetDoublePtr PvaClientMultiGetDouble::create( @@ -79,7 +79,7 @@ epics::pvData::shared_vector PvaClientMultiGetDouble::get() { if(!isGetConnected) connect(); shared_vector isConnected = pvaClientMultiChannel->getIsConnected(); - + for(size_t i=0; i PvaClientMultiGetDouble::get() throw std::runtime_error(message); } } - + for(size_t i=0; igetSubField("field.timeStamp")) { gotTimeStamp = true; @@ -165,7 +165,7 @@ void PvaClientNTMultiData::endDeltaTime(bool valueOnly) userTag[i] = pvTag->get(); } } - } + } } } diff --git a/src/pvaClientNTMultiGet.cpp b/src/pvaClientNTMultiGet.cpp index 0790280..c9c36e6 100644 --- a/src/pvaClientNTMultiGet.cpp +++ b/src/pvaClientNTMultiGet.cpp @@ -20,7 +20,7 @@ using namespace epics::pvAccess; using namespace epics::nt; using namespace std; -namespace epics { namespace pvaClient { +namespace epics { namespace pvaClient { PvaClientNTMultiGetPtr PvaClientNTMultiGet::create( @@ -75,7 +75,7 @@ void PvaClientNTMultiGet::connect() if(isConnected[i]) { Status status = pvaClientGet[i]->waitConnect(); if(status.isOK()) continue; - string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + " PvaChannelGet::waitConnect " + status.getMessage(); throw std::runtime_error(message); } @@ -87,7 +87,7 @@ void PvaClientNTMultiGet::get(bool valueOnly) { if(!isConnected) connect(); shared_vector isConnected = pvaClientMultiChannel->getIsConnected(); - + for(size_t i=0; iwaitGet(); if(status.isOK()) continue; - string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + " PvaChannelGet::waitGet " + status.getMessage(); throw std::runtime_error(message); } diff --git a/src/pvaClientNTMultiMonitor.cpp b/src/pvaClientNTMultiMonitor.cpp index 8282f16..6758ec6 100644 --- a/src/pvaClientNTMultiMonitor.cpp +++ b/src/pvaClientNTMultiMonitor.cpp @@ -23,7 +23,7 @@ using namespace epics::pvAccess; using namespace epics::nt; using namespace std; -namespace epics { namespace pvaClient { +namespace epics { namespace pvaClient { PvaClientNTMultiMonitorPtr PvaClientNTMultiMonitor::create( PvaClientMultiChannelPtr const &pvaMultiChannel, @@ -79,7 +79,7 @@ void PvaClientNTMultiMonitor::connect() if(isConnected[i]) { Status status = pvaClientMonitor[i]->waitConnect(); if(status.isOK()) continue; - string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + " PvaChannelMonitor::waitConnect " + status.getMessage(); throw std::runtime_error(message); } diff --git a/src/pvaClientNTMultiPut.cpp b/src/pvaClientNTMultiPut.cpp index a965026..21d444b 100644 --- a/src/pvaClientNTMultiPut.cpp +++ b/src/pvaClientNTMultiPut.cpp @@ -22,7 +22,7 @@ using namespace epics::pvAccess; using namespace epics::nt; using namespace std; -namespace epics { namespace pvaClient { +namespace epics { namespace pvaClient { PvaClientNTMultiPutPtr PvaClientNTMultiPut::create( PvaClientMultiChannelPtr const &pvaMultiChannel, @@ -67,7 +67,7 @@ void PvaClientNTMultiPut::connect() if(isConnected[i]) { Status status = pvaClientPut[i]->waitConnect(); if(status.isOK()) continue; - string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + " PvaChannelPut::waitConnect " + status.getMessage(); throw std::runtime_error(message); } @@ -83,7 +83,7 @@ void PvaClientNTMultiPut::connect() if(isConnected[i]) { Status status = pvaClientPut[i]->waitGet(); if(status.isOK()) continue; - string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + " PvaChannelPut::waitGet " + status.getMessage(); throw std::runtime_error(message); } @@ -121,9 +121,9 @@ void PvaClientNTMultiPut::put() if(isConnected[i]) { Status status = pvaClientPut[i]->waitPut(); if(status.isOK()) continue; - string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + string message = string("channel ") +pvaClientChannelArray[i]->getChannelName() + " PvaChannelPut::waitPut " + status.getMessage(); - throw std::runtime_error(message); + throw std::runtime_error(message); } } } diff --git a/src/pvaClientProcess.cpp b/src/pvaClientProcess.cpp index 87412cf..59ec66f 100644 --- a/src/pvaClientProcess.cpp +++ b/src/pvaClientProcess.cpp @@ -54,7 +54,7 @@ public: { PvaClientProcessPtr clientProcess(pvaClientProcess.lock()); if(!clientProcess) return; - clientProcess->channelProcessConnect(status,channelProcess); + clientProcess->channelProcessConnect(status,channelProcess); } virtual void processDone( @@ -156,7 +156,7 @@ void PvaClientProcess::channelProcessConnect( req->channelProcessConnect(status,shared_from_this()); } waitForConnect.signal(); - + } void PvaClientProcess::processDone( @@ -174,7 +174,7 @@ void PvaClientProcess::processDone( channelProcessStatus = status; processState = processComplete; } - + PvaClientProcessRequesterPtr req(pvaClientProcessRequester.lock()); if(req) { req->processDone(status,shared_from_this()); diff --git a/src/pvaClientPut.cpp b/src/pvaClientPut.cpp index f046263..4e00e7a 100644 --- a/src/pvaClientPut.cpp +++ b/src/pvaClientPut.cpp @@ -55,7 +55,7 @@ public: { PvaClientPutPtr clientPut(pvaClientPut.lock()); if(!clientPut) return; - clientPut->channelPutConnect(status,channelPut,structure); + clientPut->channelPutConnect(status,channelPut,structure); } virtual void getDone( @@ -183,7 +183,7 @@ void PvaClientPut::channelPutConnect( req->channelPutConnect(status,shared_from_this()); } waitForConnect.signal(); - + } void PvaClientPut::getDone( @@ -249,7 +249,7 @@ void PvaClientPut::connect() issueConnect(); Status status = waitConnect(); if(status.isOK()) return; - string message = string("channel ") + string message = string("channel ") + pvaClientChannel->getChannel()->getChannelName() + " PvaClientPut::connect " + status.getMessage(); @@ -271,7 +271,7 @@ void PvaClientPut::issueConnect() connectState = connectActive; channelPutConnectStatus = Status(Status::STATUSTYPE_ERROR, "connect active"); channelPut = pvaClientChannel->getChannel()->createChannelPut(channelPutRequester,pvRequest); - + } Status PvaClientPut::waitConnect() @@ -308,7 +308,7 @@ void PvaClientPut::get() issueGet(); Status status = waitGet(); if(status.isOK()) return; - string message = string("channel ") + string message = string("channel ") + pvaClientChannel->getChannel()->getChannelName() + " PvaClientPut::get " + status.getMessage(); @@ -376,7 +376,7 @@ void PvaClientPut::issuePut() if(PvaClient::getDebug()) { cout << "PvaClientPut::issuePut" << " channelName " << pvaClientChannel->getChannel()->getChannelName() - << " pvStructure\n" << pvaClientData->getPVStructure() + << " pvStructure\n" << pvaClientData->getPVStructure() << " bitSet " << *pvaClientData->getChangedBitSet() << endl << endl; } diff --git a/src/pvaClientPutGet.cpp b/src/pvaClientPutGet.cpp index a370c07..0bffd17 100644 --- a/src/pvaClientPutGet.cpp +++ b/src/pvaClientPutGet.cpp @@ -55,7 +55,7 @@ public: { PvaClientPutGetPtr clientPutGet(pvaClientPutGet.lock()); if(!clientPutGet) return; - clientPutGet->channelPutGetConnect(status,channelPutGet,putStructure,getStructure); + clientPutGet->channelPutGetConnect(status,channelPutGet,putStructure,getStructure); } virtual void putGetDone( @@ -173,7 +173,7 @@ void PvaClientPutGet::channelPutGetConnect( << " channelName " << pvaClientChannel->getChannel()->getChannelName() << " status.isOK " << (status.isOK() ? "true" : "false") << endl; - } + } { Lock xx(mutex); this->channelPutGet = channelPutGet; @@ -184,7 +184,7 @@ void PvaClientPutGet::channelPutGetConnect( pvaClientPutData->setMessagePrefix(channelPutGet->getChannel()->getChannelName()); pvaClientGetData = PvaClientGetData::create(getStructure); pvaClientGetData->setMessagePrefix(channelPutGet->getChannel()->getChannelName()); - + } else { stringstream ss; ss << pvRequest; @@ -199,7 +199,7 @@ void PvaClientPutGet::channelPutGetConnect( req->channelPutGetConnect(status,shared_from_this()); } waitForConnect.signal(); - + } void PvaClientPutGet::putGetDone( @@ -297,7 +297,7 @@ void PvaClientPutGet::connect() issueConnect(); Status status = waitConnect(); if(status.isOK()) return; - string message = string("channel ") + string message = string("channel ") + pvaClientChannel->getChannel()->getChannelName() + " PvaClientPutGet::connect " + status.getMessage(); @@ -358,7 +358,7 @@ void PvaClientPutGet::putGet() issuePutGet(); Status status = waitPutGet(); if(status.isOK()) return; - string message = string("channel ") + string message = string("channel ") + pvaClientChannel->getChannel()->getChannelName() + " PvaClientPut::putGet " + status.getMessage(); @@ -413,7 +413,7 @@ void PvaClientPutGet::getGet() issueGetGet(); Status status = waitGetGet(); if(status.isOK()) return; - string message = string("channel ") + string message = string("channel ") + pvaClientChannel->getChannel()->getChannelName() + " PvaClientPut::getGet " + status.getMessage(); @@ -466,7 +466,7 @@ void PvaClientPutGet::getPut() issueGetPut(); Status status = waitGetPut(); if(status.isOK()) return; - string message = string("channel ") + string message = string("channel ") + pvaClientChannel->getChannel()->getChannelName() + " PvaClientPut::getPut " + status.getMessage(); diff --git a/src/pvaClientRPC.cpp b/src/pvaClientRPC.cpp index 678dfc9..9b95551 100644 --- a/src/pvaClientRPC.cpp +++ b/src/pvaClientRPC.cpp @@ -94,7 +94,7 @@ PvaClientRPC::PvaClientRPC( PvaClientPtr const &pvaClient, Channel::shared_pointer const & channel, PVStructurePtr const &pvRequest) -: +: connectState(connectIdle), pvaClient(pvaClient), channel(channel), @@ -104,7 +104,7 @@ PvaClientRPC::PvaClientRPC( { if(PvaClient::getDebug()) { cout<< "PvaClientRPC::PvaClientRPC()" - << " channelName " << channel->getChannelName() + << " channelName " << channel->getChannelName() << endl; } } @@ -170,7 +170,7 @@ void PvaClientRPC::rpcConnect( cout << "PvaClientRPC::rpcConnect calling waitForConnect.signal\n"; } waitForConnect.signal(); - + } void PvaClientRPC::requestDone( @@ -195,7 +195,7 @@ void PvaClientRPC::requestDone( Channel::shared_pointer chan(channel.lock()); if(chan) channelName = chan->getChannelName(); string message = "channel " - + channelName + + channelName +" PvaClientRPC::requestDone" + " but not active"; throw std::runtime_error(message); @@ -222,7 +222,7 @@ void PvaClientRPC::connect() Channel::shared_pointer chan(channel.lock()); string channelName("disconnected"); if(chan) channelName = chan->getChannelName(); - string message = string("channel ") + string message = string("channel ") + channelName + " PvaClientRPC::connect " + status.getMessage(); @@ -237,7 +237,7 @@ void PvaClientRPC::issueConnect() string channelName("disconnected"); if(chan) channelName = chan->getChannelName(); string message = string("channel ") - + channelName + + channelName + " pvaClientRPC already connected "; throw std::runtime_error(message); } @@ -326,7 +326,7 @@ void PvaClientRPC::request( PVStructure::shared_pointer const & pvArgument, PvaClientRPCRequesterPtr const & pvaClientRPCRequester) { - checkRPCState(); + checkRPCState(); this->pvaClientRPCRequester = pvaClientRPCRequester; if(responseTimeout<=0.0) { {