Page Menu
Home
GnuPG
Search
Configure Global Search
Log In
Files
F22947981
exechelp-w32ce.c
No One
Temporary
Actions
Download File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Size
22 KB
Subscribers
None
exechelp-w32ce.c
View Options
/* exechelp-w32.c - Fork and exec helpers for W32CE.
* Copyright (C) 2004, 2007, 2008, 2009,
* 2010 Free Software Foundation, Inc.
*
* This file is part of GnuPG.
*
* GnuPG is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* GnuPG is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, see <http://www.gnu.org/licenses/>.
*/
#include
<config.h>
#if !defined(HAVE_W32_SYSTEM) && !defined (HAVE_W32CE_SYSTEM)
#error This code is only used on W32CE.
#endif
#include
<stdio.h>
#include
<stdlib.h>
#include
<string.h>
#include
<errno.h>
#include
<assert.h>
#ifdef HAVE_SIGNAL_H
# include <signal.h>
#endif
#include
<unistd.h>
#include
<fcntl.h>
#ifdef WITHOUT_GNU_PTH
/* Give the Makefile a chance to build without Pth. */
#undef HAVE_PTH
#undef USE_GNU_PTH
#endif
#ifdef USE_GNU_PTH
#include
<pth.h>
#endif
#ifdef HAVE_STAT
# include <sys/stat.h>
#endif
#include
<assuan.h>
#include
"util.h"
#include
"i18n.h"
#include
"sysutils.h"
#include
"exechelp.h"
/* It seems Vista doesn't grok X_OK and so fails access() tests.
Previous versions interpreted X_OK as F_OK anyway, so we'll just
use F_OK directly. */
#undef X_OK
#define X_OK F_OK
/* We assume that a HANDLE can be represented by an int which should
be true for all i386 systems (HANDLE is defined as void *) and
these are the only systems for which Windows is available. Further
we assume that -1 denotes an invalid handle. */
#define fd_to_handle(a) ((HANDLE)(a))
#define handle_to_fd(a) ((int)(a))
#define pid_to_handle(a) ((HANDLE)(a))
#define handle_to_pid(a) ((int)(a))
#ifdef USE_GNU_PTH
/* The data passed to the feeder_thread. */
struct
feeder_thread_parms
{
estream_t
stream
;
volatile
int
stream_valid
;
HANDLE
hd
;
int
direction
;
};
/* The thread started by start_feede3. */
static
void
*
feeder_thread
(
void
*
arg
)
{
struct
feeder_thread_parms
*
parm
=
arg
;
char
buffer
[
4096
];
int
rc
;
if
(
parm
->
direction
)
{
size_t
nread
=
0
;
DWORD
nwritten
;
log_debug
(
"feeder_thread estream->pipe: stream=%p pipe=%p
\n
"
,
parm
->
stream
,
parm
->
hd
);
while
(
parm
->
stream_valid
&&
!
es_read
(
parm
->
stream
,
buffer
,
sizeof
buffer
,
&
nread
))
{
do
{
pth_enter
();
rc
=
WriteFile
(
parm
->
hd
,
buffer
,
nread
,
&
nwritten
,
NULL
);
pth_leave
();
if
(
!
rc
)
{
log_debug
(
"feeder(%p): WriteFile error: rc=%d
\n
"
,
parm
->
hd
,
(
int
)
GetLastError
());
goto
leave
;
}
nread
-=
nwritten
;
}
while
(
nread
);
}
if
(
!
parm
->
stream_valid
)
log_debug
(
"feeder(%p): closed by other thread
\n
"
,
parm
->
hd
);
else
if
(
nread
)
log_debug
(
"feeder(%p): es_read error: %s
\n
"
,
parm
->
hd
,
strerror
(
errno
));
}
else
{
DWORD
nread
=
0
;
size_t
nwritten
;
log_debug
(
"feeder_thread pipe->estream: stream=%p pipe=%p
\n
"
,
parm
->
stream
,
parm
->
hd
);
while
(
(
pth_enter
(),
(
rc
=
ReadFile
(
parm
->
hd
,
buffer
,
sizeof
buffer
,
&
nread
,
NULL
)),
pth_leave
(),
rc
)
&&
nread
)
{
log_debug
(
"feeder_thread pipe->estream: read %d bytes
\n
"
,
(
int
)
nread
);
do
{
if
(
parm
->
stream_valid
&&
es_write
(
parm
->
stream
,
buffer
,
nread
,
&
nwritten
))
{
log_debug
(
"feeder(%p): es_write error: %s
\n
"
,
parm
->
hd
,
strerror
(
errno
));
goto
leave
;
}
log_debug
(
"feeder_thread pipe->estream: es_wrote %d bytes
\n
"
,
(
int
)
nwritten
);
nread
-=
nwritten
;
}
while
(
nread
&&
parm
->
stream_valid
);
}
if
(
!
parm
->
stream_valid
)
log_debug
(
"feeder(%p): closed by other thread
\n
"
,
parm
->
hd
);
else
if
(
nread
)
log_debug
(
"feeder(%p): ReadFile error: rc=%d
\n
"
,
parm
->
hd
,
(
int
)
GetLastError
());
else
log_debug
(
"feeder(%p)
:
eof
\
n
", parm->hd)
;
}
leave
:
log_debug
(
"feeder(%p): waiting for es_fclose
\n
"
,
parm
->
hd
);
while
(
parm
->
stream_valid
)
pth_yield
(
NULL
);
log_debug
(
"feeder(%p): about to close the pipe handle
\n
"
,
parm
->
hd
);
CloseHandle
(
parm
->
hd
);
log_debug
(
"feeder(%p): pipe handle closed
\n
"
,
parm
->
hd
);
xfree
(
parm
);
return
NULL
;
}
#endif
/*USE_GNU_PTH*/
#ifdef USE_GNU_PTH
static
void
feeder_onclose_notification
(
estream_t
stream
,
void
*
opaque
)
{
struct
feeder_thread_parms
*
parm
=
opaque
;
(
void
)
stream
;
log_debug
(
"feeder(%p): received onclose note
\n
"
,
parm
->
hd
);
parm
->
stream_valid
=
0
;
}
#endif
/*USE_GNU_PTH*/
/* Fire up a thread to copy data between STREAM and a pipe's
descriptor FD. With DIRECTION set to true the copy takes place
from the stream to the pipe, otherwise from the pipe to the
stream. */
static
gpg_error_t
start_feeder
(
estream_t
stream
,
HANDLE
hd
,
int
direction
)
{
#ifdef USE_GNU_PTH
gpg_error_t
err
;
struct
feeder_thread_parms
*
parm
;
pth_attr_t
tattr
;
parm
=
xtrymalloc
(
sizeof
*
parm
);
if
(
!
parm
)
return
gpg_error_from_syserror
();
parm
->
stream
=
stream
;
parm
->
stream_valid
=
1
;
parm
->
hd
=
hd
;
parm
->
direction
=
direction
;
if
(
es_onclose
(
stream
,
1
,
feeder_onclose_notification
,
parm
))
{
err
=
gpg_error_from_syserror
();
xfree
(
parm
);
return
err
;
}
tattr
=
pth_attr_new
();
pth_attr_set
(
tattr
,
PTH_ATTR_JOINABLE
,
0
);
pth_attr_set
(
tattr
,
PTH_ATTR_STACK_SIZE
,
64
*
1024
);
pth_attr_set
(
tattr
,
PTH_ATTR_NAME
,
"exec-feeder"
);
log_debug
(
"spawning new feeder(%p, %p, %d)
\n
"
,
stream
,
hd
,
direction
);
if
(
!
pth_spawn
(
tattr
,
feeder_thread
,
parm
))
{
err
=
gpg_error_from_syserror
();
es_onclose
(
stream
,
0
,
feeder_onclose_notification
,
parm
);
xfree
(
parm
);
}
else
err
=
0
;
pth_attr_destroy
(
tattr
);
return
err
;
#else
(
void
)
stream
;
(
void
)
hd
;
(
void
)
direction
;
return
gpg_error
(
GPG_ERR_NOT_IMPLEMENTED
);
/* No Pth. */
#endif
}
/* Return the maximum number of currently allowed open file
descriptors. Only useful on POSIX systems but returns a value on
other systems too. */
int
get_max_fds
(
void
)
{
int
max_fds
=
-1
;
#ifdef OPEN_MAX
if
(
max_fds
==
-1
)
max_fds
=
OPEN_MAX
;
#endif
if
(
max_fds
==
-1
)
max_fds
=
256
;
/* Arbitrary limit. */
return
max_fds
;
}
/* Under Windows this is a dummy function. */
void
close_all_fds
(
int
first
,
int
*
except
)
{
(
void
)
first
;
(
void
)
except
;
}
/* Returns an array with all currently open file descriptors. The end
of the array is marked by -1. The caller needs to release this
array using the *standard free* and not with xfree. This allow the
use of this function right at startup even before libgcrypt has
been initialized. Returns NULL on error and sets ERRNO
accordingly. */
int
*
get_all_open_fds
(
void
)
{
int
*
array
;
size_t
narray
;
int
fd
,
max_fd
,
idx
;
#ifndef HAVE_STAT
array
=
calloc
(
1
,
sizeof
*
array
);
if
(
array
)
array
[
0
]
=
-1
;
#else
/*HAVE_STAT*/
struct
stat
statbuf
;
max_fd
=
get_max_fds
();
narray
=
32
;
/* If you change this change also t-exechelp.c. */
array
=
calloc
(
narray
,
sizeof
*
array
);
if
(
!
array
)
return
NULL
;
/* Note: The list we return is ordered. */
for
(
idx
=
0
,
fd
=
0
;
fd
<
max_fd
;
fd
++
)
if
(
!
(
fstat
(
fd
,
&
statbuf
)
==
-1
&&
errno
==
EBADF
))
{
if
(
idx
+
1
>=
narray
)
{
int
*
tmp
;
narray
+=
(
narray
<
256
)
?
32
:
256
;
tmp
=
realloc
(
array
,
narray
*
sizeof
*
array
);
if
(
!
tmp
)
{
free
(
array
);
return
NULL
;
}
array
=
tmp
;
}
array
[
idx
++
]
=
fd
;
}
array
[
idx
]
=
-1
;
#endif
/*HAVE_STAT*/
return
array
;
}
static
char
*
copy_quoted
(
char
*
p
,
const
char
*
string
)
{
const
char
*
s
;
if
(
!*
string
)
/* Empty string. */
p
=
stpcpy
(
p
,
"
\"\"
"
);
else
if
(
strpbrk
(
string
,
"
\t\n\v\f\"
"
))
/* Need quotes. */
{
p
=
stpcpy
(
p
,
"
\"
"
);
for
(
s
=
string
;
*
s
;
s
++
)
{
*
p
++
=
*
s
;
if
(
*
s
==
'\"'
)
*
p
++
=
*
s
;
}
*
p
++
=
'\"'
;
*
p
=
0
;
}
else
/* Copy verbatim. */
p
=
stpcpy
(
p
,
string
);
return
p
;
}
/* Build a command line for use with W32's CreateProcess. On success
CMDLINE gets the address of a newly allocated string. */
static
int
build_w32_commandline
(
const
char
*
const
*
argv
,
int
rvid0
,
int
rvid1
,
int
rvid2
,
char
**
cmdline
)
{
int
i
,
n
;
const
char
*
s
;
char
*
buf
,
*
p
;
char
fdbuf
[
3
*
30
];
p
=
fdbuf
;
*
p
=
0
;
if
(
rvid0
)
snprintf
(
p
,
25
,
"-&S0=%d "
,
rvid0
);
else
strcpy
(
p
,
"-&S0=null "
);
p
+=
strlen
(
p
);
if
(
rvid1
)
snprintf
(
p
,
25
,
"-&S1=%d "
,
rvid1
);
else
strcpy
(
p
,
"-&S1=null "
);
p
+=
strlen
(
p
);
if
(
rvid2
)
snprintf
(
p
,
25
,
"-&S2=%d "
,
rvid2
);
else
strcpy
(
p
,
"-&S2=null "
);
p
+=
strlen
(
p
);
*
cmdline
=
NULL
;
n
=
strlen
(
fdbuf
);
for
(
i
=
0
;
(
s
=
argv
[
i
]);
i
++
)
{
n
+=
strlen
(
s
)
+
1
+
2
;
/* (1 space, 2 quoting) */
for
(;
*
s
;
s
++
)
if
(
*
s
==
'\"'
)
n
++
;
/* Need to double inner quotes. */
}
n
++
;
buf
=
p
=
xtrymalloc
(
n
);
if
(
!
buf
)
return
-1
;
p
=
stpcpy
(
p
,
fdbuf
);
for
(
i
=
0
;
argv
[
i
];
i
++
)
{
*
p
++
=
' '
;
p
=
copy_quoted
(
p
,
argv
[
i
]);
}
*
cmdline
=
buf
;
return
0
;
}
/* Create pipe where one end is inheritable: With an INHERIT_IDX of 0
the read end is inheritable, with 1 the write end is inheritable.
Note that the inheritable ends are rendezvous ids and no file
descriptors or handles. */
static
gpg_error_t
create_inheritable_pipe
(
int
filedes
[
2
],
int
inherit_idx
)
{
HANDLE
hd
;
int
rvid
;
filedes
[
0
]
=
filedes
[
1
]
=
-1
;
hd
=
_assuan_w32ce_prepare_pipe
(
&
rvid
,
!
inherit_idx
);
if
(
hd
==
INVALID_HANDLE_VALUE
)
{
log_error
(
"_assuan_w32ce_prepare_pipe failed: %s
\n
"
,
w32_strerror
(
-1
));
gpg_err_set_errno
(
EIO
);
return
gpg_error_from_syserror
();
}
if
(
inherit_idx
)
{
filedes
[
0
]
=
handle_to_fd
(
hd
);
filedes
[
1
]
=
rvid
;
}
else
{
filedes
[
0
]
=
rvid
;
filedes
[
1
]
=
handle_to_fd
(
hd
);
}
return
0
;
}
/* Portable function to create a pipe. Under Windows the write end is
inheritable (i.e. an rendezvous id). */
gpg_error_t
gnupg_create_inbound_pipe
(
int
filedes
[
2
])
{
return
create_inheritable_pipe
(
filedes
,
1
);
}
/* Portable function to create a pipe. Under Windows the read end is
inheritable (i.e. an rendezvous id). */
gpg_error_t
gnupg_create_outbound_pipe
(
int
filedes
[
2
])
{
return
create_inheritable_pipe
(
filedes
,
0
);
}
static
int
create_process
(
const
char
*
pgmname
,
const
char
*
cmdline
,
PROCESS_INFORMATION
*
pi
)
{
int
res
;
wchar_t
*
wpgmname
,
*
wcmdline
;
wpgmname
=
utf8_to_wchar
(
pgmname
);
if
(
!
wpgmname
)
return
0
;
wcmdline
=
utf8_to_wchar
(
cmdline
);
if
(
!
wcmdline
)
{
xfree
(
wpgmname
);
return
0
;
}
res
=
CreateProcess
(
wpgmname
,
/* Program to start. */
wcmdline
,
/* Command line arguments. */
NULL
,
/* Process security attributes. */
NULL
,
/* Thread security attributes. */
FALSE
,
/* Inherit handles. */
CREATE_SUSPENDED
,
/* Creation flags. */
NULL
,
/* Environment. */
NULL
,
/* Use current drive/directory. */
NULL
,
/* Startup information. */
pi
);
/* Returns process information. */
xfree
(
wcmdline
);
xfree
(
wpgmname
);
return
res
;
}
/* Fork and exec the PGMNAME, see exechelp.h for details. */
gpg_error_t
gnupg_spawn_process
(
const
char
*
pgmname
,
const
char
*
argv
[],
gpg_err_source_t
errsource
,
void
(
*
preexec
)(
void
),
unsigned
int
flags
,
estream_t
infp
,
estream_t
*
r_outfp
,
estream_t
*
r_errfp
,
pid_t
*
pid
)
{
gpg_error_t
err
;
PROCESS_INFORMATION
pi
=
{
NULL
};
char
*
cmdline
;
es_syshd_t
syshd
;
struct
{
HANDLE
hd
;
int
rvid
;
}
inpipe
=
{
INVALID_HANDLE_VALUE
,
0
};
struct
{
HANDLE
hd
;
int
rvid
;
}
outpipe
=
{
INVALID_HANDLE_VALUE
,
0
};
struct
{
HANDLE
hd
;
int
rvid
;
}
errpipe
=
{
INVALID_HANDLE_VALUE
,
0
};
estream_t
outfp
=
NULL
;
estream_t
errfp
=
NULL
;
(
void
)
preexec
;
(
void
)
flags
;
/* Setup return values. */
if
(
r_outfp
)
*
r_outfp
=
NULL
;
if
(
r_errfp
)
*
r_errfp
=
NULL
;
*
pid
=
(
pid_t
)(
-1
);
/* Always required. */
log_debug
(
"%s: enter
\n
"
,
__func__
);
if
(
infp
)
{
es_fflush
(
infp
);
es_rewind
(
infp
);
/* Create a pipe to copy our infile to the stdin of the child
process. On success inpipe.hd is owned by the feeder. */
inpipe
.
hd
=
_assuan_w32ce_prepare_pipe
(
&
inpipe
.
rvid
,
1
);
if
(
inpipe
.
hd
==
INVALID_HANDLE_VALUE
)
{
log_error
(
"_assuan_w32ce_prepare_pipe failed: %s
\n
"
,
w32_strerror
(
-1
));
gpg_err_set_errno
(
EIO
);
return
gpg_error_from_syserror
();
}
log_debug
(
"%s: inpipe %p created; hd=%p rvid=%d
\n
"
,
__func__
,
infp
,
inpipe
.
hd
,
inpipe
.
rvid
);
err
=
start_feeder
(
infp
,
inpipe
.
hd
,
1
);
if
(
err
)
{
log_error
(
"error spawning feeder: %s
\n
"
,
gpg_strerror
(
err
));
CloseHandle
(
inpipe
.
hd
);
return
err
;
}
inpipe
.
hd
=
INVALID_HANDLE_VALUE
;
/* Now owned by the feeder. */
log_debug
(
"%s: inpipe %p created; feeder started
\n
"
,
__func__
,
infp
);
}
if
(
r_outfp
)
{
/* Create a pipe to make the stdout of the child process
available as a stream. */
outpipe
.
hd
=
_assuan_w32ce_prepare_pipe
(
&
outpipe
.
rvid
,
0
);
if
(
outpipe
.
hd
==
INVALID_HANDLE_VALUE
)
{
log_error
(
"_assuan_w32ce_prepare_pipe failed: %s
\n
"
,
w32_strerror
(
-1
));
gpg_err_set_errno
(
EIO
);
/* Fixme release other stuff/kill feeder. */
return
gpg_error_from_syserror
();
}
syshd
.
type
=
ES_SYSHD_HANDLE
;
syshd
.
u
.
handle
=
outpipe
.
hd
;
err
=
0
;
outfp
=
es_sysopen
(
&
syshd
,
"r"
);
if
(
!
outfp
)
{
err
=
gpg_err_make
(
errsource
,
gpg_err_code_from_syserror
());
log_error
(
"error opening pipe stream: %s
\n
"
,
gpg_strerror
(
err
));
CloseHandle
(
outpipe
.
hd
);
return
err
;
}
log_debug
(
"%s: outpipe %p created; hd=%p rvid=%d
\n
"
,
__func__
,
outfp
,
outpipe
.
hd
,
outpipe
.
rvid
);
outpipe
.
hd
=
INVALID_HANDLE_VALUE
;
/* Now owned by the OUTFP. */
}
if
(
r_errfp
)
{
/* Create a pipe to make the stderr of the child process
available as a stream. */
errpipe
.
hd
=
_assuan_w32ce_prepare_pipe
(
&
errpipe
.
rvid
,
0
);
if
(
errpipe
.
hd
==
INVALID_HANDLE_VALUE
)
{
log_error
(
"_assuan_w32ce_prepare_pipe failed: %s
\n
"
,
w32_strerror
(
-1
));
gpg_err_set_errno
(
EIO
);
/* Fixme release other stuff/kill feeder. */
return
gpg_error_from_syserror
();
}
syshd
.
type
=
ES_SYSHD_HANDLE
;
syshd
.
u
.
handle
=
errpipe
.
hd
;
err
=
0
;
errfp
=
es_sysopen
(
&
syshd
,
"r"
);
if
(
!
errfp
)
{
err
=
gpg_err_make
(
errsource
,
gpg_err_code_from_syserror
());
log_error
(
"error opening pipe stream: %s
\n
"
,
gpg_strerror
(
err
));
CloseHandle
(
errpipe
.
hd
);
return
err
;
}
log_debug
(
"%s: errpipe %p created; hd=%p rvid=%d
\n
"
,
__func__
,
errfp
,
errpipe
.
hd
,
errpipe
.
rvid
);
errpipe
.
hd
=
INVALID_HANDLE_VALUE
;
/* Now owned by the ERRFP. */
}
/* Build the command line. */
err
=
build_w32_commandline
(
argv
,
inpipe
.
rvid
,
outpipe
.
rvid
,
errpipe
.
rvid
,
&
cmdline
);
if
(
err
)
{
/* Fixme release other stuff/kill feeder. */
CloseHandle
(
errpipe
.
hd
);
return
err
;
}
log_debug
(
"CreateProcess, path=`%s' cmdline=`%s'
\n
"
,
pgmname
,
cmdline
);
if
(
!
create_process
(
pgmname
,
cmdline
,
&
pi
))
{
log_error
(
"CreateProcess failed: %s
\n
"
,
w32_strerror
(
-1
));
xfree
(
cmdline
);
/* Fixme release other stuff/kill feeder. */
CloseHandle
(
errpipe
.
hd
);
return
gpg_error
(
GPG_ERR_GENERAL
);
}
xfree
(
cmdline
);
cmdline
=
NULL
;
/* Note: The other end of the pipe is a rendezvous id and thus there
is no need for a close. */
log_debug
(
"CreateProcess ready: hProcess=%p hThread=%p"
" dwProcessID=%d dwThreadId=%d
\n
"
,
pi
.
hProcess
,
pi
.
hThread
,
(
int
)
pi
.
dwProcessId
,
(
int
)
pi
.
dwThreadId
);
/* Process has been created suspended; resume it now. */
ResumeThread
(
pi
.
hThread
);
CloseHandle
(
pi
.
hThread
);
if
(
r_outfp
)
*
r_outfp
=
outfp
;
if
(
r_errfp
)
*
r_errfp
=
errfp
;
*
pid
=
handle_to_pid
(
pi
.
hProcess
);
return
0
;
}
/* Simplified version of gnupg_spawn_process. This function forks and
then execs PGMNAME, while connecting INFD to stdin, OUTFD to stdout
and ERRFD to stderr (any of them may be -1 to connect them to
/dev/null). The arguments for the process are expected in the NULL
terminated array ARGV. The program name itself should not be
included there. Calling gnupg_wait_process is required.
Returns 0 on success or an error code. */
gpg_error_t
gnupg_spawn_process_fd
(
const
char
*
pgmname
,
const
char
*
argv
[],
int
infd
,
int
outfd
,
int
errfd
,
pid_t
*
pid
)
{
gpg_error_t
err
;
PROCESS_INFORMATION
pi
=
{
NULL
};
char
*
cmdline
;
/* Setup return values. */
*
pid
=
(
pid_t
)(
-1
);
if
(
infd
!=
-1
||
outfd
!=
-1
||
errfd
!=
-1
)
return
gpg_error
(
GPG_ERR_NOT_SUPPORTED
);
/* Build the command line. */
err
=
build_w32_commandline
(
argv
,
0
,
0
,
0
,
&
cmdline
);
if
(
err
)
return
err
;
log_debug
(
"CreateProcess, path=`%s' cmdline=`%s'
\n
"
,
pgmname
,
cmdline
);
if
(
!
create_process
(
pgmname
,
cmdline
,
&
pi
))
{
log_error
(
"CreateProcess(fd) failed: %s
\n
"
,
w32_strerror
(
-1
));
xfree
(
cmdline
);
return
gpg_error
(
GPG_ERR_GENERAL
);
}
xfree
(
cmdline
);
cmdline
=
NULL
;
log_debug
(
"CreateProcess(fd) ready: hProcess=%p hThread=%p"
" dwProcessID=%d dwThreadId=%d
\n
"
,
pi
.
hProcess
,
pi
.
hThread
,
(
int
)
pi
.
dwProcessId
,
(
int
)
pi
.
dwThreadId
);
/* Process has been created suspended; resume it now. */
ResumeThread
(
pi
.
hThread
);
CloseHandle
(
pi
.
hThread
);
*
pid
=
handle_to_pid
(
pi
.
hProcess
);
return
0
;
}
/* See exechelp.h for a description. */
gpg_error_t
gnupg_wait_process
(
const
char
*
pgmname
,
pid_t
pid
,
int
hang
,
int
*
exitcode
)
{
gpg_err_code_t
ec
;
HANDLE
proc
=
fd_to_handle
(
pid
);
int
code
;
DWORD
exc
;
if
(
exitcode
)
*
exitcode
=
-1
;
if
(
pid
==
(
pid_t
)(
-1
))
return
gpg_error
(
GPG_ERR_INV_VALUE
);
/* FIXME: We should do a pth_waitpid here. However this has not yet
been implemented. A special W32 pth system call would even be
better. */
code
=
WaitForSingleObject
(
proc
,
hang
?
INFINITE
:
0
);
switch
(
code
)
{
case
WAIT_TIMEOUT
:
ec
=
GPG_ERR_TIMEOUT
;
break
;
case
WAIT_FAILED
:
log_error
(
_
(
"waiting for process %d to terminate failed: %s
\n
"
),
(
int
)
pid
,
w32_strerror
(
-1
));
ec
=
GPG_ERR_GENERAL
;
break
;
case
WAIT_OBJECT_0
:
if
(
!
GetExitCodeProcess
(
proc
,
&
exc
))
{
log_error
(
_
(
"error getting exit code of process %d: %s
\n
"
),
(
int
)
pid
,
w32_strerror
(
-1
)
);
ec
=
GPG_ERR_GENERAL
;
}
else
if
(
exc
)
{
log_error
(
_
(
"error running `%s': exit status %d
\n
"
),
pgmname
,
(
int
)
exc
);
if
(
exitcode
)
*
exitcode
=
(
int
)
exc
;
ec
=
GPG_ERR_GENERAL
;
}
else
{
if
(
exitcode
)
*
exitcode
=
0
;
ec
=
0
;
}
break
;
default
:
log_error
(
"WaitForSingleObject returned unexpected "
"code %d for pid %d
\n
"
,
code
,
(
int
)
pid
);
ec
=
GPG_ERR_GENERAL
;
break
;
}
return
gpg_err_make
(
GPG_ERR_SOURCE_DEFAULT
,
ec
);
}
void
gnupg_release_process
(
pid_t
pid
)
{
if
(
pid
!=
(
pid_t
)
INVALID_HANDLE_VALUE
)
{
HANDLE
process
=
(
HANDLE
)
pid
;
CloseHandle
(
process
);
}
}
/* Spawn a new process and immediatley detach from it. The name of
the program to exec is PGMNAME and its arguments are in ARGV (the
programname is automatically passed as first argument).
Environment strings in ENVP are set. An error is returned if
pgmname is not executable; to make this work it is necessary to
provide an absolute file name. All standard file descriptors are
connected to /dev/null. */
gpg_error_t
gnupg_spawn_process_detached
(
const
char
*
pgmname
,
const
char
*
argv
[],
const
char
*
envp
[]
)
{
gpg_error_t
err
;
char
*
cmdline
;
PROCESS_INFORMATION
pi
=
{
NULL
};
(
void
)
envp
;
/* Build the command line. */
err
=
build_w32_commandline
(
argv
,
0
,
0
,
0
,
&
cmdline
);
if
(
err
)
return
err
;
/* Note: There is no detached flag under CE. */
log_debug
(
"CreateProcess, path=`%s' cmdline=`%s'
\n
"
,
pgmname
,
cmdline
);
if
(
!
create_process
(
pgmname
,
cmdline
,
&
pi
))
{
log_error
(
"CreateProcess(detached) failed: %s
\n
"
,
w32_strerror
(
-1
));
xfree
(
cmdline
);
return
gpg_error
(
GPG_ERR_GENERAL
);
}
xfree
(
cmdline
);
cmdline
=
NULL
;
log_debug
(
"CreateProcess(detached) ready: hProcess=%p hThread=%p"
" dwProcessID=%d dwThreadId=%d
\n
"
,
pi
.
hProcess
,
pi
.
hThread
,
(
int
)
pi
.
dwProcessId
,
(
int
)
pi
.
dwThreadId
);
/* Process has been created suspended; resume it now. */
ResumeThread
(
pi
.
hThread
);
CloseHandle
(
pi
.
hThread
);
return
0
;
}
/* Kill a process; that is send an appropriate signal to the process.
gnupg_wait_process must be called to actually remove the process
from the system. An invalid PID is ignored. */
void
gnupg_kill_process
(
pid_t
pid
)
{
if
(
pid
!=
(
pid_t
)
INVALID_HANDLE_VALUE
)
{
HANDLE
process
=
(
HANDLE
)
pid
;
/* Arbitrary error code. */
TerminateProcess
(
process
,
1
);
}
}
File Metadata
Details
Attached
Mime Type
text/x-c
Expires
Sat, May 10, 8:47 AM (1 d, 18 h)
Storage Engine
local-disk
Storage Format
Raw Data
Storage Handle
5f/16/2c6774ebe3bcaf0f4035d4160330
Attached To
rG GnuPG
Event Timeline
Log In to Comment