mulit: implement aggregate stats request for 0x01

Author: seliopou

async/Async_OpenFlow.mli

@@ -201,6 +201,7 @@ module OpenFlow0x01 : sig
 
     val send_pkt_out : t -> Client_id.t -> OpenFlow0x01_Core.packetOut -> (unit, exn) Deferred.Result.t
     val barrier : t -> Client_id.t -> (unit, exn) Result.t Deferred.t
+    val stats : t -> Client_id.t -> OpenFlow0x01_Core.pattern -> (OpenFlow0x01_Stats.aggregateStats, exn) Deferred.Result.t
   end
 
 end
@@ -225,7 +226,6 @@ module OpenFlow0x04 : sig
 
     val send_pkt_out : t -> Client_id.t -> OpenFlow0x04_Core.packetOut -> (unit, exn) Deferred.Result.t
     val barrier : t -> Client_id.t -> (unit, exn) Result.t Deferred.t
-
   end
 
 end

async/Async_OpenFlow0x01.ml

@@ -224,4 +224,15 @@ module Controller = struct
     send_txn_with t sw_id M.BarrierRequest (function
       | M.BarrierReply -> Result.Ok ()
       | _              -> assert false)
+
+  let stats t sw_id pattern =
+    let open OpenFlow0x01_Stats in
+    let msg = AggregateRequest
+      { as_of_match = pattern
+      ; as_table_id = 0xff
+      ; as_out_port = None }
+    in
+    send_txn_with t sw_id (M.StatsRequestMsg msg) (function
+      | M.StatsReplyMsg (AggregateFlowRep r) -> Result.Ok r
+      | _                                    -> assert false)
 end