Merge pull request #84 from Derecho-Project/minor_cleanup

Since this is almost entirely non-code changes, and Thiago is no longer available to review pull requests, I'm going to review and merge this myself.

Author: etremel

include/cascade/cascade_interface.hpp

@@ -49,8 +49,6 @@ class CriticalDataPathObserver : public derecho::DeserializationContext {
      * @param[in]   value             The value of the K/V pair
      * @param[in]   cascade_ctxt      The cascade context to be used later
      * @param[in]   is_trigger        True for critical data path of `p2p_send`; otherwise, the critical data path of `ordered_send`.
-     *
-     * @return void
      */
     virtual void operator()(const uint32_t subgroup_idx,
                             const uint32_t shard_idx,
@@ -111,8 +109,6 @@ class ICascadeStore {
      *
      * @param[in]   value   The K/V pair value
      * @param[in]   as_trigger  The object will NOT be used to update the K/V state.
-     *
-     * @return      void
      */
     virtual void put_and_forget(const VT& value, bool as_trigger) const = 0;
 
@@ -149,7 +145,7 @@ class ICascadeStore {
      *              If `stable == false`, we only return the data reflecting the latest locally delivered atomic
      *              broadcast. Otherwise, stable data will be returned, meaning that the persisted states returned
      *              is safe: they will survive after whole system recovery.
-     * @param[in]   exact 
+     * @param[in]   exact
      *              The exact match flag: this function try to return the value of that key at the 'ver'. If such a
      *              value does not exists and exact is true, it will throw an exception. If such a value does not
      *              exists and exact is false, it will return the latest state of the value for 'key' before 'ver'.
@@ -272,7 +268,7 @@ class ICascadeStore {
      * @param[in]   key     The key
      * @param[in]   ver     Version, if `ver == CURRENT_VERSION`, get the latest value.
      * @param[in]   stable
-     * @param[in]   exact 
+     * @param[in]   exact
      *              The exact match flag: this function try to return the value of that key at the 'ver'. If such a
      *              value does not exists and exact is true, it will throw an exception. If such a value does not
      *              exists and exact is false, it will return the latest state of the value for 'key' before 'ver'.
@@ -427,7 +423,7 @@ VT create_null_object_cb(const KT& key = *IK);
  * We use both the concepts of null and valid object in Cascade. A null object precisely means 'no data'; while a
  * valid object literarily means an object is 'valid'. Technically, a null object has a valid key while invalid
  * object does not.
- * 
+ *
  * @tparam      KT      The key type.
  * @tparam      VT      The value type.
  */
@@ -489,7 +485,7 @@ class IKeepVersion {
 
     /**
      * @brief   The version getter
-     * 
+     *
      * Get the version
      *
      * @return  The K/V object's version.

include/cascade/detail/prefix_registry.hpp

@@ -115,8 +115,6 @@ class PrefixRegistry {
      *
      * @param path      - the full path.
      * @param collector - the lambda function to collect values for all prefixes of a string.
-     *
-     * @return 
      */
     void collect_values_for_prefixes(const std::string& path,
             const std::function<void(const std::string& prefix,const std::shared_ptr<T>& value)>& collector) const;

include/cascade/detail/service_impl.hpp

@@ -2440,7 +2440,7 @@ void ExecutionEngine<CascadeTypes...>::workhorse(uint32_t worker_id, struct acti
     dbg_default_trace("Cascade context workhorse[{}] started", worker_id);
     while(is_running) {
         // waiting for an action
-        Action action = std::move(aq.action_buffer_dequeue(is_running));
+        Action action = aq.action_buffer_dequeue(is_running);
         // if action_buffer_dequeue return with is_running == false, value_ptr is invalid(nullptr).
         action.fire(this,worker_id);
 

include/cascade/service.hpp

@@ -85,7 +85,6 @@ class OpenLoopLatencyCollectorClient {
      * @param id        The event id for corresponding event.
      * @param use_local_ts  Using loca timestamp.
      *
-     * @return          N/A
      */
     virtual void ack(uint32_t type, uint32_t id, bool use_local_ts = false) = 0;
 

include/cascade/utils.hpp

@@ -1,5 +1,8 @@
 #!/bin/bash
-INSTALL_PREFIX=${HOME}/opt-dev
+INSTALL_PREFIX="/usr/local"
+if [[ $# -gt 0 ]]; then
+    INSTALL_PREFIX=$1
+fi
 
 wget https://www.cs.umd.edu/~mount/ANN/Files/1.1.2/ann_1.1.2.tar.gz
 tar -xf ann_1.1.2.tar.gz

scripts/prerequisites/install-ann.sh

@@ -0,0 +1,16 @@
+#!/usr/bin/env bash
+set -eu
+export TMPDIR=/var/tmp
+WORKPATH=`mktemp -d`
+INSTALL_PREFIX="/usr/local"
+if [[ $# -gt 0 ]]; then
+    INSTALL_PREFIX=$1
+fi
+
+echo "Using INSTALL_PREFIX=${INSTALL_PREFIX}"
+
+cd ${WORKPATH}
+git clone https://github.com/k06a/boolinq.git
+cd boolinq
+cp -r include/ ${INSTALL_PREFIX}
+rm -rf ${WORKPATH}

scripts/prerequisites/install-boolinq.sh

@@ -1,5 +1,8 @@
 #!/bin/bash
-export INSTALL_PREFIX=$HOME/opt-dev/
+INSTALL_PREFIX="/usr/local"
+if [[ $# -gt 0 ]]; then
+    INSTALL_PREFIX=$1
+fi
 git clone https://github.com/serizba/cppflow.git
 cd cppflow
 git checkout 9ea9519c66d9b1893e2d298db8aa1ee866f903a2

scripts/prerequisites/install-cppflow.sh

@@ -1,11 +1,14 @@
 #!/bin/bash
 
-if [ $# != 1 ]; then
+if [ $# -lt 1 ]; then
   echo "USAGE: $0 <cpu|gpu>"
   exit 0
 fi
 
-INSTALL_PREFIX=${HOME}/opt-dev
+INSTALL_PREFIX="/usr/local"
+if [[ $# -gt 1 ]]; then
+    INSTALL_PREFIX=$2
+fi
 INSTALL_TYPE=$1
 ZIP_FILE=libtorch-cxx11.zip
 if [ $INSTALL_TYPE == 'cpu' ]; then

scripts/prerequisites/install-libtorch.sh

@@ -1,5 +1,8 @@
 #!/bin/bash
-export INSTALL_PREFIX=$HOME/opt-dev/
+INSTALL_PREFIX="/usr/local"
+if [[ $# -gt 0 ]]; then
+    INSTALL_PREFIX=$1
+fi
 # install python opencv
 sudo apt-get -y install python3-opencv
 # Download and unpack sources