runmode.c

Go to the documentation of this file.

/* Copyright (C) 2024 Open Information Security Foundation
 *
 * You can copy, redistribute or modify this Program under the terms of
 * the GNU General Public License version 2 as published by the Free
 * Software Foundation.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * version 2 along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
 * 02110-1301, USA.
 */
 
#include "suricata-common.h"
#include "runmodes.h"
#include "tm-threads.h"
#include "util-affinity.h"
 
#include "runmode.h"
 
const char *CiCaptureIdsGetDefaultRunMode(void)
{
    return "autofp";
}
 
static int RunModeSingle(void)
{
    SCLogNotice("...");
 
    char thread_name[TM_THREAD_NAME_MAX];
    snprintf(thread_name, sizeof(thread_name), "%s#01", thread_name_single);
    ThreadVars *tv = TmThreadCreatePacketHandler(
            thread_name, "packetpool", "packetpool", "packetpool", "packetpool", "pktacqloop");
    if (tv == NULL) {
        SCLogError("TmThreadCreatePacketHandler failed");
        return -1;
    }
 
    TmModule *tm_module = TmModuleGetByName("ReceiveCiCapture");
    if (tm_module == NULL) {
        FatalError("TmModuleGetByName failed for ReceiveCiCapture");
    }
    TmSlotSetFuncAppend(tv, tm_module, NULL);
 
    tm_module = TmModuleGetByName("DecodeCiCapture");
    if (tm_module == NULL) {
        FatalError("TmModuleGetByName DecodeCiCapture failed");
    }
    TmSlotSetFuncAppend(tv, tm_module, NULL);
 
    tm_module = TmModuleGetByName("FlowWorker");
    if (tm_module == NULL) {
        FatalError("TmModuleGetByName for FlowWorker failed");
    }
    TmSlotSetFuncAppend(tv, tm_module, NULL);
 
    TmThreadSetCPU(tv, WORKER_CPU_SET);
 
    if (TmThreadSpawn(tv) != TM_ECODE_OK) {
        FatalError("TmThreadSpawn failed");
    }
 
    return 0;
}
 
void CiCaptureIdsRegister(int slot)
{
    RunModeRegisterNewRunMode(slot, "single", "Single threaded", RunModeSingle, NULL);
}