diff options
Diffstat (limited to 'cs/src/Ice/Util.cs')
| -rwxr-xr-x | cs/src/Ice/Util.cs | 818 |
1 files changed, 409 insertions, 409 deletions
diff --git a/cs/src/Ice/Util.cs b/cs/src/Ice/Util.cs index 3f11df349bc..80f72a6a9cb 100755 --- a/cs/src/Ice/Util.cs +++ b/cs/src/Ice/Util.cs @@ -27,399 +27,399 @@ namespace Ice public class InitializationData : ICloneable { public System.Object Clone() - { - // - // A member-wise copy is safe because the members are immutable. - // - return MemberwiseClone(); - } + { + // + // A member-wise copy is safe because the members are immutable. + // + return MemberwiseClone(); + } public Properties properties; - public Logger logger; - public Stats stats; - public ThreadNotification threadHook; + public Logger logger; + public Stats stats; + public ThreadNotification threadHook; } public sealed class Util { - public static Properties createProperties() - { - return new PropertiesI(); - } - - public static Properties createProperties(ref string[] args) - { - return new PropertiesI(ref args, null); - } - - public static Properties createProperties(ref string[] args, Properties defaults) - { - return new PropertiesI(ref args, defaults); - } - - public static Communicator initialize(ref string[] args) - { - return initialize(ref args, null); - } - - public static Communicator initialize(ref string[] args, InitializationData initData) - { - if(initData == null) - { - initData = new InitializationData(); - } - else - { - initData = (InitializationData)initData.Clone(); - } - - initData.properties = createProperties(ref args, initData.properties); - - CommunicatorI result = new CommunicatorI(initData); - result.finishSetup(ref args); - return result; - } - - public static Communicator initialize(InitializationData initData) - { - if(initData == null) - { - initData = new InitializationData(); - } - else - { - initData = (InitializationData)initData.Clone(); - } - - CommunicatorI result = new CommunicatorI(initData); - string[] args = new string[0]; - result.finishSetup(ref args); - return result; - } - - public static Communicator initialize() - { - return initialize(null); - } - - [Obsolete("This method is deprecated, use initialize instead.")] - public static Communicator initializeWithLogger(ref string[] args, Logger logger) - { - InitializationData initData = new InitializationData(); - initData.logger = logger; - return initialize(ref args, initData); - } - - [Obsolete("This method is deprecated, use initialize instead.")] - public static Communicator initializeWithProperties(ref string[] args, Properties properties) - { - InitializationData initData = new InitializationData(); - initData.properties = properties; - return initialize(ref args, initData); - } - - [Obsolete("This method is deprecated, use initialize instead.")] - public static Communicator initializeWithPropertiesAndLogger(ref string[] args, Properties properties, - Ice.Logger logger) - { - InitializationData initData = new InitializationData(); - initData.properties = properties; - initData.logger = logger; - return initialize(ref args, initData); - } - - public static IceInternal.Instance getInstance(Communicator communicator) - { - CommunicatorI p = (CommunicatorI) communicator; - return p.getInstance(); - } - - public static IceInternal.ProtocolPluginFacade getProtocolPluginFacade(Communicator communicator) - { - return new IceInternal.ProtocolPluginFacadeI(communicator); - } - - public static Identity stringToIdentity(string s) - { - Identity ident = new Identity(); - - // - // Find unescaped separator. - // - int slash = -1, pos = 0; - while((pos = s.IndexOf((System.Char) '/', pos)) != -1) - { - if(pos == 0 || s[pos - 1] != '\\') - { - if(slash == -1) - { - slash = pos; - } - else - { - // - // Extra unescaped slash found. - // - IdentityParseException ex = new IdentityParseException(); - ex.str = s; - throw ex; - } - } - pos++; - } - - if(slash == -1) - { - if(!IceUtil.StringUtil.unescapeString(s, 0, s.Length, out ident.name)) - { - IdentityParseException ex = new IdentityParseException(); - ex.str = s; - throw ex; - } - ident.category = ""; - } - else - { - if(!IceUtil.StringUtil.unescapeString(s, 0, slash, out ident.category)) - { - IdentityParseException ex = new IdentityParseException(); - ex.str = s; - throw ex; - } - if(slash + 1 < s.Length) - { - if(!IceUtil.StringUtil.unescapeString(s, slash + 1, s.Length, out ident.name)) - { - IdentityParseException ex = new IdentityParseException(); - ex.str = s; - throw ex; - } - } - else - { - ident.name = ""; - } - } - - return ident; - } - - public static string identityToString(Identity ident) - { - if(ident.category.Length == 0) - { - return IceUtil.StringUtil.escapeString(ident.name, "/"); - } - else - { - return IceUtil.StringUtil.escapeString(ident.category, "/") + '/' + IceUtil.StringUtil.escapeString(ident.name, "/"); - } - } - - [StructLayout(LayoutKind.Sequential)] - private struct UUID - { - public ulong Data1; - public ushort Data2; - public ushort Data3; - [MarshalAs(UnmanagedType.ByValTStr, SizeConst=8)] - public string Data4; - } - - [DllImport("rpcrt4.dll")] - private static extern int UuidCreate(ref UUID uuid); - - [DllImport("rpcrt4.dll")] - private static extern int UuidToString(ref UUID uuid, ref System.IntPtr str); - - [DllImport("rpcrt4.dll")] - private static extern int RpcStringFree(ref System.IntPtr str); - - private const int RPC_S_OK = 0; - private const int RPC_S_OUT_OF_MEMORY = 14; - private const int RPC_S_UUID_LOCAL_ONLY = 1824; - - public static string generateUUID() - { - if(AssemblyUtil.platform_ == AssemblyUtil.Platform.Windows) - { - // - // Under Windows, with both .NET and Mono, there is no /dev/urandom. - // - int rc; - UUID uuid = new UUID(); - rc = UuidCreate(ref uuid); - if(rc != RPC_S_OK && rc != RPC_S_UUID_LOCAL_ONLY) - { - Ice.SyscallException ex = new Ice.SyscallException("UuidCreate() failed"); - ex.error = rc; - throw ex; - } - System.IntPtr str = new System.IntPtr(); - rc = UuidToString(ref uuid, ref str); - switch(rc) - { - case RPC_S_OK: - { - break; - } - case RPC_S_OUT_OF_MEMORY: - { - throw new Ice.MemoryLimitException("No memory for UUID string"); - } - default: - { - Ice.SyscallException ex = new Ice.SyscallException("UuidToString() failed"); - ex.error = rc; - throw ex; - } - } - string result; - try - { - result = Marshal.PtrToStringAnsi(str); - } - catch(System.Exception ex) - { - throw new Ice.SyscallException(ex); - } - if((rc = RpcStringFree(ref str)) != RPC_S_OK) - { - Ice.SyscallException ex = new Ice.SyscallException("Cannot deallocate UUID"); - ex.error = rc; - throw ex; - } - return result; - } - else - { - // - // On Linux, /dev/random, even when used in blocking mode, sometimes - // fails or returns fewer bytes. - // Maybe we should use a combination of version 4 UUIDs (with /dev/random), - // and version 1 UUIDs (MAC address + time), when /dev/random is exhausted? - // - FileStream f = File.OpenRead("/dev/urandom"); - - const int uuidSize = 16; - byte[] buf = new byte[uuidSize]; - - // - // Limit the number of attempts to 20 reads to avoid an infinite loop. - // - int reads = 0; - int index = 0; - while(reads < 20 && index != uuidSize) - { - int bytesRead = f.Read(buf, index, uuidSize - index); - index += bytesRead; - reads++; - } - f.Close(); - if(index != uuidSize) - { - throw new System.ApplicationException("generateUUID(): could not get 16 random bytes"); - } - - // - // Adjust the bits that say "version 4" UUUID - // - buf[6] &= 0x0F; - buf[6] |= (4 << 4); - buf[8] &= 0x3F; - buf[8] |= 0x80; - - StringBuilder sb = new StringBuilder(); - for(int i = 0; i < 4; ++i) - { - sb.AppendFormat("{0:X2}", buf[i]); - } - sb.Append("-"); - for(int i = 4; i < 6; ++i) - { - sb.AppendFormat("{0:X2}", buf[i]); - } - sb.Append("-"); - for(int i = 6; i < 8; ++i) - { - sb.AppendFormat("{0:X2}", buf[i]); - } - sb.Append("-"); - for(int i = 8; i < 10; ++i) - { - sb.AppendFormat("{0:X2}", buf[i]); - } - sb.Append("-"); - for(int i = 10; i < 16; ++i) - { - sb.AppendFormat("{0:X2}", buf[i]); - } - return sb.ToString(); - } - } - - - public static int - proxyIdentityCompare(ObjectPrx lhs, ObjectPrx rhs) - { - if(lhs == null && rhs == null) - { - return 0; - } - else if(lhs == null && rhs != null) - { - return -1; - } - else if(lhs != null && rhs == null) - { - return 1; - } - else - { - Identity lhsIdentity = lhs.ice_getIdentity(); - Identity rhsIdentity = rhs.ice_getIdentity(); - int n; - n = string.Compare(lhsIdentity.name, rhsIdentity.name, false, CultureInfo.InvariantCulture); - if(n != 0) - { - return n; - } - return string.Compare(lhsIdentity.category, rhsIdentity.category, false, CultureInfo.InvariantCulture); - } - } - - public static int proxyIdentityAndFacetCompare(ObjectPrx lhs, ObjectPrx rhs) - { - if(lhs == null && rhs == null) - { - return 0; - } - else if(lhs == null && rhs != null) - { - return -1; - } - else if(lhs != null && rhs == null) - { - return 1; - } - else - { - Identity lhsIdentity = lhs.ice_getIdentity(); - Identity rhsIdentity = rhs.ice_getIdentity(); - int n; - n = string.Compare(lhsIdentity.name, rhsIdentity.name, false, CultureInfo.InvariantCulture); - if(n != 0) - { - return n; - } - n = string.Compare(lhsIdentity.category, rhsIdentity.category, false, CultureInfo.InvariantCulture); + public static Properties createProperties() + { + return new PropertiesI(); + } + + public static Properties createProperties(ref string[] args) + { + return new PropertiesI(ref args, null); + } + + public static Properties createProperties(ref string[] args, Properties defaults) + { + return new PropertiesI(ref args, defaults); + } + + public static Communicator initialize(ref string[] args) + { + return initialize(ref args, null); + } + + public static Communicator initialize(ref string[] args, InitializationData initData) + { + if(initData == null) + { + initData = new InitializationData(); + } + else + { + initData = (InitializationData)initData.Clone(); + } + + initData.properties = createProperties(ref args, initData.properties); + + CommunicatorI result = new CommunicatorI(initData); + result.finishSetup(ref args); + return result; + } + + public static Communicator initialize(InitializationData initData) + { + if(initData == null) + { + initData = new InitializationData(); + } + else + { + initData = (InitializationData)initData.Clone(); + } + + CommunicatorI result = new CommunicatorI(initData); + string[] args = new string[0]; + result.finishSetup(ref args); + return result; + } + + public static Communicator initialize() + { + return initialize(null); + } + + [Obsolete("This method is deprecated, use initialize instead.")] + public static Communicator initializeWithLogger(ref string[] args, Logger logger) + { + InitializationData initData = new InitializationData(); + initData.logger = logger; + return initialize(ref args, initData); + } + + [Obsolete("This method is deprecated, use initialize instead.")] + public static Communicator initializeWithProperties(ref string[] args, Properties properties) + { + InitializationData initData = new InitializationData(); + initData.properties = properties; + return initialize(ref args, initData); + } + + [Obsolete("This method is deprecated, use initialize instead.")] + public static Communicator initializeWithPropertiesAndLogger(ref string[] args, Properties properties, + Ice.Logger logger) + { + InitializationData initData = new InitializationData(); + initData.properties = properties; + initData.logger = logger; + return initialize(ref args, initData); + } + + public static IceInternal.Instance getInstance(Communicator communicator) + { + CommunicatorI p = (CommunicatorI) communicator; + return p.getInstance(); + } + + public static IceInternal.ProtocolPluginFacade getProtocolPluginFacade(Communicator communicator) + { + return new IceInternal.ProtocolPluginFacadeI(communicator); + } + + public static Identity stringToIdentity(string s) + { + Identity ident = new Identity(); + + // + // Find unescaped separator. + // + int slash = -1, pos = 0; + while((pos = s.IndexOf((System.Char) '/', pos)) != -1) + { + if(pos == 0 || s[pos - 1] != '\\') + { + if(slash == -1) + { + slash = pos; + } + else + { + // + // Extra unescaped slash found. + // + IdentityParseException ex = new IdentityParseException(); + ex.str = s; + throw ex; + } + } + pos++; + } + + if(slash == -1) + { + if(!IceUtil.StringUtil.unescapeString(s, 0, s.Length, out ident.name)) + { + IdentityParseException ex = new IdentityParseException(); + ex.str = s; + throw ex; + } + ident.category = ""; + } + else + { + if(!IceUtil.StringUtil.unescapeString(s, 0, slash, out ident.category)) + { + IdentityParseException ex = new IdentityParseException(); + ex.str = s; + throw ex; + } + if(slash + 1 < s.Length) + { + if(!IceUtil.StringUtil.unescapeString(s, slash + 1, s.Length, out ident.name)) + { + IdentityParseException ex = new IdentityParseException(); + ex.str = s; + throw ex; + } + } + else + { + ident.name = ""; + } + } + + return ident; + } + + public static string identityToString(Identity ident) + { + if(ident.category.Length == 0) + { + return IceUtil.StringUtil.escapeString(ident.name, "/"); + } + else + { + return IceUtil.StringUtil.escapeString(ident.category, "/") + '/' + IceUtil.StringUtil.escapeString(ident.name, "/"); + } + } + + [StructLayout(LayoutKind.Sequential)] + private struct UUID + { + public ulong Data1; + public ushort Data2; + public ushort Data3; + [MarshalAs(UnmanagedType.ByValTStr, SizeConst=8)] + public string Data4; + } + + [DllImport("rpcrt4.dll")] + private static extern int UuidCreate(ref UUID uuid); + + [DllImport("rpcrt4.dll")] + private static extern int UuidToString(ref UUID uuid, ref System.IntPtr str); + + [DllImport("rpcrt4.dll")] + private static extern int RpcStringFree(ref System.IntPtr str); + + private const int RPC_S_OK = 0; + private const int RPC_S_OUT_OF_MEMORY = 14; + private const int RPC_S_UUID_LOCAL_ONLY = 1824; + + public static string generateUUID() + { + if(AssemblyUtil.platform_ == AssemblyUtil.Platform.Windows) + { + // + // Under Windows, with both .NET and Mono, there is no /dev/urandom. + // + int rc; + UUID uuid = new UUID(); + rc = UuidCreate(ref uuid); + if(rc != RPC_S_OK && rc != RPC_S_UUID_LOCAL_ONLY) + { + Ice.SyscallException ex = new Ice.SyscallException("UuidCreate() failed"); + ex.error = rc; + throw ex; + } + System.IntPtr str = new System.IntPtr(); + rc = UuidToString(ref uuid, ref str); + switch(rc) + { + case RPC_S_OK: + { + break; + } + case RPC_S_OUT_OF_MEMORY: + { + throw new Ice.MemoryLimitException("No memory for UUID string"); + } + default: + { + Ice.SyscallException ex = new Ice.SyscallException("UuidToString() failed"); + ex.error = rc; + throw ex; + } + } + string result; + try + { + result = Marshal.PtrToStringAnsi(str); + } + catch(System.Exception ex) + { + throw new Ice.SyscallException(ex); + } + if((rc = RpcStringFree(ref str)) != RPC_S_OK) + { + Ice.SyscallException ex = new Ice.SyscallException("Cannot deallocate UUID"); + ex.error = rc; + throw ex; + } + return result; + } + else + { + // + // On Linux, /dev/random, even when used in blocking mode, sometimes + // fails or returns fewer bytes. + // Maybe we should use a combination of version 4 UUIDs (with /dev/random), + // and version 1 UUIDs (MAC address + time), when /dev/random is exhausted? + // + FileStream f = File.OpenRead("/dev/urandom"); + + const int uuidSize = 16; + byte[] buf = new byte[uuidSize]; + + // + // Limit the number of attempts to 20 reads to avoid an infinite loop. + // + int reads = 0; + int index = 0; + while(reads < 20 && index != uuidSize) + { + int bytesRead = f.Read(buf, index, uuidSize - index); + index += bytesRead; + reads++; + } + f.Close(); + if(index != uuidSize) + { + throw new System.ApplicationException("generateUUID(): could not get 16 random bytes"); + } + + // + // Adjust the bits that say "version 4" UUUID + // + buf[6] &= 0x0F; + buf[6] |= (4 << 4); + buf[8] &= 0x3F; + buf[8] |= 0x80; + + StringBuilder sb = new StringBuilder(); + for(int i = 0; i < 4; ++i) + { + sb.AppendFormat("{0:X2}", buf[i]); + } + sb.Append("-"); + for(int i = 4; i < 6; ++i) + { + sb.AppendFormat("{0:X2}", buf[i]); + } + sb.Append("-"); + for(int i = 6; i < 8; ++i) + { + sb.AppendFormat("{0:X2}", buf[i]); + } + sb.Append("-"); + for(int i = 8; i < 10; ++i) + { + sb.AppendFormat("{0:X2}", buf[i]); + } + sb.Append("-"); + for(int i = 10; i < 16; ++i) + { + sb.AppendFormat("{0:X2}", buf[i]); + } + return sb.ToString(); + } + } + + + public static int + proxyIdentityCompare(ObjectPrx lhs, ObjectPrx rhs) + { + if(lhs == null && rhs == null) + { + return 0; + } + else if(lhs == null && rhs != null) + { + return -1; + } + else if(lhs != null && rhs == null) + { + return 1; + } + else + { + Identity lhsIdentity = lhs.ice_getIdentity(); + Identity rhsIdentity = rhs.ice_getIdentity(); + int n; + n = string.Compare(lhsIdentity.name, rhsIdentity.name, false, CultureInfo.InvariantCulture); + if(n != 0) + { + return n; + } + return string.Compare(lhsIdentity.category, rhsIdentity.category, false, CultureInfo.InvariantCulture); + } + } + + public static int proxyIdentityAndFacetCompare(ObjectPrx lhs, ObjectPrx rhs) + { + if(lhs == null && rhs == null) + { + return 0; + } + else if(lhs == null && rhs != null) + { + return -1; + } + else if(lhs != null && rhs == null) + { + return 1; + } + else + { + Identity lhsIdentity = lhs.ice_getIdentity(); + Identity rhsIdentity = rhs.ice_getIdentity(); + int n; + n = string.Compare(lhsIdentity.name, rhsIdentity.name, false, CultureInfo.InvariantCulture); + if(n != 0) + { + return n; + } + n = string.Compare(lhsIdentity.category, rhsIdentity.category, false, CultureInfo.InvariantCulture); if(n != 0) - { - return n; - } + { + return n; + } - string lhsFacet = lhs.ice_getFacet(); - string rhsFacet = rhs.ice_getFacet(); + string lhsFacet = lhs.ice_getFacet(); + string rhsFacet = rhs.ice_getFacet(); if(lhsFacet == null && rhsFacet == null) { return 0; @@ -436,8 +436,8 @@ namespace Ice { return string.Compare(lhsFacet, rhsFacet, false, CultureInfo.InvariantCulture); } - } - } + } + } public static InputStream createInputStream(Communicator communicator, byte[] bytes) { @@ -449,27 +449,27 @@ namespace Ice return new OutputStreamI(communicator); } - public static Logger getProcessLogger() - { - lock(_processLoggerMutex) - { - if(_processLogger == null) - { - _processLogger = new LoggerI(System.AppDomain.CurrentDomain.FriendlyName); - } - return _processLogger; - } - } - - public static void setProcessLogger(Logger logger) - { - lock(_processLoggerMutex) - { - _processLogger = logger; - } - } - - private static object _processLoggerMutex = new object(); - private static Logger _processLogger = null; + public static Logger getProcessLogger() + { + lock(_processLoggerMutex) + { + if(_processLogger == null) + { + _processLogger = new LoggerI(System.AppDomain.CurrentDomain.FriendlyName); + } + return _processLogger; + } + } + + public static void setProcessLogger(Logger logger) + { + lock(_processLoggerMutex) + { + _processLogger = logger; + } + } + + private static object _processLoggerMutex = new object(); + private static Logger _processLogger = null; } } |