mirrors/tres
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

quality: Add test cases for meter_mod message

Browse source
This commit is contained in:
Eishun Kondoh 2019-04-29 03:07:31 +09:00
parent a0ee397921
commit c5e38155e1
4 changed files with 102 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

22
lib/openflow/meter_band/drop.ex
View file

@ -6,17 +6,17 @@ defmodule Openflow.MeterBand.Drop do
alias __MODULE__
def new(options) do
rate = Keyword.get(options, :rate, 0)
burst_size = Keyword.get(options, :burst_size, 0)
%Drop{rate: rate, burst_size: burst_size}
end
@type t :: %Drop{rate: 0..0xFFFFFFFF, burst_size: 0..0xFFFFFFFF}
def read(<<1::16, 16::16, rate::32, burst_size::32, _::size(4)-unit(8)>>) do
%Drop{rate: rate, burst_size: burst_size}
end
@spec new(rate: 0..0xFFFFFFFF, burst_size: 0..0xFFFFFFFF) :: t()
def new(options),
do: %Drop{rate: options[:rate] || 0, burst_size: options[:burst_size] || 0}
def to_binary(%Drop{rate: rate, burst_size: burst_size}) do
<<1::16, 16::16, rate::32, burst_size::32, 0::size(4)-unit(8)>>
end
@spec read(<<_::128>>) :: t()
def read(<<1::16, 16::16, rate::32, burst_size::32, _::size(4)-unit(8)>>),
do: %Drop{rate: rate, burst_size: burst_size}
@spec to_binary(t()) :: <<_::128>>
def to_binary(%Drop{rate: rate, burst_size: burst_size}),
do: <<1::16, 16::16, rate::32, burst_size::32, 0::size(4)-unit(8)>>
end

32
lib/openflow/meter_band/remark.ex
View file

@ -7,18 +7,30 @@ defmodule Openflow.MeterBand.Remark do
alias __MODULE__
@type t :: %Remark{
rate: 0..0xFFFFFFFF,
burst_size: 0..0xFFFFFFFF,
prec_level: 0..0xFF
}
@spec new(
rate: 0..0xFFFFFFFF,
burst_size: 0..0xFFFFFFFF,
prec_level: 0..0xFF
) :: t()
def new(options) do
rate = Keyword.get(options, :rate, 0)
burst_size = Keyword.get(options, :burst_size, 0)
prec_level = Keyword.get(options, :prec_level, 0)
%Remark{rate: rate, burst_size: burst_size, prec_level: prec_level}
%Remark{
rate: options[:rate] || 0,
burst_size: options[:burst_size] || 0,
prec_level: options[:prec_level] || 0
}
end
def read(<<2::16, 16::16, rate::32, burst_size::32, prec_level::8, _::size(3)-unit(8)>>) do
%Remark{rate: rate, burst_size: burst_size, prec_level: prec_level}
end
@spec read(<<_::128>>) :: t()
def read(<<2::16, 16::16, rate::32, burst_size::32, prec_level::8, _::size(3)-unit(8)>>),
do: %Remark{rate: rate, burst_size: burst_size, prec_level: prec_level}
def to_binary(%Remark{rate: rate, burst_size: burst_size, prec_level: prec_level}) do
<<2::16, 16::16, rate::32, burst_size::32, prec_level::8, 0::size(3)-unit(8)>>
end
@spec to_binary(t()) :: <<_::128>>
def to_binary(%Remark{rate: rate, burst_size: burst_size, prec_level: prec_level}),
do: <<2::16, 16::16, rate::32, burst_size::32, prec_level::8, 0::size(3)-unit(8)>>
end

25
lib/openflow/meter_mod.ex
View file

@ -12,10 +12,33 @@ defmodule Openflow.MeterMod do
alias __MODULE__
@type command :: :add | :modify | :delete
@type t :: %MeterMod{
version: 4,
xid: 0..0xFFFFFFFF,
datapath_id: String.t() | nil,
aux_id: 0..0xFF | nil,
command: command(),
flags: [:kbps | :pktps | :burst | :stats],
bands: [Openflow.MeterBand.Drop.t() | Openflow.MeterBand.Remark.t()]
}
@spec ofp_type() :: 29
def ofp_type, do: 29
@spec new(
version: 4,
xid: 0..0xFFFFFFFF,
datapath_id: String.t() | nil,
aux_id: 0..0xFF | nil,
command: command(),
flags: [:kbps | :pktps | :burst | :stats],
bands: [Openflow.MeterBand.Drop.t() | Openflow.MeterBand.Remark.t()]
) :: t()
def new(options \\ []) do
%MeterMod{
xid: options[:xid] || 0,
command: options[:command] || :add,
flags: options[:flags] || [],
meter_id: options[:meter_id] || 0,
@ -23,6 +46,7 @@ defmodule Openflow.MeterMod do
}
end
@spec read(<<_::64, _::_*128>>) :: t()
def read(<<command_int::16, flags_int::16, meter_id_int::32, bands_bin::bytes>>) do
command = Openflow.Enums.to_atom(command_int, :meter_mod_command)
flags = Openflow.Enums.int_to_flags(flags_int, :meter_flags)
@ -31,6 +55,7 @@ defmodule Openflow.MeterMod do
%MeterMod{command: command, flags: flags, meter_id: meter_id, bands: bands}
end
@spec to_binary(t()) :: <<_::64, _::_*128>>
def to_binary(%MeterMod{command: command, flags: flags, meter_id: meter_id, bands: bands}) do
command_int = Openflow.Enums.to_int(command, :meter_mod_command)
flags_int = Openflow.Enums.flags_to_int(flags, :meter_flags)