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  RUNMODE_DAG, "single", "Singled threaded DAG mode", RunModeIdsErfDagSingle, NULL);
60 
62  "Workers DAG mode, each thread does all "
63  " tasks from acquisition to logging",
65 
66  return;
67 }
68 
70 {
71  int ret;
72 
73  SCEnter();
74 
76 
78 
79  ret = RunModeSetLiveCaptureSingle(ParseDagConfig,
80  DagConfigGetThreadCount,
81  "ReceiveErfDag",
82  "DecodeErfDag",
84  NULL);
85  if (ret != 0) {
86  FatalError("DAG single runmode failed to start");
87  }
88 
89  SCLogInfo("RunModeIdsDagSingle initialised");
90 
91  SCReturnInt(0);
92 }
93 
95 {
96  int ret;
97 
98  SCEnter();
99 
101 
102  TimeModeSetLive();
103 
104  ret = RunModeSetLiveCaptureAutoFp(ParseDagConfig, DagConfigGetThreadCount, "ReceiveErfDag",
105  "DecodeErfDag", thread_name_autofp, NULL);
106  if (ret != 0) {
107  FatalError("DAG autofp runmode failed to start");
108  }
109 
110  SCLogInfo("RunModeIdsDagAutoFp initialised");
111 
112  SCReturnInt(0);
113 }
114 
116 {
117  int ret;
118 
119  SCEnter();
120 
122 
123  TimeModeSetLive();
124 
125  ret = RunModeSetLiveCaptureWorkers(ParseDagConfig, DagConfigGetThreadCount, "ReceiveErfDag",
126  "DecodeErfDag", thread_name_workers, NULL);
127  if (ret != 0) {
128  FatalError("DAG workers runmode failed to start");
129  }
130 
131  SCLogInfo("RunModeIdsErfDagWorkers initialised");
132 
133  SCReturnInt(0);
134 }
thread_name_workers
const char * thread_name_workers
Definition: runmodes.c:81
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:322
RunModeInitialize
void RunModeInitialize(void)
Definition: runmodes.c:985
util-runmodes.h
RunModeIdsErfDagSingle
int RunModeIdsErfDagSingle(void)
Definition: runmode-erf-dag.c:69
thread_name_autofp
const char * thread_name_autofp
Definition: runmodes.c:79
RunModeRegisterNewRunMode
void RunModeRegisterNewRunMode(enum RunModes runmode, const char *name, const char *description, int(*RunModeFunc)(void), void(*RunModeIsIPSEnabled)(void))
Registers a new runmode.
Definition: runmodes.c:491
thread_name_single
const char * thread_name_single
Definition: runmodes.c:80
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:86
RunModeIdsErfDagWorkers
int RunModeIdsErfDagWorkers(void)
Definition: runmode-erf-dag.c:115
util-debug.h
util-cpu.h
SCEnter
#define SCEnter(...)
Definition: util-debug.h:271
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:224
TimeModeSetLive
void TimeModeSetLive(void)
Definition: util-time.c:99
suricata-common.h
RunModeIdsErfDagAutoFp
int RunModeIdsErfDagAutoFp(void)
Definition: runmode-erf-dag.c:94
FatalError
#define FatalError(...)
Definition: util-debug.h:502
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:351
SCReturnInt
#define SCReturnInt(x)
Definition: util-debug.h:275
output.h