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

repo: When listening, make poll interval long for every repo

Browse source
This commit is contained in:
Hylke Bons 2011-11-13 00:27:25 +00:00
parent 478ff8b33d
commit 1100fa205b
2 changed files with 32 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
SparkleLib/SparkleListenerBase.cs
View file

@ -165,7 +165,7 @@ namespace SparkleLib {
public void OnConnected ()
{
SparkleHelpers.DebugInfo ("Listener", "Connected to " + Server);
SparkleHelpers.DebugInfo ("Listener", "Listening for announcements on " + Server);
if (Connected != null)
Connected ();
@ -185,7 +185,7 @@ namespace SparkleLib {
public void OnDisconnected ()
{
SparkleHelpers.DebugInfo ("Listener", "Disonnected from " + Server);
SparkleHelpers.DebugInfo ("Listener", "Signal of " + Server + " lost");
if (Disconnected != null)
Disconnected ();

49
SparkleLib/SparkleRepoBase.cs
View file

@ -126,6 +126,7 @@ namespace SparkleLib {
while (HasUnsyncedChanges)
SyncUpBase ();
EnableWatching ();
}
@ -232,18 +233,28 @@ namespace SparkleLib {
{
this.listener = SparkleListenerFactory.CreateListener (Name, Identifier);
if (this.listener.IsConnected) {
this.poll_interval = this.long_interval;
if (!IsSyncing && CheckForRemoteChanges ())
SyncDownBase ();
}
// Stop polling when the connection to the irc channel is succesful
this.listener.Connected += delegate {
this.poll_interval = this.long_interval;
this.last_poll = DateTime.Now;
// Check for changes manually one more time
if (CheckForRemoteChanges ())
SyncDownBase ();
if (!IsSyncing) {
// Push changes that were made since the last disconnect
if (HasUnsyncedChanges)
SyncUpBase ();
// Check for changes manually one more time
if (CheckForRemoteChanges ())
SyncDownBase ();
// Push changes that were made since the last disconnect
if (HasUnsyncedChanges)
SyncUpBase ();
}
};
// Start polling when the connection to the irc channel is lost
@ -259,30 +270,30 @@ namespace SparkleLib {
if (announcement.FolderIdentifier.Equals (identifier) &&
!announcement.Message.Equals (CurrentRevision)) {
while (this.IsSyncing ()) {
while (this.IsSyncing)
System.Threading.Thread.Sleep (100);
}
SparkleHelpers.DebugInfo ("Listener", "Syncing due to Announcement");
if (!announcement.Message.Equals (CurrentRevision))
SyncDownBase ();
SparkleHelpers.DebugInfo ("Listener", "Syncing due to announcement");
SyncDownBase ();
} else {
if (announcement.FolderIdentifier.Equals (identifier))
SparkleHelpers.DebugInfo ("Listener", "Not syncing message is for current revision");
SparkleHelpers.DebugInfo ("Listener", "Not syncing, message is for current revision");
}
};
// Start listening
if (!this.listener.IsConnected && !this.listener.IsConnecting) {
if (!this.listener.IsConnected && !this.listener.IsConnecting)
this.listener.Connect ();
}
}
private bool IsSyncing ()
{
if (Status == SyncStatus.SyncUp || Status == SyncStatus.SyncDown || this.is_buffering)
return true;
return false;
private bool IsSyncing {
get {
return (Status == SyncStatus.SyncUp ||
Status == SyncStatus.SyncDown ||
this.is_buffering);
}
}