aiden
/
suricata
mirror of https://github.com/OISF/suricata
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

sip: rustfmt

Browse Source 
As this is new Rust code, format with rustfmt using default
styling.
pull/4210/head
Jason Ish 7 years ago committed by Victor Julien
parent a45a2fa1fc
commit 517ecd68a9
5 changed files with 214 additions and 206 deletions
Show Stats Download Patch File Download Diff File

74
rust/src/sip/detect.rs
Unescape Escape View File

@ -17,16 +17,16 @@
// written by Giuseppe Longo <giuseppe@glongo.it> // written by Giuseppe Longo <giuseppe@glongo.it>
use std::ptr;
use core::{STREAM_TOCLIENT, STREAM_TOSERVER}; use core::{STREAM_TOCLIENT, STREAM_TOSERVER};
use sip::sip::SIPTransaction; use sip::sip::SIPTransaction;
use std::ptr;
#[no_mangle] #[no_mangle]
pub unsafe extern "C" fn rs_sip_tx_get_method(tx: &mut SIPTransaction, pub unsafe extern "C" fn rs_sip_tx_get_method(
buffer: *mut *const u8, tx: &mut SIPTransaction,
buffer_len: *mut u32) buffer: *mut *const u8,
-> u8 buffer_len: *mut u32,
{ ) -> u8 {
if let Some(ref r) = tx.request { if let Some(ref r) = tx.request {
let m = &r.method; let m = &r.method;
if m.len() > 0 { if m.len() > 0 {
@ -43,11 +43,11 @@ pub unsafe extern "C" fn rs_sip_tx_get_method(tx: &mut SIPTransaction,
} }
#[no_mangle] #[no_mangle]
pub unsafe extern "C" fn rs_sip_tx_get_uri(tx: &mut SIPTransaction, pub unsafe extern "C" fn rs_sip_tx_get_uri(
buffer: *mut *const u8, tx: &mut SIPTransaction,
buffer_len: *mut u32) buffer: *mut *const u8,
-> u8 buffer_len: *mut u32,
{ ) -> u8 {
if let Some(ref r) = tx.request { if let Some(ref r) = tx.request {
let p = &r.path; let p = &r.path;
if p.len() > 0 { if p.len() > 0 {
@ -64,12 +64,12 @@ pub unsafe extern "C" fn rs_sip_tx_get_uri(tx: &mut SIPTransaction,
} }
#[no_mangle] #[no_mangle]
pub unsafe extern "C" fn rs_sip_tx_get_protocol(tx: &mut SIPTransaction, pub unsafe extern "C" fn rs_sip_tx_get_protocol(
buffer: *mut *const u8, tx: &mut SIPTransaction,
buffer_len: *mut u32, buffer: *mut *const u8,
direction: u8) buffer_len: *mut u32,
-> u8 direction: u8,
{ ) -> u8 {
match direction { match direction {
STREAM_TOSERVER => { STREAM_TOSERVER => {
if let Some(ref r) = tx.request { if let Some(ref r) = tx.request {
@ -101,11 +101,11 @@ pub unsafe extern "C" fn rs_sip_tx_get_protocol(tx: &mut SIPTransaction,
} }
#[no_mangle] #[no_mangle]
pub unsafe extern "C" fn rs_sip_tx_get_stat_code(tx: &mut SIPTransaction, pub unsafe extern "C" fn rs_sip_tx_get_stat_code(
buffer: *mut *const u8, tx: &mut SIPTransaction,
buffer_len: *mut u32) buffer: *mut *const u8,
-> u8 buffer_len: *mut u32,
{ ) -> u8 {
if let Some(ref r) = tx.response { if let Some(ref r) = tx.response {
let c = &r.code; let c = &r.code;
if c.len() > 0 { if c.len() > 0 {
@ -122,11 +122,11 @@ pub unsafe extern "C" fn rs_sip_tx_get_stat_code(tx: &mut SIPTransaction,
} }
#[no_mangle] #[no_mangle]
pub unsafe extern "C" fn rs_sip_tx_get_stat_msg(tx: &mut SIPTransaction, pub unsafe extern "C" fn rs_sip_tx_get_stat_msg(
buffer: *mut *const u8, tx: &mut SIPTransaction,
buffer_len: *mut u32) buffer: *mut *const u8,
-> u8 buffer_len: *mut u32,
{ ) -> u8 {
if let Some(ref r) = tx.response { if let Some(ref r) = tx.response {
let re = &r.reason; let re = &r.reason;
if re.len() > 0 { if re.len() > 0 {
@ -143,11 +143,11 @@ pub unsafe extern "C" fn rs_sip_tx_get_stat_msg(tx: &mut SIPTransaction,
} }
#[no_mangle] #[no_mangle]
pub unsafe extern "C" fn rs_sip_tx_get_request_line(tx: &mut SIPTransaction, pub unsafe extern "C" fn rs_sip_tx_get_request_line(
buffer: *mut *const u8, tx: &mut SIPTransaction,
buffer_len: *mut u32) buffer: *mut *const u8,
-> u8 buffer_len: *mut u32,
{ ) -> u8 {
if let Some(ref r) = tx.request_line { if let Some(ref r) = tx.request_line {
if r.len() > 0 { if r.len() > 0 {
*buffer = r.as_ptr(); *buffer = r.as_ptr();
@ -163,11 +163,11 @@ pub unsafe extern "C" fn rs_sip_tx_get_request_line(tx: &mut SIPTransaction,
} }
#[no_mangle] #[no_mangle]
pub unsafe extern "C" fn rs_sip_tx_get_response_line(tx: &mut SIPTransaction, pub unsafe extern "C" fn rs_sip_tx_get_response_line(
buffer: *mut *const u8, tx: &mut SIPTransaction,
buffer_len: *mut u32) buffer: *mut *const u8,
-> u8 buffer_len: *mut u32,
{ ) -> u8 {
if let Some(ref r) = tx.response_line { if let Some(ref r) = tx.response_line {
if r.len() > 0 { if r.len() > 0 {
*buffer = r.as_ptr(); *buffer = r.as_ptr();

15
rust/src/sip/log.rs
Unescape Escape View File

@ -21,8 +21,7 @@ use json::*;
use sip::sip::{SIPState, SIPTransaction}; use sip::sip::{SIPState, SIPTransaction};
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_log_json(_state: &mut SIPState, tx: &mut SIPTransaction) -> *mut JsonT pub extern "C" fn rs_sip_log_json(_state: &mut SIPState, tx: &mut SIPTransaction) -> *mut JsonT {
{
let js = Json::object(); let js = Json::object();
match tx.request { match tx.request {
@ -30,13 +29,13 @@ pub extern "C" fn rs_sip_log_json(_state: &mut SIPState, tx: &mut SIPTransaction
js.set_string("method", &req.method); js.set_string("method", &req.method);
js.set_string("uri", &req.path); js.set_string("uri", &req.path);
js.set_string("version", &req.version); js.set_string("version", &req.version);
}, }
None => {} None => {}
} }
match tx.request_line { match tx.request_line {
Some (ref req_line) => { Some(ref req_line) => {
js.set_string("request_line", &req_line); js.set_string("request_line", &req_line);
}, }
None => {} None => {}
} }
match tx.response { match tx.response {
@ -44,13 +43,13 @@ pub extern "C" fn rs_sip_log_json(_state: &mut SIPState, tx: &mut SIPTransaction
js.set_string("version", &resp.version); js.set_string("version", &resp.version);
js.set_string("code", &resp.code); js.set_string("code", &resp.code);
js.set_string("reason", &resp.reason); js.set_string("reason", &resp.reason);
}, }
None => {} None => {}
} }
match tx.response_line { match tx.response_line {
Some (ref resp_line) => { Some(ref resp_line) => {
js.set_string("response_line", &resp_line); js.set_string("response_line", &resp_line);
}, }
None => {} None => {}
} }

6
rust/src/sip/mod.rs
Unescape Escape View File

@ -17,7 +17,7 @@
// written by Giuseppe Longo <giuseppe@glongo.it> // written by Giuseppe Longo <giuseppe@glongo.it>
pub mod sip;
pub mod parser;
pub mod log;
pub mod detect; pub mod detect;
pub mod log;
pub mod parser;
pub mod sip;

50
rust/src/sip/parser.rs
Unescape Escape View File

@ -17,10 +17,10 @@
// written by Giuseppe Longo <giuseppe@glono.it> // written by Giuseppe Longo <giuseppe@glono.it>
use nom::*;
use nom::{crlf, IResult};
use std; use std;
use std::collections::HashMap; use std::collections::HashMap;
use nom::{IResult,crlf};
use nom::*;
#[derive(Debug)] #[derive(Debug)]
pub struct Header { pub struct Header {
@ -33,17 +33,17 @@ pub struct Request {
pub method: String, pub method: String,
pub path: String, pub path: String,
pub version: String, pub version: String,
pub headers: HashMap<String, String> pub headers: HashMap<String, String>,
} }
#[derive(Debug)] #[derive(Debug)]
pub struct Response { pub struct Response {
pub version: String, pub version: String,
pub code: String, pub code: String,
pub reason: String pub reason: String,
} }
#[derive(PartialEq,Debug,Clone)] #[derive(PartialEq, Debug, Clone)]
pub enum Method { pub enum Method {
Register, Register,
Custom(String), Custom(String),
@ -74,7 +74,7 @@ fn is_reason_phrase(b: u8) -> bool {
is_alphanumeric(b) || is_token_char(b) || b"$&(),/:;=?@[\\]^ ".contains(&b) is_alphanumeric(b) || is_token_char(b) || b"$&(),/:;=?@[\\]^ ".contains(&b)
} }
fn is_header_name(b :u8) -> bool { fn is_header_name(b: u8) -> bool {
is_alphanumeric(b) || is_token_char(b) is_alphanumeric(b) || is_token_char(b)
} }
@ -130,19 +130,24 @@ named!(#[inline], header_value<&[u8], &str>,
map_res!(parse_header_value, std::str::from_utf8) map_res!(parse_header_value, std::str::from_utf8)
); );
named!(hcolon<char>, delimited!( named!(
take_while!(is_space), hcolon<char>,
char!(':'), delimited!(take_while!(is_space), char!(':'), take_while!(is_space))
take_while!(is_space) );
));
named!(message_header<Header>, do_parse!( named!(
n: header_name >> message_header<Header>,
hcolon >> do_parse!(
v: header_value >> n: header_name
crlf >> >> hcolon
(Header{ name: String::from(n), value: String::from(v) }) >> v: header_value
)); >> crlf
>> (Header {
name: String::from(n),
value: String::from(v)
})
)
);
named!(pub sip_take_line<&[u8], Option<String> >, named!(pub sip_take_line<&[u8], Option<String> >,
do_parse!( do_parse!(
@ -151,8 +156,7 @@ named!(pub sip_take_line<&[u8], Option<String> >,
) )
); );
pub fn parse_headers(mut input: &[u8]) -> IResult<&[u8],HashMap<String, String>> pub fn parse_headers(mut input: &[u8]) -> IResult<&[u8], HashMap<String, String>> {
{
let mut headers_map: HashMap<String, String> = HashMap::new(); let mut headers_map: HashMap<String, String> = HashMap::new();
loop { loop {
match crlf(input) { match crlf(input) {
@ -215,7 +219,8 @@ mod tests {
From: <sip:voi18063@sip.cybercity.dk>;tag=903df0a\r\n\ From: <sip:voi18063@sip.cybercity.dk>;tag=903df0a\r\n\
To: <sip:voi18063@sip.cybercity.dk>\r\n\ To: <sip:voi18063@sip.cybercity.dk>\r\n\
Content-Length: 0\r\n\ Content-Length: 0\r\n\
\r\n".as_bytes(); \r\n"
.as_bytes();
match sip_parse_request(buf) { match sip_parse_request(buf) {
Ok((_, req)) => { Ok((_, req)) => {
@ -233,7 +238,8 @@ mod tests {
#[test] #[test]
fn test_parse_response() { fn test_parse_response() {
let buf: &[u8] = "SIP/2.0 401 Unauthorized\r\n\ let buf: &[u8] = "SIP/2.0 401 Unauthorized\r\n\
\r\n".as_bytes(); \r\n"
.as_bytes();
match sip_parse_response(buf) { match sip_parse_response(buf) {
Ok((_, resp)) => { Ok((_, resp)) => {

275
rust/src/sip/sip.rs
Unescape Escape View File

@ -19,15 +19,15 @@
extern crate nom; extern crate nom;
use std;
use std::ffi::{CStr,CString};
use applayer; use applayer;
use conf;
use core; use core;
use core::{AppProto,Flow,ALPROTO_UNKNOWN,sc_detect_engine_state_free}; use core::{sc_detect_engine_state_free, AppProto, Flow, ALPROTO_UNKNOWN};
use parser::*;
use log::*; use log::*;
use parser::*;
use sip::parser::*; use sip::parser::*;
use conf; use std;
use std::ffi::{CStr, CString};
#[repr(u32)] #[repr(u32)]
pub enum SIPEvent { pub enum SIPEvent {
@ -63,7 +63,7 @@ pub struct SIPTransaction {
impl SIPState { impl SIPState {
pub fn new() -> SIPState { pub fn new() -> SIPState {
SIPState{ SIPState {
transactions: Vec::new(), transactions: Vec::new(),
tx_id: 0, tx_id: 0,
} }
@ -83,7 +83,10 @@ impl SIPState {
} }
fn free_tx(&mut self, tx_id: u64) { fn free_tx(&mut self, tx_id: u64) {
let tx = self.transactions.iter().position(|ref tx| tx.id == tx_id + 1); let tx = self
.transactions
.iter()
.position(|ref tx| tx.id == tx_id + 1);
debug_assert!(tx != None); debug_assert!(tx != None);
if let Some(idx) = tx { if let Some(idx) = tx {
let _ = self.transactions.remove(idx); let _ = self.transactions.remove(idx);
@ -144,7 +147,7 @@ impl SIPState {
impl SIPTransaction { impl SIPTransaction {
pub fn new(id: u64) -> SIPTransaction { pub fn new(id: u64) -> SIPTransaction {
SIPTransaction{ SIPTransaction {
id: id, id: id,
de_state: None, de_state: None,
request: None, request: None,
@ -172,128 +175,121 @@ impl Drop for SIPTransaction {
pub extern "C" fn rs_sip_state_new() -> *mut std::os::raw::c_void { pub extern "C" fn rs_sip_state_new() -> *mut std::os::raw::c_void {
let state = SIPState::new(); let state = SIPState::new();
let boxed = Box::new(state); let boxed = Box::new(state);
return unsafe{std::mem::transmute(boxed)}; return unsafe { std::mem::transmute(boxed) };
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_free(state: *mut std::os::raw::c_void) { pub extern "C" fn rs_sip_state_free(state: *mut std::os::raw::c_void) {
let mut state: Box<SIPState> = unsafe{std::mem::transmute(state)}; let mut state: Box<SIPState> = unsafe { std::mem::transmute(state) };
state.free(); state.free();
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_get_tx(state: *mut std::os::raw::c_void, pub extern "C" fn rs_sip_state_get_tx(
tx_id: u64) state: *mut std::os::raw::c_void,
-> *mut std::os::raw::c_void tx_id: u64,
{ ) -> *mut std::os::raw::c_void {
let state = cast_pointer!(state,SIPState); let state = cast_pointer!(state, SIPState);
match state.get_tx_by_id(tx_id) { match state.get_tx_by_id(tx_id) {
Some(tx) => unsafe{std::mem::transmute(tx)}, Some(tx) => unsafe { std::mem::transmute(tx) },
None => std::ptr::null_mut(), None => std::ptr::null_mut(),
} }
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_get_tx_count(state: *mut std::os::raw::c_void) pub extern "C" fn rs_sip_state_get_tx_count(state: *mut std::os::raw::c_void) -> u64 {
-> u64 let state = cast_pointer!(state, SIPState);
{
let state = cast_pointer!(state,SIPState);
state.tx_id state.tx_id
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_tx_free(state: *mut std::os::raw::c_void, pub extern "C" fn rs_sip_state_tx_free(state: *mut std::os::raw::c_void, tx_id: u64) {
tx_id: u64) let state = cast_pointer!(state, SIPState);
{
let state = cast_pointer!(state,SIPState);
state.free_tx(tx_id); state.free_tx(tx_id);
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_progress_completion_status( pub extern "C" fn rs_sip_state_progress_completion_status(_direction: u8) -> std::os::raw::c_int {
_direction: u8)
-> std::os::raw::c_int
{
return 1; return 1;
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_tx_get_alstate_progress(_tx: *mut std::os::raw::c_void, pub extern "C" fn rs_sip_tx_get_alstate_progress(
_direction: u8) _tx: *mut std::os::raw::c_void,
-> std::os::raw::c_int _direction: u8,
{ ) -> std::os::raw::c_int {
1 1
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_tx_set_logged(_state: *mut std::os::raw::c_void, pub extern "C" fn rs_sip_tx_set_logged(
tx: *mut std::os::raw::c_void, _state: *mut std::os::raw::c_void,
logged: u32) tx: *mut std::os::raw::c_void,
{ logged: u32,
let tx = cast_pointer!(tx,SIPTransaction); ) {
let tx = cast_pointer!(tx, SIPTransaction);
tx.logged.set(logged); tx.logged.set(logged);
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_tx_get_logged(_state: *mut std::os::raw::c_void, pub extern "C" fn rs_sip_tx_get_logged(
tx: *mut std::os::raw::c_void) _state: *mut std::os::raw::c_void,
-> u32 tx: *mut std::os::raw::c_void,
{ ) -> u32 {
let tx = cast_pointer!(tx,SIPTransaction); let tx = cast_pointer!(tx, SIPTransaction);
return tx.logged.get(); return tx.logged.get();
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_set_tx_detect_state( pub extern "C" fn rs_sip_state_set_tx_detect_state(
tx: *mut std::os::raw::c_void, tx: *mut std::os::raw::c_void,
de_state: &mut core::DetectEngineState) -> std::os::raw::c_int de_state: &mut core::DetectEngineState,
{ ) -> std::os::raw::c_int {
let tx = cast_pointer!(tx,SIPTransaction); let tx = cast_pointer!(tx, SIPTransaction);
tx.de_state = Some(de_state); tx.de_state = Some(de_state);
0 0
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_get_tx_detect_state( pub extern "C" fn rs_sip_state_get_tx_detect_state(
tx: *mut std::os::raw::c_void) tx: *mut std::os::raw::c_void,
-> *mut core::DetectEngineState ) -> *mut core::DetectEngineState {
{ let tx = cast_pointer!(tx, SIPTransaction);
let tx = cast_pointer!(tx,SIPTransaction);
match tx.de_state { match tx.de_state {
Some(ds) => ds, Some(ds) => ds,
None => std::ptr::null_mut(), None => std::ptr::null_mut(),
} }
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_get_events(tx: *mut std::os::raw::c_void) pub extern "C" fn rs_sip_state_get_events(
-> *mut core::AppLayerDecoderEvents tx: *mut std::os::raw::c_void,
{ ) -> *mut core::AppLayerDecoderEvents {
let tx = cast_pointer!(tx, SIPTransaction); let tx = cast_pointer!(tx, SIPTransaction);
return tx.events return tx.events;
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_get_event_info(event_name: *const std::os::raw::c_char, pub extern "C" fn rs_sip_state_get_event_info(
event_id: *mut std::os::raw::c_int, event_name: *const std::os::raw::c_char,
event_type: *mut core::AppLayerEventType) event_id: *mut std::os::raw::c_int,
-> std::os::raw::c_int event_type: *mut core::AppLayerEventType,
{ ) -> std::os::raw::c_int {
if event_name == std::ptr::null() { return -1; } if event_name == std::ptr::null() {
return -1;
}
let c_event_name: &CStr = unsafe { CStr::from_ptr(event_name) }; let c_event_name: &CStr = unsafe { CStr::from_ptr(event_name) };
let event = match c_event_name.to_str() { let event = match c_event_name.to_str() {
Ok(s) => { Ok(s) => {
match s { match s {
"incomplete_data" => SIPEvent::IncompleteData as i32, "incomplete_data" => SIPEvent::IncompleteData as i32,
"invalid_data" => SIPEvent::InvalidData as i32, "invalid_data" => SIPEvent::InvalidData as i32,
_ => -1, // unknown event _ => -1, // unknown event
} }
}, }
Err(_) => -1, // UTF-8 conversion failed Err(_) => -1, // UTF-8 conversion failed
}; };
unsafe{ unsafe {
*event_type = core::APP_LAYER_EVENT_TYPE_TRANSACTION; *event_type = core::APP_LAYER_EVENT_TYPE_TRANSACTION;
*event_id = event as std::os::raw::c_int; *event_id = event as std::os::raw::c_int;
}; };
@ -301,17 +297,17 @@ pub extern "C" fn rs_sip_state_get_event_info(event_name: *const std::os::raw::c
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_state_get_event_info_by_id(event_id: std::os::raw::c_int, pub extern "C" fn rs_sip_state_get_event_info_by_id(
event_name: *mut *const std::os::raw::c_char, event_id: std::os::raw::c_int,
event_type: *mut core::AppLayerEventType) event_name: *mut *const std::os::raw::c_char,
-> i8 event_type: *mut core::AppLayerEventType,
{ ) -> i8 {
if let Some(e) = SIPEvent::from_i32(event_id as i32) { if let Some(e) = SIPEvent::from_i32(event_id as i32) {
let estr = match e { let estr = match e {
SIPEvent::IncompleteData => { "incomplete_data\0" }, SIPEvent::IncompleteData => "incomplete_data\0",
SIPEvent::InvalidData => { "invalid_data\0" }, SIPEvent::InvalidData => "invalid_data\0",
}; };
unsafe{ unsafe {
*event_name = estr.as_ptr() as *const std::os::raw::c_char; *event_name = estr.as_ptr() as *const std::os::raw::c_char;
*event_type = core::APP_LAYER_EVENT_TYPE_TRANSACTION; *event_type = core::APP_LAYER_EVENT_TYPE_TRANSACTION;
}; };
@ -321,28 +317,31 @@ pub extern "C" fn rs_sip_state_get_event_info_by_id(event_id: std::os::raw::c_in
} }
} }
static mut ALPROTO_SIP : AppProto = ALPROTO_UNKNOWN; static mut ALPROTO_SIP: AppProto = ALPROTO_UNKNOWN;
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_probing_parser_ts(_flow: *const Flow, pub extern "C" fn rs_sip_probing_parser_ts(
_direction: u8, _flow: *const Flow,
input:*const u8, input_len: u32, _direction: u8,
_rdir: *mut u8) -> AppProto input: *const u8,
{ input_len: u32,
_rdir: *mut u8,
) -> AppProto {
let buf = build_slice!(input, input_len as usize); let buf = build_slice!(input, input_len as usize);
if sip_parse_request(buf).is_ok() { if sip_parse_request(buf).is_ok() {
return unsafe{ ALPROTO_SIP }; return unsafe { ALPROTO_SIP };
} }
return ALPROTO_UNKNOWN; return ALPROTO_UNKNOWN;
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_probing_parser_tc(_flow: *const Flow, pub extern "C" fn rs_sip_probing_parser_tc(
_direction: u8, _flow: *const Flow,
input: *const u8, _direction: u8,
input_len: u32, input: *const u8,
_rdir: *mut u8) -> AppProto input_len: u32,
{ _rdir: *mut u8,
) -> AppProto {
let buf = build_slice!(input, input_len as usize); let buf = build_slice!(input, input_len as usize);
if sip_parse_response(buf).is_ok() { if sip_parse_response(buf).is_ok() {
return unsafe { ALPROTO_SIP }; return unsafe { ALPROTO_SIP };
@ -351,15 +350,17 @@ pub extern "C" fn rs_sip_probing_parser_tc(_flow: *const Flow,
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_parse_request(_flow: *const core::Flow, pub extern "C" fn rs_sip_parse_request(
state: *mut std::os::raw::c_void, _flow: *const core::Flow,
_pstate: *mut std::os::raw::c_void, state: *mut std::os::raw::c_void,
input: *const u8, _pstate: *mut std::os::raw::c_void,
input_len: u32, input: *const u8,
_data: *const std::os::raw::c_void, input_len: u32,
_flags: u8) -> i32 { _data: *const std::os::raw::c_void,
let buf = build_slice!(input,input_len as usize); _flags: u8,
let state = cast_pointer!(state,SIPState); ) -> i32 {
let buf = build_slice!(input, input_len as usize);
let state = cast_pointer!(state, SIPState);
if state.parse_request(buf) { if state.parse_request(buf) {
1 1
} else { } else {
@ -368,15 +369,17 @@ pub extern "C" fn rs_sip_parse_request(_flow: *const core::Flow,
} }
#[no_mangle] #[no_mangle]
pub extern "C" fn rs_sip_parse_response(_flow: *const core::Flow, pub extern "C" fn rs_sip_parse_response(
state: *mut std::os::raw::c_void, _flow: *const core::Flow,
_pstate: *mut std::os::raw::c_void, state: *mut std::os::raw::c_void,
input: *const u8, _pstate: *mut std::os::raw::c_void,
input_len: u32, input: *const u8,
_data: *const std::os::raw::c_void, input_len: u32,
_flags: u8) -> i32 { _data: *const std::os::raw::c_void,
let buf = build_slice!(input,input_len as usize); _flags: u8,
let state = cast_pointer!(state,SIPState); ) -> i32 {
let buf = build_slice!(input, input_len as usize);
let state = cast_pointer!(state, SIPState);
if state.parse_response(buf) { if state.parse_response(buf) {
1 1
} else { } else {
@ -384,41 +387,41 @@ pub extern "C" fn rs_sip_parse_response(_flow: *const core::Flow,
} }
} }
const PARSER_NAME : &'static [u8] = b"sip\0"; const PARSER_NAME: &'static [u8] = b"sip\0";
#[no_mangle] #[no_mangle]
pub unsafe extern "C" fn rs_sip_register_parser() { pub unsafe extern "C" fn rs_sip_register_parser() {
let default_port = CString::new("5060").unwrap(); let default_port = CString::new("5060").unwrap();
let parser = RustParser { let parser = RustParser {
name : PARSER_NAME.as_ptr() as *const std::os::raw::c_char, name: PARSER_NAME.as_ptr() as *const std::os::raw::c_char,
default_port : default_port.as_ptr(), default_port: default_port.as_ptr(),
ipproto : core::IPPROTO_UDP, ipproto: core::IPPROTO_UDP,
probe_ts : rs_sip_probing_parser_ts, probe_ts: rs_sip_probing_parser_ts,
probe_tc : rs_sip_probing_parser_tc, probe_tc: rs_sip_probing_parser_tc,
min_depth : 0, min_depth: 0,
max_depth : 16, max_depth: 16,
state_new : rs_sip_state_new, state_new: rs_sip_state_new,
state_free : rs_sip_state_free, state_free: rs_sip_state_free,
tx_free : rs_sip_state_tx_free, tx_free: rs_sip_state_tx_free,
parse_ts : rs_sip_parse_request, parse_ts: rs_sip_parse_request,
parse_tc : rs_sip_parse_response, parse_tc: rs_sip_parse_response,
get_tx_count : rs_sip_state_get_tx_count, get_tx_count: rs_sip_state_get_tx_count,
get_tx : rs_sip_state_get_tx, get_tx: rs_sip_state_get_tx,
tx_get_comp_st : rs_sip_state_progress_completion_status, tx_get_comp_st: rs_sip_state_progress_completion_status,
tx_get_progress : rs_sip_tx_get_alstate_progress, tx_get_progress: rs_sip_tx_get_alstate_progress,
get_tx_logged : Some(rs_sip_tx_get_logged), get_tx_logged: Some(rs_sip_tx_get_logged),
set_tx_logged : Some(rs_sip_tx_set_logged), set_tx_logged: Some(rs_sip_tx_set_logged),
get_de_state : rs_sip_state_get_tx_detect_state, get_de_state: rs_sip_state_get_tx_detect_state,
set_de_state : rs_sip_state_set_tx_detect_state, set_de_state: rs_sip_state_set_tx_detect_state,
get_events : Some(rs_sip_state_get_events), get_events: Some(rs_sip_state_get_events),
get_eventinfo : Some(rs_sip_state_get_event_info), get_eventinfo: Some(rs_sip_state_get_event_info),
get_eventinfo_byid : Some(rs_sip_state_get_event_info_by_id), get_eventinfo_byid: Some(rs_sip_state_get_event_info_by_id),
localstorage_new : None, localstorage_new: None,
localstorage_free : None, localstorage_free: None,
get_tx_mpm_id : None, get_tx_mpm_id: None,
set_tx_mpm_id : None, set_tx_mpm_id: None,
get_files : None, get_files: None,
get_tx_iterator : None, get_tx_iterator: None,
}; };
/* For 5.0 we want this disabled by default, so check that it /* For 5.0 we want this disabled by default, so check that it

Write Preview
Loading…
Cancel
Save