checksum::Pseudoheader6 ps6;
h->cksum = 0;
- memcpy(ps6.sip, &api.get_src()->ip32, sizeof(ps6.sip));
- memcpy(ps6.dip, &api.get_dst()->ip32, sizeof(ps6.dip));
+ memcpy(ps6.sip, api.get_src()->ip32, sizeof(ps6.sip));
+ memcpy(ps6.dip, api.get_dst()->ip32, sizeof(ps6.dip));
ps6.zero = 0;
ps6.protocol = IPPROTO_ICMPV6;
ps6.len = htons((uint16_t)updated_len);
{
checksum::Pseudoheader6 ps6;
const ip::IP6Hdr* const ip6h = ip_api.get_ip6h();
- memcpy(ps6.sip, &ip6h->ip6_src.u6_addr32, sizeof(ps6.sip));
- memcpy(ps6.dip, &ip6h->ip6_dst.u6_addr32, sizeof(ps6.dip));
+ memcpy(ps6.sip, ip6h->ip6_src.u6_addr32, sizeof(ps6.sip));
+ memcpy(ps6.dip, ip6h->ip6_dst.u6_addr32, sizeof(ps6.dip));
ps6.zero = 0;
ps6.protocol = IPPROTO_ID_UDP;
ps6.len = htons((uint16_t)updated_len);
if (!file_session)
{
FileFlowData* ffd = new FileFlowData;
- file_session = &ffd->session;
flow->set_application_data(ffd);
}
if (unused > 0)
{
- used = snprintf(cur, unused, "\nProcessed size: %u\n",
+ snprintf(cur, unused, "\nProcessed size: %u\n",
(unsigned int)context->processed_bytes);
- unused -= used;
- cur += used;
}
buf[sizeof(buf) - 1] = '\0';
}
void FlowKey::init(
- uint8_t type, uint8_t proto,
+ uint8_t type, uint8_t proto,
const sfip_t *srcIP, uint16_t srcPort,
const sfip_t *dstIP, uint16_t dstPort,
uint16_t vlanId, uint32_t mplsId, uint16_t addrSpaceId)
*
* Returns: void function
*/
-#define SEPARATOR \
- "- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -"
+static const char SEPARATOR[] =
+ "- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -";
#define BYTES_PER_FRAME 20
/* middle:"41 02 43 04 45 06 47 08 49 0A 4B 0C 4D 0E 4F 0F 01 02 03 04 A.C.E.G.I.K.M.O....."
at end:"41 02 43 04 45 06 47 08 A.C.E.G."*/
-static const char pad3[] =
+static const char PAD3[] =
" ";
void LogNetData(TextLog* log, const uint8_t* data, const int len, Packet* p)
}
}
/* print ' ' past end of packet and before ascii */
- TextLog_Puts(log, pad3+(3*i));
+ TextLog_Puts(log, PAD3+(3*i));
/* then print the actual ascii chars
or a '.' for control chars */
/*******************************************************************************
* Private function prototypes
******************************************************************************/
-static inline int NumObfuscateMaxLenEntries(void);
-static inline int NumObfuscateSliceEntries(void);
-static inline ObRet ObfuscationEntryOverflow(ob_size_t);
static inline int PayloadObfuscationRequired(Packet*);
-static inline void SetObfuscationEntry(ObfuscationEntry*, Packet*,
- ob_size_t, ob_size_t, ob_char_t);
-
static inline void SortObfuscationEntries(void);
static inline void SetObfuscationCallbackData(
ObfuscationCallbackData*, Packet*, ObfuscationCallback, void*);
-static inline void SetObfuscationStreamCallbackData(
- ObfuscationStreamCallbackData*, ObfuscationCallbackData*,
- Packet*, ObfuscationCallback, void*);
-
static ObRet AddObfuscationEntry(Packet*, ob_size_t, ob_size_t, ob_char_t);
static int ObfuscationEntrySort(const void*, const void*);
const DAQ_PktHdr_t*, const uint8_t*, ob_size_t);
static ObRet GetObfuscatedPayloadCallback(const DAQ_PktHdr_t*,
-const uint8_t*, ob_size_t, ob_char_t, void*);
+ const uint8_t*, ob_size_t, ob_char_t, void*);
+
static void PrintObfuscationEntry(const ObfuscationEntry*, int);
/*******************************************************************************
* None
*
******************************************************************************/
+#if 0
static inline void SetObfuscationStreamCallbackData(
ObfuscationStreamCallbackData* stream_callback_data,
ObfuscationCallbackData* callback_data, Packet* packet,
stream_callback_data->next_seq = 0;
stream_callback_data->last_entry_index = 0;
}
+#endif
/*******************************************************************************
* Function: SortObfuscationEntries()
else if ( v.is("proto") )
{
const PktType mask[] =
- {
+ {
PktType::ANY, PktType::IP, PktType::ICMP, PktType::TCP, PktType::UDP,
PktType::USER, PktType::FILE
};
{
assert(ins);
return &((StreamFile*)ins)->config;
-}
-
+}
+
//-------------------------------------------------------------------------
// api stuff
//-------------------------------------------------------------------------
pkth->egress_index = tcpssn->ingress_index;
pkth->egress_group = tcpssn->ingress_group;
}
+#ifdef HAVE_DAQ_ADDRESS_SPACE_ID
+ pkth->opaque = 0;
+#endif
pkth->flags = tcpssn->daq_flags;
pkth->address_space_id = tcpssn->address_space_id;
}