mononoke: init cachelib only once and add more logging

Summary:
Initializing twice causes it to fail. Let's not do that, and also let's use
init_mononoke function instead of our adhoc logger and runtime creationg (at
the very least it also initializes tunables and sets correct tokio runtime
parameters).

Also let's add more logging to see the progress of uploading

Reviewed By: ahornby

Differential Revision: D27079673

fbshipit-source-id: 940135a9aed62f7139835b2450a1964b879e814b

Author: StanislavGlebik

eden/mononoke/streaming_clone/src/main.rs

@@ -40,7 +40,6 @@ pub async fn streaming_clone<'a>(
     logger: Logger,
     matches: &'a MononokeMatches<'a>,
 ) -> Result<(), Error> {
-    args::init_cachelib(fb, &matches);
     let ctx = CoreContext::new_with_logger(fb, logger.clone());
     let repo = args::open_repo(fb, &logger, &matches).await?;
 
@@ -221,6 +220,15 @@ async fn upload_chunks_blobstore<'a>(
         }
     }))
     .buffered(10)
+    .inspect({
+        let mut i = 0;
+        move |_| {
+            i += 1;
+            if i % 100 == 0 {
+                info!(ctx.logger(), "uploaded {}", i);
+            }
+        }
+    })
     .try_collect::<Vec<_>>()
     .await?;
 
@@ -438,9 +446,7 @@ fn main(fb: FacebookInit) -> Result<(), Error> {
         ))
         .get_matches();
 
-    args::init_cachelib(fb, &matches);
-    let logger = args::init_logging(fb, &matches)?;
 
-    let mut runtime = tokio::runtime::Runtime::new()?;
+    let (_, logger, mut runtime) = args::init_mononoke(fb, &matches)?;
     runtime.block_on(streaming_clone(fb, logger, &matches))
 }