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
: