[BREAKING] Remove old pag construction and all support other than timely

li1 · Apr 30, 2019 · f512049 · f512049
1 parent 176d86d
commit f512049
Show file tree

Hide file tree

Showing 51 changed files with 3 additions and 2,336 deletions.
diff --git a/pag-construction/.gitignore → backup_pag-construction/.gitignore b/pag-construction/.gitignore → backup_pag-construction/.gitignore
diff --git a/pag-construction/Cargo.toml → backup_pag-construction/Cargo.toml b/pag-construction/Cargo.toml → backup_pag-construction/Cargo.toml
diff --git a/pag-construction/config_default.py → backup_pag-construction/config_default.py b/pag-construction/config_default.py → backup_pag-construction/config_default.py
diff --git a/pag-construction/config_heron.py → backup_pag-construction/config_heron.py b/pag-construction/config_heron.py → backup_pag-construction/config_heron.py
diff --git a/pag-construction/examples/end_to_end.rs → ...p_pag-construction/examples/end_to_end.rs b/pag-construction/examples/end_to_end.rs → ...p_pag-construction/examples/end_to_end.rs
diff --git a/pag-construction/examples/verify.rs → backup_pag-construction/examples/verify.rs b/pag-construction/examples/verify.rs → backup_pag-construction/examples/verify.rs
diff --git a/pag-construction/matplotlibrc → backup_pag-construction/matplotlibrc b/pag-construction/matplotlibrc → backup_pag-construction/matplotlibrc
diff --git a/pag-construction/requirements.txt → backup_pag-construction/requirements.txt b/pag-construction/requirements.txt → backup_pag-construction/requirements.txt
diff --git a/pag-construction/run_all_the_things.sh → ...up_pag-construction/run_all_the_things.sh b/pag-construction/run_all_the_things.sh → ...up_pag-construction/run_all_the_things.sh
diff --git a/pag-construction/run_all_timely.sh → backup_pag-construction/run_all_timely.sh b/pag-construction/run_all_timely.sh → backup_pag-construction/run_all_timely.sh
diff --git a/pag-construction/run_benchmark.py → backup_pag-construction/run_benchmark.py b/pag-construction/run_benchmark.py → backup_pag-construction/run_benchmark.py
diff --git a/pag-construction/run_test.py → backup_pag-construction/run_test.py b/pag-construction/run_test.py → backup_pag-construction/run_test.py
diff --git a/pag-construction/setup_py_dependencies.sh → ...pag-construction/setup_py_dependencies.sh b/pag-construction/setup_py_dependencies.sh → ...pag-construction/setup_py_dependencies.sh
diff --git a/pag-construction/src/bin/construct.rs → backup_pag-construction/src/bin/construct.rs b/pag-construction/src/bin/construct.rs → backup_pag-construction/src/bin/construct.rs
diff --git a/pag-construction/src/bin/test-gen.rs → backup_pag-construction/src/bin/test-gen.rs b/pag-construction/src/bin/test-gen.rs → backup_pag-construction/src/bin/test-gen.rs
diff --git a/pag-construction/src/bin/tosvg.rs → backup_pag-construction/src/bin/tosvg.rs b/pag-construction/src/bin/tosvg.rs → backup_pag-construction/src/bin/tosvg.rs
diff --git a/pag-construction/src/dataflow.rs → backup_pag-construction/src/dataflow.rs b/pag-construction/src/dataflow.rs → backup_pag-construction/src/dataflow.rs
diff --git a/pag-construction/src/input.rs → backup_pag-construction/src/input.rs b/pag-construction/src/input.rs → backup_pag-construction/src/input.rs
diff --git a/pag-construction/src/lib.rs → backup_pag-construction/src/lib.rs b/pag-construction/src/lib.rs → backup_pag-construction/src/lib.rs
diff --git a/pag-construction/src/output.rs → backup_pag-construction/src/output.rs b/pag-construction/src/output.rs → backup_pag-construction/src/output.rs
diff --git a/snailtrail/Cargo.toml → backup_snailtrail/Cargo.toml b/snailtrail/Cargo.toml → backup_snailtrail/Cargo.toml
diff --git a/...src/exploration/betweenness_centrality.rs → ...src/exploration/betweenness_centrality.rs b/...src/exploration/betweenness_centrality.rs → ...src/exploration/betweenness_centrality.rs
diff --git a/snailtrail/src/exploration/groupexplore.rs → ...nailtrail/src/exploration/groupexplore.rs b/snailtrail/src/exploration/groupexplore.rs → ...nailtrail/src/exploration/groupexplore.rs
diff --git a/snailtrail/src/exploration/mod.rs → backup_snailtrail/src/exploration/mod.rs b/snailtrail/src/exploration/mod.rs → backup_snailtrail/src/exploration/mod.rs
diff --git a/snailtrail/src/exploration/single_path.rs → ...snailtrail/src/exploration/single_path.rs b/snailtrail/src/exploration/single_path.rs → ...snailtrail/src/exploration/single_path.rs
diff --git a/snailtrail/src/graph/mod.rs → backup_snailtrail/src/graph/mod.rs b/snailtrail/src/graph/mod.rs → backup_snailtrail/src/graph/mod.rs
diff --git a/snailtrail/src/lib.rs → backup_snailtrail/src/lib.rs b/snailtrail/src/lib.rs → backup_snailtrail/src/lib.rs
diff --git a/logformat/rust/Cargo.toml → logformat/Cargo.toml b/logformat/rust/Cargo.toml → logformat/Cargo.toml
@@ -10,14 +10,5 @@ enum-primitive-derive = "^0.1"
 num-traits = "^0.2"
 abomonation = "0.7"
 abomonation_derive = "0.3"
-# @TODO: replace with serde
 json = "0.11.12"
-clap = "^2.32"
-
-[dev-dependencies]
-rmp-serde = "^0.13"
-quick-protobuf = "^0.6"
-serde = { version = "1.0", features = ["derive"] }
-# serde_json = "1.0"
-# protobuf = "1.4.3" necessary?
-byteorder = "^1.2"
+clap = "^2.32"
diff --git a/logformat/rust/examples/logcat.rs → logformat/examples/logcat.rs b/logformat/rust/examples/logcat.rs → logformat/examples/logcat.rs
diff --git a/logformat/java/.gitignore b/logformat/java/.gitignore
diff --git a/logformat/java/build.sbt b/logformat/java/build.sbt
diff --git a/logformat/java/src/main/java/criticalpath/ActivityType.java b/logformat/java/src/main/java/criticalpath/ActivityType.java
diff --git a/logformat/java/src/main/java/criticalpath/EventType.java b/logformat/java/src/main/java/criticalpath/EventType.java
diff --git a/logformat/java/src/main/java/criticalpath/LogRecordPacker.java b/logformat/java/src/main/java/criticalpath/LogRecordPacker.java
diff --git a/logformat/rust/src/bin/chromeviz.rs → logformat/src/bin/chromeviz.rs b/logformat/rust/src/bin/chromeviz.rs → logformat/src/bin/chromeviz.rs
diff --git a/logformat/rust/src/bin/cpviz.rs → logformat/src/bin/cpviz.rs b/logformat/rust/src/bin/cpviz.rs → logformat/src/bin/cpviz.rs
diff --git a/logformat/rust/src/lib.rs → logformat/src/lib.rs b/logformat/rust/src/lib.rs → logformat/src/lib.rs
@@ -1,20 +1,11 @@
-#![deny(missing_docs)]
-
-// Copyright 2017 ETH Zurich. All rights reserved.
-//
-// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
-// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
-// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
-// option. This file may not be copied, modified, or distributed
-// except according to those terms.
-
 //! Data structure for a `LogRecord`.
 //! A `LogRecord` constitutes the unified `struct` representation of
 //! log messages from various stream processors.
 //!
 //! It is the underlying structure from which the PAG construction starts.
 //! If necessary, it can also be serialized e.g. into a `msgpack` representation.
 
+#![deny(missing_docs)]
 
 #[macro_use]
 extern crate enum_primitive_derive;
@@ -182,7 +173,7 @@ impl LogRecord {
         let ts_nanos = self.timestamp.subsec_nanos();
         msgpack::encode::write_uint(writer, u64::from(ts_secs))?;
         msgpack::encode::write_uint(writer, u64::from(ts_nanos))?;
-        msgpack::encode::write_uint(writer, self.epoch);
+        msgpack::encode::write_uint(writer, self.epoch)?;
         msgpack::encode::write_uint(writer, u64::from(self.local_worker as u64))?;
         msgpack::encode::write_uint(writer, self.activity_type.to_u64().unwrap())?;
         msgpack::encode::write_uint(writer, self.event_type.to_u64().unwrap())?;

diff --git a/spark-parser/Cargo.toml b/spark-parser/Cargo.toml
diff --git a/spark-parser/INSTRUMENTATION.md b/spark-parser/INSTRUMENTATION.md
diff --git a/spark-parser/README.md b/spark-parser/README.md
diff --git a/spark-parser/resources/app-20170324182509-0000 b/spark-parser/resources/app-20170324182509-0000