hramrach · November 22, 2015 12:45 · Nov 22, 2015
diff --git a/client.rb b/client.rb
@@ -0,0 +1,70 @@
+require 'dbus'
+
+class Exception
+	def pp
+		STDERR.puts self.inspect
+		self.backtrace.each{|l|
+			STDERR.puts "  " + l
+		}
+	end
+end
+
+
+$bus = DBus::SessionBus.instance
+
+$path = %w(net luon trac rubydbus testsrv)
+$cli_path = %w(net luon trac rubydbus testcli)
+
+$service = $path.join "."
+$cli_service = $cli_path.join "."
+
+class TestCli < DBus::Object
+	dbus_interface ($cli_path.join '.') do
+		dbus_method :RecvToken, "in server:o, in token:u" do |server,token|
+			begin
+				STDERR.puts "RecvToken #{server}, #{token}"
+				t = Thread.new {
+					Thread.stop
+					STDERR.puts "Query thread #{server}, #{token}"
+					loop {
+						sleep 1
+						begin
+							STDERR.puts "Data: #{@server.GetData @token}"
+							exit 0
+						rescue Exception
+							pp $!
+						end
+					}
+				}
+				@server = service.object server
+				@server.introspect
+				@server.default_iface = $path.join '.'
+				@token = token
+				@server.AckToken @token
+				t.wakeup
+			rescue Exception
+				pp $!
+			end
+		end
+	end
+end
+
+
+
+
+
+$object = TestCli.new ('/' + $cli_path.join('/'))
+
+$service = $bus.service $service
+$cli_service = $bus.request_service $cli_service
+
+$cli_service.export $object
+
+server = $service.object ('/' + $path.join('/'))
+server.introspect
+server.default_iface = $path.join '.'
+server.Register $object.path
+
+loop = DBus::Main.new
+loop << $bus
+loop.run
diff --git a/server.rb b/server.rb
@@ -0,0 +1,80 @@
+require 'dbus'
+
+class Exception
+	def pp
+		STDERR.puts self.inspect
+		self.backtrace.each{|l|
+			STDERR.puts "  " + l
+		}
+	end
+end
+
+$bus = DBus::SessionBus.instance
+
+$path = %w(net luon trac rubydbus testsrv)
+$cli_path = %w(net luon trac rubydbus testcli)
+
+$service = $path.join "."
+
+class TestSrv < DBus::Object
+	dbus_interface ($path.join('.')) do
+		dbus_method :Register, "in client:o" do |client|
+			begin
+				STDERR.puts "Register #{client}"
+				t = Thread.new {
+					Thread.stop
+					STDERR.puts "Token thread #{client}"
+					sleep 3 # fake some processing
+					begin
+						client = $service.object client
+						client.introspect
+						client.default_iface = $cli_path.join '.'
+						@token = Random.rand 65535
+						@client = client
+						@data = nil
+						STDERR.puts "Sending token #@token to #{client}"
+						client.RecvToken @token
+					rescue Exception
+						pp $!
+					end
+				}
+				t.run
+			rescue Exception
+				pp $!
+			end
+		end
+		dbus_method :AckToken, "in token:u" do |token|
+			STDERR.puts "AckToken #{token}"
+			raise RuntimeError.new "Invalid token!" unless token == @token
+			begin
+				t = Thread.new {
+					Thread.stop
+					STDERR.puts "Data thread #{token}"
+					sleep 5 # fake some processing
+					@data = Random.rand 65535
+					STDERR.puts "Generated data #@data"
+				}
+				t.run
+			rescue Exception
+				pp $!
+			end
+		end
+		dbus_method :GetData, "in token:u, out data:u" do |token|
+			STDERR.puts "GetData #{token}"
+			raise RuntimeError.new "Invalid token!" unless token == @token
+			raise RuntimeError.new "No data available!" unless @data
+			@data
+		end
+	end
+end
+
+
+$object = TestSrv.new ('/' + $path.join('/'))
+
+$service = $bus.request_service $service
+
+$service.export $object
+
+loop = DBus::Main.new
+loop << $bus
+loop.run