RealProxy的PrivateInvoke方法在构造调用时的执行代码

王朝c#·作者佚名  2006-12-17
宽屏版  字体: |||超大  

private void PrivateInvoke(ref MessageData msgData, int type)

{

IMessage message1 = null;

CallType type1 = (CallType) type;

IMessage message2 = null;

int num1 = -1;

RemotingProxy proxy1 = null;

////////////////////////

num1 = 0;

proxy1 = this as RemotingProxy;

ConstructorCallMessage message4 = null;

bool flag1 = false;

if (!this.IsRemotingProxy())

{

message4 = new ConstructorCallMessage(null, null, null, this.GetProxiedType());

}

else

{

message4 = proxy1.ConstructorMessage;

Identity identity1 = proxy1.IdentityObject;

if (identity1 != null)

{

flag1 = identity1.IsWellKnown();

}

}

if ((message4 == null) || flag1)

{

message4 = new ConstructorCallMessage(null, null, null, this.GetProxiedType());

message4.SetFrame(msgData);

message1 = message4;

if (flag1)

{

proxy1.ConstructorMessage = null;

if (message4.ArgCount != 0)

{

throw new RemotingException(Environment.GetResourceString('Remoting_Activation_WellKnownCTOR'));

}

}

message2 = new ConstructorReturnMessage((MarshalByRefObject) this.GetTransparentProxy(), null, 0, null, message4);

}

else

{

message4.SetFrame(msgData);

message1 = message4;

}

////////////////////////

ChannelServices.IncrementRemoteCalls();

if (message2 == null)

{

LogicalCallContext context1 = null;

Thread thread1 = Thread.CurrentThread;

context1 = thread1.GetLogicalCallContext();

this.SetCallContextInMessage(message1, num1, context1);

context1.PropagateOutgoingHeadersToMessage(message1);

message2 = this.Invoke(message1);

this.ReturnCallContextToThread(thread1, message2, num1, context1);

CallContext.GetLogicalCallContext().PropagateIncomingHeadersToCallContext(message2);

}

RealProxy.HandleReturnMessage(message1, message2);

////////////////////////

MarshalByRefObject obj1 = null;

IConstructionReturnMessage message7 = message2 as IConstructionReturnMessage;

if (message7 == null)

{

throw new RemotingException(Environment.GetResourceString('Remoting_Proxy_BadReturnTypeForActivation'));

}

ConstructorReturnMessage message8 = message7 as ConstructorReturnMessage;

if (message8 != null)

{

obj1 = (MarshalByRefObject) message8.GetObject();

if (obj1 == null)

{

throw new RemotingException(Environment.GetResourceString('Remoting_Activation_NullReturnValue'));

}

}

else

{

obj1 = (MarshalByRefObject) RemotingServices.InternalUnmarshal((ObjRef) message7.ReturnValue, this.GetTransparentProxy(), true);

if (obj1 == null)

{

throw new RemotingException(Environment.GetResourceString('Remoting_Activation_NullFromInternalUnmarshal'));

}

}

if (obj1 != ((MarshalByRefObject) this.GetTransparentProxy()))

{

throw new RemotingException(Environment.GetResourceString('Remoting_Activation_InconsistentState'));

}

if (this.IsRemotingProxy())

{

proxy1.ConstructorMessage = null;

}

////////////////////////

}

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
© 2005- 王朝网络 版权所有