2 // System.Runtime.Remoting.Channels.Tcp.TcpServerTransportSink.cs
4 // Author: Rodrigo Moya (rodrigo@ximian.com)
5 // Lluis Sanchez Gual (lsg@ctv.es)
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;
33 using System.Runtime.Remoting.Messaging;
34 using System.Net.Sockets;
37 namespace System.Runtime.Remoting.Channels.Tcp
39 internal class TcpServerTransportSink : IServerChannelSink, IChannelSinkBase
41 IServerChannelSink next_sink;
43 public TcpServerTransportSink (IServerChannelSink next)
48 public IServerChannelSink NextChannelSink
56 public IDictionary Properties
60 if (next_sink != null) return next_sink.Properties;
65 public void AsyncProcessResponse (IServerResponseChannelSinkStack sinkStack, object state,
66 IMessage msg, ITransportHeaders headers, Stream responseStream)
68 ClientConnection connection = (ClientConnection)state;
70 NetworkStream ns = new NetworkStream (connection.Socket);
71 TcpMessageIO.SendMessageStream (ns, responseStream, headers, connection.Buffer);
76 public Stream GetResponseStream (IServerResponseChannelSinkStack sinkStack, object state,
77 IMessage msg, ITransportHeaders headers)
82 public ServerProcessing ProcessMessage (IServerChannelSinkStack sinkStack,
84 ITransportHeaders requestHeaders,
86 out IMessage responseMsg,
87 out ITransportHeaders responseHeaders,
88 out Stream responseStream)
90 // this is the first sink, and TcpServerChannel does not call it.
91 throw new NotSupportedException ();
94 internal void InternalProcessMessage (ClientConnection connection, Stream stream)
96 // Reads the headers and the request stream
99 ITransportHeaders requestHeaders;
101 requestStream = TcpMessageIO.ReceiveMessageStream (stream, out requestHeaders, connection.Buffer);
102 requestHeaders [CommonTransportKeys.IPAddress] = connection.ClientAddress;
103 requestHeaders [CommonTransportKeys.ConnectionId] = connection.Id;
105 string uri = (string) requestHeaders [CommonTransportKeys.RequestUri];
106 TcpChannel.ParseChannelUrl (uri, out uri);
109 requestHeaders [CommonTransportKeys.RequestUri] = uri;
111 // Pushes the connection object together with the sink. This information
112 // will be used for sending the response in an async call.
114 ServerChannelSinkStack sinkStack = new ServerChannelSinkStack();
115 sinkStack.Push(this, connection);
117 ITransportHeaders responseHeaders;
118 Stream responseStream;
119 IMessage responseMsg;
121 ServerProcessing proc = next_sink.ProcessMessage(sinkStack, null, requestHeaders, requestStream, out responseMsg, out responseHeaders, out responseStream);
125 case ServerProcessing.Complete:
126 TcpMessageIO.SendMessageStream (stream, responseStream, responseHeaders, connection.Buffer);
130 case ServerProcessing.Async:
131 case ServerProcessing.OneWay: