dbus_tokioでnonblockなGetManagedObjectsのmethod_callがタイムアウトになる

Question

実現したいこと

dbus-tokioを使って、、非同期にbluezのmanaged objectの情報を取得したい。

発生している問題・エラーメッセージ

blockingの実装とnonblockの実装でそれぞれbluezに対してorg.freedesktop.DBus.ObjectManager.GetManagedObjectsを実施し、標準出力に取得した情報を表示するプログラムです。

期待している動作は同じ内容が２回出力されることなのですが、nonblockの方はタイムアウトしてしまいます。以下のエラーメッセージが出力されます。

Error: D-Bus error: Timeout waiting for reply (org.freedesktop.DBus.Error.Timeout)

該当のソースコード

use dbus;
use dbus::arg;
use dbus::blocking::Connection;
use dbus::nonblock::Proxy;
use dbus_tokio::connection;
use std::collections::HashMap;
use std::error::Error;
use std::time::Duration;

type ManagedObjects = HashMap<
    dbus::Path<'static>,
    HashMap<String, HashMap<String, arg::Variant<Box<dyn arg::RefArg + 'static>>>>,
>;

#[tokio::main]
pub async fn main() -> Result<(), Box<dyn Error>> {
    println!("--- blocking ---");
    blocking_get_managed_objects()?; // OK.
    println!("--- nonblock ---");
    nonblock_get_managed_objects().await?; // Error: D-Bus error: Timeout waiting for reply (org.freedesktop.DBus.Error.Timeout)
    Ok(())
}

async fn nonblock_get_managed_objects() -> Result<(), Box<dyn Error>> {
    let (_resource, conn) = connection::new_system_sync()?;
    let proxy = Proxy::new("org.bluez", "/", Duration::from_secs(2), conn);
    let (objects,): (ManagedObjects,) = proxy
        .method_call(
            "org.freedesktop.DBus.ObjectManager",
            "GetManagedObjects",
            (),
        )
        .await?;
    print_managed_object(objects);
    Ok(())
}

fn blocking_get_managed_objects() -> Result<(), Box<dyn Error>> {
    let conn = Connection::new_system()?;
    let proxy = conn.with_proxy("org.bluez", "/", Duration::from_secs(2));
    let (objects,): (ManagedObjects,) = proxy.method_call(
        "org.freedesktop.DBus.ObjectManager",
        "GetManagedObjects",
        (),
    )?;
    print_managed_object(objects);
    Ok(())
}

fn print_managed_object(objects: ManagedObjects) {
    for (key, value) in objects.iter() {
        println!("{}: {{", key);
        for (key, value) in value.iter() {
            println!("    {}: {{", key);
            for (key, value) in value.iter() {
                print!("        {}: ", key);
                print_refarg(value);
            }
            println!("    }}");
        }
        println!("}}");
    }
}

fn print_refarg(value: &dyn arg::RefArg) {
    if let Some(s) = value.as_str() {
        println!("{}", s);
    } else if let Some(i) = value.as_i64() {
        println!("{}", i);
    } else {
        println!("{:?}", value);
    }
}

試したこと

dbus-monitorでnonblockの方もmethod_returnが返ってきていることは確認しています。

補足情報（FW/ツールのバージョンなど）

項目	バージョン
OS	Ubuntu 18.04
rustc	ver 1.40.0
dbus	ver 1.12.2
bluez	ver 5.48

Answer 1

必要な処理をしていない部分がありました。

   let (_resource, conn) = connection::new_system_sync()?;

としているところで、resourceを捨てていましたが、捨ててはならず、

    let (resource, conn) = connection::new_system_sync()?;
    tokio::spawn(async {
        let err = resource.await;
        panic!("Lost connection to D-Bus: {}", err);
    });

とする必要があったようです。
上記修正に加えてissue #233のパッチをdbus-rsに当てるとmanaged objectが取得できました。

まだissue自体は解決になっていませんが、issueに上がっている問題だということが判明したのでこの質問はクローズします。

Answer 2

こちらの未解決の issue #233 によるとProxy::new()してからproxy.method_call()するまでの時間差によっては、D-Bus error: Timeoutになってしまうようです。

とりあえずの回避策として、async sleepを追加するといいようです。（具体的にどう書いたらいいのかは、このissueからは読み取れませんでした）

Right now this issue can be worked around by adding an async sleep after spawning resource.await.

Comments

[i-poper]

素早い回答ありがとうございます。
ご指摘のIssue #233に上がったパッチをdbus-tokioに当てたところ、タイムアウトにならなくなりました。
(私のプログラムにも問題がありました…)

[tatsuya6502]

ご報告ありがとうございました。解決して良かったです！