client.h

#ifndef _DHT_CLIENT_H_
#define _DHT_CLIENT_H_

#include "common.h"
#include "key.h"
#include "value.h"
#include "name_value_map.h"
#include "notify_handler.h"
#include "search_handler.h"
#include "event_observer_notifier.h"

namespace dht {
    class client {
        event_observer_notifier *_obs_notifier;
    protected:
        inline event_observer_notifier *observer_notifier() {
            return _obs_notifier;
        }
        
    public:
        enum {
            disconnected = 1,
            connecting,
            connected,
            disconnecting,
        };
        
        client();
        virtual ~client();

        virtual int in_state() const;
        virtual const char *in_state_str() const;
        virtual const char *state_str(int state) const;
        
        virtual void init(const dht::name_value_map &opts) = 0;

        virtual void observer_attach(dht::event_observer *h,
                                     int event_mask);
        virtual void observer_remove(dht::event_observer *h);
        virtual void observer_remove(dht::event_observer *h, int event_mask);
        
        virtual void connect(dht::notify_handler  *handler = NULL) = 0;

        virtual void disconnect(dht::notify_handler *handler = NULL) = 0;

        virtual void find(const dht::key      &fkey,
                          dht::search_handler *handler) = 0;

        virtual void store(const dht::key      &skey,
                           const dht::value    &svalue,
                           dht::notify_handler *handler = NULL) = 0;

        virtual const addr_inet_type &external_addr() = 0;

        virtual int process(time_value_type &max_wait) = 0;

        virtual int process(time_value_type *max_wait = NULL) = 0;
        
        virtual reactor_type *reactor() = 0;

        virtual void          reactor(reactor_type *reactor) = 0;
        
        
        virtual int handler_cancel(dht::notify_handler *handler) = 0;
        
    };
}

#endif //_DHT_CLIENT_H_

---