merge -r 58060:58217
[mono.git] / mcs / class / corlib / System.Runtime.Remoting.Messaging / MonoMethodMessage.cs
index 5f496b8faf48dcdc56cc1d55bef7c4b1f4f9d3cb..32bee231a1ba4c72818cce50d9614a0b8063fb8b 100644 (file)
@@ -3,10 +3,34 @@
 //
 // Author:
 //   Dietmar Maurer (dietmar@ximian.com)
+//   Patrik Torstensson
 //
 // (C) Ximian, Inc.  http://www.ximian.com
 //
 
+//
+// Copyright (C) 2004 Novell, Inc (http://www.novell.com)
+//
+// Permission is hereby granted, free of charge, to any person obtaining
+// a copy of this software and associated documentation files (the
+// "Software"), to deal in the Software without restriction, including
+// without limitation the rights to use, copy, modify, merge, publish,
+// distribute, sublicense, and/or sell copies of the Software, and to
+// permit persons to whom the Software is furnished to do so, subject to
+// the following conditions:
+// 
+// The above copyright notice and this permission notice shall be
+// included in all copies or substantial portions of the Software.
+// 
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+//
+
 using System;
 using System.Collections;
 using System.Reflection;
@@ -14,38 +38,69 @@ using System.Runtime.CompilerServices;
 
 namespace System.Runtime.Remoting.Messaging {
        
-       internal class MonoMethodMessage : IMethodCallMessage, IMethodReturnMessage {
+       [Serializable]
+       internal class MonoMethodMessage : IMethodCallMessage, IMethodReturnMessage, IInternalMessage {
 
+               #region keep in sync with MonoMessage in object-internals.h
                MonoMethod method;
-
                object []  args;
-
                string []  names;
+               byte [] arg_types; /* 1 == IN; 2 == OUT; 3 == INOUT; 4 == COPY OUT */
+               public LogicalCallContext ctx;
+               public object rval;
+               public Exception exc;
+               AsyncResult asyncResult;
+               CallType call_type;
+               #endregion
 
-               byte [] arg_types; /* 1 == IN; 2 == OUT ; 3 = INOUT */
+               string uri;
 
-               public LogicalCallContext ctx;
+               MethodCallDictionary properties;
 
-               public object rval;
+               Type[] methodSignature;
+
+               Identity identity;
 
-               public Exception exc;
 
                [MethodImplAttribute(MethodImplOptions.InternalCall)]
                internal extern void InitMessage (MonoMethod method, object [] out_args);
 
-               public MonoMethodMessage (MonoMethod method, object [] out_args)
+               public MonoMethodMessage (MethodBase method, object [] out_args)
                {
-                       InitMessage (method, out_args);                 
+                       if (method != null)
+                               InitMessage ((MonoMethod)method, out_args);
+                       else
+                               args = null;
+               }
+
+               public MonoMethodMessage (Type type, string method_name, object [] in_args)
+               {
+                       // fixme: consider arg types
+                       MethodInfo minfo = type.GetMethod (method_name);
+                       
+                       InitMessage ((MonoMethod)minfo, null);
+
+                       int len = in_args.Length;
+                       for (int i = 0; i < len; i++) {
+                               args [i] = in_args [i];
+                       }
                }
                
                public IDictionary Properties {
                        get {
-                               return null;
+                               if (properties == null) properties = new MethodCallDictionary (this);
+                               return properties;
                        }
                }
 
                public int ArgCount {
                        get {
+                               if (CallType == CallType.EndInvoke)
+                                       return -1;
+                                       
+                               if (null == args)
+                                       return 0;
+
                                return args.Length;
                        }
                }
@@ -66,6 +121,10 @@ namespace System.Runtime.Remoting.Messaging {
                        get {
                                return ctx;
                        }
+
+                       set {
+                               ctx = value;
+                       }
                }
 
                public MethodBase MethodBase {
@@ -76,43 +135,68 @@ namespace System.Runtime.Remoting.Messaging {
 
                public string MethodName {
                        get {
+                               if (null == method)
+                                       return String.Empty;
+
                                return method.Name;
                        }
                }
 
                public object MethodSignature {
                        get {
-                               return null;
+                               if (methodSignature == null) {
+                                       ParameterInfo[] parameters = method.GetParameters();
+                                       methodSignature = new Type[parameters.Length];
+                                       for (int n=0; n<parameters.Length; n++)
+                                               methodSignature[n] = parameters[n].ParameterType;
+                               }
+                               return methodSignature;
                        }
                }
 
                public string TypeName {
                        get {
-                               return null;
+                               if (null == method)
+                                       return String.Empty;
+
+                               return method.DeclaringType.AssemblyQualifiedName;
                        }
                }
 
                public string Uri {
                        get {
-                               return null;
+                               return uri;
                        }
 
                        set {
+                               uri = value;
                        }
                }
 
                public object GetArg (int arg_num)
                {
+                       if (null == args)
+                               return null;
+
                        return args [arg_num];
                }
                
                public string GetArgName (int arg_num)
                {
+                       if (null == args)
+                               return String.Empty;
+
                        return names [arg_num];
                }
 
                public int InArgCount {
                        get {
+                               if (CallType == CallType.EndInvoke)
+                                       return -1;
+
+                               if (null == args)
+                                       return 0;
+
                                int count = 0;
 
                                foreach (byte t in arg_types) {
@@ -124,7 +208,7 @@ namespace System.Runtime.Remoting.Messaging {
                }
                
                public object [] InArgs {
-                       get {
+                       get {                
                                int i, j, count = InArgCount;
                                object [] inargs = new object [count];
 
@@ -173,6 +257,9 @@ namespace System.Runtime.Remoting.Messaging {
                
                public int OutArgCount {
                        get {
+                               if (null == args)
+                                       return 0;
+                               
                                int count = 0;
 
                                foreach (byte t in arg_types) {
@@ -185,6 +272,9 @@ namespace System.Runtime.Remoting.Messaging {
                
                public object [] OutArgs {
                        get {
+                               if (null == args)
+                                       return null;
+
                                int i, j, count = OutArgCount;
                                object [] outargs = new object [count];
 
@@ -231,5 +321,54 @@ namespace System.Runtime.Remoting.Messaging {
                        return null;
                }
 
+               Identity IInternalMessage.TargetIdentity
+               {
+                       get { return identity; }
+                       set { identity = value; }
+               }
+
+               public bool IsAsync
+               {
+                       get { return asyncResult != null; }
+               }
+
+               public AsyncResult AsyncResult
+               {
+                       get { return asyncResult; }
+               }
+
+               internal CallType CallType
+               {
+                       get
+                       {
+                               // FIXME: ideally, the OneWay type would be set by the runtime
+                               
+                               if (call_type == CallType.Sync && RemotingServices.IsOneWay (method))
+                                       call_type = CallType.OneWay;
+                               return call_type;
+                       }
+               }
+               
+               public bool NeedsOutProcessing (out int outCount) {
+                       bool res = false;
+                       outCount = 0;
+                       foreach (byte t in arg_types) {
+                               if ((t & 2) != 0)
+                                       outCount++;
+                               else if ((t & 4) != 0)
+                                       res = true;
+                       }
+                       return outCount > 0 || res;
+               }
+               
+       }
+
+       internal enum CallType: int
+       {
+               Sync = 0,
+               BeginInvoke = 1,
+               EndInvoke = 2,
+               OneWay = 3
        }
 }
+