2000-02-18 03:38:33 +08:00
|
|
|
/* fork.cc
|
|
|
|
|
2004-01-04 02:53:49 +08:00
|
|
|
Copyright 1996, 1997, 1998, 1999, 2000, 2001, 2002, 2004 Red Hat, Inc.
|
2000-02-18 03:38:33 +08:00
|
|
|
|
|
|
|
This file is part of Cygwin.
|
|
|
|
|
|
|
|
This software is a copyrighted work licensed under the terms of the
|
|
|
|
Cygwin license. Please consult the file "CYGWIN_LICENSE" for
|
|
|
|
details. */
|
|
|
|
|
2000-08-03 00:28:18 +08:00
|
|
|
#include "winsup.h"
|
2000-02-18 03:38:33 +08:00
|
|
|
#include <stdio.h>
|
|
|
|
#include <unistd.h>
|
|
|
|
#include <stdlib.h>
|
|
|
|
#include <stdarg.h>
|
2001-07-27 03:22:24 +08:00
|
|
|
#include "security.h"
|
2001-10-01 12:10:07 +08:00
|
|
|
#include "path.h"
|
* devices.cc: New file.
* devices.gperf: New file.
* devices.shilka: New file.
* cygwin-gperf: New file.
* cygwin-shilka: New file.
* fhandler_fifo.cc: New file.
* fhandler_nodevice.cc : New file. Reorganize headers so that path.h precedes
fhandler.h throughout. Remove device argument and unit arguments from fhandler
constructors throughout. Remove pc arguments to fhandler functions and use
internal pc element instead, throughout. Use dev element in pc throughout.
Use major/minor elements rather than units and device numbers previously in
fhandler class. Use correct methods for fhandler file names rather than
directly accessing file name variables, throughout.
* Makefile.in (DLL_OFILES): Add devices.o, fhandler_fifo.o
* dcrt0.cc (dll_crt0_1): Call device::init.
* devices.h: Renumber devices based on more Linux-like major/minor numbers.
Add more devices. Declare standard device storage.
(device): Declare struct.
* dir.cc (opendir): Use new 'build_fh_name' to construct a fhandler_* type.
* dtable.cc (dtable::get_debugger_info): Ditto.
(cygwin_attach_handle_to_fd): Ditto.
(dtable::release): Remove special FH_SOCKET case in favor of generic
"need_fixup_before" test.
(dtable::init_std_file_from_handle): Use either build_fh_dev or build_fh_name
to build standard fhandler.
(dtable::build_fh_name): Renamed from dtable::build_fhandler_from_name. Move
out of dtable class. Don't accept a path_conv argument. Just build it here
and pass it to:
(build_fh_pc): Renamed from dtable::build_fhandler. Move out of dtable class.
Use intrinsic device type in path_conv to create new fhandler.
(build_fh_dev): Renamed from dtable::build_fhandler. Move out of dtable class.
Simplify arguments to just take new 'device' type and a name. Just return
pointer to fhandler rather than trying to insert into dtable.
(dtable::dup_worker): Accommodate above build_fh name changes.
(dtable::find_fifo): New (currently broken) function.
(handle_to_fn): Use strechr for efficiency.
* dtable.h: Reflect above build_fh name changes and argument differences.
(fhandler_base *&operator []): Return self rather than copy of self.
* fhandler.cc (fhandler_base::operator =): Use pc element to set normalized
path.
(fhandler_base::set_name): Ditto.
(fhandler_base::raw_read): Use method to access name.
(fhandler_base::write): Correctly use get_output_handle rather than get_handle.
(handler_base::device_access_denied): New function.
(fhandler_base::open): Eliminate pc argument and use pc element of
fhandler_base throughout.
(fhandler_base::fstat): Detect if device is based in filesystem and use
fstat_fs to calculate stat, if so.
(fhandler_base::fhandler_base): Eliminate handling of file names and, instead,
just free appropriate component from pc.
(fhandler_base::opendir): Remove path_conv parameter.
* fhandler.h: Remove all device flags.
(fhandler_base::pc): New element.
(fhandler_base::set_name): Change argument to path_conv.
(fhandler_base::error): New function.
(fhandler_base::exists): New function.
(fhandler_base::pc_binmode): New function.
(fhandler_base::dev): New function.
(fhandler_base::open_fs): New function.
(fhandler_base::fstat_fs): New function.
(fhandler_base::fstat_by_name): New function.
(fhandler_base::fstat_by_handle): New function.
(fhandler_base::isfifo): New function.
(fhandler_base::is_slow): New function.
(fhandler_base::is_auto_device): New function.
(fhandler_base::is_fs_special): New function.
(fhandler_base::device_access_denied): New function.
(fhandler_base::operator DWORD&): New operator.
(fhandler_base::get_name): Return normalized path from pc.
(fhandler_base::get_win32_name): Return windows path from pc.
(fhandler_base::isdevice): Renamed from is_device.
(fhandler_base::get_native_name): Return device format.
(fhandler_fifo): New class.
(fhandler_nodevice): New class.
(select_stuff::device_specific): Remove array.
(select_stuff::device_specific_pipe): New class element.
(select_stuff::device_specific_socket): New class element.
(select_stuff::device_specific_serial): New class element.
(select_stuff::select_stuff): Initialize new elements.
* fhandler_disk_file.cc (fhandler_base::fstat_by_handle): Move to base class
from fhandler_disk_file.
(fhandler_base::fstat_by_name): Ditto.
(fhandler_base::fstat_by_name): Ditto.
(fhandler_disk_file::open): Move most functionality into
fhandler_base::open_fs.
(fhandler_base::open_fs): New function.
(fhandler_disk_file::close): Move most functionality into
fhandler_base::close_fs.
(fhandler_base::close_fs): New function.
* fhandler_mem.cc (fhandler_dev_mem::open): Use device name in debugging
output.
* fhandler_socket.cc (fhandler_socket::set_connect_secret): Copy standard
urandom device into appropriate place.
(fhandler_socket::accept): Reflect change in fdsock return value.
* fhandler_tty.cc: See "throughouts" above.
* net.cc: Accommodate fdsock change throughout.
(fdsock): Return success or failure, accept fd argument and device argument.
* path.cc (symlink_info::major): New element.
(symlink_info::minor): New element.
(symlink_info::parse_device): Declare new function.
(fs_info::update): Accommodate changes in path_conv class.
(path_conv::fillin): Ditto.
(path_conv::return_and_clear_normalized_path): Eliminate.
(path_conv::set_normalized_path): New function.
(path_conv::path_conv): Set info in dev element. Use path_conv methods Check
for FH_FS rather than FH_BAD to indicate when to fill in filesystem stuff.
where appropriate rather than direct access. Use set_normalized_path to set
normalized path.
(windows_device_names): Eliminate.
(get_dev): Ditto.
(get_raw_device_number): Ditto.
(get_device_number): Ditto.
(win32_device_name): Call new device name parser to do most of the heavy
lifting.
(mount_info::conv_to_win32_path): Fill in dev field as appropriate.
(symlink_worker): Handle new device files.
(symlink_info::check): Ditto.
(symlink_info::parse_device): Define new function.
* path.h (executable_states): Move here from fhandler.h.
(fs_info): Rename variables to *_storage and create methods for accessing same.
(path_conv): Add dev element, remove devn and unit and adjust inline methods to
accommodate.
(set_normalized_path): Declare new function.
* pinfo.cc (_pinfo::commune_recv): Add broken support for handling fifos.
(_pinfo::commune_send): Ditto.
* pipe.cc (fhandler_pipe::close): check for existence of handle before closing
it.
(handler_pipe::create): Rename from make_pipe. Change arguments to accept
fhandler_pipe array. Accommodate fifos.
(pipe): Rework to deal with fhandler_pipe::create changes.
(_pipe): Ditto.
* select.cc: Use individual device_specific types throughout rather than
indexing with obsolete device number.
(set_bits): Use is_socket call rather than checking device number.
* shared_info.h (CURR_MOUNT_MAGIC): Update.
(conv_to_win32_path): Reflect addition of device argument.
* syscalls.cc (mknod_worker): New function.
(open): Use build_fh_name to build fhandler.
(chown_worker): Detect if this is an 'auto' device rather than an on-filesystem
device and handle appropriately.
(chmod_device): New function.
(chmod): Detect if this is an 'auto' device rather than an on-filesystem device
and handle appropriately. Use chmod_device to set mode of in-filesystem
devices.
(stat_worker): Eliminate path_conv argument. Call build_fh_name to construct
fhandler. Use fh->error() rather than pc->error to detect errors in fhandler
construction.
(access_worker): New function pulled from access. Accommodate in-filesystem
devices.
(access): Use access_worker.
(fpathconf): Detect if this is an 'auto' device rather than an on-filesystem
device and handle appropriately.
(mknod_worker): New function.
(mknod32): New function.
(chroot): Free normalized path -- assuming it was actually cmalloced.
* tty.cc (create_tty_master): Tweak for new device class.
(tty::common_init): Ditto.
* winsup.h (stat_worker): Remove.
(symlink_worker): Declare.
* exceptions.cc (set_process_mask): Just call sig_dispatch_pending and don't
worry about pending_signals since sig_dispatch_pending should always do the
right thing now.
(sig_handle): Reorganize SIGCONT handling to more closely conform to SUSv3.
* pinfo.h: Move __SIG enum to sigproc.h.
(PICOM_FIFO): New enum element.
(_pinfo): Remove 'thread2signal' stuff throughout class.
(_pinfo::commune_send): Make varargs.
(_pinfo::sigtodo): Eliminate.
(_pinfo::thread2signal): Ditto.
* signal.cc (kill_worker): Eliminate call to setthread2signal.
* sigproc.cc (local_sigtodo): Eliminate.
(getlocal_sigtodo): Ditto.
(sigelem): New class.
(pending_signals): New class.
(sigqueue): New variable, start of sigqueue linked list.
(sigcatch_nonmain): Eliminate.
(sigcatch_main): Eliminate.
(sigcatch_nosync): Eliminate.
(sigcomplete_nonmain): Eliminate.
(pending_signals): Eliminate.
(sig_clear): Call signal thread to clear pending signals, unless already in
signal thread.
(sigpending): Call signal thread to get pending signals.
(sig_dispatch_pending): Eliminate use of pending_signals and just check
sigqueue.
(sigproc_terminate): Eliminate all of the obsolete semaphore stuff. Close
signal pipe handle.
(sig_send): Eliminate all of the obsolete semaphore stuff and use pipe to send
signals.
(getevent): Eliminate.
(pending_signals::add): New function.
(pending_signals::del): New function.
(pending_signals::next): New function.
(wait_sig): Eliminate all of the obsolete semaphore stuff. Use pipe to
communicate and maintain a linked list of signals.
* sigproc.h: Move __SIG defines here. Add __SIGPENDING.
(sig_dispatch_pending): Remove "C" specifier.
(sig_handle): Accept a mask argument.
* thread.cc: Remove signal handling considerations throughout.
2003-09-25 08:37:18 +08:00
|
|
|
#include "fhandler.h"
|
2000-08-12 13:35:42 +08:00
|
|
|
#include "dtable.h"
|
2000-08-22 11:58:47 +08:00
|
|
|
#include "cygerrno.h"
|
2000-08-22 13:10:20 +08:00
|
|
|
#include "sigproc.h"
|
|
|
|
#include "pinfo.h"
|
2000-09-03 12:16:35 +08:00
|
|
|
#include "cygheap.h"
|
2000-09-02 04:54:22 +08:00
|
|
|
#include "child_info.h"
|
2000-09-08 10:56:55 +08:00
|
|
|
#define NEED_VFORK
|
2000-08-22 13:10:20 +08:00
|
|
|
#include "perthread.h"
|
2000-09-08 10:56:55 +08:00
|
|
|
#include "perprocess.h"
|
|
|
|
#include "dll_init.h"
|
2002-08-17 03:41:39 +08:00
|
|
|
#include "sync.h"
|
2002-10-15 04:25:52 +08:00
|
|
|
#include "shared_info.h"
|
2002-08-17 03:41:39 +08:00
|
|
|
#include "cygmalloc.h"
|
2002-10-19 08:57:06 +08:00
|
|
|
#include "cygthread.h"
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-11-15 14:27:48 +08:00
|
|
|
#ifdef DEBUGGING
|
2001-09-06 12:41:59 +08:00
|
|
|
static int npid;
|
|
|
|
static int npid_max;
|
|
|
|
static pid_t fork_pids[100];
|
2000-11-15 14:27:48 +08:00
|
|
|
#endif
|
|
|
|
|
2000-02-18 03:38:33 +08:00
|
|
|
/* Timeout to wait for child to start, parent to init child, etc. */
|
|
|
|
/* FIXME: Once things stabilize, bump up to a few minutes. */
|
|
|
|
#define FORK_WAIT_TIMEOUT (300 * 1000) /* 300 seconds */
|
|
|
|
|
|
|
|
#define dll_data_start &_data_start__
|
|
|
|
#define dll_data_end &_data_end__
|
|
|
|
#define dll_bss_start &_bss_start__
|
|
|
|
#define dll_bss_end &_bss_end__
|
|
|
|
|
|
|
|
void
|
|
|
|
per_thread::set (void *s)
|
2000-09-03 12:16:35 +08:00
|
|
|
{
|
|
|
|
if (s == PER_THREAD_FORK_CLEAR)
|
|
|
|
{
|
|
|
|
tls = TlsAlloc ();
|
|
|
|
s = NULL;
|
|
|
|
}
|
|
|
|
TlsSetValue (get_tls (), s);
|
|
|
|
}
|
2000-02-18 03:38:33 +08:00
|
|
|
|
|
|
|
static void
|
|
|
|
stack_base (child_info_fork &ch)
|
|
|
|
{
|
|
|
|
MEMORY_BASIC_INFORMATION m;
|
|
|
|
memset (&m, 0, sizeof m);
|
|
|
|
if (!VirtualQuery ((LPCVOID) &m, &m, sizeof m))
|
|
|
|
system_printf ("couldn't get memory info, %E");
|
|
|
|
|
|
|
|
ch.stacktop = m.AllocationBase;
|
|
|
|
ch.stackbottom = (LPBYTE) m.BaseAddress + m.RegionSize;
|
|
|
|
ch.stacksize = (DWORD) ch.stackbottom - (DWORD) &m;
|
|
|
|
debug_printf ("bottom %p, top %p, stack %p, size %d, reserve %d",
|
|
|
|
ch.stackbottom, ch.stacktop, &m, ch.stacksize,
|
|
|
|
(DWORD) ch.stackbottom - (DWORD) ch.stacktop);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Copy memory from parent to child.
|
|
|
|
The result is a boolean indicating success. */
|
|
|
|
|
|
|
|
static int
|
|
|
|
fork_copy (PROCESS_INFORMATION &pi, const char *what, ...)
|
|
|
|
{
|
|
|
|
va_list args;
|
|
|
|
char *low;
|
|
|
|
int pass = 0;
|
|
|
|
|
|
|
|
va_start (args, what);
|
|
|
|
|
|
|
|
while ((low = va_arg (args, char *)))
|
|
|
|
{
|
|
|
|
char *high = va_arg (args, char *);
|
* Makefile.in: Build wincap.o.
* wincap.cc: New file.
* wincap.h: Ditto.
* autoload.cc: Add dynamic load statement for `CreateHardLinkA'.
* dcrt0.cc (os_being_run): Eliminated.
(osname): Ditto.
(iswinnt): Ditto.
(set_os_type): Ditto.
(dll_crt0_1): Call wincap.init() instead of set_os_type().
(_dll_crt0): Ditto.
* environ.cc (set_chunksize): New function.
(parse_thing): `forkchunk' setting now invokes function `set_chunksize'.
* fork.cc (chunksize): Eliminated. Moved to be member of wincap.
* host_dependent.h: Removed.
* syscalls.cc (_link): Try using `CreateHardLinkA' first, if available.
* cygheap.cc, dcrt0.cc, delqueue.cc, dir.cc,
environ.cc, fhandler.cc, fhandler.h, fhandler_console.cc,
fhandler_mem.cc, fork.cc, mmap.cc, net.cc, pinfo.cc, pinfo.h,
security.cc, syscalls.cc, sysconf.cc, syslog.cc, thread.cc,
times.cc, tty.cc, uinfo.cc, uname.cc, winsup.h: Use new wincap
capability check throughout.
* winsup.h: Include wincap.h. Eliminate extern declarations of
`os_being_run' and `iswinnt'. Eliminate `os_type" definition.
* include/cygwin/version.h: Bump version to 1.3.4.
2001-09-13 01:46:37 +08:00
|
|
|
DWORD todo = wincap.chunksize () ?: high - low;
|
2000-02-18 03:38:33 +08:00
|
|
|
char *here;
|
|
|
|
|
|
|
|
for (here = low; here < high; here += todo)
|
|
|
|
{
|
|
|
|
DWORD done = 0;
|
|
|
|
if (here + todo > high)
|
|
|
|
todo = high - here;
|
|
|
|
int res = WriteProcessMemory (pi.hProcess, here, here, todo, &done);
|
|
|
|
debug_printf ("child handle %p, low %p, high %p, res %d", pi.hProcess,
|
|
|
|
low, high, res);
|
|
|
|
if (!res || todo != done)
|
|
|
|
{
|
|
|
|
if (!res)
|
|
|
|
__seterrno ();
|
|
|
|
/* If this happens then there is a bug in our fork
|
|
|
|
implementation somewhere. */
|
2001-06-19 05:18:59 +08:00
|
|
|
system_printf ("%s pass %d failed, %p..%p, done %d, windows pid %u, %E",
|
|
|
|
what, pass, low, high, done, pi.dwProcessId);
|
2000-02-18 03:38:33 +08:00
|
|
|
goto err;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
pass++;
|
|
|
|
}
|
|
|
|
|
|
|
|
debug_printf ("done");
|
|
|
|
return 1;
|
|
|
|
|
2001-08-05 05:10:52 +08:00
|
|
|
err:
|
2000-02-18 03:38:33 +08:00
|
|
|
TerminateProcess (pi.hProcess, 1);
|
|
|
|
set_errno (EAGAIN);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Wait for child to finish what it's doing and signal us.
|
|
|
|
We don't want to wait forever here.If there's a problem somewhere
|
|
|
|
it'll hang the entire system (since all forks are mutex'd). If we
|
|
|
|
time out, set errno = EAGAIN and hope the app tries again. */
|
|
|
|
static int
|
|
|
|
sync_with_child (PROCESS_INFORMATION &pi, HANDLE subproc_ready,
|
2003-12-08 06:37:12 +08:00
|
|
|
bool hang_child, const char *s)
|
2000-02-18 03:38:33 +08:00
|
|
|
{
|
|
|
|
/* We also add the child process handle to the wait. If the child fails
|
|
|
|
to initialize (eg. because of a missing dll). Then this
|
|
|
|
handle will become signalled. This stops a *looong* timeout wait.
|
|
|
|
*/
|
|
|
|
HANDLE w4[2];
|
|
|
|
|
2000-10-12 12:38:29 +08:00
|
|
|
debug_printf ("waiting for child. reason: %s, hang_child %d", s,
|
|
|
|
hang_child);
|
2000-02-18 03:38:33 +08:00
|
|
|
w4[1] = pi.hProcess;
|
|
|
|
w4[0] = subproc_ready;
|
|
|
|
DWORD rc = WaitForMultipleObjects (2, w4, FALSE, FORK_WAIT_TIMEOUT);
|
|
|
|
|
|
|
|
if (rc == WAIT_OBJECT_0 ||
|
|
|
|
WaitForSingleObject (subproc_ready, 0) == WAIT_OBJECT_0)
|
|
|
|
/* That's ok */;
|
|
|
|
else if (rc == WAIT_FAILED || rc == WAIT_TIMEOUT)
|
|
|
|
{
|
|
|
|
if (rc != WAIT_FAILED)
|
|
|
|
system_printf ("WaitForMultipleObjects timed out");
|
|
|
|
else
|
|
|
|
system_printf ("WaitForMultipleObjects failed, %E");
|
|
|
|
set_errno (EAGAIN);
|
|
|
|
syscall_printf ("-1 = fork(), WaitForMultipleObjects failed");
|
|
|
|
TerminateProcess (pi.hProcess, 1);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
/* Child died. Clean up and exit. */
|
|
|
|
DWORD errcode;
|
|
|
|
GetExitCodeProcess (pi.hProcess, &errcode);
|
|
|
|
/* Fix me. This is not enough. The fork should not be considered
|
|
|
|
* to have failed if the process was essentially killed by a signal.
|
|
|
|
*/
|
|
|
|
if (errcode != STATUS_CONTROL_C_EXIT)
|
|
|
|
{
|
2004-02-12 11:01:58 +08:00
|
|
|
system_printf ("child %u(%p) died before initialization with status code %p",
|
|
|
|
cygwin_pid (pi.dwProcessId), pi.hProcess, errcode);
|
|
|
|
system_printf ("*** child state %s", s);
|
2000-02-18 03:38:33 +08:00
|
|
|
#ifdef DEBUGGING
|
2004-02-12 11:01:58 +08:00
|
|
|
try_to_debug ();
|
2000-02-18 03:38:33 +08:00
|
|
|
#endif
|
|
|
|
}
|
|
|
|
set_errno (EAGAIN);
|
|
|
|
syscall_printf ("Child died before subproc_ready signalled");
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
debug_printf ("child signalled me");
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
2000-02-21 13:20:38 +08:00
|
|
|
resume_child (PROCESS_INFORMATION &pi, HANDLE forker_finished)
|
2000-02-18 03:38:33 +08:00
|
|
|
{
|
|
|
|
SetEvent (forker_finished);
|
2000-10-13 06:15:47 +08:00
|
|
|
debug_printf ("signalled child");
|
|
|
|
return 1;
|
2000-02-18 03:38:33 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
/* Notify parent that it is time for the next step.
|
|
|
|
Note that this has to be a macro since the parent may be messing with
|
|
|
|
our stack. */
|
2000-10-13 06:15:47 +08:00
|
|
|
static void __stdcall
|
2002-09-22 11:38:57 +08:00
|
|
|
sync_with_parent (const char *s, bool hang_self)
|
2000-02-18 03:38:33 +08:00
|
|
|
{
|
2000-10-13 06:15:47 +08:00
|
|
|
debug_printf ("signalling parent: %s", s);
|
|
|
|
/* Tell our parent we're waiting. */
|
2002-06-16 05:59:32 +08:00
|
|
|
if (!SetEvent (fork_info->subproc_ready))
|
2001-09-23 00:55:02 +08:00
|
|
|
api_fatal ("fork child - SetEvent for %s failed, %E", s);
|
2000-10-13 06:15:47 +08:00
|
|
|
if (hang_self)
|
|
|
|
{
|
2002-06-16 05:59:32 +08:00
|
|
|
HANDLE h = fork_info->forker_finished;
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Wait for the parent to fill in our stack and heap.
|
|
|
|
Don't wait forever here. If our parent dies we don't want to clog
|
|
|
|
the system. If the wait fails, we really can't continue so exit. */
|
|
|
|
DWORD psync_rc = WaitForSingleObject (h, FORK_WAIT_TIMEOUT);
|
|
|
|
debug_printf ("awake");
|
|
|
|
switch (psync_rc)
|
|
|
|
{
|
|
|
|
case WAIT_TIMEOUT:
|
2004-02-12 11:01:58 +08:00
|
|
|
api_fatal ("WFSO timed out %s", s);
|
2000-10-13 06:15:47 +08:00
|
|
|
break;
|
|
|
|
case WAIT_FAILED:
|
|
|
|
if (GetLastError () == ERROR_INVALID_HANDLE &&
|
2002-06-16 05:59:32 +08:00
|
|
|
WaitForSingleObject (fork_info->forker_finished, 1) != WAIT_FAILED)
|
2000-10-13 06:15:47 +08:00
|
|
|
break;
|
2004-02-12 11:01:58 +08:00
|
|
|
api_fatal ("WFSO failed %s, fork_finished %p, %E", s,
|
2002-06-16 05:59:32 +08:00
|
|
|
fork_info->forker_finished);
|
2000-10-13 06:15:47 +08:00
|
|
|
break;
|
|
|
|
default:
|
|
|
|
debug_printf ("no problems");
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
2000-02-18 03:38:33 +08:00
|
|
|
}
|
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
static int __stdcall
|
|
|
|
fork_child (HANDLE& hParent, dll *&first_dll, bool& load_dlls)
|
2000-02-18 03:38:33 +08:00
|
|
|
{
|
2004-01-19 13:46:54 +08:00
|
|
|
extern void fixup_timers_after_fork ();
|
2000-10-13 06:15:47 +08:00
|
|
|
debug_printf ("child is running. pid %d, ppid %d, stack here %p",
|
|
|
|
myself->pid, myself->ppid, __builtin_frame_address (0));
|
|
|
|
|
|
|
|
/* Restore the inheritance state as in parent
|
|
|
|
Don't call setuid here! The flags are already set. */
|
2003-06-30 21:07:36 +08:00
|
|
|
cygheap->user.reimpersonate ();
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2003-12-08 06:37:12 +08:00
|
|
|
sync_with_parent ("after longjmp", true);
|
2002-09-30 12:35:18 +08:00
|
|
|
sigproc_printf ("hParent %p, child 1 first_dll %p, load_dlls %d", hParent,
|
2001-09-08 05:32:07 +08:00
|
|
|
first_dll, load_dlls);
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2004-02-12 11:01:58 +08:00
|
|
|
/* If we've played with the stack, stacksize != 0. That means that
|
|
|
|
fork() was invoked from other than the main thread. Make sure that
|
|
|
|
the threadinfo information is properly set up. */
|
2004-02-19 06:32:15 +08:00
|
|
|
if (fork_info->stacksize)
|
2004-02-12 11:01:58 +08:00
|
|
|
{
|
|
|
|
_main_tls = &_my_tls;
|
|
|
|
_main_tls->init_thread (NULL, NULL);
|
|
|
|
_main_tls->local_clib = *_impure_ptr;
|
|
|
|
_impure_ptr = &_main_tls->local_clib;
|
|
|
|
}
|
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
#ifdef DEBUGGING
|
|
|
|
char c;
|
|
|
|
if (GetEnvironmentVariable ("FORKDEBUG", &c, 1))
|
|
|
|
try_to_debug ();
|
|
|
|
char buf[80];
|
|
|
|
/* This is useful for debugging fork problems. Use gdb to attach to
|
|
|
|
the pid reported here. */
|
|
|
|
if (GetEnvironmentVariable ("CYGWIN_FORK_SLEEP", buf, sizeof (buf)))
|
|
|
|
{
|
|
|
|
small_printf ("Sleeping %d after fork, pid %u\n", atoi (buf), GetCurrentProcessId ());
|
2002-09-22 11:38:57 +08:00
|
|
|
Sleep (atoi (buf));
|
2000-10-13 06:15:47 +08:00
|
|
|
}
|
|
|
|
#endif
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2001-06-12 19:31:05 +08:00
|
|
|
set_file_api_mode (current_codepage);
|
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
MALLOC_CHECK;
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2002-10-19 07:52:59 +08:00
|
|
|
if (fixup_mmaps_after_fork (hParent))
|
|
|
|
api_fatal ("recreate_mmaps_after_fork_failed");
|
|
|
|
|
2002-10-21 09:00:58 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
MALLOC_CHECK;
|
|
|
|
|
|
|
|
/* If we haven't dynamically loaded any dlls, just signal
|
|
|
|
the parent. Otherwise, load all the dlls, tell the parent
|
|
|
|
that we're done, and wait for the parent to fill in the.
|
|
|
|
loaded dlls' data/bss. */
|
|
|
|
if (!load_dlls)
|
2002-10-23 04:16:31 +08:00
|
|
|
{
|
|
|
|
cygheap->fdtab.fixup_after_fork (hParent);
|
|
|
|
ProtectHandleINH (hParent);
|
2003-12-08 06:37:12 +08:00
|
|
|
sync_with_parent ("performed fork fixup", false);
|
2002-10-23 04:16:31 +08:00
|
|
|
}
|
2000-10-13 06:15:47 +08:00
|
|
|
else
|
2000-02-18 03:38:33 +08:00
|
|
|
{
|
2000-10-13 06:15:47 +08:00
|
|
|
dlls.load_after_fork (hParent, first_dll);
|
2002-10-23 04:16:31 +08:00
|
|
|
cygheap->fdtab.fixup_after_fork (hParent);
|
|
|
|
ProtectHandleINH (hParent);
|
2003-12-08 06:37:12 +08:00
|
|
|
sync_with_parent ("loaded dlls", true);
|
2000-02-18 03:38:33 +08:00
|
|
|
}
|
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
ForceCloseHandle (hParent);
|
2002-07-14 04:00:27 +08:00
|
|
|
(void) ForceCloseHandle1 (fork_info->subproc_ready, subproc_ready);
|
|
|
|
(void) ForceCloseHandle1 (fork_info->forker_finished, forker_finished);
|
2000-07-15 10:48:11 +08:00
|
|
|
|
2004-02-18 05:17:25 +08:00
|
|
|
pinfo_fixup_after_fork ();
|
|
|
|
_my_tls.fixup_after_fork ();
|
|
|
|
sigproc_init ();
|
|
|
|
|
2003-08-26 02:21:07 +08:00
|
|
|
#ifdef USE_SERVER
|
2002-02-28 22:30:38 +08:00
|
|
|
if (fixup_shms_after_fork ())
|
|
|
|
api_fatal ("recreate_shm areas after fork failed");
|
2003-07-02 11:16:00 +08:00
|
|
|
#endif
|
2002-02-28 22:30:38 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Set thread local stuff to zero. Under Windows 95/98 this is sometimes
|
|
|
|
non-zero, for some reason.
|
|
|
|
FIXME: There is a memory leak here after a fork. */
|
|
|
|
for (per_thread **t = threadstuff; *t; t++)
|
|
|
|
if ((*t)->clear_on_fork ())
|
|
|
|
(*t)->set ();
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2002-09-17 17:12:36 +08:00
|
|
|
pthread::atforkchild ();
|
2004-01-19 13:46:54 +08:00
|
|
|
fixup_timers_after_fork ();
|
2002-10-21 09:00:58 +08:00
|
|
|
wait_for_sigthread ();
|
2000-10-17 07:55:58 +08:00
|
|
|
cygbench ("fork-child");
|
2004-02-12 11:01:58 +08:00
|
|
|
cygwin_finished_initializing = true;
|
2000-10-13 06:15:47 +08:00
|
|
|
return 0;
|
|
|
|
}
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2003-04-24 09:57:07 +08:00
|
|
|
#ifndef NO_SLOW_PID_REUSE
|
2000-11-15 14:27:48 +08:00
|
|
|
static void
|
|
|
|
slow_pid_reuse (HANDLE h)
|
|
|
|
{
|
2003-04-24 09:57:07 +08:00
|
|
|
static NO_COPY HANDLE last_fork_procs[4] = {0};
|
2000-11-15 14:27:48 +08:00
|
|
|
static NO_COPY unsigned nfork_procs = 0;
|
|
|
|
|
2000-11-15 14:46:19 +08:00
|
|
|
if (nfork_procs >= (sizeof (last_fork_procs) / sizeof (last_fork_procs [0])))
|
2000-11-15 14:27:48 +08:00
|
|
|
nfork_procs = 0;
|
|
|
|
/* Keep a list of handles to forked processes sitting around to prevent
|
|
|
|
Windows from reusing the same pid n times in a row. Having the same pids
|
|
|
|
close in succesion confuses bash. Keeping a handle open will stop
|
|
|
|
windows from reusing the same pid. */
|
|
|
|
if (last_fork_procs[nfork_procs])
|
2000-11-15 14:46:19 +08:00
|
|
|
ForceCloseHandle1 (last_fork_procs[nfork_procs], fork_stupidity);
|
|
|
|
if (DuplicateHandle (hMainProc, h, hMainProc, &last_fork_procs[nfork_procs],
|
2000-11-15 14:27:48 +08:00
|
|
|
0, FALSE, DUPLICATE_SAME_ACCESS))
|
2000-11-15 14:46:19 +08:00
|
|
|
ProtectHandle1 (last_fork_procs[nfork_procs], fork_stupidity);
|
|
|
|
else
|
2000-11-15 14:27:48 +08:00
|
|
|
{
|
|
|
|
last_fork_procs[nfork_procs] = NULL;
|
|
|
|
system_printf ("couldn't create last_fork_proc, %E");
|
|
|
|
}
|
|
|
|
nfork_procs++;
|
|
|
|
}
|
2003-03-22 09:45:18 +08:00
|
|
|
#endif
|
2000-11-15 14:27:48 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
static int __stdcall
|
2001-06-19 05:18:59 +08:00
|
|
|
fork_parent (HANDLE& hParent, dll *&first_dll,
|
|
|
|
bool& load_dlls, void *stack_here, child_info_fork &ch)
|
2000-10-13 06:15:47 +08:00
|
|
|
{
|
|
|
|
HANDLE subproc_ready, forker_finished;
|
|
|
|
DWORD rc;
|
|
|
|
PROCESS_INFORMATION pi = {0, NULL, 0, 0};
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2002-09-17 17:12:36 +08:00
|
|
|
pthread::atforkprepare ();
|
2001-05-20 09:19:20 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
subproc_init ();
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
int c_flags = GetPriorityClass (hMainProc) /*|
|
|
|
|
CREATE_NEW_PROCESS_GROUP*/;
|
|
|
|
STARTUPINFO si = {0, NULL, NULL, NULL, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, NULL, NULL, NULL, NULL};
|
|
|
|
|
|
|
|
/* If we don't have a console, then don't create a console for the
|
|
|
|
child either. */
|
2002-09-19 23:12:48 +08:00
|
|
|
HANDLE console_handle = CreateFile ("CONOUT$", GENERIC_WRITE,
|
|
|
|
FILE_SHARE_WRITE, &sec_none_nih,
|
|
|
|
OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL,
|
|
|
|
NULL);
|
2000-10-13 06:15:47 +08:00
|
|
|
|
2002-09-19 23:12:48 +08:00
|
|
|
if (console_handle != INVALID_HANDLE_VALUE)
|
2000-10-13 06:15:47 +08:00
|
|
|
CloseHandle (console_handle);
|
|
|
|
else
|
|
|
|
c_flags |= DETACHED_PROCESS;
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-26 18:13:41 +08:00
|
|
|
/* Some file types (currently only sockets) need extra effort in the
|
|
|
|
parent after CreateProcess and before copying the datastructures
|
|
|
|
to the child. So we have to start the child in suspend state,
|
|
|
|
unfortunately, to avoid a race condition. */
|
2001-04-19 05:10:15 +08:00
|
|
|
if (cygheap->fdtab.need_fixup_before ())
|
2000-10-26 18:13:41 +08:00
|
|
|
c_flags |= CREATE_SUSPENDED;
|
|
|
|
|
2000-11-15 14:27:48 +08:00
|
|
|
/* Create an inheritable handle to pass to the child process. This will
|
|
|
|
allow the child to duplicate handles from the parent to itself. */
|
2000-10-13 06:15:47 +08:00
|
|
|
hParent = NULL;
|
|
|
|
if (!DuplicateHandle (hMainProc, hMainProc, hMainProc, &hParent, 0, 1,
|
|
|
|
DUPLICATE_SAME_ACCESS))
|
|
|
|
{
|
|
|
|
system_printf ("couldn't create handle to myself for child, %E");
|
|
|
|
return -1;
|
|
|
|
}
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Remember the address of the first loaded dll and decide
|
|
|
|
if we need to load dlls. We do this here so that this
|
|
|
|
information will be available in the parent and, when
|
|
|
|
the stack is copied, in the child. */
|
|
|
|
first_dll = dlls.start.next;
|
|
|
|
load_dlls = dlls.reload_on_fork && dlls.loaded_dlls;
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* This will help some of the confusion. */
|
|
|
|
fflush (stdout);
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
subproc_ready = CreateEvent (&sec_all, FALSE, FALSE, NULL);
|
|
|
|
if (subproc_ready == NULL)
|
|
|
|
{
|
|
|
|
CloseHandle (hParent);
|
|
|
|
system_printf ("unable to allocate subproc_ready event, %E");
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
forker_finished = CreateEvent (&sec_all, FALSE, FALSE, NULL);
|
|
|
|
if (forker_finished == NULL)
|
|
|
|
{
|
|
|
|
CloseHandle (hParent);
|
|
|
|
CloseHandle (subproc_ready);
|
2001-10-14 23:49:13 +08:00
|
|
|
system_printf ("unable to allocate forker_finished event, %E");
|
2000-10-13 06:15:47 +08:00
|
|
|
return -1;
|
|
|
|
}
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2002-07-14 04:00:27 +08:00
|
|
|
ProtectHandleINH (subproc_ready);
|
|
|
|
ProtectHandleINH (forker_finished);
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2001-10-10 10:32:12 +08:00
|
|
|
init_child_info (PROC_FORK, &ch, 1, subproc_ready);
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
ch.forker_finished = forker_finished;
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
stack_base (ch);
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
si.cb = sizeof (STARTUPINFO);
|
|
|
|
si.lpReserved2 = (LPBYTE)&ch;
|
2002-09-22 11:38:57 +08:00
|
|
|
si.cbReserved2 = sizeof (ch);
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Remove impersonation */
|
2003-06-30 21:07:36 +08:00
|
|
|
cygheap->user.deimpersonate ();
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
ch.parent = hParent;
|
2000-11-15 14:27:48 +08:00
|
|
|
#ifdef DEBUGGING
|
|
|
|
if (npid_max)
|
|
|
|
{
|
|
|
|
for (int pass = 0; pass < 2; pass++)
|
|
|
|
{
|
|
|
|
pid_t pid;
|
|
|
|
while ((pid = fork_pids[npid++]))
|
|
|
|
if (!pinfo (pid))
|
|
|
|
{
|
|
|
|
ch.cygpid = pid;
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
npid = 0;
|
|
|
|
}
|
|
|
|
}
|
2001-08-05 05:10:52 +08:00
|
|
|
out:
|
2000-11-15 14:27:48 +08:00
|
|
|
#endif
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-14 13:52:38 +08:00
|
|
|
syscall_printf ("CreateProcess (%s, %s, 0, 0, 1, %x, 0, 0, %p, %p)",
|
|
|
|
myself->progname, myself->progname, c_flags, &si, &pi);
|
2004-02-12 11:01:58 +08:00
|
|
|
bool locked = __malloc_lock ();
|
2001-09-14 08:49:00 +08:00
|
|
|
void *newheap;
|
2002-10-09 12:08:05 +08:00
|
|
|
newheap = cygheap_setup_for_child (&ch, cygheap->fdtab.need_fixup_before ());
|
2000-10-14 13:52:38 +08:00
|
|
|
rc = CreateProcess (myself->progname, /* image to run */
|
|
|
|
myself->progname, /* what we send in arg0 */
|
2004-02-06 18:37:37 +08:00
|
|
|
&sec_none_nih,
|
|
|
|
&sec_none_nih,
|
2000-10-14 13:52:38 +08:00
|
|
|
TRUE, /* inherit handles from parent */
|
|
|
|
c_flags,
|
|
|
|
NULL, /* environment filled in later */
|
2000-11-15 14:27:48 +08:00
|
|
|
0, /* use current drive/directory */
|
2000-10-14 13:52:38 +08:00
|
|
|
&si,
|
|
|
|
&pi);
|
2000-07-30 00:24:59 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
CloseHandle (hParent);
|
2000-07-30 00:24:59 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
if (!rc)
|
|
|
|
{
|
|
|
|
__seterrno ();
|
|
|
|
syscall_printf ("CreateProcessA failed, %E");
|
2002-09-22 11:38:57 +08:00
|
|
|
ForceCloseHandle (subproc_ready);
|
|
|
|
ForceCloseHandle (forker_finished);
|
2000-06-17 03:36:07 +08:00
|
|
|
/* Restore impersonation */
|
2003-06-30 21:07:36 +08:00
|
|
|
cygheap->user.reimpersonate ();
|
2001-09-14 08:49:00 +08:00
|
|
|
cygheap_setup_for_child_cleanup (newheap, &ch, 0);
|
2004-02-12 11:01:58 +08:00
|
|
|
__malloc_unlock ();
|
2000-10-13 06:15:47 +08:00
|
|
|
return -1;
|
|
|
|
}
|
2000-06-17 03:36:07 +08:00
|
|
|
|
2000-10-26 18:13:41 +08:00
|
|
|
/* Fixup the parent datastructure if needed and resume the child's
|
|
|
|
main thread. */
|
2001-09-14 08:49:00 +08:00
|
|
|
if (!cygheap->fdtab.need_fixup_before ())
|
|
|
|
cygheap_setup_for_child_cleanup (newheap, &ch, 0);
|
|
|
|
else
|
2000-10-26 18:13:41 +08:00
|
|
|
{
|
2001-04-19 05:10:15 +08:00
|
|
|
cygheap->fdtab.fixup_before_fork (pi.dwProcessId);
|
2001-09-14 08:49:00 +08:00
|
|
|
cygheap_setup_for_child_cleanup (newheap, &ch, 1);
|
2000-10-26 18:13:41 +08:00
|
|
|
ResumeThread (pi.hThread);
|
|
|
|
}
|
|
|
|
|
2000-11-15 14:27:48 +08:00
|
|
|
#ifdef DEBUGGING
|
2004-08-31 11:34:04 +08:00
|
|
|
int forked_pid = ch.cygpid != 1 ? ch.cygpid : cygwin_pid (pi.dwProcessId);
|
2000-11-15 14:27:48 +08:00
|
|
|
#else
|
2004-08-31 11:34:04 +08:00
|
|
|
int forked_pid = cygwin_pid (pi.dwProcessId);
|
2000-11-15 14:27:48 +08:00
|
|
|
#endif
|
2004-08-31 11:34:04 +08:00
|
|
|
pinfo forked (forked_pid, 1);
|
|
|
|
|
2003-09-26 11:20:30 +08:00
|
|
|
if (!forked)
|
|
|
|
{
|
|
|
|
syscall_printf ("pinfo failed");
|
|
|
|
if (get_errno () != ENOMEM)
|
|
|
|
set_errno (EAGAIN);
|
|
|
|
goto cleanup;
|
|
|
|
}
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Initialize things that are done later in dll_crt0_1 that aren't done
|
|
|
|
for the forkee. */
|
2002-09-22 11:38:57 +08:00
|
|
|
strcpy (forked->progname, myself->progname);
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Restore impersonation */
|
2003-06-30 21:07:36 +08:00
|
|
|
cygheap->user.reimpersonate ();
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
ProtectHandle (pi.hThread);
|
|
|
|
/* Protect the handle but name it similarly to the way it will
|
|
|
|
be called in subproc handling. */
|
|
|
|
ProtectHandle1 (pi.hProcess, childhProc);
|
2000-10-21 12:53:49 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Fill in fields in the child's process table entry. */
|
|
|
|
forked->hProcess = pi.hProcess;
|
|
|
|
forked->dwProcessId = pi.dwProcessId;
|
2001-02-10 12:20:52 +08:00
|
|
|
|
|
|
|
/* Hopefully, this will succeed. The alternative to doing things this
|
|
|
|
way is to reserve space prior to calling CreateProcess and then fill
|
|
|
|
it in afterwards. This requires more bookkeeping than I like, though,
|
|
|
|
so we'll just do it the easy way. So, terminate any child process if
|
|
|
|
we can't actually record the pid in the internal table. */
|
|
|
|
if (!forked.remember ())
|
|
|
|
{
|
|
|
|
TerminateProcess (pi.hProcess, 1);
|
|
|
|
set_errno (EAGAIN);
|
|
|
|
goto cleanup;
|
|
|
|
}
|
|
|
|
|
2003-04-24 09:57:07 +08:00
|
|
|
#ifndef NO_SLOW_PID_REUSE
|
2001-02-10 12:20:52 +08:00
|
|
|
slow_pid_reuse (pi.hProcess);
|
2003-03-22 09:45:18 +08:00
|
|
|
#endif
|
2000-10-13 06:15:47 +08:00
|
|
|
|
|
|
|
/* Wait for subproc to initialize itself. */
|
2003-12-08 06:37:12 +08:00
|
|
|
if (!sync_with_child (pi, subproc_ready, true, "waiting for longjmp"))
|
2000-10-13 06:15:47 +08:00
|
|
|
goto cleanup;
|
|
|
|
|
|
|
|
/* CHILD IS STOPPED */
|
|
|
|
debug_printf ("child is alive (but stopped)");
|
|
|
|
|
|
|
|
/* Initialize, in order: data, bss, heap, stack, dll data, dll bss
|
|
|
|
Note: variables marked as NO_COPY will not be copied
|
|
|
|
since they are placed in a protected segment. */
|
2000-02-18 03:38:33 +08:00
|
|
|
|
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
MALLOC_CHECK;
|
2003-12-24 00:26:31 +08:00
|
|
|
void *impure_beg;
|
|
|
|
void *impure_end;
|
|
|
|
if (&_my_tls == _main_tls)
|
|
|
|
impure_beg = impure_end = NULL;
|
|
|
|
else
|
|
|
|
{
|
|
|
|
impure_beg = _impure_ptr;
|
|
|
|
impure_end = _impure_ptr + 1;
|
|
|
|
}
|
2000-10-13 06:15:47 +08:00
|
|
|
rc = fork_copy (pi, "user/cygwin data",
|
|
|
|
user_data->data_start, user_data->data_end,
|
|
|
|
user_data->bss_start, user_data->bss_end,
|
2002-10-23 00:18:55 +08:00
|
|
|
cygheap->user_heap.base, cygheap->user_heap.ptr,
|
2000-10-13 06:15:47 +08:00
|
|
|
stack_here, ch.stackbottom,
|
|
|
|
dll_data_start, dll_data_end,
|
2003-12-24 00:26:31 +08:00
|
|
|
dll_bss_start, dll_bss_end, impure_beg, impure_end, NULL);
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2002-08-17 03:41:39 +08:00
|
|
|
__malloc_unlock ();
|
2004-02-12 11:01:58 +08:00
|
|
|
locked = false;
|
2000-10-13 06:15:47 +08:00
|
|
|
MALLOC_CHECK;
|
|
|
|
if (!rc)
|
|
|
|
goto cleanup;
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Now fill data/bss of any DLLs that were linked into the program. */
|
|
|
|
for (dll *d = dlls.istart (DLL_LINK); d; d = dlls.inext ())
|
|
|
|
{
|
|
|
|
debug_printf ("copying data/bss of a linked dll");
|
|
|
|
if (!fork_copy (pi, "linked dll data/bss", d->p.data_start, d->p.data_end,
|
|
|
|
d->p.bss_start, d->p.bss_end,
|
|
|
|
NULL))
|
2000-02-18 03:38:33 +08:00
|
|
|
goto cleanup;
|
|
|
|
}
|
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Start thread, and wait for it to reload dlls. */
|
|
|
|
if (!resume_child (pi, forker_finished) ||
|
|
|
|
!sync_with_child (pi, subproc_ready, load_dlls, "child loading dlls"))
|
|
|
|
goto cleanup;
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
/* If DLLs were loaded in the parent, then the child has reloaded all
|
|
|
|
of them and is now waiting to have all of the individual data and
|
|
|
|
bss sections filled in. */
|
|
|
|
if (load_dlls)
|
|
|
|
{
|
|
|
|
/* CHILD IS STOPPED */
|
|
|
|
/* write memory of reloaded dlls */
|
|
|
|
for (dll *d = dlls.istart (DLL_LOAD); d; d = dlls.inext ())
|
2000-02-18 03:38:33 +08:00
|
|
|
{
|
2000-10-13 06:15:47 +08:00
|
|
|
debug_printf ("copying data/bss for a loaded dll");
|
|
|
|
if (!fork_copy (pi, "loaded dll data/bss", d->p.data_start, d->p.data_end,
|
|
|
|
d->p.bss_start, d->p.bss_end,
|
|
|
|
NULL))
|
|
|
|
goto cleanup;
|
2000-02-18 03:38:33 +08:00
|
|
|
}
|
2000-10-13 06:15:47 +08:00
|
|
|
/* Start the child up again. */
|
|
|
|
(void) resume_child (pi, forker_finished);
|
2000-02-18 03:38:33 +08:00
|
|
|
}
|
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
ForceCloseHandle (subproc_ready);
|
|
|
|
ForceCloseHandle (pi.hThread);
|
|
|
|
ForceCloseHandle (forker_finished);
|
|
|
|
forker_finished = NULL;
|
|
|
|
pi.hThread = NULL;
|
2002-09-17 17:12:36 +08:00
|
|
|
pthread::atforkparent ();
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2004-03-07 12:57:47 +08:00
|
|
|
return forked_pid;
|
2000-02-18 03:38:33 +08:00
|
|
|
|
|
|
|
/* Common cleanup code for failure cases */
|
2001-08-05 05:10:52 +08:00
|
|
|
cleanup:
|
2004-02-12 11:01:58 +08:00
|
|
|
if (locked)
|
|
|
|
__malloc_unlock ();
|
|
|
|
|
2000-02-18 03:38:33 +08:00
|
|
|
/* Remember to de-allocate the fd table. */
|
|
|
|
if (pi.hProcess)
|
|
|
|
ForceCloseHandle1 (pi.hProcess, childhProc);
|
|
|
|
if (pi.hThread)
|
|
|
|
ForceCloseHandle (pi.hThread);
|
|
|
|
if (subproc_ready)
|
|
|
|
ForceCloseHandle (subproc_ready);
|
|
|
|
if (forker_finished)
|
|
|
|
ForceCloseHandle (forker_finished);
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
extern "C" int
|
|
|
|
fork ()
|
2000-02-18 03:38:33 +08:00
|
|
|
{
|
2000-10-13 06:15:47 +08:00
|
|
|
struct
|
|
|
|
{
|
|
|
|
HANDLE hParent;
|
|
|
|
dll *first_dll;
|
|
|
|
bool load_dlls;
|
|
|
|
} grouped;
|
|
|
|
|
|
|
|
MALLOC_CHECK;
|
|
|
|
|
|
|
|
debug_printf ("entering");
|
2000-10-14 13:52:38 +08:00
|
|
|
grouped.hParent = grouped.first_dll = NULL;
|
|
|
|
grouped.load_dlls = 0;
|
2000-10-13 06:15:47 +08:00
|
|
|
|
2000-10-14 13:52:38 +08:00
|
|
|
void *esp;
|
2001-06-19 05:18:59 +08:00
|
|
|
__asm__ volatile ("movl %%esp,%0": "=r" (esp));
|
2000-10-14 13:52:38 +08:00
|
|
|
|
2000-10-25 11:54:50 +08:00
|
|
|
myself->set_has_pgid_children ();
|
|
|
|
|
2000-10-13 06:15:47 +08:00
|
|
|
child_info_fork ch;
|
|
|
|
|
2000-10-14 13:52:38 +08:00
|
|
|
int res = setjmp (ch.jmp);
|
|
|
|
if (res)
|
2000-10-13 06:15:47 +08:00
|
|
|
res = fork_child (grouped.hParent, grouped.first_dll, grouped.load_dlls);
|
|
|
|
else
|
2001-06-19 05:18:59 +08:00
|
|
|
res = fork_parent (grouped.hParent, grouped.first_dll, grouped.load_dlls, esp, ch);
|
2000-10-13 06:15:47 +08:00
|
|
|
|
|
|
|
MALLOC_CHECK;
|
|
|
|
syscall_printf ("%d = fork()", res);
|
|
|
|
return res;
|
2000-02-18 03:38:33 +08:00
|
|
|
}
|
2000-11-15 14:27:48 +08:00
|
|
|
#ifdef DEBUGGING
|
|
|
|
void
|
|
|
|
fork_init ()
|
|
|
|
{
|
|
|
|
char buf[1024];
|
|
|
|
if (!GetEnvironmentVariable ("CYGWIN_FORK_PIDS", buf, 1024))
|
|
|
|
return;
|
|
|
|
pid_t pid;
|
|
|
|
char *p, *pe;
|
|
|
|
for (p = buf; (pid = strtol (p, &pe, 10)); p = pe)
|
|
|
|
fork_pids[npid_max++] = pid;
|
|
|
|
}
|
|
|
|
#endif /*DEBUGGING*/
|
2000-02-18 03:38:33 +08:00
|
|
|
|
|
|
|
#ifdef NEWVFORK
|
|
|
|
/* Dummy function to force second assignment below to actually be
|
|
|
|
carried out */
|
|
|
|
static vfork_save *
|
|
|
|
get_vfork_val ()
|
|
|
|
{
|
|
|
|
return vfork_storage.val ();
|
|
|
|
}
|
|
|
|
#endif
|
|
|
|
|
2002-08-18 13:49:26 +08:00
|
|
|
extern "C" int
|
2000-02-18 03:38:33 +08:00
|
|
|
vfork ()
|
|
|
|
{
|
|
|
|
#ifndef NEWVFORK
|
2004-02-02 02:29:12 +08:00
|
|
|
debug_printf ("stub called");
|
2000-02-18 03:38:33 +08:00
|
|
|
return fork ();
|
|
|
|
#else
|
|
|
|
vfork_save *vf = get_vfork_val ();
|
2000-08-03 11:02:41 +08:00
|
|
|
char **esp, **pp;
|
2000-02-18 03:38:33 +08:00
|
|
|
|
|
|
|
if (vf == NULL)
|
|
|
|
vf = vfork_storage.create ();
|
2001-09-14 12:37:57 +08:00
|
|
|
else if (vf->pid)
|
|
|
|
return fork ();
|
2000-02-18 03:38:33 +08:00
|
|
|
|
2003-11-29 04:55:59 +08:00
|
|
|
// FIXME the tls stuff could introduce a signal race if a child process
|
|
|
|
// exits quickly.
|
2000-02-18 03:38:33 +08:00
|
|
|
if (!setjmp (vf->j))
|
|
|
|
{
|
|
|
|
vf->pid = -1;
|
2000-08-03 11:02:41 +08:00
|
|
|
__asm__ volatile ("movl %%esp,%0": "=r" (vf->vfork_esp):);
|
2000-02-18 03:38:33 +08:00
|
|
|
__asm__ volatile ("movl %%ebp,%0": "=r" (vf->vfork_ebp):);
|
2003-11-29 04:55:59 +08:00
|
|
|
for (pp = (char **) vf->frame, esp = vf->vfork_esp;
|
2001-09-15 08:47:44 +08:00
|
|
|
esp <= vf->vfork_ebp + 2; pp++, esp++)
|
2000-08-03 11:02:41 +08:00
|
|
|
*pp = *esp;
|
2002-08-18 13:49:26 +08:00
|
|
|
vf->ctty = myself->ctty;
|
|
|
|
vf->sid = myself->sid;
|
|
|
|
vf->pgid = myself->pgid;
|
2004-01-04 02:15:03 +08:00
|
|
|
cygheap->ctty_on_hold = cygheap->ctty;
|
2003-12-30 09:57:16 +08:00
|
|
|
vf->open_fhs = cygheap->open_fhs;
|
2004-01-14 23:45:37 +08:00
|
|
|
debug_printf ("cygheap->ctty_on_hold %p, cygheap->open_fhs %d", cygheap->ctty_on_hold, cygheap->open_fhs);
|
2001-06-25 05:57:50 +08:00
|
|
|
int res = cygheap->fdtab.vfork_child_dup () ? 0 : -1;
|
|
|
|
debug_printf ("%d = vfork()", res);
|
2004-02-12 11:01:58 +08:00
|
|
|
_my_tls.call_signal_handler (); // FIXME: racy
|
2003-11-29 04:55:59 +08:00
|
|
|
vf->tls = _my_tls;
|
2001-06-25 05:57:50 +08:00
|
|
|
return res;
|
2000-02-18 03:38:33 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
vf = get_vfork_val ();
|
2001-09-14 08:49:00 +08:00
|
|
|
|
2003-11-29 04:55:59 +08:00
|
|
|
for (pp = (char **) vf->frame, esp = vf->vfork_esp;
|
2001-09-15 08:47:44 +08:00
|
|
|
esp <= vf->vfork_ebp + 2; pp++, esp++)
|
2001-09-14 08:49:00 +08:00
|
|
|
*esp = *pp;
|
|
|
|
|
2001-09-15 08:47:44 +08:00
|
|
|
cygheap->fdtab.vfork_parent_restore ();
|
|
|
|
|
2002-08-18 13:49:26 +08:00
|
|
|
myself->ctty = vf->ctty;
|
|
|
|
myself->sid = vf->sid;
|
|
|
|
myself->pgid = vf->pgid;
|
2004-01-04 02:15:03 +08:00
|
|
|
termios_printf ("cygheap->ctty %p, cygheap->ctty_on_hold %p", cygheap->ctty, cygheap->ctty_on_hold);
|
|
|
|
cygheap->open_fhs = vf->open_fhs;
|
2002-08-18 13:49:26 +08:00
|
|
|
|
2000-02-18 03:38:33 +08:00
|
|
|
if (vf->pid < 0)
|
|
|
|
{
|
2002-08-18 13:49:26 +08:00
|
|
|
int exitval = vf->exitval;
|
2001-09-14 12:39:56 +08:00
|
|
|
vf->pid = 0;
|
2000-02-18 03:38:33 +08:00
|
|
|
if ((vf->pid = fork ()) == 0)
|
|
|
|
exit (exitval);
|
|
|
|
}
|
|
|
|
|
2001-09-14 12:37:57 +08:00
|
|
|
int pid = vf->pid;
|
|
|
|
vf->pid = 0;
|
2001-10-04 10:34:20 +08:00
|
|
|
debug_printf ("exiting vfork, pid %d", pid);
|
2001-09-15 08:47:44 +08:00
|
|
|
sig_dispatch_pending ();
|
2003-11-29 04:55:59 +08:00
|
|
|
|
2004-02-12 11:01:58 +08:00
|
|
|
_my_tls.call_signal_handler (); // FIXME: racy
|
2003-11-29 04:55:59 +08:00
|
|
|
_my_tls = vf->tls;
|
2001-09-14 12:37:57 +08:00
|
|
|
return pid;
|
2000-02-18 03:38:33 +08:00
|
|
|
#endif
|
|
|
|
}
|