http://www.ousob.com --- Legacy Redefined OuSob - File: /wwwroot/clipx/usr/include/wvstreams/uniretrygen.h

/* -*- Mode: C++ -*- * Worldvisions Weaver Software: * Copyright (C) 2002 Net Integration Technologies, Inc. * * A UniConfGen that reconnects to an inner generator whenever the inner * generator is no longer OK. */ #ifndef __UNIRETRYGEN_H #define __UNIRETRYGEN_H #include "unifiltergen.h" #include "wvtimeutils.h" #include "wvlog.h" /** * A UniConfGen that reconnects to an inner generator specified by * a moniker whenever the inner generator is no longer OK. It will * try to periodically recreate the inner generator until the resulting * object returns isok() true. * * The UniRetryGen's moniker takes either of the forms retry:<inner moniker> * or retry:{<inner moniker> <retry timeout>}; in the second form the retry * timeout is specified in milliseconds. If not specified, the retry timout * is 5000ms. Specifically this means that whenever the retry generator is * does not have a good inner generator and at least 5000ms have passed * since the disconnect or last reconnect attempt, reconnection will be * attempted again. * * The connection is created through the underlying * backend's moniker and destroyed by delete. * * If UniRetryGen's constructor is used directly, a callback of type * UniRetryGen::ReconnectCallback can be specified, which will be called * whenever the UniRetryGen reconnects to the underlying moniker. This allows * for any necessary resynchronisation, such as a call to refresh(). * * UniRetryGen can be used in combination with UniReplicateGen to create * a connection to a UniConf daemon that is robust against network * failures through a moniker such as replicate:{retry:tcp:192.168.0.1 tmp:} */ class UniRetryGen : public UniFilterGen { public: typedef WvCallback<void, UniRetryGen &> ReconnectCallback; private: WvLog log; WvString moniker; ReconnectCallback reconnect_callback; time_t retry_interval_ms; WvTime next_reconnect_attempt; void maybe_disconnect(); void maybe_reconnect(); public: UniRetryGen(WvStringParm _moniker, ReconnectCallback _reconect_callback = ReconnectCallback(), time_t _retry_internal_ms = 5000); /***** Overridden methods *****/ virtual void commit(); virtual bool refresh(); virtual void prefetch(const UniConfKey &key, bool recursive); virtual void flush_buffers() { } virtual WvString get(const UniConfKey &key); virtual void set(const UniConfKey &key, WvStringParm value); virtual bool exists(const UniConfKey &key); virtual bool haschildren(const UniConfKey &key); virtual bool isok(); virtual Iter *iterator(const UniConfKey &key); virtual Iter *recursiveiterator(const UniConfKey &key); }; #endif //__UNIRETRYGEN_H