---
lua/publisher.lua | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++++
lua/subscriber.lua | 25 ++++++++++++++++++++++
2 files changed, 85 insertions(+)
create mode 100644 lua/publisher.lua
create mode 100644 lua/subscriber.lua
diff --git a/lua/publisher.lua b/lua/publisher.lua
new file mode 100644
index 0000000..ba5f6a4
--- /dev/null
+++ b/lua/publisher.lua
@@ -0,0 +1,60 @@
+#!/usr/bin/env lua
+
+require "ubus"
+require "uloop"
+
+--[[
+ A demo of ubus publisher binding. Should be run before subscriber.lua
+--]]
+
+
+uloop.init()
+
+local conn = ubus.connect()
+if not conn then
+ error("Failed to connect to ubus")
+end
+
+local ubus_objects = {
+ test = {
+ hello = {
+ function(req, msg)
+ conn:reply(req, {message="foo"});
+ print("Call to function 'hello'")
+ for k, v in pairs(msg) do
+ print("key=" .. k .. " value=" ..
tostring(v))
+ end
+ end, {id = ubus.INT32, msg = ubus.STRING }
+ },
+ hello1 = {
+ function(req)
+ conn:reply(req, {message="foo1"});
+ conn:reply(req, {message="foo2"});
+ print("Call to function 'hello1'")
+ end, {id = ubus.INT32, msg = ubus.STRING }
+ },
+ __subscriber_cb = function( subs )
+ print("total subs: ", subs )
+ end
+ }
+}
+
+conn:add( ubus_objects )
+print("Objects added, starting loop")
+
+-- start time
+local timer
+local counter = 0
+function t()
+ counter = counter + 1
+ local params = {
+ count = counter
+ }
+ conn:notify( ubus_objects.test.__ubusobj, "test.alarm", params )
+ timer:set(10000)
+end
+timer = uloop.timer(t)
+timer:set(1000)
+
+
+uloop.run()
diff --git a/lua/subscriber.lua b/lua/subscriber.lua
new file mode 100644
index 0000000..b0abf96
--- /dev/null
+++ b/lua/subscriber.lua
@@ -0,0 +1,25 @@
+#!/usr/bin/env lua
+
+--[[
+ A demo of ubus subscriber binding. Should be run after publisher.lua
+--]]
+
+require "ubus"
+require "uloop"
+
+uloop.init()
+
+local conn = ubus.connect()
+if not conn then
+ error("Failed to connect to ubus")
+end
+
+local sub = {
+ notify = function( msg )
+ print("Count: ", msg["count"])
+ end,
+}
+
+conn:subscribe( "test", sub )
+
+uloop.run()
--
1.7.9.5
_______________________________________________
Lede-dev mailing list
Lede-dev@lists.infradead.org
http://lists.infradead.org/mailman/listinfo/lede-dev
