mcs/class/corlib/System.Runtime.Remoting.Messaging/ServerObjectTerminatorSink.cs

   1 //
   2 // System.Runtime.Remoting.ServerObjectTerminatorSink.cs
   3 //
   4 // Author: Lluis Sanchez Gual (lsg@ctv.es)
   5 //
   6 // (C) 2002, Lluis Sanchez Gual
   7 //
   8
   9 using System;
  10
  11 namespace System.Runtime.Remoting.Messaging
  12 {
  13         // The final sink of the Server Object Sink Chain.
  14         // It invokes object dynamic sinks and forwards the message
  15         // to the StackBuilderSink
  16
  17         internal class ServerObjectTerminatorSink: IMessageSink
  18         {
  19                 IMessageSink _nextSink;
  20
  21                 public ServerObjectTerminatorSink(IMessageSink nextSink)
  22                 {
  23                         _nextSink = nextSink;
  24                 }
  25
  26                 public IMessage SyncProcessMessage (IMessage msg)
  27                 {
  28                         ServerIdentity identity = (ServerIdentity) RemotingServices.GetMessageTargetIdentity (msg);
  29                         identity.NotifyServerDynamicSinks (true, msg, false, false);
  30                         IMessage res = _nextSink.SyncProcessMessage (msg);
  31                         identity.NotifyServerDynamicSinks (false, msg, false, false);
  32                         return res;
  33                 }
  34
  35                 public IMessageCtrl AsyncProcessMessage (IMessage msg, IMessageSink replySink)
  36                 {
  37                         ServerIdentity identity = (ServerIdentity) RemotingServices.GetMessageTargetIdentity (msg);
  38                         if (identity.HasServerDynamicSinks)
  39                         {
  40                                 identity.NotifyServerDynamicSinks (true, msg, false, true);
  41                                 if (replySink != null) replySink = new ServerObjectReplySink(identity, replySink);
  42                         }
  43
  44                         IMessageCtrl res = _nextSink.AsyncProcessMessage (msg, replySink);
  45
  46                         if (replySink == null)
  47                                 identity.NotifyServerDynamicSinks (false, msg, true, true);
  48
  49                         return res;
  50                 }
  51
  52                 public IMessageSink NextSink
  53                 {
  54                         get { return _nextSink; }
  55                 }
  56         }
  57
  58         class ServerObjectReplySink: IMessageSink
  59         {
  60                 IMessageSink _replySink;
  61                 ServerIdentity _identity;
  62
  63                 public ServerObjectReplySink (ServerIdentity identity, IMessageSink replySink)
  64                 {
  65                         _replySink = replySink;
  66                         _identity = identity;
  67                 }
  68
  69                 public IMessage SyncProcessMessage (IMessage msg)
  70                 {
  71                         _identity.NotifyServerDynamicSinks (false, msg, true, true);
  72                         return _replySink.SyncProcessMessage (msg);
  73                 }
  74
  75                 public IMessageCtrl AsyncProcessMessage (IMessage msg, IMessageSink replySink)
  76                 {
  77                         throw new NotSupportedException ();
  78                 }
  79
  80                 public IMessageSink NextSink
  81                 {
  82                         get { return _replySink; }
  83                 }
  84         }
  85 }