package hack_parallel

You can search for identifiers within the package.

in-package search v0.2.0

Parallel and shared memory library

Install

Dune Dependency

github.com Readme Edit opam file Versions (3)

Authors

F

Facebook. Modifications by Rijnard van Tonder

Maintainers

R

Rijnard van Tonder <rvantonder@gmail.com>

Sources

1.0.1.tar.gz

md5=ba7c72bc207e326b72e294fc76f6ad2c

sha512=5020d47f97bea2f88e2a40411894d03232a7f2282606926c93c7d4c96d72e94a966be852897a9b16f7e0893ba376512045abb9d93020a7c03c3def4f3d918f8e

doc/hack_parallel.utils/Timeout/index.html

Module `Timeout`Source

* Copyright (c) 2015, Facebook, Inc. * All rights reserved. * * This source code is licensed under the BSD-style license found in the * LICENSE file in the root directory of this source tree. An additional grant * of patent rights can be found in the PATENTS file in the same directory. *

type t

Sourceexception Timeout

val with_timeout : 
  timeout:int ->
  ?on_timeout:(unit -> unit) ->
  do_:(t -> 'a) ->
  'a

val check_timeout : t -> unit

type in_channel

val open_in : string -> in_channel

val close_in : in_channel -> unit

val close_in_noerr : in_channel -> unit

val in_channel_of_descr : Unix.file_descr -> in_channel

val descr_of_in_channel : in_channel -> Unix.file_descr

val input : ?timeout:t -> in_channel -> bytes -> int -> int -> int

val really_input : ?timeout:t -> in_channel -> bytes -> int -> int -> unit

val input_char : ?timeout:t -> in_channel -> char

val input_line : ?timeout:t -> in_channel -> string

val input_value : ?timeout:t -> in_channel -> 'a

val open_process : string -> string array -> in_channel * out_channel

val open_process_in : string -> string array -> in_channel

val close_process_in : in_channel -> Unix.process_status

val read_process : 
  timeout:int ->
  ?on_timeout:(unit -> unit) ->
  reader:(t -> in_channel -> out_channel -> 'a) ->
  string ->
  string array ->
  'a

val open_connection : ?timeout:t -> Unix.sockaddr -> in_channel * out_channel

Source

val read_connection : 
  timeout:int ->
  ?on_timeout:(unit -> unit) ->
  reader:(t -> in_channel -> out_channel -> 'a) ->
  Unix.sockaddr ->
  'a

val shutdown_connection : in_channel -> unit