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

ServerContextImpl::destroyAllTransports()

Browse Source 
Better check for ref. leaks
This commit is contained in:
Michael Davidsaver
2017-05-31 15:58:15 +02:00
parent 3fa6a4e4cc
commit 8971d2771c
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/server/serverContext.cpp
View File

@@ -282,27 +282,21 @@ void ServerContextImpl::shutdown()
void ServerContextImpl::destroyAllTransports()
{
TransportRegistry::transportVector_t transports;
_transportRegistry.toArray(transports);
std::auto_ptr<TransportRegistry::transportVector_t> transports = _transportRegistry.toArray();
if (transports.get() == 0)
return;
int size = (int)transports->size();
size_t size = transports.size();
if (size == 0)
return;
LOG(logLevelInfo, "Server context still has %d transport(s) active and closing...", size);
for (int i = 0; i < size; i++)
for (size_t i = 0; i < size; i++)
{
Transport::shared_pointer transport = (*transports)[i];
const Transport::shared_pointer& transport = transports[i];
try
{
transport->close();
if(!transport.unique())
LOG(logLevelError, "Closed transport %s still has use_count=%u",
transport->getRemoteName().c_str(),
(unsigned)transport.use_count());
}
catch (std::exception &e)
{
@@ -319,6 +313,14 @@ void ServerContextImpl::destroyAllTransports()
// now clear all (release)
_transportRegistry.clear();
for (size_t i = 0; i < size; i++)
{
const Transport::shared_pointer& transport = transports[i];
if(!transport.unique())
LOG(logLevelError, "Closed transport %s still has use_count=%u",
transport->getRemoteName().c_str(),
(unsigned)transport.use_count());
}
}
void ServerContext::printInfo()