microsoft
/
MixedReality-Sharing
зеркало из https://github.com/microsoft/MixedReality-Sharing.git
1
0
Форкнуть 0
Код Задачи Пакеты Проекты Релизы Вики Активность

Remove category on last unsubscription 

Fixes #85.
This commit is contained in:
Filippo Banno 2020-01-23 17:16:24 +00:00 коммит произвёл Filippo Bannò
Родитель bd72b34cc9
Коммит 12621d553d
2 изменённых файлов: 28 добавлений и 7 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

4
libs/Matchmaking/src/Peer/PeerDiscoveryAgent.cs
Просмотреть файл

@ -799,6 +799,10 @@ namespace Microsoft.MixedReality.Sharing.Matchmaking
lock (this)
{
info.subscriptions_.Remove(subscription);
if (!info.subscriptions_.Any())
{
infoFromCategory_.Remove(info.category_);
}
}
}

31
libs/Matchmaking/test/Matchmaking.PeerDiscovery.Test/PeerDiscoveryTest.cs
Просмотреть файл

@ -63,25 +63,42 @@ namespace Microsoft.MixedReality.Sharing.Matchmaking.Test
// Create some resources in the first one
const string category = "FindResourcesLocalAndRemote";
var resource1 = svc1.PublishAsync(category, "Conn1", null, cts.Token).Result;
var resource2 = svc1.PublishAsync(category, "Conn2", null, cts.Token).Result;
var resource3 = svc1.PublishAsync(category, "Conn3", null, cts.Token).Result;
var resource2 = svc2.PublishAsync(category, "Conn2", null, cts.Token).Result;
// Discover them from the first service
{
var resources = Utils.QueryAndWaitForResourcesPredicate(svc1, category, rl => rl.Count() >= 3, cts.Token);
Assert.Equal(3, resources.Count());
var resources = Utils.QueryAndWaitForResourcesPredicate(svc1, category, rl => rl.Count() == 2, cts.Token);
Assert.Contains(resources, r => r.UniqueId.Equals(resource1.UniqueId));
Assert.Contains(resources, r => r.UniqueId.Equals(resource2.UniqueId));
Assert.Contains(resources, r => r.UniqueId.Equals(resource3.UniqueId));
}
// And also from the second
{
var resources = Utils.QueryAndWaitForResourcesPredicate(svc2, category, rl => rl.Count() >= 3, cts.Token);
Assert.Equal(3, resources.Count());
var resources = Utils.QueryAndWaitForResourcesPredicate(svc2, category, rl => rl.Count() == 2, cts.Token);
Assert.Contains(resources, r => r.UniqueId.Equals(resource1.UniqueId));
Assert.Contains(resources, r => r.UniqueId.Equals(resource2.UniqueId));
}
// Add more resources
var resource3 = svc1.PublishAsync(category, "Conn3", null, cts.Token).Result;
var resource4 = svc2.PublishAsync(category, "Conn4", null, cts.Token).Result;
// Discover them from the first service
{
var resources = Utils.QueryAndWaitForResourcesPredicate(svc1, category, rl => rl.Count() == 4, cts.Token);
Assert.Contains(resources, r => r.UniqueId.Equals(resource1.UniqueId));
Assert.Contains(resources, r => r.UniqueId.Equals(resource2.UniqueId));
Assert.Contains(resources, r => r.UniqueId.Equals(resource3.UniqueId));
Assert.Contains(resources, r => r.UniqueId.Equals(resource4.UniqueId));
}
// And also from the second
{
var resources = Utils.QueryAndWaitForResourcesPredicate(svc2, category, rl => rl.Count() == 4, cts.Token);
Assert.Contains(resources, r => r.UniqueId.Equals(resource1.UniqueId));
Assert.Contains(resources, r => r.UniqueId.Equals(resource2.UniqueId));
Assert.Contains(resources, r => r.UniqueId.Equals(resource3.UniqueId));
Assert.Contains(resources, r => r.UniqueId.Equals(resource4.UniqueId));
}
}
}