Skip to content

Commit

Permalink
ZeroConf: rename Hosts
Browse files Browse the repository at this point in the history
  • Loading branch information
meee1 committed Jun 19, 2021
1 parent 6f790f4 commit 782b586
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 19 deletions.
2 changes: 1 addition & 1 deletion Controls/Video.cs
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ private void Video_Load(object sender, EventArgs e)
chk.Text = "Display External";
flowLayoutPanel1.Controls.Add(chk);

foreach (var zeroconfHost in ZeroConf.Hosts)
foreach (var zeroconfHost in ZeroConf.RtspHosts)
{
Label lbl = new Label();
lbl.Text = zeroconfHost.Id;
Expand Down
32 changes: 14 additions & 18 deletions ExtLibs/Utilities/ZeroConf.cs
Original file line number Diff line number Diff line change
Expand Up @@ -10,43 +10,41 @@ namespace MissionPlanner.Utilities
{
public class ZeroConf
{
public static List<IZeroconfHost> Hosts = new List<IZeroconfHost>();
public static List<IZeroconfHost> RtspHosts = new List<IZeroconfHost>();

public delegate void ZeroConfHost(IZeroconfHost zeroconfHost);

public static event ZeroConfHost StartUDPMavlink;

public static void ProbeForRTSP()
{
Thread th = new Thread(resolverAsync);
th.IsBackground = true;
th.Start();
resolverAsync();
}

private static void resolverAsync()
private static async void resolverAsync()
{
while (true)
{
try
{
var results = ZeroconfResolver.ResolveAsync("_rtsp._udp.local.");
var results = await ZeroconfResolver.ResolveAsync("_rtsp._udp.local.");

if (results != null)
{
foreach (var zeroconfHost in results.Result)
foreach (var zeroconfHost in results)
{
Console.WriteLine("Stream " + zeroconfHost);
if (!Hosts.Contains(zeroconfHost))
Hosts.Add(zeroconfHost);
if (!RtspHosts.Contains(zeroconfHost))
RtspHosts.Add(zeroconfHost);
}
}
}
catch
{

}

Thread.Sleep(30000);
await Task.Delay(30000);
}
}

Expand All @@ -60,22 +58,20 @@ public static async Task EnumerateAllServicesFromAllHosts()

public static void ProbeForMavlink()
{
Thread th = new Thread(resolverMavlinkAsync);
th.IsBackground = true;
th.Start();
resolverMavlinkAsync();
}

private static void resolverMavlinkAsync(object obj)
private static async void resolverMavlinkAsync()
{
while (true)
{
try
{
var results = ZeroconfResolver.ResolveAsync("_mavlink._udp.local.");
var results = await ZeroconfResolver.ResolveAsync("_mavlink._udp.local.");

if (results != null)
{
foreach (var zeroconfHost in results.Result)
foreach (var zeroconfHost in results)
{
Console.WriteLine("Mavlink " + zeroconfHost);
var service = zeroconfHost.Services.Where(a => a.Key == "_mavlink._udp.local.");
Expand All @@ -91,7 +87,7 @@ private static void resolverMavlinkAsync(object obj)

}

Thread.Sleep(30000);
await Task.Delay(30000);
}
}
}
Expand Down

0 comments on commit 782b586

Please sign in to comment.