From 6f6e4b97cba49469440fc0aefafb71623a3eabb9 Mon Sep 17 00:00:00 2001 From: fiaxh Date: Fri, 15 Mar 2019 20:56:19 +0100 Subject: Use glib log functions --- libdino/src/service/avatar_manager.vala | 4 +- libdino/src/service/connection_manager.vala | 64 ++++++++++++----------------- 2 files changed, 28 insertions(+), 40 deletions(-) (limited to 'libdino/src') diff --git a/libdino/src/service/avatar_manager.vala b/libdino/src/service/avatar_manager.vala index 40115345..9e75a9dd 100644 --- a/libdino/src/service/avatar_manager.vala +++ b/libdino/src/service/avatar_manager.vala @@ -91,7 +91,7 @@ public class AvatarManager : StreamInteractionModule, Object { on_user_avatar_received(account, account.bare_jid, Base64.encode(buffer)); } } catch (Error e) { - print("error " + e.message + "\n"); + warning(e.message); } } @@ -138,4 +138,4 @@ public class AvatarManager : StreamInteractionModule, Object { } } -} \ No newline at end of file +} diff --git a/libdino/src/service/connection_manager.vala b/libdino/src/service/connection_manager.vala index 464302cb..e81b9b99 100644 --- a/libdino/src/service/connection_manager.vala +++ b/libdino/src/service/connection_manager.vala @@ -44,7 +44,6 @@ public class ConnectionManager : Object { public Source source; public string? identifier; public Reconnect reconnect_recomendation { get; set; default=Reconnect.NOW; } - public bool resource_rejected = false; public ConnectionError(Source source, string? identifier) { this.source = source; @@ -110,14 +109,13 @@ public class ConnectionManager : Object { return connection_todo; } - public XmppStream? connect_account(Account account) { + public void connect_account(Account account) { if (!connection_todo.contains(account)) connection_todo.add(account); if (!connections.has_key(account)) { - return connect_(account); + connect_(account); } else { check_reconnect(account); } - return null; } public void make_offline_all() { @@ -139,7 +137,7 @@ public class ConnectionManager : Object { try { connections[account].stream.disconnect(); } catch (Error e) { - warning(@"Error disconnecting stream $(e.message)\n"); + debug("Error disconnecting stream: %s", e.message); } connection_todo.remove(account); if (connections.has_key(account)) { @@ -148,7 +146,7 @@ public class ConnectionManager : Object { } } - private XmppStream? connect_(Account account, string? resource = null) { + private void connect_(Account account, string? resource = null) { if (connections.has_key(account)) connections[account].stream.detach_modules(); connection_errors.unset(account); if (resource == null) resource = account.resourcepart; @@ -158,7 +156,7 @@ public class ConnectionManager : Object { stream.add_module(module); } stream.log = new XmppLog(account.bare_jid.to_string(), log_options); - print("[%s] New connection with resource %s: %p\n".printf(account.bare_jid.to_string(), resource, stream)); + debug("[%s] New connection with resource %s: %p", account.bare_jid.to_string(), resource, stream); Connection connection = new Connection(stream, new DateTime.now_utc()); connections[account] = connection; @@ -177,47 +175,35 @@ public class ConnectionManager : Object { }); connect_async.begin(account, stream); stream_opened(account, stream); - - return stream; } private async void connect_async(Account account, XmppStream stream) { try { yield stream.connect(account.domainpart); } catch (Error e) { - print(@"[$(account.bare_jid)] Error: $(e.message)\n"); + debug("[%s %p] Error: %s", account.bare_jid.to_string(), stream, e.message); change_connection_state(account, ConnectionState.DISCONNECTED); if (!connection_todo.contains(account)) { return; } StreamError.Flag? flag = stream.get_flag(StreamError.Flag.IDENTITY); if (flag != null) { - set_connection_error(account, new ConnectionError(ConnectionError.Source.STREAM_ERROR, flag.error_type) { resource_rejected=flag.resource_rejected }); - } + warning(@"[%s %p] Stream Error: %s", account.bare_jid.to_string(), stream, flag.error_type); + set_connection_error(account, new ConnectionError(ConnectionError.Source.STREAM_ERROR, flag.error_type)); - ConnectionError? error = connection_errors[account]; - int wait_sec = 5; - if (error == null) { - wait_sec = 3; - } else if (error.source == ConnectionError.Source.STREAM_ERROR) { - print(@"[$(account.bare_jid)] Stream Error: $(error.identifier)\n"); - if (error.resource_rejected) { + if (flag.resource_rejected) { connect_(account, account.resourcepart + "-" + random_uuid()); return; } - switch (error.reconnect_recomendation) { - case ConnectionError.Reconnect.NOW: - wait_sec = 5; break; - case ConnectionError.Reconnect.LATER: - wait_sec = 60; break; - case ConnectionError.Reconnect.NEVER: - return; - } - } else if (error.source == ConnectionError.Source.SASL) { + } + + ConnectionError? error = connection_errors[account]; + if (error != null && error.source == ConnectionError.Source.SASL) { return; } - print(@"[$(account.bare_jid)] Check reconnect in $wait_sec sec\n"); - Timeout.add_seconds(wait_sec, () => { + + debug("[%s] Check reconnect in 5 sec", account.bare_jid.to_string()); + Timeout.add_seconds(5, () => { check_reconnect(account); return false; }); @@ -236,8 +222,8 @@ public class ConnectionManager : Object { XmppStream stream = connections[account].stream; stream.get_module(Xep.Ping.Module.IDENTITY).send_ping(stream, account.bare_jid.domain_jid, () => { - if (connections[account].stream != stream) return; acked = true; + if (connections[account].stream != stream) return; change_connection_state(account, ConnectionState.CONNECTED); }); @@ -247,11 +233,13 @@ public class ConnectionManager : Object { if (connections[account].last_activity != last_activity_was) return false; // Reconnect. Nothing gets through the stream. - print(@"[$(account.bare_jid)] Ping timeouted. Reconnecting\n"); + debug("[%s %p] Ping timeouted. Reconnecting", account.bare_jid.to_string(), stream); change_connection_state(account, ConnectionState.DISCONNECTED); try { connections[account].stream.disconnect(); - } catch (Error e) { } + } catch (Error e) { + debug("Error disconnecting stream: %s", e.message); + } connect_(account); return false; }); @@ -269,10 +257,10 @@ public class ConnectionManager : Object { private void on_network_changed() { if (network_is_online()) { - print("Network reported online\n"); + debug("NetworkMonitor: Network reported online"); check_reconnects(); } else { - print("Network reported offline\n"); + debug("NetworkMonitor: Network reported offline"); foreach (Account account in connection_todo) { change_connection_state(account, ConnectionState.DISCONNECTED); } @@ -284,17 +272,17 @@ public class ConnectionManager : Object { change_connection_state(account, ConnectionState.DISCONNECTED); } if (suspend) { - print("Device suspended\n"); + debug("Login1: Device suspended"); foreach (Account account in connection_todo) { try { make_offline(account); connections[account].stream.disconnect(); } catch (Error e) { - warning(@"Error disconnecting stream $(e.message)\n"); + debug("Error disconnecting stream %p: %s", connections[account].stream, e.message); } } } else { - print("Device un-suspend\n"); + debug("Login1: Device un-suspend"); check_reconnects(); } } -- cgit v1.2.3-70-g09d2