Cygwin: FIFO: update clone and dup
Deal with all clients.
This commit is contained in:
parent
c6e221c036
commit
035bf7dc84
@ -1309,9 +1309,11 @@ public:
|
|||||||
fhandler_fifo *clone (cygheap_types malloc_type = HEAP_FHANDLER)
|
fhandler_fifo *clone (cygheap_types malloc_type = HEAP_FHANDLER)
|
||||||
{
|
{
|
||||||
void *ptr = (void *) ccalloc (malloc_type, 1, sizeof (fhandler_fifo));
|
void *ptr = (void *) ccalloc (malloc_type, 1, sizeof (fhandler_fifo));
|
||||||
fhandler_fifo *fh = new (ptr) fhandler_fifo (ptr);
|
fhandler_fifo *fhf = new (ptr) fhandler_fifo (ptr);
|
||||||
copyto (fh);
|
copyto (fhf);
|
||||||
return fh;
|
for (int i = 0; i < nclients; i++)
|
||||||
|
fhf->client[i].fh = client[i].fh->fhandler_base::clone ();
|
||||||
|
return fhf;
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@ -816,6 +816,31 @@ fhandler_fifo::dup (fhandler_base *child, int flags)
|
|||||||
__seterrno ();
|
__seterrno ();
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
for (int i = 0; i < nclients; i++)
|
||||||
|
{
|
||||||
|
if (!DuplicateHandle (GetCurrentProcess (), client[i].fh->get_handle (),
|
||||||
|
GetCurrentProcess (),
|
||||||
|
&fhf->client[i].fh->get_handle (),
|
||||||
|
0, true, DUPLICATE_SAME_ACCESS)
|
||||||
|
|| !DuplicateHandle (GetCurrentProcess (), client[i].connect_evt,
|
||||||
|
GetCurrentProcess (),
|
||||||
|
&fhf->client[i].connect_evt,
|
||||||
|
0, true, DUPLICATE_SAME_ACCESS)
|
||||||
|
|| !DuplicateHandle (GetCurrentProcess (), client[i].dummy_evt,
|
||||||
|
GetCurrentProcess (),
|
||||||
|
&fhf->client[i].dummy_evt,
|
||||||
|
0, true, DUPLICATE_SAME_ACCESS))
|
||||||
|
{
|
||||||
|
CloseHandle (fhf->read_ready);
|
||||||
|
CloseHandle (fhf->write_ready);
|
||||||
|
fhf->close ();
|
||||||
|
__seterrno ();
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
fhf->listen_client_thr = NULL;
|
||||||
|
fhf->lct_termination_evt = NULL;
|
||||||
|
fhf->fifo_client_unlock ();
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user