Skip to content

Commit

Permalink
rebase fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
Alexander Lyon authored and Alexander Lyon committed Feb 14, 2024
1 parent ddedf28 commit 0f78ba6
Showing 1 changed file with 3 additions and 16 deletions.
19 changes: 3 additions & 16 deletions crates/turborepo-lib/src/daemon/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,8 @@ use turborepo_repository::discovery::{
LocalPackageDiscoveryBuilder, PackageDiscovery, PackageDiscoveryBuilder,
};

use super::{bump_timeout::BumpTimeout, endpoint::SocketOpenError, proto, Paths};
use crate::daemon::{bump_timeout_layer::BumpTimeoutLayer, endpoint::listen_socket};
use super::{bump_timeout::BumpTimeout, endpoint::SocketOpenError, proto};
use crate::daemon::{bump_timeout_layer::BumpTimeoutLayer, endpoint::listen_socket, Paths};

#[derive(Debug)]
#[allow(dead_code)]
Expand Down Expand Up @@ -196,9 +196,6 @@ where

pub async fn serve(self) -> Result<CloseReason, PDB::Error> {
let Self {
watcher_tx,
watcher_rx,
daemon_root,
external_shutdown,
paths,
repo_root,
Expand All @@ -216,7 +213,7 @@ where
package_discovery_backup,
repo_root.clone(),
trigger_shutdown,
log_file,
paths.log_file,
);

let running = Arc::new(AtomicBool::new(true));
Expand All @@ -240,16 +237,6 @@ where
};
};

// Run the actual service. It takes ownership of the struct given to it,
// so we use a private struct with just the pieces of state needed to handle
// RPCs.
let service = TurboGrpcServiceInner {
shutdown: trigger_shutdown,
watcher_rx,
times_saved: Arc::new(Mutex::new(HashMap::new())),
start_time: Instant::now(),
log_file: paths.log_file.clone(),
};
let server_fut = {
let service = ServiceBuilder::new()
.layer(BumpTimeoutLayer::new(bump_timeout.clone()))
Expand Down

0 comments on commit 0f78ba6

Please sign in to comment.