dprint 0.18.2

Binary for dprint code formatter—a pluggable and configurable code formatting platform.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

use std::path::PathBuf;
use std::sync::Arc;

use crate::environment::Environment;
use crate::plugins::InitializedPluginPool;

use super::Deque;

pub struct PluginStealInfo {
  pub has_plugin_available: bool,
  pub steal_time: u64,
}

pub struct LocalPluginWork<TEnvironment: Environment> {
  pub pool: Arc<InitializedPluginPool<TEnvironment>>,
  items: Deque<PathBuf>,
}

impl<TEnvironment: Environment> LocalPluginWork<TEnvironment> {
  pub fn new(pool: Arc<InitializedPluginPool<TEnvironment>>, file_paths: Vec<PathBuf>) -> Self {
    LocalPluginWork {
      pool,
      items: Deque::new(file_paths),
    }
  }

  pub fn work_items_len(&self) -> usize {
    self.items.len()
  }

  pub fn take_next_work_item(&mut self) -> PathBuf {
    self.items.dequeue().unwrap().to_owned()
  }

  pub fn split(&mut self) -> LocalPluginWork<TEnvironment> {
    LocalPluginWork {
      pool: self.pool.clone(),
      items: self.items.split(),
    }
  }

  pub fn calculate_worthwhile_steal_time(&self) -> Option<PluginStealInfo> {
    let remaining_len = self.items.len() as u64;
    if remaining_len <= 1 {
      return None; // don't steal, not worth it
    }
    let time_snapshot = self.pool.get_time_snapshot();
    let actual_startup_time = if time_snapshot.has_plugin_available { 0 } else { time_snapshot.startup_time };
    let steal_time = (remaining_len / 2) * time_snapshot.average_format_time + actual_startup_time;
    let remaining_time = remaining_len * time_snapshot.average_format_time;
    if steal_time + time_snapshot.average_format_time * 2 > remaining_time {
      None // don't steal, not worth it
    } else {
      Some(PluginStealInfo {
        has_plugin_available: time_snapshot.has_plugin_available,
        steal_time,
      })
    }
  }
}