formatting

Author: Tianyi Chen

src/common/init.cpp

@@ -83,7 +83,7 @@ void PelotonInit::Initialize() {
   // initialize the catalog and add the default database, so we don't do this on
   // the first query
   pg_catalog->CreateDatabase(DEFAULT_DB_NAME, txn);
-  
+
   txn_manager.CommitTransaction(txn);
 
   // Initialize the Statement Cache Manager

src/include/executor/plan_executor.h

@@ -55,13 +55,13 @@ class PlanExecutor {
    * Before ExecutePlan, a node first receives value list, so we should
    * pass value list directly rather than passing Postgres's ParamListInfo
    */
-  static void ExecutePlan(std::shared_ptr<planner::AbstractPlan> plan,
-                          concurrency::TransactionContext *txn,
-                          const std::vector<type::Value> &params,
-                          const std::vector<int> &result_format,
-                          std::function<void(executor::ExecutionResult,
-                                             std::vector<ResultValue> &&)>
-                              on_complete);
+  static void ExecutePlan(
+      std::shared_ptr<planner::AbstractPlan> plan,
+      concurrency::TransactionContext *txn,
+      const std::vector<type::Value> &params,
+      const std::vector<int> &result_format,
+      std::function<void(executor::ExecutionResult,
+                         std::vector<ResultValue> &&)> on_complete);
 
   /*
    * @brief When a peloton node recvs a query plan, this function is invoked

src/traffic_cop/traffic_cop.cpp

@@ -204,8 +204,7 @@ executor::ExecutionResult TrafficCop::ExecuteHelper(
 }
 
 void TrafficCop::ExecuteStatementPlanGetResult() {
-  if (p_status_.m_result == ResultType::FAILURE)
-    return;
+  if (p_status_.m_result == ResultType::FAILURE) return;
 
   auto txn_result = GetCurrentTxnState().first->GetResult();
   if (single_statement_txn_ || txn_result == ResultType::FAILURE) {
@@ -363,8 +362,8 @@ void TrafficCop::ProcessInvalidStatement() {
 }
 
 bool TrafficCop::BindParamsForCachePlan(
-    const std::vector<std::unique_ptr<expression::AbstractExpression>>
-        &parameters,
+    const std::vector<std::unique_ptr<expression::AbstractExpression>> &
+        parameters,
     const size_t thread_id UNUSED_ATTRIBUTE) {
   if (tcop_txn_state_.empty()) {
     single_statement_txn_ = true;

test/network/exception_test.cpp

@@ -35,10 +35,10 @@ class ExceptionTests : public PelotonTest {};
 
 void *ExecutorExceptionTest(int port) {
   try {
-    pqxx::connection C(
-        StringUtil::Format("host=127.0.0.1 port=%d user=default_database "
-                           "sslmode=disable application_name=psql",
-                           port));
+    pqxx::connection C(StringUtil::Format(
+        "host=127.0.0.1 port=%d user=default_database "
+        "sslmode=disable application_name=psql",
+        port));
     int exception_count = 0, total = 2;
     pqxx::work txn1(C);
     try {
@@ -84,10 +84,10 @@ void *ExecutorExceptionTest(int port) {
 void *ParserExceptionTest(int port) {
   try {
     // forcing the factory to generate psql protocol handler
-    pqxx::connection C(
-        StringUtil::Format("host=127.0.0.1 port=%d user=default_database "
-                           "sslmode=disable application_name=psql",
-                           port));
+    pqxx::connection C(StringUtil::Format(
+        "host=127.0.0.1 port=%d user=default_database "
+        "sslmode=disable application_name=psql",
+        port));
 
     peloton::network::ConnectionHandle *conn =
         peloton::network::ConnectionHandleFactory::GetInstance()
@@ -243,7 +243,6 @@ TEST_F(ExceptionTests, ExceptionTest) {
   ParserExceptionTest(port);
   ExecutorExceptionTest(port);
 
-
   server.Close();
   serverThread.join();
   LOG_INFO("Peloton is shutting down");