Code formatting.

Author: Alexandr-Konovalov

sycl/source/detail/queue_impl.cpp

@@ -286,10 +286,10 @@ event queue_impl::memcpyFromDeviceGlobal(
 sycl::detail::optional<event> queue_impl::getLastEvent() {
   // The external event is required to finish last if set, so it is considered
   // the last event if present.
-  if (std::optional<event> ExternalEvent =
-          MInOrderExternalEvent.read([](std::optional<event> &InOrderExternalEvent) {
-        return InOrderExternalEvent;
-      }))
+  if (std::optional<event> ExternalEvent = MInOrderExternalEvent.read(
+          [](std::optional<event> &InOrderExternalEvent) {
+            return InOrderExternalEvent;
+          }))
     return ExternalEvent;
 
   std::lock_guard<std::mutex> Lock{MMutex};
@@ -618,11 +618,12 @@ void queue_impl::wait(const detail::code_location &CodeLoc) {
     WeakEvents.swap(MEventsWeak);
     SharedEvents.swap(MEventsShared);
 
-    MMissedCleanupRequests.get([this](MissedCleanupRequestsType &MissedCleanupRequests){
-      for (auto &UpdatedGraph : MissedCleanupRequests)
-        doUnenqueuedCommandCleanup(UpdatedGraph);
-      MissedCleanupRequests.clear();
-    });
+    MMissedCleanupRequests.get(
+        [this](MissedCleanupRequestsType &MissedCleanupRequests){
+          for (auto &UpdatedGraph : MissedCleanupRequests)
+            doUnenqueuedCommandCleanup(UpdatedGraph);
+          MissedCleanupRequests.clear();
+        });
   }
   // If the queue is either a host one or does not support OOO (and we use
   // multiple in-order queues as a result of that), wait for each event
@@ -798,9 +799,10 @@ void queue_impl::revisitUnenqueuedCommandsState(
   if (Lock.owns_lock())
     doUnenqueuedCommandCleanup(CompletedHostTask->getCommandGraph());
   else {
-    MMissedCleanupRequests.put([CompletedHostTask](MissedCleanupRequestsType &MissedCleanupRequests){
-      MissedCleanupRequests.push_back(CompletedHostTask->getCommandGraph());
-    });
+    MMissedCleanupRequests.put(
+        [CompletedHostTask](MissedCleanupRequestsType &MissedCleanupRequests){
+          MissedCleanupRequests.push_back(CompletedHostTask->getCommandGraph());
+        });
   }
 }
 

sycl/source/detail/queue_impl.hpp

@@ -710,17 +710,19 @@ class queue_impl {
   void *getTraceEvent() { return MTraceEvent; }
 
   void setExternalEvent(const event &Event) {
-    MInOrderExternalEvent.put([&Event](std::optional<event> &InOrderExternalEvent){
-      InOrderExternalEvent = Event;
-    });
+    MInOrderExternalEvent.put(
+        [&Event](std::optional<event> &InOrderExternalEvent){
+          InOrderExternalEvent = Event;
+        });
   }
 
   std::optional<event> popExternalEvent() {
     std::optional<event> Result = std::nullopt;
 
-    MInOrderExternalEvent.get([&Result](std::optional<event> &InOrderExternalEvent) {
-      std::swap(Result, InOrderExternalEvent);
-    });
+    MInOrderExternalEvent.get(
+        [&Result](std::optional<event> &InOrderExternalEvent) {
+          std::swap(Result, InOrderExternalEvent);
+        });
     return Result;
   }
 
@@ -836,11 +838,12 @@ class queue_impl {
     // dependency so in the case where some commands were not enqueued
     // (blocked), we track them to prevent barrier from being enqueued
     // earlier.
-    MMissedCleanupRequests.get([this](MissedCleanupRequestsType &MissedCleanupRequests){
-      for (auto &UpdatedGraph : MissedCleanupRequests)
-        doUnenqueuedCommandCleanup(UpdatedGraph);
-      MissedCleanupRequests.clear();
-    });
+    MMissedCleanupRequests.get(
+        [this](MissedCleanupRequestsType &MissedCleanupRequests){
+          for (auto &UpdatedGraph : MissedCleanupRequests)
+            doUnenqueuedCommandCleanup(UpdatedGraph);
+          MissedCleanupRequests.clear();
+        });
     auto &Deps = MGraph.expired() ? MDefaultGraphDeps : MExtGraphDeps;
     if (Type == CGType::Barrier && !Deps.UnenqueuedCmdEvents.empty()) {
       Handler.depends_on(Deps.UnenqueuedCmdEvents);
@@ -1025,20 +1028,18 @@ class queue_impl {
   } MDefaultGraphDeps, MExtGraphDeps;
 
   // implement check-lock-check pattern to not lock empty MData
-  template <typename DataType>
-  class CheckLockCheck {
+  template <typename DataType> class CheckLockCheck {
     DataType MData;
     std::atomic_bool MDataPresent = false;
     mutable std::mutex MDataMtx;
+
   public:
-    template <typename F>
-    void put(F &&func) {
+    template <typename F> void put(F &&func) {
       std::lock_guard<std::mutex> Lock(MDataMtx);
       MDataPresent.store(true, std::memory_order_release);
       func(MData);
     }
-    template <typename F>
-    void get(F &&func) {
+    template <typename F> void get(F &&func) {
       if (MDataPresent.load(std::memory_order_acquire)) {
         std::lock_guard<std::mutex> Lock(MDataMtx);
         if (MDataPresent.load(std::memory_order_acquire)) {
@@ -1047,8 +1048,7 @@ class queue_impl {
         }
       }
     }
-    template <typename F>
-    DataType read(F &&func) {
+    template <typename F> DataType read(F &&func) {
       if (!MDataPresent.load(std::memory_order_acquire))
         return DataType{};
       std::lock_guard<std::mutex> Lock(MDataMtx);
@@ -1101,8 +1101,8 @@ class queue_impl {
   unsigned long long MQueueID;
   static std::atomic<unsigned long long> MNextAvailableQueueID;
 
-  using MissedCleanupRequestsType =
-    std::deque<std::shared_ptr<ext::oneapi::experimental::detail::graph_impl>>;
+  using MissedCleanupRequestsType = std::deque<
+      std::shared_ptr<ext::oneapi::experimental::detail::graph_impl>>;
   CheckLockCheck<MissedCleanupRequestsType> MMissedCleanupRequests;
 
   friend class sycl::ext::oneapi::experimental::detail::node_impl;