diff options
| -rw-r--r-- | CSharp/Ivy/IvyPPC/IvyWatcher.cs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/CSharp/Ivy/IvyPPC/IvyWatcher.cs b/CSharp/Ivy/IvyPPC/IvyWatcher.cs index 3ab1fb3..0cacef6 100644 --- a/CSharp/Ivy/IvyPPC/IvyWatcher.cs +++ b/CSharp/Ivy/IvyPPC/IvyWatcher.cs @@ -158,7 +158,7 @@ namespace IvyBus /// </summary>
internal virtual void stop()
{
- lock(this)
+ lock (stream)
{
traceDebug("begining stopping an IvyWatcher");
stream.Close();
@@ -174,7 +174,7 @@ namespace IvyBus internal virtual void start()
{
- lock(this)
+ lock (stream)
{
listenThread.Start();
IPEndPoint EPhost = new IPEndPoint(group, port);
@@ -183,7 +183,7 @@ namespace IvyBus }
- internal static String getDomain(String net)
+ internal static String getDomain(string net)
{
int sep_index = net.LastIndexOf(":");
if (sep_index != - 1)
@@ -204,7 +204,7 @@ namespace IvyBus return net;
}
- internal static int getPort(String net)
+ internal static int getPort(string net)
{
int sep_index = net.LastIndexOf(":");
int port = (sep_index == - 1)?Ivy.DEFAULT_PORT:Int32.Parse(net.Substring(sep_index + 1));
|