void HTPMemuseCounter(ThreadVars *tv, TcpReassemblyThreadCtx *trt)
{
uint64_t tmpval = SC_ATOMIC_GET(htp_memuse);
- SCPerfCounterSetUI64(trt->counter_htp_memuse, tv->sc_perf_pca, tmpval);
+ SCPerfCounterSetUI64(trt->counter_htp_memuse, tv->perf_private_ctx, tmpval);
tmpval = SC_ATOMIC_GET(htp_memcap);
- SCPerfCounterSetUI64(trt->counter_htp_memcap, tv->sc_perf_pca, tmpval);
+ SCPerfCounterSetUI64(trt->counter_htp_memcap, tv->perf_private_ctx, tmpval);
return;
}
/**
DNSMemcapGetCounters(&memuse, &memcap_state, &memcap_global);
SCPerfCounterSetUI64(app_tctx->counter_dns_memuse,
- tv->sc_perf_pca, memuse);
+ tv->perf_private_ctx, memuse);
SCPerfCounterSetUI64(app_tctx->counter_dns_memcap_state,
- tv->sc_perf_pca, memcap_state);
+ tv->perf_private_ctx, memcap_state);
SCPerfCounterSetUI64(app_tctx->counter_dns_memcap_global,
- tv->sc_perf_pca, memcap_global);
+ tv->perf_private_ctx, memcap_global);
}
/***** L7 layer dispatchers *****/
return 0;
}
- tv.sc_perf_pca = SCPerfGetAllCountersArray(NULL);
+ tv.perf_private_ctx = SCPerfGetAllCountersArray(NULL);
- return (!tv.sc_perf_pca)?1:0;
+ return (!tv.perf_private_ctx)?1:0;
}
static int SCPerfTestGetCntArray06()
if (id != 1)
return 0;
- tv.sc_perf_pca = SCPerfGetAllCountersArray(&tv.perf_public_ctx);
+ tv.perf_private_ctx = SCPerfGetAllCountersArray(&tv.perf_public_ctx);
- result = (tv.sc_perf_pca)?1:0;
+ result = (tv.perf_private_ctx)?1:0;
SCPerfReleasePerfCounterS(tv.perf_public_ctx.head);
- SCPerfReleasePCA(tv.sc_perf_pca);
+ SCPerfReleasePCA(tv.perf_private_ctx);
return result;
}
memset(&tv, 0, sizeof(ThreadVars));
- //pca = (SCPerfPrivateContext *)&tv.sc_perf_pca;
+ //pca = (SCPerfPrivateContext *)&tv.perf_private_ctx;
SCPerfRegisterCounter("t1", "c1", SC_PERF_TYPE_UINT64, NULL,
&tv.perf_public_ctx);
void SCPerfCounterAddUI64(uint16_t, SCPerfPrivateContext *, uint64_t);
#define SCPerfSyncCounters(tv) \
- SCPerfUpdateCounterArray((tv)->sc_perf_pca, &(tv)->perf_public_ctx); \
+ SCPerfUpdateCounterArray((tv)->perf_private_ctx, &(tv)->perf_public_ctx); \
#define SCPerfSyncCountersIfSignalled(tv) \
do { \
if ((tv)->perf_public_ctx.perf_flag == 1) { \
- SCPerfUpdateCounterArray((tv)->sc_perf_pca, &(tv)->perf_public_ctx); \
+ SCPerfUpdateCounterArray((tv)->perf_private_ctx, &(tv)->perf_public_ctx); \
} \
} while (0)
int DecodeEthernet(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p,
uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_eth, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_eth, tv->perf_private_ctx);
if (unlikely(len < ETHERNET_HEADER_LEN)) {
ENGINE_SET_INVALID_EVENT(p, ETHERNET_PKT_TOO_SMALL);
uint16_t header_len = GRE_HDR_LEN;
GRESreHdr *gsre = NULL;
- SCPerfCounterIncr(dtv->counter_gre, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_gre, tv->perf_private_ctx);
if(len < GRE_HDR_LEN) {
ENGINE_SET_INVALID_EVENT(p, GRE_PKT_TOO_SMALL);
*/
int DecodeICMPV4(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_icmpv4, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_icmpv4, tv->perf_private_ctx);
if (len < ICMPV4_HEADER_LEN) {
ENGINE_SET_INVALID_EVENT(p, ICMPV4_PKT_TOO_SMALL);
uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
int full_hdr = 0;
- SCPerfCounterIncr(dtv->counter_icmpv6, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_icmpv6, tv->perf_private_ctx);
if (len < ICMPV6_HEADER_LEN) {
SCLogDebug("ICMPV6_PKT_TOO_SMALL");
int DecodeIPV4(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_ipv4, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_ipv4, tv->perf_private_ctx);
SCLogDebug("pkt %p len %"PRIu16"", pkt, len);
PKT_SET_SRC(tp, PKT_SRC_DECODER_IPV6);
/* add the tp to the packet queue. */
PacketEnqueue(pq,tp);
- SCPerfCounterIncr(dtv->counter_ipv4inipv6, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_ipv4inipv6, tv->perf_private_ctx);
return;
}
}
if (tp != NULL) {
PKT_SET_SRC(tp, PKT_SRC_DECODER_IPV6);
PacketEnqueue(pq,tp);
- SCPerfCounterIncr(dtv->counter_ipv6inipv6, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_ipv6inipv6, tv->perf_private_ctx);
}
}
} else {
{
int ret;
- SCPerfCounterIncr(dtv->counter_ipv6, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_ipv6, tv->perf_private_ctx);
/* do the actual decoding */
ret = DecodeIPV6Packet (tv, dtv, p, pkt, len);
int label;
int event = 0;
- SCPerfCounterIncr(dtv->counter_mpls, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_mpls, tv->perf_private_ctx);
do {
if (len < MPLS_HEADER_LEN) {
int DecodeNull(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_null, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_null, tv->perf_private_ctx);
if (unlikely(len < HDR_SIZE)) {
ENGINE_SET_INVALID_EVENT(p, LTNULL_PKT_TOO_SMALL);
int DecodePPP(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_ppp, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_ppp, tv->perf_private_ctx);
if (unlikely(len < PPP_HEADER_LEN)) {
ENGINE_SET_INVALID_EVENT(p, PPP_PKT_TOO_SMALL);
*/
int DecodePPPOEDiscovery(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_pppoe, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_pppoe, tv->perf_private_ctx);
if (len < PPPOE_DISCOVERY_HEADER_MIN_LEN) {
ENGINE_SET_INVALID_EVENT(p, PPPOE_PKT_TOO_SMALL);
*/
int DecodePPPOESession(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_pppoe, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_pppoe, tv->perf_private_ctx);
if (len < PPPOE_SESSION_HEADER_LEN) {
ENGINE_SET_INVALID_EVENT(p, PPPOE_PKT_TOO_SMALL);
int DecodeRaw(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_raw, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_raw, tv->perf_private_ctx);
/* If it is ipv4 or ipv6 it should at least be the size of ipv4 */
if (unlikely(len < IPV4_HEADER_LEN)) {
int DecodeSCTP(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_sctp, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_sctp, tv->perf_private_ctx);
if (unlikely(DecodeSCTPPacket(tv, p,pkt,len) < 0)) {
p->sctph = NULL;
int DecodeSll(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_sll, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_sll, tv->perf_private_ctx);
if (unlikely(len < SLL_HEADER_LEN)) {
ENGINE_SET_INVALID_EVENT(p, SLL_PKT_TOO_SMALL);
int DecodeTCP(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_tcp, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_tcp, tv->perf_private_ctx);
if (unlikely(DecodeTCPPacket(tv, p,pkt,len) < 0)) {
SCLogDebug("invalid TCP packet");
PKT_SET_SRC(tp, PKT_SRC_DECODER_TEREDO);
/* add the tp to the packet queue. */
PacketEnqueue(pq,tp);
- SCPerfCounterIncr(dtv->counter_teredo, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_teredo, tv->perf_private_ctx);
return TM_ECODE_OK;
}
}
int DecodeUDP(ThreadVars *tv, DecodeThreadVars *dtv, Packet *p, uint8_t *pkt, uint16_t len, PacketQueue *pq)
{
- SCPerfCounterIncr(dtv->counter_udp, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_udp, tv->perf_private_ctx);
if (unlikely(DecodeUDPPacket(tv, p,pkt,len) < 0)) {
p->udph = NULL;
uint32_t proto;
if (p->vlan_idx == 0)
- SCPerfCounterIncr(dtv->counter_vlan, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_vlan, tv->perf_private_ctx);
else if (p->vlan_idx == 1)
- SCPerfCounterIncr(dtv->counter_vlan_qinq, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_vlan_qinq, tv->perf_private_ctx);
if(len < VLAN_HEADER_LEN) {
ENGINE_SET_INVALID_EVENT(p, VLAN_HEADER_TOO_SMALL);
{
if (p->flags & PKT_IS_INVALID)
- SCPerfCounterIncr(dtv->counter_invalid, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_invalid, tv->perf_private_ctx);
#ifdef __SC_CUDA_SUPPORT__
if (dtv->cuda_vars.mpm_is_cuda)
r = Defrag4Reassemble(tv, tracker, p);
if (r != NULL && tv != NULL && dtv != NULL) {
SCPerfCounterIncr(dtv->counter_defrag_ipv4_reassembled,
- tv->sc_perf_pca);
+ tv->perf_private_ctx);
if (pq && DecodeIPV4(tv, dtv, r, (void *)r->ip4h,
IPV4_GET_IPLEN(r), pq) != TM_ECODE_OK) {
TmqhOutputPacketpool(tv, r);
r = Defrag6Reassemble(tv, tracker, p);
if (r != NULL && tv != NULL && dtv != NULL) {
SCPerfCounterIncr(dtv->counter_defrag_ipv6_reassembled,
- tv->sc_perf_pca);
+ tv->perf_private_ctx);
if (pq && DecodeIPV6(tv, dtv, r, (uint8_t *)r->ip6h,
IPV6_GET_PLEN(r) + IPV6_HEADER_LEN,
pq) != TM_ECODE_OK) {
if (tv != NULL && dtv != NULL) {
if (af == AF_INET) {
SCPerfCounterIncr(dtv->counter_defrag_ipv4_fragments,
- tv->sc_perf_pca);
+ tv->perf_private_ctx);
}
else if (af == AF_INET6) {
SCPerfCounterIncr(dtv->counter_defrag_ipv6_fragments,
- tv->sc_perf_pca);
+ tv->perf_private_ctx);
}
}
PACKET_PROFILING_DETECT_END(p, PROF_DETECT_MPM);
#ifdef PROFILING
if (th_v) {
- SCPerfCounterAddUI64(det_ctx->counter_mpm_list, th_v->sc_perf_pca,
+ SCPerfCounterAddUI64(det_ctx->counter_mpm_list, th_v->perf_private_ctx,
(uint64_t)det_ctx->pmq.rule_id_array_cnt);
- SCPerfCounterAddUI64(det_ctx->counter_nonmpm_list, th_v->sc_perf_pca,
+ SCPerfCounterAddUI64(det_ctx->counter_nonmpm_list, th_v->perf_private_ctx,
(uint64_t)det_ctx->sgh->non_mpm_store_cnt);
/* non mpm sigs after mask prefilter */
SCPerfCounterAddUI64(det_ctx->counter_fnonmpm_list,
- th_v->sc_perf_pca, (uint64_t)det_ctx->non_mpm_id_cnt);
+ th_v->perf_private_ctx, (uint64_t)det_ctx->non_mpm_id_cnt);
}
#endif
SigIntId match_cnt = det_ctx->match_array_cnt;
#ifdef PROFILING
if (th_v) {
- SCPerfCounterAddUI64(det_ctx->counter_match_list, th_v->sc_perf_pca,
+ SCPerfCounterAddUI64(det_ctx->counter_match_list, th_v->perf_private_ctx,
(uint64_t)match_cnt);
}
#endif
PACKET_PROFILING_DETECT_START(p, PROF_DETECT_ALERT);
PacketAlertFinalize(de_ctx, det_ctx, p);
if (p->alerts.cnt > 0) {
- SCPerfCounterAddUI64(det_ctx->counter_alerts, det_ctx->tv->sc_perf_pca, (uint64_t)p->alerts.cnt);
+ SCPerfCounterAddUI64(det_ctx->counter_alerts, det_ctx->tv->perf_private_ctx, (uint64_t)p->alerts.cnt);
}
PACKET_PROFILING_DETECT_END(p, PROF_DETECT_ALERT);
DetectEngineThreadCtxInit(&tv, de_ctx, (void *)&det_ctx);
/* init counters */
- tv.sc_perf_pca = SCPerfGetAllCountersArray(&tv.perf_public_ctx);
+ tv.perf_private_ctx = SCPerfGetAllCountersArray(&tv.perf_public_ctx);
SCPerfAddToClubbedTMTable((tv.thread_group_name != NULL) ?
tv.thread_group_name : tv.name, &tv.perf_public_ctx);
p = UTHBuildPacket((uint8_t *)"boo", strlen("boo"), IPPROTO_TCP);
Detect(&tv, p, det_ctx, NULL, NULL);
- result = (SCPerfGetLocalCounterValue(det_ctx->counter_alerts, tv.sc_perf_pca) == 1);
+ result = (SCPerfGetLocalCounterValue(det_ctx->counter_alerts, tv.perf_private_ctx) == 1);
Detect(&tv, p, det_ctx, NULL, NULL);
- result &= (SCPerfGetLocalCounterValue(det_ctx->counter_alerts, tv.sc_perf_pca) == 2);
+ result &= (SCPerfGetLocalCounterValue(det_ctx->counter_alerts, tv.perf_private_ctx) == 2);
UTHFreePackets(&p, 1);
p = UTHBuildPacket((uint8_t *)"roo", strlen("roo"), IPPROTO_TCP);
Detect(&tv, p, det_ctx, NULL, NULL);
- result &= (SCPerfGetLocalCounterValue(det_ctx->counter_alerts, tv.sc_perf_pca) == 2);
+ result &= (SCPerfGetLocalCounterValue(det_ctx->counter_alerts, tv.perf_private_ctx) == 2);
UTHFreePackets(&p, 1);
p = UTHBuildPacket((uint8_t *)"laboosa", strlen("laboosa"), IPPROTO_TCP);
Detect(&tv, p, det_ctx, NULL, NULL);
- result &= (SCPerfGetLocalCounterValue(det_ctx->counter_alerts, tv.sc_perf_pca) == 3);
+ result &= (SCPerfGetLocalCounterValue(det_ctx->counter_alerts, tv.perf_private_ctx) == 3);
UTHFreePackets(&p, 1);
end:
SCLogDebug("Flow emergency mode entered...");
- SCPerfCounterIncr(ftd->flow_emerg_mode_enter, th_v->sc_perf_pca);
+ SCPerfCounterIncr(ftd->flow_emerg_mode_enter, th_v->perf_private_ctx);
}
}
IPPairTimeoutHash(&ts);
}
/*
- SCPerfCounterAddUI64(flow_mgr_host_prune, th_v->sc_perf_pca, (uint64_t)hosts_pruned);
+ SCPerfCounterAddUI64(flow_mgr_host_prune, th_v->perf_private_ctx, (uint64_t)hosts_pruned);
uint32_t hosts_active = HostGetActiveCount();
- SCPerfCounterSetUI64(flow_mgr_host_active, th_v->sc_perf_pca, (uint64_t)hosts_active);
+ SCPerfCounterSetUI64(flow_mgr_host_active, th_v->perf_private_ctx, (uint64_t)hosts_active);
uint32_t hosts_spare = HostGetSpareCount();
- SCPerfCounterSetUI64(flow_mgr_host_spare, th_v->sc_perf_pca, (uint64_t)hosts_spare);
+ SCPerfCounterSetUI64(flow_mgr_host_spare, th_v->perf_private_ctx, (uint64_t)hosts_spare);
*/
- SCPerfCounterAddUI64(ftd->flow_mgr_cnt_clo, th_v->sc_perf_pca, (uint64_t)counters.clo);
- SCPerfCounterAddUI64(ftd->flow_mgr_cnt_new, th_v->sc_perf_pca, (uint64_t)counters.new);
- SCPerfCounterAddUI64(ftd->flow_mgr_cnt_est, th_v->sc_perf_pca, (uint64_t)counters.est);
+ SCPerfCounterAddUI64(ftd->flow_mgr_cnt_clo, th_v->perf_private_ctx, (uint64_t)counters.clo);
+ SCPerfCounterAddUI64(ftd->flow_mgr_cnt_new, th_v->perf_private_ctx, (uint64_t)counters.new);
+ SCPerfCounterAddUI64(ftd->flow_mgr_cnt_est, th_v->perf_private_ctx, (uint64_t)counters.est);
long long unsigned int flow_memuse = SC_ATOMIC_GET(flow_memuse);
- SCPerfCounterSetUI64(ftd->flow_mgr_memuse, th_v->sc_perf_pca, (uint64_t)flow_memuse);
- SCPerfCounterAddUI64(ftd->flow_tcp_reuse, th_v->sc_perf_pca, (uint64_t)counters.tcp_reuse);
+ SCPerfCounterSetUI64(ftd->flow_mgr_memuse, th_v->perf_private_ctx, (uint64_t)flow_memuse);
+ SCPerfCounterAddUI64(ftd->flow_tcp_reuse, th_v->perf_private_ctx, (uint64_t)counters.tcp_reuse);
uint32_t len = 0;
FQLOCK_LOCK(&flow_spare_q);
len = flow_spare_q.len;
FQLOCK_UNLOCK(&flow_spare_q);
- SCPerfCounterSetUI64(ftd->flow_mgr_spare, th_v->sc_perf_pca, (uint64_t)len);
+ SCPerfCounterSetUI64(ftd->flow_mgr_spare, th_v->perf_private_ctx, (uint64_t)len);
/* Don't fear, FlowManagerThread is here...
* clear emergency bit if we have at least xx flows pruned. */
"%% flows at the queue", (uintmax_t)ts.tv_sec,
(uintmax_t)ts.tv_usec, len * 100 / flow_config.prealloc);
- SCPerfCounterIncr(ftd->flow_emerg_mode_over, th_v->sc_perf_pca);
+ SCPerfCounterIncr(ftd->flow_emerg_mode_over, th_v->perf_private_ctx);
} else {
flow_update_delay_sec = FLOW_EMERG_MODE_UPDATE_DELAY_SEC;
flow_update_delay_nsec = FLOW_EMERG_MODE_UPDATE_DELAY_NSEC;
SCLogDebug("(%s) Kernel: Packets %" PRIu32 ", dropped %" PRIu32 "",
ptv->tv->name,
kstats.tp_packets, kstats.tp_drops);
- SCPerfCounterAddUI64(ptv->capture_kernel_packets, ptv->tv->sc_perf_pca, kstats.tp_packets);
- SCPerfCounterAddUI64(ptv->capture_kernel_drops, ptv->tv->sc_perf_pca, kstats.tp_drops);
+ SCPerfCounterAddUI64(ptv->capture_kernel_packets, ptv->tv->perf_private_ctx, kstats.tp_packets);
+ SCPerfCounterAddUI64(ptv->capture_kernel_drops, ptv->tv->perf_private_ctx, kstats.tp_drops);
(void) SC_ATOMIC_ADD(ptv->livedev->drop, (uint64_t) kstats.tp_drops);
(void) SC_ATOMIC_ADD(ptv->livedev->pkts, (uint64_t) kstats.tp_packets);
}
AFPDumpCounters(ptv);
SCLogInfo("(%s) Kernel: Packets %" PRIu64 ", dropped %" PRIu64 "",
tv->name,
- (uint64_t) SCPerfGetLocalCounterValue(ptv->capture_kernel_packets, tv->sc_perf_pca),
- (uint64_t) SCPerfGetLocalCounterValue(ptv->capture_kernel_drops, tv->sc_perf_pca));
+ (uint64_t) SCPerfGetLocalCounterValue(ptv->capture_kernel_packets, tv->perf_private_ctx),
+ (uint64_t) SCPerfGetLocalCounterValue(ptv->capture_kernel_drops, tv->perf_private_ctx));
#endif
SCLogInfo("(%s) Packets %" PRIu64 ", bytes %" PRIu64 "", tv->name, ptv->pkts, ptv->bytes);
return TM_ECODE_OK;
/* update counters */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
-// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->perf_private_ctx);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
#if 0
- SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->sc_perf_pca,
+ SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->perf_private_ctx,
(GET_PKT_LEN(p) * 8)/1000000.0);
#endif
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
/* If suri has set vlan during reading, we increase vlan counter */
if (p->vlan_idx) {
- SCPerfCounterIncr(dtv->counter_vlan, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_vlan, tv->perf_private_ctx);
}
/* call the decoder */
break;
case TYPE_ETH:
if (dr->lctr) {
- SCPerfCounterAddUI64(ewtn->drops, ewtn->tv->sc_perf_pca,
+ SCPerfCounterAddUI64(ewtn->drops, ewtn->tv->perf_private_ctx,
ntohs(dr->lctr));
}
break;
p->ts.tv_sec++;
}
- SCPerfCounterIncr(ewtn->packets, ewtn->tv->sc_perf_pca);
+ SCPerfCounterIncr(ewtn->packets, ewtn->tv->perf_private_ctx);
ewtn->bytes += wlen;
if (TmThreadsSlotProcessPkt(ewtn->tv, ewtn->slot, p) != TM_ECODE_OK) {
ErfDagThreadVars *ewtn = (ErfDagThreadVars *)data;
(void)SC_ATOMIC_SET(ewtn->livedev->pkts,
- (uint64_t)SCPerfGetLocalCounterValue(ewtn->packets, tv->sc_perf_pca));
+ (uint64_t)SCPerfGetLocalCounterValue(ewtn->packets, tv->perf_private_ctx));
(void)SC_ATOMIC_SET(ewtn->livedev->drop,
- (uint64_t)SCPerfGetLocalCounterValue(ewtn->drops, tv->sc_perf_pca));
+ (uint64_t)SCPerfGetLocalCounterValue(ewtn->drops, tv->perf_private_ctx));
SCLogInfo("Stream: %d; Bytes: %"PRIu64"; Packets: %"PRIu64
"; Drops: %"PRIu64,
ewtn->dagstream,
ewtn->bytes,
- (uint64_t)SCPerfGetLocalCounterValue(ewtn->packets, tv->sc_perf_pca),
- (uint64_t)SCPerfGetLocalCounterValue(ewtn->drops, tv->sc_perf_pca));
+ (uint64_t)SCPerfGetLocalCounterValue(ewtn->packets, tv->perf_private_ctx),
+ (uint64_t)SCPerfGetLocalCounterValue(ewtn->drops, tv->perf_private_ctx));
}
/**
return TM_ECODE_OK;
/* update counters */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
-// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->perf_private_ctx);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
#if 0
- SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->sc_perf_pca,
+ SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->perf_private_ctx,
(GET_PKT_LEN(p) * 8)/1000000.0);
#endif
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca,
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx,
GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca,
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx,
GET_PKT_LEN(p));
/* call the decoder */
return TM_ECODE_OK;
/* Update counters. */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
-// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->perf_private_ctx);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
#if 0
- SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->sc_perf_pca,
+ SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->perf_private_ctx,
(GET_PKT_LEN(p) * 8)/1000000.0 );
#endif
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
DecodeEthernet(tv, dtv, p, GET_PKT_DATA(p), GET_PKT_LEN(p), pq);
return TM_ECODE_OK;
/* update counters */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
/* Process IP packets */
if (IPV4_GET_RAW_VER(ip4h) == 4) {
}
if (unlikely(n > max_queued)) {
SCPerfCounterSetUI64(ptv->max_mpipe_depth,
- tv->sc_perf_pca,
+ tv->perf_private_ctx,
(uint64_t)n);
max_queued = n;
}
/* Buffer Error - No buffer available, so mPipe
* dropped the packet. */
SCPerfCounterIncr(XlateStack(ptv, idesc->stack_idx),
- tv->sc_perf_pca);
+ tv->perf_private_ctx);
} else {
/* Bad packet. CRC error */
- SCPerfCounterIncr(ptv->mpipe_drop, tv->sc_perf_pca);
+ SCPerfCounterIncr(ptv->mpipe_drop, tv->perf_private_ctx);
gxio_mpipe_iqueue_drop(iqueue, idesc);
}
gxio_mpipe_iqueue_release(iqueue, idesc);
return TM_ECODE_OK;
/* update counters */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
-// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->perf_private_ctx);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
/* call the decoder */
DecodeEthernet(tv, dtv, p, GET_PKT_DATA(p), GET_PKT_LEN(p), pq);
return TM_ECODE_OK;
/* update counters */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
-// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->sc_perf_pca);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->perf_private_ctx);
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
switch (p->datalink) {
case LINKTYPE_ETHERNET:
*/
static inline void NetmapDumpCounters(NetmapThreadVars *ntv)
{
- SCPerfCounterAddUI64(ntv->capture_kernel_packets, ntv->tv->sc_perf_pca, ntv->pkts);
- SCPerfCounterAddUI64(ntv->capture_kernel_drops, ntv->tv->sc_perf_pca, ntv->drops);
+ SCPerfCounterAddUI64(ntv->capture_kernel_packets, ntv->tv->perf_private_ctx, ntv->pkts);
+ SCPerfCounterAddUI64(ntv->capture_kernel_drops, ntv->tv->perf_private_ctx, ntv->drops);
(void) SC_ATOMIC_ADD(ntv->livedev->drop, ntv->drops);
(void) SC_ATOMIC_ADD(ntv->livedev->pkts, ntv->pkts);
ntv->drops = 0;
NetmapDumpCounters(ntv);
SCLogInfo("(%s) Kernel: Packets %" PRIu64 ", dropped %" PRIu64 ", bytes %" PRIu64 "",
tv->name,
- (uint64_t) SCPerfGetLocalCounterValue(ntv->capture_kernel_packets, tv->sc_perf_pca),
- (uint64_t) SCPerfGetLocalCounterValue(ntv->capture_kernel_drops, tv->sc_perf_pca),
+ (uint64_t) SCPerfGetLocalCounterValue(ntv->capture_kernel_packets, tv->perf_private_ctx),
+ (uint64_t) SCPerfGetLocalCounterValue(ntv->capture_kernel_drops, tv->perf_private_ctx),
ntv->bytes);
}
SCReturnInt(TM_ECODE_OK);
/* update counters */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
DecodeEthernet(tv, dtv, p, GET_PKT_DATA(p), GET_PKT_LEN(p), pq);
IPV6Hdr *ip6h = (IPV6Hdr *)GET_PKT_DATA(p);
DecodeThreadVars *dtv = (DecodeThreadVars *)data;
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
if (IPV4_GET_RAW_VER(ip4h) == 4) {
SCLogDebug("IPv4 packet");
if (p->flags & PKT_PSEUDO_STREAM_END)
return TM_ECODE_OK;
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
#if 0
- SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->sc_perf_pca,
+ SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->perf_private_ctx,
(GET_PKT_LEN(p) * 8)/1000000.0);
#endif
return TM_ECODE_OK;
/* update counters */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
-// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->perf_private_ctx);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
#if 0
- SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->sc_perf_pca,
+ SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->perf_private_ctx,
(GET_PKT_LEN(p) * 8)/1000000.0 );
#endif
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
double curr_ts = p->ts.tv_sec + p->ts.tv_usec / 1000.0;
if (curr_ts < prev_signaled_ts || (curr_ts - prev_signaled_ts) > 60.0) {
{
struct pcap_stat pcap_s;
if (likely((pcap_stats(ptv->pcap_handle, &pcap_s) >= 0))) {
- SCPerfCounterSetUI64(ptv->capture_kernel_packets, ptv->tv->sc_perf_pca, pcap_s.ps_recv);
- SCPerfCounterSetUI64(ptv->capture_kernel_drops, ptv->tv->sc_perf_pca, pcap_s.ps_drop);
+ SCPerfCounterSetUI64(ptv->capture_kernel_packets, ptv->tv->perf_private_ctx, pcap_s.ps_recv);
+ SCPerfCounterSetUI64(ptv->capture_kernel_drops, ptv->tv->perf_private_ctx, pcap_s.ps_drop);
(void) SC_ATOMIC_SET(ptv->livedev->drop, pcap_s.ps_drop);
- SCPerfCounterSetUI64(ptv->capture_kernel_ifdrops, ptv->tv->sc_perf_pca, pcap_s.ps_ifdrop);
+ SCPerfCounterSetUI64(ptv->capture_kernel_ifdrops, ptv->tv->perf_private_ctx, pcap_s.ps_ifdrop);
}
}
return TM_ECODE_OK;
/* update counters */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
-// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->perf_private_ctx);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
#if 0
- SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->sc_perf_pca,
+ SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->perf_private_ctx,
(GET_PKT_LEN(p) * 8)/1000000.0);
#endif
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
/* call the decoder */
switch(p->datalink) {
* the newly seen packets and drops for this thread and add it
* to the interface counter */
uint64_t th_pkts = SCPerfGetLocalCounterValue(ptv->capture_kernel_packets,
- ptv->tv->sc_perf_pca);
+ ptv->tv->perf_private_ctx);
uint64_t th_drops = SCPerfGetLocalCounterValue(ptv->capture_kernel_drops,
- ptv->tv->sc_perf_pca);
+ ptv->tv->perf_private_ctx);
SC_ATOMIC_ADD(ptv->livedev->pkts, pfring_s.recv - th_pkts);
SC_ATOMIC_ADD(ptv->livedev->drop, pfring_s.drop - th_drops);
- SCPerfCounterSetUI64(ptv->capture_kernel_packets, ptv->tv->sc_perf_pca, pfring_s.recv);
- SCPerfCounterSetUI64(ptv->capture_kernel_drops, ptv->tv->sc_perf_pca, pfring_s.drop);
+ SCPerfCounterSetUI64(ptv->capture_kernel_packets, ptv->tv->perf_private_ctx, pfring_s.recv);
+ SCPerfCounterSetUI64(ptv->capture_kernel_drops, ptv->tv->perf_private_ctx, pfring_s.drop);
}
}
PfringDumpCounters(ptv);
SCLogInfo("(%s) Kernel: Packets %" PRIu64 ", dropped %" PRIu64 "",
tv->name,
- (uint64_t) SCPerfGetLocalCounterValue(ptv->capture_kernel_packets, tv->sc_perf_pca),
- (uint64_t) SCPerfGetLocalCounterValue(ptv->capture_kernel_drops, tv->sc_perf_pca));
+ (uint64_t) SCPerfGetLocalCounterValue(ptv->capture_kernel_packets, tv->perf_private_ctx),
+ (uint64_t) SCPerfGetLocalCounterValue(ptv->capture_kernel_drops, tv->perf_private_ctx));
SCLogInfo("(%s) Packets %" PRIu64 ", bytes %" PRIu64 "", tv->name, ptv->pkts, ptv->bytes);
}
return TM_ECODE_OK;
/* update counters */
- SCPerfCounterIncr(dtv->counter_pkts, tv->sc_perf_pca);
-// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_pkts, tv->perf_private_ctx);
+// SCPerfCounterIncr(dtv->counter_pkts_per_sec, tv->perf_private_ctx);
- SCPerfCounterAddUI64(dtv->counter_bytes, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_bytes, tv->perf_private_ctx, GET_PKT_LEN(p));
#if 0
- SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->sc_perf_pca,
+ SCPerfCounterAddDouble(dtv->counter_bytes_per_sec, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterAddDouble(dtv->counter_mbit_per_sec, tv->perf_private_ctx,
(GET_PKT_LEN(p) * 8)/1000000.0 );
#endif
- SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
- SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->sc_perf_pca, GET_PKT_LEN(p));
+ SCPerfCounterAddUI64(dtv->counter_avg_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
+ SCPerfCounterSetUI64(dtv->counter_max_pkt_size, tv->perf_private_ctx, GET_PKT_LEN(p));
/* If suri has set vlan during reading, we increase vlan counter */
if (p->vlan_idx) {
- SCPerfCounterIncr(dtv->counter_vlan, tv->sc_perf_pca);
+ SCPerfCounterIncr(dtv->counter_vlan, tv->perf_private_ctx);
}
DecodeEthernet(tv, dtv, p, GET_PKT_DATA(p), GET_PKT_LEN(p), pq);
{
uint64_t smemuse = SC_ATOMIC_GET(ra_memuse);
if (tv != NULL && rtv != NULL)
- SCPerfCounterSetUI64(rtv->counter_tcp_reass_memuse, tv->sc_perf_pca, smemuse);
+ SCPerfCounterSetUI64(rtv->counter_tcp_reass_memuse, tv->perf_private_ctx, smemuse);
return;
}
if (stream->flags & STREAMTCP_STREAM_FLAG_DEPTH_REACHED) {
/* increment stream depth counter */
- SCPerfCounterIncr(ra_ctx->counter_tcp_stream_depth, tv->sc_perf_pca);
+ SCPerfCounterIncr(ra_ctx->counter_tcp_stream_depth, tv->perf_private_ctx);
stream->flags |= STREAMTCP_STREAM_FLAG_NOREASSEMBLY;
SCLogDebug("ssn %p: reassembly depth reached, "
stream->flags |= STREAMTCP_STREAM_FLAG_GAP;
StreamTcpSetEvent(p, STREAM_REASSEMBLY_SEQ_GAP);
- SCPerfCounterIncr(ra_ctx->counter_tcp_reass_gap, tv->sc_perf_pca);
+ SCPerfCounterIncr(ra_ctx->counter_tcp_reass_gap, tv->perf_private_ctx);
#ifdef DEBUG
dbg_app_layer_gap++;
#endif
stream->flags |= STREAMTCP_STREAM_FLAG_GAP;
StreamTcpSetEvent(p, STREAM_REASSEMBLY_SEQ_GAP);
- SCPerfCounterIncr(ra_ctx->counter_tcp_reass_gap, tv->sc_perf_pca);
+ SCPerfCounterIncr(ra_ctx->counter_tcp_reass_gap, tv->perf_private_ctx);
#ifdef DEBUG
dbg_app_layer_gap++;
#endif
segment_pool[idx]->allocated);
/* Increment the counter to show that we are not able to serve the
segment request due to memcap limit */
- SCPerfCounterIncr(ra_ctx->counter_tcp_segment_memcap, tv->sc_perf_pca);
+ SCPerfCounterIncr(ra_ctx->counter_tcp_segment_memcap, tv->perf_private_ctx);
} else {
seg->flags = stream_config.segment_init_flags;
seg->next = NULL;
void StreamTcpMemuseCounter(ThreadVars *tv, StreamTcpThread *stt)
{
uint64_t memusecopy = SC_ATOMIC_GET(st_memuse);
- SCPerfCounterSetUI64(stt->counter_tcp_memuse, tv->sc_perf_pca, memusecopy);
+ SCPerfCounterSetUI64(stt->counter_tcp_memuse, tv->perf_private_ctx, memusecopy);
return;
}
if (ssn == NULL) {
ssn = StreamTcpNewSession(p, stt->ssn_pool_id);
if (ssn == NULL) {
- SCPerfCounterIncr(stt->counter_tcp_ssn_memcap, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_ssn_memcap, tv->perf_private_ctx);
return -1;
}
- SCPerfCounterIncr(stt->counter_tcp_sessions, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_sessions, tv->perf_private_ctx);
}
/* set the state */
StreamTcpPacketSetState(p, ssn, TCP_SYN_RECV);
if (ssn == NULL) {
ssn = StreamTcpNewSession(p, stt->ssn_pool_id);
if (ssn == NULL) {
- SCPerfCounterIncr(stt->counter_tcp_ssn_memcap, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_ssn_memcap, tv->perf_private_ctx);
return -1;
}
- SCPerfCounterIncr(stt->counter_tcp_sessions, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_sessions, tv->perf_private_ctx);
}
/* set the state */
if (ssn == NULL) {
ssn = StreamTcpNewSession(p, stt->ssn_pool_id);
if (ssn == NULL) {
- SCPerfCounterIncr(stt->counter_tcp_ssn_memcap, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_ssn_memcap, tv->perf_private_ctx);
return -1;
}
- SCPerfCounterIncr(stt->counter_tcp_sessions, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_sessions, tv->perf_private_ctx);
}
/* set the state */
StreamTcpPacketSetState(p, ssn, TCP_ESTABLISHED);
/* update counters */
if ((p->tcph->th_flags & (TH_SYN|TH_ACK)) == (TH_SYN|TH_ACK)) {
- SCPerfCounterIncr(stt->counter_tcp_synack, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_synack, tv->perf_private_ctx);
} else if (p->tcph->th_flags & (TH_SYN)) {
- SCPerfCounterIncr(stt->counter_tcp_syn, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_syn, tv->perf_private_ctx);
}
if (p->tcph->th_flags & (TH_RST)) {
- SCPerfCounterIncr(stt->counter_tcp_rst, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_rst, tv->perf_private_ctx);
}
/* broken TCP http://ask.wireshark.org/questions/3183/acknowledgment-number-broken-tcp-the-acknowledge-field-is-nonzero-while-the-ack-flag-is-not-set */
return TM_ECODE_OK;
if (p->flow == NULL) {
- SCPerfCounterIncr(stt->counter_tcp_no_flow, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_no_flow, tv->perf_private_ctx);
return TM_ECODE_OK;
}
if (stream_config.flags & STREAMTCP_INIT_FLAG_CHECKSUM_VALIDATION) {
if (StreamTcpValidateChecksum(p) == 0) {
- SCPerfCounterIncr(stt->counter_tcp_invalid_checksum, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_invalid_checksum, tv->perf_private_ctx);
return TM_ECODE_OK;
}
} else {
Packet *np = StreamTcpPseudoSetup(p, GET_PKT_DATA(p), GET_PKT_LEN(p));
if (np == NULL) {
SCLogDebug("The packet received from packet allocation is NULL");
- SCPerfCounterIncr(stt->counter_tcp_pseudo_failed, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_pseudo_failed, tv->perf_private_ctx);
SCReturn;
}
PKT_SET_SRC(np, PKT_SRC_STREAM_TCP_STREAM_END_PSEUDO);
PacketEnqueue(pq, np);
- SCPerfCounterIncr(stt->counter_tcp_pseudo, tv->sc_perf_pca);
+ SCPerfCounterIncr(stt->counter_tcp_pseudo, tv->perf_private_ctx);
SCReturn;
}
SCPerfPublicContext perf_public_ctx;
/** private counter store: counter updates modify this */
- SCPerfPrivateContext *sc_perf_pca;
+ SCPerfPrivateContext *perf_private_ctx;
SCCtrlMutex *ctrl_mutex;
SCCtrlCondT *ctrl_cond;
}
}
- tv->sc_perf_pca = SCPerfGetAllCountersArray(&tv->perf_public_ctx);
+ tv->perf_private_ctx = SCPerfGetAllCountersArray(&tv->perf_public_ctx);
SCPerfAddToClubbedTMTable((tv->thread_group_name != NULL) ?
tv->thread_group_name : tv->name, &tv->perf_public_ctx);
}
}
- tv->sc_perf_pca = SCPerfGetAllCountersArray(&tv->perf_public_ctx);
+ tv->perf_private_ctx = SCPerfGetAllCountersArray(&tv->perf_public_ctx);
SCPerfAddToClubbedTMTable((tv->thread_group_name != NULL) ?
tv->thread_group_name : tv->name, &tv->perf_public_ctx);
memset(&s->slot_pre_pq, 0, sizeof(PacketQueue));
memset(&s->slot_post_pq, 0, sizeof(PacketQueue));
- tv->sc_perf_pca = SCPerfGetAllCountersArray(&tv->perf_public_ctx);
+ tv->perf_private_ctx = SCPerfGetAllCountersArray(&tv->perf_public_ctx);
SCPerfAddToClubbedTMTable((tv->thread_group_name != NULL) ?
tv->thread_group_name : tv->name, &tv->perf_public_ctx);
/* set the thread name */
SCLogDebug("%s started...", th_v->name);
- th_v->sc_perf_pca = SCPerfGetAllCountersArray(&th_v->perf_public_ctx);
+ th_v->perf_private_ctx = SCPerfGetAllCountersArray(&th_v->perf_public_ctx);
SCPerfAddToClubbedTMTable(th_v->name, &th_v->perf_public_ctx);
if (UnixNew(&command) == 0) {