Python cannot work as dbus server and client in the multi-thread enviroment -

-

i created dbus server following code, named server1.py

#!/usr/bin/python2.7 import dbus.service import dbus.glib import glib import gobject dbus.mainloop.glib import dbusgmainloop   class app_server(dbus.service.object):     def __init__(self):         bus = dbus.sessionbus(private = true, mainloop = dbusgmainloop())         bus_name = dbus.service.busname('de.test.app1', bus)         dbus.service.object.__init__(self, bus_name, '/de/test/app1_obj_path')      @dbus.service.method("test.app1.interface",)     def is_ready(self):                    return true  def publish_dbus():     loop = glib.mainloop()     app_server()     loop.run()  if __name__ == '__main__':      gobject.threads_init()     dbus.glib.init_threads()     publish_dbus()

and want access dbus service in server1.py following code, named server2.py work dbus server.

#!/usr/bin/python2.7 import dbus.service import dbus.glib import glib import dbus.mainloop import gobject dbus.mainloop.glib import dbusgmainloop threading import thread time import sleep   class app_server(dbus.service.object):     def __init__(self):         bus = dbus.sessionbus(private = true, mainloop = dbusgmainloop())         bus_name = dbus.service.busname('de.test.app3', bus)         dbus.service.object.__init__(self, bus_name, '/de/test/app3_obj_path')      @dbus.service.method("test.app3.interface",)     def is_ready(self):                    return true  def call_dbus():     bus_name = 'de.test.app1'     obj_path = '/de/test/app1_obj_path'     interface_name = 'test.app1.interface'     count = 1     while count < 1000:         proxy_bus = dbus.sessionbus(private = true)         obj = none         try:             obj = proxy_bus.get_object(bus_name, obj_path)         except:             sleep(1)             obj = proxy_bus.get_object(bus_name, obj_path)         ready = obj.get_dbus_method('is_ready', interface_name)         ready(pid_, bin_path)         count += 1         print count   def publish_dbus():     loop = glib.mainloop()     app_server()     loop.run()  if __name__ == '__main__':     gobject.threads_init()     dbus.glib.init_threads()     th1 = thread(target = publish_dbus)     th1.start()     th2 = thread(target = call_dbus)     th2.start()     sleep(10000000)

then after run server2.py, application terminated without finished dbus call in thread "call_dbus".

and if tried follwoing code, changed code in server2.py following:

from:

 proxy_bus = dbus.sessionbus(private = true)

to:

  proxy_bus = dbus.sessionbus(private = true, mainloop = dbus.mainloop.null_main_loop)

now, there have many connnections after thread "callbus" finished using tools "d-feet" can used d-bus debugger check if dbus server ready or if dbus connection has been established.

if can make suggeston make work normally??

what i've noticed this:

  • your bus/object names don't match.
  • you create new dbus connection each time in while loop. bad idea, specially seen don't close them.
    either move call out of loop, or use shared connection (private=false)
  • you don't need own thread publish dbus object, that's mainloop anyway.
  • if run mainloop in different thread, make sure have way stop, otherwise kill way of terminating program. or put int in main thread, should @ least react ctrl-c
  • the sleep @ end of program unnecessary. long there running non-daemon threads around program won't exit anyway.

putting together, should work:

#!/usr/bin/python2.7 import dbus.service import dbus.glib import glib import dbus.mainloop import gobject dbus.mainloop.glib import dbusgmainloop threading import thread time import sleep   class app_server(dbus.service.object):     def __init__(self):         bus = dbus.sessionbus(private = true, mainloop = dbusgmainloop())         bus_name = dbus.service.busname('de.test.app3', bus)         dbus.service.object.__init__(self, bus_name, '/de/test/app3_obj_path')      @dbus.service.method("test.app3.interface",)     def is_ready(self):                    return true  def call_dbus():     bus_name = 'de.test.app3'     obj_path = '/de/test/app3_obj_path'     interface_name = 'test.app3.interface'     proxy_bus = dbus.sessionbus(private = true)     count = 1     while count < 1000:         obj = none         try:             obj = proxy_bus.get_object(bus_name, obj_path)         except:             sleep(1)             obj = proxy_bus.get_object(bus_name, obj_path)         ready = obj.get_dbus_method('is_ready', interface_name)         #ready(pid_, bin_path)         count += 1         print count    if __name__ == '__main__':     gobject.threads_init()     dbus.glib.init_threads()     loop = glib.mainloop()     server = app_server()     #th1 = thread(target = publish_dbus)     #th1.start()     th2 = thread(target = call_dbus)     th2.start()     loop.run()

Popular posts from this blog

How to calculate SNR of signals in MATLAB? -

-
i've encountered simple, yet fundamental problem on calculating snr: there several signals : s1 = original , pure clean signal without noise. n1 = white gaussian noise going added s1. s2 = s1 + n1 (the noisy signal before performing noise-reduction algorithm) s3 = noise-reduced signal (after performing noise reduction algorithm) n2 = s3 - s1 (the amount of noise after performing noise-reduction algorithm) now want compare snr before , after performing noise-reduction algorithm. which signals should consider snr_before!? s1/n1 or s2/n1 ? which signals should consider snr_after!? s3/n1 or s3/n2 ? which commands or functions should use in matlab in order compute snr_before , snr_after? thanks billion putting time on helping me. what know calculating snr before : snrbeforenoise = mean( signal .^ 2 ) / mean( noise .^ 2 ); and snr after : residual_noise = signal - noise_reduced_signal; snr_after = mean( signal .^ 2 ) / mean( residual_noise .^ 2
Read more

c# - Attempting to upload to FTP: System.Net.WebException: System error -

-
i have api takes in xml , uploads files based on information in xml. uploads on schedule (also xml), , have tested surrounding , know works. i getting error 40% of time on first file attempt upload in each time cycle (time cycle = 45 minutes files, 30 minutes others). here code upload: try { loggerftp.log("uploading file: " + filename, false); // create request. ftpwebrequest request = (ftpwebrequest)webrequest.create(appsettingsftp.ftpurl + @"/" + filename); request.method = webrequestmethods.ftp.uploadfile; request.timeout = 6000000; //set 100 minutes //request.timeout = -1; //set infinite // add login credentials. request.credentials = new networkcredential(appsettingsftp.ftplogin, appsettingsftp.ftppassword); // grab file contents. streamreader sourcestream = new streamreader(appsettingsftp.uploadfiledirectory + filename); byte[] filecontents = encoding.utf8.getbytes(sourcestream.readtoend()); sourcest
Read more

ios - UISlider customization: how to properly add shadow to custom knob image -

-
Image
i need place custom knob image shadow uislider. far have image of 38x38, of there region defines shadow of knob. now while using image, when slide knob extreme ends actual knob not able cover end points, hence end points visible under transparent region of knob image this code using customize uislider uiimage *slidebtimg = [uiimage imagenamed:sliderknobimg]; [self.ratingslider setthumbimage:slidebtimg forstate:uicontrolstatenormal]; [self.ratingslider setthumbimage:slidebtimg forstate:uicontrolstatehighlighted]; how can implement custom knob shadow beneath it, covering end points?? look inside uislider.h , there methods let customize slider knob , track needed. (ios 2.0 , above) // lets subclass lay out track , thumb needed - (cgrect)minimumvalueimagerectforbounds:(cgrect)bounds; - (cgrect)maximumvalueimagerectforbounds:(cgrect)bounds; - (cgrect)trackrectforbounds:(cgrect)bounds; - (cgrect)thumbrectforbounds:(cgrect)bounds trackrect:(cgrect)rect value:
Read more