Use rust logging API

src/rust/engine/Cargo.toml

@@ -28,6 +28,7 @@ fs = { path = "fs" }
 futures = "0.1.16"
 hashing = { path = "hashing" }
 lazy_static = "0.2.2"
+log = "0.4"
 ordermap = "0.2.8"
 petgraph = "0.4.5"
 process_execution = { path = "process_execution" }

src/rust/engine/fs/fs_util/Cargo.toml

@@ -8,6 +8,7 @@ bazel_protos = { path = "../../process_execution/bazel_protos" }
 boxfuture = { path = "../../boxfuture" }
 bytes = "0.4.5"
 clap = "2"
+env_logger = "0.5.4"
 fs = { path = ".." }
 futures = "0.1.16"
 hashing = { path = "../../hashing" }

src/rust/engine/fs/fs_util/src/main.rs

@@ -2,6 +2,7 @@ extern crate bazel_protos;
 extern crate boxfuture;
 extern crate bytes;
 extern crate clap;
+extern crate env_logger;
 extern crate fs;
 extern crate futures;
 extern crate hashing;
@@ -37,6 +38,8 @@ impl From<String> for ExitError {
 }
 
 fn main() {
+  env_logger::init();
+
   match execute(
     App::new("fs_util")
       .subcommand(

src/rust/engine/process_execution/Cargo.toml

@@ -12,6 +12,7 @@ fs = { path = "../fs" }
 futures = "0.1.16"
 grpcio = { version = "0.2.0", features = ["secure"] }
 hashing = { path = "../hashing" }
+log = "0.4"
 protobuf = { version = "1.4.1", features = ["with-bytes"] }
 sha2 = "0.6.0"
 tempdir = "0.3.5"

src/rust/engine/process_execution/src/lib.rs

@@ -6,6 +6,8 @@ extern crate fs;
 extern crate futures;
 extern crate grpcio;
 extern crate hashing;
+#[macro_use]
+extern crate log;
 #[cfg(test)]
 extern crate mock;
 extern crate protobuf;

src/rust/engine/process_execution/src/remote.rs

@@ -80,8 +80,7 @@ impl CommandRunner {
       Ok((command, execute_request)) => {
         self.upload_command(&command, execute_request.get_action().get_command_digest().into())
           .and_then(move |_| {
-            // TODO: Log less verbosely
-            println!("Executing remotely request: {:?} (command: {:?})", execute_request, command);
+            debug!("Executing remotely request: {:?} (command: {:?})", execute_request, command);
 
             map_grpc_result(execution_client.execute(&execute_request))
                 .map(|result| (Arc::new(execute_request), result))
@@ -194,7 +193,7 @@ fn extract_execute_response(
   mut operation: bazel_protos::operations::Operation,
 ) -> Result<ExecuteProcessResult, ExecutionError> {
   // TODO: Log less verbosely
-  println!("Got operation response: {:?}", operation);
+  debug!("Got operation response: {:?}", operation);
   if !operation.get_done() {
     return Err(ExecutionError::NotFinished(operation.take_name()));
   }
@@ -213,7 +212,7 @@ fn extract_execute_response(
       ExecutionError::Fatal(format!("Invalid ExecuteResponse: {:?}", e))
     })?;
   // TODO: Log less verbosely
-  println!("Got (nested) execute response: {:?}", execute_response);
+  debug!("Got (nested) execute response: {:?}", execute_response);
 
   match grpcio::RpcStatusCode::from(execute_response.get_status().get_code()) {
     grpcio::RpcStatusCode::Ok => Ok(ExecuteProcessResult {