| Age | Commit message (Collapse) | Author |
|---|
|
|
|
|
|
|
|
|
|
in some rare case
|
|
|
|
only the pattern [callback, arg ...] was allowed, but another
pattern is allowed : [obj, method, arg]
|
|
|
|
* New upstream version: * verify validity callback arg in bindRegexp
instead of verifiying it whell actually calling the callback
-- Alexandre Bustico <bustico@cena.fr> Wed, 14 Fev 2008 16:43:00 +0200
|
|
|
|
|
|
|
|
|
|
revert to ip adress
* when etablishing tcp connection as an answer
to bonjour msg, use directly adress of udp
socket instead of doing 2 useless name resolution
|
|
|
|
|
|
a read on a socket fails
|
|
|
|
* force socket on raw mode
* when read or write returns error, examine errno before closing connexion
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
inmplementations (uuid and appName were swapped)
|
|
|
|
because of
wrong generation of uuid on 32 bits system (64 bits was ok).
b/ bad filtering of non printable char in appname argument in callback statusFunc
|
|
test mainloop fix of Ivy.pm
|
|
|
|
message,
le desabonnement devenant donc automatique.
|
|
precedemment fait avec bindRegexp de manière atomique.
|
|
interval support within the regular expression definition.
|
|
de la forme A=((?I10#20))
l'api ne change pas.
|
|
Alexandre Bustico <alexandre.bustico@cena.fr>
|
|
|
|
|
|
|
|
|
|
s'abonnent
à des regexps identiques, de manière à savoir si ça vaut le coups de changer les structures
de données dans les libs ivy : à l'heure actuelle on a des liste de regexp par agent, si il y a
beaucoup de regexp communes à differents agents ça serait plus optimisé d'avoir une table de hash
regexp ->[ liste d'appli abonnées] pour que sur un sendmessage les regexp ne soient parsé qu'une
fois.
|
|
polling des agents via les messages ping et pong pour sortir des stats sur la charge des agents
|
|
|
|
° bindRegexp : 3eme argument optionnel : si sa valeur est 0 ou undef, fonctionnement inchangé,
si sa valeur est 1 le premier argument fourni à la callback est une liste
[nom, adresse, n° port] au lieu juste du nom de l'agent qui envoie le message
° la callback statusFunc : est appelée avec 7 arguments au lieu de 6 : arg 1 à 5 inchangé,
arg 6 $host_or_regexp changé par $host, $regexp, si il n'y a pas de regexp $regexp vaut undef
|
|
|
|
|
|
non blocking
mode was requested
° Optimisation : remove buffer copy when it's possible
ivyprobe.pl : ° use non blocking mode,
° fix bug with the use of gnu readline : now editing previous entries is possible
° add -regexpFile regexpfile option : ivyprobe.pl will bind qll the regexp
which are in the file given in argument.
° add -filter class1,classe2,...,classeN : add the possibility to filter messages
for test/debug purpose.
testCongestionTk.pl : simple demo which demonstrate non blocking mode with Tk
|
|
non blocking
mode was requested
° Optimisation : remove buffer copy when it's possible
|
|
une modification du message UDP Hello afin d'y intégrer un
identificateur unique d'application et le nom de l'application
Ceci afin de corriger les problèmes de connexion multiples en cas
d'utilisation de plusieurs réseau ( il arrive que l'on reçoive plusieurs
fois le paquet ) L'identifiant permettra d'identifier à coup sur
l'application et donc de rejeter les paquets multiples
Le protocole reste compatible avec les anciennes versions d'ivy.
2/ notification des congestions :
on spécifier une callback qui sera appelée si un client ne consomme pas ses
messages assez vite : la callback n'est appelée que lors d'un changement
d'état : congestion ou decongestion.
my $bus = Ivy->new (-slowAgentFunc=> \&congestionFunc )
sub congestionFunc ($$$)
{
my ($name, $addr, $state) = @_;
if ($state == 1) {
printf ("$name [$addr] %s will stop at N=%d\n", $state ? "CONGESTION" :
"OK", $numberOfSentMsg+100);
$numberOfSentMsgWhenCongestion = $numberOfSentMsg;
} else {
printf ("$name [$addr] %s\n", $state ? "CONGESTION" : "OK");
}
}
3/ possibilité de rendre Ivy non bloquant : si un client ne consomme pas
ses messages assez vite les messages seront accumulés en local et le
sendMsgs non bloquant rendra la main.
my $bus = Ivy->new (-blockOnSlowAgent => 0)
4/ optimisation en terme de vitesse et de conso mémoire.
|
