OscarCanek
commented
8 years ago Problema
Actualmente existe un problema al llamar al método Dispose en las consultas con sentencia Group by. Al ejecutar una consulta, procesar eventos y llamar a Dispose se obtiene el siguiente error:
An exception of type 'System.NullReferenceException' occurred in Integra.Messaging.dll but was not handled in user code
Additional information: Object reference not set to an instance of an object.Revisando el código generado por la expresión creada durante la compilación se puede observar que el código generado tiene la misma estructura que el observable esperado en c#. El problema parece ser que hace Dispose sin antes terminar de procesar el conjunto completo de eventos de los grupos, comportamiento que en el observable esperado no ocurre.
Cabe mencionar que la llamada al método
Disposeen consultas de la forma: from SpaceObservable1 select @event.Message.#1.#18 as MCC; no ocurre ningún problema.
Objetivo
Analizar el origen del error y proponer soluciones para los casos en donde se analizan grupos de eventos, ya que la estructura en los dos códigos sigue el mismo patrón pero el generado a partir de la compilación da error al ejecutarse.
Contexto
El siguiente EQL es uno de los casos para los que se necesita llamar al método Dispose de los mensajes en los eventos procesados.
from SpaceObservable1
apply window of '00:00:00:01'
group by @event.Message.#1.CardAcceptorNameLocation as grupo1
select top 1 grupo1 as Llave,
sum((decimal)@event.Message.#1.TransactionAmount) as Sumatoria
order by desc SumatoriaNota: es un EQL que contiene Group by
El siguiente código muestra la estructura del observable esperado de la compilación.
SourceTest.source
.Buffer(TimeSpan.FromSeconds(1))
.Select<IList<EventObject>, IEnumerable<Test>>(b =>
{
IEnumerable<Test> resFinal = b
.GroupBy<EventObject, object>(y => new { g1 = y.Message["Body"]["MerchantType"].Value.ToString() }, new GroupByKeyComparer<object>())
.Select<IGrouping<object, EventObject>, Test>(e =>
{
Test t = new Test();
t.A = e.Key;
t.B = e.Sum(e1r => (decimal)e1r.Message[1][4].Value);
e.ToList().ForEach(x => x.Message.Dispose());
return t;
})
.OrderByDescending(x => (decimal)x.B)
.Take(1)
;
return resFinal;
});El código generado de la expresión creada por el compilador que se necesita analizar se encuentra en el siguiente archivo: Codigo generado de la expresion creada.txt
A continuación se muestran las partes del código de la expresión creada necesarias para entender su estructura:
El siguiente bloque de código representa en rx el select del group by: .Select<IGrouping<object, EventObject>, dynamic>(e =>
$EnumerableGroupBy = .Call System.Linq.Enumerable.Select(
.Block(System.Collections.Generic.IEnumerable`1[System.Linq.IGrouping`2[SpaceDynamicType_36,Integra.Space.Event.EventObject]] $resultGroupByObservable)
{
.Try {
.Block() {
.If (
True
) {
.Call System.Diagnostics.Debug.WriteLine("Start of the enumerable group by")
} .Else {
.Default(System.Void)
};
$resultGroupByObservable = .Call System.Linq.Enumerable.GroupBy(
$var3,
.Lambda #Lambda2<System.Func`2[Integra.Space.Event.EventObject,SpaceDynamicType_36]>,
.New Integra.Space.Language.Runtime.GroupByKeyComparer`1[SpaceDynamicType_36]());
.If (
True
) {
.Call System.Diagnostics.Debug.WriteLine("End of the enumerable group by")
} .Else {
.Default(System.Void)
};
.Default(System.Void)
}
} .Catch (System.Exception $var4) {
.Block() {
.Call System.Diagnostics.Debug.WriteLine("Error");
.Throw .New Integra.Space.Language.Exceptions.RuntimeException(
"RuntimeException: Line: 0, Column: 52, Instruction: group by @event.Message.#1.CardAcceptorNameLocation as grupo1, Error: RE25: Error with 'group by' function.",
$var4)
}
};
$resultGroupByObservable
},
.Lambda #Lambda3<System.Func`2[System.Linq.IGrouping`2[SpaceDynamicType_36,Integra.Space.Event.EventObject],SpaceDynamicType_642]>)Lambda3 es el lambda del select
.Lambda #Lambda3<System.Func`2[System.Linq.IGrouping`2[SpaceDynamicType_36,Integra.Space.Event.EventObject],SpaceDynamicType_642]>(System.Linq.IGrouping`2[SpaceDynamicType_36,Integra.Space.Event.EventObject] $var14)$var14 en el bloque anterior es la variable e en el observable.
La parte del observable e.ToList().ForEach(x => x.Message.Dispose()); se encuentra en el siguiente bloque:
.Try {
.Block() {
.If (
True
) {
.Call System.Diagnostics.Debug.WriteLine("Start of the enumerable to list")
} .Else {
.Default(System.Void)
};
.Call (.Block(System.Collections.Generic.List`1[Integra.Space.Event.EventObject] $ToListParam) {
.Try {
.Block() {
.If (
True
) {
.Call System.Diagnostics.Debug.WriteLine("Start of the enumerable to list")
} .Else {
.Default(System.Void)
};
.If ($var14 != null) {
$ToListParam = .Call System.Linq.Enumerable.ToList($var14)
} .Else {
.Default(System.Void)
};
.If (
True
) {
.Call System.Diagnostics.Debug.WriteLine("End of the enumerable to list")
} .Else {
.Default(System.Void)
};
.Default(System.Void)
}
} .Catch (System.Exception $var19) {
.Block() {
.Call System.Diagnostics.Debug.WriteLine("Error");
.Throw .New Integra.Space.Language.Exceptions.RuntimeException(
"RuntimeException: Line: 0, Column: 114, Instruction: select top listOfValues: numero grupo1 as Llave, sum((decimal)@event.Message.#1.TransactionAmount) as Sumatoria, Error: RE54: Error with ToList method.",
$var19)
}
};
$ToListParam
}).ForEach(.Lambda #Lambda6<System.Action`1[Integra.Space.Event.EventObject]>);
.If (
True
) {
.Call System.Diagnostics.Debug.WriteLine("End of the enumerable to list")
} .Else {
.Default(System.Void)
}
}
}El código que precede al código del bloque anterior es el setteo de las propiedades del objeto del tipo creado para la proyección con los valores resultantes, como se muestra en la siguiente imagen.
Lambda6 es la llamada al método Dispose de cada mensaje de grupo, representa x => x.Message.Dispose() donde $ForEachParam es igual a x
.Lambda #Lambda6<System.Action`1[Integra.Space.Event.EventObject]>(Integra.Space.Event.EventObject $ForEachParam) {
.Block() {
.If (
True
) {
.Call System.Diagnostics.Debug.WriteLine("++++++++++++++++++++")
} .Else {
.Default(System.Void)
};
.If ($ForEachParam != null) {
.Block() {
.If (
True
) {
.Call System.Diagnostics.Debug.WriteLine("**************")
} .Else {
.Default(System.Void)
};
.If (.Call $ForEachParam.get_Message() != null) {
.Block() {
.Call System.Diagnostics.Debug.WriteLine("Hará dispose del mensaje.");
.Call ($ForEachParam.Message).Dispose();
.Call System.Diagnostics.Debug.WriteLine("Hizo dispose del mensaje.")
}
} .Else {
.Default(System.Void)
}
}
} .Else {
.Default(System.Void)
}
}
}Conclusión
La estructura del código generado sigue el mismo patrón que la estructura del código del observable esperado, sin embargo el código generado por la compilación da error al ejecutarse.
marianogenovese
Como parte de la optimización en el procesamiento de eventos, se debe llamar al método
Disposede los mensajes Integra que ya hayan sido procesados por el observable. Para realizar esta tarea se debe agregar al árbol de ejecución de cada sentencia los nodos necesarios para hacer la llamada al método previamente mencionado, dependiendo si la sentencia tienegroup by, soloapply window of, solofrom ... select ..., etc.Pautas a seguir:
Disposedel mensaje de cada evento procesado.Disposecon Expression trees.Este issue esta relacionado con el issue iidec/Integra.Space.Services#7.