casa6

#include "AsynchronousInterface.h"

#include "VLAT.h"

​

#include <stdcasa/thread/AsynchronousTools.h>

#include <stdcasa/UtilJ.h>

#include <casacore/casa/System/AipsrcValue.h>

#include <msvis/MSVis/VisBufferAsync.h>

#include <msvis/MSVis/VisibilityIteratorImplAsync.h>

​

#include <ostream>

#include <utility>

​

using namespace casacore;

using namespace casa::async;

using namespace casacore;

using namespace casa::utilj;

using namespace std;

​

#define Log(level, ...) \

        {if (AsynchronousInterface::logThis (level)) \

    Logger::get()->log (__VA_ARGS__);};

​

using casa::async::Mutex;

​

using namespace casacore;

namespace casa {

​

namespace asyncio {

​

Bool AsynchronousInterface::loggingInitialized_p = false;

Int AsynchronousInterface::logLevel_p = -1;

​

AsynchronousInterface::AsynchronousInterface (int maxNBuffers)

: lookaheadTerminationRequested_p (false),

  sweepTerminationRequested_p (false),

  viResetComplete_p (false),

  viResetRequested_p (false),

  vlaData_p (maxNBuffers, mutex_p),

  vlat_p (NULL),

  writeQueue_p ()

{}

​

AsynchronousInterface::~AsynchronousInterface ()

{}

​

void

AsynchronousInterface::addModifier (RoviaModifier * modifier)

{

    Log (1, "AsynchronousInterface::addModifier: {%s}\n", string(*modifier).c_str());

​

    LockGuard lg (mutex_p);

​

    roviaModifiers_p.add (modifier);

}

​

async::Mutex &

AsynchronousInterface::getMutex () const

{

    return mutex_p;

}

​

VlaData *

AsynchronousInterface::getVlaData ()