Clang format newline (faasm#29)

* using same clang format binary than faasm

* applied new clang-format to all codebase

* adding newline at the end of the bash script

bin/run_clang_format.sh

@@ -2,6 +2,14 @@
 
 set -e
 
+function append_newline {
+    if [[ -z "$(tail -c 1 "$1")" ]]; then
+        :
+    else
+        echo >> "$1"
+    fi
+}
+
 if [ -z "$1" ]; then
     TARGET_DIR="."
 else
@@ -11,7 +19,15 @@ fi
 pushd ${TARGET_DIR} >> /dev/null
 
 # Find all source files using Git to automatically respect .gitignore
-clang-format-10 -i $(git ls-files "*.h" "*.cpp" "*.c") 
+FILES=$(git ls-files "*.h" "*.cpp" "*.c")
+
+# Run clang-format
+clang-format-10 -i ${FILES}
+
+# Check newlines
+for f in ${FILES}; do
+    append_newline $f
+done
 
 popd >> /dev/null
 

faabric.cpp

@@ -1 +1 @@
-// Stub to link together top-level CMake library
+// Stub to link together top-level CMake library

include/faabric/executor/FaabricExecutor.h

@@ -59,4 +59,4 @@ class FaabricExecutor
                     bool success,
                     const std::string& errorMsg);
 };
-}
+}

include/faabric/executor/FaabricMain.h

@@ -21,4 +21,4 @@ class FaabricMain
 
     faabric::executor::FaabricPool& pool;
 };
-}
+}

include/faabric/proto/RPCServer.h

@@ -28,4 +28,4 @@ class RPCServer
 
     virtual void doStart(const std::string& serverAddr) = 0;
 };
-}
+}

include/faabric/proto/macros.h

@@ -12,4 +12,4 @@
 #define DEFAULT_RPC_HOST "0.0.0.0"
 #define STATE_PORT 8003
 #define FUNCTION_CALL_PORT 8004
-#define MPI_MESSAGE_PORT 8005
+#define MPI_MESSAGE_PORT 8005

include/faabric/scheduler/ExecGraph.h

@@ -20,4 +20,4 @@ int countExecGraphNodes(const ExecGraph& graph);
 std::string execNodeToJson(const ExecGraphNode& node);
 
 std::string execGraphToJson(const ExecGraph& graph);
-}
+}

include/faabric/scheduler/FunctionCallClient.h

@@ -28,4 +28,4 @@ class FunctionCallClient
 
     void sendMPIMessage(const faabric::MPIMessage& msg);
 };
-}
+}

include/faabric/scheduler/FunctionCallServer.h

@@ -30,4 +30,4 @@ class FunctionCallServer final
   private:
     Scheduler& scheduler;
 };
-}
+}

include/faabric/scheduler/InMemoryMessageQueue.h

@@ -6,4 +6,4 @@
 namespace faabric::scheduler {
 typedef faabric::util::Queue<faabric::Message> InMemoryMessageQueue;
 typedef std::pair<std::string, InMemoryMessageQueue*> InMemoryMessageQueuePair;
-}
+}

include/faabric/scheduler/MpiContext.h

@@ -24,4 +24,4 @@ class MpiContext
     int rank;
     int worldId;
 };
-}
+}

include/faabric/scheduler/Scheduler.h

@@ -132,4 +132,4 @@ class Scheduler
 };
 
 Scheduler& getScheduler();
-}
+}

include/faabric/state/DummyStateServer.h

@@ -29,4 +29,4 @@ class DummyStateServer
     state::StateServer stateServer;
 };
 
-}
+}

include/faabric/state/InMemoryStateRegistry.h

@@ -27,4 +27,4 @@ class InMemoryStateRegistry
 };
 
 InMemoryStateRegistry& getInMemoryStateRegistry();
-}
+}

include/faabric/state/State.h

@@ -43,4 +43,4 @@ class State
 };
 
 State& getGlobalState();
-}
+}

include/faabric/state/StateClient.h

@@ -54,4 +54,4 @@ class StateClient
 
     void unlock();
 };
-}
+}

include/faabric/state/StateKeyValue.h

@@ -177,4 +177,4 @@ class StateKeyValueException : public std::runtime_error
       : runtime_error(message)
     {}
 };
-}
+}

include/faabric/state/StateServer.h

@@ -59,4 +59,4 @@ class StateServer final
   private:
     State& state;
 };
-}
+}

include/faabric/util/barrier.h

@@ -23,4 +23,4 @@ class Barrier
     std::mutex mx;
     std::condition_variable cv;
 };
-}
+}

include/faabric/util/bytes.h

@@ -18,4 +18,4 @@ int safeCopyToBuffer(const uint8_t* dataIn,
                      int dataLen,
                      uint8_t* buffer,
                      int bufferLen);
-}
+}

include/faabric/util/chaining.h

@@ -15,4 +15,4 @@ class ChainedCallFailedException : public faabric::util::FaabricException
       : FaabricException(std::move(message))
     {}
 };
-}
+}

include/faabric/util/clock.h

@@ -22,4 +22,4 @@ class Clock
 };
 
 Clock& getGlobalClock();
-}
+}

include/faabric/util/config.h

@@ -76,4 +76,4 @@ class SystemConfig
 };
 
 SystemConfig& getSystemConfig();
-}
+}

include/faabric/util/environment.h

@@ -10,4 +10,4 @@ std::string setEnvVar(const std::string& varName, const std::string& value);
 void unsetEnvVar(const std::string& varName);
 
 unsigned int getUsableCores();
-}
+}

include/faabric/util/exception.h

@@ -19,4 +19,4 @@ class FaabricException : public std::exception
   protected:
     std::string _message;
 };
-}
+}

include/faabric/util/files.h

@@ -37,4 +37,4 @@ class FileAtUrlIsDirectoryException : public faabric::util::FaabricException
       : FaabricException(std::move(message))
     {}
 };
-}
+}

include/faabric/util/gids.h

@@ -4,4 +4,4 @@
 
 namespace faabric::util {
 unsigned int generateGid();
-}
+}

include/faabric/util/json.h

@@ -18,4 +18,4 @@ class JsonFieldNotFound : public faabric::util::FaabricException
 
 std::string getValueFromJsonString(const std::string& key,
                                    const std::string& jsonIn);
-}
+}

include/faabric/util/locks.h

@@ -7,4 +7,4 @@ namespace faabric::util {
 typedef std::unique_lock<std::mutex> UniqueLock;
 typedef std::unique_lock<std::shared_mutex> FullLock;
 typedef std::shared_lock<std::shared_mutex> SharedLock;
-}
+}

include/faabric/util/logging.h

@@ -6,4 +6,4 @@ namespace faabric::util {
 void initLogging();
 
 std::shared_ptr<spdlog::logger> getLogger();
-}
+}

include/faabric/util/memory.h

@@ -25,4 +25,4 @@ size_t getRequiredHostPagesRoundDown(size_t nBytes);
 size_t alignOffsetDown(size_t offset);
 
 AlignedChunk getPageAlignedChunk(long offset, long length);
-}
+}

include/faabric/util/network.h

@@ -8,4 +8,4 @@ namespace faabric::util {
 std::string getIPFromHostname(const std::string& hostname);
 
 std::string getPrimaryIPForThisHost(const std::string& interface);
-}
+}

include/faabric/util/queue.h

@@ -98,4 +98,4 @@ class TokenPool
     int _size;
     Queue<int> queue;
 };
-}
+}

include/faabric/util/random.h

@@ -6,4 +6,4 @@ namespace faabric::util {
 std::string randomString(int len);
 
 std::string randomStringFromSet(const std::unordered_set<std::string>& s);
-}
+}

include/faabric/wasm/wasm.h

@@ -1,3 +1,3 @@
 #pragma once
 
-int helloFaabricWasm();
+int helloFaabricWasm();

src/executor/FaabricExecutor.cpp

@@ -219,4 +219,4 @@ void FaabricExecutor::postFinish() {}
 
 void FaabricExecutor::postFlush() {}
 
-}
+}

src/proto/RPCServer.cpp

@@ -50,4 +50,4 @@ void RPCServer::stop()
         }
     }
 }
-}
+}

src/scheduler/FunctionCallClient.cpp

@@ -26,4 +26,4 @@ void FunctionCallClient::sendMPIMessage(const faabric::MPIMessage& msg)
     faabric::FunctionStatusResponse response;
     CHECK_RPC("mpi_message", stub->MPICall(&context, msg, &response));
 }
-}
+}

src/scheduler/FunctionCallServer.cpp

@@ -66,4 +66,4 @@ Status FunctionCallServer::MPICall(ServerContext* context,
 
     return Status::OK;
 }
-}
+}

src/scheduler/MpiContext.cpp

@@ -65,4 +65,4 @@ int MpiContext::getWorldId()
 {
     return worldId;
 }
-}
+}

src/scheduler/MpiWorldRegistry.cpp

@@ -68,4 +68,4 @@ void MpiWorldRegistry::clear()
     faabric::util::FullLock lock(registryMutex);
     worldMap.clear();
 }
-}
+}

src/scheduler/Scheduler.cpp

@@ -727,4 +727,4 @@ std::unordered_set<unsigned int> Scheduler::getChainedFunctions(
 
     return chainedIds;
 }
-}
+}

src/state/DummyStateServer.cpp

@@ -94,4 +94,4 @@ void DummyStateServer::stop()
         serverThread.join();
     }
 }
-}
+}

src/state/RedisStateKeyValue.cpp

@@ -143,4 +143,4 @@ void RedisStateKeyValue::clearAppendedFromRemote()
 {
     redis::Redis::getState().del(joinedKey);
 }
-}
+}

src/state/StateClient.cpp

@@ -201,4 +201,4 @@ void StateClient::unlock()
     ClientContext context;
     CHECK_RPC("state_unlock", stub->Unlock(&context, request, &response))
 }
-}
+}

src/state/StateKeyValue.cpp

@@ -630,4 +630,4 @@ std::vector<StateChunk> StateKeyValue::getDirtyChunks(
 
     return chunks;
 }
-}
+}

src/util/barrier.cpp

@@ -39,4 +39,4 @@ int Barrier::getUseCount()
     return uses;
 }
 
-}
+}

src/util/environment.cpp

@@ -44,4 +44,4 @@ unsigned int getUsableCores()
 
     return nCores;
 }
-}
+}

src/util/gids.cpp

@@ -32,4 +32,4 @@ unsigned int generateGid()
         return intHash + counter.fetch_add(1);
     }
 }
-}
+}

src/util/logging.cpp

@@ -39,4 +39,4 @@ std::shared_ptr<spdlog::logger> getLogger()
 
     return logger;
 }
-}
+}

src/util/random.cpp

@@ -43,4 +43,4 @@ std::string randomStringFromSet(const std::unordered_set<std::string>& s)
 
     return *it;
 }
-}
+}

src/util/timing.cpp

@@ -52,4 +52,4 @@ void nanosToTimespec(uint64_t nanos, struct timespec* nativeTimespec)
     nativeTimespec->tv_sec = nanos / 1000000000;
     nativeTimespec->tv_nsec = nanos % 1000000000;
 }
-}
+}

tests/test/endpoint/test_handler.cpp

@@ -145,4 +145,4 @@ TEST_CASE("Check getting function status from endpoint", "[endpoint]")
 
     REQUIRE(actual == expectedOutput);
 }
-}
+}

tests/test/main.cpp

@@ -13,4 +13,4 @@ int main(int argc, char* argv[])
     fflush(stdout);
 
     return result;
-}
+}