/usr/include/wvstreams/uniretrygen.h is in libwvstreams-dev 4.6.1-12~deb9u1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 | /* -*- 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 wv::function<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
|