Falcon
Loading...
Searching...
No Matches
event2state.hpp
1// ---------------------------------------------------------------------
2// This file is part of falcon-core.
3//
4// Copyright (C) 2015, 2016, 2017 Neuro-Electronics Research Flanders
5//
6// Falcon-server is free software: you can redistribute it and/or modify
7// it under the terms of the GNU General Public License as published by
8// the Free Software Foundation, either version 3 of the License, or
9// (at your option) any later version.
10//
11// Falcon-server is distributed in the hope that it will be useful,
12// but WITHOUT ANY WARRANTY; without even the implied warranty of
13// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14// GNU General Public License for more details.
15//
16// You should have received a copy of the GNU General Public License
17// along with falcon-core. If not, see <http://www.gnu.org/licenses/>.
18// ---------------------------------------------------------------------
19
20#pragma once
21
22#include <string>
23
24#include "eventdata/eventdata.hpp"
25#include "iprocessor.hpp"
26#include "utilities/general.hpp"
27#include "utilities/time.hpp"
28
29class Event2State : public IProcessor {
30 // CONSTRUCTOR and OVERLOADED METHODS
31 public:
32 Event2State();
33 void CreatePorts() override;
34 void Process(ProcessingContext& context) override;
35 void Postprocess(ProcessingContext& context) override;
36
37 // METHODS
38 protected:
39 BroadcasterState<bool>* enabled_;
40
41 /*
42 * During post-processing, log as info if all counters are consistent
43 * and as warning if not, all counters used: number of events received,
44 * with the number of targeted, and non-target and finally reset them.
45 *
46 * @input port_name name of the input port
47 * @input counter counter structure with three counters to log
48 * (all_received, target, non_target)
49 */
50 void log_and_reset_counters(std::string port_name, EventCounter& counter);
51
52 // DATA PORTS
53 protected:
54 PortIn<EventType>* data_in_port_;
55 PortOut<EventType>* data_out_port_;
56
57 // variables
58 protected:
59 EventCounter event_counter_;
60
61 // OPTIONS
62 protected:
63 options::Value<EventType::Data, false> target_event_{DEFAULT_EVENT,
64 options::notempty<EventType::Data>()};
65};
Definition streamports.hpp:256
Definition streamports.hpp:98
Definition runinfo.hpp:248