aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--client-native-lib/src/peer.rs9
-rw-r--r--client-native-rift/src/main.rs9
2 files changed, 9 insertions, 9 deletions
diff --git a/client-native-lib/src/peer.rs b/client-native-lib/src/peer.rs
index 8e89f48..82c7c94 100644
--- a/client-native-lib/src/peer.rs
+++ b/client-native-lib/src/peer.rs
@@ -6,9 +6,8 @@
use crate::{
instance::Instance,
protocol::{self, ProvideInfo, RelayMessage, Sdp},
- LocalResource,
};
-use log::{info, warn};
+use log::{debug, info, warn};
use std::{collections::HashMap, sync::Arc};
use tokio::sync::RwLock;
use webrtc::{
@@ -191,7 +190,7 @@ impl Peer {
warn!("({}) requested unknown local resource", self.id)
}
}
- RelayMessage::RequestStop { id } => {}
+ RelayMessage::RequestStop { id: _ } => {} // TODO
}
}
@@ -200,14 +199,14 @@ impl Peer {
}
pub async fn on_ice_candidate(&self, candidate: RTCIceCandidate) {
- info!("publishing local ICE candidate");
+ debug!("publishing local ICE candidate");
self.send_relay(RelayMessage::IceCandidate(
candidate.to_json().await.unwrap(),
))
.await;
}
pub async fn on_remote_ice_candidate(&self, candidate: RTCIceCandidateInit) {
- info!("adding remote ICE candidate");
+ debug!("adding remote ICE candidate");
self.peer_connection
.add_ice_candidate(candidate)
.await
diff --git a/client-native-rift/src/main.rs b/client-native-rift/src/main.rs
index 40f7fce..1a36177 100644
--- a/client-native-rift/src/main.rs
+++ b/client-native-rift/src/main.rs
@@ -5,12 +5,12 @@
*/
#![feature(box_syntax)]
-use bytes::{Bytes, BytesMut};
+use bytes::Bytes;
use clap::{Parser, Subcommand};
use client_native_lib::{
instance::Instance,
peer::{Peer, TransportChannel},
- protocol::{ProvideInfo, RelayMessage},
+ protocol::ProvideInfo,
Config, DynFut, EventHandler, LocalResource,
};
use humansize::DECIMAL;
@@ -31,7 +31,8 @@ use tokio::{
fn main() {
env_logger::builder()
- .filter_level(log::LevelFilter::Info)
+ .filter_module("rift", log::LevelFilter::Info)
+ .filter_module("client_native_lib", log::LevelFilter::Info)
.parse_env("LOG")
.init();
tokio::runtime::Builder::new_multi_thread()
@@ -105,7 +106,7 @@ struct Handler {
}
impl EventHandler for Handler {
- fn peer_join(&self, peer: Arc<Peer>) -> client_native_lib::DynFut<()> {
+ fn peer_join(&self, _peer: Arc<Peer>) -> client_native_lib::DynFut<()> {
Box::pin(async move {})
}