Discussion :

[juju1988]

Bonjour,

J'utilise une application serveur socket Delphi pour communiquer avec une application cliente windev mobile. Mon scan envoit des trames au serveur qui me retourne des réponses. Mon serveur de socket Delphi tourne en permanence.
J'utilise Oracle et notamment le composant OracleSession pour me connecter à ma base de données.
Après quelques mois j'ai eu une erreur "Nombre maximal de curseurs ouverts atteints".
J'ai testé cette requête :

Code :

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

Select * from V$system_parameter where name = 'open_cursors' ;

Qui m'a permis de voir que j'avais une autorisation de 300 curseurs ouverts par session.
J'utilise de nombreuses requêtes mais je prend soin de faire un .Close à la fin de chacune de mes procédures.
J'ai ensuite regarder le nombre de curseurs actifs un instant T pour ma session grâce à cette requête :

Code :

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

1
2
3
4
5
select user_name, status, osuser, machine, a.sql_text
from v$session b,
v$open_cursor a
where a.sid = b.sid
and osuser =nomdemassesion/

Et j'ai vu que j'avais 262 curseurs actifs... en stoppant mon serveur ce chiffre passe à 158...
Je pense donc que des curseurs ne sont pas fermés... pourtant je prend soin de faire des .Close sur toutes mes requêtes utilisées à la fin de chacune de mes procédures....

Est ce qu'il y'a quelque chose à faire sur le OracleSession ?

[ShaiLeTroll]

utilise des try finally pour garantir qu'un Close correspond à un Open même si une exception se produit durant un traitement ou alors à cause d'un Exit trop bien caché !

Si tu as le "sql_text" ça devrait t'aider à traquer les coupables ! non ?

On ne peut que penser qu'il manque des Close, à cause de rupture dans le cheminement des fonctions !

As-tu dans tes Objets OnAfterClose, OnAfterOpen ?
Dans une phase d'analyse, enregistret dans un log toute ouverture et toute fermeture !
Cela sera fastidieux à trouver tous les objets dans le code mais tu devrais au fur et à mesure trouver les fuites !

Pour ma part, j'avais traqué aussi les Query non fermées dans un projet dont j'avais maintenance, les Query étant créés par une Factory (une chance), je pouvais aisément surveiller leur création, un thread scrutait régulièrement les adresses mémoires avec ma fonction RealAssigned (IsBadReadPtr couplé à ClassName, ClassType et is), je détectais ainsi les libérations et seules les Query non libérées trainaient
En général, une Query était fermée puis libérée, pas de DataModule ni d'objets posés sur les fenêtres à quelques exceptions près !

Comment gères-tu tes Query, tu as des DataModule et donc les Query sont créées une seule fois et tu fais des Open\Close !
Ou tu utilises une Factory ou une instanciation manuelle locale à la fonction ?

Pense que si tu peux utiliser Prepared sur tes Query les plus utilisées dont l'instance reste tout le long de ton serveur, leurs performances seront améliorées

[juju1988]

J'utilise des try finally quasiment de partout...
Pas de OnAfeterClose ni de OnAfterOpen...
Je n'utilise pas de DatModule je créée simplement ma requête en début de procédure et j'utilise des .Execute, ou des .Exectue puis .Commit et je fais des .Close à chaque fin de procédure dans mon finally...

Un exemple de procédure :

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
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
// -----------------------------
// SI06 Test du numéro de série du colis
//------------------------------
procedure TestColisSerie(adIp : string; numeroCmd : string; ligne : string; lot : string; sMod : string; sAct : string; OraSession : TOracleSession; SerSocket : TServerSocket; idConnex : integer; Trace : TMemo);
var
  oqSelect : TOracleQuery;
begin
 
oqSelect := TOracleQuery.Create(Nil);
oqSelect.Session := OraSession;
 
  Try
    oqSelect.Close;
    oqSelect.SQL.Clear;
    oqSelect.SQL.Add('select count(*) as total from COLXRES where NUMXCOL=:num and LIGXCOL=:lig and LT1XCOL=:lot');
    oqSelect.DeclareAndSet('num', otInteger, StrToInt(numeroCmd));
    oqSelect.DeclareAndSet('lig', otInteger, StrToInt(ligne));
    oqSelect.DeclareAndSet('lot', otInteger, lot);
    if TestRequete(oqSelect, 'OPENREQ') then
    begin
      if oqSelect.Field('total') > 0 then
      begin
        envoiMsgSocket(idConnex, numeroCmd, 'NUMSERIEDEJA', SerSocket, Trace);
        maj_raoxres('', adIp, sMod, sAct, '', numeroCmd, '', '', '', 'Prep Chariot - Num Serie déjà saisi', '', 1, 0, 0, 0, 0, 0, 0, 0, 0, 'N', 'N', 'N', 'A', OraSession);
      end
      else
      begin
        envoiMsgSocket(idConnex, numeroCmd, 'SERIEOK', SerSocket, Trace);
        maj_raoxres('', adIp, sMod, sAct, '', numeroCmd, '', '', '', 'Prep Chariot - Num Serie Ok', '', 1, 0, 0, 0, 0, 0, 0, 0, 0, 'N', 'N', 'N', 'A', OraSession);
      end;
    end
    else
    begin
      envoiMsgSocket(idConnex, numeroCmd, 'ANOMALIERECHSERIE', SerSocket, Trace);
      maj_raoxres('', adIp, sMod, sAct, '', numeroCmd, '', '', '', 'Prep Chariot - Anomalie recherche num série', '', 1, 0, 0, 0, 0, 0, 0, 0, 0, 'N', 'N', 'N', 'A', OraSession);
    end;
  Finally
    oqSelect.Close; oqSelect.Free;
  End;
end;

Sachant que l'exécution de ma procédure se fait dans le TestRequete :

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
17
18
19
20
21
22
23
24
25
26
27
28
29
function TestRequete(requete : TOracleQuery ; lancer : string) : boolean;
var
   x_i : integer;
   x_ok : boolean;
   erreurMsg : string;
begin
  Result := True;
  try
    case AnsiIndexStr(lancer, ['OPENREQ', 'EXECUTE']) of
 
      0 : begin
            requete.Execute;
          end;
      1 : begin
            requete.Execute;
            requete.Session.Commit;
          end;
      -1 : begin
             Result:=False;
             LogErreur('Anomalie dans TestRequete  = '+lancer);// Message d''erreur : '+ e.Message);
           end;
    end;
    except on e:exception do
    begin
      Result:=False;
      LogErreur('Anomalie sur la requête ' + requete.SQL.Text +' : Message d''erreur : '+ e.Message);
    end;
  end;
end;