AsyncNotifiableBlock.cxx

Go to the documentation of this file.

 
#ifndef _DEFAULT_SOURCE
#define _DEFAULT_SOURCE
#endif
 
#include "AsyncNotifiableBlock.hxx"
 
#include "os/sleep.h"
 
AsyncNotifiableBlock::~AsyncNotifiableBlock()
{
    // Recollects all notifiable instances, including waiting as long as needed
    // if there are some that have not finished yet.
    for (unsigned i = 0; i < count_; ++i)
    {
        while (true)
        {
            QMember *m = next().item;
            if (!m)
            {
                LOG(VERBOSE,
                    "shutdown async notifiable block: waiting for returns");
                microsleep(100);
            }
            else
            {
                HASSERT(initialize(m)->abort_if_almost_done());
                break;
            }
        }
    }
}