thePR0M3TH3AN/Marlin
1
0
Fork 0
mirror of https://github.com/PR0M3TH3AN/Marlin.git synced 2025-09-09 07:38:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #32 from PR0M3TH3AN/codex/review-repo-for-maintenance-or-cleanup

Browse Source 
Apply repo hygiene fixes
This commit is contained in:
thePR0M3TH3AN
2025-05-21 10:56:02 -04:00
committed by GitHub
parent 0458f54a7c 23ac9a9533
commit c75cba99ac
13 changed files with 21 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
.github/workflows/ci.yml vendored
View File

@@ -35,6 +35,12 @@ jobs:
sudo apt-get update sudo apt-get update
sudo apt-get install -y hyperfine jq bc # For benchmarks within run_all_tests.sh sudo apt-get install -y hyperfine jq bc # For benchmarks within run_all_tests.sh
- name: Check formatting
run: cargo fmt -- --check
- name: Lint with Clippy
run: cargo clippy -- -D warnings
- name: Ensure run_all_tests.sh is executable - name: Ensure run_all_tests.sh is executable
run: chmod +x ./run_all_tests.sh run: chmod +x ./run_all_tests.sh

0
bench/dirty-vs-full.sh Normal file → Executable file
View File

7
libmarlin/src/watcher.rs
View File

@@ -16,6 +16,7 @@ use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering};
use std::sync::{Arc, Mutex}; use std::sync::{Arc, Mutex};
use std::thread::{self, JoinHandle}; use std::thread::{self, JoinHandle};
use std::time::{Duration, Instant}; use std::time::{Duration, Instant};
use tracing::info;
/// Configuration for the file watcher /// Configuration for the file watcher
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
@@ -430,7 +431,7 @@ impl FileWatcher {
if let Some(db_mutex) = &*db_guard_option { if let Some(db_mutex) = &*db_guard_option {
if let Ok(mut _db_instance_guard) = db_mutex.lock() { if let Ok(mut _db_instance_guard) = db_mutex.lock() {
for event_item in &evts_to_process { for event_item in &evts_to_process {
println!( info!(
"Processing event (DB available): {:?} for path {:?}", "Processing event (DB available): {:?} for path {:?}",
event_item.kind, event_item.path event_item.kind, event_item.path
); );
@@ -440,7 +441,7 @@ impl FileWatcher {
} }
} else { } else {
for event_item in &evts_to_process { for event_item in &evts_to_process {
println!( info!(
"Processing event (no DB): {:?} for path {:?}", "Processing event (no DB): {:?} for path {:?}",
event_item.kind, event_item.path event_item.kind, event_item.path
); );
@@ -454,7 +455,7 @@ impl FileWatcher {
let final_evts = debouncer.flush(); let final_evts = debouncer.flush();
events_processed_clone.fetch_add(final_evts.len(), Ordering::SeqCst); events_processed_clone.fetch_add(final_evts.len(), Ordering::SeqCst);
for processed_event in final_evts { for processed_event in final_evts {
println!( info!(
"Processing final event: {:?} for path {:?}", "Processing final event: {:?} for path {:?}",
processed_event.kind, processed_event.path processed_event.kind, processed_event.path
); );