---

IguanaNetProducer.h

Go to the documentation of this file.

#ifndef ANALYZER_IGUANA_NET_PRODUCER_H
# define ANALYZER_IGUANA_NET_PRODUCER_H

//<<<<<< INCLUDES                                                       >>>>>>

# include "Iguana/Framework/interface/IgNet.h"
# include "classlib/utils/DebugAids.h"
# include "classlib/utils/TimeInfo.h"
# include "classlib/utils/Signal.h"
# include "classlib/utils/Time.h"
# include <cstdlib>
# include <cstring>
# include <iostream>
# include <signal.h>
# include <unistd.h>

static sig_atomic_t s_stop = 0;

class IguanaNetProducer : public IgNet
{
public:
    IguanaNetProducer (bool verbose, int port)
        : IgNet("iguana-source")
        {
            logme() << "INFO: serving data at port " << port << '\n';
            debug(verbose);
            startLocalServer(port);
        }

    virtual bool
    shouldStop(void)
        {
            return s_stop > 0;
        }
};

static void
onInterrupt(int /* sig */)
{
    s_stop++;
}

static char
onAssertFail(const char *message)
{
    std::cout.flush();
    fflush(stdout);
    std::cerr.flush();
    fflush(stderr);
    std::cerr << message << "ABORTING\n";
    return 'a';
}

#endif // ANALYZER_IGUANA_NET_PRODUCER_H

---