};
use std::os::raw::{c_int, c_void};
-fn rs_dhcp_tx_get_time(tx: &DHCPTransaction, code: u8) -> Option<u64> {
+fn dhcp_tx_get_time(tx: &DHCPTransaction, code: u8) -> Option<u64> {
for option in &tx.message.options {
if option.code == code {
if let DHCPOptionWrapper::TimeValue(ref time_value) = option.option {
) -> c_int {
let tx = cast_pointer!(tx, DHCPTransaction);
let ctx = cast_pointer!(ctx, DetectUintData<u64>);
- if let Some(val) = rs_dhcp_tx_get_time(tx, DHCP_OPT_ADDRESS_TIME) {
+ if let Some(val) = dhcp_tx_get_time(tx, DHCP_OPT_ADDRESS_TIME) {
return rs_detect_u64_match(val, ctx);
}
return 0;
) -> c_int {
let tx = cast_pointer!(tx, DHCPTransaction);
let ctx = cast_pointer!(ctx, DetectUintData<u64>);
- if let Some(val) = rs_dhcp_tx_get_time(tx, DHCP_OPT_REBINDING_TIME) {
+ if let Some(val) = dhcp_tx_get_time(tx, DHCP_OPT_REBINDING_TIME) {
return rs_detect_u64_match(val, ctx);
}
return 0;
) -> c_int {
let tx = cast_pointer!(tx, DHCPTransaction);
let ctx = cast_pointer!(ctx, DetectUintData<u64>);
- if let Some(val) = rs_dhcp_tx_get_time(tx, DHCP_OPT_RENEWAL_TIME) {
+ if let Some(val) = dhcp_tx_get_time(tx, DHCP_OPT_RENEWAL_TIME) {
return rs_detect_u64_match(val, ctx);
}
return 0;
}
#[no_mangle]
-pub unsafe extern "C" fn ScDetectDHCPRegister() {
+pub unsafe extern "C" fn SCDetectDHCPRegister() {
let kw = SCSigTableElmt {
name: b"dhcp.leasetime\0".as_ptr() as *const libc::c_char,
desc: b"match DHCP leasetime\0".as_ptr() as *const libc::c_char,
}
pub fn parse(&mut self, input: &[u8]) -> bool {
- match dhcp_parse(input) {
+ match parse_dhcp(input) {
Ok((_, message)) => {
let malformed_options = message.malformed_options;
let truncated_options = message.truncated_options;
}
}
-#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_probing_parser(_flow: *const Flow,
+unsafe extern "C" fn dhcp_probing_parser(_flow: *const Flow,
_direction: u8,
input: *const u8,
input_len: u32,
}
}
-#[no_mangle]
-pub extern "C" fn rs_dhcp_tx_get_alstate_progress(_tx: *mut std::os::raw::c_void,
+extern "C" fn dhcp_tx_get_alstate_progress(_tx: *mut std::os::raw::c_void,
_direction: u8) -> std::os::raw::c_int {
// As this is a stateless parser, simply use 1.
return 1;
}
-#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_state_get_tx(state: *mut std::os::raw::c_void,
+unsafe extern "C" fn dhcp_state_get_tx(state: *mut std::os::raw::c_void,
tx_id: u64) -> *mut std::os::raw::c_void {
let state = cast_pointer!(state, DHCPState);
match state.get_tx(tx_id) {
}
}
-#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_state_get_tx_count(state: *mut std::os::raw::c_void) -> u64 {
+unsafe extern "C" fn dhcp_state_get_tx_count(state: *mut std::os::raw::c_void) -> u64 {
let state = cast_pointer!(state, DHCPState);
return state.tx_id;
}
-#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_parse(_flow: *const Flow,
+unsafe extern "C" fn dhcp_parse(_flow: *const Flow,
state: *mut std::os::raw::c_void,
_pstate: *mut std::os::raw::c_void,
stream_slice: StreamSlice,
return AppLayerResult::err();
}
-#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_state_tx_free(
+pub unsafe extern "C" fn dhcp_state_tx_free(
state: *mut std::os::raw::c_void,
tx_id: u64)
{
state.free_tx(tx_id);
}
-#[no_mangle]
-pub extern "C" fn rs_dhcp_state_new(_orig_state: *mut std::os::raw::c_void, _orig_proto: AppProto) -> *mut std::os::raw::c_void {
+extern "C" fn dhcp_state_new(_orig_state: *mut std::os::raw::c_void, _orig_proto: AppProto) -> *mut std::os::raw::c_void {
let state = DHCPState::new();
let boxed = Box::new(state);
return Box::into_raw(boxed) as *mut _;
}
-#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_state_free(state: *mut std::os::raw::c_void) {
+unsafe extern "C" fn dhcp_state_free(state: *mut std::os::raw::c_void) {
std::mem::drop(Box::from_raw(state as *mut DHCPState));
}
const PARSER_NAME: &[u8] = b"dhcp\0";
#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_register_parser() {
+pub unsafe extern "C" fn SCRegisterDhcpParser() {
SCLogDebug!("Registering DHCP parser.");
let ports = CString::new("[67,68]").unwrap();
let parser = RustParser {
name: PARSER_NAME.as_ptr() as *const std::os::raw::c_char,
default_port : ports.as_ptr(),
ipproto : IPPROTO_UDP,
- probe_ts : Some(rs_dhcp_probing_parser),
- probe_tc : Some(rs_dhcp_probing_parser),
+ probe_ts : Some(dhcp_probing_parser),
+ probe_tc : Some(dhcp_probing_parser),
min_depth : 0,
max_depth : 16,
- state_new : rs_dhcp_state_new,
- state_free : rs_dhcp_state_free,
- tx_free : rs_dhcp_state_tx_free,
- parse_ts : rs_dhcp_parse,
- parse_tc : rs_dhcp_parse,
- get_tx_count : rs_dhcp_state_get_tx_count,
- get_tx : rs_dhcp_state_get_tx,
+ state_new : dhcp_state_new,
+ state_free : dhcp_state_free,
+ tx_free : dhcp_state_tx_free,
+ parse_ts : dhcp_parse,
+ parse_tc : dhcp_parse,
+ get_tx_count : dhcp_state_get_tx_count,
+ get_tx : dhcp_state_get_tx,
tx_comp_st_ts : 1,
tx_comp_st_tc : 1,
- tx_get_progress : rs_dhcp_tx_get_alstate_progress,
+ tx_get_progress : dhcp_tx_get_alstate_progress,
get_eventinfo : Some(DHCPEvent::get_event_info),
get_eventinfo_byid : Some(DHCPEvent::get_event_info_by_id),
localstorage_new : None,
}
#[no_mangle]
-pub extern "C" fn rs_dhcp_logger_new(conf: *const c_void) -> *mut std::os::raw::c_void {
+pub extern "C" fn SCDhcpLoggerNew(conf: *const c_void) -> *mut std::os::raw::c_void {
let conf = ConfNode::wrap(conf);
let boxed = Box::new(DHCPLogger::new(conf));
return Box::into_raw(boxed) as *mut _;
}
#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_logger_free(logger: *mut std::os::raw::c_void) {
+pub unsafe extern "C" fn SCDhcpLoggerFree(logger: *mut std::os::raw::c_void) {
std::mem::drop(Box::from_raw(logger as *mut DHCPLogger));
}
#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_logger_log(logger: *mut std::os::raw::c_void,
+pub unsafe extern "C" fn SCDhcpLoggerLog(logger: *mut std::os::raw::c_void,
tx: *mut std::os::raw::c_void,
js: &mut JsonBuilder) -> bool {
let logger = cast_pointer!(logger, DHCPLogger);
}
#[no_mangle]
-pub unsafe extern "C" fn rs_dhcp_logger_do_log(logger: *mut std::os::raw::c_void,
+pub unsafe extern "C" fn SCDhcpLoggerDoLog(logger: *mut std::os::raw::c_void,
tx: *mut std::os::raw::c_void)
-> bool {
let logger = cast_pointer!(logger, DHCPLogger);
}
}
-pub fn dhcp_parse(input: &[u8]) -> IResult<&[u8], DHCPMessage> {
+pub fn parse_dhcp(input: &[u8]) -> IResult<&[u8], DHCPMessage> {
match parse_header(input) {
Ok((rem, header)) => {
let mut options = Vec::new();
let pcap = include_bytes!("discover.pcap");
let payload = &pcap[24 + 16 + 42..];
- let (_rem, message) = dhcp_parse(payload).unwrap();
+ let (_rem, message) = parse_dhcp(payload).unwrap();
let header = message.header;
assert_eq!(header.opcode, BOOTP_REQUEST);
assert_eq!(header.htype, 1);
RegisterTFTPParsers();
RegisterIKEParsers();
rs_register_krb5_parser();
- rs_dhcp_register_parser();
+ SCRegisterDhcpParser();
rs_register_snmp_parser();
rs_sip_register_parser();
rs_quic_register_parser();
DetectVlanLayersRegister();
ScDetectSNMPRegister();
- ScDetectDHCPRegister();
+ SCDetectDHCPRegister();
ScDetectWebsocketRegister();
ScDetectEnipRegister();
ScDetectMqttRegister();
LogDHCPLogThread *thread = thread_data;
LogDHCPFileCtx *ctx = thread->dhcplog_ctx;
- if (!rs_dhcp_logger_do_log(ctx->rs_logger, tx)) {
+ if (!SCDhcpLoggerDoLog(ctx->rs_logger, tx)) {
return TM_ECODE_OK;
}
return TM_ECODE_FAILED;
}
- rs_dhcp_logger_log(ctx->rs_logger, tx, js);
+ SCDhcpLoggerLog(ctx->rs_logger, tx, js);
OutputJsonBuilderBuffer(tv, p, p->flow, js, thread->thread);
jb_free(js);
static void OutputDHCPLogDeInitCtxSub(OutputCtx *output_ctx)
{
LogDHCPFileCtx *dhcplog_ctx = (LogDHCPFileCtx *)output_ctx->data;
- rs_dhcp_logger_free(dhcplog_ctx->rs_logger);
+ SCDhcpLoggerFree(dhcplog_ctx->rs_logger);
SCFree(dhcplog_ctx);
SCFree(output_ctx);
}
output_ctx->data = dhcplog_ctx;
output_ctx->DeInit = OutputDHCPLogDeInitCtxSub;
- dhcplog_ctx->rs_logger = rs_dhcp_logger_new(conf);
+ dhcplog_ctx->rs_logger = SCDhcpLoggerNew(conf);
AppLayerParserRegisterLogger(IPPROTO_UDP, ALPROTO_DHCP);