debian/libwvstreams-dev/usr/include/wvstreams/wvstreamsdaemon.h

/* -*- Mode: C++ -*-
 * Worldvisions Tunnel Vision Software:
 *   Copyright (C) 1997-2002 Net Integration Technologies, Inc.
 *
 * High-level abstraction for creating daemon processes that do
 * nothing but listen on a list of WvStreams and add connections
 * to the global list.
 */
#ifndef __WVSTREAMSDAEMON_H
#define __WVSTREAMSDAEMON_H
 
#include "wvdaemon.h"
#include "iwvstream.h"
#include "wvistreamlist.h"

class WvStreamsDaemon : public WvDaemon
{
private:
 
    WvDaemonCallback callback;
 
    bool do_full_close;
    WvIStreamList streams;
 
    void init(WvDaemonCallback cb);
 
protected:
 
    virtual void do_start();
    virtual void do_run();
    virtual void do_stop();
 
private:
 
    void restart_close_cb(IWvStream *s, const char *id);
    void die_close_cb(IWvStream *s, const char *id);
 
public:

    WvStreamsDaemon(WvStringParm name,
            WvStringParm version,
            WvDaemonCallback cb) :
        WvDaemon(name, version, WvDaemonCallback(),
                WvDaemonCallback(), WvDaemonCallback())
    {
        init(cb);
    }

    void add_stream(IWvStream *istream,
                    bool auto_free, const char *id);
    void add_restart_stream(IWvStream *istream,
                            bool auto_free, const char *id);
    void add_die_stream(IWvStream *istream,
                        bool auto_free, const char *id);

    void close_existing_connections_on_restart()
    {
        do_full_close = true;
    }

    void setcallback(WvDaemonCallback cb);
 
private:
    void add_stream(IWvStream *istream, bool auto_free, WvString id);
    void add_restart_stream(IWvStream *istream, bool auto_free, WvString id);
    void add_die_stream(IWvStream *istream, bool auto_free, WvString id);
public:
    const char *wstype() const { return "WvStreamsDaemon"; }
};
#endif // __WVSTREAMSDAEMON_H