Page MenuHomePhorge
Files F2884557

No OneTemporary
Actions

Size
4 KB
Referenced Files
None
Subscribers
None

View Options

diff --git a/src/id.rs b/src/id.rs
new file mode 100644
index 0000000..654bee5
--- /dev/null
+++ b/src/id.rs
@@ -0,0 +1,10 @@
+use std::sync::atomic::{AtomicUsize, Ordering};
+
+pub struct AutoIncrement {
+ pub counter: AtomicUsize,
+}
+
+impl AutoIncrement {
+ pub fn new(start: usize) -> Self { AutoIncrement { counter: AtomicUsize::new(start) } }
+ pub fn next(&self) -> usize { self.counter.fetch_add(1, Ordering::SeqCst) }
+}
diff --git a/src/main.rs b/src/main.rs
index 8748648..70aaae6 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -1,91 +1,43 @@
-use macros_rs::{crashln, ternary};
-use std::collections::HashMap;
-use std::sync::atomic::{AtomicUsize, Ordering};
+mod id;
+mod process;
+
+use crate::process::Runner;
+use macros_rs::ternary;
use std::{thread, time::Duration};
#[cxx::bridge]
-pub mod process {
+pub mod service {
unsafe extern "C++" {
include!("pmc/src/include/process.h");
include!("pmc/src/include/bridge.h");
pub fn stop(pid: i64) -> i64;
pub fn run(name: &str, log_path: &str, command: &str) -> i64;
}
}
-struct AutoIncrementId {
- counter: AtomicUsize,
-}
-
-impl AutoIncrementId {
- fn new() -> Self { AutoIncrementId { counter: AtomicUsize::new(0) } }
- fn next(&self) -> usize { self.counter.fetch_add(1, Ordering::SeqCst) }
-}
-
-#[derive(Clone, Debug)]
-struct Process<'a> {
- pid: i64,
- name: &'a str,
- running: bool,
-}
-
-struct Runner<'a> {
- log_path: &'a str,
- id: AutoIncrementId,
- process_list: HashMap<usize, Process<'a>>,
-}
-
-impl<'a> Runner<'a> {
- fn new(path: &'a str) -> Self {
- Runner {
- log_path: path,
- id: AutoIncrementId::new(),
- process_list: HashMap::new(),
- }
- }
-
- fn start(&mut self, name: &'a str, command: &'a str) {
- let pid = process::run(&name, &self.log_path, &command);
- self.process_list.insert(self.id.next(), Process { pid, name, running: true });
- }
-
- fn stop(&mut self, id: usize) {
- if let Some(item) = self.process_list.get_mut(&id) {
- let pid = item.pid;
- process::stop(pid);
- item.running = false;
- } else {
- crashln!("process with {id} does not exist");
- }
- }
-
- fn info(&self, id: usize) -> Option<&Process> { self.process_list.get(&id) }
- fn list(&self) -> &HashMap<usize, Process<'a>> { &self.process_list }
-}
-
fn main() {
// save in .pmc/dump.toml
// use global placeholders for home crate
// use psutil for memory and cpu usage (in PAW)
// create log dir if not exist
// use clap cli and rataui for ui
// (pmc ls, pmc list, pmc ls --json, pmc list --json)
// [use clap command alias]
let mut runner = Runner::new("tests/logs");
runner.start("example", "node tests/index.js");
println!("{:?}", runner.info(0));
thread::sleep(Duration::from_millis(1000));
runner.stop(0);
println!("{:?}", runner.info(0));
// runner.list().iter().for_each(|(id, item)| println!("id: {}\nname: {}", id, item.name));
for (id, item) in runner.list() {
println!("id: {id}\nname: {}\npid: {}\nstatus: {}", item.name, item.pid, ternary!(item.running, "online", "offline"));
}
}
diff --git a/src/process.rs b/src/process.rs
new file mode 100644
index 0000000..488bd0b
--- /dev/null
+++ b/src/process.rs
@@ -0,0 +1,49 @@
+use crate::id::AutoIncrement;
+use crate::service::{run, stop};
+use macros_rs::crashln;
+use std::collections::HashMap;
+
+#[derive(Clone, Debug)]
+pub struct Process<'a> {
+ pub pid: i64,
+ pub name: &'a str,
+ pub running: bool,
+}
+
+pub struct Runner<'a> {
+ id: AutoIncrement,
+ log_path: &'a str,
+ process_list: HashMap<usize, Process<'a>>,
+}
+
+impl<'a> Runner<'a> {
+ pub fn new(path: &'a str) -> Self {
+ Runner {
+ log_path: path,
+ // start at highest id in dump
+ id: AutoIncrement::new(0),
+ process_list: HashMap::new(),
+ }
+ }
+
+ pub fn start(&mut self, name: &'a str, command: &'a str) {
+ let pid = run(&name, &self.log_path, &command);
+ self.process_list.insert(self.id.next(), Process { pid, name, running: true });
+ }
+
+ pub fn stop(&mut self, id: usize) {
+ if let Some(item) = self.process_list.get_mut(&id) {
+ let pid = item.pid;
+
+ // add error catching in cc
+ // to allow match Err() here
+ stop(pid);
+ item.running = false;
+ } else {
+ crashln!("process with {id} does not exist");
+ }
+ }
+
+ pub fn info(&self, id: usize) -> Option<&Process> { self.process_list.get(&id) }
+ pub fn list(&self) -> &HashMap<usize, Process<'a>> { &self.process_list }
+}

File Metadata

Mime Type
text/x-diff
Expires
Fri, Mar 20, 2:50 PM (3 h, 17 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
507768
Default Alt Text
(4 KB)

Event Timeline