OpenFlow0x04_Plugin (p.frenetic.5.0.5.doc.frenetic.async.Frenetic_async.OpenFlow0x04

Source

val send_message : 
  Async.Writer.t ->
  Frenetic_kernel.OpenFlow_Header.xid ->
  Frenetic_kernel.OpenFlow0x04.Message.t ->
  unit

Source

val implement_group_table : 
  Async.Writer.t ->
  Frenetic_kernel.GroupTable0x04.t ->
  unit

Sourceval mask_meta : int -> int64 Frenetic_kernel.OpenFlow0x04.mask

Source

val implement_flow : 
  Async.Writer.t ->
  Frenetic_netkat.Local_compiler.t ->
  Frenetic_netkat.Local_compiler.flow_layout ->
  Frenetic_kernel.OpenFlow.switchId ->
  unit

Source

val implement_tolerant_flow : 
  Async.Writer.t ->
  Frenetic_netkat.Local_compiler.t ->
  Frenetic_kernel.Net.Net.Topology.t ->
  Frenetic_kernel.OpenFlow.switchId ->
  unit

Source

val process_message : 
  Frenetic_kernel.OpenFlow_Header.xid ->
  Frenetic_kernel.OpenFlow0x04.Message.t ->
  (Frenetic_kernel.OpenFlow_Header.xid ->
    Frenetic_kernel.OpenFlow0x04.Message.t ->
    unit) ->
  (Frenetic_kernel.OpenFlow.switchId -> unit) ->
  unit

Source

val read_respond_loop : 
  Async.Reader.t ->
  (Frenetic_kernel.OpenFlow_Header.xid ->
    Frenetic_kernel.OpenFlow0x04.Message.t ->
    unit) ->
  (Frenetic_kernel.OpenFlow.switchId -> unit) ->
  unit ->
  [ `Finished of unit | `Repeat of unit ] Async.Deferred.t

Source

val client_handler : 
  Async.Reader.t ->
  (Frenetic_kernel.OpenFlow_Header.xid ->
    Frenetic_kernel.OpenFlow0x04.Message.t ->
    unit) ->
  (Frenetic_kernel.OpenFlow.switchId -> unit) ->
  unit Async.Deferred.t

Source

val main : 
  int ->
  string ->
  Frenetic_netkat.Local_compiler.flow_layout ->
  unit ->
  unit

Sourceval fault_tolerant_main : int -> string -> string -> unit -> unit