Avahiサービスを停止して要素のリストを返します

Question

次へthis exampleすべての要素を取得してリストに戻したら、サービスを停止します。

無限ループを停止するには、gobject.MainLoop().quit()を呼び出しますが、呼び出すタイミングや場所はわかりません。 ありがとう

Answer 1

サービスは、今すぐ最後のサービスが到着したときにを参照してください。これにより、現在利用可能なサービスのスナップショットが表示されます。

C層には、サービスがもうすぐ近づいているかどうかを検査できるフラグがあります。それはAVAHI_BROWSER_ALL_FOR_NOWと呼ばれています。私はのPythonバインディングに精通していませんが、おそらくこのフラグはコールバックのstypeまたはflags引数で何らかの形で検査されますか？

あなたは、このフラグが設定されている参照 - あなたにもAllForNow信号を聞きたいと思うでしょうgobject.MainLoop().quit()

Answer 2

を呼び出します。 CacheExhaustedをととしてください。失敗も同様です。 org.freedesktop.Avahi.ServiceBrowserのインターフェイスはhereと宣言されています。 1秒程度と版画で私のマシンのリターンに次のことを実行している

：

browsing ... 
cache exhausted 
New service: name = Lexmark X264dn; address = 10.9.0.93; port = 80 
that's all for now 
done 
0:00:01.004258 

はそれが役に立てば幸い！

---

from _dbus_glib_bindings import DBusGMainLoop 
import dbus, avahi 
import gobject 

class ServiceBrowser(): 
    def __init__(self, service): 
     loop = DBusGMainLoop(set_as_default=True) 

     bus = dbus.SystemBus(mainloop=loop) 

     self._server = dbus.Interface(bus.get_object(avahi.DBUS_NAME, avahi.DBUS_PATH_SERVER), avahi.DBUS_INTERFACE_SERVER) 

     browser = self._server.ServiceBrowserNew(avahi.IF_UNSPEC, avahi.PROTO_INET, service, '', 0) 
     listener = dbus.Interface(bus.get_object(avahi.DBUS_NAME, browser), avahi.DBUS_INTERFACE_SERVICE_BROWSER) 

     listener.connect_to_signal("ItemNew", self.item_new_handler) 
     listener.connect_to_signal("ItemRemove", self.item_remove_handler) 
     listener.connect_to_signal("AllForNow", self.all_for_now_handler) 
     listener.connect_to_signal("CacheExhausted", self.cache_exhausted_handler) 
     listener.connect_to_signal("Failure", self.failure_handler) 

     self._mainloop = gobject.MainLoop() 


    def service_resolved(self, *args): 
     print 'New service: name = %s; address = %s; port = %s' % (args[2], args[7], args[8]) 


    def print_error(self, *args): 
     print 'error_handler' 
     print args[0] 

    def item_new_handler(self, interface, protocol, name, stype, domain, flags): 
     self._server.ResolveService(interface, protocol, name, stype, domain, avahi.PROTO_UNSPEC, dbus.UInt32(0), reply_handler=self.service_resolved, error_handler=self.print_error) 


    def item_remove_handler(self, interface, protocol, name, stype, domain, flags): 
     print "Removed service: %s" % name 


    def all_for_now_handler(self): 
     print "that's all for now" 
     self._mainloop.quit() 


    def cache_exhausted_handler(self): 
     print "cache exhausted" 


    def failure_handler(self, error): 
     print "failure: %s" % error 


    def browse(self): 
     self._mainloop.run() 


def browse_avahi(service): 
    browser = ServiceBrowser(service) 
    browser.browse() 

def main(): 
    t0 = datetime.utcnow() 
    print "browsing ..." 
    browse_avahi('_http._tcp') 
    print "done" 
    print datetime.utcnow()-t0 

if __name__ == '__main__': 
    main()