+ */\r
+ /*\r
+ for(std::vector<PThread::Thread *>::iterator i=m_connectionthreads.begin(); i!=m_connectionthreads.end(); i++)\r
+ {\r
+ if((*i)->IsRunning())\r
+ {\r
+ LogFile::Instance()->WriteLog(LogFile::LOGLEVEL_DEBUG,"NNTPListener::Run waiting for connection thread to exit.");\r
+ (*i)->Cancel();\r
+ (*i)->Join();\r
+ }\r
+ delete (*i);\r
+ }\r
+ */\r
+ m_connections.Cancel();\r
+ m_connections.Join();\r
+\r
+ for(listeni=m_listensockets.begin(); listeni!=m_listensockets.end(); listeni++)\r
+ {\r
+ #ifdef _WIN32\r
+ closesocket((*listeni));\r
+ #else\r
+ close((*listeni));\r
+ #endif\r
+ }\r
+ m_listensockets.clear();\r
+\r
+ LogFile::Instance()->WriteLog(LogFile::LOGLEVEL_DEBUG,"NNTPListener::run thread exiting.");\r