src/cpp/rtps/participant/RTPSParticipantImpl.cpp
void RTPSParticipantImpl::disableReader(RTPSReader *reader)
{
    m_receiverResourcelistMutex.lock();
    for (auto it = m_receiverResourcelist.begin(); it != m_receiverResourcelist.end(); ++it)
    {
        it->mp_receiver->removeEndpoint(reader);
    }
    m_receiverResourcelistMutex.unlock();
}
// Avoid to receive PDPSimple reader a DATA while calling ~PDPSimple and EDP was destroy already.
Avoid to receive PDPSimple reader a DATA while calling ~PDPSimple and EDP was destroy already.
Avoid to receive PDPSimple reader a DATA while calling ~PDPSimple and EDP was destroy already .
void RTPSParticipantImpl::disableReader(RTPSReader *reader)
{
    m_receiverResourcelistMutex.lock();
    for (auto it = m_receiverResourcelist.begin(); it != m_receiverResourcelist.end(); ++it)
    {
        it->mp_receiver->removeEndpoint(reader);
    }
    m_receiverResourcelistMutex.unlock();
}
void RTPSParticipantImpl :: disableReader ( RTPSReader * reader ) { m_receiverResourcelistMutex . lock ( ) ; for ( auto it = m_receiverResourcelist . begin ( ) ; it != m_receiverResourcelist . end ( ) ; ++ it ) { it -> mp_receiver -> removeEndpoint ( reader ) ; } m_receiverResourcelistMutex . unlock ( ) ; }
Avoid to receive PDPSimple reader a DATA while calling ~PDPSimple and EDP was destroy already.
Avoid to receive PDPSimple reader a DATA while calling ~PDPSimple and EDP was destroy already .