Merge pull request #3 from shun159/refactoring_enum_macro
Refactored Enum macro
This commit is contained in:
commit
8e29f78f9c
10 changed files with 14006 additions and 530 deletions
BIN
bin/enum_gen
Executable file
BIN
bin/enum_gen
Executable file
Binary file not shown.
|
|
@ -11,7 +11,7 @@ config :tres,
|
||||||
callback_args: []
|
callback_args: []
|
||||||
|
|
||||||
config :logger,
|
config :logger,
|
||||||
level: :debug,
|
level: :info,
|
||||||
format: "$date $time [$level] $metadata$message\n",
|
format: "$date $time [$level] $metadata$message\n",
|
||||||
metadata: [:application],
|
metadata: [:application],
|
||||||
handle_otp_reports: true
|
handle_otp_reports: true
|
||||||
|
|
|
||||||
|
|
@ -19,6 +19,7 @@ defmodule Openflow.Echo.Reply do
|
||||||
data: options[:data] || ""
|
data: options[:data] || ""
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
|
|
||||||
def new(data) when is_binary(data) do
|
def new(data) when is_binary(data) do
|
||||||
%Reply{data: data}
|
%Reply{data: data}
|
||||||
end
|
end
|
||||||
|
|
|
||||||
|
|
@ -19,6 +19,7 @@ defmodule Openflow.Echo.Request do
|
||||||
data: options[:data] || ""
|
data: options[:data] || ""
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
|
|
||||||
def new(data) when is_binary(data) do
|
def new(data) when is_binary(data) do
|
||||||
%Request{data: data}
|
%Request{data: data}
|
||||||
end
|
end
|
||||||
|
|
|
||||||
1122
lib/openflow/enum_gen.ex
Normal file
1122
lib/openflow/enum_gen.ex
Normal file
File diff suppressed because it is too large
Load diff
13393
lib/openflow/enums.ex
13393
lib/openflow/enums.ex
File diff suppressed because it is too large
Load diff
|
|
@ -18,6 +18,7 @@ defmodule Openflow.TableMod do
|
||||||
table_id: options[:table_id] || 0
|
table_id: options[:table_id] || 0
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
|
|
||||||
def new(table_id) when is_integer(table_id) or is_atom(table_id) do
|
def new(table_id) when is_integer(table_id) or is_atom(table_id) do
|
||||||
%TableMod{table_id: table_id}
|
%TableMod{table_id: table_id}
|
||||||
end
|
end
|
||||||
|
|
|
||||||
|
|
@ -82,11 +82,13 @@ defmodule Tres.MessageHelper do
|
||||||
end
|
end
|
||||||
|
|
||||||
defp send_group_mod_delete(datapath_id, options \\ []) do
|
defp send_group_mod_delete(datapath_id, options \\ []) do
|
||||||
group_mod = Openflow.GroupMod.new(
|
group_mod =
|
||||||
|
Openflow.GroupMod.new(
|
||||||
xid: options[:xid] || 0,
|
xid: options[:xid] || 0,
|
||||||
command: :delete,
|
command: :delete,
|
||||||
group_id: options[:group_id] || :all
|
group_id: options[:group_id] || :all
|
||||||
)
|
)
|
||||||
|
|
||||||
send_message(group_mod, datapath_id)
|
send_message(group_mod, datapath_id)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -500,6 +500,7 @@ defmodule Tres.SecureChannel do
|
||||||
XACT_KV.insert(state_data.xact_kv_ref, xid, message)
|
XACT_KV.insert(state_data.xact_kv_ref, xid, message)
|
||||||
send_message(messages, state_data)
|
send_message(messages, state_data)
|
||||||
end
|
end
|
||||||
|
|
||||||
defp xactional_send_message(%{xid: xid} = message, state_data) do
|
defp xactional_send_message(%{xid: xid} = message, state_data) do
|
||||||
_ = State.set_transaction_id(state_data.xid, xid)
|
_ = State.set_transaction_id(state_data.xid, xid)
|
||||||
|
|
||||||
|
|
|
||||||
3
mix.exs
3
mix.exs
|
|
@ -7,9 +7,10 @@ defmodule Tres.Mixfile do
|
||||||
version: "0.1.0",
|
version: "0.1.0",
|
||||||
elixir: "~> 1.5",
|
elixir: "~> 1.5",
|
||||||
start_permanent: Mix.env() == :prod,
|
start_permanent: Mix.env() == :prod,
|
||||||
|
escript: [main_module: Openflow.EnumGen, name: :enum_gen, path: "bin/enum_gen"],
|
||||||
compilers: [:erlang] ++ Mix.compilers(),
|
compilers: [:erlang] ++ Mix.compilers(),
|
||||||
deps: deps(),
|
deps: deps(),
|
||||||
aliases: [test: "test --no-start"]
|
aliases: [test: "test --no-start", compile: ["escript.build"]]
|
||||||
]
|
]
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue