This commit is contained in:
2020-04-17 17:24:01 +02:00

View File

@ -64,9 +64,11 @@ Listener::Listener(int ind, detectorType dtype, Fifo*& f, runStatus* s,
Listener::~Listener() { Listener::~Listener() {
if (udpSocket) delete udpSocket; if (udpSocket) {
sem_post(&semaphore_socket); delete udpSocket;
sem_destroy(&semaphore_socket); sem_post(&semaphore_socket);
sem_destroy(&semaphore_socket);
}
if (carryOverPacket) delete [] carryOverPacket; if (carryOverPacket) delete [] carryOverPacket;
if (listeningPacket) delete [] listeningPacket; if (listeningPacket) delete [] listeningPacket;
ThreadObject::DestroyThread(); ThreadObject::DestroyThread();
@ -228,7 +230,9 @@ void Listener::ShutDownUDPSocket() {
FILE_LOG(logINFO) << "Shut down of UDP port " << *udpPortNumber; FILE_LOG(logINFO) << "Shut down of UDP port " << *udpPortNumber;
fflush(stdout); fflush(stdout);
//delete socket at stoplistening //delete socket at stoplistening
sem_wait(&semaphore_socket); if (runningFlag) {
sem_wait(&semaphore_socket);
}
delete udpSocket; delete udpSocket;
udpSocket = 0; udpSocket = 0;
sem_destroy(&semaphore_socket); sem_destroy(&semaphore_socket);