static void
destroy_reader (struct reader_context_s *c)
{
- LOCK (c->mutex)
+ LOCK (c->mutex);
c->stop_me = 1;
if (c->have_space_ev)
SetEvent (c->have_space_ev);
- UNLOCK (c->mutex)
+ UNLOCK (c->mutex);
DEBUG1 ("waiting for thread %p termination ...", c->thread_hd );
WaitForSingleObject (c->stopped, INFINITE);
static void
destroy_writer (struct writer_context_s *c)
{
- LOCK (c->mutex)
+ LOCK (c->mutex);
c->stop_me = 1;
if (c->have_data)
SetEvent (c->have_data);
- UNLOCK (c->mutex)
+ UNLOCK (c->mutex);
DEBUG1 ("waiting for thread %p termination ...", c->thread_hd );
WaitForSingleObject (c->stopped, INFINITE);