OCaml: Lwt и неблокирующий сокет

Question

Я хотел попробовать модуль Lwt_unix для простого клиента, который считывает данные в сокете, пока не будет ничего, что можно прочитать. Некоторые говорили мне, что Lwt создать не блокирующие сокеты, но с моим кодом, он по-прежнему блокируют:

open Lwt 
open Unix 

(* ocamlfind ocamlc -o lwt_socket_client -package lwt,lwt.unix,unix -linkpkg -g lwt_socket_client.ml *) 
let host = Unix.inet_addr_loopback 
let port = 6600 

let create_socket() = 
    let sock = Lwt_unix.socket PF_INET SOCK_STREAM 0 in 
    Lwt_unix.set_blocking sock false; 
    sock 

let s_read sock maxlen = 
    let str = Bytes.create maxlen in 
    let rec _read sock acc = 
    Lwt.ignore_result(Lwt_io.write_line Lwt_io.stdout "_read"); 
    Lwt_unix.read sock str 0 maxlen >>= fun recvlen -> 
    Lwt.ignore_result(Lwt_io.write_line Lwt_io.stdout (string_of_int recvlen)); 
    if recvlen = 0 then Lwt.return (acc) 
    else _read sock (acc^(String.sub str 0 recvlen)) 
    in _read sock "" 

let socket_read sock = 
    Lwt.ignore_result(Lwt_unix.connect sock @@ ADDR_INET(host, port)); 
    s_read sock 1024 >>= fun answer -> 
    Lwt_io.write_line Lwt_io.stdout answer 

let() = 
    let sock = create_socket() in 
    Lwt_main.run (socket_read sock) 

Если бы я попробовать этот пример с в термине:

echo "totoche" | netcat -l 127.0.0.1 -p 6600 

то результат:

./lwt_socket_client 
_read 
8 
_read 

Какой блок, пока я не попал Ctrl +гр.

Я попробовал оба с:

Lwt_unix.set_blocking sock false; 

и

Lwt_unix.set_blocking sock true; 

и, конечно, без этой линии, но он по-прежнему блокирует. Что я делаю не так?

Для получения дополнительной информации, один из моего предыдущего вопроса: OCaml non-blocking client socket

Answer 1

Концептуально Lwt_unix.readвсегда блокирует LWT нить, но никогда блокирует весь процесс - если процесс не ждет, что LWT нить, и нет никаких других потоков LWT для запуска. Lwt_unix.set_blocking не влияет на это поведение. Он просто меняет настройки на базовом сокете и, следовательно, стратегия, используемая внутри Lwt, чтобы избежать блокировки процесса.

Таким образом, как уже упоминалось, в @ThomasLeonard «идиоматичен LWT» способ сделать неблокирующая read (с точки зрения процесса) просто запустить дополнительные потоки LWT одновременно с Lwt_unix.read.

---

Что касается конкретного кода в этом вопросе, лежащий в основе read системного вызов завершается с EAGAIN или EWOULDBLOCK (в зависимости от системы), если основной сокет неблокирующий, но никаких данных не доступны, - а не успех с чтение нулевых байтов, что указывает на то, что сокет был закрыт.

Unix.read преобразует это в исключение Unix.Unix_error Unix.EAGAIN (соответственно Unix.Unix_error Unix.EWOULDBLOCK). Lwt_unix.read повторных попыток Unix.read в этом случае. Таким образом, вы не можете (в настоящее время) напрямую реагировать на неблокирующие чтения, которые терпят неудачу при использовании Lwt_unix.read.

Если вы хотите/нужно этот уровень управления на сокет, созданный с Lwt_unix, вы можете сделать это:

Lwt_unix.set_blocking sock false; 

try 
    Unix.read (Lwt_unix.unix_file_descr sock) str 0 maxlen 
with Unix.Unix_error (Unix.EAGAIN | Unix.EWOULDBLOCK) -> 
    (* Handle no data available. *) 

---

EDIT: Кроме того, как уже упоминалось @ThomasLeonard, некоторые виды использования ignore_result в вашем коде должно быть, вероятно, e >>= fun() -> e'. Это заставляет Lwt ждать e для завершения перед запуском e'. В частности, вы должны сделать это для Lwt_unix.connect.

Answer 2

На OS X, я получаю:

> ./lwt_socket_client 
_read 
8 
_read 
0 
totoche 

Который, кажется, что вы просите. Однако я не уверен, что это поведение полезно, поскольку оно зависит от того, как ядро ​​планирует работу. Что ты пытаешься сделать? Если вы хотите, например, переходите к чему-то еще, ожидая ввода, просто запустите второй поток Lwt параллельно с прочитанным (блокирующим).