Sha256: 9d1ae0aa82f27c4955044f6c71259cefc83221f7024317b7870089a477bf4968
Contents?: true
Size: 1.77 KB
Versions: 4
Compression:
Stored size: 1.77 KB
Contents
#!/usr/bin/env rspec # frozen_string_literal: true # Test thread safety require_relative "spec_helper" require "dbus" class TestSignalRace < DBus::Object dbus_interface "org.ruby.ServerTest" do dbus_signal :signal_without_arguments end end # Run *count* threads all doing *body*, wait for their finish def race_threads(count, &body) jobs = count.times.map do |j| Thread.new do Thread.current.abort_on_exception = true body.call(j) end end jobs.each(&:join) end # Repeat *count* times: { random sleep, *body* }, printing progress def repeat_with_jitter(count, &body) count.times do |i| sleep 0.1 * rand print "#{i} " $stdout.flush body.call end end describe "thread safety" do context "R/W: when the threads call methods with return values" do it "it works with separate bus connections" do race_threads(5) do |_j| # use separate connections to avoid races bus = DBus::ASessionBus.new svc = bus.service("org.ruby.service") obj = svc.object("/org/ruby/MyInstance") obj.default_iface = "org.ruby.SampleInterface" repeat_with_jitter(10) do expect(obj.the_answer[0]).to eq(42) end end puts end end context "W/O: when the threads only send signals" do it "it works with a shared separate bus connection" do race_threads(5) do |j| # shared connection bus = DBus::SessionBus.instance # hackish: we do not actually request the name svc = DBus::Service.new("org.ruby.server-test#{j}", bus) obj = TestSignalRace.new "/org/ruby/Foo" svc.export obj repeat_with_jitter(10) do obj.signal_without_arguments end svc.unexport(obj) end puts end end end
Version data entries
4 entries across 4 versions & 1 rubygems
Version | Path |
---|---|
ruby-dbus-0.22.1 | spec/thread_safety_spec.rb |
ruby-dbus-0.22.0 | spec/thread_safety_spec.rb |
ruby-dbus-0.21.0 | spec/thread_safety_spec.rb |
ruby-dbus-0.20.0 | spec/thread_safety_spec.rb |