Comment author: administrator

Les primitives d'ouverture de fichiers devraient être non bloquantes
en mode multithread.
Il me semble (et mon experience dans POESIA tend à le montrer) que
l'ouverture d'un FIFO en écriture bloque tout le processus, et pas
seulement le thread Ocaml qui fait open. C'est à mon avis un bogue
(que je trouve génant, mais je reconnais que c'est tordu) du runtime
OCaml.

Ca marche normalement avec les threads systeme (seul le thread faisant open()
est bloque). Avec les threads bytecode, il est essentiellement impossible
d'implementer le meme comportement: il n'y a pas d'equivalent de select()
pour demander "previens-moi quand je pourrais ouvrir ce pipe nomme sans
bloquer";
quant a ouvrir systematiquement en mode non bloquant, ca change le comportement
de l'application, donc c'est a l'application de le demander en mettant l'option
NONBLOCK sur l'appel a open.

• Xavier Leroy

Comment author: administrator

"Xavier" == Xavier Leroy caml-bugs@pauillac.inria.fr writes:

>> Les primitives d'ouverture de fichiers devraient être non
>> bloquantes en mode multithread.  Il me semble (et mon
>> experience dans POESIA tend à le montrer) que l'ouverture d'un
>> FIFO en écriture bloque tout le *processus*, et pas seulement
>> le thread Ocaml qui fait open. C'est à mon avis un bogue (que
>> je trouve génant, mais je reconnais que c'est tordu) du runtime
>> OCaml.

Xavier> Ca marche normalement avec les threads systeme (seul le
Xavier> thread faisant open() est bloque). [...]

Merci de ta réponse, mais en es tu sûr? Ca ne correspond pas à mes
observations!

La fonction open_descriptor_in de ocaml/byterun/io.c (cvs rev 1.62) ne
contient pas d'appel à enter_blocking_section & leave_blocking_section

Mais je reconnais que je n'ai pas tout compris de io.c; il y a
sûrement un détail qui m'échappe?

(Sinon, tu peux piquer sans vergogne le petit bout de code qui fait
usleep et uname dans Poesia), le voici pour te faciliter la tâche:

void poesiamonicap_usleep_ml(value usec_v)
{
// this is hugly, but it is only declared in ocaml-3.06/byterun/signals.h
CAMLextern void enter_blocking_section (void);
CAMLextern void leave_blocking_section (void);
CAMLparam1(usec_v);
long usec = Long_val(usec_v);
enter_blocking_section();
if (usec>=0) usleep(usec);
leave_blocking_section();
CAMLreturn0;
} // end of poesiamonicap_usleep_ml

value
poesiamonicap_uname_ml(void) {
struct utsname uts;
CAMLparam0();
CAMLlocal1(res_v);
CAMLlocal5(sysname_v,nodename_v,release_v,version_v,machine_v);
memset(&uts, 0, sizeof(uts));
if (uname(&uts)) failwith("Util.uname failed");
sysname_v = copy_string(uts.sysname);
nodename_v = copy_string(uts.nodename);
release_v = copy_string(uts.release);
version_v = copy_string(uts.version);
machine_v = copy_string(uts.machine);
res_v = alloc_tuple(5);
Store_field(res_v, 0, sysname_v);
Store_field(res_v, 1, nodename_v);
Store_field(res_v, 2, release_v);
Store_field(res_v, 3, version_v);
Store_field(res_v, 4, machine_v);
CAMLreturn(res_v);
} /* end of poesiamonicap_uname_ml */

--

Basile STARYNKEVITCH http://starynkevitch.net/Basile/
email: basilestarynkevitchnet
alias: basiletunesorg
8, rue de la Faïencerie, 92340 Bourg La Reine, France

Comment author: administrator

XL, 2003-02-11: turned sys_open and unix_open into blocking sections. This
fixes the
issue with system threads. For bytecode threads, no way to work around this
issue.