現在Avahi raw dbusインターフェイスを使用しているコードを、Avahi gobjectインターフェイスを使用するように移植しようとしています（Pythonからのgobjectイントロスペクションを介して）。
ServiceBrowser を取得しましたが、ServiceResolver を動作させることができません。これが私のコードです：
#!/usr/bin/env python
import logging
from gi.repository import Avahi
logging.basicConfig(level=logging.DEBUG)
ac_log = logging.getLogger('Avahi.Client')
sb_log = logging.getLogger('Avahi.ServiceBrowser')
sr_log = logging.getLogger('Avahi.ServiceResolver')
def ac_state_changed(client, state):
ac_log.debug('state_changed: {}'.format(state))
avahi_client = Avahi.Client(flags=0,)
avahi_client.connect('state-changed', ac_state_changed)
avahi_client.start()
def sb_new_service(browser, interface, protocol, name, type, domain, flags ):
sb_log.debug('new: {}'.format(name))
if not (flags & Avahi.LookupResultFlags.GA_LOOKUP_RESULT_LOCAL):
sb_log.debug('resolving: {}'.format(name))
service_resolver = Avahi.ServiceResolver(
interface=interface,
protocol=protocol,
name=name,
type=type,
domain=domain,
aprotocol=Avahi.Protocol.GA_PROTOCOL_UNSPEC,
flags=0,)
service_resolver.connect('found', sr_found)
service_resolver.connect('failure', sr_failure)
service_resolver.attach(avahi_client)
def sb_all_for_now(*args):
sb_log.debug('all_for_now')
seen_all = True
def sb_failure(*args):
sb_log.error('failure: {}'.format(args))
def sr_found(*args):
sr_log.debug('found: {}'.format(args))
def sr_failure(*args):
sr_log.error('failure: {}'.format(args))
service_browser = Avahi.ServiceBrowser(
domain='local',
flags=0,
interface=-1,
protocol=Avahi.Protocol.GA_PROTOCOL_UNSPEC,
type='_workstation._tcp')
service_browser.connect("new_service", sb_new_service)
service_browser.connect("failure", sb_failure)
service_browser.attach(avahi_client)
from gi.repository import GObject
mainloop = GObject.MainLoop()
mainloop.run()
出力例:
DEBUG:Avahi.Client:state_changed: <enum GA_CLIENT_STATE_S_RUNNING of type GaClientState>
DEBUG:Avahi.ServiceBrowser:new: Mobi [d8:d3:85:e8:26:3d]
DEBUG:Avahi.ServiceBrowser:resolving: Mobi [d8:d3:85:e8:26:3d]
DEBUG:Avahi.ServiceBrowser:new: garyvdm [00:1d:09:a5:10:54]
DEBUG:Avahi.ServiceBrowser:new: noddy [00:15:c5:c6:46:4b]
DEBUG:Avahi.ServiceBrowser:resolving: noddy [00:15:c5:c6:46:4b]
DEBUG:Avahi.ServiceBrowser:new: crack [00:1c:26:20:e0:1d]
DEBUG:Avahi.ServiceBrowser:resolving: crack [00:1c:26:20:e0:1d]
DEBUG:Avahi.ServiceBrowser:new: opium [00:1d:09:c1:ed:cf]
DEBUG:Avahi.ServiceBrowser:resolving: opium [00:1d:09:c1:ed:cf]
DEBUG:Avahi.ServiceBrowser:new: gerard-vm [00:0c:29:d0:2a:af]
DEBUG:Avahi.ServiceBrowser:resolving: gerard-vm [00:0c:29:d0:2a:af]
DEBUG:Avahi.ServiceBrowser:all_for_now
^CTraceback (most recent call last):
File "pacshare/xfer.py", line 65, in <module>
mainloop.run()
KeyboardInterrupt
ctrl-cを押す前に、約1分間実行したままにしました。ご覧のとおり、ServiceResolver を呼び出していますが、sr_found メソッドと sr_failure メソッドは呼び出されません。どうすればこれを機能させることができますか?
（ http://code.ohloh.net/でこれを行う他のコードを見つけることができないため、これを試みたのは私が最初ではないかと思います）