managing OS processes - Erlang Programming

The old Google Groups will be going away soon, but your browser is incompatible with the new version.
Message from discussion managing OS processes
Received-SPF: pass (google.com: domain of erlang-questions-boun...@erlang.org designates 192.121.151.104 as permitted sender) client-ip=192.121.151.104;
MIME-Version: 1.0
In-Reply-To: <CA+Tk8fzRFMicCr5jMyyTSwQxFJsz2XFc5-VW1iBpcNRvJYo...@mail.gmail.com>
References: <CAJNb-9pg8s5qJ3p-qzqSwhA47XycP+GfxCRNo0ELP0KENdu...@mail.gmail.com>
 <CADOS1qKshuW-5AiVCbDbfJFOcoCJ0w=_nyDZ6isxb_HvTQ9...@mail.gmail.com>
 <CA+Tk8fzRFMicCr5jMyyTSwQxFJsz2XFc5-VW1iBpcNRvJYo...@mail.gmail.com>
Date: Tue, 29 May 2012 12:13:16 +0100
Message-ID: <CAH+xwdBT1MY3i7MZNi7qGAL+S5MAt7dK9kozRX5-NPhXDbu...@mail.gmail.com>
From: Robert Raschke <rtrli...@googlemail.com>
To: erlang-questi...@erlang.org
Subject: Re: [erlang-questions] managing OS processes
Precedence: list
Content-Type: multipart/mixed; boundary="===============5600555872926310467=="
Errors-To: erlang-questions-boun...@erlang.org
Sender: erlang-questions-boun...@erlang.org

--===============5600555872926310467==
Content-Type: multipart/alternative; boundary=14dae9340435d7775704c12aeb34

--14dae9340435d7775704c12aeb34
Content-Type: text/plain; charset=UTF-8

On Tue, May 29, 2012 at 10:21 AM, Ciprian Dorin Craciun <
ciprian.crac...@gmail.com> wrote:

>    Hello all!
>
>    I don't think its the right way (although it seems to be suggested
> by the Erlang manual or somewhere else I've read it), but the way I
> did it was to write a small C program that is the one "babysitting"
> the real process, and a small Erlang wrapper.
>
>    The code is here (Apache 2.0 licensed):
>
> https://github.com/cipriancraciun/mosaic-node/tree/development/applications/mosaic-harness/sources
>
> https://github.com/cipriancraciun/mosaic-node/blob/development/applications/mosaic-harness/sources/mosaic_harness_backend.erl
>
> https://github.com/cipriancraciun/mosaic-node/blob/development/applications/mosaic-harness/sources/mosaic_harness.c
>
>    The C program allows the following:
>    * it uses a small protocol based on JSON to communicate with the
> Erlang wrapper, using solely `stdin` / `stdout` between itself and
> Erlang, and between itself and the "babysitted" program;
>    * it allows a single process to be executed at a time (controlling
> environment, arguments, and working directory); (it could be extended
> to multiple process in parallel if wanted;) (but you can run it again
> if you want;)
>    * it allows a signal to be sent;
>    * it allows "exchange" messages to be sent to and from Erlang and
> the process;
>    * it allows brutal termination; (i.e. SIGKILL;)
>    * if `stdin` is closed by the Erlang side it kills the process;
>    * if `stdin` is closed by the process side it informs the Erlang side;
>
>    The C part is a self-contained `.c` file (of about 2k lines, of
> which 25% are structure definitions), written in an event driven
> manner (no threads), statically linkable, depending only on the
> `jansson` library (for JSON), using mostly POSIX syscalls.
>
>    I've successfully used it for about a year now (in non-production
> systems) and it behaves nicely.
>
>    If someone finds it useful I could try to extract it in a
> standalone project.
>
>    Ciprian.
>
>
I have a similar "proxy" to run killable external programs on Windows. It's
part of a larger project though, so I'd need to extract it. Would there be
interest for me to do that?

The approach is:

Start the proxy program using open_port/2 and send it the command to run,
the proxy then uses DuplicateHandle() and CreateProcessW() to kick off the
command in a separate OS process but with stdin/stdout/stderr forwarded
from the proxy to the new external command, prints the OS process id back
to Erlang and waits for the external OS process to finish.

Thus you now have your command running in the backgroud, able to
communicate using stdio with the Erlang process that started the proxy.

If you want to stop the command, you invoke the proxy with the process id
you got earlier and it kills it using TerminateProcess().

Robby

PS I vaguely remember getting the idea of passing back a process id for
later kill purposes from some open source app that uses a similar approach
to running killable commands from Erlang. Not that I can remember which one
at the mooment, sorry.

--14dae9340435d7775704c12aeb34
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<br><div class=3D"gmail_quote">On Tue, May 29, 2012 at 10:21 AM, Ciprian Do=
rin Craciun <span dir=3D"ltr">&lt;<a href=3D"mailto:ciprian.crac...@gmail.c=
om" target=3D"_blank">ciprian.crac...@gmail.com</a>&gt;</span> wrote:<br><b=
lockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px =
#ccc solid;padding-left:1ex">
 =C2=A0=C2=A0 Hello all!<br>
<br>
 =C2=A0 =C2=A0I don&#39;t think its the right way (although it seems to be =
suggested<br>
by the Erlang manual or somewhere else I&#39;ve read it), but the way I<br>
did it was to write a small C program that is the one &quot;babysitting&quo=
t;<br>
the real process, and a small Erlang wrapper.<br>
<br>
 =C2=A0 =C2=A0The code is here (Apache 2.0 licensed):<br>
 =C2=A0 =C2=A0 =C2=A0<a href=3D"https://github.com/cipriancraciun/mosaic-no=
de/tree/development/applications/mosaic-harness/sources" target=3D"_blank">=
https://github.com/cipriancraciun/mosaic-node/tree/development/applications=
/mosaic-harness/sources</a><br>

 =C2=A0 =C2=A0 =C2=A0<a href=3D"https://github.com/cipriancraciun/mosaic-no=
de/blob/development/applications/mosaic-harness/sources/mosaic_harness_back=
end.erl" target=3D"_blank">https://github.com/cipriancraciun/mosaic-node/bl=
ob/development/applications/mosaic-harness/sources/mosaic_harness_backend.e=
rl</a><br>

 =C2=A0 =C2=A0 =C2=A0<a href=3D"https://github.com/cipriancraciun/mosaic-no=
de/blob/development/applications/mosaic-harness/sources/mosaic_harness.c" t=
arget=3D"_blank">https://github.com/cipriancraciun/mosaic-node/blob/develop=
ment/applications/mosaic-harness/sources/mosaic_harness.c</a><br>

<br>
 =C2=A0 =C2=A0The C program allows the following:<br>
 =C2=A0 =C2=A0* it uses a small protocol based on JSON to communicate with =
the<br>
Erlang wrapper, using solely `stdin` / `stdout` between itself and<br>
Erlang, and between itself and the &quot;babysitted&quot; program;<br>
 =C2=A0 =C2=A0* it allows a single process to be executed at a time (contro=
lling<br>
environment, arguments, and working directory); (it could be extended<br>
to multiple process in parallel if wanted;) (but you can run it again<br>
if you want;)<br>
 =C2=A0 =C2=A0* it allows a signal to be sent;<br>
 =C2=A0 =C2=A0* it allows &quot;exchange&quot; messages to be sent to and f=
rom Erlang and<br>
the process;<br>
 =C2=A0 =C2=A0* it allows brutal termination; (i.e. SIGKILL;)<br>
 =C2=A0 =C2=A0* if `stdin` is closed by the Erlang side it kills the proces=
s;<br>
 =C2=A0 =C2=A0* if `stdin` is closed by the process side it informs the Erl=
ang side;<br>
<br>
 =C2=A0 =C2=A0The C part is a self-contained `.c` file (of about 2k lines, =
of<br>
which 25% are structure definitions), written in an event driven<br>
manner (no threads), statically linkable, depending only on the<br>
`jansson` library (for JSON), using mostly POSIX syscalls.<br>
<br>
 =C2=A0 =C2=A0I&#39;ve successfully used it for about a year now (in non-pr=
oduction<br>
systems) and it behaves nicely.<br>
<br>
 =C2=A0 =C2=A0If someone finds it useful I could try to extract it in a<br>
standalone project.<br>
<span class=3D"HOEnZb"><font color=3D"#888888"><br>
 =C2=A0 =C2=A0Ciprian.<br>
</font></span><div class=3D"HOEnZb"><div class=3D"h5"><br></div></div></blo=
ckquote><div><br>I have a similar &quot;proxy&quot; to run killable externa=
l programs on Windows. It&#39;s part of a larger project though, so I&#39;d=
 need to extract it. Would there be interest for me to do that?<br>
<br>The approach is:<br><br>Start the proxy program using open_port/2 and s=
end it the command to run, the proxy then uses DuplicateHandle() and Create=
ProcessW() to kick off the command in a separate OS process but with stdin/=
stdout/stderr forwarded from the proxy to the new external command, prints =
the OS process id back to Erlang and waits for the external OS process to f=
inish.<br>
<br>Thus you now have your command running in the backgroud, able to commun=
icate using stdio with the Erlang process that started the proxy.<br><br>If=
 you want to stop the command, you invoke the proxy with the process id you=
 got earlier and it kills it using TerminateProcess().<br>
<br>Robby<br><br>PS I vaguely remember getting the idea of passing back a p=
rocess id for later kill purposes from some open source app that uses a sim=
ilar approach to running killable commands from Erlang. Not that I can reme=
mber which one at the mooment, sorry.<br>
<br></div></div>

--14dae9340435d7775704c12aeb34--

--===============5600555872926310467==
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Content-Disposition: inline

_______________________________________________
erlang-questions mailing list
erlang-questi...@erlang.org
http://erlang.org/mailman/listinfo/erlang-questions

--===============5600555872926310467==--
Create a group - Google Groups - Google Home - Terms of Service - Privacy Policy
Account Options
