Skip to content

Commit 098d3b5

Browse files
committed
Merge pull request #22 from sergeybykov/MembershipOracle
Remove unused methods from MembershipOracleData
2 parents 7065848 + ed49c0f commit 098d3b5

File tree

1 file changed

+0
-56
lines changed

1 file changed

+0
-56
lines changed

src/OrleansRuntime/MembershipService/MembershipOracleData.cs

Lines changed: 0 additions & 56 deletions
Original file line numberDiff line numberDiff line change
@@ -268,62 +268,6 @@ private bool TryUpdateStatus(MembershipEntry updatedSilo)
268268
return true;
269269
}
270270

271-
internal bool TryUpdateStatusesAndNotify(Dictionary<SiloAddress, MembershipEntry> newEntries)
272-
{
273-
List<MembershipEntry> changed = TryUpdateStatuses(newEntries);
274-
if (changed == null || changed.Count <= 0) return false;
275-
276-
localTableCopy = GetSiloStatuses(status => true, true); // all the silos including me.
277-
localTableCopyOnlyActive = GetSiloStatuses(status => status.Equals(SiloStatus.Active), true); // only active silos including me.
278-
localNamesTableCopy = localTable.ToDictionary(pair => pair.Key, pair => pair.Value.InstanceName); // all the silos excluding me.
279-
280-
foreach (var entry in changed)
281-
{
282-
if (logger.IsVerbose) logger.Verbose("-Updated my local view of {0} status. It is now {1}.", entry.SiloAddress.ToLongString(), GetSiloStatus(entry.SiloAddress));
283-
NotifyLocalSubscribers(entry.SiloAddress, entry.Status);
284-
}
285-
return true;
286-
}
287-
288-
// return the list of MembershipEntry that changed.
289-
// first find all entries in the new list that either don't appear in the old list or have changed.
290-
// second, find all entries in the old list that have been removed from the new list.
291-
private List<MembershipEntry> TryUpdateStatuses(Dictionary<SiloAddress, MembershipEntry> newEntries)
292-
{
293-
List<MembershipEntry> changedEntries = null;
294-
foreach (MembershipEntry updatedSilo in newEntries.Values.Where(
295-
item => !item.SiloAddress.Endpoint.Equals(MyAddress.Endpoint)))
296-
{
297-
MembershipEntry currSiloData;
298-
if (!localTable.TryGetValue(updatedSilo.SiloAddress, out currSiloData))
299-
{
300-
// an optimization - if I learn about dead silo and I never knew about him before, I don't care, can just ignore him.
301-
if (updatedSilo.Status == SiloStatus.Dead) continue;
302-
303-
localTable.Add(updatedSilo.SiloAddress, updatedSilo);
304-
changedEntries = changedEntries ?? new List<MembershipEntry>();
305-
changedEntries.Add(updatedSilo);
306-
}
307-
else if (currSiloData.Status != updatedSilo.Status)
308-
{
309-
currSiloData.Update(updatedSilo);
310-
changedEntries = changedEntries ?? new List<MembershipEntry>();
311-
changedEntries.Add(updatedSilo);
312-
}
313-
}
314-
List<MembershipEntry> removedEntries = null;
315-
foreach (var currSilo in localTable.Values.Where(item => !item.Status.Equals(SiloStatus.Dead)))
316-
{
317-
if (newEntries.ContainsKey(currSilo.SiloAddress)) continue;
318-
319-
currSilo.Status = SiloStatus.Dead;
320-
removedEntries = removedEntries ?? new List<MembershipEntry>();
321-
removedEntries.Add(currSilo);
322-
}
323-
324-
return SetExtensions.Union(changedEntries, removedEntries);
325-
}
326-
327271
private void NotifyLocalSubscribers(SiloAddress siloAddress, SiloStatus newStatus)
328272
{
329273
if (logger.IsVerbose2) logger.Verbose2("-NotifyLocalSubscribers about {0} status {1}", siloAddress.ToLongString(), newStatus);

0 commit comments

Comments
 (0)