Discussion :

[poinclin]

Salut à tous,

Je travaille sur un projet dans lequels on envoie des requêtes DII CORBA vers un serveur. Ce que je veux faire, c'est pourvoir gérer un timeout au cas où, par exemple, le serveur est mort ou ce genre de choses, histoire de pas rester sur un appel de fonction.

J'ai vu que dans l'invocation dynamique, on pouvait faire des appels asynchrones a l'aide de send_deferred. Le seul problème, c'est qu'on est obligé de questionner continuellement l'ORB à l'aide de poll_response pour savoir si une réponse est arrivée, ce qui, dans mon cas, est pénalisant car ca consomme de la charge CPU.

En lisant la doc de JacORB, j'ai vu qu'on pouvait utiliser la classe Policy pour gérer des temps, comme par exemple dire à l'ORB de délivrer les réponses avant un certain temps (mon timeout out). En revanche, aucune idée de comment il faut utiliser ca...

Donc si qqun avait deja utilisé ce systeme, ce serait vraiment qu'il me donne qqes billes pour avancer.

Merci

Julien

[Sylvain.Barthelemy]

Bonjour Julien,

Effectivement, les Policy permettent de gérer les timeout. L'OMG a ainsi défini 4 timeout policies et certains ORB en on ajouté.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
  RelativeRoundtripTimeoutPolicy
  ReplyEndTimePolicy
  RelativeRequestTimeoutPolicy
  RequestEndTimePolicy

Tout dépend de ce que tu veux faire avec les timeout. Tu peux définir des Policy pour tes appels de fonction mais tu peux aussi utiliser les Policy pour tester si ton serveur est mort ou pas, à l'aide d'un ping.

En utilisant JacORB tu peux faire un timeout à 3 secondes avec le code suivant:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
PolicyManager policyManager = PolicyManagerHelper.narrow(      
   orb.resolve_initial_references("ORBPolicyManager"));
Policy p = new
org.jacorb.orb.policies.RelativeRoundtripTimeoutPolicy(3L
* 10000000);
policyManager.set_policy_overrides(new Policy[]{ p },
                        SetOverrideType.ADD_OVERRIDE);

Tu peux aussi faire un test avec ping une fois que tu as fixé les policies, pour tester toi même si un serveur est mort. J'ai trouvé le code suivant qui fonctionne avec les policies précédentes:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
  CORBA::Object_var newObj = ior->_set_policy_overrides ( policies, CORBA::ADD_OVERRIDE );
  try
    {
      SBase_var newSB = SBase::_narrow ( newObj );
      if ( !CORBA::is_nil ( newSB ) )
	newSB->Ping();
    }
  catch ( const CORBA::NO_RESPONSE& )
    {
      cout << "ping timed out" << endl;
    &#125;
  catch &#40; CORBA&#58;&#58;Exception& e &#41;
    &#123;
      cout << e;
    &#125;

Sinon, tout ca est très bien expliqué ici:
http://www.cs.wustl.edu/~schmidt/PDF/C++-report-col19.pdf


Cordialement.

[poinclin]

Merci, j'ai juste encore un souci, en ce qui concerne l'erreur qui devrait être renvoyée par l'ORB. Normalement, une exception org.omg.CORBA.TIMEOUT est levée, ce qui n'arrive jamais chez moi.

Pour info, mon code :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
try
{
     Policy p = new RelativeRoundtripTimeoutPolicy(1000);
     PolicyManager policyManager = PolicyManagerHelper.narrow(
          orb.resolve_initial_references("ORBPolicyManager"));
     policyManager.set_policy_overrides(
          new Policy[] { p },SetOverrideType.ADD_OVERRIDE);
     requestOnObject.invoke();
}
catch (Exception e)
{
     System.out.println("TO");
     e.printStackTrace();
}

Ce qui est sur, c'est que ma méthode invoke met au moins 15ms pour être exécutée, donc le timeout (qui est ici de 0,1ms) est écoulé alors que je n'entre jamais dans le catch.

Si qqun a une idee, merci

Julien

[Sylvain.Barthelemy]

Mon exemple avec le ping était justement fait pour lever des exceptions de TIMEOUT. Mais si tu es sur JacORB, le plus simple est d'utiliser les deux timeout policies qui ont été définies depuis la version 1.4.1 et qui lèvent des TIMEOUT exceptions:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
jacorb.connection.client.pending_reply_timeout: timeout sur les requêtes
jacorb.connection.client.idle_timeout: timeout sur les connections

Tu peux mettre tout ca dans le fichier de config (properties) de JacORB. Il est vrai que tout celà n'est pas tout à fait évident parce qu'il y a les 4 timeout policies de l'OMG et puis après ca, en fonction des implémentations les choses sont plus ou moins conformes. Pour prendre un autre exemple, IONA a ajouté les policies suivantes:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
  BindingEstablishmentPolicy
  RelativeBindingExclusiveRoundtripTimeoutPolicy
  RelativeBindingExclusiveRequestTimeoutPolicy
  InvocationRetryPolicy
  RelativeConnectionCreationTimeoutPolicy

La meilleure chose à faire pour ce genre de choses, est de consulter en détail la doc de l'ORB concerné, pour voire ce qu'ils recommandent d'utiliser pour les TIMEOUT. Ainsi, dans le cas de JacORB, le plus simple semble être d'utiliser le fichier de config.

Bye.

[poinclin]

Il semblerait qu'il y ait un bug dans la distrib 2.2 de JacORB au sujet de cette property particulière (c'est pas de chance pour moi sur ce coup là...)

http://www.jacorb.org/cgi-bin/bugzil...bug.cgi?id=482

En attendant des suggestions particulières, je fais voir ce que je peux faire avec leur patch...

Julien

[poinclin]

Sur le site de JacORB, on peut trouver la correction du bug :

http://www.jacorb.org/cgi-bin/cvsweb...-cvsweb-markup

En revanche, cette correction n'est pas incluse dans la distribution standard. Il faut alors télécharger les sources, les compiler avec Ant après avoir remplacé le fichier incriminé...

Pour le moment, j'obtiens donc un CORBA_TIMEOUT avec la propriété
jacorb.connection.client.pending_reply_timeout

Je mettrai un résolu quand je verrai quand ca marche parfaitement

Julien

[Sylvain.Barthelemy]

Pour le moment, j'obtiens donc un CORBA_TIMEOUT avec la propriété
jacorb.connection.client.pending_reply_timeout

C'est déjà ça.

Je mettrai un résolu quand je verrai quand ca marche parfaitement

C'est d'accord, et d'ici là, bon courage à toi.

A bientôt.