pmaint.h

chord 源码 http://pdos.csail.mit.edu/chord/

#ifndef __PMAINT_H__
#define __PMAINT_H__

#include <chord.h>
#include <chord_prot.h>

#include <dhash_common.h>
#include <dhash.h>
#include <dhashcli.h>
#include <ihash.h>
#include <location.h>

#include <libadb.h>

class pmaint {

public:
  pmaint (dhashcli *cli, ptr<vnode> host_node, ptr<dhblock_srv> srv);

  void start ();
  void stop ();

  enum { PRTTMTINY = 1, PRTTMSHORT = 10, PRTTMLONG = 60, MAX_PENDING = 20};
  enum { PMAINT_HANDOFF_ERROR = 0, PMAINT_HANDOFF_NOTPRESENT = 1, 
	 PMAINT_HANDOFF_PRESENT = -1};


private:

  //helpers from parent class
  dhashcli *cli;
  ptr<vnode> host_node;
  ptr<dhblock_srv> srv;

  //state
  bool pmaint_searching;
  bigint pmaint_next_key;

  timecb_t *active_cb;

  void pmaint_next ();
  void pmaint_lookup (chordID key, dhash_stat err, 
		      vec<chord_node> sl, route r);
  void pmaint_offer (bigint key, chord_node succ);
  void pmaint_offer_cb (chord_node dst, bigint key, ref<dhash_offer_res> res, 
			clnt_stat err);
  void pmaint_handoff (chord_node dst, bigint key, cbi cb);
  void pmaint_handoff_cb (bigint key, cbi cb, dhash_stat err, bool present);
  void handed_off_cb (bigint key, int status);
  void pmaint_gotkey (adb_status stat, vec<chordID> keys, vec<u_int32_t>);
};

#endif