Fixed syntax error
This commit is contained in:
parent
ca12983e7c
commit
10b3a86f83
@ -269,11 +269,11 @@ create_reader (HANDLE fd)
|
|||||||
static void
|
static void
|
||||||
destroy_reader (struct reader_context_s *c)
|
destroy_reader (struct reader_context_s *c)
|
||||||
{
|
{
|
||||||
LOCK (c->mutex)
|
LOCK (c->mutex);
|
||||||
c->stop_me = 1;
|
c->stop_me = 1;
|
||||||
if (c->have_space_ev)
|
if (c->have_space_ev)
|
||||||
SetEvent (c->have_space_ev);
|
SetEvent (c->have_space_ev);
|
||||||
UNLOCK (c->mutex)
|
UNLOCK (c->mutex);
|
||||||
|
|
||||||
DEBUG1 ("waiting for thread %p termination ...", c->thread_hd );
|
DEBUG1 ("waiting for thread %p termination ...", c->thread_hd );
|
||||||
WaitForSingleObject (c->stopped, INFINITE);
|
WaitForSingleObject (c->stopped, INFINITE);
|
||||||
@ -522,11 +522,11 @@ create_writer (HANDLE fd)
|
|||||||
static void
|
static void
|
||||||
destroy_writer (struct writer_context_s *c)
|
destroy_writer (struct writer_context_s *c)
|
||||||
{
|
{
|
||||||
LOCK (c->mutex)
|
LOCK (c->mutex);
|
||||||
c->stop_me = 1;
|
c->stop_me = 1;
|
||||||
if (c->have_data)
|
if (c->have_data)
|
||||||
SetEvent (c->have_data);
|
SetEvent (c->have_data);
|
||||||
UNLOCK (c->mutex)
|
UNLOCK (c->mutex);
|
||||||
|
|
||||||
DEBUG1 ("waiting for thread %p termination ...", c->thread_hd );
|
DEBUG1 ("waiting for thread %p termination ...", c->thread_hd );
|
||||||
WaitForSingleObject (c->stopped, INFINITE);
|
WaitForSingleObject (c->stopped, INFINITE);
|
||||||
|
Loading…
Reference in New Issue
Block a user