Channel (u.7b4642b4a2e37a33e5997c38da913bdb.awa.0.1.0.doc.awa.Awa.Channel)

Sourcetype state =

| Open
| Sent_close

Sourceval state_of_sexp : Sexplib0.Sexp.t -> state

Sourceval sexp_of_state : state -> Sexplib0.Sexp.t

Sourcetype channel_end = {

id : int32;
win : int32;
max_pkt : int32;

}

Sourceval channel_end_of_sexp : Sexplib0.Sexp.t -> channel_end

Sourceval sexp_of_channel_end : channel_end -> Sexplib0.Sexp.t

Sourcetype channel = {

us : channel_end;
them : channel_end;
state : state;
tosend : Cstruct_sexp.t;

}

Sourceval channel_of_sexp : Sexplib0.Sexp.t -> channel

Sourceval sexp_of_channel : channel -> Sexplib0.Sexp.t

Sourceval compare : channel -> channel -> int

Sourcetype t = channel

Sourcemodule Ordered : sig ... end

Sourceval make_end : int32 -> int32 -> int32 -> channel_end

Sourceval make : us:channel_end -> them:channel_end -> channel

Sourceval to_string : channel -> string

Source

val input_data : 
  channel ->
  Cstruct.t ->
  (channel * Cstruct.t * Ssh.message option, string) result

Source

val output_data : 
  channel ->
  Cstruct_sexp.t ->
  (channel * Ssh.message list, string) result

Source

val adjust_window : 
  channel ->
  int32 ->
  (channel * Ssh.message list, string) result

Sourcemodule Channel_map : sig ... end

Sourcetype db = channel Channel_map.t

Sourceval empty_db : 'a Channel_map.t

Sourceval is_empty : 'a Channel_map.t -> bool

Sourceval next_free : 'a Channel_map.t -> int32 option

Source

val add : 
  id:int32 ->
  win:int32 ->
  max_pkt:int32 ->
  channel Channel_map.t ->
  (channel * channel Channel_map.t, [> `No_channels_left ]) result

Sourceval update : channel -> channel Channel_map.t -> channel Channel_map.t

Sourceval remove : Channel_map.key -> 'a Channel_map.t -> 'a Channel_map.t

Sourceval lookup : Channel_map.key -> 'a Channel_map.t -> 'a option

Sourceval id : channel -> int32

Sourceval their_id : channel -> int32