Fix code lint

Author: niehao100

attn.log

@@ -133,7 +133,8 @@ class AFTensorWorker {
     req.event = GetEvent();
     req.event->Record();
 
-    PS_VLOG(3) << "ts" << start_ts << " pushpull_queue_ push "  << pushpull_queue_.Size();
+    PS_VLOG(3) << "ts" << start_ts << " pushpull_queue_ push "
+               << pushpull_queue_.Size();
     pushpull_queue_.Push(std::move(req));
 
     // std::unique_lock<std::mutex> timestamp_lock(timestamp_mu_);
@@ -217,7 +218,8 @@ class AFTensorWorker {
       }
       ZBatchPushPull_(req.push, req.push_timestamps, req.pull,
                       req.pull_timestamps);
-      PS_VLOG(4) << "pushpull_queue_ Loop done " << req.push_timestamps[0] << " " << req.pull_timestamps[0];
+      PS_VLOG(4) << "pushpull_queue_ Loop done " << req.push_timestamps[0]
+                 << " " << req.pull_timestamps[0];
     }
     PS_LOG(INFO) << "Stop PushPullWorker" << gpu_;
   }
@@ -235,7 +237,8 @@ class AFTensorWorker {
     msg.meta.timestamp = ts;
     msg.meta.addr = reinterpret_cast<uint64_t>(tensor.data_ptr());
     msg.meta.val_len = tensor.numel() * tensor.itemsize();
-    PS_VLOG(2) << "ZPush_ addr: 0x" << std::hex << msg.meta.addr << std::dec << " val_len: " << msg.meta.val_len;
+    PS_VLOG(2) << "ZPush_ addr: 0x" << std::hex << msg.meta.addr << std::dec
+               << " val_len: " << msg.meta.val_len;
     msg.meta.key = keys[0];
     msg.meta.is_tensor = 1;
     msg.meta.dtype = static_cast<int>(tensor.scalar_type());

ffn.log

@@ -384,7 +384,7 @@ struct Message {
       meta.dst_dev_id = val.dst_device_id_;
     }
   }
-  
+
   std::string DebugString() const {
     std::stringstream ss;
     ss << meta.DebugString();

include/ps/af_tensor_app.h

@@ -9,10 +9,11 @@
 #include <mutex>
 #include <queue>
 #include <utility>
+
+#include "dmlc/logging.h"
 #include "ps/base.h"
 #include "ps/internal/env.h"
 #include "ps/internal/spsc_queue.h"
-#include "dmlc/logging.h"
 
 namespace ps {
 
@@ -34,7 +35,7 @@ class ThreadsafeQueue {
    * \brief push an value into the end. threadsafe.
    * \param new_value the value
    */
-  inline void Push(T new_value, bool print_log=false) {
+  inline void Push(T new_value, bool print_log = false) {
     if (lockless_) {
       // PushLockless(std::move(new_value));
       PushAtomic(std::move(new_value), print_log);

include/ps/internal/message.h

@@ -6,6 +6,7 @@
 #define PS_INTERNAL_UTILS_H_
 
 #include <ctype.h>
+#include <execinfo.h>
 #include <pthread.h>
 #include <sched.h>
 #include <stdio.h>
@@ -19,7 +20,6 @@
 
 #include "dmlc/logging.h"
 #include "ps/internal/env.h"
-#include <execinfo.h>
 
 namespace ps {
 
@@ -125,13 +125,12 @@ static inline uint64_t GetNanosecond(bool return_zero = true) {
 
 static int PS_VERBOSE = ps::GetEnv("PS_VERBOSE", 0);
 
-
 /**
  * @brief Rename Thread
- * 
+ *
  */
 
-static inline void RenameThread(const std::string& name) {
+static inline void RenameThread(const std::string &name) {
   pthread_setname_np(pthread_self(), name.c_str());
 }
 
@@ -141,7 +140,6 @@ static inline void RenameThread(const std::string& name) {
  * \param core_count is the number of cores the thread need.
  */
 static inline void BindCpuCore(int offset, int core_count = 1) {
-
   RenameThread("StepMesh: BindCpuCore");
   int gpu = -1;
   Environment::Get()->find("STEPMESH_GPU", &gpu, gpu);

include/ps/internal/threadsafe_queue.h

@@ -208,7 +208,9 @@ class KVWorker : public SimpleApp {
    *
    * \param timestamp the timestamp returned by the push or pull
    */
-  void Wait(int timestamp, uint64_t timeout_ms = 10000) { obj_->WaitRequest(timestamp, timeout_ms); }
+  void Wait(int timestamp, uint64_t timeout_ms = 10000) {
+    obj_->WaitRequest(timestamp, timeout_ms);
+  }
 
   /**
    * \brief zero-copy Push

include/ps/internal/utils.h

@@ -49,8 +49,7 @@ class SArray {
   SArray() {}
 
   /** \brief empty deconstrcutor */
-  ~SArray() {
-  }
+  ~SArray() {}
 
   /**
    * \brief Create an array with length n with initialized value
@@ -216,7 +215,8 @@ class SArray {
   template <typename Deleter>
   void reset(V* data, size_t size, Deleter del,
              DeviceType src_device_type = CPU, int src_device_id = 0,
-             DeviceType dst_device_type = CPU, int dst_device_id = 0 , bool force = false) {
+             DeviceType dst_device_type = CPU, int dst_device_id = 0,
+             bool force = false) {
     size_ = size;
     capacity_ = size;
 
@@ -229,16 +229,15 @@ class SArray {
 
   /**
    * @brief force reset the data pointer
-   * 
-   * @param data 
-   * @param size 
-   * @param src_device_type 
-   * @param src_device_id 
-   * @param dst_device_type 
-   * @param dst_device_id 
+   *
+   * @param data
+   * @param size
+   * @param src_device_type
+   * @param src_device_id
+   * @param dst_device_type
+   * @param dst_device_id
    */
   void force_reset(SArray<V>& arr) {
-
     this->ptr_ = arr.ptr_;
     this->size_ = arr.size_;
     this->capacity_ = arr.capacity_;

include/ps/kv_app.h

@@ -60,8 +60,10 @@ void Customer::WaitRequest(int timestamp, uint64_t timeout_ms) {
     } else {
       uint64_t now = GetNanosecond(false);
       // 1s for timeout
-      if(now - req->start_time > timeout_ns) {
-        PS_LOG(FATAL) << "request timeout " << timeout_ms << "ms, handler " << timestamp << " " << (now - req->start_time)/1000 << "us";
+      if (now - req->start_time > timeout_ns) {
+        PS_LOG(FATAL) << "request timeout " << timeout_ms << "ms, handler "
+                      << timestamp << " " << (now - req->start_time) / 1000
+                      << "us";
       }
       // _mm_pause();
     }
@@ -116,7 +118,8 @@ void Customer::DirectProcess(Message& recv) {
     t->request = recv.meta.request_trace;
     t->response = recv.meta.response_trace;
 #endif  // STEPMESH_ENABLE_TRACE
-    PS_VLOG(4) << "recv response " << recv.meta.timestamp << " " << recv.meta.DebugString();
+    PS_VLOG(4) << "recv response " << recv.meta.timestamp << " "
+               << recv.meta.DebugString();
     t->response_count.fetch_add(1, std::memory_order_release);
   }
 }

include/ps/sarray.h

@@ -476,10 +476,11 @@ class RDMATransport : public Transport {
       resp->origin_addr = req->origin_addr;
       resp->idx = addrpool.StoreAddress(buf_ctx);
 
-      PS_VLOG(2) << "GDR Server Reply: meta_addr=" << std::hex << resp->meta_addr
-                 << ", meta_rkey=" << std::hex << resp->meta_rkey
-                 << ", data_addr=" << std::hex << resp->data_addr
-                 << ", data_rkey=" << std::hex << resp->data_rkey;
+      PS_VLOG(2) << "GDR Server Reply: meta_addr=" << std::hex
+                 << resp->meta_addr << ", meta_rkey=" << std::hex
+                 << resp->meta_rkey << ", data_addr=" << std::hex
+                 << resp->data_addr << ", data_rkey=" << std::hex
+                 << resp->data_rkey;
 
       // Send the reply
       struct ibv_sge sge;
@@ -664,7 +665,9 @@ class RDMATransport : public Transport {
     auto data_raddr = msg.meta.addr;
     auto data_rkey = msg.meta.option;
     auto data_len = msg.meta.val_len;
-    PS_CHECK_EQ((size_t)msg.meta.val_len, msg_buf->data[1].size()) << "val len" << (size_t)msg.meta.val_len << " data len " << msg_buf->data[1].size();
+    PS_CHECK_EQ((size_t)msg.meta.val_len, msg_buf->data[1].size())
+        << "val len" << (size_t)msg.meta.val_len << " data len "
+        << msg_buf->data[1].size();
 
     struct ibv_sge data_sge;
     data_sge.addr = reinterpret_cast<uint64_t>(msg_buf->data[1].data());
@@ -924,7 +927,8 @@ class IPCTransport : public RDMATransport {
 
   void SendPullResponse(Message &msg, MessageBuffer *msg_buf,
                         RemoteTuple remote_tuple, size_t lkey) {
-    auto addr = reinterpret_cast<void *>(PS_CHECK_NOTNULL(msg_buf->data[1].data()));
+    auto addr =
+        reinterpret_cast<void *>(PS_CHECK_NOTNULL(msg_buf->data[1].data()));
     void *shm_addr =
         PS_CHECK_NOTNULL(GetSharedMemory(shm_prefix_, msg.meta.key));