show runtime warning on OSC node. https://forum.vvvv.org/t/binding-bug/24507/2 it is a bit weird, that after changing the port and IP and back again you can have three working OSC nodes with the same configuration, but only after going through those steps. #7265

gregsn · gregsn · commit a4d0e1b5f09a · 2025-08-01T15:43:52.000+02:00
diff --git a/VL.CoreLib/src/IO/Socket/DatagramReceiver.cs b/VL.CoreLib/src/IO/Socket/DatagramReceiver.cs
@@ -1,11 +1,14 @@
-﻿using System;
+﻿using Microsoft.Extensions.Logging;
+using System;
 using System.Net;
 using System.Net.Sockets;
+using System.Reactive.Disposables;
 using System.Reactive.Subjects;
 using System.Threading;
 using System.Threading.Tasks;
 using VL.Core;
 using VL.Core.Import;
+using VL.Lang;
 using VL.Lib.Basics.Resources;
 using VL.Lib.Collections;
 using VL.Lib.IO.Socket;
@@ -28,6 +31,17 @@ public class DatagramReceiver : IDisposable
         IResourceProvider<NetSocket> FLocalSocketProvider;
         Task FCurrentTask;
 
+        private readonly NodeContext FNodeContext;
+        private readonly ILogger FLogger;
+        private readonly IVLRuntime FRuntime;
+
+        public DatagramReceiver(NodeContext nodeContext)
+        {
+            FRuntime = IVLRuntime.Current;
+            FNodeContext = nodeContext;
+            FLogger = nodeContext.GetLogger();
+        }
+
         /// <summary>
         /// The observable sequence of datagrams. The datagrams will be pushed on the network thread.
         /// </summary>
@@ -88,8 +102,9 @@ void Start(IResourceProvider<NetSocket> provider)
                                 }
                             }
                         }
-                        catch (Exception)
+                        catch (Exception e)
                         {
+                            Warn($"Error receiving datagram: {e.Message}");
                             if (!token.IsCancellationRequested)
                                 // Try again
                                 await Task.Delay(100);
@@ -110,5 +125,22 @@ void IDisposable.Dispose()
         {
             Stop(1);
         }
+
+        private void Warn(string message)
+        {
+            ResourceProvider.NewPooledSystemWide(FNodeContext.Path,
+                _ =>
+                {
+                    var messages = new CompositeDisposable();
+                    foreach (var id in FNodeContext.Path.Stack)
+                    {
+                        FRuntime.AddPersistentMessage(new Message(id, MessageSeverity.Warning, message))
+                            .DisposeBy(messages);
+                    }
+                    return messages;
+                }, delayDisposalInMilliseconds: 1000)
+                .GetHandle()
+                .Dispose(); // messages will stick for some seconds
+        }
     }
 }
