void Init (IServerChannelSinkProvider serverSinkProvider)
{
- if (serverSinkProvider == null) \r
+ if (serverSinkProvider == null)
{
serverSinkProvider = new BinaryServerFormatterSinkProvider ();
}
// Gets channel data from the chain of channel providers
channel_data = new ChannelDataStore (null);
- IServerChannelSinkProvider provider = serverSinkProvider;\r
- while (provider != null)\r
- {\r
- provider.GetChannelData(channel_data);\r
- provider = provider.Next;\r
- }\r
+ IServerChannelSinkProvider provider = serverSinkProvider;
+ while (provider != null)
+ {
+ provider.GetChannelData(channel_data);
+ provider = provider.Next;
+ }
// Creates the sink chain that will process all incoming messages
- IServerChannelSink next_sink = ChannelServices.CreateServerChannelSinkChain (serverSinkProvider, this);\r
+ IServerChannelSink next_sink = ChannelServices.CreateServerChannelSinkChain (serverSinkProvider, this);
sink = new TcpServerTransportSink (next_sink);
}
IServerChannelSinkProvider serverSinkProvider)
{
foreach(DictionaryEntry property in properties)
- {\r
- switch((string)property.Key)\r
- {\r
+ {
+ switch((string)property.Key)
+ {
case "name":
name = property.Value.ToString();
break;
- case "port":\r
+ case "port":
port = Convert.ToInt32(property.Value);
- break;\r
- case "priority":\r
+ break;
+ case "priority":
priority = Convert.ToInt32(property.Value);
- break;\r
- case "bindTo":\r
+ break;
+ case "bindTo":
bindAddress = IPAddress.Parse((string)property.Value);
- break;\r
- case "rejectRemoteRequests":\r
+ break;
+ case "rejectRemoteRequests":
if(Convert.ToBoolean(properties["rejectRemoteRequests"]))
bindAddress = IPAddress.Loopback;
break;
case "supressChannelData":
supressChannelData = Convert.ToBoolean (property.Value);
- break;\r
+ break;
case "useIpAddress":
useIpAddress = Convert.ToBoolean (property.Value);
break;
case "machineName":
host = property.Value as string;
break;
- }\r
+ }
}
Init (serverSinkProvider);
}
return "tcp://" + host + ":" + port;
}
- public string[] GetUrlsForUri (string uri)\r
- {\r
+ public virtual string[] GetUrlsForUri (string uri)
+ {
if (!uri.StartsWith ("/")) uri = "/" + uri;
-\r
- string [] chnl_uris = channel_data.ChannelUris;\r
- string [] result = new String [chnl_uris.Length];\r
-\r
- for (int i = 0; i < chnl_uris.Length; i++) \r
- result [i] = chnl_uris [i] + uri;\r
- \r
- return result;\r
- }\r
+
+ string [] chnl_uris = channel_data.ChannelUris;
+ string [] result = new String [chnl_uris.Length];
+
+ for (int i = 0; i < chnl_uris.Length; i++)
+ result [i] = chnl_uris [i] + uri;
+
+ return result;
+ }
public string Parse (string url, out string objectURI)
{
stopped = false;
#endif
listener = new TcpListener (bindAddress, port);
- if (server_thread == null) \r
+ if (server_thread == null)
{
threadPool = RemotingThreadPool.GetSharedPool ();
listener.Start ();
#endif
listener.Stop ();
threadPool.Free ();
- server_thread.Join ();\r
- server_thread = null; \r
+ server_thread.Join ();
+ server_thread = null;
}
}
_id = _count++;
}
- public Stream Stream
- {
- get { return _stream; }
+ public Socket Socket {
+ get { return _socket; }
}
public byte[] Buffer
switch (type)
{
case MessageStatus.MethodMessage:
- _sink.InternalProcessMessage (this);
+ _sink.InternalProcessMessage (this, _stream);
break;
case MessageStatus.Unknown: