Skip to content

Commit e27d3a0

Browse files
author
Damir Zainullin
committed
CTT - Fix plugin events
1 parent e5b7a46 commit e27d3a0

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

include/ipfixprobe/storage.hpp

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ class StoragePlugin : public Plugin
138138
*/
139139
bool all_data_required(const Flow& flow) const noexcept
140140
{
141-
return m_plugins_status.get_all_data.any();
141+
return flow.plugins_status.get_all_data.any();
142142
}
143143

144144
/**
@@ -148,7 +148,7 @@ class StoragePlugin : public Plugin
148148
*/
149149
bool no_data_required(const Flow& flow) const noexcept
150150
{
151-
return m_plugins_status.get_no_data.all();
151+
return flow.plugins_status.get_no_data.all();
152152
}
153153

154154
/**
@@ -161,6 +161,9 @@ class StoragePlugin : public Plugin
161161
return !all_data_required(flow) && !no_data_required(flow);
162162
}
163163
protected:
164+
uint32_t get_plugin_count() const noexcept {
165+
return m_plugin_cnt;
166+
}
164167
//Every StoragePlugin implementation should call these functions at appropriate places
165168

166169
/**

0 commit comments

Comments
 (0)