Skip to content

Commit f6a2fc8

Browse files
hynekkarcejkato2
authored andcommitted
SSADetector: Bugfix, improved memory consumption
1 parent 553b278 commit f6a2fc8

File tree

2 files changed

+11
-11
lines changed

2 files changed

+11
-11
lines changed

process/ssadetector.cpp

Lines changed: 11 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -133,19 +133,20 @@ void SSADetectorPlugin::update_record(RecordExtSSADetector* record, const Packet
133133
transition_from_init(record, len, ts, dir);
134134
}
135135

136-
int SSADetectorPlugin::post_create(Flow& rec, const Packet& pkt)
137-
{
138-
RecordExtSSADetector* record = new RecordExtSSADetector();
139-
rec.add_extension(record);
140-
141-
update_record(record, pkt);
142-
return 0;
143-
}
144136

145137
int SSADetectorPlugin::post_update(Flow& rec, const Packet& pkt)
146138
{
147-
RecordExtSSADetector* record
148-
= (RecordExtSSADetector*) rec.get_extension(RecordExtSSADetector::REGISTERED_ID);
139+
RecordExtSSADetector* record = nullptr;
140+
if (rec.src_packets + rec.dst_packets < MIN_PKT_IN_FLOW) {
141+
return 0;
142+
}
143+
144+
record = (RecordExtSSADetector*) rec.get_extension(RecordExtSSADetector::REGISTERED_ID);
145+
if (record == nullptr) {
146+
record = new RecordExtSSADetector();
147+
rec.add_extension(record);
148+
}
149+
149150
update_record(record, pkt);
150151
return 0;
151152
}

process/ssadetector.hpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,6 @@ class SSADetectorPlugin : public ProcessPlugin {
189189
RecordExt* get_ext() const { return new RecordExtSSADetector(); }
190190
ProcessPlugin* copy();
191191

192-
int post_create(Flow& rec, const Packet& pkt);
193192
int post_update(Flow& rec, const Packet& pkt);
194193
void pre_export(Flow& rec);
195194
void update_record(RecordExtSSADetector* record, const Packet& pkt);

0 commit comments

Comments
 (0)