suricata
runmode-erf-dag.c
Go to the documentation of this file.
1 /* Copyright (C) 2007-2010 Open Information Security Foundation
2  *
3  * You can copy, redistribute or modify this Program under the terms of
4  * the GNU General Public License version 2 as published by the Free
5  * Software Foundation.
6  *
7  * This program is distributed in the hope that it will be useful,
8  * but WITHOUT ANY WARRANTY; without even the implied warranty of
9  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10  * GNU General Public License for more details.
11  *
12  * You should have received a copy of the GNU General Public License
13  * version 2 along with this program; if not, write to the Free Software
14  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
15  * 02110-1301, USA.
16  */
17 
18 #include "suricata-common.h"
19 #include "tm-threads.h"
20 #include "conf.h"
21 #include "runmodes.h"
22 #include "runmode-erf-dag.h"
23 #include "output.h"
24 
25 #include "detect-engine.h"
26 
27 #include "util-debug.h"
28 #include "util-time.h"
29 #include "util-cpu.h"
30 #include "util-affinity.h"
31 #include "util-runmodes.h"
32 
33 static int DagConfigGetThreadCount(void *conf)
34 {
35  return 1;
36 }
37 
38 static void *ParseDagConfig(const char *iface)
39 {
40  return (void *)iface;
41 }
42 
43 const char *RunModeErfDagGetDefaultMode(void)
44 {
45  return "autofp";
46 }
47 
49 {
51  "Multi threaded DAG mode. Packets from "
52  "each flow are assigned to a single detect "
53  "thread, unlike \"dag_auto\" where packets "
54  "from the same flow can be processed by any "
55  "detect thread",
57 
59  "Singled threaded DAG mode",
61 
63  "Workers DAG mode, each thread does all "
64  " tasks from acquisition to logging",
66 
67  return;
68 }
69 
71 {
72  int ret;
73 
74  SCEnter();
75 
77 
79 
80  ret = RunModeSetLiveCaptureSingle(ParseDagConfig,
81  DagConfigGetThreadCount,
82  "ReceiveErfDag",
83  "DecodeErfDag",
85  NULL);
86  if (ret != 0) {
87  FatalError(SC_ERR_FATAL, "DAG single runmode failed to start");
88  }
89 
90  SCLogInfo("RunModeIdsDagSingle initialised");
91 
92  SCReturnInt(0);
93 }
94 
96 {
97  int ret;
98 
99  SCEnter();
100 
102 
103  TimeModeSetLive();
104 
105  ret = RunModeSetLiveCaptureAutoFp(ParseDagConfig,
106  DagConfigGetThreadCount,
107  "ReceiveErfDag",
108  "DecodeErfDag",
110  NULL);
111  if (ret != 0) {
112  FatalError(SC_ERR_FATAL, "DAG autofp runmode failed to start");
113  }
114 
115  SCLogInfo("RunModeIdsDagAutoFp initialised");
116 
117  SCReturnInt(0);
118 }
119 
121 {
122  int ret;
123 
124  SCEnter();
125 
127 
128  TimeModeSetLive();
129 
130  ret = RunModeSetLiveCaptureWorkers(ParseDagConfig,
131  DagConfigGetThreadCount,
132  "ReceiveErfDag",
133  "DecodeErfDag",
135  NULL);
136  if (ret != 0) {
137  FatalError(SC_ERR_FATAL, "DAG workers runmode failed to start");
138  }
139 
140  SCLogInfo("RunModeIdsErfDagWorkers initialised");
141 
142  SCReturnInt(0);
143 }
thread_name_workers
const char * thread_name_workers
Definition: runmodes.c:63
tm-threads.h
detect-engine.h
RunModeSetLiveCaptureWorkers
int RunModeSetLiveCaptureWorkers(ConfigIfaceParserFunc ConfigParser, ConfigIfaceThreadsCountFunc ModThreadsCount, const char *recv_mod_name, const char *decode_mod_name, const char *thread_name, const char *live_dev)
Definition: util-runmodes.c:341
RunModeInitialize
void RunModeInitialize(void)
Definition: runmodes.c:904
util-runmodes.h
RunModeIdsErfDagSingle
int RunModeIdsErfDagSingle(void)
Definition: runmode-erf-dag.c:70
thread_name_autofp
const char * thread_name_autofp
Definition: runmodes.c:61
thread_name_single
const char * thread_name_single
Definition: runmodes.c:62
RUNMODE_DAG
@ RUNMODE_DAG
Definition: runmodes.h:36
RunModeSetLiveCaptureAutoFp
int RunModeSetLiveCaptureAutoFp(ConfigIfaceParserFunc ConfigParser, ConfigIfaceThreadsCountFunc ModThreadsCount, const char *recv_mod_name, const char *decode_mod_name, const char *thread_name, const char *live_dev)
Definition: util-runmodes.c:89
RunModeIdsErfDagWorkers
int RunModeIdsErfDagWorkers(void)
Definition: runmode-erf-dag.c:120
util-debug.h
util-cpu.h
SCEnter
#define SCEnter(...)
Definition: util-debug.h:300
util-affinity.h
util-time.h
RunModeErfDagGetDefaultMode
const char * RunModeErfDagGetDefaultMode(void)
Definition: runmode-erf-dag.c:43
runmode-erf-dag.h
conf.h
RunModeErfDagRegister
void RunModeErfDagRegister(void)
Definition: runmode-erf-dag.c:48
runmodes.h
SCLogInfo
#define SCLogInfo(...)
Macro used to log INFORMATIONAL messages.
Definition: util-debug.h:217
TimeModeSetLive
void TimeModeSetLive(void)
Definition: util-time.c:97
suricata-common.h
RunModeRegisterNewRunMode
void RunModeRegisterNewRunMode(enum RunModes runmode, const char *name, const char *description, int(*RunModeFunc)(void))
Registers a new runmode.
Definition: runmodes.c:416
RunModeIdsErfDagAutoFp
int RunModeIdsErfDagAutoFp(void)
Definition: runmode-erf-dag.c:95
FatalError
#define FatalError(x,...)
Definition: util-debug.h:532
SC_ERR_FATAL
@ SC_ERR_FATAL
Definition: util-error.h:203
RunModeSetLiveCaptureSingle
int RunModeSetLiveCaptureSingle(ConfigIfaceParserFunc ConfigParser, ConfigIfaceThreadsCountFunc ModThreadsCount, const char *recv_mod_name, const char *decode_mod_name, const char *thread_name, const char *live_dev)
Definition: util-runmodes.c:375
SCReturnInt
#define SCReturnInt(x)
Definition: util-debug.h:304
output.h