beenull/SparkleShare
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

listener: remove some unused code

Browse source
This commit is contained in:
Hylke Bons 2012-09-08 10:48:01 +01:00
parent 16446ff566
commit 34ab7d9450
2 changed files with 4 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
SparkleLib/SparkleListenerBase.cs
View file

@ -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);
} }

4
SparkleLib/SparkleRepoBase.cs
View file

@ -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");
} }
} }