Skip to content

Commit db0016c

Browse files
committed
Apply Clippy suggestions
These are the suggestion that could be applied automatically; others will require manual review.
1 parent b62795f commit db0016c

12 files changed

Lines changed: 36 additions & 28 deletions

libwebrtc/src/audio_source.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ pub mod native {
161161
if self.queue_size_samples == 0 {
162162
// frame size must be 10ms for fast path
163163
let expected_frames_per_ch = (self.sample_rate / 100) as usize;
164-
if frame.data.len() % (self.num_channels as usize) != 0 {
164+
if !frame.data.len().is_multiple_of(self.num_channels as usize) {
165165
return Err(RtcError {
166166
error_type: RtcErrorType::InvalidState,
167167
message: "frame.data length not divisible by channel count".to_owned(),

libwebrtc/src/data_channel.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ impl DataChannel {
135135
observer_ptr as *mut ::std::os::raw::c_void,
136136
);
137137
}
138-
Self { ffi: sys_handle, observer: observer }
138+
Self { ffi: sys_handle, observer }
139139
}
140140

141141
pub fn send(&self, data: &[u8], binary: bool) -> Result<(), DataChannelError> {

libwebrtc/src/ice_candidate.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ impl IceCandidate {
4242
})?;
4343

4444
let ffi = unsafe {
45-
sys::lkCreateIceCandidate(c_sdp_mid.as_ptr(), sdp_mline_index as i32, c_sdp.as_ptr())
45+
sys::lkCreateIceCandidate(c_sdp_mid.as_ptr(), sdp_mline_index, c_sdp.as_ptr())
4646
};
4747
Ok(IceCandidate { ffi: unsafe { sys::RefCounted::from_raw(ffi) } })
4848
}
@@ -56,7 +56,7 @@ impl IceCandidate {
5656
}
5757

5858
pub fn sdp_mline_index(&self) -> i32 {
59-
unsafe { sys::lkIceCandidateGetMlineIndex(self.ffi.as_ptr()).into() }
59+
unsafe { sys::lkIceCandidateGetMlineIndex(self.ffi.as_ptr()) }
6060
}
6161

6262
pub fn candidate(&self) -> String {

libwebrtc/src/native/apm.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ impl AudioProcessingModule {
4646
) -> Result<(), RtcError> {
4747
let samples_per_10ms = (sample_rate as usize / 100) * num_channels as usize;
4848
assert!(
49-
data.len() % samples_per_10ms == 0 && data.len() >= samples_per_10ms,
49+
data.len().is_multiple_of(samples_per_10ms) && data.len() >= samples_per_10ms,
5050
"slice must have a multiple of 10ms worth of samples"
5151
);
5252

@@ -79,7 +79,7 @@ impl AudioProcessingModule {
7979
) -> Result<(), RtcError> {
8080
let samples_per_10ms = (sample_rate as usize / 100) * num_channels as usize;
8181
assert!(
82-
data.len() % samples_per_10ms == 0 && data.len() >= samples_per_10ms,
82+
data.len().is_multiple_of(samples_per_10ms) && data.len() >= samples_per_10ms,
8383
"slice must have a multiple of 10ms worth of samples"
8484
);
8585

libwebrtc/src/native/audio_mixer.rs

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,12 @@ pub static SYS_AUDIO_MIXER_CALLBACKS: sys::lkAudioMixerSourceCallback =
5050
getAudioFrameWithInfo: Some(AudioMixer::audio_mixer_source_get_audio_frame_with_info),
5151
};
5252

53+
impl Default for AudioMixer {
54+
fn default() -> Self {
55+
Self::new()
56+
}
57+
}
58+
5359
impl AudioMixer {
5460
pub fn new() -> Self {
5561
let ffi = unsafe { sys::lkCreateAudioMixer() };
@@ -103,9 +109,9 @@ impl AudioMixer {
103109
let source =
104110
unsafe { &*(userdata as *const AudioMixerSourceImpl<Box<dyn AudioMixerSource>>) };
105111
if let Some(frame) = source.inner.get_audio_frame_with_info(target_sample_rate) {
106-
let samples_count = (frame.sample_rate as usize / 100) as usize;
112+
let samples_count = (frame.sample_rate as usize / 100);
107113
assert_eq!(
108-
frame.sample_rate, target_sample_rate as u32,
114+
frame.sample_rate, target_sample_rate,
109115
"sample rate must match target_sample_rate"
110116
);
111117
assert_eq!(
@@ -128,9 +134,9 @@ impl AudioMixer {
128134
frame.num_channels,
129135
);
130136
}
131-
return sys::lkAudioFrameInfo::AUDIO_FRAME_INFO_NORMAL;
137+
sys::lkAudioFrameInfo::AUDIO_FRAME_INFO_NORMAL
132138
} else {
133-
return sys::lkAudioFrameInfo::AUDIO_FRAME_INFO_MUTE;
139+
sys::lkAudioFrameInfo::AUDIO_FRAME_INFO_MUTE
134140
}
135141
}
136142
}

libwebrtc/src/native/frame_cryptor.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@ impl FrameCryptor {
200200
let observer = unsafe { &*(userdata as *const Arc<RtcFrameCryptorObserver>) };
201201
let str: String =
202202
unsafe { std::ffi::CStr::from_ptr(participant_id).to_str().unwrap().to_string() };
203-
observer.on_frame_cryption_state_change(str, state.into());
203+
observer.on_frame_cryption_state_change(str, state);
204204
}
205205

206206
pub fn new_for_rtp_sender(
@@ -224,7 +224,7 @@ impl FrameCryptor {
224224
Some(FrameCryptor::on_encryption_state_changed),
225225
observer_box as *mut ::std::os::raw::c_void,
226226
);
227-
Self { observer: observer, ffi: sys::RefCounted::from_raw(ffi) }
227+
Self { observer, ffi: sys::RefCounted::from_raw(ffi) }
228228
}
229229
}
230230

@@ -249,7 +249,7 @@ impl FrameCryptor {
249249
Some(FrameCryptor::on_encryption_state_changed),
250250
observer_box as *mut ::std::os::raw::c_void,
251251
);
252-
Self { observer: observer, ffi: sys::RefCounted::from_raw(ffi) }
252+
Self { observer, ffi: sys::RefCounted::from_raw(ffi) }
253253
}
254254
}
255255

libwebrtc/src/native/yuv_helper.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ fn i420_assert_safety(
3131
height: i32,
3232
) {
3333
let height_abs = height.unsigned_abs();
34-
let chroma_height = (height_abs + 1) / 2;
34+
let chroma_height = height_abs.div_ceil(2);
3535
let min_y = (src_stride_y * height_abs) as usize;
3636
let min_u = (src_stride_u * chroma_height) as usize;
3737
let min_v = (src_stride_v * chroma_height) as usize;
@@ -50,7 +50,7 @@ fn nv12_assert_safety(
5050
height: i32,
5151
) {
5252
let height_abs = height.unsigned_abs();
53-
let chroma_height = (height_abs + 1) / 2;
53+
let chroma_height = height_abs.div_ceil(2);
5454

5555
let min_y = (src_stride_y * height_abs) as usize;
5656
let min_uv = (src_stride_uv * chroma_height) as usize;

libwebrtc/src/peer_connection.rs

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -100,6 +100,7 @@ impl From<OfferOptions> for lkOfferAnswerOptions {
100100
}
101101

102102
#[derive(Debug, Clone)]
103+
#[derive(Default)]
103104
pub struct AnswerOptions {
104105
pub offer_to_receive_audio: bool,
105106
pub offer_to_receive_video: bool,
@@ -116,11 +117,6 @@ impl From<AnswerOptions> for lkOfferAnswerOptions {
116117
}
117118
}
118119

119-
impl Default for AnswerOptions {
120-
fn default() -> Self {
121-
Self { offer_to_receive_audio: false, offer_to_receive_video: false }
122-
}
123-
}
124120

125121
#[derive(Debug, Clone)]
126122
pub struct IceCandidateError {
@@ -639,7 +635,7 @@ impl PeerConnection {
639635
if ffi.is_null() {
640636
return Err(RtcError {
641637
error_type: RtcErrorType::Internal,
642-
message: format!("Failed to create data channel"),
638+
message: "Failed to create data channel".to_string(),
643639
});
644640
}
645641

libwebrtc/src/peer_connection_factory.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ impl PeerConnectionFactory {
148148
observer_ptr as *mut ::std::os::raw::c_void,
149149
)
150150
};
151-
if sys_peer == std::ptr::null_mut() {
151+
if sys_peer.is_null() {
152152
unsafe {
153153
let _ = Rc::from_raw(observer_ptr);
154154
}
@@ -158,7 +158,7 @@ impl PeerConnectionFactory {
158158
});
159159
}
160160
let ffi = unsafe { sys::RefCounted::from_raw(sys_peer) };
161-
let peer = PeerConnection { observer: observer, ffi: ffi };
161+
let peer = PeerConnection { observer, ffi };
162162
Ok(peer)
163163
}
164164

libwebrtc/src/sys/conv.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -300,7 +300,7 @@ pub fn rtp_parameters_to_native(params: RtpParameters) -> sys::RefCounted<sys::l
300300

301301
sys::lkRtpCodecParametersSetPayloadType(
302302
c_codec.as_ptr(),
303-
codec.payload_type.try_into().unwrap(),
303+
codec.payload_type.into(),
304304
);
305305
sys::lkRtpCodecParametersSetMimeType(
306306
c_codec.as_ptr(),
@@ -315,7 +315,7 @@ pub fn rtp_parameters_to_native(params: RtpParameters) -> sys::RefCounted<sys::l
315315
if let Some(channels) = codec.channels {
316316
sys::lkRtpCodecParametersSetChannels(
317317
c_codec.as_ptr(),
318-
channels.try_into().unwrap(),
318+
channels.into(),
319319
);
320320
}
321321
lk_codecs_vec.push_back(c_codec);

0 commit comments

Comments
 (0)