Org.Lwes/Listener/UnicastEventListener.cs

   1 //
   2 // This file is part of the LWES .NET Binding (LWES.net)
   3 //
   4 // COPYRIGHT© 2009, Phillip Clark (phillip[at*flitbit[dot*org)
   5 //       original .NET implementation
   6 //
   7 // LWES.net is free software: you can redistribute it and/or modify
   8 // it under the terms of the Lesser GNU General Public License as published by
   9 // the Free Software Foundation, either version 3 of the License, or
  10 // (at your option) any later version.
  11 //
  12 // LWES.net is distributed in the hope that it will be useful,
  13 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  14 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15 // Lesser GNU General Public License for more details.
  16 //
  17 // You should have received a copy of the Lesser GNU General Public License
  18 // along with LWES.net.  If not, see <http://www.gnu.org/licenses/>.
  19 //
  20 namespace Org.Lwes.Listener
  21 {
  22         using System;
  23         using System.Net;
  24         using System.Net.Sockets;
  25
  26         using Org.Lwes.DB;
  27         using Org.Lwes.Properties;
  28
  29         /// <summary>
  30         /// Implementation of the IEventListener for listening to multicast events.
  31         /// </summary>
  32         public sealed class UnicastEventListener : EventListenerBase
  33         {
  34                 #region Methods
  35
  36                 /// <summary>
  37                 /// Initializes the event listener.
  38                 /// </summary>
  39                 /// <param name="db"></param>
  40                 /// <param name="address"></param>
  41                 /// <param name="port"></param>
  42                 /// <param name="parallel"></param>
  43                 /// <param name="garbageHandling"></param>
  44                 public void Initialize(IEventTemplateDB db
  45                         , IPAddress address
  46                         , int port
  47                         , bool parallel
  48                         , ListenerGarbageHandling garbageHandling)
  49                 {
  50                         TemplateDB = db;
  51                         Address = address;
  52                         Port = port;
  53                         IsParallel = parallel;
  54                         Initialize();
  55                 }
  56
  57                 /// <summary>
  58                 /// Initializes the listener on a unicast address.
  59                 /// </summary>
  60                 protected override void PerformInitialization()
  61                 {
  62                         base.FinishInitialize(new IPEndPoint(Address, Port),
  63                                 (s, e) =>
  64                                 {
  65                                         s.SetSocketOption(SocketOptionLevel.Udp, SocketOptionName.NoDelay, 1);
  66                                         s.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, 1);
  67                                         s.Bind(e);
  68                                 });
  69                 }
  70
  71                 #endregion Methods
  72         }
  73 }