libp2p · EduMenges · Mar 14, 2026
diff --git a/example/01-echo/libp2p_echo_client.cpp b/example/01-echo/libp2p_echo_client.cpp
@@ -68,7 +68,7 @@ int main(int argc, char *argv[]) {
           // Additional logging config for application
           logger_config));
   auto r = logging_system->configure();
-  if (not r.message.empty()) {
+  if (!r.message.empty()) {
     (r.has_error ? std::cerr : std::cout) << r.message << std::endl;
   }
   if (r.has_error) {

diff --git a/example/01-echo/libp2p_echo_server.cpp b/example/01-echo/libp2p_echo_server.cpp
@@ -90,7 +90,7 @@ int main(int argc, char **argv) {
           // Additional logging config for application
           logger_config));
   auto r = logging_system->configure();
-  if (not r.message.empty()) {
+  if (!r.message.empty()) {
     (r.has_error ? std::cerr : std::cout) << r.message << std::endl;
   }
   if (r.has_error) {

diff --git a/example/02-kademlia/rendezvous_chat.cpp b/example/02-kademlia/rendezvous_chat.cpp
@@ -49,7 +49,7 @@ class Session : public std::enable_shared_from_this<Session> {
     stream_->readSome(
         *incoming_,
         [self = shared_from_this()](outcome::result<size_t> result) {
-          if (not result) {
+          if (!result) {
             self->close();
             std::cout << self->stream_->remotePeerId().value().toBase58()
                       << " - closed at reading" << std::endl;
@@ -74,7 +74,7 @@ class Session : public std::enable_shared_from_this<Session> {
         stream_,
         *buffer,
         [self = shared_from_this(), buffer](outcome::result<void> result) {
-          if (not result) {
+          if (!result) {
             self->close();
             std::cout << self->stream_->remotePeerId().value().toBase58()
                       << " - closed at writting" << std::endl;
@@ -128,7 +128,7 @@ void handleIncomingStream(libp2p::StreamAndProtocol stream_and_protocol) {
 }
 
 void handleOutgoingStream(libp2p::StreamAndProtocolOrError stream_res) {
-  if (not stream_res) {
+  if (!stream_res) {
     fmt::println(
         std::cerr, " ! outgoing connection failed: {}", stream_res.error());
     return;
@@ -178,7 +178,7 @@ int main(int argc, char *argv[]) {
           // Additional logging config for application
           logger_config));
   auto r = logging_system->configure();
-  if (not r.message.empty()) {
+  if (!r.message.empty()) {
     (r.has_error ? std::cerr : std::cout) << r.message << std::endl;
   }
   if (r.has_error) {
@@ -295,7 +295,7 @@ int main(int argc, char *argv[]) {
             scheduler.schedule(std::function{find_providers},
                                kademlia_config.randomWalk.interval);
 
-            if (not res) {
+            if (!res) {
               fmt::println(std::cerr, "Cannot find providers: {}", res.error());
               return;
             }
@@ -317,7 +317,7 @@ int main(int argc, char *argv[]) {
 
     post(*io, [&] {
       auto listen = host->listen(ma);
-      if (not listen) {
+      if (!listen) {
         fmt::println(std::cerr,
                      "Cannot listen address {}. Error: {}",
                      ma.getStringAddress(),

diff --git a/example/03-gossip/gossip_chat_example.cpp b/example/03-gossip/gossip_chat_example.cpp
@@ -67,7 +67,7 @@ int main(int argc, char *argv[]) {
           // Additional logging config for application
           logger_config));
   auto r = logging_system->configure();
-  if (not r.message.empty()) {
+  if (!r.message.empty()) {
     (r.has_error ? std::cerr : std::cout) << r.message << std::endl;
   }
   if (r.has_error) {

diff --git a/example/04-dnstxt/ares_resolver.cpp b/example/04-dnstxt/ares_resolver.cpp
@@ -38,7 +38,7 @@ int main(int argc, char *argv[]) {
           // Additional logging config for application
           logger_config));
   auto r = logging_system->configure();
-  if (not r.message.empty()) {
+  if (!r.message.empty()) {
     (r.has_error ? std::cerr : std::cout) << r.message << std::endl;
   }
   if (r.has_error) {

diff --git a/include/libp2p/basic/read.hpp b/include/libp2p/basic/read.hpp
@@ -36,7 +36,7 @@ namespace libp2p {
           }
           // read remaining bytes
           auto reader = weak.lock();
-          if (not reader) {
+          if (!reader) {
             return cb(make_error_code(boost::asio::error::operation_aborted));
           }
           read(reader, out.subspan(n), std::move(cb));

diff --git a/include/libp2p/basic/write.hpp b/include/libp2p/basic/write.hpp
@@ -36,7 +36,7 @@ namespace libp2p {
           }
           // write remaining bytes
           auto writer = weak.lock();
-          if (not writer) {
+          if (!writer) {
             return cb(make_error_code(boost::asio::error::operation_aborted));
           }
           write(writer, in.subspan(n), std::move(cb));

diff --git a/include/libp2p/common/outcome_macro.hpp b/include/libp2p/common/outcome_macro.hpp
@@ -11,7 +11,7 @@
 #define _IF_ERROR_CB_RETURN(tmp, r) \
   ({                                \
     auto &&_r = r;                  \
-    if (not _r.has_value()) {       \
+    if (!_r.has_value()) {       \
       return cb(_r.error());        \
     }                               \
     _r.value();                     \

diff --git a/include/libp2p/injector/network_injector.hpp b/include/libp2p/injector/network_injector.hpp
@@ -160,7 +160,7 @@ namespace libp2p::injector {
    */
   inline auto useWssPem(std::string_view pem) {
     layer::WssCertificate cert;
-    if (not pem.empty()) {
+    if (!pem.empty()) {
       if (auto cert_res = layer::WssCertificate::make(pem)) {
         cert = std::move(cert_res.value());
       } else {

diff --git a/include/libp2p/transport/tcp/tcp_util.hpp b/include/libp2p/transport/tcp/tcp_util.hpp
@@ -128,7 +128,7 @@ namespace libp2p::transport::detail {
     auto v = ma.getProtocolsWithValues();
     auto it = v.begin();
     OUTCOME_TRY(addr, readTcpOrUdp(it, v.end()));
-    if (not addr.udp) {
+    if (!addr.udp) {
       return std::errc::protocol_not_supported;
     }
     if (it == v.end()) {
@@ -185,7 +185,7 @@ namespace libp2p::transport::detail {
       const boost::asio::ip::tcp::endpoint &endpoint,
       const ProtoAddrVec &layers) {
     OUTCOME_TRY(s, toMultiaddr(endpoint));
-    if (not layers.empty()) {
+    if (!layers.empty()) {
       auto &protocol = layers.at(0).first.code;
       if (protocol == P::WS) {
         s += "/ws";

diff --git a/src/basic/scheduler/scheduler_impl.cpp b/src/basic/scheduler/scheduler_impl.cpp
@@ -20,19 +20,19 @@ namespace libp2p::basic {
       Callback &&cb,
       std::chrono::milliseconds delay_from_now,
       bool make_handle) {
-    if (not cb) {
+    if (!cb) {
       throw std::logic_error{"SchedulerImpl::scheduleImpl empty cb arg"};
     }
 
     auto abs = Time::zero();
     if (Time::zero() < delay_from_now) {
       abs = backend_->now() + delay_from_now;
     }
-    if (not make_handle) {
+    if (!make_handle) {
       backend_->post(
           [weak_self{weak_from_this()}, cb{std::move(cb)}, abs]() mutable {
             auto self = weak_self.lock();
-            if (not self) {
+            if (!self) {
               return;
             }
             self->callbacks_.emplace(abs, std::move(cb));
@@ -45,7 +45,7 @@ namespace libp2p::basic {
     backend_->post(
         [weak_self{weak_from_this()}, abs, cancel{std::move(cancel)}] {
           auto self = weak_self.lock();
-          if (not self) {
+          if (!self) {
             return;
           }
           if (cancel->cancelled.test()) {
@@ -57,26 +57,26 @@ namespace libp2p::basic {
     return cancelFn(
         [weak_self{weak_from_this()}, weak_cancel{std::move(weak_cancel)}] {
           auto cancel = weak_cancel.lock();
-          if (not cancel) {
+          if (!cancel) {
             return;
           }
           if (cancel->cancelled.test_and_set()) {
             return;
           }
           auto self = weak_self.lock();
-          if (not self) {
+          if (!self) {
             return;
           }
           self->backend_->post([weak_self, weak_cancel] {
             auto cancel = weak_cancel.lock();
-            if (not cancel) {
+            if (!cancel) {
               return;
             }
-            if (not cancel->it) {
+            if (!cancel->it) {
               return;
             }
             auto self = weak_self.lock();
-            if (not self) {
+            if (!self) {
               return;
             }
             self->callbacks_.erase(*cancel->it);

diff --git a/src/connection/loopback_stream.cpp b/src/connection/loopback_stream.cpp
@@ -19,7 +19,7 @@ namespace libp2p::connection {
       boost::asio::post(
           ctx,
           [wptr{std::move(wptr)}, cb{std::move(cb)}, arg{std::move(arg)}]() {
-            if (not wptr.expired()) {
+            if (!wptr.expired()) {
               cb(arg);
             }
           });
@@ -154,7 +154,7 @@ namespace libp2p::connection {
     }
 
     // subscribe to new data updates
-    if (not data_notifyee_) {
+    if (!data_notifyee_) {
       data_notifyee_ = std::move(read_lambda);
     }
   }

diff --git a/src/crypto/hmac_provider/hmac_provider_ctr_impl.cpp b/src/crypto/hmac_provider/hmac_provider_ctr_impl.cpp
@@ -52,7 +52,7 @@ namespace libp2p::crypto::hmac {
   }
 
   outcome::result<void> HmacProviderCtrImpl::write(BytesIn data) {
-    if (not initialized_) {
+    if (!initialized_) {
       return HmacProviderError::FAILED_INITIALIZE_CONTEXT;
     }
     if (1 != HMAC_Update(hmac_ctx_, data.data(), data.size())) {
@@ -62,7 +62,7 @@ namespace libp2p::crypto::hmac {
   }
 
   outcome::result<void> HmacProviderCtrImpl::digestOut(BytesOut out) const {
-    if (not initialized_) {
+    if (!initialized_) {
       return HmacProviderError::FAILED_INITIALIZE_CONTEXT;
     }
     if (out.size() != digestSize()) {

diff --git a/src/crypto/sha/sha1.cpp b/src/crypto/sha/sha1.cpp
@@ -19,7 +19,7 @@ namespace libp2p::crypto {
   }
 
   outcome::result<void> Sha1::write(BytesIn data) {
-    if (not initialized_) {
+    if (!initialized_) {
       return HmacProviderError::FAILED_INITIALIZE_CONTEXT;
     }
     if (1 != SHA1_Update(&ctx_, data.data(), data.size())) {
@@ -29,7 +29,7 @@ namespace libp2p::crypto {
   }
 
   outcome::result<void> Sha1::digestOut(BytesOut out) const {
-    if (not initialized_) {
+    if (!initialized_) {
       return HmacProviderError::FAILED_INITIALIZE_CONTEXT;
     }
     if (out.size() != digestSize()) {

diff --git a/src/crypto/sha/sha256.cpp b/src/crypto/sha/sha256.cpp
@@ -21,7 +21,7 @@ namespace libp2p::crypto {
   }
 
   outcome::result<void> Sha256::write(BytesIn data) {
-    if (not initialized_) {
+    if (!initialized_) {
       return HmacProviderError::FAILED_INITIALIZE_CONTEXT;
     }
     if (1 != SHA256_Update(&ctx_, data.data(), data.size())) {
@@ -31,7 +31,7 @@ namespace libp2p::crypto {
   }
 
   outcome::result<void> Sha256::digestOut(BytesOut out) const {
-    if (not initialized_) {
+    if (!initialized_) {
       return HmacProviderError::FAILED_INITIALIZE_CONTEXT;
     }
     if (out.size() != digestSize()) {

diff --git a/src/crypto/sha/sha512.cpp b/src/crypto/sha/sha512.cpp
@@ -21,7 +21,7 @@ namespace libp2p::crypto {
   }
 
   outcome::result<void> Sha512::write(BytesIn data) {
-    if (not initialized_) {
+    if (!initialized_) {
       return HmacProviderError::FAILED_INITIALIZE_CONTEXT;
     }
     if (1 != SHA512_Update(&ctx_, data.data(), data.size())) {
@@ -31,7 +31,7 @@ namespace libp2p::crypto {
   }
 
   outcome::result<void> Sha512::digestOut(BytesOut out) const {
-    if (not initialized_) {
+    if (!initialized_) {
       return HmacProviderError::FAILED_INITIALIZE_CONTEXT;
     }
     if (out.size() != digestSize()) {

diff --git a/src/host/basic_host/basic_host.cpp b/src/host/basic_host/basic_host.cpp
@@ -72,7 +72,7 @@ namespace libp2p::host {
           }
         }
       }
-      if (not is_good_addr) {
+      if (!is_good_addr) {
         i = unique_addresses.erase(i);
       } else {
         ++i;

diff --git a/src/layer/websocket/ws_connection.cpp b/src/layer/websocket/ws_connection.cpp
@@ -39,7 +39,7 @@ namespace libp2p::connection {
   }
 
   void WsConnection::stop() {
-    if (not started_) {
+    if (!started_) {
       log_->error("already stopped (double stop)");
       return;
     }

diff --git a/src/layer/websocket/wss_adaptor.cpp b/src/layer/websocket/wss_adaptor.cpp
@@ -43,7 +43,7 @@ namespace libp2p::layer {
   void WssAdaptor::upgradeInbound(
       std::shared_ptr<connection::LayerConnection> conn,
       LayerAdaptor::LayerConnCallbackFunc cb) const {
-    if (not server_certificate_.context) {
+    if (!server_certificate_.context) {
       return cb(std::errc::address_family_not_supported);
     }
     auto ssl = std::make_shared<connection::SslConnection>(

diff --git a/src/multi/converters/converter_utils.cpp b/src/multi/converters/converter_utils.cpp
@@ -191,7 +191,7 @@ namespace libp2p::multi::converters {
     };
     auto uvar = [&]() -> outcome::result<uint64_t> {
       auto var = UVarint::create(bytes);
-      if (not var) {
+      if (!var) {
         return ConversionError::INVALID_ADDRESS;
       }
       bytes = bytes.subspan(var->size());

diff --git a/src/multi/multiaddress.cpp b/src/multi/multiaddress.cpp
@@ -107,7 +107,7 @@ namespace libp2p::multi {
     }
 
     std::string proto_str = '/' + std::string(p->name);
-    if (not address.empty()) {
+    if (!address.empty()) {
       proto_str += '/';
       proto_str += address;
     }

diff --git a/src/muxer/mplex/mplex_stream.cpp b/src/muxer/mplex/mplex_stream.cpp
@@ -120,7 +120,7 @@ namespace libp2p::connection {
           std::lock_guard<std::mutex> lock(self->write_queue_mutex_);
           // check if new write messages were received while stream was writing
           // and propagate these messages
-          if (not self->write_queue_.empty()) {
+          if (!self->write_queue_.empty()) {
             auto [in, cb] = self->write_queue_.front();
             self->write_queue_.pop_front();
             self->writeSome(in, cb);

diff --git a/src/muxer/yamux/yamuxed_connection.cpp b/src/muxer/yamux/yamuxed_connection.cpp
@@ -660,7 +660,7 @@ namespace libp2p::connection {
 
     is_writing_ = false;
 
-    if (not write_queue_.empty()) {
+    if (!write_queue_.empty()) {
       auto next_packet = std::move(write_queue_.front());
       write_queue_.pop_front();
       doWrite(std::move(next_packet));
@@ -723,10 +723,10 @@ namespace libp2p::connection {
     cleanup_handle_ = scheduler_->scheduleWithHandle(
         [weak_self{weak_from_this()}] {
           auto self = weak_self.lock();
-          if (not self) {
+          if (!self) {
             return;
           }
-          if (not self->started_) {
+          if (!self->started_) {
             return;
           }
           std::vector<StreamId> abandoned;
@@ -751,14 +751,14 @@ namespace libp2p::connection {
     ping_handle_ = scheduler_->scheduleWithHandle(
         [weak_self{weak_from_this()}] {
           auto self = weak_self.lock();
-          if (not self) {
+          if (!self) {
             return;
           }
-          if (not self->started_) {
+          if (!self->started_) {
             return;
           }
           // dont send pings if something is being written
-          if (not self->is_writing_) {
+          if (!self->is_writing_) {
             self->enqueue(pingOutMsg(++self->ping_counter_));
             SL_TRACE(log(), "written ping message #{}", self->ping_counter_);
           }