Changes
1 changed files (+14/-1)
-
-
@@ -47,6 +47,7 @@ public class AsyncConnection : GLib.Object {private Connection conn; private GLib.Thread<void>? thread = null; private bool is_closed = false; public size_t retry_max = 3; public AsyncConnection(Discovery.Server server) { this.conn = new Connection(server, null);
-
@@ -75,6 +76,8 @@ connection_started();return false; }); size_t retry_count = 0; while (true) { if (is_closed) { return;
-
@@ -93,14 +96,24 @@ }switch (event.kind) { case ERROR: { var error_event = event.get_connection_error_event(); if (error_event.code == CLOSED_BY_SERVER && retry_count < retry_max) { retry_count += 1; GLib.log( "Plac", LEVEL_INFO, "Connection closed by server, retrying (#%u)", (uint) retry_count ); break; } deactivate(); GLib.Idle.add(() => { connection_error(event.get_connection_error_event()); connection_error(error_event); return false; }); break; } case CONNECTED: { retry_count = 0; conn.subscribe_zones(); GLib.Idle.add(() => { connected(event.get_connected_event());
-