http://www.linux-nantes.org/~fmonnier/ocaml/ocaml-wrapping-c.phpのガイドに基づいて、CZMQ 用の OCaml バインディングをいくつか作成しました。たとえば、zstr_send は次のとおりです。
CAMLprim value
caml_zstr_send(value socket_val, value string_val)
{
CAMLparam2 (socket_val, string_val);
void *sock = CAML_CZMQ_zsocket_val(socket_val);
char *string = String_val(string_val);
int rc = zstr_send(sock, string);
CAMLreturn (Val_int(rc));
}
ほとんどのコードでこれらのバインディングを使用してメッセージを送受信できます。ただし、シグナルハンドラー内で送受信を行い、他のコードのバックグラウンドでメッセージパッシングを行うシナリオがあります。次の簡単な例を見てください。
open ZMQ
exception SocketBindFailure
let bg_ctx = zctx_new ();;
let pub_sock = zsocket_new bg_ctx ZMQ_PUB;;
let handler _ =
print_endline "enter handler";
print_endline (string_of_int (zstr_send pub_sock "hello"));
print_endline "end handler";
;;
let () =
(try (
(* bind pub socket *)
let rc = zsocket_bind pub_sock "tcp://*:5556" in
if (rc < 0) then ( raise SocketBindFailure );
Sys.set_signal
Sys.sigalrm
(Sys.Signal_handle handler);
ignore
(Unix.setitimer
Unix.ITIMER_REAL
{ Unix.it_interval = 0.01 ; Unix.it_value = 0.01 });
(* do some work *)
)
with
| SocketBindFailure -> raise SocketBindFailure)
;;
トップレベルから、これは出力で失敗します:
enter handler
0
end handler
Fatal error: exception Sys_blocked_io
上記の OCaml に似た C コードは問題なく動作します。この例外を引き起こしている方程式に OCaml が追加しているものは何ですか?