void AppLayerParserPostStreamSetup(void)
{
- AppProto alproto = 0;
- int flow_proto = 0;
-
/* lets set a default value for stream_depth */
- for (flow_proto = 0; flow_proto < FLOW_PROTO_DEFAULT; flow_proto++) {
- for (alproto = 0; alproto < ALPROTO_MAX; alproto++) {
+ for (int flow_proto = 0; flow_proto < FLOW_PROTO_DEFAULT; flow_proto++) {
+ for (AppProto alproto = 0; alproto < ALPROTO_MAX; alproto++) {
if (!(alp_ctx.ctxs[flow_proto][alproto].internal_flags &
APP_LAYER_PARSER_INT_STREAM_DEPTH_SET)) {
alp_ctx.ctxs[flow_proto][alproto].stream_depth =
{
SCEnter();
- AppProto alproto = 0;
- uint8_t flow_proto = 0;
- AppLayerParserThreadCtx *tctx;
-
- tctx = SCMalloc(sizeof(*tctx));
+ AppLayerParserThreadCtx *tctx = SCCalloc(1, sizeof(*tctx));
if (tctx == NULL)
goto end;
- memset(tctx, 0, sizeof(*tctx));
- for (flow_proto = 0; flow_proto < FLOW_PROTO_DEFAULT; flow_proto++) {
- for (alproto = 0; alproto < ALPROTO_MAX; alproto++) {
+ for (uint8_t flow_proto = 0; flow_proto < FLOW_PROTO_DEFAULT; flow_proto++) {
+ for (AppProto alproto = 0; alproto < ALPROTO_MAX; alproto++) {
uint8_t ipproto = FlowGetReverseProtoMapping(flow_proto);
tctx->alproto_local_storage[flow_proto][alproto] =
{
SCEnter();
- AppProto alproto = 0;
- uint8_t flow_proto = 0;
-
- for (flow_proto = 0; flow_proto < FLOW_PROTO_DEFAULT; flow_proto++) {
- for (alproto = 0; alproto < ALPROTO_MAX; alproto++) {
+ for (uint8_t flow_proto = 0; flow_proto < FLOW_PROTO_DEFAULT; flow_proto++) {
+ for (AppProto alproto = 0; alproto < ALPROTO_MAX; alproto++) {
uint8_t ipproto = FlowGetReverseProtoMapping(flow_proto);
AppLayerParserDestroyProtocolParserLocalStorage(ipproto, alproto,
if (pstate == NULL)
SCReturnCT(0ULL, "uint64_t");
- SCReturnCT(pstate->inspect_id[direction & STREAM_TOSERVER ? 0 : 1], "uint64_t");
+ SCReturnCT(pstate->inspect_id[(direction & STREAM_TOSERVER) ? 0 : 1], "uint64_t");
}
static inline uint64_t GetTxDetectFlags(AppLayerTxData *txd, const uint8_t dir)
uint64_t active_id;
uint64_t log_id = pstate->log_id;
- uint64_t inspect_id = pstate->inspect_id[direction & STREAM_TOSERVER ? 0 : 1];
+ uint64_t inspect_id = pstate->inspect_id[(direction & STREAM_TOSERVER) ? 0 : 1];
if (alp_ctx.ctxs[f->protomap][f->alproto].logger == true) {
active_id = MIN(log_id, inspect_id);
} else {
return;
}
-static int TCPProtoDetectTriggerOpposingSide(ThreadVars *tv,
- TcpReassemblyThreadCtx *ra_ctx,
- Packet *p, TcpSession *ssn, TcpStream *stream)
+static int TCPProtoDetectTriggerOpposingSide(ThreadVars *tv, TcpReassemblyThreadCtx *ra_ctx,
+ Packet *p, TcpSession *ssn, const TcpStream *stream)
{
TcpStream *opposing_stream = NULL;
if (stream == &ssn->client) {
#define IPPROTOS_MAX 2
void AppLayerSetupCounters()
{
- uint8_t ipprotos[] = { IPPROTO_TCP, IPPROTO_UDP };
+ const uint8_t ipprotos[] = { IPPROTO_TCP, IPPROTO_UDP };
AppProto alprotos[ALPROTO_MAX];
const char *str = "app_layer.flow.";
const char *estr = "app_layer.error.";
void AppLayerRegisterThreadCounters(ThreadVars *tv)
{
- uint8_t ipprotos[] = { IPPROTO_TCP, IPPROTO_UDP };
+ const uint8_t ipprotos[] = { IPPROTO_TCP, IPPROTO_UDP };
AppProto alprotos[ALPROTO_MAX];
AppLayerProtoDetectSupportedAppProtocols(alprotos);