Пример крупной утечки памяти с ADOMD.NET 8.0. AS2000, база FoodMart 2000. В цикле запускаем поток, ждем 5 секунд, abort-аем поток. В потоке устанавливаем коннект, открываем ридер, начинаем читать, и если оборвали - не закрываем ридер, так как будет КОНКРЕТНЫЙ тормоз (почему - см. выше).
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.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
using System;
using System.Threading;
using System.Xml;
using Microsoft.AnalysisServices.AdomdClient;
namespace AdomdMemotyLeakTest
{
class Program
{
static void Main(string[] args)
{
for (int i = 0 ; i < 1000 ; ++i)
{
Thread t = new Thread(new ThreadStart(RunTest2));
t.Start();
Thread.Sleep( 5000 );
t.Abort();
Console.WriteLine("Launch: {0}", i);
}
Console.ReadLine();
}
static void RunTest2()
{
Thread.CurrentThread.Priority = ThreadPriority.BelowNormal;
Thread.CurrentThread.SetApartmentState(ApartmentState.MTA);
AdomdConnection conn = new AdomdConnection("Data Source=localhost;Catalog=FoodMart 2000;ConnectTo=8.0");
bool aborted = false;
XmlReader reader = null;
try
{
AdomdCommand command = conn.CreateCommand();
command.CommandText =
@"
select
{{[Product].[Product Name].Members} *
{[Customers].[Name].Members}}
on columns,
[Store].[Store Name].Members on rows
from sales
";
conn.Open();
reader = command.ExecuteXmlReader();
while (reader.Read())
Thread.Sleep( 68 );
}
catch (ThreadAbortException)
{
aborted = true;
}
finally
{
if (!aborted)
reader.Close();
try
{
conn.Close();
}
catch (Exception ex)
{
Console.WriteLine("Exception: {0}", ex.Message);
}
}
GC.Collect();
}
}
}
И наблюдаем вот такую картину:
0) если поток обрывается на момент выполнения XmlaReader.Read(), то срабатывает XmlaReader.HandleException который успешно сделает XmlaClient.Disconnect(endsession=false). Тот в свою очередь вызовет CloseAll, дальше IXmlaStream.Dispose(), ну а тот закроет все стримы построенные на COM (NativeIStream и пр.).
Проблема: память при этом ДАЖЕ НЕ ДУМАЕТ освобождаться.
1) если поток обрывается на момент выполнения действия после Read (в демонстрационном коде - Thread.Sleep(68)), то connection.Close() вылетает с грохотом "The connection cannot be used while an XMLReader object is open". А почему? А потому в отличие от предыдущего случае идет вызов XmlaClient.Disconnect(endsession=true) -> XmlaClient.EndSession, который естественно отваливается ибо ридер еще открыт.
2) AdomdCommand.Cancel, вызваннае как перед Thread.Abort, так и внутри, не помогает - матерится "the session sddsf384932jdsdasff does not exist" если поток обрывается на момент XmlaReader.Read.
А в чем же задача? В том, чтобы в реальной апликации оборвать выполнение запроса, когда пользователь нажал на кнопку Cancel.
Так вот, если обрывать поток, то память не освобождается. Даже несмотря на то, что теоретически все закрыто. Если запустить вышеуказанный пример, то можно наблюдать как размер памяти, занимаемой процессом, все пухнет, пухнет, пухнет, пока не зажрет все и не вылетит "you are out of virtual memory". .NET Memory Profiler показывает, что проблема как раз в native memory. Похоже на то, что если не выкачать из ридера все то, что пользователю 100 лет не нужно (ибо он нажал Cancel), то даже несмотря на все вызовы Marshal.ReleaseComObject(this.nativeIStream) native memory не освобождается, и все тут.
Короче, люди добрые, у меня полный стопор. Надо оборвать выполнение команды, да так, чтобы вся память ОСВОБОДИЛАСЬ, и чтобы сам процесс обрыва ПРОХОДИЛ МГНОВЕННО.
Буду очень благодарен за любые советы.
