Revision c98457ae src/raft/ReplicaManager.cc

View differences:

src/raft/ReplicaManager.cc
59 59
    for ( it = thread_pool.begin() ; it != thread_pool.end() ; ++it )
60 60
    {
61 61
        it->second->finalize();
62

  
63
        pthread_cancel(it->second->thread_id());
64

  
65
        delete it->second;
66 62
    }
67 63

  
68 64
    thread_pool.clear();
......
110 106

  
111 107
    it->second->finalize();
112 108

  
113
    NebulaLog::log("RCM", Log::INFO, "Replication thread stopped");
114

  
115
    delete it->second;
116

  
117 109
    thread_pool.erase(it);
118 110
};
119 111

  

Also available in: Unified diff