done = 1;
buffer_lock->unlock();
Thread::cancel();
done = 1;
buffer_lock->unlock();
Thread::cancel();
delete buffer_lock;
delete putq;
}
delete buffer_lock;
delete putq;
}
{
done = 1;
Thread::cancel();
{
done = 1;
Thread::cancel();
if(put_thread)
{
delete put_thread;
if(put_thread)
{
delete put_thread;