minor fix

Author: Binyang2014

include/mscclpp/core.hpp

@@ -381,10 +381,10 @@ struct EndpointConfig {
   /// These settings are only used when the transport is an InfiniBand type (IB0-IB7); they are ignored for other
   /// transports.
   struct Ib {
-    static const int DefaultMaxCqSize = 1024;
-    static const int DefaultMaxCqPollNum = 1;
-    static const int DefaultMaxSendWr = 8192;
-    static const int DefaultMaxWrPerSend = 64;
+    static constexpr int DefaultMaxCqSize = 1024;
+    static constexpr int DefaultMaxCqPollNum = 1;
+    static constexpr int DefaultMaxSendWr = 8192;
+    static constexpr int DefaultMaxWrPerSend = 64;
 
     /// Maximum size of the completion queue.
     int maxCqSize;

python/csrc/algorithm.cpp

@@ -48,8 +48,8 @@ void register_algorithm(nb::module_& m) {
           .def(
               "execute",
               [](Algorithm& self, std::shared_ptr<Communicator> comm, uintptr_t input, uintptr_t output,
-                 size_t inputSize, size_t outputSize, DataType dtype, uintptr_t stream, std::shared_ptr<Executor> executor,
-                 std::unordered_map<std::string, uintptr_t> extras) {
+                 size_t inputSize, size_t outputSize, DataType dtype, uintptr_t stream,
+                 std::shared_ptr<Executor> executor, std::unordered_map<std::string, uintptr_t> extras) {
                 return self.execute(comm, reinterpret_cast<const void*>(input), reinterpret_cast<void*>(output),
                                     inputSize, outputSize, dtype, reinterpret_cast<cudaStream_t>(stream), executor,
                                     extras);

src/unix_socket.cc

@@ -229,6 +229,7 @@ void UnixSocketServer::mainLoop(int listenUnixSockFd) {
           std::lock_guard<std::mutex> lock(mutex_);
           auto it = fdSet_.find(fd);
           if (it == fdSet_.end()) {
+            WARN("Requested fd %d not found, size of fdSet_ is %zu", fd, fdSet_.size());
             throw Error("Requested fd not found: " + std::to_string(fd), ErrorCode::InvalidUsage);
           }
           fdToSend = *it;