epics/pvAccess
0
0
Fork 0
Code Issues Pull Requests Projects Wiki Activity

request resubscription threading issue fix

Browse Source
This commit is contained in:
Matej Sekoranja
2012-09-05 09:34:19 +02:00
parent a1c1d27d4f
commit c798ccaa3e
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
pvAccessApp/remoteClient/clientContextImpl.cpp
View File

@@ -126,6 +126,8 @@ namespace epics {
bool m_destroyed;
bool m_initialized;
AtomicBoolean m_subscribed;
virtual ~BaseRequestImpl() {};
BaseRequestImpl(ChannelImpl::shared_pointer const & channel, Requester::shared_pointer const & requester) :
@@ -134,7 +136,8 @@ namespace epics {
m_ioid(INVALID_IOID),
m_pendingRequest(NULL_REQUEST),
m_destroyed(false),
m_initialized(false)
m_initialized(false),
m_subscribed()
{
}
@@ -277,13 +280,19 @@ namespace epics {
if (&status == &ChannelImpl::channelDestroyed)
destroy();
else if (&status == &ChannelImpl::channelDisconnected)
{
m_subscribed.clear();
stopRequest();
}
// TODO notify?
}
virtual void resubscribeSubscription(Transport::shared_pointer const & transport) {
if (transport.get() != 0 && startRequest(QOS_INIT))
if (transport.get() != 0 && !m_subscribed.get() && startRequest(QOS_INIT))
{
m_subscribed.set();
transport->enqueueSendRequest(shared_from_this());
}
}
virtual void updateSubscription() {