2 // Mono.Remoting.Channels.Unix.UnixBinaryServerFormatterSink.cs
4 // Author: Duncan Mak (duncan@ximian.com)
5 // Lluis Sanchez Gual (lluis@ideary.com)
7 // 2002 (C) Copyright, Ximian, Inc.
11 // Permission is hereby granted, free of charge, to any person obtaining
12 // a copy of this software and associated documentation files (the
13 // "Software"), to deal in the Software without restriction, including
14 // without limitation the rights to use, copy, modify, merge, publish,
15 // distribute, sublicense, and/or sell copies of the Software, and to
16 // permit persons to whom the Software is furnished to do so, subject to
17 // the following conditions:
19 // The above copyright notice and this permission notice shall be
20 // included in all copies or substantial portions of the Software.
22 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
23 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
24 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
25 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
26 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
27 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
28 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
32 using System.Collections;
34 using System.Runtime.Remoting.Messaging;
35 using System.Runtime.Remoting.Channels;
36 using System.Runtime.Serialization;
37 using System.Runtime.Serialization.Formatters;
38 using System.Runtime.Serialization.Formatters.Binary;
39 using System.Runtime.InteropServices;
41 namespace Mono.Remoting.Channels.Unix {
43 internal class UnixBinaryServerFormatterSink : IServerChannelSink, IChannelSinkBase
45 UnixBinaryCore _binaryCore = UnixBinaryCore.DefaultInstance;
47 IServerChannelSink next_sink;
48 IChannelReceiver receiver;
50 public UnixBinaryServerFormatterSink (IServerChannelSink nextSink, IChannelReceiver receiver)
52 this.next_sink = nextSink;
53 this.receiver = receiver;
56 internal UnixBinaryCore BinaryCore
58 get { return _binaryCore; }
59 set { _binaryCore = value; }
62 public IServerChannelSink NextChannelSink {
68 public IDictionary Properties {
74 public void AsyncProcessResponse (IServerResponseChannelSinkStack sinkStack, object state,
75 IMessage message, ITransportHeaders headers, Stream stream)
77 ITransportHeaders responseHeaders = new TransportHeaders();
79 if (sinkStack != null) stream = sinkStack.GetResponseStream (message, responseHeaders);
80 if (stream == null) stream = new MemoryStream();
82 _binaryCore.Serializer.Serialize (stream, message, null);
83 if (stream is MemoryStream) stream.Position = 0;
85 sinkStack.AsyncProcessResponse (message, responseHeaders, stream);
88 public Stream GetResponseStream (IServerResponseChannelSinkStack sinkStack, object state,
89 IMessage msg, ITransportHeaders headers)
94 public ServerProcessing ProcessMessage (IServerChannelSinkStack sinkStack,
95 IMessage requestMsg, ITransportHeaders requestHeaders, Stream requestStream,
96 out IMessage responseMsg, out ITransportHeaders responseHeaders, out Stream responseStream)
98 sinkStack.Push (this, null);
103 string url = (string)requestHeaders["__RequestUri"];
105 receiver.Parse (url, out uri);
106 if (uri == null) uri = url;
108 MethodCallHeaderHandler mhh = new MethodCallHeaderHandler(uri);
109 requestMsg = (IMessage) _binaryCore.Deserializer.Deserialize (requestStream, new HeaderHandler(mhh.HandleHeaders));
111 res = next_sink.ProcessMessage (sinkStack, requestMsg, requestHeaders, null, out responseMsg, out responseHeaders, out responseStream);
115 responseMsg = new ReturnMessage (ex, (IMethodCallMessage)requestMsg);
116 res = ServerProcessing.Complete;
117 responseHeaders = null;
118 responseStream = null;
121 if (res == ServerProcessing.Complete)
123 for (int n=0; n<3; n++) {
124 responseStream = null;
125 responseHeaders = new TransportHeaders();
127 if (sinkStack != null) responseStream = sinkStack.GetResponseStream (responseMsg, responseHeaders);
128 if (responseStream == null) responseStream = new MemoryStream();
131 _binaryCore.Serializer.Serialize (responseStream, responseMsg);
133 } catch (Exception ex) {
134 if (n == 2) throw ex;
135 else responseMsg = new ReturnMessage (ex, (IMethodCallMessage)requestMsg);
139 if (responseStream is MemoryStream) responseStream.Position = 0;
142 sinkStack.Pop (this);
149 internal class MethodCallHeaderHandler
153 public MethodCallHeaderHandler (string uri)
158 public object HandleHeaders (Header[] headers)