Skip to content

Commit

Permalink
Fix some compiler warnings
Browse files Browse the repository at this point in the history
  • Loading branch information
locka99 committed Aug 24, 2022
1 parent c1bd964 commit 6719c9f
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 13 deletions.
5 changes: 0 additions & 5 deletions lib/src/server/comms/tcp_transport.rs
Original file line number Diff line number Diff line change
Expand Up @@ -311,11 +311,6 @@ impl TcpTransport {
transport.finish(final_status);
}

fn make_debug_task_id(component: &str, transport: Arc<RwLock<TcpTransport>>) -> String {
let transport = trace_read_lock!(transport);
format!("{}/{}", transport.transport_id, component)
}

/// Spawns the writing loop task. The writing loop takes messages to send off of a queue
/// and sends them to the stream.
async fn spawn_writing_loop_task(
Expand Down
7 changes: 2 additions & 5 deletions lib/src/server/session.rs
Original file line number Diff line number Diff line change
Expand Up @@ -119,12 +119,9 @@ impl SessionManager {

/// Register the session in the map so it can be searched on
pub fn register_session(&mut self, session: Arc<RwLock<Session>>) {
let (session_id, authentication_token) = {
let session_id = {
let session = trace_read_lock!(session);
(
session.session_id().clone(),
session.authentication_token().clone(),
)
session.session_id().clone()
};
self.sessions.insert(session_id, session);
}
Expand Down
4 changes: 2 additions & 2 deletions lib/src/server/tests/services/session.rs
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ where

#[test]
fn anonymous_user_token() {
do_session_service_test(None, |server_state, session_service| {
do_session_service_test(None, |server_state, _session_service| {
let server_state = server_state.read();

// Makes an anonymous token and sticks it into an extension object
Expand Down Expand Up @@ -146,7 +146,7 @@ fn make_unencrypted_user_name_identity_token(user: &str, pass: &str) -> Extensio
fn user_name_pass_token() {
do_session_service_test(
Some("./pki_user_name_pass_token"),
|server_state, session_service| {
|server_state, _session_service| {
let server_nonce = random::byte_string(20);

let server_state = server_state.read();
Expand Down
2 changes: 1 addition & 1 deletion lib/src/server/tests/services/subscription.rs
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ fn republish_request(subscription_id: u32, retransmit_sequence_number: u32) -> R

#[test]
fn create_modify_destroy_subscription() {
do_subscription_service_test(|server_state, _session, _, _ss, _| {
do_subscription_service_test(|_server_state, _session, _, _ss, _| {
// TODO Create a subscription, modify it, destroy it
//unimplemented!();
})
Expand Down

0 comments on commit 6719c9f

Please sign in to comment.