From: Jason Ish Date: Wed, 5 Oct 2022 15:00:21 +0000 (-0600) Subject: rust: fix clippy lints for clippy::collapsible_if X-Git-Tag: suricata-7.0.0-beta1~37 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=119e02cf8199210aaf4c6b1af5f46689a7ce5726;p=thirdparty%2Fsuricata.git rust: fix clippy lints for clippy::collapsible_if --- diff --git a/rust/src/dcerpc/dcerpc_udp.rs b/rust/src/dcerpc/dcerpc_udp.rs index ea82074653..85618ac200 100644 --- a/rust/src/dcerpc/dcerpc_udp.rs +++ b/rust/src/dcerpc/dcerpc_udp.rs @@ -128,12 +128,9 @@ impl DCERPCUDPState { fn find_incomplete_tx(&mut self, hdr: &DCERPCHdrUdp) -> Option<&mut DCERPCTransaction> { for tx in &mut self.transactions { - if tx.seqnum == hdr.seqnum && tx.activityuuid == hdr.activityuuid { - if (hdr.pkt_type == DCERPC_TYPE_REQUEST && !tx.req_done) || - (hdr.pkt_type == DCERPC_TYPE_RESPONSE && !tx.resp_done) { - SCLogDebug!("found tx id {}, last tx_id {}, {} {}", tx.id, self.tx_id, tx.seqnum, tx.activityuuid[0]); - return Some(tx); - } + if tx.seqnum == hdr.seqnum && tx.activityuuid == hdr.activityuuid && ((hdr.pkt_type == DCERPC_TYPE_REQUEST && !tx.req_done) || (hdr.pkt_type == DCERPC_TYPE_RESPONSE && !tx.resp_done)) { + SCLogDebug!("found tx id {}, last tx_id {}, {} {}", tx.id, self.tx_id, tx.seqnum, tx.activityuuid[0]); + return Some(tx); } } None diff --git a/rust/src/http2/detect.rs b/rust/src/http2/detect.rs index 9a3a6a57a2..9c233cd4dc 100644 --- a/rust/src/http2/detect.rs +++ b/rust/src/http2/detect.rs @@ -308,10 +308,8 @@ fn http2_detect_sizeupdate_match( blocks: &[parser::HTTP2FrameHeaderBlock], ctx: &DetectUintData, ) -> std::os::raw::c_int { for block in blocks.iter() { - if block.error == parser::HTTP2HeaderDecodeStatus::HTTP2HeaderDecodeSizeUpdate { - if detect_match_uint(ctx, block.sizeupdate) { - return 1; - } + if block.error == parser::HTTP2HeaderDecodeStatus::HTTP2HeaderDecodeSizeUpdate && detect_match_uint(ctx, block.sizeupdate) { + return 1; } } return 0; diff --git a/rust/src/ike/ikev2.rs b/rust/src/ike/ikev2.rs index 37004780a4..cd2e551812 100644 --- a/rust/src/ike/ikev2.rs +++ b/rust/src/ike/ikev2.rs @@ -278,14 +278,12 @@ fn add_proposals( IkeV2Transform::Auth(IkeTransformAuthType::NONE) => false, IkeV2Transform::Auth(_) => true, _ => false, - }) { - if !transforms.iter().any(|x| match *x { + }) && !transforms.iter().any(|x| match *x { IkeV2Transform::Encryption(ref enc) => enc.is_aead(), _ => false, }) { - SCLogDebug!("No integrity transform found"); - tx.set_event(IkeEvent::WeakCryptoNoAuth); - } + SCLogDebug!("No integrity transform found"); + tx.set_event(IkeEvent::WeakCryptoNoAuth); } // Finally if direction == Direction::ToClient { diff --git a/rust/src/smb/smb.rs b/rust/src/smb/smb.rs index 4ab807c46d..a7c9db9e39 100644 --- a/rust/src/smb/smb.rs +++ b/rust/src/smb/smb.rs @@ -2086,10 +2086,8 @@ fn smb_probe_tcp_midstream(direction: Direction, slice: &[u8], rdir: *mut u8, be fn smb_probe_tcp(flags: u8, slice: &[u8], rdir: *mut u8, begins: bool) -> AppProto { - if flags & STREAM_MIDSTREAM == STREAM_MIDSTREAM { - if smb_probe_tcp_midstream(flags.into(), slice, rdir, begins) == 1 { - unsafe { return ALPROTO_SMB; } - } + if flags & STREAM_MIDSTREAM == STREAM_MIDSTREAM && smb_probe_tcp_midstream(flags.into(), slice, rdir, begins) == 1 { + unsafe { return ALPROTO_SMB; } } match parse_nbss_record_partial(slice) { Ok((_, ref hdr)) => { diff --git a/rust/src/smb/smb1.rs b/rust/src/smb/smb1.rs index ec24d7e1c0..ddeccf64d2 100644 --- a/rust/src/smb/smb1.rs +++ b/rust/src/smb/smb1.rs @@ -570,15 +570,13 @@ fn smb1_request_record_one<'b>(state: &mut SMBState, r: &SmbRecord<'b>, command: false }, }; - if !have_tx { - if smb1_create_new_tx(command) { - let tx_key = SMBCommonHdr::from1(r, SMBHDR_TYPE_GENERICTX); - let tx = state.new_generic_tx(1, command as u16, tx_key); - SCLogDebug!("tx {} created for {}/{}", tx.id, command, &smb1_command_string(command)); - tx.set_events(events); - if no_response_expected { - tx.response_done = true; - } + if !have_tx && smb1_create_new_tx(command) { + let tx_key = SMBCommonHdr::from1(r, SMBHDR_TYPE_GENERICTX); + let tx = state.new_generic_tx(1, command as u16, tx_key); + SCLogDebug!("tx {} created for {}/{}", tx.id, command, &smb1_command_string(command)); + tx.set_events(events); + if no_response_expected { + tx.response_done = true; } } } diff --git a/rust/src/smb/smb2.rs b/rust/src/smb/smb2.rs index 96f169ccbd..e925747fc8 100644 --- a/rust/src/smb/smb2.rs +++ b/rust/src/smb/smb2.rs @@ -635,14 +635,12 @@ pub fn smb2_request_record<'b>(state: &mut SMBState, r: &Smb2Record<'b>) }, }; /* if we don't have a tx, create it here (maybe) */ - if !have_tx { - if smb2_create_new_tx(r.command) { - let tx_key = SMBCommonHdr::from2(r, SMBHDR_TYPE_GENERICTX); - let tx = state.new_generic_tx(2, r.command, tx_key); - SCLogDebug!("TS TX {} command {} created with session_id {} tree_id {} message_id {}", - tx.id, r.command, r.session_id, r.tree_id, r.message_id); - tx.set_events(events); - } + if !have_tx && smb2_create_new_tx(r.command) { + let tx_key = SMBCommonHdr::from2(r, SMBHDR_TYPE_GENERICTX); + let tx = state.new_generic_tx(2, r.command, tx_key); + SCLogDebug!("TS TX {} command {} created with session_id {} tree_id {} message_id {}", + tx.id, r.command, r.session_id, r.tree_id, r.message_id); + tx.set_events(events); } }