From bea23caadc61013d9530f0f6391361b062e861d4 Mon Sep 17 00:00:00 2001 From: atsushi Date: Fri, 17 Jul 2009 13:47:15 +0000 Subject: [PATCH] 2009-07-17 Atsushi Enomoto * PeerDuplexChannel.cs: add the registered node itself to peer list. (The messaging must be done as TCP request/reply pattern, so it's not working yet.) git-svn-id: svn+ssh://mono-cvs.ximian.com/source/trunk/mcs@138126 e3ebcda4-bce8-0310-ba0a-eca2169e7518 --- class/System.ServiceModel/System.ServiceModel.Channels/ChangeLog | 6 ++++++ .../System.ServiceModel.Channels/PeerDuplexChannel.cs | 4 ++++ 2 files changed, 10 insertions(+) diff --git a/class/System.ServiceModel/System.ServiceModel.Channels/ChangeLog b/class/System.ServiceModel/System.ServiceModel.Channels/ChangeLog index dadd835826..aa60483cfe 100755 --- a/class/System.ServiceModel/System.ServiceModel.Channels/ChangeLog +++ b/class/System.ServiceModel/System.ServiceModel.Channels/ChangeLog @@ -1,5 +1,11 @@ 2009-07-17 Atsushi Enomoto + * PeerDuplexChannel.cs: add the registered node itself to peer list. + (The messaging must be done as TCP request/reply pattern, so it's + not working yet.) + +2009-07-17 Atsushi Enomoto + * TcpRequestChannel.cs : new channel file (TCP for request/reply messaging pattern). The messaging part is not working yet. * TcpChannelFactory.cs : support IRequestChannel. diff --git a/class/System.ServiceModel/System.ServiceModel.Channels/PeerDuplexChannel.cs b/class/System.ServiceModel/System.ServiceModel.Channels/PeerDuplexChannel.cs index 2bc8f03065..a9d74e7776 100755 --- a/class/System.ServiceModel/System.ServiceModel.Channels/PeerDuplexChannel.cs +++ b/class/System.ServiceModel/System.ServiceModel.Channels/PeerDuplexChannel.cs @@ -163,6 +163,10 @@ namespace System.ServiceModel.Channels node.RegisteredId = resolver.Register (node.MeshId, pna, timeout - (DateTime.Now - start)); node.NodeId = nid; + // Add itself to the local list as well. + // FIXME: it might become unnecessary once it implemented new node registration from peer resolver service. + peers.Add (pna); + node.SetOnline (); } } -- 2.11.4.GIT