File tree Expand file tree Collapse file tree
agent/src/flow_generator/protocol_logs/rpc Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1717use serde:: Serialize ;
1818
1919use enterprise_utils:: l7:: rpc:: iso8583:: { Iso8583ParseConfig , Iso8583Parser } ;
20- use public:: l7_protocol:: { L7Protocol , LogMessageType } ;
20+ use public:: {
21+ enums:: PacketDirection ,
22+ l7_protocol:: { L7Protocol , LogMessageType } ,
23+ } ;
2124
2225use crate :: config:: handler:: LogParserConfig ;
2326use crate :: {
@@ -338,9 +341,15 @@ impl L7ProtocolParserInterface for Iso8583Log {
338341 match info. msg_type {
339342 LogMessageType :: Request => {
340343 self . perf_stats . as_mut ( ) . map ( |p| p. inc_req ( ) ) ;
344+ if param. direction == PacketDirection :: ServerToClient {
345+ info. is_reversed = true ;
346+ }
341347 }
342348 LogMessageType :: Response => {
343349 self . perf_stats . as_mut ( ) . map ( |p| p. inc_resp ( ) ) ;
350+ if param. direction == PacketDirection :: ClientToServer {
351+ info. is_reversed = true ;
352+ }
344353 }
345354 _ => { }
346355 }
You can’t perform that action at this time.
0 commit comments