diff options
| author | fcolin | 2007-02-01 09:54:54 +0000 |
|---|---|---|
| committer | fcolin | 2007-02-01 09:54:54 +0000 |
| commit | df2dac6f13eb95a451142228da9900c8198e39d0 (patch) | |
| tree | 7e1861a6dabb8a0293c12d455678971969a30d46 /CSharp/Ivy/IvyPPC/Ivy.cs | |
| parent | ce08b27551323c7a3d3572399ea6e1f79e651c96 (diff) | |
| download | ivy-csharp-df2dac6f13eb95a451142228da9900c8198e39d0.zip ivy-csharp-df2dac6f13eb95a451142228da9900c8198e39d0.tar.gz ivy-csharp-df2dac6f13eb95a451142228da9900c8198e39d0.tar.bz2 ivy-csharp-df2dac6f13eb95a451142228da9900c8198e39d0.tar.xz | |
Utilisateur : Fcolin Date : 1/12/05 Heure : 17:47 Archivé dans $/CSharp/Ivy Commentaire: (vss 29)
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 |