diff options
Diffstat (limited to 'CSharp/Ivy/IvyPPC/Ivy.cs')
| -rw-r--r-- | CSharp/Ivy/IvyPPC/Ivy.cs | 29 |
1 files changed, 21 insertions, 8 deletions
diff --git a/CSharp/Ivy/IvyPPC/Ivy.cs b/CSharp/Ivy/IvyPPC/Ivy.cs index 8ca2736..7332eed 100644 --- a/CSharp/Ivy/IvyPPC/Ivy.cs +++ b/CSharp/Ivy/IvyPPC/Ivy.cs @@ -118,7 +118,7 @@ namespace IvyBus {
foreach (IvyClient client in clients )
{
- client.sendApplicationId();
+ client.stream.sendApplicationId(applicationPriority, AppId);
}
}
@@ -268,7 +268,7 @@ namespace IvyBus {
throw new IvyException("can't open TCP service socket " + e);
}
- traceDebug("lib: " + libVersion + " protocol: " + IvyUDPStream.PROCOCOLVERSION + " TCP service open on port " + applicationPort);
+ traceDebug("lib: " + libVersion + " protocol: " + IvyUDPStreamV4.PROCOCOLVERSION + " TCP service open on port " + applicationPort);
watchers = new ArrayList();
Domain[] d = parseDomains(domainbus);
@@ -293,7 +293,7 @@ namespace IvyBus ((IvyWatcher) watchers[i]).start();
}
}
- public void SortClients()
+ internal void SortClients()
{
lock ( clients.SyncRoot )
{
@@ -482,7 +482,7 @@ namespace IvyBus {
foreach (IvyClient c in clients )
{
- c.sendBinding(newbind);
+ c.stream.sendBinding(newbind);
}
}
return newbind.key;
@@ -504,7 +504,7 @@ namespace IvyBus {
foreach (IvyClient c in clients )
{
- c.delBinding(bind);
+ c.stream.delBinding(bind);
}
}
lock( bindings.SyncRoot ) bindings.Remove( id );
@@ -570,12 +570,25 @@ namespace IvyBus {
foreach (IvyClient c in clients )
{
- c.sendBinding(newbind);
+ c.stream.sendBinding(newbind);
}
}
return newbind.key;
}
-
+ public int Die( string target, string message )
+ {
+ System.Collections.ArrayList v = getIvyClientsByName(target);
+ for (int i = 0; i < v.Count; i++)
+ ((IvyClient) v[i]).stream.sendDie(message);
+ return v.Count;
+ }
+ public int Ping( string target, string message)
+ {
+ System.Collections.ArrayList v = getIvyClientsByName(target);
+ for (int i = 0; i < v.Count; i++)
+ ((IvyClient)v[i]).stream.sendPing(message);
+ return v.Count;
+ }
internal void FireDirectMessage (IvyClient app, int id, byte[] arg )
{
if ( directMessageReceived != null )
@@ -818,7 +831,7 @@ namespace IvyBus {
return domainaddr + ":" + port;
}
- }
+ }
}
}
\ No newline at end of file |