Org.Lwes/Listener/MulticastEventListener.cs

   1 namespace Org.Lwes.Listener
   2 {
   3         using System;
   4         using System.Collections.Generic;
   5         using System.Linq;
   6         using System.Net;
   7         using System.Net.Sockets;
   8         using System.Text;
   9
  10         using Org.Lwes.DB;
  11         using Org.Lwes.Properties;
  12
  13         /// <summary>
  14         /// Implementation of the IEventListener for listening to multicast events.
  15         /// </summary>
  16         public sealed class MulticastEventListener : EventListenerBase
  17         {
  18                 #region Methods
  19
  20                 /// <summary>
  21                 /// Initializes the instance.
  22                 /// </summary>
  23                 /// <param name="db"></param>
  24                 /// <param name="multicastAddress"></param>
  25                 /// <param name="multicastPort"></param>
  26                 /// <param name="parallel"></param>
  27                 /// <param name="garbageHandling"></param>
  28                 public void Initialize(IEventTemplateDB db
  29                         , IPAddress multicastAddress
  30                         , int multicastPort
  31                         , bool parallel
  32                         , ListenerGarbageHandling garbageHandling)
  33                 {
  34                         if (IsInitialized) throw new InvalidOperationException(Resources.Error_AlreadyInitialized);
  35
  36                         base.Initialize(db, new IPEndPoint(multicastAddress, multicastPort), parallel, garbageHandling,
  37                                 (s, e) =>
  38                                 {
  39                                         s.SetSocketOption(SocketOptionLevel.Udp, SocketOptionName.NoDelay, 1);
  40                                         s.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, 1);
  41                                         if (e.AddressFamily == AddressFamily.InterNetworkV6)
  42                                         {
  43                                                 s.Bind(new IPEndPoint(IPAddress.IPv6Any, e.Port));
  44                                                 s.SetSocketOption(SocketOptionLevel.IPv6, SocketOptionName.AddMembership,
  45                                                                 new IPv6MulticastOption(e.Address));
  46                                         }
  47                                         else
  48                                         {
  49                                                 s.Bind(new IPEndPoint(IPAddress.Any, e.Port));
  50                                                 s.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership,
  51                                                                 new MulticastOption(e.Address));
  52                                         }
  53                                 });
  54                 }
  55
  56                 #endregion Methods
  57         }
  58 }