//
// (C) 2003, Lluis Sanchez Gual
//\r
+
+//
+// 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.
+//
\r
using System;\r
using System.IO;\r
{\r
internal class MessageFormatter\r
{\r
- public static void WriteMethodCall (BinaryWriter writer, object obj, Header[] headers, ISurrogateSelector surrogateSelector, StreamingContext context)\r
+ public static void WriteMethodCall (BinaryWriter writer, object obj, Header[] headers, ISurrogateSelector surrogateSelector, StreamingContext context, FormatterAssemblyStyle assemblyFormat)\r
{\r
IMethodCallMessage call = (IMethodCallMessage)obj;\r
writer.Write ((byte) BinaryElement.MethodCall);\r
if ((methodFlags & MethodFlags.PrimitiveArguments) > 0)\r
{\r
writer.Write ((uint)call.Args.Length);\r
- for (int n=0; n<call.InArgCount; n++)\r
+ for (int n=0; n<call.ArgCount; n++)\r
{\r
object arg = call.GetArg(n);\r
if (arg != null) {\r
\r
if (info != null)\r
{\r
- ObjectWriter objectWriter = new ObjectWriter(surrogateSelector, context);\r
+ ObjectWriter objectWriter = new ObjectWriter (surrogateSelector, context, assemblyFormat);\r
objectWriter.WriteObjectGraph (writer, info, headers);\r
}\r
else\r
writer.Write ((byte) BinaryElement.End);\r
}\r
\r
- public static void WriteMethodResponse (BinaryWriter writer, object obj, Header[] headers, ISurrogateSelector surrogateSelector, StreamingContext context)\r
+ public static void WriteMethodResponse (BinaryWriter writer, object obj, Header[] headers, ISurrogateSelector surrogateSelector, StreamingContext context, FormatterAssemblyStyle assemblyFormat)\r
{\r
IMethodReturnMessage resp = (IMethodReturnMessage)obj;\r
writer.Write ((byte) BinaryElement.MethodResponse);\r
formatFlag = MethodFlags.NoArguments;\r
else \r
{\r
- if (AllTypesArePrimitive (resp.OutArgs)) \r
+ if (AllTypesArePrimitive (resp.Args)) \r
formatFlag = MethodFlags.PrimitiveArguments;\r
else \r
{\r
\r
if (formatFlag == MethodFlags.PrimitiveArguments)\r
{\r
- writer.Write ((uint)resp.OutArgCount);\r
- for (int n=0; n<resp.OutArgCount; n++)\r
+ writer.Write ((uint)resp.ArgCount);\r
+ for (int n=0; n<resp.ArgCount; n++)\r
{\r
- object val = resp.GetOutArg(n);\r
+ object val = resp.GetArg(n);\r
if (val != null) {\r
writer.Write (BinaryCommon.GetTypeCode (val.GetType()));\r
ObjectWriter.WritePrimitiveValue (writer, val);\r
int n = 0;\r
\r
if (formatFlag == MethodFlags.ArgumentsInMultiArray)\r
- infoArray[n++] = resp.OutArgs;\r
+ infoArray[n++] = resp.Args;\r
\r
if (returnTypeTag == ReturnTypeTag.ObjectType)\r
infoArray[n++] = resp.ReturnValue;\r
info = infoArray;\r
}\r
else if ((formatFlag & MethodFlags.ArgumentsInSimpleArray) > 0)\r
- info = resp.OutArgs;\r
+ info = resp.Args;\r
\r
if (info != null)\r
{\r
- ObjectWriter objectWriter = new ObjectWriter(surrogateSelector, context);\r
+ ObjectWriter objectWriter = new ObjectWriter (surrogateSelector, context, assemblyFormat);\r
objectWriter.WriteObjectGraph (writer, info, headers);\r
}\r
else\r
writer.Write ((byte) BinaryElement.End);\r
}\r
\r
- public static object ReadMethodCall (BinaryReader reader, bool hasHeaders, HeaderHandler headerHandler, ISurrogateSelector surrogateSelector, StreamingContext context)\r
+ public static object ReadMethodCall (BinaryReader reader, bool hasHeaders, HeaderHandler headerHandler, BinaryFormatter formatter)\r
{\r
BinaryElement elem = (BinaryElement)reader.ReadByte(); // The element code\r
if (elem != BinaryElement.MethodCall) throw new SerializationException("Invalid format. Expected BinaryElement.MethodCall, found " + elem);\r
if (((BinaryTypeCode)reader.ReadByte()) != BinaryTypeCode.String) throw new SerializationException ("Invalid format");\r
string className = reader.ReadString();\r
\r
- bool hasContextInfo = (flags & MethodFlags.IncludesLogicalCallContext) > 0;
+ //bool hasContextInfo = (flags & MethodFlags.IncludesLogicalCallContext) > 0;
object[] arguments = null;
object methodSignature = null;
object callContext = null;
object[] extraProperties = null;
+ Header[] headers = null;
if ((flags & MethodFlags.PrimitiveArguments) > 0)
{
if ((flags & MethodFlags.NeedsInfoArrayMask) > 0)\r
{\r
- ObjectReader objectReader = new ObjectReader(surrogateSelector, context);\r
- object[] msgInfo = (object[]) objectReader.ReadObjectGraph (reader, hasHeaders, headerHandler);\r
+ ObjectReader objectReader = new ObjectReader (formatter);\r
+\r
+ object result;\r
+ objectReader.ReadObjectGraph (reader, hasHeaders, out result, out headers);\r
+ object[] msgInfo = (object[]) result;\r
\r
if ((flags & MethodFlags.ArgumentsInSimpleArray) > 0) {\r
arguments = msgInfo;\r
\r
if (arguments == null) arguments = new object[0];\r
\r
- Header[] methodInfo = new Header[5];\r
+ string uri = null;\r
+ if (headerHandler != null)\r
+ uri = headerHandler(headers) as string;\r
+\r
+ Header[] methodInfo = new Header[6];\r
methodInfo[0] = new Header("__MethodName", methodName);
methodInfo[1] = new Header("__MethodSignature", methodSignature);
methodInfo[2] = new Header("__TypeName", className);
methodInfo[3] = new Header("__Args", arguments);
methodInfo[4] = new Header("__CallContext", callContext);
+ methodInfo[5] = new Header("__Uri", uri);
MethodCall call = new MethodCall (methodInfo);
return call;
}\r
\r
- public static object ReadMethodResponse (BinaryReader reader, bool hasHeaders, HeaderHandler headerHandler, IMethodCallMessage methodCallMessage, ISurrogateSelector surrogateSelector, StreamingContext context)\r
+ public static object ReadMethodResponse (BinaryReader reader, bool hasHeaders, HeaderHandler headerHandler, IMethodCallMessage methodCallMessage, BinaryFormatter formatter)\r
{\r
BinaryElement elem = (BinaryElement)reader.ReadByte(); // The element code\r
if (elem != BinaryElement.MethodResponse) throw new SerializationException("Invalid format. Expected BinaryElement.MethodResponse, found " + elem);\r
LogicalCallContext callContext = null;\r
Exception exception = null;\r
object[] extraProperties = null;
+ Header[] headers = null;
\r
if ((typeTag & ReturnTypeTag.PrimitiveType) > 0)
{\r
{\r
// There objects that need to be deserialized using an ObjectReader\r
\r
- ObjectReader objectReader = new ObjectReader(surrogateSelector, context);\r
- object[] msgInfo = (object[]) objectReader.ReadObjectGraph (reader, hasHeaders, headerHandler);\r
+ ObjectReader objectReader = new ObjectReader (formatter);\r
+ object result;\r
+ objectReader.ReadObjectGraph (reader, hasHeaders, out result, out headers);\r
+ object[] msgInfo = (object[]) result;\r
\r
if ((typeTag & ReturnTypeTag.Exception) > 0) {\r
exception = (Exception) msgInfo[0];\r
reader.ReadByte (); // Reads the stream ender\r
}\r
\r
+ if (headerHandler != null) \r
+ headerHandler(headers);\r
+\r
if (exception != null)\r
return new ReturnMessage (exception, methodCallMessage);\r
else\r