Mercurial > public > mercurial-scm > hg
annotate rust/chg/src/main.rs @ 43818:ce088b38f92b
rust: run rustfmt
# skip-blame automated reformatting
Differential Revision: https://phab.mercurial-scm.org/D7578
author | Gregory Szorc <gregory.szorc@gmail.com> |
---|---|
date | Sat, 07 Dec 2019 13:06:25 -0800 |
parents | 87c76e5f3427 |
children | bb936e25a84a |
rev | line source |
---|---|
39967 | 1 // Copyright 2018 Yuya Nishihara <yuya@tcha.org> |
2 // | |
3 // This software may be used and distributed according to the terms of the | |
4 // GNU General Public License version 2 or any later version. | |
5 | |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
6 extern crate chg; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
7 extern crate futures; |
40288
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
8 extern crate log; |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
9 extern crate tokio; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
10 extern crate tokio_hglib; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
11 |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
12 use chg::locator; |
40120
89742f1fa6cb
rust-chg: install signal handlers to forward signals to server
Yuya Nishihara <yuya@tcha.org>
parents:
39979
diff
changeset
|
13 use chg::procutil; |
43818
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
14 use chg::{ChgClientExt, ChgUiHandler}; |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
15 use futures::sync::oneshot; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
16 use std::env; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
17 use std::io; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
18 use std::process; |
40288
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
19 use std::time::Instant; |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
20 use tokio::prelude::*; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
21 use tokio_hglib::UnixClient; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
22 |
40288
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
23 struct DebugLogger { |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
24 start: Instant, |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
25 } |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
26 |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
27 impl DebugLogger { |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
28 pub fn new() -> DebugLogger { |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
29 DebugLogger { |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
30 start: Instant::now(), |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
31 } |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
32 } |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
33 } |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
34 |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
35 impl log::Log for DebugLogger { |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
36 fn enabled(&self, metadata: &log::Metadata) -> bool { |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
37 metadata.target().starts_with("chg::") |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
38 } |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
39 |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
40 fn log(&self, record: &log::Record) { |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
41 if self.enabled(record.metadata()) { |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
42 // just make the output looks similar to chg of C |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
43 let l = format!("{}", record.level()).to_lowercase(); |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
44 let t = self.start.elapsed(); |
43818
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
45 writeln!( |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
46 io::stderr(), |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
47 "chg: {}: {}.{:06} {}", |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
48 l, |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
49 t.as_secs(), |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
50 t.subsec_micros(), |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
51 record.args() |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
52 ) |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
53 .unwrap_or(()); |
40288
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
54 } |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
55 } |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
56 |
43818
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
57 fn flush(&self) {} |
40288
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
58 } |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
59 |
39967 | 60 fn main() { |
40288
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
61 if env::var_os("CHGDEBUG").is_some() { |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
62 log::set_boxed_logger(Box::new(DebugLogger::new())) |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
63 .expect("any logger should not be installed yet"); |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
64 log::set_max_level(log::LevelFilter::Debug); |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
65 } |
87c76e5f3427
rust-chg: install logger if $CHGDEBUG is set
Yuya Nishihara <yuya@tcha.org>
parents:
40286
diff
changeset
|
66 |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
67 let code = run().unwrap_or_else(|err| { |
40286
af52181f71ff
rust-chg: suppress panic while writing chg error to stderr
Yuya Nishihara <yuya@tcha.org>
parents:
40120
diff
changeset
|
68 writeln!(io::stderr(), "chg: abort: {}", err).unwrap_or(()); |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
69 255 |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
70 }); |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
71 process::exit(code); |
39967 | 72 } |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
73 |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
74 fn run() -> io::Result<i32> { |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
75 let current_dir = env::current_dir()?; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
76 let sock_path = locator::prepare_server_socket_path()?; |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
77 let handler = ChgUiHandler::new(); |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
78 let (result_tx, result_rx) = oneshot::channel(); |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
79 let fut = UnixClient::connect(sock_path) |
43818
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
80 .and_then(|client| client.set_current_dir(current_dir)) |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
81 .and_then(|client| client.attach_io(io::stdin(), io::stdout(), io::stderr())) |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
82 .and_then(|client| { |
40120
89742f1fa6cb
rust-chg: install signal handlers to forward signals to server
Yuya Nishihara <yuya@tcha.org>
parents:
39979
diff
changeset
|
83 let pid = client.server_spec().process_id.unwrap(); |
89742f1fa6cb
rust-chg: install signal handlers to forward signals to server
Yuya Nishihara <yuya@tcha.org>
parents:
39979
diff
changeset
|
84 let pgid = client.server_spec().process_group_id; |
89742f1fa6cb
rust-chg: install signal handlers to forward signals to server
Yuya Nishihara <yuya@tcha.org>
parents:
39979
diff
changeset
|
85 procutil::setup_signal_handler_once(pid, pgid)?; |
89742f1fa6cb
rust-chg: install signal handlers to forward signals to server
Yuya Nishihara <yuya@tcha.org>
parents:
39979
diff
changeset
|
86 Ok(client) |
89742f1fa6cb
rust-chg: install signal handlers to forward signals to server
Yuya Nishihara <yuya@tcha.org>
parents:
39979
diff
changeset
|
87 }) |
43818
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
88 .and_then(|client| client.run_command_chg(handler, env::args_os().skip(1))) |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
89 .map(|(_client, _handler, code)| { |
40120
89742f1fa6cb
rust-chg: install signal handlers to forward signals to server
Yuya Nishihara <yuya@tcha.org>
parents:
39979
diff
changeset
|
90 procutil::restore_signal_handler_once()?; |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
91 Ok(code) |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
92 }) |
43818
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
93 .or_else(|err| Ok(Err(err))) // pass back error to caller |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
94 .map(|res| result_tx.send(res).unwrap()); |
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
95 tokio::run(fut); |
43818
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
96 result_rx.wait().unwrap_or(Err(io::Error::new( |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
97 io::ErrorKind::Other, |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
98 "no exit code set", |
ce088b38f92b
rust: run rustfmt
Gregory Szorc <gregory.szorc@gmail.com>
parents:
40288
diff
changeset
|
99 ))) |
39979
6bdee4bc181a
rust-chg: add main program
Yuya Nishihara <yuya@tcha.org>
parents:
39967
diff
changeset
|
100 } |