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                                 IMessage res = _nextSink.SyncProcessMessage (msg);
  42                                 replySink = new ServerObjectReplySink(identity, replySink);
  43                         }
  44                         return _nextSink.AsyncProcessMessage (msg, replySink);
  45                 }
  46
  47                 public IMessageSink NextSink
  48                 {
  49                         get { return _nextSink; }
  50                 }
  51         }
  52
  53         class ServerObjectReplySink: IMessageSink
  54         {
  55                 IMessageSink _replySink;
  56                 ServerIdentity _identity;
  57
  58                 public ServerObjectReplySink (ServerIdentity identity, IMessageSink replySink)
  59                 {
  60                         _replySink = replySink;
  61                         _identity = identity;
  62                 }
  63
  64                 public IMessage SyncProcessMessage (IMessage msg)
  65                 {
  66                         _identity.NotifyServerDynamicSinks (false, msg, true, true);
  67                         return _replySink.SyncProcessMessage (msg);
  68                 }
  69
  70                 public IMessageCtrl AsyncProcessMessage (IMessage msg, IMessageSink replySink)
  71                 {
  72                         throw new NotSupportedException ();
  73                 }
  74
  75                 public IMessageSink NextSink
  76                 {
  77                         get { return _replySink; }
  78                 }
  79         }
  80 }