mirror of
https://github.com/Xahau/xahaud.git
synced 2025-12-06 17:27:52 +00:00
Remove Journal from most Stoppable overrides
This commit is contained in:
@@ -65,47 +65,47 @@ void Stoppable::stopped ()
|
|||||||
m_stoppedEvent.signal();
|
m_stoppedEvent.signal();
|
||||||
}
|
}
|
||||||
|
|
||||||
void Stoppable::onPrepare (Journal journal)
|
void Stoppable::onPrepare ()
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
void Stoppable::onStart (Journal journal)
|
void Stoppable::onStart ()
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
void Stoppable::onStop (Journal journal)
|
void Stoppable::onStop ()
|
||||||
{
|
{
|
||||||
stopped();
|
stopped();
|
||||||
}
|
}
|
||||||
|
|
||||||
void Stoppable::onChildrenStopped (Journal journal)
|
void Stoppable::onChildrenStopped ()
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
//------------------------------------------------------------------------------
|
//------------------------------------------------------------------------------
|
||||||
|
|
||||||
void Stoppable::prepareRecursive (Journal journal)
|
void Stoppable::prepareRecursive ()
|
||||||
{
|
{
|
||||||
onPrepare (journal);
|
|
||||||
for (Children::const_iterator iter (m_children.cbegin ());
|
for (Children::const_iterator iter (m_children.cbegin ());
|
||||||
iter != m_children.cend(); ++iter)
|
iter != m_children.cend(); ++iter)
|
||||||
iter->stoppable->prepareRecursive (journal);
|
iter->stoppable->prepareRecursive ();
|
||||||
|
onPrepare ();
|
||||||
}
|
}
|
||||||
|
|
||||||
void Stoppable::startRecursive (Journal journal)
|
void Stoppable::startRecursive ()
|
||||||
{
|
{
|
||||||
onStart (journal);
|
onStart ();
|
||||||
for (Children::const_iterator iter (m_children.cbegin ());
|
for (Children::const_iterator iter (m_children.cbegin ());
|
||||||
iter != m_children.cend(); ++iter)
|
iter != m_children.cend(); ++iter)
|
||||||
iter->stoppable->startRecursive (journal);
|
iter->stoppable->startRecursive ();
|
||||||
}
|
}
|
||||||
|
|
||||||
void Stoppable::stopAsyncRecursive (Journal journal)
|
void Stoppable::stopAsyncRecursive ()
|
||||||
{
|
{
|
||||||
onStop (journal);
|
onStop ();
|
||||||
for (Children::const_iterator iter (m_children.cbegin ());
|
for (Children::const_iterator iter (m_children.cbegin ());
|
||||||
iter != m_children.cend(); ++iter)
|
iter != m_children.cend(); ++iter)
|
||||||
iter->stoppable->stopAsyncRecursive (journal);
|
iter->stoppable->stopAsyncRecursive ();
|
||||||
}
|
}
|
||||||
|
|
||||||
void Stoppable::stopRecursive (Journal journal)
|
void Stoppable::stopRecursive (Journal journal)
|
||||||
@@ -120,7 +120,7 @@ void Stoppable::stopRecursive (Journal journal)
|
|||||||
//
|
//
|
||||||
memoryBarrier ();
|
memoryBarrier ();
|
||||||
m_childrenStopped = true;
|
m_childrenStopped = true;
|
||||||
onChildrenStopped (journal);
|
onChildrenStopped ();
|
||||||
|
|
||||||
// Now block on this Stoppable.
|
// Now block on this Stoppable.
|
||||||
//
|
//
|
||||||
@@ -151,30 +151,24 @@ bool RootStoppable::isStopping() const
|
|||||||
return m_calledStopAsync.get() != 0;
|
return m_calledStopAsync.get() != 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
void RootStoppable::prepare (Journal journal)
|
void RootStoppable::prepare ()
|
||||||
{
|
{
|
||||||
if (! m_prepared.compareAndSetBool (1, 0))
|
if (! m_prepared.compareAndSetBool (1, 0))
|
||||||
{
|
|
||||||
journal.warning << "Stoppable::prepare called again";
|
|
||||||
return;
|
return;
|
||||||
}
|
|
||||||
|
|
||||||
prepareRecursive (journal);
|
prepareRecursive ();
|
||||||
}
|
}
|
||||||
|
|
||||||
void RootStoppable::start (Journal journal)
|
void RootStoppable::start ()
|
||||||
{
|
{
|
||||||
// Courtesy call to prepare.
|
// Courtesy call to prepare.
|
||||||
if (m_prepared.compareAndSetBool (1, 0))
|
if (m_prepared.compareAndSetBool (1, 0))
|
||||||
prepareRecursive (journal);
|
prepareRecursive ();
|
||||||
|
|
||||||
if (! m_started.compareAndSetBool (1, 0))
|
if (! m_started.compareAndSetBool (1, 0))
|
||||||
{
|
|
||||||
journal.warning << "Stoppable::start called again";
|
|
||||||
return;
|
return;
|
||||||
}
|
|
||||||
|
|
||||||
startRecursive (journal);
|
startRecursive ();
|
||||||
}
|
}
|
||||||
|
|
||||||
void RootStoppable::stop (Journal journal)
|
void RootStoppable::stop (Journal journal)
|
||||||
@@ -185,14 +179,14 @@ void RootStoppable::stop (Journal journal)
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
stopAsync (journal);
|
stopAsync ();
|
||||||
stopRecursive (journal);
|
stopRecursive (journal);
|
||||||
}
|
}
|
||||||
|
|
||||||
void RootStoppable::stopAsync (Journal journal)
|
void RootStoppable::stopAsync ()
|
||||||
{
|
{
|
||||||
if (! m_calledStopAsync.compareAndSetBool (1, 0))
|
if (! m_calledStopAsync.compareAndSetBool (1, 0))
|
||||||
return;
|
return;
|
||||||
|
|
||||||
stopAsyncRecursive (journal);
|
stopAsyncRecursive ();
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -185,10 +185,10 @@ public:
|
|||||||
The default implementation does nothing.
|
The default implementation does nothing.
|
||||||
Guaranteed to only be called once.
|
Guaranteed to only be called once.
|
||||||
*/
|
*/
|
||||||
virtual void onPrepare (Journal journal);
|
virtual void onPrepare ();
|
||||||
|
|
||||||
/** Override called during start. */
|
/** Override called during start. */
|
||||||
virtual void onStart (Journal journal);
|
virtual void onStart ();
|
||||||
|
|
||||||
/** Override called when the stop notification is issued.
|
/** Override called when the stop notification is issued.
|
||||||
|
|
||||||
@@ -211,7 +211,7 @@ public:
|
|||||||
Guaranteed only to be called once.
|
Guaranteed only to be called once.
|
||||||
Must be safe to call from any thread at any time.
|
Must be safe to call from any thread at any time.
|
||||||
*/
|
*/
|
||||||
virtual void onStop (Journal journal);
|
virtual void onStop ();
|
||||||
|
|
||||||
/** Override called when all children have stopped.
|
/** Override called when all children have stopped.
|
||||||
|
|
||||||
@@ -231,7 +231,7 @@ public:
|
|||||||
Guaranteed only to be called once.
|
Guaranteed only to be called once.
|
||||||
Must be safe to call from any thread at any time.
|
Must be safe to call from any thread at any time.
|
||||||
*/
|
*/
|
||||||
virtual void onChildrenStopped (Journal journal);
|
virtual void onChildrenStopped ();
|
||||||
|
|
||||||
private:
|
private:
|
||||||
friend class RootStoppable;
|
friend class RootStoppable;
|
||||||
@@ -248,9 +248,9 @@ private:
|
|||||||
Stoppable* stoppable;
|
Stoppable* stoppable;
|
||||||
};
|
};
|
||||||
|
|
||||||
void prepareRecursive (Journal journal);
|
void prepareRecursive ();
|
||||||
void startRecursive (Journal journal);
|
void startRecursive ();
|
||||||
void stopAsyncRecursive (Journal journal);
|
void stopAsyncRecursive ();
|
||||||
void stopRecursive (Journal journal);
|
void stopRecursive (Journal journal);
|
||||||
|
|
||||||
protected:
|
protected:
|
||||||
@@ -280,7 +280,7 @@ public:
|
|||||||
Thread safety:
|
Thread safety:
|
||||||
May be called from any thread.
|
May be called from any thread.
|
||||||
*/
|
*/
|
||||||
void prepare (Journal journal = Journal());
|
void prepare ();
|
||||||
|
|
||||||
/** Start all contained Stoppable objects.
|
/** Start all contained Stoppable objects.
|
||||||
The default implementation does nothing.
|
The default implementation does nothing.
|
||||||
@@ -288,7 +288,7 @@ public:
|
|||||||
Thread safety:
|
Thread safety:
|
||||||
May be called from any thread.
|
May be called from any thread.
|
||||||
*/
|
*/
|
||||||
void start (Journal journal = Journal());
|
void start ();
|
||||||
|
|
||||||
/** Notify a root stoppable and children to stop, and block until stopped.
|
/** Notify a root stoppable and children to stop, and block until stopped.
|
||||||
Has no effect if the stoppable was already notified.
|
Has no effect if the stoppable was already notified.
|
||||||
@@ -304,7 +304,7 @@ public:
|
|||||||
Thread safety:
|
Thread safety:
|
||||||
Safe to call from any thread at any time.
|
Safe to call from any thread at any time.
|
||||||
*/
|
*/
|
||||||
void stopAsync (Journal journal = Journal());
|
void stopAsync ();
|
||||||
|
|
||||||
private:
|
private:
|
||||||
Atomic <int> m_prepared;
|
Atomic <int> m_prepared;
|
||||||
|
|||||||
Reference in New Issue
Block a user