listener: remove some unused code
This commit is contained in:
parent
d790d1b003
commit
8793b9205a
|
@ -50,7 +50,6 @@ namespace SparkleLib {
|
||||||
new Dictionary<string, List<SparkleAnnouncement>> ();
|
new Dictionary<string, List<SparkleAnnouncement>> ();
|
||||||
|
|
||||||
private Dictionary<string, SparkleAnnouncement> queue_up = new Dictionary<string, SparkleAnnouncement> ();
|
private Dictionary<string, SparkleAnnouncement> queue_up = new Dictionary<string, SparkleAnnouncement> ();
|
||||||
private Dictionary<string, SparkleAnnouncement> queue_down = new Dictionary<string, SparkleAnnouncement> ();
|
|
||||||
|
|
||||||
private Timer reconnect_timer = new Timer {
|
private Timer reconnect_timer = new Timer {
|
||||||
Interval = 60 * 1000,
|
Interval = 60 * 1000,
|
||||||
|
@ -130,8 +129,6 @@ namespace SparkleLib {
|
||||||
SparkleAnnouncement announcement = item.Value;
|
SparkleAnnouncement announcement = item.Value;
|
||||||
Announce (announcement);
|
Announce (announcement);
|
||||||
}
|
}
|
||||||
|
|
||||||
this.queue_down.Clear ();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -148,19 +145,10 @@ namespace SparkleLib {
|
||||||
SparkleLogger.LogInfo ("Listener", "Got message " + announcement.Message + " from " +
|
SparkleLogger.LogInfo ("Listener", "Got message " + announcement.Message + " from " +
|
||||||
announcement.FolderIdentifier + " on " + Server);
|
announcement.FolderIdentifier + " on " + Server);
|
||||||
|
|
||||||
if (IsRecentAnnouncement (announcement)) {
|
if (IsRecentAnnouncement (announcement))
|
||||||
SparkleLogger.LogInfo ("Listener", "Ignoring previously processed message " + announcement.Message +
|
return;
|
||||||
" from " + announcement.FolderIdentifier + " on " + Server);
|
|
||||||
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
SparkleLogger.LogInfo ("Listener", "Processing message " + announcement.Message + " from " +
|
|
||||||
announcement.FolderIdentifier + " on " + Server);
|
|
||||||
|
|
||||||
AddRecentAnnouncement (announcement);
|
AddRecentAnnouncement (announcement);
|
||||||
this.queue_down [announcement.FolderIdentifier] = announcement;
|
|
||||||
|
|
||||||
AnnouncementReceived (announcement);
|
AnnouncementReceived (announcement);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -451,12 +451,12 @@ namespace SparkleLib {
|
||||||
while (this.is_syncing)
|
while (this.is_syncing)
|
||||||
Thread.Sleep (100);
|
Thread.Sleep (100);
|
||||||
|
|
||||||
SparkleLogger.LogInfo ("Listener", "Syncing due to announcement");
|
SparkleLogger.LogInfo (Name, "Syncing due to announcement");
|
||||||
SyncDownBase ();
|
SyncDownBase ();
|
||||||
|
|
||||||
} else {
|
} else {
|
||||||
if (announcement.FolderIdentifier.Equals (identifier))
|
if (announcement.FolderIdentifier.Equals (identifier))
|
||||||
SparkleLogger.LogInfo ("Listener", "Not syncing, message is for current revision");
|
SparkleLogger.LogInfo (Name, "Not syncing, message is for current revision");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue