Replace 'Downloading' with 'Caching' in logs
This commit is contained in:
1 parent
f67b13e27e
commit
2838b25738
2 files changed
+12
-12
No files matched your search
@@ -169,7 +169,7 @@ pub async fn play_track(
|
|||||||
tokio::spawn(async move {
|
tokio::spawn(async move {
|
||||||
match download_and_stream(&url, buffer_writer, track_id, cache_clone, content_len).await {
|
match download_and_stream(&url, buffer_writer, track_id, cache_clone, content_len).await {
|
||||||
Ok(()) => log::info!("Track {} ready for instant replay from cache", track_id),
|
Ok(()) => log::info!("Track {} ready for instant replay from cache", track_id),
|
||||||
Err(e) => log::error!("Streaming download failed for track {}: {}", track_id, e),
|
Err(e) => log::error!("Streaming cache failed for track {}: {}", track_id, e),
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -185,7 +185,7 @@ pub async fn play_track(
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Standard download path (streaming disabled)
|
// Standard download path (streaming disabled)
|
||||||
log::info!("Standard download mode for track {}", track_id);
|
log::info!("Standard caching mode for track {}", track_id);
|
||||||
|
|
||||||
// Download the audio
|
// Download the audio
|
||||||
let audio_data = download_audio(&stream_url.url).await?;
|
let audio_data = download_audio(&stream_url.url).await?;
|
||||||
@@ -281,7 +281,7 @@ async fn download_audio(url: &str) -> Result<Vec<u8>, String> {
|
|||||||
.build()
|
.build()
|
||||||
.map_err(|e| format!("Failed to create HTTP client: {}", e))?;
|
.map_err(|e| format!("Failed to create HTTP client: {}", e))?;
|
||||||
|
|
||||||
log::info!("Downloading audio...");
|
log::info!("Caching audio...");
|
||||||
|
|
||||||
let response = client
|
let response = client
|
||||||
.get(url)
|
.get(url)
|
||||||
@@ -299,7 +299,7 @@ async fn download_audio(url: &str) -> Result<Vec<u8>, String> {
|
|||||||
.await
|
.await
|
||||||
.map_err(|e| format!("Failed to read audio bytes: {}", e))?;
|
.map_err(|e| format!("Failed to read audio bytes: {}", e))?;
|
||||||
|
|
||||||
log::info!("Downloaded {} bytes", bytes.len());
|
log::info!("Cached {} bytes", bytes.len());
|
||||||
Ok(bytes.to_vec())
|
Ok(bytes.to_vec())
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -493,7 +493,7 @@ async fn download_and_stream(
|
|||||||
.build()
|
.build()
|
||||||
.map_err(|e| format!("Failed to create HTTP client: {}", e))?;
|
.map_err(|e| format!("Failed to create HTTP client: {}", e))?;
|
||||||
|
|
||||||
log::info!("Starting streaming download for track {} ({:.2} MB total)",
|
log::info!("Starting streaming cache for track {} ({:.2} MB total)",
|
||||||
track_id,
|
track_id,
|
||||||
content_length as f64 / (1024.0 * 1024.0)
|
content_length as f64 / (1024.0 * 1024.0)
|
||||||
);
|
);
|
||||||
@@ -573,7 +573,7 @@ async fn download_and_stream(
|
|||||||
let avg_speed = (bytes_received as f64 / total_time.as_secs_f64()) / (1024.0 * 1024.0);
|
let avg_speed = (bytes_received as f64 / total_time.as_secs_f64()) / (1024.0 * 1024.0);
|
||||||
|
|
||||||
log::info!(
|
log::info!(
|
||||||
"Streaming download complete: {:.2} MB in {:.1}s ({:.2} MB/s avg)",
|
"Streaming cache complete: {:.2} MB in {:.1}s ({:.2} MB/s avg)",
|
||||||
bytes_received as f64 / (1024.0 * 1024.0),
|
bytes_received as f64 / (1024.0 * 1024.0),
|
||||||
total_time.as_secs_f64(),
|
total_time.as_secs_f64(),
|
||||||
avg_speed
|
avg_speed
|
||||||
|
|||||||
@@ -1654,12 +1654,12 @@ impl Player {
|
|||||||
log::info!("Player: Got stream URL: {} (format: {})", stream_url.url, stream_url.mime_type);
|
log::info!("Player: Got stream URL: {} (format: {})", stream_url.url, stream_url.mime_type);
|
||||||
|
|
||||||
// Download the audio data
|
// Download the audio data
|
||||||
log::info!("Player: Starting audio download...");
|
log::info!("Player: Starting audio caching...");
|
||||||
let audio_data = self.download_audio(&stream_url.url).await.map_err(|e| {
|
let audio_data = self.download_audio(&stream_url.url).await.map_err(|e| {
|
||||||
log::error!("Player: Download failed: {}", e);
|
log::error!("Player: Caching failed: {}", e);
|
||||||
e
|
e
|
||||||
})?;
|
})?;
|
||||||
log::info!("Player: Downloaded {} bytes of audio data", audio_data.len());
|
log::info!("Player: Cached {} bytes of audio data", audio_data.len());
|
||||||
|
|
||||||
// Send to audio thread
|
// Send to audio thread
|
||||||
self.play_data(audio_data, track_id)
|
self.play_data(audio_data, track_id)
|
||||||
@@ -1793,7 +1793,7 @@ impl Player {
|
|||||||
.build()
|
.build()
|
||||||
.map_err(|e| format!("Failed to create HTTP client: {}", e))?;
|
.map_err(|e| format!("Failed to create HTTP client: {}", e))?;
|
||||||
|
|
||||||
log::info!("Downloading audio from URL...");
|
log::info!("Caching audio from URL...");
|
||||||
|
|
||||||
let response = client
|
let response = client
|
||||||
.get(url)
|
.get(url)
|
||||||
@@ -1806,14 +1806,14 @@ impl Player {
|
|||||||
return Err(format!("HTTP error: {}", response.status()));
|
return Err(format!("HTTP error: {}", response.status()));
|
||||||
}
|
}
|
||||||
|
|
||||||
log::info!("Download response received, reading bytes...");
|
log::info!("Response received, reading bytes...");
|
||||||
|
|
||||||
let bytes = response
|
let bytes = response
|
||||||
.bytes()
|
.bytes()
|
||||||
.await
|
.await
|
||||||
.map_err(|e| format!("Failed to read audio bytes: {}", e))?;
|
.map_err(|e| format!("Failed to read audio bytes: {}", e))?;
|
||||||
|
|
||||||
log::info!("Downloaded {} bytes", bytes.len());
|
log::info!("Cached {} bytes", bytes.len());
|
||||||
Ok(bytes.to_vec())
|
Ok(bytes.to_vec())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in new issue
Block a user