class/Mono.Posix/Mono.Remoting.Channels.Unix/UnixChannel.cs

   1 //
   2 // Mono.Remoting.Channels.Unix.UnixChannel.cs
   3 //
   4 // Author: Rodrigo Moya (rodrigo@ximian.com)
   5 //         Lluis Sanchez Gual (lluis@ideary.com)
   6 //
   7 // Copyright (C) 2005 Novell, Inc (http://www.novell.com)
   8 //
   9
  10 //
  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:
  18 //
  19 // The above copyright notice and this permission notice shall be
  20 // included in all copies or substantial portions of the Software.
  21 //
  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.
  29 //
  30
  31 using System;
  32 using System.Collections;
  33 using System.Runtime.Remoting.Messaging;
  34 using System.Runtime.Remoting.Channels;
  35 using System.Text.RegularExpressions;
  36
  37 namespace Mono.Remoting.Channels.Unix
  38 {
  39     public class UnixChannel : IChannelReceiver, IChannel, IChannelSender
  40     {
  41         private UnixClientChannel _clientChannel;
  42         private UnixServerChannel _serverChannel = null;
  43         private string _name = "unix";
  44         private int _priority = 1;
  45
  46         public UnixChannel (): this (null)
  47         {
  48         }
  49
  50         public UnixChannel (string path)
  51         {
  52             Hashtable ht = new Hashtable();
  53             ht["path"] = path;
  54             Init(ht, null, null);
  55         }
  56
  57         void Init (IDictionary properties, IClientChannelSinkProvider clientSink, IServerChannelSinkProvider serverSink)
  58         {
  59             _clientChannel = new UnixClientChannel (properties,clientSink);
  60
  61             if(properties["path"] != null)
  62                 _serverChannel = new UnixServerChannel(properties, serverSink);
  63
  64             object val = properties ["name"];
  65             if (val != null) _name = val as string;
  66
  67             val = properties ["priority"];
  68             if (val != null) _priority = Convert.ToInt32 (val);
  69         }
  70
  71
  72         public UnixChannel (IDictionary properties,
  73                             IClientChannelSinkProvider clientSinkProvider,
  74                             IServerChannelSinkProvider serverSinkProvider)
  75         {
  76             Init (properties, clientSinkProvider, serverSinkProvider);
  77         }
  78
  79         public IMessageSink CreateMessageSink(string url, object remoteChannelData, out string objectURI)
  80         {
  81             return _clientChannel.CreateMessageSink(url, remoteChannelData, out objectURI);
  82         }
  83
  84         public string ChannelName
  85         {
  86             get { return _name; }
  87         }
  88
  89         public int ChannelPriority
  90         {
  91             get { return _priority; }
  92         }
  93
  94         public void StartListening (object data)
  95         {
  96             if (_serverChannel != null) _serverChannel.StartListening (data);
  97         }
  98
  99         public void StopListening (object data)
 100         {
 101             if (_serverChannel != null) _serverChannel.StopListening(data);
 102         }
 103
 104         public string[] GetUrlsForUri (string uri)
 105         {
 106             if (_serverChannel != null) return _serverChannel.GetUrlsForUri(uri);
 107             else return null;
 108         }
 109
 110         public object ChannelData
 111         {
 112             get
 113             {
 114                 if (_serverChannel != null) return _serverChannel.ChannelData;
 115                 else return null;
 116             }
 117         }
 118
 119         public string Parse (string url, out string objectURI)
 120         {
 121             return UnixChannel.ParseUnixURL (url, out objectURI);
 122         }
 123
 124         internal static string ParseUnixURL (string url, out string objectURI)
 125         {
 126             // format: "unix:///path/to/unix/socket?/path/to/object"
 127
 128             objectURI = null;
 129
 130                         if (!url.StartsWith ("unix://")) return null;
 131
 132                         int i = url.IndexOf ('?');
 133                         if (i == -1) return url.Substring (7);
 134
 135                         objectURI = url.Substring (i+1);
 136
 137             if (objectURI.Length == 0)
 138                 objectURI = null;
 139
 140                         return url.Substring (7, i - 7);
 141         }
 142     }
 143 }