@@ -710,17 +710,17 @@ class queue_impl {
710710 void *getTraceEvent () { return MTraceEvent; }
711711
712712 void setExternalEvent (const event &Event) {
713- MInOrderExternalEvent.put (
714- [&Event ](std::optional<event> &InOrderExternalEvent) {
713+ MInOrderExternalEvent.push (
714+ [&](std::optional<event> &InOrderExternalEvent) {
715715 InOrderExternalEvent = Event;
716716 });
717717 }
718718
719719 std::optional<event> popExternalEvent () {
720720 std::optional<event> Result = std::nullopt ;
721721
722- MInOrderExternalEvent.get (
723- [&Result ](std::optional<event> &InOrderExternalEvent) {
722+ MInOrderExternalEvent.pop (
723+ [&](std::optional<event> &InOrderExternalEvent) {
724724 std::swap (Result, InOrderExternalEvent);
725725 });
726726 return Result;
@@ -838,8 +838,8 @@ class queue_impl {
838838 // dependency so in the case where some commands were not enqueued
839839 // (blocked), we track them to prevent barrier from being enqueued
840840 // earlier.
841- MMissedCleanupRequests.get (
842- [this ](MissedCleanupRequestsType &MissedCleanupRequests) {
841+ MMissedCleanupRequests.pop (
842+ [& ](MissedCleanupRequestsType &MissedCleanupRequests) {
843843 for (auto &UpdatedGraph : MissedCleanupRequests)
844844 doUnenqueuedCommandCleanup (UpdatedGraph);
845845 MissedCleanupRequests.clear ();
@@ -853,14 +853,13 @@ class queue_impl {
853853 Handler.depends_on (Deps.LastBarrier );
854854
855855 auto EventRet = Handler.finalize ();
856- EventImplPtr EventRetImpl = getSyclObjImpl (EventRet);
857856 if (Type == CGType::CodeplayHostTask)
858- Deps.UnenqueuedCmdEvents .push_back (std::move (EventRetImpl ));
857+ Deps.UnenqueuedCmdEvents .push_back (getSyclObjImpl (EventRet ));
859858 else if (Type == CGType::Barrier || Type == CGType::BarrierWaitlist) {
860- Deps.LastBarrier = std::move (EventRetImpl );
859+ Deps.LastBarrier = getSyclObjImpl (EventRet );
861860 Deps.UnenqueuedCmdEvents .clear ();
862- } else if (!EventRetImpl ->isEnqueued ()) {
863- Deps.UnenqueuedCmdEvents .push_back (std::move (EventRetImpl ));
861+ } else if (!getSyclObjImpl (EventRet) ->isEnqueued ()) {
862+ Deps.UnenqueuedCmdEvents .push_back (getSyclObjImpl (EventRet ));
864863 }
865864
866865 return EventRet;
@@ -1034,12 +1033,12 @@ class queue_impl {
10341033 mutable std::mutex MDataMtx;
10351034
10361035 public:
1037- template <typename F> void put (F &&func) {
1036+ template <typename F> void push (F &&func) {
10381037 std::lock_guard<std::mutex> Lock (MDataMtx);
10391038 MDataPresent.store (true , std::memory_order_release);
10401039 func (MData);
10411040 }
1042- template <typename F> void get (F &&func) {
1041+ template <typename F> void pop (F &&func) {
10431042 if (MDataPresent.load (std::memory_order_acquire)) {
10441043 std::lock_guard<std::mutex> Lock (MDataMtx);
10451044 if (MDataPresent.load (std::memory_order_acquire)) {
0 commit comments