package hvsock

You can search for identifiers within the package.

in-package search v0.2.0

Bindings for Hyper-V AF_VSOCK

Install

Dune Dependency

github.com Readme Changelog ISC License Edit opam file Versions (4)

Authors

Maintainers

D

dave@recoil.org

Sources

hvsock-3.0.1.tbz

sha256=41659fb404dd3c7b694e7e5ab450df7af4240f4592b5b7c356d1598dbd32cac4

sha512=4d355c58a86630dfe77ae084d93f23f2666bc46b0161128d99f51db286d0e49afc4f8130596b513b850c601fad8029e2e6dfc40d50cd854bf330c280a654e164

doc/hvsock.lwt/Hvsock_lwt/Buffering/Make/index.html

Module `Buffering.Make`Source

Parameters

module Fn : S.FN

module RW : Hvsock.Af_common.S

Signature

Sourcetype 'a io = 'a Lwt.t

Sourcetype buffer = Cstruct.t

Sourcetype error = [

| `Unix of Unix.error

]

Sourceval pp_error : Format.formatter -> [< `Unix of Unix.error ] -> unit

Sourcetype write_error = [

| Mirage_flow.write_error
| error

]

Source

val pp_write_error : 
  Format.formatter ->
  [< `Closed | `Unix of Unix.error ] ->
  unit

Sourcetype flow = {

fd : RW.t;
read_buffers_max : int;
read_max : int;
mutable read_buffers : Cstruct.t list;
mutable read_buffers_len : int;
read_buffers_m : Mutex.t;
read_buffers_c : Condition.t;
read_histogram : Histogram.t;
mutable write_buffers : Cstruct.t list;
mutable write_buffers_len : int;
write_buffers_m : Mutex.t;
write_buffers_c : Condition.t;
write_buffers_max : int;
write_max : int;
mutable write_flushed : bool;
write_histogram : Histogram.t;
mutable closed : bool;
mutable shutdown_read : bool;
mutable read_thread_exit : bool;
mutable shutdown_write : bool;
mutable shutdown_write_complete : bool;
mutable write_error : bool;

}

Sourceval connect : ?message_size:int -> ?buffer_size:int -> RW.t -> flow

Sourceval detach : ('a -> 'b) -> 'a -> 'b Lwt.t

Sourceval wait_write_flush : flow -> unit

Sourceval close : flow -> unit Lwt.t

Sourceval shutdown_read : 'a -> unit Lwt.t

Sourceval shutdown_write : flow -> unit Lwt.t

Sourceval wait_for_data_or_eof : flow -> int -> unit

Sourceval read : flow -> ([> `Data of Cstruct.t | `Eof ], 'a) result Lwt.t

Sourceval read_into : 'a -> 'b -> 'c

Sourceval wait_for_space : flow -> int -> unit

Sourceval writev : flow -> Cstruct.t list -> (unit, [> `Closed ]) result Lwt.t

Sourceval write : flow -> Cstruct.t -> (unit, [> `Closed ]) result Lwt.t

On This Page

Parameters
Signature